diff options
Diffstat (limited to 'src/protocol/pubsub')
| -rw-r--r-- | src/protocol/pubsub/pub.c | 10 | ||||
| -rw-r--r-- | src/protocol/pubsub/sub.c | 9 |
2 files changed, 4 insertions, 15 deletions
diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c index 684b916d..b597f896 100644 --- a/src/protocol/pubsub/pub.c +++ b/src/protocol/pubsub/pub.c @@ -257,20 +257,16 @@ static nni_proto_pipe_ops nni_pub_pipe_ops = { .pipe_fini = nni_pub_pipe_fini, .pipe_add = nni_pub_pipe_add, .pipe_rem = nni_pub_pipe_rem, - .pipe_send = nni_pub_pipe_send, - .pipe_recv = nni_pub_pipe_recv, + .pipe_worker = { nni_pub_pipe_send, + nni_pub_pipe_recv }, }; nni_proto_sock_ops nni_pub_sock_ops = { .sock_init = nni_pub_sock_init, .sock_fini = nni_pub_sock_fini, - .sock_close = NULL, .sock_setopt = nni_pub_sock_setopt, .sock_getopt = nni_pub_sock_getopt, - .sock_send = nni_pub_sock_send, - .sock_recv = NULL, - .sock_rfilter = NULL, - .sock_sfilter = NULL, + .sock_worker = { nni_pub_sock_send }, }; nni_proto nni_pub_proto = { diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c index dd288d5e..0a6ce5fd 100644 --- a/src/protocol/pubsub/sub.c +++ b/src/protocol/pubsub/sub.c @@ -297,22 +297,15 @@ nni_sub_sock_rfilter(void *arg, nni_msg *msg) static nni_proto_pipe_ops nni_sub_pipe_ops = { .pipe_init = nni_sub_pipe_init, .pipe_fini = nni_sub_pipe_fini, - .pipe_add = NULL, - .pipe_rem = NULL, - .pipe_send = NULL, - .pipe_recv = nni_sub_pipe_recv, + .pipe_worker = { nni_sub_pipe_recv }, }; static nni_proto_sock_ops nni_sub_sock_ops = { .sock_init = nni_sub_sock_init, .sock_fini = nni_sub_sock_fini, - .sock_close = NULL, .sock_setopt = nni_sub_sock_setopt, .sock_getopt = nni_sub_sock_getopt, .sock_rfilter = nni_sub_sock_rfilter, - .sock_sfilter = NULL, - .sock_send = NULL, - .sock_recv = NULL, }; nni_proto nni_sub_proto = { |