diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go index 11a9d71b..37460f07 100644 --- a/rtmp/rtmp.go +++ b/rtmp/rtmp.go @@ -250,17 +250,21 @@ func handlePacket(s *Session, pkt *packet) error { switch pkt.packetType { case packetTypeChunkSize: s.inChunkSize = amf.DecodeInt32(pkt.body[:4]) + s.log(DebugLevel, pkg+"set inChunkSize", "size", int(s.inChunkSize)) case packetTypeBytesReadReport: - s.serverBW = amf.DecodeInt32(pkt.body[:4]) + s.log(DebugLevel, pkg+"received packetTypeBytesReadReport") case packetTypeServerBW: s.serverBW = amf.DecodeInt32(pkt.body[:4]) + s.log(DebugLevel, pkg+"set serverBW", "size", int(s.serverBW)) case packetTypeClientBW: s.clientBW = amf.DecodeInt32(pkt.body[:4]) + s.log(DebugLevel, pkg+"set clientBW", "size", int(s.clientBW)) if pkt.bodySize > 4 { s.clientBW2 = pkt.body[4] + s.log(DebugLevel, pkg+"set clientBW2", "size", int(s.clientBW2)) } else { s.clientBW2 = 0xff }