external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-02-15 04:42:04 +00:00
Code Issues Releases Wiki Activity

Refacor STAP RTP packet

Browse source
This commit is contained in:
winlin 2020-04-12 01:05:11 +08:00
parent ca027ca5cb
commit acbbdf51d6
2 changed files with 14 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
trunk/src/kernel/srs_kernel_rtp.cpp
View file

@ -212,21 +212,25 @@ srs_error_t SrsRtpRawPayload::encode(SrsBuffer* buf)
SrsRtpSTAPPayload::SrsRtpSTAPPayload()
{
nri = (SrsAvcNaluType)0;
nalus = NULL;
nn_nalus = 0;
}
SrsRtpSTAPPayload::~SrsRtpSTAPPayload()
{
srs_freepa(nalus);
vector<SrsSample*>::iterator it;
for (it = nalus.begin(); it != nalus.end(); ++it) {
SrsSample* p = *it;
srs_freep(p);
}
nalus.clear();
}
int SrsRtpSTAPPayload::nb_bytes()
{
int size = 1;
for (int i = 0; i < nn_nalus; i++) {
SrsSample* p = nalus + i;
vector<SrsSample*>::iterator it;
for (it = nalus.begin(); it != nalus.end(); ++it) {
SrsSample* p = *it;
size += 2 + p->size;
}
@ -246,8 +250,9 @@ srs_error_t SrsRtpSTAPPayload::encode(SrsBuffer* buf)
buf->write_1bytes(v);
// NALUs.
for (int i = 0; i < nn_nalus; i++) {
SrsSample* p = nalus + i;
vector<SrsSample*>::iterator it;
for (it = nalus.begin(); it != nalus.end(); ++it) {
SrsSample* p = *it;
if (!buf->require(2 + p->size)) {
return srs_error_new(ERROR_RTC_RTP_MUXER, "requires %d bytes", 2 + p->size);
}
@ -272,6 +277,7 @@ SrsRtpFUAPayload::~SrsRtpFUAPayload()
SrsSample* p = *it;
srs_freep(p);
}
nalus.clear();
}
int SrsRtpFUAPayload::nb_bytes()

3
trunk/src/kernel/srs_kernel_rtp.hpp
View file

@ -110,8 +110,7 @@ public:
SrsAvcNaluType nri;
// The NALU samples.
// @remark We only refer to the memory, user must free its bytes.
SrsSample* nalus;
int nn_nalus;
std::vector<SrsSample*> nalus;
public:
SrsRtpSTAPPayload();
virtual ~SrsRtpSTAPPayload();