3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-10 07:56:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix socket creation above sistem limits for all 'other' OS not covered by eventfd, windows or vms; enhanced test to create sockets up to a bigger limit to really test hitting the OS limit

Browse Source
This commit is contained in:
Bruno D. Rodrigues 2013-11-10 10:19:19 +00:00
parent 2b989ded67
commit 750426037d
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/signaler.cpp
View File

@ -474,7 +474,7 @@ int zmq::signaler_t::make_fdpair (fd_t *r_, fd_t *w_)
int rc = socketpair (AF_UNIX, SOCK_STREAM, 0, sv); int rc = socketpair (AF_UNIX, SOCK_STREAM, 0, sv);
if (rc == -1) { if (rc == -1) {
errno_assert (errno == ENFILE || errno == EMFILE); errno_assert (errno == ENFILE || errno == EMFILE);
sv [0] = sv [1] = -1; *w_ = *r_ = -1;
return -1; return -1;
} }
else { else {

3
tests/test_many_sockets.cpp
View File

@ -22,13 +22,14 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
const int no_of_sockets = 5000; const int no_of_sockets = 2 * 65536;
int main(void) int main(void)
{ {
setup_test_environment(); setup_test_environment();
void *ctx = zmq_ctx_new(); void *ctx = zmq_ctx_new();
zmq_ctx_set(ctx, ZMQ_MAX_SOCKETS, no_of_sockets);
void *sockets[no_of_sockets]; void *sockets[no_of_sockets];
int sockets_created = 0; int sockets_created = 0;