aboutsummaryrefslogtreecommitdiff
path: root/src/protocol
diff options
context:
space:
mode:
Diffstat (limited to 'src/protocol')
-rw-r--r--src/protocol/bus/bus.c1
-rw-r--r--src/protocol/pair/pair.c1
-rw-r--r--src/protocol/pipeline/pull.c2
-rw-r--r--src/protocol/pipeline/push.c1
-rw-r--r--src/protocol/pubsub/pub.c1
-rw-r--r--src/protocol/pubsub/sub.c2
-rw-r--r--src/protocol/reqrep/rep.c2
-rw-r--r--src/protocol/survey/respond.c2
8 files changed, 0 insertions, 12 deletions
diff --git a/src/protocol/bus/bus.c b/src/protocol/bus/bus.c
index 3c9d0674..0d57f1db 100644
--- a/src/protocol/bus/bus.c
+++ b/src/protocol/bus/bus.c
@@ -41,7 +41,6 @@ static int
nni_bus_sock_init(void **sp, nni_sock *nsock)
{
nni_bus_sock *psock;
- int rv;
if ((psock = NNI_ALLOC_STRUCT(psock)) == NULL) {
return (NNG_ENOMEM);
diff --git a/src/protocol/pair/pair.c b/src/protocol/pair/pair.c
index ff02c2d1..0d8b32fe 100644
--- a/src/protocol/pair/pair.c
+++ b/src/protocol/pair/pair.c
@@ -45,7 +45,6 @@ static int
nni_pair_sock_init(void **sp, nni_sock *nsock)
{
nni_pair_sock *psock;
- int rv;
if ((psock = NNI_ALLOC_STRUCT(psock)) == NULL) {
return (NNG_ENOMEM);
diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c
index dc37e72b..20beb873 100644
--- a/src/protocol/pipeline/pull.c
+++ b/src/protocol/pipeline/pull.c
@@ -33,7 +33,6 @@ static int
nni_pull_sock_init(void **pullp, nni_sock *sock)
{
nni_pull_sock *pull;
- int rv;
if ((pull = NNI_ALLOC_STRUCT(pull)) == NULL) {
return (NNG_ENOMEM);
@@ -59,7 +58,6 @@ static int
nni_pull_pipe_init(void **ppp, nni_pipe *pipe, void *psock)
{
nni_pull_pipe *pp;
- int rv;
if ((pp = NNI_ALLOC_STRUCT(pp)) == NULL) {
return (NNG_ENOMEM);
diff --git a/src/protocol/pipeline/push.c b/src/protocol/pipeline/push.c
index e3b9ace8..4704a323 100644
--- a/src/protocol/pipeline/push.c
+++ b/src/protocol/pipeline/push.c
@@ -240,7 +240,6 @@ nni_push_sock_send(void *arg)
nni_msgq *uwq = push->uwq;
nni_msg *msg = NULL;
nni_mtx *mx = nni_sock_mtx(push->sock);
- int rv;
int i;
for (;;) {
diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c
index c9b0ce09..a167d523 100644
--- a/src/protocol/pubsub/pub.c
+++ b/src/protocol/pubsub/pub.c
@@ -41,7 +41,6 @@ static int
nni_pub_sock_init(void **pubp, nni_sock *sock)
{
nni_pub_sock *pub;
- int rv;
if ((pub = NNI_ALLOC_STRUCT(pub)) == NULL) {
return (NNG_ENOMEM);
diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c
index 0a6ce5fd..9390b0d2 100644
--- a/src/protocol/pubsub/sub.c
+++ b/src/protocol/pubsub/sub.c
@@ -44,7 +44,6 @@ static int
nni_sub_sock_init(void **subp, nni_sock *sock)
{
nni_sub_sock *sub;
- int rv;
if ((sub = NNI_ALLOC_STRUCT(sub)) == NULL) {
return (NNG_ENOMEM);
@@ -79,7 +78,6 @@ static int
nni_sub_pipe_init(void **spp, nni_pipe *pipe, void *ssock)
{
nni_sub_pipe *sp;
- int rv;
if ((sp = NNI_ALLOC_STRUCT(sp)) == NULL) {
return (NNG_ENOMEM);
diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c
index 485fd4bc..90346236 100644
--- a/src/protocol/reqrep/rep.c
+++ b/src/protocol/reqrep/rep.c
@@ -224,7 +224,6 @@ nni_rep_pipe_recv(void *arg)
NNI_PUT32(idbuf, id);
for (;;) {
- size_t len;
uint8_t *body;
int hops;
@@ -323,7 +322,6 @@ static nni_msg *
nni_rep_sock_sfilter(void *arg, nni_msg *msg)
{
nni_rep_sock *rep = arg;
- size_t len;
if (rep->raw) {
return (msg);
diff --git a/src/protocol/survey/respond.c b/src/protocol/survey/respond.c
index 2359fef1..0cef5a68 100644
--- a/src/protocol/survey/respond.c
+++ b/src/protocol/survey/respond.c
@@ -219,7 +219,6 @@ nni_resp_pipe_recv(void *arg)
NNI_PUT32(idbuf, id);
for (;;) {
- size_t len;
uint8_t *body;
int hops;
@@ -326,7 +325,6 @@ static nni_msg *
nni_resp_sock_sfilter(void *arg, nni_msg *msg)
{
nni_resp_sock *psock = arg;
- size_t len;
if (psock->raw) {
return (msg);