aboutsummaryrefslogtreecommitdiff
path: root/src/protocol/pipeline
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-01-21 20:16:02 -0800
committerGarrett D'Amore <garrett@damore.org>2017-01-21 20:16:02 -0800
commit68e2aea44d766c6dbe438642d2591875602c78b4 (patch)
tree5f5c2db8b976e940305ba8d911208b613e578476 /src/protocol/pipeline
parentc9593dfc5796a98b94ef516fce662f2e040acffe (diff)
downloadnng-68e2aea44d766c6dbe438642d2591875602c78b4.tar.gz
nng-68e2aea44d766c6dbe438642d2591875602c78b4.tar.bz2
nng-68e2aea44d766c6dbe438642d2591875602c78b4.zip
Added protocol flags (which ones can send, and which can receive).
Diffstat (limited to 'src/protocol/pipeline')
-rw-r--r--src/protocol/pipeline/pull.c1
-rw-r--r--src/protocol/pipeline/push.c1
2 files changed, 2 insertions, 0 deletions
diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c
index ca15efef..5b3efd4d 100644
--- a/src/protocol/pipeline/pull.c
+++ b/src/protocol/pipeline/pull.c
@@ -155,6 +155,7 @@ nni_proto nni_pull_proto = {
.proto_self = NNG_PROTO_PULL,
.proto_peer = NNG_PROTO_PUSH,
.proto_name = "pull",
+ .proto_flags = NNI_PROTO_FLAG_RECV,
.proto_pipe_ops = &nni_pull_pipe_ops,
.proto_sock_ops = &nni_pull_sock_ops,
};
diff --git a/src/protocol/pipeline/push.c b/src/protocol/pipeline/push.c
index 1d1e6d88..8794d84f 100644
--- a/src/protocol/pipeline/push.c
+++ b/src/protocol/pipeline/push.c
@@ -313,6 +313,7 @@ nni_proto nni_push_proto = {
.proto_self = NNG_PROTO_PUSH,
.proto_peer = NNG_PROTO_PULL,
.proto_name = "push",
+ .proto_flags = NNI_PROTO_FLAG_SEND,
.proto_pipe_ops = &nni_push_pipe_ops,
.proto_sock_ops = &nni_push_sock_ops,
};