diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-08 11:18:16 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-08 11:18:16 -0800 |
| commit | ec2574b09a746709f15d2a3f5de135e29f4bcb52 (patch) | |
| tree | 25f970232f8093b9ce94969eeed2a5f230e94a89 /src/protocol/pair/pair.c | |
| parent | 360d19001b90d92ac2f232efb67e356979b0bc4b (diff) | |
| download | nng-ec2574b09a746709f15d2a3f5de135e29f4bcb52.tar.gz nng-ec2574b09a746709f15d2a3f5de135e29f4bcb52.tar.bz2 nng-ec2574b09a746709f15d2a3f5de135e29f4bcb52.zip | |
Move to generic socket & pipe workers, and up to 4 each.
This should eliminate all need for protocols to do their own
thread management tasks.
Diffstat (limited to 'src/protocol/pair/pair.c')
| -rw-r--r-- | src/protocol/pair/pair.c | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/src/protocol/pair/pair.c b/src/protocol/pair/pair.c index 51608e07..ec6709ac 100644 --- a/src/protocol/pair/pair.c +++ b/src/protocol/pair/pair.c @@ -200,20 +200,15 @@ static nni_proto_pipe_ops nni_pair_pipe_ops = { .pipe_fini = nni_pair_pipe_fini, .pipe_add = nni_pair_pipe_add, .pipe_rem = nni_pair_pipe_rem, - .pipe_send = nni_pair_pipe_send, - .pipe_recv = nni_pair_pipe_recv, + .pipe_worker = { nni_pair_pipe_send, + nni_pair_pipe_recv }, }; static nni_proto_sock_ops nni_pair_sock_ops = { .sock_init = nni_pair_sock_init, .sock_fini = nni_pair_sock_fini, - .sock_close = NULL, .sock_setopt = nni_pair_sock_setopt, .sock_getopt = nni_pair_sock_getopt, - .sock_rfilter = NULL, - .sock_sfilter = NULL, - .sock_send = NULL, - .sock_recv = NULL, }; nni_proto nni_pair_proto = { |