aboutsummaryrefslogtreecommitdiff
path: root/src/protocol/pipeline
diff options
context:
space:
mode:
Diffstat (limited to 'src/protocol/pipeline')
-rw-r--r--src/protocol/pipeline/pull.c2
-rw-r--r--src/protocol/pipeline/push.c1
2 files changed, 0 insertions, 3 deletions
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 (;;) {