aboutsummaryrefslogtreecommitdiff
path: root/src/protocol
diff options
context:
space:
mode:
Diffstat (limited to 'src/protocol')
-rw-r--r--src/protocol/bus/bus.c4
-rw-r--r--src/protocol/pair/pair_v0.c4
-rw-r--r--src/protocol/pair/pair_v1.c4
-rw-r--r--src/protocol/pipeline/pull.c4
-rw-r--r--src/protocol/pipeline/push.c6
-rw-r--r--src/protocol/pubsub/pub.c6
-rw-r--r--src/protocol/pubsub/sub.c4
-rw-r--r--src/protocol/reqrep/rep.c4
-rw-r--r--src/protocol/reqrep/req.c6
-rw-r--r--src/protocol/survey/respond.c4
-rw-r--r--src/protocol/survey/survey.c4
11 files changed, 25 insertions, 25 deletions
diff --git a/src/protocol/bus/bus.c b/src/protocol/bus/bus.c
index 07f91602..6ec0066b 100644
--- a/src/protocol/bus/bus.c
+++ b/src/protocol/bus/bus.c
@@ -387,8 +387,8 @@ static nni_proto_sock_ops bus_sock_ops = {
static nni_proto bus_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_BUS_V0, "bus" },
- .proto_peer = { NNG_PROTO_BUS_V0, "bus" },
+ .proto_self = { NNI_PROTO_BUS_V0, "bus" },
+ .proto_peer = { NNI_PROTO_BUS_V0, "bus" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &bus_sock_ops,
.proto_pipe_ops = &bus_pipe_ops,
diff --git a/src/protocol/pair/pair_v0.c b/src/protocol/pair/pair_v0.c
index 29f3b59c..93cd1497 100644
--- a/src/protocol/pair/pair_v0.c
+++ b/src/protocol/pair/pair_v0.c
@@ -287,8 +287,8 @@ static nni_proto_sock_ops pair0_sock_ops = {
// Legacy protocol (v0)
static nni_proto pair0_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_PAIR_V0, "pair" },
- .proto_peer = { NNG_PROTO_PAIR_V0, "pair" },
+ .proto_self = { NNI_PROTO_PAIR_V0, "pair" },
+ .proto_peer = { NNI_PROTO_PAIR_V0, "pair" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &pair0_sock_ops,
.proto_pipe_ops = &pair0_pipe_ops,
diff --git a/src/protocol/pair/pair_v1.c b/src/protocol/pair/pair_v1.c
index 86ee97eb..e14d06d5 100644
--- a/src/protocol/pair/pair_v1.c
+++ b/src/protocol/pair/pair_v1.c
@@ -499,8 +499,8 @@ static nni_proto_sock_ops pair1_sock_ops = {
static nni_proto pair1_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_PAIR_V1, "pair1" },
- .proto_peer = { NNG_PROTO_PAIR_V1, "pair1" },
+ .proto_self = { NNI_PROTO_PAIR_V1, "pair1" },
+ .proto_peer = { NNI_PROTO_PAIR_V1, "pair1" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &pair1_sock_ops,
.proto_pipe_ops = &pair1_pipe_ops,
diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c
index 267352c5..9685f0a1 100644
--- a/src/protocol/pipeline/pull.c
+++ b/src/protocol/pipeline/pull.c
@@ -228,8 +228,8 @@ static nni_proto_sock_ops pull_sock_ops = {
static nni_proto pull_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_PULL_V0, "pull" },
- .proto_peer = { NNG_PROTO_PUSH_V0, "push" },
+ .proto_self = { NNI_PROTO_PULL_V0, "pull" },
+ .proto_peer = { NNI_PROTO_PUSH_V0, "push" },
.proto_flags = NNI_PROTO_FLAG_RCV,
.proto_pipe_ops = &pull_pipe_ops,
.proto_sock_ops = &pull_sock_ops,
diff --git a/src/protocol/pipeline/push.c b/src/protocol/pipeline/push.c
index 995ac56d..9ff74558 100644
--- a/src/protocol/pipeline/push.c
+++ b/src/protocol/pipeline/push.c
@@ -114,7 +114,7 @@ push_pipe_start(void *arg)
push_pipe *p = arg;
push_sock *s = p->push;
- if (nni_pipe_peer(p->pipe) != NNG_PROTO_PULL) {
+ if (nni_pipe_peer(p->pipe) != NNI_PROTO_PULL_V0) {
return (NNG_EPROTO);
}
@@ -245,8 +245,8 @@ static nni_proto_sock_ops push_sock_ops = {
static nni_proto push_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_PUSH_V0, "push" },
- .proto_peer = { NNG_PROTO_PULL_V0, "pull" },
+ .proto_self = { NNI_PROTO_PUSH_V0, "push" },
+ .proto_peer = { NNI_PROTO_PULL_V0, "pull" },
.proto_flags = NNI_PROTO_FLAG_SND,
.proto_pipe_ops = &push_pipe_ops,
.proto_sock_ops = &push_sock_ops,
diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c
index 29863322..9e5cd67f 100644
--- a/src/protocol/pubsub/pub.c
+++ b/src/protocol/pubsub/pub.c
@@ -142,7 +142,7 @@ pub_pipe_start(void *arg)
pub_pipe *p = arg;
pub_sock *s = p->pub;
- if (nni_pipe_peer(p->pipe) != NNG_PROTO_SUB) {
+ if (nni_pipe_peer(p->pipe) != NNI_PROTO_SUB_V0) {
return (NNG_EPROTO);
}
nni_mtx_lock(&s->mtx);
@@ -321,8 +321,8 @@ static nni_proto_sock_ops pub_sock_ops = {
static nni_proto pub_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_PUB_V0, "pub" },
- .proto_peer = { NNG_PROTO_SUB_V0, "sub" },
+ .proto_self = { NNI_PROTO_PUB_V0, "pub" },
+ .proto_peer = { NNI_PROTO_SUB_V0, "sub" },
.proto_flags = NNI_PROTO_FLAG_SND,
.proto_sock_ops = &pub_sock_ops,
.proto_pipe_ops = &pub_pipe_ops,
diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c
index d87b42ec..555d528e 100644
--- a/src/protocol/pubsub/sub.c
+++ b/src/protocol/pubsub/sub.c
@@ -384,8 +384,8 @@ static nni_proto_sock_ops sub_sock_ops = {
static nni_proto sub_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_SUB_V0, "sub" },
- .proto_peer = { NNG_PROTO_PUB_V0, "pub" },
+ .proto_self = { NNI_PROTO_SUB_V0, "sub" },
+ .proto_peer = { NNI_PROTO_PUB_V0, "pub" },
.proto_flags = NNI_PROTO_FLAG_RCV,
.proto_sock_ops = &sub_sock_ops,
.proto_pipe_ops = &sub_pipe_ops,
diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c
index 5d924e32..100e739d 100644
--- a/src/protocol/reqrep/rep.c
+++ b/src/protocol/reqrep/rep.c
@@ -492,8 +492,8 @@ static nni_proto_sock_ops rep_sock_ops = {
static nni_proto nni_rep_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_REP_V0, "rep" },
- .proto_peer = { NNG_PROTO_REQ_V0, "req" },
+ .proto_self = { NNI_PROTO_REP_V0, "rep" },
+ .proto_peer = { NNI_PROTO_REQ_V0, "req" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &rep_sock_ops,
.proto_pipe_ops = &rep_pipe_ops,
diff --git a/src/protocol/reqrep/req.c b/src/protocol/reqrep/req.c
index 1ab49f3e..bead1ec4 100644
--- a/src/protocol/reqrep/req.c
+++ b/src/protocol/reqrep/req.c
@@ -185,7 +185,7 @@ req_pipe_start(void *arg)
req_pipe *p = arg;
req_sock *s = p->req;
- if (nni_pipe_peer(p->pipe) != NNG_PROTO_REP) {
+ if (nni_pipe_peer(p->pipe) != NNI_PROTO_REP_V0) {
return (NNG_EPROTO);
}
@@ -654,8 +654,8 @@ static nni_proto_sock_ops req_sock_ops = {
static nni_proto req_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_REQ_V0, "req" },
- .proto_peer = { NNG_PROTO_REP_V0, "rep" },
+ .proto_self = { NNI_PROTO_REQ_V0, "req" },
+ .proto_peer = { NNI_PROTO_REP_V0, "rep" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &req_sock_ops,
.proto_pipe_ops = &req_pipe_ops,
diff --git a/src/protocol/survey/respond.c b/src/protocol/survey/respond.c
index dbce0751..94730be6 100644
--- a/src/protocol/survey/respond.c
+++ b/src/protocol/survey/respond.c
@@ -486,8 +486,8 @@ static nni_proto_sock_ops resp_sock_ops = {
static nni_proto resp_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_RESPONDENT_V0, "respondent" },
- .proto_peer = { NNG_PROTO_SURVEYOR_V0, "surveyor" },
+ .proto_self = { NNI_PROTO_RESPONDENT_V0, "respondent" },
+ .proto_peer = { NNI_PROTO_SURVEYOR_V0, "surveyor" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &resp_sock_ops,
.proto_pipe_ops = &resp_pipe_ops,
diff --git a/src/protocol/survey/survey.c b/src/protocol/survey/survey.c
index f44cd63a..9dcd6664 100644
--- a/src/protocol/survey/survey.c
+++ b/src/protocol/survey/survey.c
@@ -461,8 +461,8 @@ static nni_proto_sock_ops surv_sock_ops = {
static nni_proto surv_proto = {
.proto_version = NNI_PROTOCOL_VERSION,
- .proto_self = { NNG_PROTO_SURVEYOR_V0, "surveyor" },
- .proto_peer = { NNG_PROTO_RESPONDENT_V0, "respondent" },
+ .proto_self = { NNI_PROTO_SURVEYOR_V0, "surveyor" },
+ .proto_peer = { NNI_PROTO_RESPONDENT_V0, "respondent" },
.proto_flags = NNI_PROTO_FLAG_SNDRCV,
.proto_sock_ops = &surv_sock_ops,
.proto_pipe_ops = &surv_pipe_ops,
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-18 18:45:55 +0000