1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-02-15 04:42:04 +00:00

RTC: Refine code, remove the reset for header

This commit is contained in:
winlin 2021-02-28 10:06:52 +08:00
parent 5af0bf9350
commit 75a4c8d9e5
2 changed files with 13 additions and 57 deletions

View file

@ -204,20 +204,15 @@ SrsRtpExtensionType SrsRtpExtensionTypes::get_type(int id) const
SrsRtpExtensionTwcc::SrsRtpExtensionTwcc() SrsRtpExtensionTwcc::SrsRtpExtensionTwcc()
{ {
reset(); has_twcc_ = false;
id_ = 0;
sn_ = 0;
} }
SrsRtpExtensionTwcc::~SrsRtpExtensionTwcc() SrsRtpExtensionTwcc::~SrsRtpExtensionTwcc()
{ {
} }
void SrsRtpExtensionTwcc::reset()
{
has_twcc_ = false;
id_ = 0;
sn_ = 0;
}
srs_error_t SrsRtpExtensionTwcc::decode(SrsBuffer* buf) srs_error_t SrsRtpExtensionTwcc::decode(SrsBuffer* buf)
{ {
srs_error_t err = srs_success; srs_error_t err = srs_success;
@ -292,20 +287,15 @@ void SrsRtpExtensionTwcc::set_sn(uint16_t sn)
SrsRtpExtensionOneByte::SrsRtpExtensionOneByte() SrsRtpExtensionOneByte::SrsRtpExtensionOneByte()
{ {
reset(); has_ext_ = false;
id_ = 0;
value_ = 0;
} }
SrsRtpExtensionOneByte::~SrsRtpExtensionOneByte() SrsRtpExtensionOneByte::~SrsRtpExtensionOneByte()
{ {
} }
void SrsRtpExtensionOneByte::reset()
{
has_ext_ = false;
id_ = 0;
value_ = 0;
}
void SrsRtpExtensionOneByte::set_id(int id) void SrsRtpExtensionOneByte::set_id(int id)
{ {
id_ = id; id_ = id;
@ -356,21 +346,14 @@ srs_error_t SrsRtpExtensionOneByte::encode(SrsBuffer* buf)
SrsRtpExtensions::SrsRtpExtensions() SrsRtpExtensions::SrsRtpExtensions()
{ {
reset(); types_ = NULL;
has_ext_ = false;
} }
SrsRtpExtensions::~SrsRtpExtensions() SrsRtpExtensions::~SrsRtpExtensions()
{ {
} }
void SrsRtpExtensions::reset()
{
types_ = NULL;
twcc_.reset();
audio_level_.reset();
has_ext_ = false;
}
srs_error_t SrsRtpExtensions::decode(SrsBuffer* buf) srs_error_t SrsRtpExtensions::decode(SrsBuffer* buf)
{ {
srs_error_t err = srs_success; srs_error_t err = srs_success;
@ -547,34 +530,19 @@ srs_error_t SrsRtpExtensions::set_audio_level(int id, uint8_t level)
SrsRtpHeader::SrsRtpHeader() SrsRtpHeader::SrsRtpHeader()
{ {
reset();
memset(csrc, 0, sizeof(csrc));
}
SrsRtpHeader::~SrsRtpHeader()
{
}
void SrsRtpHeader::reset()
{
// Reset the fields in protocol.
cc = 0; cc = 0;
marker = false; marker = false;
payload_type = 0; payload_type = 0;
sequence = 0; sequence = 0;
timestamp = 0; timestamp = 0;
ssrc = 0; ssrc = 0;
// Reset the parsed fields.
padding_length = 0; padding_length = 0;
extensions_.reset();
// Reset other fields.
ignore_padding_ = false; ignore_padding_ = false;
memset(csrc, 0, sizeof(csrc));
}
// The CSRC is not used yet, so we never reset it. SrsRtpHeader::~SrsRtpHeader()
//memset(csrc, 0, sizeof(csrc)); {
} }
srs_error_t SrsRtpHeader::decode(SrsBuffer* buf) srs_error_t SrsRtpHeader::decode(SrsBuffer* buf)
@ -822,7 +790,7 @@ void SrsRtpPacket2::reset()
decode_handler = NULL; decode_handler = NULL;
// It's important to reset the header. // It's important to reset the header.
header.reset(); header = SrsRtpHeader();
// Recyle the payload again, to ensure the packet is new one. // Recyle the payload again, to ensure the packet is new one.
recycle_payload(); recycle_payload();

View file

@ -137,9 +137,6 @@ class SrsRtpExtensionTwcc// : public ISrsCodec
public: public:
SrsRtpExtensionTwcc(); SrsRtpExtensionTwcc();
virtual ~SrsRtpExtensionTwcc(); virtual ~SrsRtpExtensionTwcc();
public:
// Reset the object to reuse it.
void reset();
public: public:
inline bool exists() { return has_twcc_; } // SrsRtpExtensionTwcc::exists inline bool exists() { return has_twcc_; } // SrsRtpExtensionTwcc::exists
uint8_t get_id(); uint8_t get_id();
@ -162,9 +159,6 @@ class SrsRtpExtensionOneByte// : public ISrsCodec
public: public:
SrsRtpExtensionOneByte(); SrsRtpExtensionOneByte();
virtual ~SrsRtpExtensionOneByte(); virtual ~SrsRtpExtensionOneByte();
public:
// Reset the object to reuse it.
void reset();
public: public:
inline bool exists() { return has_ext_; } // SrsRtpExtensionOneByte::exists inline bool exists() { return has_ext_; } // SrsRtpExtensionOneByte::exists
int get_id() { return id_; } int get_id() { return id_; }
@ -193,9 +187,6 @@ private:
public: public:
SrsRtpExtensions(); SrsRtpExtensions();
virtual ~SrsRtpExtensions(); virtual ~SrsRtpExtensions();
public:
// Reset the object to reuse it.
void reset();
public: public:
inline bool exists() { return has_ext_; } // SrsRtpExtensions::exists inline bool exists() { return has_ext_; } // SrsRtpExtensions::exists
void set_types_(SrsRtpExtensionTypes* types); void set_types_(SrsRtpExtensionTypes* types);
@ -230,9 +221,6 @@ private:
public: public:
SrsRtpHeader(); SrsRtpHeader();
virtual ~SrsRtpHeader(); virtual ~SrsRtpHeader();
public:
// Reset the object to reuse it.
void reset();
public: public:
virtual srs_error_t decode(SrsBuffer* buf); virtual srs_error_t decode(SrsBuffer* buf);
private: private: