|
|
|
@ -110,6 +110,7 @@ VOID TEST(TCPServerTest, PingPong)
|
|
|
|
|
SrsTcpClient c(_srs_tmp_host, _srs_tmp_port, _srs_tmp_timeout);
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
EXPECT_TRUE(h.fd != NULL);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -122,7 +123,10 @@ VOID TEST(TCPServerTest, PingPong)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.write((void*)"Hello", 5, NULL));
|
|
|
|
@ -141,7 +145,10 @@ VOID TEST(TCPServerTest, PingPong)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.write((void*)"Hello", 5, NULL));
|
|
|
|
@ -149,7 +156,7 @@ VOID TEST(TCPServerTest, PingPong)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.write((void*)"SRS", 3, NULL));
|
|
|
|
|
|
|
|
|
|
char buf[16] = {0};
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.read(buf, 9, NULL));
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.read_fully(buf, 9, NULL));
|
|
|
|
|
EXPECT_STREQ(buf, "Hello SRS");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -162,7 +169,10 @@ VOID TEST(TCPServerTest, PingPong)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.write((void*)"Hello SRS", 9, NULL));
|
|
|
|
@ -194,7 +204,10 @@ VOID TEST(TCPServerTest, PingPongWithTimeout)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
skt.set_recv_timeout(1 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
|
|
|
|
@ -213,7 +226,10 @@ VOID TEST(TCPServerTest, PingPongWithTimeout)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
skt.set_recv_timeout(1 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
|
|
|
|
@ -232,7 +248,10 @@ VOID TEST(TCPServerTest, PingPongWithTimeout)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
skt.set_recv_timeout(1 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
|
|
|
|
@ -363,7 +382,9 @@ VOID TEST(TCPServerTest, StringIsHex)
|
|
|
|
|
char* str = (char*)"!1234567890";
|
|
|
|
|
char* parsed = str; errno = 0;
|
|
|
|
|
EXPECT_EQ(0x0, ::strtol(str, &parsed, 16));
|
|
|
|
|
#ifndef SRS_AUTO_OSX
|
|
|
|
|
EXPECT_EQ(0, errno);
|
|
|
|
|
#endif
|
|
|
|
|
EXPECT_EQ(str, parsed);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -379,7 +400,9 @@ VOID TEST(TCPServerTest, StringIsHex)
|
|
|
|
|
char* str = (char*)"";
|
|
|
|
|
char* parsed = str; errno = 0;
|
|
|
|
|
EXPECT_EQ(0x0, ::strtol(str, &parsed, 16));
|
|
|
|
|
#ifndef SRS_AUTO_OSX
|
|
|
|
|
EXPECT_EQ(0, errno);
|
|
|
|
|
#endif
|
|
|
|
|
EXPECT_EQ(str, parsed);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -405,7 +428,10 @@ VOID TEST(TCPServerTest, WritevIOVC)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
|
|
|
|
|
iovec iovs[3];
|
|
|
|
@ -432,7 +458,10 @@ VOID TEST(TCPServerTest, WritevIOVC)
|
|
|
|
|
HELPER_EXPECT_SUCCESS(c.connect());
|
|
|
|
|
|
|
|
|
|
SrsStSocket skt;
|
|
|
|
|
srs_usleep(100 * SRS_UTIME_MILLISECONDS);
|
|
|
|
|
#ifdef SRS_AUTO_OSX
|
|
|
|
|
ASSERT_TRUE(h.fd != NULL);
|
|
|
|
|
#endif
|
|
|
|
|
HELPER_EXPECT_SUCCESS(skt.initialize(h.fd));
|
|
|
|
|
|
|
|
|
|
iovec iovs[3];
|
|
|
|
|