dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-28 07:14:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

log seq and destination identities

Browse Source
This commit is contained in:
boks1971
2025-11-08 08:26:38 +05:30
parent 266c7cded2
commit 3a44635f13
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/participant.go
+12 -1
View File
@@ -2571,7 +2571,14 @@ func (p *ParticipantImpl) handleReceivedDataMessage(kind livekit.DataPacket_Kind
overrideSenderIdentity = true
}
}
p.params.Logger.Infow("STREAM_DBG: received StreamHeader", "streamID", payload.StreamHeader.GetStreamId(), "topic", payload.StreamHeader.GetTopic(), "mimeType", payload.StreamHeader.GetMimeType())
p.params.Logger.Infow(
"STREAM_DBG: received StreamHeader",
"streamID", payload.StreamHeader.GetStreamId(),
"topic", payload.StreamHeader.GetTopic(),
"mimeType", payload.StreamHeader.GetMimeType(),
"seq", dp.GetSequence(),
"destinationIdentities", dp.GetDestinationIdentities(),
)
case *livekit.DataPacket_StreamChunk:
if payload.StreamChunk == nil {
return
@@ -2581,6 +2588,8 @@ func (p *ParticipantImpl) handleReceivedDataMessage(kind livekit.DataPacket_Kind
"streamID", payload.StreamChunk.GetStreamId(),
"chunkIndex", payload.StreamChunk.GetChunkIndex(),
"chunkSize", len(payload.StreamChunk.GetContent()),
"seq", dp.GetSequence(),
"destinationIdentities", dp.GetDestinationIdentities(),
)
case *livekit.DataPacket_StreamTrailer:
if payload.StreamTrailer == nil {
@@ -2591,6 +2600,8 @@ func (p *ParticipantImpl) handleReceivedDataMessage(kind livekit.DataPacket_Kind
"streamID", payload.StreamTrailer.GetStreamId(),
"attributes", payload.StreamTrailer.GetAttributes(),
"reason", payload.StreamTrailer.GetReason(),
"seq", dp.GetSequence(),
"destinationIdentities", dp.GetDestinationIdentities(),
)
case *livekit.DataPacket_EncryptedPacket:
if payload.EncryptedPacket == nil {