summaryrefslogtreecommitdiff
path: root/src/protocol
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-01-22 02:32:32 -0800
committerGarrett D'Amore <garrett@damore.org>2017-01-22 02:32:32 -0800
commitb93d5759c9b39ff153a14d474d800cd981f7dc97 (patch)
tree1a98b7ac74cd91003c38f53ae3eb01fb8027deef /src/protocol
parent769f9a2b66aca629eb4dd240a072849a48aa300f (diff)
downloadnng-b93d5759c9b39ff153a14d474d800cd981f7dc97.tar.gz
nng-b93d5759c9b39ff153a14d474d800cd981f7dc97.tar.bz2
nng-b93d5759c9b39ff153a14d474d800cd981f7dc97.zip
Event notification via pollable FDs verified working.
Diffstat (limited to 'src/protocol')
-rw-r--r--src/protocol/bus/bus.c2
-rw-r--r--src/protocol/pair/pair.c2
-rw-r--r--src/protocol/pipeline/pull.c2
-rw-r--r--src/protocol/pipeline/push.c2
-rw-r--r--src/protocol/pubsub/pub.c2
-rw-r--r--src/protocol/pubsub/sub.c2
-rw-r--r--src/protocol/reqrep/rep.c2
-rw-r--r--src/protocol/reqrep/req.c2
-rw-r--r--src/protocol/survey/respond.c2
-rw-r--r--src/protocol/survey/survey.c2
10 files changed, 10 insertions, 10 deletions
diff --git a/src/protocol/bus/bus.c b/src/protocol/bus/bus.c
index c1334fa5..c9a1b42b 100644
--- a/src/protocol/bus/bus.c
+++ b/src/protocol/bus/bus.c
@@ -273,7 +273,7 @@ nni_proto nni_bus_proto = {
.proto_self = NNG_PROTO_BUS,
.proto_peer = NNG_PROTO_BUS,
.proto_name = "bus",
- .proto_flags = NNI_PROTO_FLAG_SENDRECV,
+ .proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &nni_bus_sock_ops,
.proto_pipe_ops = &nni_bus_pipe_ops,
};
diff --git a/src/protocol/pair/pair.c b/src/protocol/pair/pair.c
index fe0874ca..b97b4b46 100644
--- a/src/protocol/pair/pair.c
+++ b/src/protocol/pair/pair.c
@@ -233,7 +233,7 @@ nni_proto nni_pair_proto = {
.proto_self = NNG_PROTO_PAIR,
.proto_peer = NNG_PROTO_PAIR,
.proto_name = "pair",
- .proto_flags = NNI_PROTO_FLAG_SENDRECV,
+ .proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &nni_pair_sock_ops,
.proto_pipe_ops = &nni_pair_pipe_ops,
};
diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c
index 5b3efd4d..6f2d716b 100644
--- a/src/protocol/pipeline/pull.c
+++ b/src/protocol/pipeline/pull.c
@@ -155,7 +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_flags = NNI_PROTO_FLAG_RCV,
.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 8794d84f..3c3164d5 100644
--- a/src/protocol/pipeline/push.c
+++ b/src/protocol/pipeline/push.c
@@ -313,7 +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_flags = NNI_PROTO_FLAG_SND,
.proto_pipe_ops = &nni_push_pipe_ops,
.proto_sock_ops = &nni_push_sock_ops,
};
diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c
index 24dddf4e..d148999b 100644
--- a/src/protocol/pubsub/pub.c
+++ b/src/protocol/pubsub/pub.c
@@ -274,7 +274,7 @@ nni_proto nni_pub_proto = {
.proto_self = NNG_PROTO_PUB,
.proto_peer = NNG_PROTO_SUB,
.proto_name = "pub",
- .proto_flags = NNI_PROTO_FLAG_SEND,
+ .proto_flags = NNI_PROTO_FLAG_SND,
.proto_sock_ops = &nni_pub_sock_ops,
.proto_pipe_ops = &nni_pub_pipe_ops,
};
diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c
index 512765eb..46dcfd5c 100644
--- a/src/protocol/pubsub/sub.c
+++ b/src/protocol/pubsub/sub.c
@@ -314,7 +314,7 @@ nni_proto nni_sub_proto = {
.proto_self = NNG_PROTO_SUB,
.proto_peer = NNG_PROTO_PUB,
.proto_name = "sub",
- .proto_flags = NNI_PROTO_FLAG_RECV,
+ .proto_flags = NNI_PROTO_FLAG_RCV,
.proto_sock_ops = &nni_sub_sock_ops,
.proto_pipe_ops = &nni_sub_pipe_ops,
};
diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c
index 36535fa4..40ee52fc 100644
--- a/src/protocol/reqrep/rep.c
+++ b/src/protocol/reqrep/rep.c
@@ -414,7 +414,7 @@ nni_proto nni_rep_proto = {
.proto_self = NNG_PROTO_REP,
.proto_peer = NNG_PROTO_REQ,
.proto_name = "rep",
- .proto_flags = NNI_PROTO_FLAG_SENDRECV,
+ .proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &nni_rep_sock_ops,
.proto_pipe_ops = &nni_rep_pipe_ops,
};
diff --git a/src/protocol/reqrep/req.c b/src/protocol/reqrep/req.c
index 5d87e30d..c200fdc9 100644
--- a/src/protocol/reqrep/req.c
+++ b/src/protocol/reqrep/req.c
@@ -406,7 +406,7 @@ nni_proto nni_req_proto = {
.proto_self = NNG_PROTO_REQ,
.proto_peer = NNG_PROTO_REP,
.proto_name = "req",
- .proto_flags = NNI_PROTO_FLAG_SENDRECV,
+ .proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &nni_req_sock_ops,
.proto_pipe_ops = &nni_req_pipe_ops,
};
diff --git a/src/protocol/survey/respond.c b/src/protocol/survey/respond.c
index a915eace..8a7239b3 100644
--- a/src/protocol/survey/respond.c
+++ b/src/protocol/survey/respond.c
@@ -416,7 +416,7 @@ nni_proto nni_respondent_proto = {
.proto_self = NNG_PROTO_RESPONDENT,
.proto_peer = NNG_PROTO_SURVEYOR,
.proto_name = "respondent",
- .proto_flags = NNI_PROTO_FLAG_SENDRECV,
+ .proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &nni_resp_sock_ops,
.proto_pipe_ops = &nni_resp_pipe_ops,
};
diff --git a/src/protocol/survey/survey.c b/src/protocol/survey/survey.c
index b887a6e9..c16bad3b 100644
--- a/src/protocol/survey/survey.c
+++ b/src/protocol/survey/survey.c
@@ -427,7 +427,7 @@ nni_proto nni_surveyor_proto = {
.proto_self = NNG_PROTO_SURVEYOR,
.proto_peer = NNG_PROTO_RESPONDENT,
.proto_name = "surveyor",
- .proto_flags = NNI_PROTO_FLAG_SENDRECV,
+ .proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &nni_surv_sock_ops,
.proto_pipe_ops = &nni_surv_pipe_ops,
};