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/include/RTC/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

#ifndef MS_RTC_RTP_PROBATION_PACKET_PACER_HPP
#define MS_RTC_RTP_PROBATION_PACKET_PACER_HPP

#include "common.hpp"
#include "api/transport/network_types.h"
#include "RTC/RtpPacket.hpp"
#include "RTC/RtpProbationGenerator.hpp"
#include "handles/Timer.hpp"
#include <libwebrtc/modules/pacing/packet_router.h>
#include <list>

namespace RTC
{
	class RtpProbationPacketPacer : public Timer::Listener
	{
	public:
		class Listener
		{
		public:
			virtual void OnRtpProbationPacketPacerSendPacket(
			  RTC::RtpPacket* packet, const webrtc::PacedPacketInfo& pacingInfo) = 0;
		};

	public:
		explicit RtpProbationPacketPacer(RTC::RtpProbationPacketPacer::Listener* listener);
		~RtpProbationPacketPacer();

	public:
		void SendPadding(size_t bytes, const webrtc::PacedPacketInfo& pacingInfo);

		/* Pure virtual methods inherited from RTC::Timer. */
	public:
		void OnTimer(Timer* timer) override;

	private:
		// Passed by argument.
		Listener* listener{ nullptr };
		std::list<std::pair<size_t, webrtc::PacedPacketInfo>> paddingInfos;
		RTC::RtpProbationGenerator* probationGenerator{ nullptr };
		Timer* timer{ nullptr };
	};
} // namespace RTC
#endif