aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/core/socket.c40
-rw-r--r--src/nng.c64
-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
19 files changed, 187 insertions, 197 deletions
diff --git a/src/core/socket.c b/src/core/socket.c
index 9376f9de..0e9b6b17 100644
--- a/src/core/socket.c
+++ b/src/core/socket.c
@@ -227,30 +227,6 @@ sock_set_sockname(void *s, const void *buf, size_t sz, nni_type t)
return (rv);
}
-static int
-sock_get_proto(void *s, void *buf, size_t *szp, nni_type t)
-{
- return (nni_copyout_int(nni_sock_proto_id(SOCK(s)), buf, szp, t));
-}
-
-static int
-sock_get_peer(void *s, void *buf, size_t *szp, nni_type t)
-{
- return (nni_copyout_int(nni_sock_peer_id(SOCK(s)), buf, szp, t));
-}
-
-static int
-sock_get_protoname(void *s, void *buf, size_t *szp, nni_type t)
-{
- return (nni_copyout_str(nni_sock_proto_name(SOCK(s)), buf, szp, t));
-}
-
-static int
-sock_get_peername(void *s, void *buf, size_t *szp, nni_type t)
-{
- return (nni_copyout_str(nni_sock_peer_name(SOCK(s)), buf, szp, t));
-}
-
static const nni_option sock_options[] = {
{
.o_name = NNG_OPT_RECVTIMEO,
@@ -281,22 +257,6 @@ static const nni_option sock_options[] = {
.o_name = NNG_OPT_RAW,
.o_get = sock_get_raw,
},
- {
- .o_name = NNG_OPT_PROTO,
- .o_get = sock_get_proto,
- },
- {
- .o_name = NNG_OPT_PEER,
- .o_get = sock_get_peer,
- },
- {
- .o_name = NNG_OPT_PROTONAME,
- .o_get = sock_get_protoname,
- },
- {
- .o_name = NNG_OPT_PEERNAME,
- .o_get = sock_get_peername,
- },
// terminate list
{
.o_name = NULL,
diff --git a/src/nng.c b/src/nng.c
index 1707ce9f..d5c1b957 100644
--- a/src/nng.c
+++ b/src/nng.c
@@ -1151,6 +1151,70 @@ nng_socket_get_send_poll_fd(nng_socket id, int *fdp)
}
int
+nng_socket_proto_id(nng_socket id, uint16_t *idp)
+{
+ int rv;
+ nni_sock *sock;
+
+ if (((rv = nni_init()) != 0) ||
+ ((rv = nni_sock_find(&sock, id.id)) != 0)) {
+ return (rv);
+ }
+
+ *idp = nni_sock_proto_id(sock);
+ nni_sock_rele(sock);
+ return (0);
+}
+
+int
+nng_socket_peer_id(nng_socket id, uint16_t *idp)
+{
+ int rv;
+ nni_sock *sock;
+
+ if (((rv = nni_init()) != 0) ||
+ ((rv = nni_sock_find(&sock, id.id)) != 0)) {
+ return (rv);
+ }
+
+ *idp = nni_sock_peer_id(sock);
+ nni_sock_rele(sock);
+ return (0);
+}
+
+int
+nng_socket_proto_name(nng_socket id, const char **name)
+{
+ int rv;
+ nni_sock *sock;
+
+ if (((rv = nni_init()) != 0) ||
+ ((rv = nni_sock_find(&sock, id.id)) != 0)) {
+ return (rv);
+ }
+
+ *name = nni_sock_proto_name(sock);
+ nni_sock_rele(sock);
+ return (0);
+}
+
+int
+nng_socket_peer_name(nng_socket id, const char **name)
+{
+ int rv;
+ nni_sock *sock;
+
+ if (((rv = nni_init()) != 0) ||
+ ((rv = nni_sock_find(&sock, id.id)) != 0)) {
+ return (rv);
+ }
+
+ *name = nni_sock_peer_name(sock);
+ nni_sock_rele(sock);
+ return (0);
+}
+
+int
nng_pipe_notify(nng_socket s, nng_pipe_ev ev, nng_pipe_cb cb, void *arg)
{
int rv;
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);
}