mirror of
https://github.com/livekit/livekit.git
synced 2026-06-06 22:01:50 +00:00
fix resume/restart with single node mode (#930)
* fix resume/restart with single node mode * clean comment
This commit is contained in:
@@ -576,12 +576,12 @@ func (p *ParticipantImpl) Start() {
|
||||
}
|
||||
|
||||
func (p *ParticipantImpl) Close(sendLeave bool, reason types.ParticipantCloseReason) error {
|
||||
p.params.Logger.Infow("try close participant", "sendLeave", sendLeave, "reason", reason.String())
|
||||
if p.isClosed.Swap(true) {
|
||||
// already closed
|
||||
return nil
|
||||
}
|
||||
|
||||
p.params.Logger.Infow("closing participant", "sendLeave", sendLeave, "reason", reason.String())
|
||||
// send leave message
|
||||
if sendLeave {
|
||||
_ = p.writeMessage(&livekit.SignalResponse{
|
||||
|
||||
@@ -415,9 +415,6 @@ func (r *RoomManager) getOrCreateRoom(ctx context.Context, roomName livekit.Room
|
||||
// manages an RTC session for a participant, runs on the RTC node
|
||||
func (r *RoomManager) rtcSessionWorker(room *rtc.Room, participant types.LocalParticipant, requestSource routing.MessageSource) {
|
||||
defer func() {
|
||||
// give time for the participant to be closed with a proper reason.
|
||||
// if participant is closed from here, we would be obscuring the real reason the participant is closed.
|
||||
time.Sleep(2 * time.Second)
|
||||
logger.Infow("RTC session finishing",
|
||||
"participant", participant.Identity(),
|
||||
"pID", participant.ID(),
|
||||
|
||||
Reference in New Issue
Block a user