8 8
#include "srt.h"
9 9
#include "udt.h"
10 10 11 +
using srt::sockaddr_any;
12 + 11 13
// Copied from ../apps/apputil.cpp, can't really link this file here.
12 14
sockaddr_any CreateAddr(const std::string& name, unsigned short port, int pref_family = AF_INET)
13 15
{
@@ -218,8 +220,8 @@ void serverSocket(std::string ip, int port, bool expect_success)
218 220
int yes = 1;
219 221
int no = 0;
220 222 221 -
SRTSOCKET m_bindsock = srt_create_socket();
222 -
ASSERT_NE(m_bindsock, SRT_ERROR);
223 +
SRTSOCKET m_bindsock = srt_create_socket();
224 +
ASSERT_NE(m_bindsock, SRT_ERROR);
223 225 224 226
ASSERT_NE(srt_setsockopt(m_bindsock, 0, SRTO_RCVSYN, &no, sizeof no), SRT_ERROR); // for async connect
225 227
ASSERT_NE(srt_setsockopt(m_bindsock, 0, SRTO_TSBPDMODE, &yes, sizeof yes), SRT_ERROR);
@@ -251,33 +253,33 @@ void serverSocket(std::string ip, int port, bool expect_success)
251 253
std::thread client(clientSocket, ip, port, expect_success);
252 254 253 255
{ // wait for connection from client
254 -
int rlen = 2;
255 -
SRTSOCKET read[2];
256 +
int rlen = 2;
257 +
SRTSOCKET read[2];
256 258 257 -
int wlen = 2;
258 -
SRTSOCKET write[2];
259 +
int wlen = 2;
260 +
SRTSOCKET write[2];
259 261 260 262
ASSERT_NE(srt_epoll_wait(server_pollid,
261 -
read, &rlen,
262 -
write, &wlen,
263 -
3000, // -1 is set for debuging purpose.
264 -
// in case of production we need to set appropriate value
265 -
0, 0, 0, 0), SRT_ERROR );
263 +
read, &rlen,
264 +
write, &wlen,
265 +
3000, // -1 is set for debuging purpose.
266 +
// in case of production we need to set appropriate value
267 +
0, 0, 0, 0), SRT_ERROR );
266 268 267 269 268 -
ASSERT_EQ(rlen, 1); // get exactly one read event without writes
269 -
ASSERT_EQ(wlen, 0); // get exactly one read event without writes
270 -
ASSERT_EQ(read[0], m_bindsock); // read event is for bind socket
270 +
ASSERT_EQ(rlen, 1); // get exactly one read event without writes
271 +
ASSERT_EQ(wlen, 0); // get exactly one read event without writes
272 +
ASSERT_EQ(read[0], m_bindsock); // read event is for bind socket
271 273
}
272 274 273 275
sockaddr_any scl;
274 276 275 -
SRTSOCKET m_sock = srt_accept(m_bindsock, scl.get(), &scl.len);
277 +
SRTSOCKET m_sock = srt_accept(m_bindsock, scl.get(), &scl.len);
276 278
if (m_sock == -1)
277 279
{
278 280
std::cout << "srt_accept: " << srt_getlasterror_str() << std::endl;
279 281
}
280 -
ASSERT_NE(m_sock, SRT_INVALID_SOCK);
282 +
ASSERT_NE(m_sock, SRT_INVALID_SOCK);
281 283 282 284
sockaddr_any showacp = (sockaddr*)&scl;
283 285
std::cout << "Accepted from: " << showacp.str() << std::endl;
@@ -308,7 +310,7 @@ void serverSocket(std::string ip, int port, bool expect_success)
308 310
char pattern[4] = {1, 2, 3, 4};
309 311 310 312
ASSERT_EQ(srt_recvmsg(m_sock, buffer, sizeof buffer),
311 -
1316);
313 +
1316);
312 314 313 315
EXPECT_EQ(memcmp(pattern, buffer, sizeof pattern), 0);
314 316 RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4