summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2012-05-03 16:19:44 +0200
committerMartin Sustrik <sustrik@250bpm.com>2012-05-04 14:36:14 +0200
commit4e6a1e5508151d308a53124e4733ae1c1f7b3fb2 (patch)
treeed90faeb2b49988f11b2a03be9677dece58fc5b5
parent5bba016135cdc13e0f5b537807c516d5f1089d1b (diff)
Test for backlog exhaustion added
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
-rw-r--r--builds/msvc/tests/tests.vcxproj4
-rw-r--r--builds/msvc/tests/tests.vcxproj.filters3
-rw-r--r--tests/Makefile.am4
-rw-r--r--tests/backlog.cpp134
-rw-r--r--tests/tests.cpp6
5 files changed, 150 insertions, 1 deletions
diff --git a/builds/msvc/tests/tests.vcxproj b/builds/msvc/tests/tests.vcxproj
index 20d2554..5c5df84 100644
--- a/builds/msvc/tests/tests.vcxproj
+++ b/builds/msvc/tests/tests.vcxproj
@@ -83,6 +83,10 @@
</Link>
</ItemDefinitionGroup>
<ItemGroup>
+ <ClCompile Include="..\..\..\tests\backlog.cpp">
+ <ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">true</ExcludedFromBuild>
+ <ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">true</ExcludedFromBuild>
+ </ClCompile>
<ClCompile Include="..\..\..\tests\emptyctx.cpp">
<ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">true</ExcludedFromBuild>
<ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">true</ExcludedFromBuild>
diff --git a/builds/msvc/tests/tests.vcxproj.filters b/builds/msvc/tests/tests.vcxproj.filters
index ea97fed..030aed7 100644
--- a/builds/msvc/tests/tests.vcxproj.filters
+++ b/builds/msvc/tests/tests.vcxproj.filters
@@ -71,6 +71,9 @@
<ClCompile Include="..\..\..\tests\shutdown.cpp">
<Filter>Header Files</Filter>
</ClCompile>
+ <ClCompile Include="..\..\..\tests\backlog.cpp">
+ <Filter>Header Files</Filter>
+ </ClCompile>
</ItemGroup>
<ItemGroup>
<Filter Include="Header Files">
diff --git a/tests/Makefile.am b/tests/Makefile.am
index 4e08ae7..71442a2 100644
--- a/tests/Makefile.am
+++ b/tests/Makefile.am
@@ -25,7 +25,8 @@ noinst_PROGRAMS = pair_inproc \
libzmq21 \
resubscribe \
survey \
- shutdown
+ shutdown \
+ backlog
pair_inproc_SOURCES = pair_inproc.cpp testutil.hpp
pair_tcp_SOURCES = pair_tcp.cpp testutil.hpp
@@ -50,5 +51,6 @@ libzmq21_SOURCES = libzmq21.cpp
resubscribe_SOURCES = resubscribe.cpp
survey_SOURCES = survey.cpp
shutdown_SOURCES = shutdown.cpp
+backlog_SOURCES = backlog.cpp
TESTS = $(noinst_PROGRAMS)
diff --git a/tests/backlog.cpp b/tests/backlog.cpp
new file mode 100644
index 0000000..7ae9ed8
--- /dev/null
+++ b/tests/backlog.cpp
@@ -0,0 +1,134 @@
+/*
+ Copyright (c) 2012 250bpm s.r.o.
+ Copyright (c) 2012 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 <http://www.gnu.org/licenses/>.
+*/
+
+#include "testutil.hpp"
+
+#define BACKLOG 10
+#define PARALLEL_CONNECTS 50
+
+extern "C"
+{
+
+#if !defined XS_HAVE_WINDOWS && !defined XS_HAVE_OPENVMS
+ static void ipc_worker (void *ctx_)
+ {
+ int rc;
+ void *push;
+
+ push = xs_socket (ctx_, XS_PUSH);
+ assert (push);
+ rc = xs_connect (push, "ipc:///tmp/test-backlog");
+ assert (rc >= 0);
+ rc = xs_send (push, NULL, 0, 0);
+ assert (rc == 0);
+ rc = xs_close (push);
+ assert (rc == 0);
+ }
+#endif
+
+ static void tcp_worker (void *ctx_)
+ {
+ int rc;
+ void *push;
+
+ push = xs_socket (ctx_, XS_PUSH);
+ assert (push);
+ rc = xs_connect (push, "tcp://127.0.0.1:5560");
+ assert (rc >= 0);
+ rc = xs_send (push, NULL, 0, 0);
+ assert (rc == 0);
+ rc = xs_close (push);
+ assert (rc == 0);
+ }
+}
+
+int XS_TEST_MAIN ()
+{
+ fprintf (stderr, "backlog test running...\n");
+
+ int rc;
+ void *ctx;
+ void *pull;
+ int i;
+ int backlog;
+ void *threads [PARALLEL_CONNECTS];
+
+ // Test the exhaustion on IPC backlog.
+#if !defined XS_HAVE_WINDOWS && !defined XS_HAVE_OPENVMS
+ ctx = xs_init ();
+ assert (ctx);
+
+ pull = xs_socket (ctx, XS_PULL);
+ assert (pull);
+ backlog = BACKLOG;
+ rc = xs_setsockopt (pull, XS_BACKLOG, &backlog, sizeof (backlog));
+ assert (rc == 0);
+ rc = xs_bind (pull, "ipc:///tmp/test-backlog");
+ assert (rc >= 0);
+
+
+ for (i = 0; i < PARALLEL_CONNECTS; i++)
+ threads [i] = thread_create (ipc_worker, ctx);
+
+ for (i = 0; i < PARALLEL_CONNECTS; i++) {
+ rc = xs_recv (pull, NULL, 0, 0);
+ assert (rc == 0);
+ }
+
+ rc = xs_close (pull);
+ assert (rc == 0);
+ rc = xs_term (ctx);
+ assert (rc == 0);
+
+ for (i = 0; i < PARALLEL_CONNECTS; i++)
+ thread_join (threads [i]);
+#endif
+
+ // Test the exhaustion on TCP backlog.
+
+ ctx = xs_init ();
+ assert (ctx);
+
+ pull = xs_socket (ctx, XS_PULL);
+ assert (pull);
+ backlog = BACKLOG;
+ rc = xs_setsockopt (pull, XS_BACKLOG, &backlog, sizeof (backlog));
+ assert (rc == 0);
+ rc = xs_bind (pull, "tcp://127.0.0.1:5560");
+ assert (rc >= 0);
+
+ for (i = 0; i < PARALLEL_CONNECTS; i++)
+ threads [i] = thread_create (tcp_worker, ctx);
+
+ for (i = 0; i < PARALLEL_CONNECTS; i++) {
+ rc = xs_recv (pull, NULL, 0, 0);
+ assert (rc == 0);
+ }
+
+ rc = xs_close (pull);
+ assert (rc == 0);
+ rc = xs_term (ctx);
+ assert (rc == 0);
+
+ for (i = 0; i < PARALLEL_CONNECTS; i++)
+ thread_join (threads [i]);
+
+ return 0;
+}
diff --git a/tests/tests.cpp b/tests/tests.cpp
index 6474300..4071056 100644
--- a/tests/tests.cpp
+++ b/tests/tests.cpp
@@ -119,6 +119,10 @@
#include "shutdown.cpp"
#undef XS_TEST_MAIN
+#define XS_TEST_MAIN backlog
+#include "backlog.cpp"
+#undef XS_TEST_MAIN
+
int main ()
{
int rc;
@@ -167,6 +171,8 @@ int main ()
assert (rc == 0);
rc = shutdown ();
assert (rc == 0);
+ rc = backlog ();
+ assert (rc == 0);
fprintf (stderr, "SUCCESS\n");
sleep (1);