diff --git a/src/rtp/rtp_packetizer/rtp_packetizer.cpp b/src/rtp/rtp_packetizer/rtp_packetizer.cpp index 473cf14..2706069 100644 --- a/src/rtp/rtp_packetizer/rtp_packetizer.cpp +++ b/src/rtp/rtp_packetizer/rtp_packetizer.cpp @@ -12,6 +12,6 @@ std::unique_ptr RtpPacketizer::Create(uint32_t payload_type, case rtp::PAYLOAD_TYPE::AV1: return std::make_unique(ssrc); default: - return std::make_unique(ssrc); + return std::make_unique(ssrc, payload_type); } } \ No newline at end of file diff --git a/src/rtp/rtp_packetizer/rtp_packetizer_generic.cpp b/src/rtp/rtp_packetizer/rtp_packetizer_generic.cpp index face0d8..53d3e26 100644 --- a/src/rtp/rtp_packetizer/rtp_packetizer_generic.cpp +++ b/src/rtp/rtp_packetizer/rtp_packetizer_generic.cpp @@ -1,12 +1,12 @@ #include "rtp_packetizer_generic.h" -RtpPacketizerGeneric::RtpPacketizerGeneric(uint32_t ssrc) +RtpPacketizerGeneric::RtpPacketizerGeneric(uint32_t ssrc, uint32_t payload_type) : version_(kRtpVersion), has_padding_(false), has_extension_(true), csrc_count_(0), marker_(false), - payload_type_(rtp::PAYLOAD_TYPE::DATA), + payload_type_(payload_type), sequence_number_(0), timestamp_(0), ssrc_(ssrc), diff --git a/src/rtp/rtp_packetizer/rtp_packetizer_generic.h b/src/rtp/rtp_packetizer/rtp_packetizer_generic.h index decb788..27af31c 100644 --- a/src/rtp/rtp_packetizer/rtp_packetizer_generic.h +++ b/src/rtp/rtp_packetizer/rtp_packetizer_generic.h @@ -11,7 +11,7 @@ class RtpPacketizerGeneric : public RtpPacketizer { public: - RtpPacketizerGeneric(uint32_t ssrc); + RtpPacketizerGeneric(uint32_t ssrc, uint32_t payload_type); virtual ~RtpPacketizerGeneric(); diff --git a/src/transport/channel/rtp_data_receiver.cpp b/src/transport/channel/rtp_data_receiver.cpp index 8fd8066..57404a8 100644 --- a/src/transport/channel/rtp_data_receiver.cpp +++ b/src/transport/channel/rtp_data_receiver.cpp @@ -50,10 +50,10 @@ void RtpDataReceiver::InsertRtpPacket(RtpPacket& rtp_packet) { // // SendRtcpRR(rtcp_rr); // } - // if (on_receive_data_) { - // on_receive_data_((const char*)rtp_packet.Payload(), - // rtp_packet.PayloadSize()); - // } + if (on_receive_data_) { + on_receive_data_((const char*)rtp_packet.Payload(), + rtp_packet.PayloadSize()); + } } void RtpDataReceiver::SetSendDataFunc(