external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

Refine object cache.

Browse source
This commit is contained in:
winlin 2021-02-27 12:32:46 +08:00
parent 1e2daf9ea3
commit aacdc21d1c
3 changed files with 36 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

38
trunk/src/kernel/srs_kernel_rtc_rtp.hpp
View file

@ -318,11 +318,11 @@ public:
SrsRtpPacket2();
virtual ~SrsRtpPacket2();
private:
void reuse_payload();
void reuse_shared_msg();
void recycle_payload();
void recycle_shared_msg();
public:
// Recycle the object to reuse it.
virtual bool reset();
virtual bool recycle();
// Wrap buffer to shared_message, which is managed by us.
char* wrap(int size);
char* wrap(char* data, int size);
@ -414,22 +414,14 @@ public:
// Try to allocate from cache, create new object if no cache.
// SrsRtpObjectCacheManager::allocate
T* allocate() {
while (true) {
if (!enabled_ || cache_objs_.empty()) {
return new T();
}
T* obj = cache_objs_.back();
cache_objs_.pop_back();
// If reset the object fail, drop the cached object.
if (!obj->reset()) {
srs_freep(obj);
continue;
}
return obj;
if (!enabled_ || cache_objs_.empty()) {
return new T();
}
T* obj = cache_objs_.back();
cache_objs_.pop_back();
return obj;
}
// Recycle the object to cache.
// @remark User can directly free the packet.
@ -446,6 +438,12 @@ public:
return;
}
// If recycle the object fail, drop the cached object.
if (!p->recycle()) {
srs_freep(p);
return;
}
// If exceed the capacity, drop the object.
if (cache_objs_.size() > capacity_) {
++_srs_pps_objs_drop->sugar;
@ -471,7 +469,7 @@ public:
SrsRtpRawPayload();
virtual ~SrsRtpRawPayload();
public:
bool reset() { return true; }
bool recycle() { return true; }
// interface ISrsRtpPayloader
public:
virtual uint64_t nb_bytes();
@ -571,7 +569,7 @@ public:
SrsRtpFUAPayload2();
virtual ~SrsRtpFUAPayload2();
public:
bool reset() { return true; }
bool recycle() { return true; }
// interface ISrsRtpPayloader
public:
virtual uint64_t nb_bytes();