dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-18 00:25:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Send data (#2270)

Browse Source 
* Avoid dropping data packets on local router

* Remove change not needed for PR
This commit is contained in:
cfbraun
2023-12-02 19:29:43 +01:00
committed by GitHub
parent d866b5110f
commit beecfe3710
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/routing/localrouter.go
-1
View File
@@ -142,7 +142,6 @@ func (r *LocalRouter) WriteNodeRTC(_ context.Context, _ string, msg *livekit.RTC
}
func (r *LocalRouter) writeRTCMessage(sink MessageSink, msg *livekit.RTCNodeMessage) error {
defer sink.Close()
msg.SenderTime = time.Now().Unix()
return sink.WriteMessage(msg)
}
pkg/routing/redisrouter.go
+2
View File
@@ -215,6 +215,7 @@ func (r *RedisRouter) WriteParticipantRTC(_ context.Context, roomName livekit.Ro
rtcSink := NewRTCNodeSink(r.rc, livekit.NodeID(rtcNode), "ephemeral", pkey, pkeyB62)
msg.ParticipantKey = string(ParticipantKeyLegacy(roomName, identity))
msg.ParticipantKeyB62 = string(ParticipantKey(roomName, identity))
defer rtcSink.Close()
return r.writeRTCMessage(rtcSink, msg)
}
@@ -230,6 +231,7 @@ func (r *RedisRouter) WriteRoomRTC(ctx context.Context, roomName livekit.RoomNam
func (r *RedisRouter) WriteNodeRTC(_ context.Context, rtcNodeID string, msg *livekit.RTCNodeMessage) error {
rtcSink := NewRTCNodeSink(r.rc, livekit.NodeID(rtcNodeID), "ephemeral", livekit.ParticipantKey(msg.ParticipantKey), livekit.ParticipantKey(msg.ParticipantKeyB62))
defer rtcSink.Close()
return r.writeRTCMessage(rtcSink, msg)
}