Some misc changes (#1107)

- ticker.Stop always
- clean up timer func (if they are added) on participant close
- sequencer test enhancement to add a real packet after a pdding packet
This commit is contained in:
Raja Subramanian
2022-10-20 11:11:45 +05:30
committed by GitHub
parent 20cbb02360
commit 4344af6fd3
4 changed files with 9 additions and 3 deletions

View File

@@ -329,6 +329,7 @@ func getNAT1to1IPsForConf(conf *config.Config) ([]string, error) {
var firstResloved bool
natMapping := make(map[string]string)
timeout := time.NewTimer(5 * time.Second)
defer timeout.Stop()
done:
for {

View File

@@ -524,6 +524,9 @@ func (p *ParticipantImpl) Close(sendLeave bool, reason types.ParticipantCloseRea
return nil
}
p.clearDisconnectTimer()
p.clearMigrationTimer()
// send leave message
if sendLeave {
_ = p.writeMessage(&livekit.SignalResponse{

View File

@@ -420,6 +420,8 @@ func (s *RedisStore) UpdateEgress(_ context.Context, info *livekit.EgressInfo) e
// Deletes egress info 24h after the egress has ended
func (s *RedisStore) egressWorker() {
ticker := time.NewTicker(time.Minute * 30)
defer ticker.Stop()
for {
select {
case <-s.done:

View File

@@ -71,14 +71,14 @@ func Test_sequencer_getNACKSeqNo(t *testing.T) {
{
name: "Should get correct seq numbers",
fields: fields{
input: []uint16{2, 3, 4, 7, 8},
input: []uint16{2, 3, 4, 7, 8, 11},
padding: []uint16{9, 10},
offset: 5,
},
args: args{
seqNo: []uint16{4 + 5, 5 + 5, 8 + 5, 9 + 5, 10 + 5},
seqNo: []uint16{4 + 5, 5 + 5, 8 + 5, 9 + 5, 10 + 5, 11 + 5},
},
want: []uint16{4, 8},
want: []uint16{4, 8, 11},
},
}
for _, tt := range tests {