From 159ef3823c367c73c74e554a00aa2508c82fa76e Mon Sep 17 00:00:00 2001 From: winlin Date: Thu, 4 Dec 2014 15:45:25 +0800 Subject: [PATCH] for bug#241, simplify the buffer, donot realloc it. --- trunk/src/rtmp/srs_protocol_buffer.cpp | 25 +++---------------------- trunk/src/rtmp/srs_protocol_buffer.hpp | 2 -- 2 files changed, 3 insertions(+), 24 deletions(-) diff --git a/trunk/src/rtmp/srs_protocol_buffer.cpp b/trunk/src/rtmp/srs_protocol_buffer.cpp index c2ab1ce29..617ce148e 100644 --- a/trunk/src/rtmp/srs_protocol_buffer.cpp +++ b/trunk/src/rtmp/srs_protocol_buffer.cpp @@ -90,10 +90,9 @@ SrsFastBuffer::SrsFastBuffer() _handler = NULL; #endif - p = end = buffer = NULL; - nb_buffer = 0; - - reset_buffer(SRS_MR_SOCKET_BUFFER); + nb_buffer = SRS_MR_SOCKET_BUFFER; + buffer = new char[nb_buffer]; + p = end = buffer; } SrsFastBuffer::~SrsFastBuffer() @@ -193,21 +192,3 @@ void SrsFastBuffer::set_merge_read(bool v, IMergeReadHandler* handler) } #endif -void SrsFastBuffer::reset_buffer(int size) -{ - // remember the cap. - int nb_cap = end - p; - - // atleast to put the old data. - nb_buffer = srs_max(nb_cap, size); - - // copy old data to buf. - char* buf = new char[nb_buffer]; - if (nb_cap > 0) { - memcpy(buf, p, nb_cap); - } - - srs_freep(buffer); - p = buffer = buf; - end = p + nb_cap; -} diff --git a/trunk/src/rtmp/srs_protocol_buffer.hpp b/trunk/src/rtmp/srs_protocol_buffer.hpp index 061b06721..e2ec16a45 100644 --- a/trunk/src/rtmp/srs_protocol_buffer.hpp +++ b/trunk/src/rtmp/srs_protocol_buffer.hpp @@ -162,8 +162,6 @@ public: */ virtual void set_merge_read(bool v, IMergeReadHandler* handler); #endif -private: - virtual void reset_buffer(int size); }; #endif