From 9f29e49da422834428bec8b3ea79e880c54fbc87 Mon Sep 17 00:00:00 2001 From: Benjamin Pracht Date: Mon, 3 Jun 2024 16:34:36 -0700 Subject: [PATCH] Log WHIP user agent and RTP packet if unmarshalling fails --- pkg/whip/relay_whip_track_handler.go | 1 + pkg/whip/server.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/whip/relay_whip_track_handler.go b/pkg/whip/relay_whip_track_handler.go index 5bbe6aa9..3273c199 100644 --- a/pkg/whip/relay_whip_track_handler.go +++ b/pkg/whip/relay_whip_track_handler.go @@ -270,6 +270,7 @@ func (t *RelayWhipTrackHandler) pushRTP(pkt *rtp.Packet) error { buf, err := t.depacketizer.Unmarshal(pkt.Payload) if err != nil { + logger.Warnw("failed unmarshalling RTP payload", err, "pkt", pkt, "payload", pkt.Payload[:min(len(pkt.Payload), 20)]) return err } diff --git a/pkg/whip/server.go b/pkg/whip/server.go index 3a21f132..62cc0b1b 100644 --- a/pkg/whip/server.go +++ b/pkg/whip/server.go @@ -310,7 +310,7 @@ func (s *WHIPServer) handleNewWhipClient(w http.ResponseWriter, r *http.Request, return err } - logger.Debugw("new whip request", "streamKey", streamKey, "sdpOffer", sdpOffer.String()) + logger.Debugw("new whip request", "streamKey", streamKey, "sdpOffer", sdpOffer.String(), "userAgent", r.Header.Get("User-Agent")) resourceId, sdp, err := s.createStream(streamKey, sdpOffer.String()) if err != nil {