aboutsummaryrefslogtreecommitdiff
path: root/tests/reqrep.c
diff options
context:
space:
mode:
Diffstat (limited to 'tests/reqrep.c')
-rw-r--r--tests/reqrep.c220
1 files changed, 105 insertions, 115 deletions
diff --git a/tests/reqrep.c b/tests/reqrep.c
index cadd0a5f..447060b0 100644
--- a/tests/reqrep.c
+++ b/tests/reqrep.c
@@ -8,147 +8,137 @@
//
#include "convey.h"
-#include "core/nng_impl.h"
#include "nng.h"
#include <string.h>
-Main({
+TestMain("REQ/REP pattern", {
int rv;
const char *addr = "inproc://test";
- nni_init();
+ Convey("We can create a REQ socket", {
+ nng_socket req;
- Test("REQ/REP pattern", {
- Convey("We can create a REQ socket", {
- nng_socket req;
+ So(nng_req_open(&req) == 0);
- So(nng_req_open(&req) == 0);
+ Reset({ nng_close(req); });
- Reset({ nng_close(req); });
+ Convey("Protocols match", {
+ So(nng_protocol(req) == NNG_PROTO_REQ);
+ So(nng_peer(req) == NNG_PROTO_REP);
+ });
+
+ Convey("Recv with no send fails", {
+ nng_msg *msg;
+ rv = nng_recvmsg(req, &msg, 0);
+ So(rv == NNG_ESTATE);
+ });
+ });
- Convey("Protocols match", {
- So(nng_protocol(req) == NNG_PROTO_REQ);
- So(nng_peer(req) == NNG_PROTO_REP);
- });
+ Convey("We can create a REP socket", {
+ nng_socket rep;
+ So(nng_rep_open(&rep) == 0);
- Convey("Recv with no send fails", {
- nng_msg *msg;
- rv = nng_recvmsg(req, &msg, 0);
- So(rv == NNG_ESTATE);
- });
+ Reset({ nng_close(rep); });
+
+ Convey("Protocols match", {
+ So(nng_protocol(rep) == NNG_PROTO_REP);
+ So(nng_peer(rep) == NNG_PROTO_REQ);
});
- Convey("We can create a REP socket", {
- nng_socket rep;
- So(nng_rep_open(&rep) == 0);
-
- Reset({ nng_close(rep); });
-
- Convey("Protocols match", {
- So(nng_protocol(rep) == NNG_PROTO_REP);
- So(nng_peer(rep) == NNG_PROTO_REQ);
- });
-
- Convey("Send with no recv fails", {
- nng_msg *msg;
- rv = nng_msg_alloc(&msg, 0);
- So(rv == 0);
- rv = nng_sendmsg(rep, msg, 0);
- So(rv == NNG_ESTATE);
- nng_msg_free(msg);
- });
+ Convey("Send with no recv fails", {
+ nng_msg *msg;
+ rv = nng_msg_alloc(&msg, 0);
+ So(rv == 0);
+ rv = nng_sendmsg(rep, msg, 0);
+ So(rv == NNG_ESTATE);
+ nng_msg_free(msg);
});
+ });
+
+ Convey("We can create a linked REQ/REP pair", {
+ nng_socket req;
+ nng_socket rep;
+
+ So(nng_rep_open(&rep) == 0);
- Convey("We can create a linked REQ/REP pair", {
- nng_socket req;
- nng_socket rep;
-
- So(nng_rep_open(&rep) == 0);
-
- So(nng_req_open(&req) == 0);
-
- Reset({
- nng_close(rep);
- nng_close(req);
- });
-
- So(nng_listen(rep, addr, NULL, NNG_FLAG_SYNCH) == 0);
- So(nng_dial(req, addr, NULL, NNG_FLAG_SYNCH) == 0);
-
- Convey("They can REQ/REP exchange", {
- nng_msg *ping;
- nng_msg *pong;
-
- So(nng_msg_alloc(&ping, 0) == 0);
- So(nng_msg_append(ping, "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);
- 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);
- So(nng_msg_len(ping) == 5);
- So(memcmp(nng_msg_body(ping), "pong", 5) == 0);
- nng_msg_free(ping);
- });
+ So(nng_req_open(&req) == 0);
+
+ Reset({
+ nng_close(rep);
+ nng_close(req);
});
- Convey("Request cancellation works", {
- nng_msg *abc;
- nng_msg *def;
- nng_msg *cmd;
- uint64_t retry = 100000; // 100 ms
- size_t len;
+ So(nng_listen(rep, addr, NULL, NNG_FLAG_SYNCH) == 0);
+ So(nng_dial(req, addr, NULL, NNG_FLAG_SYNCH) == 0);
+
+ Convey("They can REQ/REP exchange", {
+ nng_msg *ping;
+ nng_msg *pong;
+
+ So(nng_msg_alloc(&ping, 0) == 0);
+ So(nng_msg_append(ping, "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);
+ 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);
+ So(nng_msg_len(ping) == 5);
+ So(memcmp(nng_msg_body(ping), "pong", 5) == 0);
+ nng_msg_free(ping);
+ });
+ });
- nng_socket req;
- nng_socket rep;
+ Convey("Request cancellation works", {
+ nng_msg *abc;
+ nng_msg *def;
+ nng_msg *cmd;
+ uint64_t retry = 100000; // 100 ms
- So(nng_rep_open(&rep) == 0);
+ nng_socket req;
+ nng_socket rep;
- So(nng_req_open(&req) == 0);
+ So(nng_rep_open(&rep) == 0);
- Reset({
- nng_close(rep);
- nng_close(req);
- });
+ So(nng_req_open(&req) == 0);
- So(nng_setopt(req, NNG_OPT_RESENDTIME, &retry,
- sizeof(retry)) == 0);
- len = 16;
- So(nng_setopt(
- req, NNG_OPT_SNDBUF, &len, sizeof(len)) == 0);
+ Reset({
+ nng_close(rep);
+ nng_close(req);
+ });
- So(nng_msg_alloc(&abc, 0) == 0);
- So(nng_msg_append(abc, "abc", 4) == 0);
- So(nng_msg_alloc(&def, 0) == 0);
- So(nng_msg_append(def, "def", 4) == 0);
+ So(nng_setopt_duration(req, NNG_OPT_RESENDTIME, retry) == 0);
+ So(nng_setopt_int(req, NNG_OPT_SNDBUF, 16) == 0);
- So(nng_listen(rep, addr, NULL, NNG_FLAG_SYNCH) == 0);
- So(nng_dial(req, addr, NULL, 0) == 0);
+ So(nng_msg_alloc(&abc, 0) == 0);
+ So(nng_msg_append(abc, "abc", 4) == 0);
+ So(nng_msg_alloc(&def, 0) == 0);
+ So(nng_msg_append(def, "def", 4) == 0);
- So(nng_sendmsg(req, abc, 0) == 0);
- So(nng_sendmsg(req, def, 0) == 0);
- So(nng_recvmsg(rep, &cmd, 0) == 0);
- So(cmd != NULL);
+ So(nng_listen(rep, addr, NULL, NNG_FLAG_SYNCH) == 0);
+ So(nng_dial(req, addr, NULL, 0) == 0);
- So(nng_sendmsg(rep, cmd, 0) == 0);
- So(nng_recvmsg(rep, &cmd, 0) == 0);
- So(nng_sendmsg(rep, cmd, 0) == 0);
- So(nng_recvmsg(req, &cmd, 0) == 0);
+ So(nng_sendmsg(req, abc, 0) == 0);
+ So(nng_sendmsg(req, def, 0) == 0);
+ So(nng_recvmsg(rep, &cmd, 0) == 0);
+ So(cmd != NULL);
- So(nng_msg_len(cmd) == 4);
- So(memcmp(nng_msg_body(cmd), "def", 4) == 0);
- nng_msg_free(cmd);
- });
- });
+ So(nng_sendmsg(rep, cmd, 0) == 0);
+ So(nng_recvmsg(rep, &cmd, 0) == 0);
+ So(nng_sendmsg(rep, cmd, 0) == 0);
+ So(nng_recvmsg(req, &cmd, 0) == 0);
- nni_fini();
+ So(nng_msg_len(cmd) == 4);
+ So(memcmp(nng_msg_body(cmd), "def", 4) == 0);
+ nng_msg_free(cmd);
+ });
+ nng_fini();
})
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-18 18:45:35 +0000