diff options
Diffstat (limited to 'src/protocol/pipeline')
| -rw-r--r-- | src/protocol/pipeline/pull.c | 4 | ||||
| -rw-r--r-- | src/protocol/pipeline/push.c | 8 |
2 files changed, 6 insertions, 6 deletions
diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c index 622bd958..b569253d 100644 --- a/src/protocol/pipeline/pull.c +++ b/src/protocol/pipeline/pull.c @@ -229,8 +229,8 @@ nni_pull_sock_getopt(void *arg, int opt, void *buf, size_t *szp) static nni_proto_pipe_ops nni_pull_pipe_ops = { .pipe_init = nni_pull_pipe_init, .pipe_fini = nni_pull_pipe_fini, - .pipe_add = nni_pull_pipe_start, - .pipe_rem = nni_pull_pipe_stop, + .pipe_start = nni_pull_pipe_start, + .pipe_stop = nni_pull_pipe_stop, }; static nni_proto_sock_ops nni_pull_sock_ops = { diff --git a/src/protocol/pipeline/push.c b/src/protocol/pipeline/push.c index d2d8363a..9691d8d8 100644 --- a/src/protocol/pipeline/push.c +++ b/src/protocol/pipeline/push.c @@ -116,7 +116,7 @@ nni_push_pipe_fini(void *arg) static int -nni_push_pipe_add(void *arg) +nni_push_pipe_start(void *arg) { nni_push_pipe *pp = arg; nni_push_sock *push = pp->push; @@ -139,7 +139,7 @@ nni_push_pipe_add(void *arg) static void -nni_push_pipe_rem(void *arg) +nni_push_pipe_stop(void *arg) { nni_push_pipe *pp = arg; nni_push_sock *push = pp->push; @@ -243,8 +243,8 @@ nni_push_sock_getopt(void *arg, int opt, void *buf, size_t *szp) static nni_proto_pipe_ops nni_push_pipe_ops = { .pipe_init = nni_push_pipe_init, .pipe_fini = nni_push_pipe_fini, - .pipe_add = nni_push_pipe_add, - .pipe_rem = nni_push_pipe_rem, + .pipe_start = nni_push_pipe_start, + .pipe_stop = nni_push_pipe_stop, }; static nni_proto_sock_ops nni_push_sock_ops = { |