aboutsummaryrefslogtreecommitdiff
path: root/src/sp/protocol
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2024-11-02 23:16:22 -0700
committerGarrett D'Amore <garrett@damore.org>2024-11-02 23:16:22 -0700
commit8bac5ccdf1de7334311459b9e2666e74a2c16c15 (patch)
tree169ce8229a1a0eb6e810685a9923be1c2bf644a6 /src/sp/protocol
parentd3622c0f6153ce0eccaad9c986d46b07cec91b5d (diff)
downloadnng-8bac5ccdf1de7334311459b9e2666e74a2c16c15.tar.gz
nng-8bac5ccdf1de7334311459b9e2666e74a2c16c15.tar.bz2
nng-8bac5ccdf1de7334311459b9e2666e74a2c16c15.zip
Replace `NNG_OPT_PROTO`, `NNG_OPT_PROTONAME`, and friends with functions.
Socket options were a little awkward, and these are core properties of the socket. Few if any applications need these. This also avoids some dynamic allocations.
Diffstat (limited to 'src/sp/protocol')
-rw-r--r--src/sp/protocol/bus0/bus_test.c16
-rw-r--r--src/sp/protocol/pair0/pair0_test.c16
-rw-r--r--src/sp/protocol/pair1/pair1_poly_test.c16
-rw-r--r--src/sp/protocol/pair1/pair1_test.c16
-rw-r--r--src/sp/protocol/pipeline0/pull_test.c16
-rw-r--r--src/sp/protocol/pipeline0/push_test.c16
-rw-r--r--src/sp/protocol/pubsub0/pub_test.c16
-rw-r--r--src/sp/protocol/pubsub0/sub_test.c16
-rw-r--r--src/sp/protocol/pubsub0/xsub_test.c16
-rw-r--r--src/sp/protocol/reqrep0/rep_test.c18
-rw-r--r--src/sp/protocol/reqrep0/req_test.c16
-rw-r--r--src/sp/protocol/reqrep0/xrep_test.c18
-rw-r--r--src/sp/protocol/reqrep0/xreq_test.c18
-rw-r--r--src/sp/protocol/survey0/respond_test.c16
-rw-r--r--src/sp/protocol/survey0/survey_test.c16
-rw-r--r--src/sp/protocol/survey0/xrespond_test.c18
-rw-r--r--src/sp/protocol/survey0/xsurvey_test.c16
17 files changed, 123 insertions, 157 deletions
diff --git a/src/sp/protocol/bus0/bus_test.c b/src/sp/protocol/bus0/bus_test.c
index 7e049e34..7a9e4a8b 100644
--- a/src/sp/protocol/bus0/bus_test.c
+++ b/src/sp/protocol/bus0/bus_test.c
@@ -17,21 +17,19 @@
void
test_bus_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_bus0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NNG_BUS0_SELF);
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NNG_BUS0_PEER); // 49
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, NNG_BUS0_SELF_NAME);
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, NNG_BUS0_PEER_NAME);
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pair0/pair0_test.c b/src/sp/protocol/pair0/pair0_test.c
index e2196479..0cdfb789 100644
--- a/src/sp/protocol/pair0/pair0_test.c
+++ b/src/sp/protocol/pair0/pair0_test.c
@@ -21,21 +21,19 @@
static void
test_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_pair0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(1u, 0u)); // 16
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(1u, 0u)); // 17
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "pair");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "pair");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pair1/pair1_poly_test.c b/src/sp/protocol/pair1/pair1_poly_test.c
index 895dd935..acd7f44d 100644
--- a/src/sp/protocol/pair1/pair1_poly_test.c
+++ b/src/sp/protocol/pair1/pair1_poly_test.c
@@ -20,21 +20,19 @@
static void
test_poly_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_pair1_open_poly(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(1u, 1u)); // 32
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(1u, 1u)); // 33
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "pair1");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "pair1");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pair1/pair1_test.c b/src/sp/protocol/pair1/pair1_test.c
index b6bbee1a..e0e6b3b2 100644
--- a/src/sp/protocol/pair1/pair1_test.c
+++ b/src/sp/protocol/pair1/pair1_test.c
@@ -21,21 +21,19 @@
static void
test_mono_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_pair1_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(1u, 1u)); // 32
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(1u, 1u)); // 33
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "pair1");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "pair1");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pipeline0/pull_test.c b/src/sp/protocol/pipeline0/pull_test.c
index 6be5c2f5..59dcf8a8 100644
--- a/src/sp/protocol/pipeline0/pull_test.c
+++ b/src/sp/protocol/pipeline0/pull_test.c
@@ -13,21 +13,19 @@
static void
test_pull_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_pull0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(5u, 1u)); // 81
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(5u, 0u)); // 80
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "pull");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "push");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pipeline0/push_test.c b/src/sp/protocol/pipeline0/push_test.c
index 249c62a9..be60ba50 100644
--- a/src/sp/protocol/pipeline0/push_test.c
+++ b/src/sp/protocol/pipeline0/push_test.c
@@ -13,21 +13,19 @@
static void
test_push_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_push0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(5u, 0u)); // 80
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(5u, 1u)); // 81
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "push");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "pull");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pubsub0/pub_test.c b/src/sp/protocol/pubsub0/pub_test.c
index 4be4b06f..5f0ef01e 100644
--- a/src/sp/protocol/pubsub0/pub_test.c
+++ b/src/sp/protocol/pubsub0/pub_test.c
@@ -13,21 +13,19 @@
static void
test_pub_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_pub0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(2u, 0u)); // 32
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(2u, 1u)); // 33
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "pub");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "sub");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pubsub0/sub_test.c b/src/sp/protocol/pubsub0/sub_test.c
index ef38042a..b823d486 100644
--- a/src/sp/protocol/pubsub0/sub_test.c
+++ b/src/sp/protocol/pubsub0/sub_test.c
@@ -13,21 +13,19 @@
static void
test_sub_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_sub0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(2u, 1u)); // 33
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(2u, 0u)); // 32
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "sub");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "pub");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/pubsub0/xsub_test.c b/src/sp/protocol/pubsub0/xsub_test.c
index b8f303f3..8e5568c4 100644
--- a/src/sp/protocol/pubsub0/xsub_test.c
+++ b/src/sp/protocol/pubsub0/xsub_test.c
@@ -13,21 +13,19 @@
static void
test_xsub_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_sub0_open_raw(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(2u, 1u)); // 33
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NUTS_PROTO(2u, 0u)); // 32
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, "sub");
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, "pub");
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/reqrep0/rep_test.c b/src/sp/protocol/reqrep0/rep_test.c
index 58a54afe..6ca8fbca 100644
--- a/src/sp/protocol/reqrep0/rep_test.c
+++ b/src/sp/protocol/reqrep0/rep_test.c
@@ -13,23 +13,21 @@
static void
test_rep_identity(void)
{
- nng_socket s;
- int p1, p2;
- char *n1;
- char *n2;
+ nng_socket s;
+ uint16_t p1, p2;
+ const char *n1;
+ const char *n2;
NUTS_PASS(nng_rep0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p1));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p2));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n1));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n2));
+ NUTS_PASS(nng_socket_proto_id(s, &p1));
+ NUTS_PASS(nng_socket_peer_id(s, &p2));
+ NUTS_PASS(nng_socket_proto_name(s, &n1));
+ NUTS_PASS(nng_socket_peer_name(s, &n2));
NUTS_CLOSE(s);
NUTS_TRUE(p1 == NNG_REP0_SELF);
NUTS_TRUE(p2 == NNG_REP0_PEER);
NUTS_MATCH(n1, NNG_REP0_SELF_NAME);
NUTS_MATCH(n2, NNG_REP0_PEER_NAME);
- nng_strfree(n1);
- nng_strfree(n2);
}
void
diff --git a/src/sp/protocol/reqrep0/req_test.c b/src/sp/protocol/reqrep0/req_test.c
index 61d9b347..08b40b08 100644
--- a/src/sp/protocol/reqrep0/req_test.c
+++ b/src/sp/protocol/reqrep0/req_test.c
@@ -14,21 +14,19 @@
static void
test_req_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_req0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NNG_REQ0_SELF);
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NNG_REQ0_PEER); // 49
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, NNG_REQ0_SELF_NAME);
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, NNG_REQ0_PEER_NAME);
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/reqrep0/xrep_test.c b/src/sp/protocol/reqrep0/xrep_test.c
index 67e38449..c1a7cb62 100644
--- a/src/sp/protocol/reqrep0/xrep_test.c
+++ b/src/sp/protocol/reqrep0/xrep_test.c
@@ -13,23 +13,21 @@
static void
test_xrep_identity(void)
{
- nng_socket s;
- int p1, p2;
- char *n1;
- char *n2;
+ nng_socket s;
+ uint16_t p1, p2;
+ const char *n1;
+ const char *n2;
NUTS_PASS(nng_rep0_open_raw(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p1));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p2));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n1));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n2));
+ NUTS_PASS(nng_socket_proto_id(s, &p1));
+ NUTS_PASS(nng_socket_peer_id(s, &p2));
+ NUTS_PASS(nng_socket_proto_name(s, &n1));
+ NUTS_PASS(nng_socket_peer_name(s, &n2));
NUTS_CLOSE(s);
NUTS_TRUE(p1 == NNG_REP0_SELF);
NUTS_TRUE(p2 == NNG_REP0_PEER);
NUTS_MATCH(n1, NNG_REP0_SELF_NAME);
NUTS_MATCH(n2, NNG_REP0_PEER_NAME);
- nng_strfree(n1);
- nng_strfree(n2);
}
static void
diff --git a/src/sp/protocol/reqrep0/xreq_test.c b/src/sp/protocol/reqrep0/xreq_test.c
index 3ebe92da..7e09ce5a 100644
--- a/src/sp/protocol/reqrep0/xreq_test.c
+++ b/src/sp/protocol/reqrep0/xreq_test.c
@@ -13,23 +13,21 @@
static void
test_xreq_identity(void)
{
- nng_socket s;
- int p1, p2;
- char *n1;
- char *n2;
+ nng_socket s;
+ uint16_t p1, p2;
+ const char *n1;
+ const char *n2;
NUTS_PASS(nng_req0_open_raw(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p1));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p2));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n1));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n2));
+ NUTS_PASS(nng_socket_proto_id(s, &p1));
+ NUTS_PASS(nng_socket_peer_id(s, &p2));
+ NUTS_PASS(nng_socket_proto_name(s, &n1));
+ NUTS_PASS(nng_socket_peer_name(s, &n2));
NUTS_CLOSE(s);
NUTS_TRUE(p1 == NNG_REQ0_SELF);
NUTS_TRUE(p2 == NNG_REQ0_PEER);
NUTS_MATCH(n1, NNG_REQ0_SELF_NAME);
NUTS_MATCH(n2, NNG_REQ0_PEER_NAME);
- nng_strfree(n1);
- nng_strfree(n2);
}
static void
diff --git a/src/sp/protocol/survey0/respond_test.c b/src/sp/protocol/survey0/respond_test.c
index 0dad2222..5e3dad34 100644
--- a/src/sp/protocol/survey0/respond_test.c
+++ b/src/sp/protocol/survey0/respond_test.c
@@ -13,21 +13,19 @@
void
test_resp_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_respondent0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NNG_RESPONDENT0_SELF);
- NUTS_TRUE(nng_socket_get_int(s, NNG_OPT_PEER, &p) == 0);
+ NUTS_TRUE(nng_socket_peer_id(s, &p) == 0);
NUTS_TRUE(p == NNG_RESPONDENT0_PEER);
- NUTS_TRUE(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n) == 0);
+ NUTS_TRUE(nng_socket_proto_name(s, &n) == 0);
NUTS_MATCH(n, NNG_RESPONDENT0_SELF_NAME);
- nng_strfree(n);
- NUTS_TRUE(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n) == 0);
+ NUTS_TRUE(nng_socket_peer_name(s, &n) == 0);
NUTS_MATCH(n, NNG_RESPONDENT0_PEER_NAME);
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/survey0/survey_test.c b/src/sp/protocol/survey0/survey_test.c
index 76fe138d..e860dc14 100644
--- a/src/sp/protocol/survey0/survey_test.c
+++ b/src/sp/protocol/survey0/survey_test.c
@@ -14,21 +14,19 @@
static void
test_surv_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_surveyor0_open(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NNG_SURVEYOR0_SELF);
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NNG_SURVEYOR0_PEER); // 49
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, NNG_SURVEYOR0_SELF_NAME);
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, NNG_SURVEYOR0_PEER_NAME);
- nng_strfree(n);
NUTS_CLOSE(s);
}
diff --git a/src/sp/protocol/survey0/xrespond_test.c b/src/sp/protocol/survey0/xrespond_test.c
index 8b8787f9..1522d1ed 100644
--- a/src/sp/protocol/survey0/xrespond_test.c
+++ b/src/sp/protocol/survey0/xrespond_test.c
@@ -13,23 +13,21 @@
static void
test_xresp_identity(void)
{
- nng_socket s;
- int p1, p2;
- char *n1;
- char *n2;
+ nng_socket s;
+ uint16_t p1, p2;
+ const char *n1;
+ const char *n2;
NUTS_PASS(nng_respondent0_open_raw(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p1));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p2));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n1));
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n2));
+ NUTS_PASS(nng_socket_proto_id(s, &p1));
+ NUTS_PASS(nng_socket_peer_id(s, &p2));
+ NUTS_PASS(nng_socket_proto_name(s, &n1));
+ NUTS_PASS(nng_socket_peer_name(s, &n2));
NUTS_CLOSE(s);
NUTS_TRUE(p1 == NNG_RESPONDENT0_SELF);
NUTS_TRUE(p2 == NNG_RESPONDENT0_PEER);
NUTS_MATCH(n1, NNG_RESPONDENT0_SELF_NAME);
NUTS_MATCH(n2, NNG_RESPONDENT0_PEER_NAME);
- nng_strfree(n1);
- nng_strfree(n2);
}
static void
diff --git a/src/sp/protocol/survey0/xsurvey_test.c b/src/sp/protocol/survey0/xsurvey_test.c
index efa54101..41c76cb2 100644
--- a/src/sp/protocol/survey0/xsurvey_test.c
+++ b/src/sp/protocol/survey0/xsurvey_test.c
@@ -13,21 +13,19 @@
static void
test_xsurveyor_identity(void)
{
- nng_socket s;
- int p;
- char *n;
+ nng_socket s;
+ uint16_t p;
+ const char *n;
NUTS_PASS(nng_surveyor0_open_raw(&s));
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PROTO, &p));
+ NUTS_PASS(nng_socket_proto_id(s, &p));
NUTS_TRUE(p == NNG_SURVEYOR0_SELF); // 0x62
- NUTS_PASS(nng_socket_get_int(s, NNG_OPT_PEER, &p));
+ NUTS_PASS(nng_socket_peer_id(s, &p));
NUTS_TRUE(p == NNG_SURVEYOR0_PEER); // 0x62
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PROTONAME, &n));
+ NUTS_PASS(nng_socket_proto_name(s, &n));
NUTS_MATCH(n, NNG_SURVEYOR0_SELF_NAME);
- nng_strfree(n);
- NUTS_PASS(nng_socket_get_string(s, NNG_OPT_PEERNAME, &n));
+ NUTS_PASS(nng_socket_peer_name(s, &n));
NUTS_MATCH(n, NNG_SURVEYOR0_PEER_NAME);
- nng_strfree(n);
NUTS_CLOSE(s);
}