mirror of
https://github.com/livekit/livekit.git
synced 2026-10-23 19:32:41 +00:00
1 parent
1a21dcb4f2
commit
3f9f3adf91
1 file changed
+2
@@ -132,6 +132,7 @@ func (s *sequencer) push(
|
||||
defer s.Unlock()
|
||||
|
||||
if !s.initialized {
|
||||
s.initialized = true
|
||||
s.extHighestSN = extModifiedSN - 1
|
||||
s.extHighestTS = extModifiedTS
|
||||
s.updateSNOffset()
|
||||
@@ -178,6 +179,7 @@ func (s *sequencer) pushPadding(extStartSNInclusive uint64, extEndSNInclusive ui
|
||||
s.Lock()
|
||||
defer s.Unlock()
|
||||
|
||||
s.logger.Debugw("sequencer padding", "extHighestSN", s.extHighestSN, "startSN", extStartSNInclusive, "endSN", extEndSNInclusive)
|
||||
if s.snRangeMap == nil {
|
||||
return
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user