diff --git a/trunk/src/app/srs_app_source.hpp b/trunk/src/app/srs_app_source.hpp index 6e730cde6..613c7240f 100644 --- a/trunk/src/app/srs_app_source.hpp +++ b/trunk/src/app/srs_app_source.hpp @@ -229,7 +229,7 @@ public: #endif // when client send the pause message. virtual srs_error_t on_play_client_pause(bool is_pause); - // ISrsWakable +// Interface ISrsWakable public: // when the consumer(for player) got msg from recv thread, // it must be processed for maybe it's a close msg, so the cond diff --git a/trunk/src/libs/srs_lib_simple_socket.cpp b/trunk/src/libs/srs_lib_simple_socket.cpp index ac3d173f6..844932ea0 100644 --- a/trunk/src/libs/srs_lib_simple_socket.cpp +++ b/trunk/src/libs/srs_lib_simple_socket.cpp @@ -365,7 +365,7 @@ int SimpleSocketStream::connect(const char* server_ip, int port) return srs_hijack_io_connect(io, server_ip, port); } -// ISrsReader +// Interface ISrsReader srs_error_t SimpleSocketStream::read(void* buf, size_t size, ssize_t* nread) { srs_assert(io); @@ -376,7 +376,7 @@ srs_error_t SimpleSocketStream::read(void* buf, size_t size, ssize_t* nread) return srs_success; } -// ISrsProtocolReader +// Interface ISrsProtocolReader void SimpleSocketStream::set_recv_timeout(srs_utime_t tm) { srs_assert(io); @@ -395,7 +395,7 @@ int64_t SimpleSocketStream::get_recv_bytes() return srs_hijack_io_get_recv_bytes(io); } -// ISrsProtocolWriter +// Interface ISrsProtocolWriter void SimpleSocketStream::set_send_timeout(srs_utime_t tm) { srs_assert(io); @@ -424,7 +424,7 @@ srs_error_t SimpleSocketStream::writev(const iovec *iov, int iov_size, ssize_t* return srs_success; } -// ISrsProtocolReadWriter +// Interface ISrsProtocolReadWriter bool SimpleSocketStream::is_never_timeout(srs_utime_t tm) { srs_assert(io); diff --git a/trunk/src/libs/srs_lib_simple_socket.hpp b/trunk/src/libs/srs_lib_simple_socket.hpp index 16685eadf..a03fa96b5 100644 --- a/trunk/src/libs/srs_lib_simple_socket.hpp +++ b/trunk/src/libs/srs_lib_simple_socket.hpp @@ -49,21 +49,21 @@ public: virtual srs_hijack_io_t hijack_io(); virtual int create_socket(srs_rtmp_t owner); virtual int connect(const char* server, int port); -// ISrsReader +// Interface ISrsReader public: virtual srs_error_t read(void* buf, size_t size, ssize_t* nread); -// ISrsProtocolReader +// Interface ISrsProtocolReader public: virtual void set_recv_timeout(srs_utime_t tm); virtual srs_utime_t get_recv_timeout(); virtual int64_t get_recv_bytes(); -// ISrsProtocolWriter +// Interface ISrsProtocolWriter public: virtual void set_send_timeout(srs_utime_t tm); virtual srs_utime_t get_send_timeout(); virtual int64_t get_send_bytes(); virtual srs_error_t writev(const iovec *iov, int iov_size, ssize_t* nwrite); -// ISrsProtocolReadWriter +// Interface ISrsProtocolReadWriter public: virtual bool is_never_timeout(srs_utime_t tm); virtual srs_error_t read_fully(void* buf, size_t size, ssize_t* nread);