mirror of
https://github.com/livekit/livekit.git
synced 2026-06-02 11:14:11 +00:00
Clear participant version cache on disconnect (#4234)
* debug participant update * more debug * context logger * log participant info * more logging * clear participant cache on disconnect * clean up * clean up
This commit is contained in:
@@ -282,7 +282,7 @@ type ParticipantImpl struct {
|
||||
// queued participant updates before join response is sent
|
||||
// guarded by updateLock
|
||||
queuedUpdates []*livekit.ParticipantInfo
|
||||
// cache of recently sent updates, to ensuring ordering by version
|
||||
// cache of recently sent updates, to ensure ordering by version
|
||||
// guarded by updateLock
|
||||
updateCache *lru.Cache[livekit.ParticipantID, participantUpdateInfo]
|
||||
updateLock utils.Mutex
|
||||
|
||||
@@ -118,6 +118,10 @@ func (p *ParticipantImpl) SendParticipantUpdate(participantsToUpdate []*livekit.
|
||||
})
|
||||
validUpdates = append(validUpdates, pi)
|
||||
}
|
||||
|
||||
if pi.State == livekit.ParticipantInfo_DISCONNECTED {
|
||||
p.updateCache.Remove(pID)
|
||||
}
|
||||
}
|
||||
p.updateLock.Unlock()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user