211
}
212
213
>
func (m *monitorImpl) SetSliceCount(readerID int64, count int) {
monitor.go
214
>
m.Lock()
215
>
defer m.Unlock()
216
>
217
>
stats := m.readerStats[readerID]
218
>
m.totalSliceCount = m.totalSliceCount - stats.sliceCount + count
219
>
220
>
stats.sliceCount = count
221
>
m.readerStats[readerID] = stats
222
>
223
>
criticalSliceCount := m.options.SliceCountCriticalThreshold()
224
>
if criticalSliceCount > 0 && m.totalSliceCount > criticalSliceCount {
225
m.sendAlertLocked(&Alert{
226
AlertType: AlertTypeSliceCount,