diff options
| author | Garrett D'Amore <garrett@damore.org> | 2018-04-30 21:41:40 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2018-05-01 12:27:19 -0700 |
| commit | 4998964a435fe0f02a2d81b01fdb837214674e72 (patch) | |
| tree | dc5fe29da0574fc1510ab6f9b23b54ffd68cd97b /tests/pair1.c | |
| parent | 63bdb2c28bc185096e579d1922d57cb71ecaa36b (diff) | |
| download | nng-4998964a435fe0f02a2d81b01fdb837214674e72.tar.gz nng-4998964a435fe0f02a2d81b01fdb837214674e72.tar.bz2 nng-4998964a435fe0f02a2d81b01fdb837214674e72.zip | |
fixes #381 Want comparators for various types
Diffstat (limited to 'tests/pair1.c')
| -rw-r--r-- | tests/pair1.c | 36 |
1 files changed, 22 insertions, 14 deletions
diff --git a/tests/pair1.c b/tests/pair1.c index 8a27bc6e..c777725c 100644 --- a/tests/pair1.c +++ b/tests/pair1.c @@ -28,14 +28,13 @@ TestMain("PAIRv1 protocol", { const char * templ = "inproc://pairv1/%u"; char addr[NNG_MAXADDRLEN + 1]; - nng_socket s1; - nng_socket c1; - nng_socket c2; + nng_socket s1 = NNG_SOCKET_INITIALIZER; + nng_socket c1 = NNG_SOCKET_INITIALIZER; + nng_socket c2 = NNG_SOCKET_INITIALIZER; nng_duration tmo; uint32_t v; size_t sz; - s1.id = c1.id = c2.id = 0; atexit(nng_fini); Convey("Given a few sockets", { @@ -44,6 +43,13 @@ TestMain("PAIRv1 protocol", { So(nng_pair1_open(&c1) == 0); So(nng_pair1_open(&c2) == 0); + So(nng_socket_id(s1) > 0); + So(nng_socket_id(c1) > 0); + So(nng_socket_id(c2) > 0); + So(nng_socket_id(s1) != nng_socket_id(c1)); + So(nng_socket_id(s1) != nng_socket_id(c2)); + So(nng_socket_id(c1) != nng_socket_id(c2)); + Reset({ nng_close(s1); nng_close(c1); @@ -211,7 +217,7 @@ TestMain("PAIRv1 protocol", { So(nng_recvmsg(s1, &msg, 0) == 0); CHECKSTR(msg, "ONE"); p1 = nng_msg_get_pipe(msg); - So(p1.id != 0); + So(nng_pipe_id(p1) > 0); nng_msg_free(msg); So(nng_msg_alloc(&msg, 0) == 0); @@ -220,10 +226,10 @@ TestMain("PAIRv1 protocol", { So(nng_recvmsg(s1, &msg, 0) == 0); CHECKSTR(msg, "TWO"); p2 = nng_msg_get_pipe(msg); - So(p2.id != 0); + So(nng_pipe_id(p2) > 0); nng_msg_free(msg); - So(p1.id != p2.id); + So(nng_pipe_id(p1) != nng_pipe_id(p2)); So(nng_msg_alloc(&msg, 0) == 0); @@ -308,7 +314,7 @@ TestMain("PAIRv1 protocol", { nng_msleep(20); Convey("Send/recv work", { - nng_pipe p; + nng_pipe p = NNG_PIPE_INITIALIZER; So(nng_msg_alloc(&msg, 0) == 0); APPENDSTR(msg, "GAMMA"); So(nng_msg_header_append_u32(msg, 1) == 0); @@ -316,7 +322,8 @@ TestMain("PAIRv1 protocol", { So(nng_sendmsg(c1, msg, 0) == 0); So(nng_recvmsg(s1, &msg, 0) == 0); p = nng_msg_get_pipe(msg); - So(p.id != 0); + So(nng_pipe_id(p) > 0); + CHECKSTR(msg, "GAMMA"); So(nng_msg_header_len(msg) == sizeof(uint32_t)); So(nng_msg_header_trim_u32(msg, &hops) == 0); @@ -332,7 +339,8 @@ TestMain("PAIRv1 protocol", { So(nng_msg_header_len(msg) == sizeof(uint32_t)); So(nng_msg_header_trim_u32(msg, &hops) == 0); p = nng_msg_get_pipe(msg); - So(p.id != 0); + So(nng_pipe_id(p) > 0); + So(hops == 2); nng_msg_free(msg); }); @@ -474,7 +482,7 @@ TestMain("PAIRv1 protocol", { So(nng_recvmsg(s1, &msg, 0) == 0); CHECKSTR(msg, "ONE"); p1 = nng_msg_get_pipe(msg); - So(p1.id != 0); + So(nng_pipe_id(p1) > 0); So(nng_msg_header_trim_u32(msg, &hops) == 0); So(hops == 1); nng_msg_free(msg); @@ -485,12 +493,12 @@ TestMain("PAIRv1 protocol", { So(nng_recvmsg(s1, &msg, 0) == 0); CHECKSTR(msg, "TWO"); p2 = nng_msg_get_pipe(msg); - So(p2.id != 0); + So(nng_pipe_id(p2) > 0); So(nng_msg_header_trim_u32(msg, &hops) == 0); So(hops == 1); nng_msg_free(msg); - So(p1.id != p2.id); + So(nng_pipe_id(p1) != nng_pipe_id(p2)); So(nng_msg_alloc(&msg, 0) == 0); nng_msg_set_pipe(msg, p1); @@ -518,7 +526,7 @@ TestMain("PAIRv1 protocol", { So(nng_recvmsg(s1, &msg, 0) == 0); CHECKSTR(msg, "ONE"); p1 = nng_msg_get_pipe(msg); - So(p1.id != 0); + So(nng_pipe_id(p1) > 0); nng_msg_free(msg); nng_close(c1); |