diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-06 08:18:50 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-06 08:21:09 -0800 |
| commit | a2801adffebb6a3679e41789b38ba925ed32832b (patch) | |
| tree | 8e3a743301fedb04d19d9af3e30f5622b737c337 /tests/reqrep.c | |
| parent | 601d7a6ca95678613ca576258314f50a6e5e742c (diff) | |
| download | nng-a2801adffebb6a3679e41789b38ba925ed32832b.tar.gz nng-a2801adffebb6a3679e41789b38ba925ed32832b.tar.bz2 nng-a2801adffebb6a3679e41789b38ba925ed32832b.zip | |
Message API was awkward.
The use of a single function to get both size and length actually
turned out to be awkward to use; better to have separate functions
to get each. While here, disable some of the initialization/fork
checks, because it turns out they aren't needed.
Diffstat (limited to 'tests/reqrep.c')
| -rw-r--r-- | tests/reqrep.c | 25 |
1 files changed, 9 insertions, 16 deletions
diff --git a/tests/reqrep.c b/tests/reqrep.c index d182559d..1bdef4fd 100644 --- a/tests/reqrep.c +++ b/tests/reqrep.c @@ -91,30 +91,25 @@ Main({ Convey("They can REQ/REP exchange", { nng_msg *ping; nng_msg *pong; - char *body; - size_t len; So(nng_msg_alloc(&ping, 0) == 0); So(nng_msg_append(ping, "ping", 5) == 0); - body = nng_msg_body(ping, &len); - So(len == 5); - So(memcmp(body, "ping", 5) == 0); + So(nng_msg_len(ping) == 5); + So(memcmp(nng_msg_body(ping), "ping", 5) == 0); So(nng_sendmsg(req, ping, 0) == 0); pong = NULL; So(nng_recvmsg(rep, &pong, 0) == 0); So(pong != NULL); - body = nng_msg_body(pong, &len); - So(len == 5); - So(memcmp(body, "ping", 5) == 0); + So(nng_msg_len(pong) == 5); + So(memcmp(nng_msg_body(pong), "ping", 5) == 0); nng_msg_trim(pong, 5); So(nng_msg_append(pong, "pong", 5) == 0); So(nng_sendmsg(rep, pong, 0) == 0); ping = 0; So(nng_recvmsg(req, &ping, 0) == 0); So(ping != NULL); - body = nng_msg_body(ping, &len); - So(len == 5); - So(memcmp(body, "pong", 5) == 0); + So(nng_msg_len(ping) == 5); + So(memcmp(nng_msg_body(ping), "pong", 5) == 0); nng_msg_free(ping); }) }) @@ -124,9 +119,8 @@ Main({ nng_msg *def; nng_msg *cmd; nng_msg *nvm; - char *body; - size_t len; uint64_t retry = 100000; // 100 ms + size_t len; nng_socket *req; nng_socket *rep; @@ -166,9 +160,8 @@ Main({ So(nng_recvmsg(req, &cmd, 0) == 0); - body = nng_msg_body(cmd, &len); - So(len == 4); - So(memcmp(body, "def", 4) == 0); + So(nng_msg_len(cmd) == 4); + So(memcmp(nng_msg_body(cmd), "def", 4) == 0); nng_msg_free(cmd); }) }) |
