in stats/basic.go [39:60]
func (s *Basic) Register(id string, handlers []string) {
s.mutex.Lock()
defer s.mutex.Unlock()
s.pendingCount++
s.pending[id] = newPendingSend(handlers, s.pendingCount)
// Trim the pending set if necessary
if len(s.pending) > *maxPendingSends {
oldestKey := ""
var oldestOrder int64 = math.MaxInt64
for k, v := range s.pending {
if v.order < oldestOrder {
oldestKey = k
oldestOrder = v.order
}
}
if oldestKey != "" {
glog.Warningf("stats.Basic: too many pending sends; deleting send %v", oldestKey)
delete(s.pending, oldestKey)
}
}
}