From a2d7bb7ff57d032cab925395d4d313c0936dff79 Mon Sep 17 00:00:00 2001 From: dijunkun Date: Mon, 11 Sep 2023 15:23:51 +0800 Subject: [PATCH] Change class name RtpVideoSession to RtpCodec --- src/rtp/{rtp_video_session.cpp => rtp_codec.cpp} | 12 ++++++------ src/rtp/{rtp_video_session.h => rtp_codec.h} | 10 +++++----- src/rtp/rtp_video_receiver.h | 2 +- src/transmission/ice_transmission.cpp | 8 ++++---- src/transmission/ice_transmission.h | 4 ++-- 5 files changed, 18 insertions(+), 18 deletions(-) rename src/rtp/{rtp_video_session.cpp => rtp_codec.cpp} (92%) rename src/rtp/{rtp_video_session.h => rtp_codec.h} (83%) diff --git a/src/rtp/rtp_video_session.cpp b/src/rtp/rtp_codec.cpp similarity index 92% rename from src/rtp/rtp_video_session.cpp rename to src/rtp/rtp_codec.cpp index ba0bdb4..9f58028 100644 --- a/src/rtp/rtp_video_session.cpp +++ b/src/rtp/rtp_codec.cpp @@ -1,4 +1,4 @@ -#include "rtp_video_session.h" +#include "rtp_codec.h" #include @@ -9,14 +9,14 @@ #define FU_A 28 #define FU_B 29 -RtpVideoSession ::RtpVideoSession(PAYLOAD_TYPE payload_type) +RtpCodec ::RtpCodec(PAYLOAD_TYPE payload_type) : version_(RTP_VERSION), has_padding_(false), has_extension_(false), payload_type_(payload_type), sequence_number_(0) {} -RtpVideoSession ::~RtpVideoSession() { +RtpCodec ::~RtpCodec() { if (extension_data_) { delete extension_data_; extension_data_ = nullptr; @@ -28,8 +28,8 @@ RtpVideoSession ::~RtpVideoSession() { // } } -void RtpVideoSession::Encode(uint8_t* buffer, size_t size, - std::vector& packets) { +void RtpCodec::Encode(uint8_t* buffer, size_t size, + std::vector& packets) { // if (!rtp_packet_) { // rtp_packet_ = new RtpPacket(); // } @@ -118,7 +118,7 @@ void RtpVideoSession::Encode(uint8_t* buffer, size_t size, } } -size_t RtpVideoSession::Decode(RtpPacket& packet, uint8_t* payload) { +size_t RtpCodec::Decode(RtpPacket& packet, uint8_t* payload) { // if ((packet.Buffer()[13] >> 6) & 0x01) { // LOG_ERROR("End bit!!!!!!!!!!!!!!!"); // } diff --git a/src/rtp/rtp_video_session.h b/src/rtp/rtp_codec.h similarity index 83% rename from src/rtp/rtp_video_session.h rename to src/rtp/rtp_codec.h index fb318a2..cd4fdec 100644 --- a/src/rtp/rtp_video_session.h +++ b/src/rtp/rtp_codec.h @@ -1,5 +1,5 @@ -#ifndef _RTP_VIDEO_SESSION_H_ -#define _RTP_VIDEO_SESSION_H_ +#ifndef _RTP_CODEC_H_ +#define _RTP_CODEC_H_ #include @@ -7,10 +7,10 @@ #include "rtp_packet.h" -class RtpVideoSession { +class RtpCodec { public: - RtpVideoSession(PAYLOAD_TYPE payload_type); - ~RtpVideoSession(); + RtpCodec(PAYLOAD_TYPE payload_type); + ~RtpCodec(); public: void Encode(uint8_t* buffer, size_t size, std::vector& packets); diff --git a/src/rtp/rtp_video_receiver.h b/src/rtp/rtp_video_receiver.h index 83bf7c7..c80b62e 100644 --- a/src/rtp/rtp_video_receiver.h +++ b/src/rtp/rtp_video_receiver.h @@ -7,7 +7,7 @@ #include "frame.h" #include "ringbuffer.h" -#include "rtp_video_session.h" +#include "rtp_codec.h" #include "thread_base.h" class RtpVideoReceiver : public ThreadBase { diff --git a/src/transmission/ice_transmission.cpp b/src/transmission/ice_transmission.cpp index e6f0b56..84f450e 100644 --- a/src/transmission/ice_transmission.cpp +++ b/src/transmission/ice_transmission.cpp @@ -47,7 +47,7 @@ IceTransmission::~IceTransmission() { } int IceTransmission::InitIceTransmission(std::string &ip, int port) { - rtp_video_session_ = std::make_unique(PAYLOAD_TYPE::H264); + rtp_codec_ = std::make_unique(PAYLOAD_TYPE::H264); rtp_video_receiver_ = std::make_unique(); rtp_video_receiver_->SetOnReceiveCompleteFrame( [this](VideoFrame &video_frame) -> void { @@ -211,8 +211,8 @@ int IceTransmission::SendData(const char *data, size_t size) { if (JUICE_STATE_COMPLETED == state_) { std::vector packets; - if (rtp_video_session_) { - rtp_video_session_->Encode((uint8_t *)data, size, packets); + if (rtp_codec_) { + rtp_codec_->Encode((uint8_t *)data, size, packets); } if (rtp_video_sender_) { rtp_video_sender_->Enqueue(packets); @@ -223,7 +223,7 @@ int IceTransmission::SendData(const char *data, size_t size) { // } // std::vector packets = - // rtp_video_session_->Encode((uint8_t *)(data), size); + // rtp_codec_->Encode((uint8_t *)(data), size); // send_ringbuffer_.insert(send_ringbuffer_.end(), packets.begin(), // packets.end()); diff --git a/src/transmission/ice_transmission.h b/src/transmission/ice_transmission.h index ee1a4e5..8b94284 100644 --- a/src/transmission/ice_transmission.h +++ b/src/transmission/ice_transmission.h @@ -6,10 +6,10 @@ #include "congestion_control.h" #include "ice_agent.h" #include "ringbuffer.h" +#include "rtp_codec.h" #include "rtp_packet.h" #include "rtp_video_receiver.h" #include "rtp_video_sender.h" -#include "rtp_video_session.h" #include "ws_transmission.h" class IceTransmission { @@ -72,7 +72,7 @@ class IceTransmission { juice_state_t state_ = JUICE_STATE_DISCONNECTED; private: - std::unique_ptr rtp_video_session_ = nullptr; + std::unique_ptr rtp_codec_ = nullptr; std::unique_ptr rtp_video_receiver_ = nullptr; std::unique_ptr rtp_video_sender_ = nullptr; uint8_t *rtp_payload_ = nullptr;