Server : Apache/2.4.41 (Ubuntu) System : Linux absol.cf 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory :  /usr/local/lib/node_modules/mediasoup/worker/src/RTC/RTCP/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

#define MS_CLASS "RTC::RTCP::CompoundPacket"
// #define MS_LOG_DEV_LEVEL 3

#include "RTC/RTCP/CompoundPacket.hpp"
#include "Logger.hpp"

namespace RTC
{
	namespace RTCP
	{
		/* Instance methods. */

		void CompoundPacket::Serialize(uint8_t* data)
		{
			MS_TRACE();

			this->header = data;

			// Calculate the total required size for the entire message.
			if (HasSenderReport())
			{
				this->size = this->senderReportPacket.GetSize();

				if (this->receiverReportPacket.GetCount() != 0u)
				{
					this->size += sizeof(ReceiverReport::Header) * this->receiverReportPacket.GetCount();
				}
			}
			// If no sender nor receiver reports are present send an empty Receiver Report
			// packet as the head of the compound packet.
			else
			{
				this->size = this->receiverReportPacket.GetSize();
			}

			if (this->sdesPacket.GetCount() != 0u)
				this->size += this->sdesPacket.GetSize();

			if (this->xrPacket.Begin() != this->xrPacket.End())
				this->size += this->xrPacket.GetSize();

			// Fill it.
			size_t offset{ 0 };

			if (HasSenderReport())
			{
				this->senderReportPacket.Serialize(this->header);
				offset = this->senderReportPacket.GetSize();

				// Fix header count field.
				auto* header = reinterpret_cast<Packet::CommonHeader*>(this->header);

				header->count = 0;

				if (this->receiverReportPacket.GetCount() != 0u)
				{
					// Fix header length field.
					size_t length =
					  ((sizeof(SenderReport::Header) +
					    (sizeof(ReceiverReport::Header) * this->receiverReportPacket.GetCount())) /
					   4);

					header->length = uint16_t{ htons(length) };

					// Fix header count field.
					header->count = this->receiverReportPacket.GetCount();

					auto it = this->receiverReportPacket.Begin();

					for (; it != this->receiverReportPacket.End(); ++it)
					{
						ReceiverReport* report = (*it);

						report->Serialize(this->header + offset);
						offset += sizeof(ReceiverReport::Header);
					}
				}
			}
			else
			{
				this->receiverReportPacket.Serialize(this->header);
				offset = this->receiverReportPacket.GetSize();
			}

			if (this->sdesPacket.GetCount() != 0u)
				offset += this->sdesPacket.Serialize(this->header + offset);

			if (this->xrPacket.Begin() != this->xrPacket.End())
				this->xrPacket.Serialize(this->header + offset);
		}

		void CompoundPacket::Dump()
		{
			MS_TRACE();

			MS_DUMP("<CompoundPacket>");

			if (HasSenderReport())
			{
				this->senderReportPacket.Dump();

				if (this->receiverReportPacket.GetCount() != 0u)
					this->receiverReportPacket.Dump();
			}
			else
			{
				this->receiverReportPacket.Dump();
			}

			if (this->sdesPacket.GetCount() != 0u)
				this->sdesPacket.Dump();

			if (this->xrPacket.Begin() != this->xrPacket.End())
				this->xrPacket.Dump();

			MS_DUMP("</CompoundPacket>");
		}

		void CompoundPacket::AddSenderReport(SenderReport* report)
		{
			MS_TRACE();

			MS_ASSERT(!HasSenderReport(), "a Sender Report is already present");

			this->senderReportPacket.AddReport(report);
		}

		void CompoundPacket::AddReceiverReport(ReceiverReport* report)
		{
			MS_TRACE();

			this->receiverReportPacket.AddReport(report);
		}

		void CompoundPacket::AddSdesChunk(SdesChunk* chunk)
		{
			MS_TRACE();

			this->sdesPacket.AddChunk(chunk);
		}

		void CompoundPacket::AddReceiverReferenceTime(ReceiverReferenceTime* report)
		{
			MS_TRACE();

			this->xrPacket.AddReport(report);
		}
	} // namespace RTCP
} // namespace RTC