From 3585000ca027740dbdb4599f4991cd2bf562e2f2 Mon Sep 17 00:00:00 2001
From: Garrett D'Amore <garrett@damore.org>
Date: Fri, 20 Oct 2017 17:03:12 -0700
Subject: fixes #112 Need to move some stuff from socket to message queues

---
 src/protocol/pair/pair_v1.c | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

(limited to 'src/protocol/pair/pair_v1.c')

diff --git a/src/protocol/pair/pair_v1.c b/src/protocol/pair/pair_v1.c
index 6c9d4bd3..f43a4785 100644
--- a/src/protocol/pair/pair_v1.c
+++ b/src/protocol/pair/pair_v1.c
@@ -446,6 +446,24 @@ pair1_sock_getopt_poly(void *arg, void *buf, size_t *szp)
 	return (nni_getopt_int(s->poly, buf, szp));
 }
 
+static void
+pair1_sock_send(void *arg, nni_aio *aio)
+{
+	pair1_sock *s = arg;
+
+	nni_sock_send_pending(s->nsock);
+	nni_msgq_aio_put(s->uwq, aio);
+}
+
+static void
+pair1_sock_recv(void *arg, nni_aio *aio)
+{
+	pair1_sock *s = arg;
+
+	nni_sock_recv_pending(s->nsock);
+	nni_msgq_aio_get(s->urq, aio);
+}
+
 static nni_proto_pipe_ops pair1_pipe_ops = {
 	.pipe_init  = pair1_pipe_init,
 	.pipe_fini  = pair1_pipe_fini,
@@ -478,6 +496,8 @@ static nni_proto_sock_ops pair1_sock_ops = {
 	.sock_fini    = pair1_sock_fini,
 	.sock_open    = pair1_sock_open,
 	.sock_close   = pair1_sock_close,
+	.sock_recv    = pair1_sock_recv,
+	.sock_send    = pair1_sock_send,
 	.sock_options = pair1_sock_options,
 };
 
-- 
cgit v1.2.3-70-g09d2