aboutsummaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
Diffstat (limited to 'src/core')
-rw-r--r--src/core/protocol.c4
-rw-r--r--src/core/socket.c7
2 files changed, 11 insertions, 0 deletions
diff --git a/src/core/protocol.c b/src/core/protocol.c
index 8669275a..072cc301 100644
--- a/src/core/protocol.c
+++ b/src/core/protocol.c
@@ -17,9 +17,13 @@
// change, as adding new protocols is not something intended to be done
// outside of the core.
extern nni_proto nni_pair_proto;
+extern nni_proto nni_rep_proto;
+extern nni_proto nni_req_proto;
static nni_proto *protocols[] = {
&nni_pair_proto,
+ &nni_rep_proto,
+ &nni_req_proto,
NULL
};
diff --git a/src/core/socket.c b/src/core/socket.c
index cad4b10a..26ca055e 100644
--- a/src/core/socket.c
+++ b/src/core/socket.c
@@ -361,6 +361,13 @@ nni_sock_proto(nni_sock *sock)
}
+uint16_t
+nni_sock_peer(nni_sock *sock)
+{
+ return (sock->s_proto.proto_peer);
+}
+
+
int
nni_sock_dial(nni_sock *sock, const char *addr, nni_ep **epp, int flags)
{