Fix the problem of the TCC package being omitted from being sent. (#1492)

Author: penguinol

worker/include/RTC/RTCP/CompoundPacket.hpp

@@ -7,7 +7,7 @@
 #include "RTC/RTCP/SenderReport.hpp"
 #include "RTC/RTCP/XrDelaySinceLastRr.hpp"
 #include "RTC/RTCP/XrReceiverReferenceTime.hpp"
-#include "RTC/RtpPacket.hpp" // MtuSize.
+#include "RTC/RtpPacket.hpp" // MaxPacketSize.
 #include <vector>
 
 namespace RTC
@@ -16,16 +16,6 @@ namespace RTC
 	{
 		class CompoundPacket
 		{
-		public:
-			// Maximum size for a CompundPacket.
-			// * IPv4|Ipv6 header size: 20|40 bytes. IPv6 considered.
-			// * UDP|TCP header size:   8|20  bytes. TCP considered.
-			// * SRTP Encryption: 148 bytes.
-			//    SRTP_MAX_TRAILER_LEN+4 is the maximum number of octects that will be
-			//    added to an RTCP packet by srtp_protect_rtcp().
-			//    srtp.h: SRTP_MAX_TRAILER_LEN (SRTP_MAX_TAG_LEN + SRTP_MAX_MKI_LEN)
-			constexpr static size_t MaxSize{ RTC::MtuSize - 40u - 20u - 148u };
-
 		public:
 			CompoundPacket() = default;
 

worker/include/RTC/RtpPacket.hpp

@@ -18,6 +18,14 @@ namespace RTC
 {
 	// Max MTU size.
 	constexpr size_t MtuSize{ 1500u };
+	// Maximum size for a CompundPacket.
+	// * IPv4|Ipv6 header size: 20|40 bytes. IPv6 considered.
+	// * UDP|TCP header size:   8|20  bytes. TCP considered.
+	// * SRTP Encryption: 148 bytes.
+	//    SRTP_MAX_TRAILER_LEN+4 is the maximum number of octects that will be
+	//    added to an RTCP packet by srtp_protect_rtcp().
+	//    srtp.h: SRTP_MAX_TRAILER_LEN (SRTP_MAX_TAG_LEN + SRTP_MAX_MKI_LEN)
+	constexpr size_t MaxPacketSize{ RTC::MtuSize - 40 - 20 - 148u };
 	// MID header extension max length (just used when setting/updating MID
 	// extension).
 	constexpr uint8_t MidMaxLength{ 8u };

worker/src/RTC/RTCP/CompoundPacket.cpp

@@ -101,7 +101,7 @@ namespace RTC
 			}
 
 			// New items can hold in the packet, report it.
-			if (GetSize() <= MaxSize)
+			if (GetSize() <= RTC::MaxPacketSize)
 			{
 				return true;
 			}
@@ -160,7 +160,7 @@ namespace RTC
 			}
 
 			// New items can hold in the packet, report it.
-			if (GetSize() <= MaxSize)
+			if (GetSize() <= RTC::MaxPacketSize)
 			{
 				return true;
 			}
@@ -206,7 +206,7 @@ namespace RTC
 			}
 
 			// New items can hold in the packet, report it.
-			if (GetSize() <= MaxSize)
+			if (GetSize() <= RTC::MaxPacketSize)
 			{
 				return true;
 			}

worker/src/RTC/RtpStreamRecv.cpp

@@ -191,7 +191,7 @@ namespace RTC
 	RtpStreamRecv::RtpStreamRecv(
 	  RTC::RtpStreamRecv::Listener* listener,
 	  RTC::RtpStream::Params& params,
-	  unsigned int sendNackDelayMs,
+	  uint32_t sendNackDelayMs,
 	  bool useRtpInactivityCheck)
 	  : RTC::RtpStream::RtpStream(listener, params, 10), sendNackDelayMs(sendNackDelayMs),
 	    useRtpInactivityCheck(useRtpInactivityCheck),

worker/src/RTC/RtpStreamSend.cpp

@@ -471,7 +471,7 @@ namespace RTC
 					MS_DEBUG_TAG(
 					  rtx,
 					  "ignoring retransmission for a packet already resent in the last RTT ms "
-					  "[seq:%" PRIu16 ", rtt:%" PRIu32 "]",
+					  "[seq:%" PRIu16 ", rtt:%" PRIu16 "]",
 					  packet->GetSequenceNumber(),
 					  rtt);
 				}

worker/src/RTC/Transport.cpp

@@ -758,8 +758,8 @@ namespace RTC
 
 					if (createTccServer)
 					{
-						this->tccServer =
-						  std::make_shared<RTC::TransportCongestionControlServer>(this, bweType, RTC::MtuSize);
+						this->tccServer = std::make_shared<RTC::TransportCongestionControlServer>(
+						  this, bweType, RTC::MaxPacketSize);
 
 						if (this->maxIncomingBitrate != 0u)
 						{

worker/src/RTC/TransportCongestionControlServer.cpp

@@ -233,14 +233,20 @@ namespace RTC
 
 				case RTC::RTCP::FeedbackRtpTransportPacket::AddPacketResult::MAX_SIZE_EXCEEDED:
 				{
-					// This should not happen.
-					MS_WARN_TAG(rtcp, "transport-cc feedback packet is exceeded");
+					// Send ongoing feedback packet.
+					auto sent = SendTransportCcFeedback();
+
+					if (sent)
+					{
+						++this->transportCcFeedbackPacketCount;
+					}
 
 					// Create a new feedback packet.
-					// NOTE: Do not increment packet count it since the previous ongoing
-					// feedback packet was not sent.
 					ResetTransportCcFeedback(this->transportCcFeedbackPacketCount);
 
+					// Decrease iterator to add current packet again.
+					--it;
+
 					break;
 				}