winlin

refine code, rename ISrsReader to ISrsBufferReader

... ... @@ -37,7 +37,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
* the socket provides TCP socket over st,
* that is, the sync socket mechanism.
*/
class SrsSocket : public ISrsReader
class SrsSocket : public ISrsBufferReader
{
private:
int64_t recv_timeout;
... ...
... ... @@ -28,11 +28,11 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
#define SOCKET_READ_SIZE 4096
ISrsReader::ISrsReader()
ISrsBufferReader::ISrsBufferReader()
{
}
ISrsReader::~ISrsReader()
ISrsBufferReader::~ISrsBufferReader()
{
}
... ... @@ -64,7 +64,7 @@ void SrsBuffer::append(char* bytes, int size)
data.insert(data.end(), bytes, bytes + size);
}
int SrsBuffer::ensure_buffer_bytes(ISrsReader* skt, int required_size)
int SrsBuffer::ensure_buffer_bytes(ISrsBufferReader* skt, int required_size)
{
int ret = ERROR_SUCCESS;
... ...
... ... @@ -32,11 +32,14 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
#include <vector>
class ISrsReader
/**
* the reader for the buffer to read from whatever channel.
*/
class ISrsBufferReader
{
public:
ISrsReader();
virtual ~ISrsReader();
ISrsBufferReader();
virtual ~ISrsBufferReader();
public:
virtual int read(const void* buf, size_t size, ssize_t* nread) = 0;
};
... ... @@ -60,7 +63,7 @@ public:
private:
virtual void append(char* bytes, int size);
public:
virtual int ensure_buffer_bytes(ISrsReader* skt, int required_size);
virtual int ensure_buffer_bytes(ISrsBufferReader* skt, int required_size);
};
#endif
\ No newline at end of file
... ...