/* Copyright (c) 2010-2012 250bpm s.r.o. Copyright (c) 2011 iMatix Corporation Copyright (c) 2010-2011 Other contributors as noted in the AUTHORS file This file is part of Crossroads I/O project. Crossroads I/O is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version. Crossroads is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this program. If not, see . */ #include "testutil.hpp" #define THREAD_COUNT 100 extern "C" { static void shutdown_stress_worker (void *s_) { int rc; rc = xs_connect (s_, "tcp://127.0.0.1:5560"); assert (rc == 0); // Start closing the socket while the connecting process is underway. rc = xs_close (s_); assert (rc == 0); } } int XS_TEST_MAIN () { void *ctx; void *s1; void *s2; int i; int j; int rc; int io_threads; void *threads [THREAD_COUNT]; fprintf (stderr, "shutdown_stress test running...\n"); for (j = 0; j != 10; j++) { // Check the shutdown with many parallel I/O threads. ctx = xs_init (); assert (ctx); io_threads = 7; rc = xs_setctxopt (ctx, XS_IO_THREADS, &io_threads, sizeof (io_threads)); assert (rc == 0); s1 = xs_socket (ctx, XS_PUB); assert (s1); rc = xs_bind (s1, "tcp://127.0.0.1:5560"); assert (rc == 0); for (i = 0; i != THREAD_COUNT; i++) { s2 = xs_socket (ctx, XS_SUB); if (!s2 && (errno == EMFILE || errno == ENFILE)) threads [i] = NULL; else { assert (s2); threads [i] = thread_create (shutdown_stress_worker, s2); assert (threads [i]); } } for (i = 0; i != THREAD_COUNT; i++) if (threads [i]) thread_join (threads [i]); rc = xs_close (s1); assert (rc == 0); rc = xs_term (ctx); assert (rc == 0); } return 0; }