diff --git a/trunk/src/app/srs_app_hls.hpp b/trunk/src/app/srs_app_hls.hpp index af395c312..af02b64c8 100644 --- a/trunk/src/app/srs_app_hls.hpp +++ b/trunk/src/app/srs_app_hls.hpp @@ -46,7 +46,7 @@ class SrsRequest; class SrsPithyPrint; class SrsSource; class SrsFileWriter; -class SrsSimpleBuffer; +class SrsSimpleStream; class SrsTsAacJitter; class SrsTsCache; class SrsHlsSegment; diff --git a/trunk/src/app/srs_app_mpegts_udp.cpp b/trunk/src/app/srs_app_mpegts_udp.cpp index 25585d427..eaf4d9334 100644 --- a/trunk/src/app/srs_app_mpegts_udp.cpp +++ b/trunk/src/app/srs_app_mpegts_udp.cpp @@ -128,7 +128,7 @@ SrsMpegtsOverUdp::SrsMpegtsOverUdp(SrsConfDirective* c) { stream = new SrsBuffer(); context = new SrsTsContext(); - buffer = new SrsSimpleBuffer(); + buffer = new SrsSimpleStream(); output = _srs_config->get_stream_caster_output(c); req = NULL; diff --git a/trunk/src/app/srs_app_mpegts_udp.hpp b/trunk/src/app/srs_app_mpegts_udp.hpp index 64bde1662..400e8627e 100644 --- a/trunk/src/app/srs_app_mpegts_udp.hpp +++ b/trunk/src/app/srs_app_mpegts_udp.hpp @@ -39,7 +39,7 @@ struct sockaddr_in; class SrsBuffer; class SrsTsContext; class SrsConfDirective; -class SrsSimpleBuffer; +class SrsSimpleStream; class SrsRtmpClient; class SrsStSocket; class SrsRequest; @@ -82,7 +82,7 @@ class SrsMpegtsOverUdp : virtual public ISrsTsHandler private: SrsBuffer* stream; SrsTsContext* context; - SrsSimpleBuffer* buffer; + SrsSimpleStream* buffer; std::string output; private: SrsRequest* req; diff --git a/trunk/src/app/srs_app_rtsp.hpp b/trunk/src/app/srs_app_rtsp.hpp index cb25dbdc4..40c9c599a 100644 --- a/trunk/src/app/srs_app_rtsp.hpp +++ b/trunk/src/app/srs_app_rtsp.hpp @@ -54,7 +54,7 @@ class SrsRawAacStream; struct SrsRawAacStreamCodec; class SrsSharedPtrMessage; class SrsCodecSample; -class SrsSimpleBuffer; +class SrsSimpleStream; class SrsPithyPrint; /** @@ -87,7 +87,7 @@ struct SrsRtspAudioCache { int64_t dts; SrsCodecSample* audio_samples; - SrsSimpleBuffer* payload; + SrsSimpleStream* payload; SrsRtspAudioCache(); virtual ~SrsRtspAudioCache(); diff --git a/trunk/src/kernel/srs_kernel_stream.cpp b/trunk/src/kernel/srs_kernel_stream.cpp index b17472ffc..ddbb4e766 100644 --- a/trunk/src/kernel/srs_kernel_stream.cpp +++ b/trunk/src/kernel/srs_kernel_stream.cpp @@ -28,27 +28,27 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. #include #include -SrsSimpleBuffer::SrsSimpleBuffer() +SrsSimpleStream::SrsSimpleStream() { } -SrsSimpleBuffer::~SrsSimpleBuffer() +SrsSimpleStream::~SrsSimpleStream() { } -int SrsSimpleBuffer::length() +int SrsSimpleStream::length() { int len = (int)data.size(); srs_assert(len >= 0); return len; } -char* SrsSimpleBuffer::bytes() +char* SrsSimpleStream::bytes() { return (length() == 0)? NULL : &data.at(0); } -void SrsSimpleBuffer::erase(int size) +void SrsSimpleStream::erase(int size) { if (size <= 0) { return; @@ -62,7 +62,7 @@ void SrsSimpleBuffer::erase(int size) data.erase(data.begin(), data.begin() + size); } -void SrsSimpleBuffer::append(const char* bytes, int size) +void SrsSimpleStream::append(const char* bytes, int size) { srs_assert(size > 0); diff --git a/trunk/src/kernel/srs_kernel_stream.hpp b/trunk/src/kernel/srs_kernel_stream.hpp index 83734ea62..c58589057 100644 --- a/trunk/src/kernel/srs_kernel_stream.hpp +++ b/trunk/src/kernel/srs_kernel_stream.hpp @@ -36,13 +36,13 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. * the simple buffer use vector to append bytes, * it's for hls and http, and need to be refined in future. */ -class SrsSimpleBuffer +class SrsSimpleStream { private: std::vector data; public: - SrsSimpleBuffer(); - virtual ~SrsSimpleBuffer(); + SrsSimpleStream(); + virtual ~SrsSimpleStream(); public: /** * get the length of buffer. empty if zero. diff --git a/trunk/src/kernel/srs_kernel_ts.cpp b/trunk/src/kernel/srs_kernel_ts.cpp index 1f7e893bc..5f4b5af27 100644 --- a/trunk/src/kernel/srs_kernel_ts.cpp +++ b/trunk/src/kernel/srs_kernel_ts.cpp @@ -95,7 +95,7 @@ SrsTsMessage::SrsTsMessage(SrsTsChannel* c, SrsTsPacket* p) sid = (SrsTsPESStreamId)0x00; continuity_counter = 0; PES_packet_length = 0; - payload = new SrsSimpleBuffer(); + payload = new SrsSimpleStream(); is_discontinuity = false; start_pts = 0; diff --git a/trunk/src/kernel/srs_kernel_ts.hpp b/trunk/src/kernel/srs_kernel_ts.hpp index 29ee6cb63..2e33501ab 100644 --- a/trunk/src/kernel/srs_kernel_ts.hpp +++ b/trunk/src/kernel/srs_kernel_ts.hpp @@ -42,7 +42,7 @@ class SrsFileWriter; class SrsFileReader; class SrsAvcAacCodec; class SrsCodecSample; -class SrsSimpleBuffer; +class SrsSimpleStream; class SrsTsAdaptationField; class SrsTsPayload; class SrsTsMessage; @@ -273,7 +273,7 @@ public: // the chunk id. u_int8_t continuity_counter; // the payload bytes. - SrsSimpleBuffer* payload; + SrsSimpleStream* payload; public: SrsTsMessage(SrsTsChannel* c = NULL, SrsTsPacket* p = NULL); virtual ~SrsTsMessage(); diff --git a/trunk/src/protocol/srs_rtsp_stack.cpp b/trunk/src/protocol/srs_rtsp_stack.cpp index 59d1e05c9..a74a3b198 100644 --- a/trunk/src/protocol/srs_rtsp_stack.cpp +++ b/trunk/src/protocol/srs_rtsp_stack.cpp @@ -133,7 +133,7 @@ SrsRtpPacket::SrsRtpPacket() timestamp = 0; ssrc = 0; - payload = new SrsSimpleBuffer(); + payload = new SrsSimpleStream(); audio_samples = new SrsCodecSample(); chunked = false; completed = false; @@ -829,7 +829,7 @@ int SrsRtspSetupResponse::encode_header(stringstream& ss) SrsRtspStack::SrsRtspStack(ISrsProtocolReaderWriter* s) { - buf = new SrsSimpleBuffer(); + buf = new SrsSimpleStream(); skt = s; } diff --git a/trunk/src/protocol/srs_rtsp_stack.hpp b/trunk/src/protocol/srs_rtsp_stack.hpp index 3b5cff0af..4cfa6b6f0 100644 --- a/trunk/src/protocol/srs_rtsp_stack.hpp +++ b/trunk/src/protocol/srs_rtsp_stack.hpp @@ -38,7 +38,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. #ifdef SRS_AUTO_STREAM_CASTER class SrsBuffer; -class SrsSimpleBuffer; +class SrsSimpleStream; class SrsCodecSample; class ISrsProtocolReaderWriter; @@ -286,7 +286,7 @@ public: u_int32_t ssrc; //32bits // the payload. - SrsSimpleBuffer* payload; + SrsSimpleStream* payload; // whether transport in chunked payload. bool chunked; // whether message is completed. @@ -657,7 +657,7 @@ private: /** * cached bytes buffer. */ - SrsSimpleBuffer* buf; + SrsSimpleStream* buf; /** * underlayer socket object, send/recv bytes. */ diff --git a/trunk/src/utest/srs_utest_kernel.cpp b/trunk/src/utest/srs_utest_kernel.cpp index 41febea7a..b0c50bff4 100644 --- a/trunk/src/utest/srs_utest_kernel.cpp +++ b/trunk/src/utest/srs_utest_kernel.cpp @@ -203,7 +203,7 @@ int MockBufferReader::read(void* buf, size_t size, ssize_t* nread) VOID TEST(KernelBufferTest, DefaultObject) { - SrsSimpleBuffer b; + SrsSimpleStream b; EXPECT_EQ(0, b.length()); EXPECT_EQ(NULL, b.bytes()); @@ -211,7 +211,7 @@ VOID TEST(KernelBufferTest, DefaultObject) VOID TEST(KernelBufferTest, AppendBytes) { - SrsSimpleBuffer b; + SrsSimpleStream b; char winlin[] = "winlin"; b.append(winlin, strlen(winlin)); @@ -231,7 +231,7 @@ VOID TEST(KernelBufferTest, AppendBytes) VOID TEST(KernelBufferTest, EraseBytes) { - SrsSimpleBuffer b; + SrsSimpleStream b; b.erase(0); b.erase(-1); diff --git a/trunk/src/utest/srs_utest_protocol.hpp b/trunk/src/utest/srs_utest_protocol.hpp index 9a5aaad55..bc61fb1b3 100644 --- a/trunk/src/utest/srs_utest_protocol.hpp +++ b/trunk/src/utest/srs_utest_protocol.hpp @@ -78,9 +78,9 @@ public: int64_t recv_bytes; int64_t send_bytes; // data source for socket read. - SrsSimpleBuffer in_buffer; + SrsSimpleStream in_buffer; // data buffer for socket send. - SrsSimpleBuffer out_buffer; + SrsSimpleStream out_buffer; public: MockBufferIO(); virtual ~MockBufferIO();