3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-27 15:41:05 +08:00
Code Issues Projects Releases Wiki Activity

Problem: test_stream_exceeds_buffer cannot be ran in parallel

Browse Source 
Solution: bind to wildcard and let the OS pick a free port instead
of using an hard-coded 12345 TCP port
This commit is contained in:
Luca Boccassi 2017-11-09 23:37:09 +00:00
parent e10b350630
commit 498c6bbb67
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/test_stream_exceeds_buffer.cpp
View File

@ -41,6 +41,7 @@ int main()
const int msgsize = 8193; const int msgsize = 8193;
char sndbuf[msgsize] = "\xde\xad\xbe\xef"; char sndbuf[msgsize] = "\xde\xad\xbe\xef";
unsigned char rcvbuf[msgsize]; unsigned char rcvbuf[msgsize];
char my_endpoint[MAX_SOCKET_STRING];
int server_sock = socket(AF_INET, SOCK_STREAM, 0); int server_sock = socket(AF_INET, SOCK_STREAM, 0);
assert(server_sock!=-1); assert(server_sock!=-1);
@ -52,18 +53,29 @@ int main()
memset(&saddr, 0, sizeof(saddr)); memset(&saddr, 0, sizeof(saddr));
saddr.sin_family = AF_INET; saddr.sin_family = AF_INET;
saddr.sin_addr.s_addr = INADDR_ANY; saddr.sin_addr.s_addr = INADDR_ANY;
#if !defined (_WIN32_WINNT) || (_WIN32_WINNT >= 0x0600)
saddr.sin_port = 0;
#else
saddr.sin_port = htons(12345); saddr.sin_port = htons(12345);
#endif
rc = bind(server_sock, (struct sockaddr *)&saddr, sizeof(saddr)); rc = bind(server_sock, (struct sockaddr *)&saddr, sizeof(saddr));
assert(rc!=-1); assert(rc!=-1);
rc = listen(server_sock, 1); rc = listen(server_sock, 1);
assert(rc!=-1); assert(rc!=-1);
#if !defined (_WIN32_WINNT) || (_WIN32_WINNT >= 0x0600)
socklen_t saddr_len = sizeof (saddr);
rc = getsockname (server_sock, (struct sockaddr *)&saddr, &saddr_len);
assert (rc != -1);
#endif
sprintf (my_endpoint, "tcp://127.0.0.1:%d", ntohs(saddr.sin_port));
void *zctx = zmq_ctx_new(); void *zctx = zmq_ctx_new();
assert(zctx); assert(zctx);
void *zsock = zmq_socket(zctx, ZMQ_STREAM); void *zsock = zmq_socket(zctx, ZMQ_STREAM);
assert(zsock); assert(zsock);
rc = zmq_connect(zsock, "tcp://127.0.0.1:12345"); rc = zmq_connect(zsock, my_endpoint);
assert(rc!=-1); assert(rc!=-1);
int client_sock = accept(server_sock, NULL, NULL); int client_sock = accept(server_sock, NULL, NULL);