Method AddOOOPacket

cmd/test-streammanager/metrics.go:61–65

()

}

func (m *Metrics) AddOOOPacket() {
	m.lock.Lock()
	defer m.lock.Unlock()
	m.oooPackets++
}

func (m *Metrics) AddBytes(n int64) {
	m.lock.Lock()