From 802d84df533c131f91fbc599dae915390fad3e2b Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Thu, 16 Feb 2012 10:05:52 +0900 Subject: Redundant test_ prefix removed from tests Signed-off-by: Martin Sustrik --- tests/test_shutdown_stress.cpp | 90 ------------------------------------------ 1 file changed, 90 deletions(-) delete mode 100644 tests/test_shutdown_stress.cpp (limited to 'tests/test_shutdown_stress.cpp') diff --git a/tests/test_shutdown_stress.cpp b/tests/test_shutdown_stress.cpp deleted file mode 100644 index 7c36106..0000000 --- a/tests/test_shutdown_stress.cpp +++ /dev/null @@ -1,90 +0,0 @@ -/* - 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 project. - - Crossroads 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" - -#include -#include - -#define THREAD_COUNT 100 - -extern "C" -{ - static void *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); - - return NULL; - } -} - -int XS_TEST_MAIN () -{ - void *ctx; - void *s1; - void *s2; - int i; - int j; - int rc; - pthread_t threads [THREAD_COUNT]; - - fprintf (stderr, "test_shutdown_stress running...\n"); - - for (j = 0; j != 10; j++) { - - // Check the shutdown with many parallel I/O threads. - ctx = xs_init (7); - assert (ctx); - - 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); - assert (s2); - rc = pthread_create (&threads [i], NULL, worker, s2); - assert (rc == 0); - } - - for (i = 0; i != THREAD_COUNT; i++) { - rc = pthread_join (threads [i], NULL); - assert (rc == 0); - } - - rc = xs_close (s1); - assert (rc == 0); - - rc = xs_term (ctx); - assert (rc == 0); - } - - return 0; -} -- cgit v1.2.3