change no response sink to info and not return (#1228)

This commit is contained in:
cnderrauber
2022-12-14 11:22:23 +08:00
committed by GitHub
parent da829fcf8e
commit 090c35ddfd
2 changed files with 6 additions and 6 deletions
+3 -5
View File
@@ -180,16 +180,14 @@ func (p *ParticipantImpl) writeMessage(msg *livekit.SignalResponse) error {
sink := p.getResponseSink()
if sink == nil {
err := fmt.Errorf("no response sink")
p.params.Logger.Warnw("could not send message to participant", err,
"message", fmt.Sprintf("%T", msg.Message))
return err
p.params.Logger.Infow("could not send message to participant", "messageType", fmt.Sprintf("%T", msg.Message))
return nil
}
err := sink.WriteMessage(msg)
if err != nil {
p.params.Logger.Warnw("could not send message to participant", err,
"message", fmt.Sprintf("%T", msg.Message))
"messageType", fmt.Sprintf("%T", msg.Message))
return err
}
return nil
+3 -1
View File
@@ -2,6 +2,8 @@ package rtc
import (
"context"
"errors"
"io"
"math"
"sort"
"sync"
@@ -803,7 +805,7 @@ func (r *Room) onDataPacket(source types.LocalParticipant, dp *livekit.DataPacke
}
err := op.SendDataPacket(dp, dpData)
if err != nil {
if err != nil && !errors.Is(err, io.ErrClosedPipe) {
r.Logger.Infow("send data packet error", "error", err, "participant", op.Identity())
}
}