summaryrefslogtreecommitdiff
path: root/tests/shutdown_stress.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2012-03-13 11:10:33 +0100
committerMartin Sustrik <sustrik@250bpm.com>2012-03-13 11:10:33 +0100
commit921da22147e201455837bcd38df1af33aceff26f (patch)
treee76e001ac65d4fa96ab89468e109db05978b7f70 /tests/shutdown_stress.cpp
parent224b7c7a816010fc0f781372051ec7c578af42a0 (diff)
io_threads argument removed from xs_init()
The argument was changed to a context option (XS_IO_THREADS). 0MQ compatibility mode sets the option and ensures that there's at least one I/O thread present. Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'tests/shutdown_stress.cpp')
-rw-r--r--tests/shutdown_stress.cpp7
1 files changed, 6 insertions, 1 deletions
diff --git a/tests/shutdown_stress.cpp b/tests/shutdown_stress.cpp
index c0816cd..d7dffe8 100644
--- a/tests/shutdown_stress.cpp
+++ b/tests/shutdown_stress.cpp
@@ -46,6 +46,7 @@ int XS_TEST_MAIN ()
int i;
int j;
int rc;
+ int io_threads;
void *threads [THREAD_COUNT];
fprintf (stderr, "shutdown_stress test running...\n");
@@ -53,8 +54,12 @@ int XS_TEST_MAIN ()
for (j = 0; j != 10; j++) {
// Check the shutdown with many parallel I/O threads.
- ctx = xs_init (7);
+ 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);