summaryrefslogtreecommitdiff
path: root/tests/wireformat.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/wireformat.cpp')
-rw-r--r--tests/wireformat.cpp34
1 files changed, 17 insertions, 17 deletions
diff --git a/tests/wireformat.cpp b/tests/wireformat.cpp
index f3e0f96..ad690d5 100644
--- a/tests/wireformat.cpp
+++ b/tests/wireformat.cpp
@@ -42,17 +42,17 @@ int XS_TEST_MAIN ()
// Create the basic infrastructure.
void *ctx = xs_init ();
- assert (ctx);
+ errno_assert (ctx);
void *push = xs_socket (ctx, XS_PUSH);
- assert (push);
+ errno_assert (push);
void *pull = xs_socket (ctx, XS_PULL);
- assert (push);
+ errno_assert (push);
// Bind the peer and get the message.
int rc = xs_bind (pull, "tcp://127.0.0.1:5560");
- assert (rc != -1);
+ errno_assert (rc != -1);
rc = xs_bind (push, "tcp://127.0.0.1:5561");
- assert (rc != -1);
+ errno_assert (rc != -1);
// Connect to the peer using raw sockets.
int rpush = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
@@ -60,30 +60,30 @@ int XS_TEST_MAIN ()
address.sin_family = AF_INET;
address.sin_addr.s_addr = inet_addr ("127.0.0.1");
address.sin_port = htons (5560);
- rc = connect(rpush, (struct sockaddr*) &address, sizeof (address));
- assert (rc == 0);
+ rc = connect (rpush, (struct sockaddr*) &address, sizeof (address));
+ errno_assert (rc == 0);
int rpull = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
address.sin_family = AF_INET;
address.sin_addr.s_addr = inet_addr ("127.0.0.1");
address.sin_port = htons (5561);
rc = connect (rpull, (struct sockaddr*) &address, sizeof (address));
- assert (rc == 0);
+ errno_assert (rc == 0);
// Let's send some data and check if it arrived
rc = send (rpush, "\x04\0abc", 5, 0);
- assert (rc == 5);
+ errno_assert (rc == 5);
unsigned char buf [3];
unsigned char buf2 [3];
rc = xs_recv (pull, buf, sizeof (buf), 0);
- assert (rc == 3);
+ errno_assert (rc == 3);
assert (!memcmp (buf, "abc", 3));
// Let's push this data into another socket
rc = xs_send (push, buf, sizeof (buf), 0);
- assert (rc == 3);
+ errno_assert (rc == 3);
rc = recv (rpull, (char*) buf2, sizeof (buf2), 0);
- assert (rc == 3);
+ errno_assert (rc == 3);
assert (!memcmp (buf2, "\x04\0abc", 3));
#if defined XS_HAVE_WINDOWS
@@ -94,17 +94,17 @@ int XS_TEST_MAIN ()
WSACleanup ();
#else
rc = close (rpush);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = close (rpull);
- assert (rc == 0);
+ errno_assert (rc == 0);
#endif
rc = xs_close (pull);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = xs_close (push);
- assert (rc == 0);
+ errno_assert (rc == 0);
rc = xs_term (ctx);
- assert (rc == 0);
+ errno_assert (rc == 0);
return 0 ;
}