winlin

librtmp: create socket

@@ -23,9 +23,32 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. @@ -23,9 +23,32 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
23 23
24 #include <srs_lib_simple_socket.hpp> 24 #include <srs_lib_simple_socket.hpp>
25 25
26 -SimpleSocketStream::SimpleSocketStream(int fd) { 26 +#include <srs_kernel_error.hpp>
  27 +
  28 +#include <unistd.h>
  29 +#include <sys/types.h>
  30 +#include <sys/socket.h>
  31 +
  32 +SimpleSocketStream::SimpleSocketStream()
  33 +{
  34 + fd = -1;
27 } 35 }
28 36
29 -SimpleSocketStream::~SimpleSocketStream() { 37 +SimpleSocketStream::~SimpleSocketStream()
  38 +{
  39 + if (fd != -1) {
  40 + ::close(fd);
  41 + fd = -1;
  42 + }
  43 +}
  44 +
  45 +int SimpleSocketStream::create_socket()
  46 +{
  47 + fd = ::socket(AF_INET, SOCK_STREAM, 0);
  48 + if(fd == -1){
  49 + return -1;
  50 + }
  51 +
  52 + return ERROR_SUCCESS;
30 } 53 }
31 54
@@ -33,10 +33,13 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. @@ -33,10 +33,13 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
33 */ 33 */
34 class SimpleSocketStream 34 class SimpleSocketStream
35 { 35 {
  36 +private:
  37 + int fd;
36 public: 38 public:
37 - SimpleSocketStream(int fd); 39 + SimpleSocketStream();
38 virtual ~SimpleSocketStream(); 40 virtual ~SimpleSocketStream();
39 public: 41 public:
  42 + virtual int create_socket();
40 }; 43 };
41 44
42 #endif 45 #endif