rename SrsSimpleBuffer to SrsSimpleStream

@@ -46,7 +46,7 @@ class SrsRequest;
 class SrsPithyPrint;
 class SrsPithyPrint;
 class SrsSource;
 class SrsSource;
 class SrsFileWriter;
 class SrsFileWriter;
-class SrsSimpleBuffer;
+class SrsSimpleStream;
 class SrsTsAacJitter;
 class SrsTsAacJitter;
 class SrsTsCache;
 class SrsTsCache;
 class SrsHlsSegment;
 class SrsHlsSegment;

@@ -128,7 +128,7 @@ SrsMpegtsOverUdp::SrsMpegtsOverUdp(SrsConfDirective* c)
 {
 {
     stream = new SrsBuffer();
     stream = new SrsBuffer();
     context = new SrsTsContext();
     context = new SrsTsContext();
-    buffer = new SrsSimpleBuffer();
+    buffer = new SrsSimpleStream();
     output = _srs_config->get_stream_caster_output(c);
     output = _srs_config->get_stream_caster_output(c);
     
     
     req = NULL;
     req = NULL;

@@ -39,7 +39,7 @@ struct sockaddr_in;
 class SrsBuffer;
 class SrsBuffer;
 class SrsTsContext;
 class SrsTsContext;
 class SrsConfDirective;
 class SrsConfDirective;
-class SrsSimpleBuffer;
+class SrsSimpleStream;
 class SrsRtmpClient;
 class SrsRtmpClient;
 class SrsStSocket;
 class SrsStSocket;
 class SrsRequest;
 class SrsRequest;
@@ -82,7 +82,7 @@ class SrsMpegtsOverUdp : virtual public ISrsTsHandler
 private:
 private:
     SrsBuffer* stream;
     SrsBuffer* stream;
     SrsTsContext* context;
     SrsTsContext* context;
-    SrsSimpleBuffer* buffer;
+    SrsSimpleStream* buffer;
     std::string output;
     std::string output;
 private:
 private:
     SrsRequest* req;
     SrsRequest* req;

@@ -54,7 +54,7 @@ class SrsRawAacStream;
 struct SrsRawAacStreamCodec;
 struct SrsRawAacStreamCodec;
 class SrsSharedPtrMessage;
 class SrsSharedPtrMessage;
 class SrsCodecSample;
 class SrsCodecSample;
-class SrsSimpleBuffer;
+class SrsSimpleStream;
 class SrsPithyPrint;
 class SrsPithyPrint;
 
 
 /**
 /**
@@ -87,7 +87,7 @@ struct SrsRtspAudioCache
 {
 {
     int64_t dts;
     int64_t dts;
     SrsCodecSample* audio_samples;
     SrsCodecSample* audio_samples;
-    SrsSimpleBuffer* payload;
+    SrsSimpleStream* payload;
 
 
     SrsRtspAudioCache();
     SrsRtspAudioCache();
     virtual ~SrsRtspAudioCache();
     virtual ~SrsRtspAudioCache();

@@ -28,27 +28,27 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #include <srs_kernel_utility.hpp>
 #include <srs_kernel_utility.hpp>
 #include <srs_core_performance.hpp>
 #include <srs_core_performance.hpp>
 
 
-SrsSimpleBuffer::SrsSimpleBuffer()
+SrsSimpleStream::SrsSimpleStream()
 {
 {
 }
 }
 
 
-SrsSimpleBuffer::~SrsSimpleBuffer()
+SrsSimpleStream::~SrsSimpleStream()
 {
 {
 }
 }
 
 
-int SrsSimpleBuffer::length()
+int SrsSimpleStream::length()
 {
 {
     int len = (int)data.size();
     int len = (int)data.size();
     srs_assert(len >= 0);
     srs_assert(len >= 0);
     return len;
     return len;
 }
 }
 
 
-char* SrsSimpleBuffer::bytes()
+char* SrsSimpleStream::bytes()
 {
 {
     return (length() == 0)? NULL : &data.at(0);
     return (length() == 0)? NULL : &data.at(0);
 }
 }
 
 
-void SrsSimpleBuffer::erase(int size)
+void SrsSimpleStream::erase(int size)
 {
 {
     if (size <= 0) {
     if (size <= 0) {
         return;
         return;
@@ -62,7 +62,7 @@ void SrsSimpleBuffer::erase(int size)
     data.erase(data.begin(), data.begin() + 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);
     srs_assert(size > 0);
 
 

@@ -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,
 * the simple buffer use vector to append bytes,
 * it's for hls and http, and need to be refined in future.
 * it's for hls and http, and need to be refined in future.
 */
 */
-class SrsSimpleBuffer
+class SrsSimpleStream
 {
 {
 private:
 private:
     std::vector<char> data;
     std::vector<char> data;
 public:
 public:
-    SrsSimpleBuffer();
-    virtual ~SrsSimpleBuffer();
+    SrsSimpleStream();
+    virtual ~SrsSimpleStream();
 public:
 public:
     /**
     /**
     * get the length of buffer. empty if zero.
     * get the length of buffer. empty if zero.

@@ -95,7 +95,7 @@ SrsTsMessage::SrsTsMessage(SrsTsChannel* c, SrsTsPacket* p)
     sid = (SrsTsPESStreamId)0x00;
     sid = (SrsTsPESStreamId)0x00;
     continuity_counter = 0;
     continuity_counter = 0;
     PES_packet_length = 0;
     PES_packet_length = 0;
-    payload = new SrsSimpleBuffer();
+    payload = new SrsSimpleStream();
     is_discontinuity = false;
     is_discontinuity = false;
 
 
     start_pts = 0;
     start_pts = 0;

@@ -42,7 +42,7 @@ class SrsFileWriter;
 class SrsFileReader;
 class SrsFileReader;
 class SrsAvcAacCodec;
 class SrsAvcAacCodec;
 class SrsCodecSample;
 class SrsCodecSample;
-class SrsSimpleBuffer;
+class SrsSimpleStream;
 class SrsTsAdaptationField;
 class SrsTsAdaptationField;
 class SrsTsPayload;
 class SrsTsPayload;
 class SrsTsMessage;
 class SrsTsMessage;
@@ -273,7 +273,7 @@ public:
     // the chunk id.
     // the chunk id.
     u_int8_t continuity_counter;
     u_int8_t continuity_counter;
     // the payload bytes.
     // the payload bytes.
-    SrsSimpleBuffer* payload;
+    SrsSimpleStream* payload;
 public:
 public:
     SrsTsMessage(SrsTsChannel* c = NULL, SrsTsPacket* p = NULL);
     SrsTsMessage(SrsTsChannel* c = NULL, SrsTsPacket* p = NULL);
     virtual ~SrsTsMessage();
     virtual ~SrsTsMessage();

@@ -133,7 +133,7 @@ SrsRtpPacket::SrsRtpPacket()
     timestamp = 0;
     timestamp = 0;
     ssrc = 0;
     ssrc = 0;
 
 
-    payload = new SrsSimpleBuffer();
+    payload = new SrsSimpleStream();
     audio_samples = new SrsCodecSample();
     audio_samples = new SrsCodecSample();
     chunked = false;
     chunked = false;
     completed = false;
     completed = false;
@@ -829,7 +829,7 @@ int SrsRtspSetupResponse::encode_header(stringstream& ss)
 
 
 SrsRtspStack::SrsRtspStack(ISrsProtocolReaderWriter* s)
 SrsRtspStack::SrsRtspStack(ISrsProtocolReaderWriter* s)
 {
 {
-    buf = new SrsSimpleBuffer();
+    buf = new SrsSimpleStream();
     skt = s;
     skt = s;
 }
 }
 
 

@@ -38,7 +38,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #ifdef SRS_AUTO_STREAM_CASTER
 #ifdef SRS_AUTO_STREAM_CASTER
 
 
 class SrsBuffer;
 class SrsBuffer;
-class SrsSimpleBuffer;
+class SrsSimpleStream;
 class SrsCodecSample;
 class SrsCodecSample;
 class ISrsProtocolReaderWriter;
 class ISrsProtocolReaderWriter;
 
 
@@ -286,7 +286,7 @@ public:
     u_int32_t ssrc; //32bits
     u_int32_t ssrc; //32bits
 
 
     // the payload.
     // the payload.
-    SrsSimpleBuffer* payload;
+    SrsSimpleStream* payload;
     // whether transport in chunked payload.
     // whether transport in chunked payload.
     bool chunked;
     bool chunked;
     // whether message is completed.
     // whether message is completed.
@@ -657,7 +657,7 @@ private:
     /**
     /**
     * cached bytes buffer.
     * cached bytes buffer.
     */
     */
-    SrsSimpleBuffer* buf;
+    SrsSimpleStream* buf;
     /**
     /**
     * underlayer socket object, send/recv bytes.
     * underlayer socket object, send/recv bytes.
     */
     */

@@ -203,7 +203,7 @@ int MockBufferReader::read(void* buf, size_t size, ssize_t* nread)
 
 
 VOID TEST(KernelBufferTest, DefaultObject)
 VOID TEST(KernelBufferTest, DefaultObject)
 {
 {
-    SrsSimpleBuffer b;
+    SrsSimpleStream b;
     
     
     EXPECT_EQ(0, b.length());
     EXPECT_EQ(0, b.length());
     EXPECT_EQ(NULL, b.bytes());
     EXPECT_EQ(NULL, b.bytes());
@@ -211,7 +211,7 @@ VOID TEST(KernelBufferTest, DefaultObject)
 
 
 VOID TEST(KernelBufferTest, AppendBytes)
 VOID TEST(KernelBufferTest, AppendBytes)
 {
 {
-    SrsSimpleBuffer b;
+    SrsSimpleStream b;
     
     
     char winlin[] = "winlin";
     char winlin[] = "winlin";
     b.append(winlin, strlen(winlin));
     b.append(winlin, strlen(winlin));
@@ -231,7 +231,7 @@ VOID TEST(KernelBufferTest, AppendBytes)
 
 
 VOID TEST(KernelBufferTest, EraseBytes)
 VOID TEST(KernelBufferTest, EraseBytes)
 {
 {
-    SrsSimpleBuffer b;
+    SrsSimpleStream b;
     
     
     b.erase(0);
     b.erase(0);
     b.erase(-1);
     b.erase(-1);

@@ -78,9 +78,9 @@ public:
     int64_t recv_bytes;
     int64_t recv_bytes;
     int64_t send_bytes;
     int64_t send_bytes;
     // data source for socket read.
     // data source for socket read.
-    SrsSimpleBuffer in_buffer;
+    SrsSimpleStream in_buffer;
     // data buffer for socket send.
     // data buffer for socket send.
-    SrsSimpleBuffer out_buffer;
+    SrsSimpleStream out_buffer;
 public:
 public:
     MockBufferIO();
     MockBufferIO();
     virtual ~MockBufferIO();
     virtual ~MockBufferIO();