summaryrefslogtreecommitdiff
path: root/tests/resubscribe.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2012-06-14 08:14:09 +0200
committerMartin Sustrik <sustrik@250bpm.com>2012-06-14 08:14:09 +0200
commit0bb0d07abd789d4efa285e757efd14b3717db0a1 (patch)
treeaeb958d774ff994ac0c0c69c72dd4f3548e76cad /tests/resubscribe.cpp
parent1f6d8da319eb536782c0f9d0b30bcc085ede646f (diff)
errno errors reported in tests
Till now when a test failed the value or errno haven't been reported. This patch fixes the problem. Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'tests/resubscribe.cpp')
-rw-r--r--tests/resubscribe.cpp34
1 files changed, 17 insertions, 17 deletions
diff --git a/tests/resubscribe.cpp b/tests/resubscribe.cpp
index 5d78712..d60d1d4 100644
--- a/tests/resubscribe.cpp
+++ b/tests/resubscribe.cpp
@@ -26,33 +26,33 @@ int XS_TEST_MAIN ()
// Create the basic infrastructure.
void *ctx = xs_init ();
- assert (ctx);
+ errno_assert (ctx);
void *xpub = xs_socket (ctx, XS_XPUB);
- assert (xpub);
+ errno_assert (xpub);
void *sub = xs_socket (ctx, XS_SUB);
- assert (sub);
+ errno_assert (sub);
// Send two subscriptions upstream.
int rc = xs_bind (xpub, "tcp://127.0.0.1:5560");
- assert (rc != -1);
+ errno_assert (rc != -1);
rc = xs_setsockopt (sub, XS_SUBSCRIBE, "a", 1);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = xs_setsockopt (sub, XS_SUBSCRIBE, "b", 1);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = xs_connect (sub, "tcp://127.0.0.1:5560");
- assert (rc != -1);
+ errno_assert (rc != -1);
// Check whether subscriptions are correctly received.
char buf [5];
rc = xs_recv (xpub, buf, sizeof (buf), 0);
- assert (rc == 5);
+ errno_assert (rc == 5);
assert (buf [0] == 0);
assert (buf [1] == 1);
assert (buf [2] == 0);
assert (buf [3] == 1);
assert (buf [4] == 'a');
rc = xs_recv (xpub, buf, sizeof (buf), 0);
- assert (rc == 5);
+ errno_assert (rc == 5);
assert (buf [0] == 0);
assert (buf [1] == 1);
assert (buf [2] == 0);
@@ -61,14 +61,14 @@ int XS_TEST_MAIN ()
// Tear down the connection.
rc = xs_close (xpub);
- assert (rc == 0);
+ errno_assert (rc == 0);
sleep (1);
// Re-establish the connection.
xpub = xs_socket (ctx, XS_XPUB);
- assert (xpub);
+ errno_assert (xpub);
rc = xs_bind (xpub, "tcp://127.0.0.1:5560");
- assert (rc != -1);
+ errno_assert (rc != -1);
// We have to give control to the SUB socket here so that it has
// chance to resend the subscriptions.
@@ -77,14 +77,14 @@ int XS_TEST_MAIN ()
// Check whether subscriptions are correctly generated.
rc = xs_recv (xpub, buf, sizeof (buf), 0);
- assert (rc == 5);
+ errno_assert (rc == 5);
assert (buf [0] == 0);
assert (buf [1] == 1);
assert (buf [2] == 0);
assert (buf [3] == 1);
assert (buf [4] == 'a');
rc = xs_recv (xpub, buf, sizeof (buf), 0);
- assert (rc == 5);
+ errno_assert (rc == 5);
assert (buf [0] == 0);
assert (buf [1] == 1);
assert (buf [2] == 0);
@@ -93,11 +93,11 @@ int XS_TEST_MAIN ()
// Clean up.
rc = xs_close (sub);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = xs_close (xpub);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = xs_term (ctx);
- assert (rc == 0);
+ errno_assert (rc == 0);
return 0 ;
}