diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/protocol/pubsub/pub.c | 2 | ||||
| -rw-r--r-- | src/protocol/survey/survey.c | 4 |
2 files changed, 1 insertions, 5 deletions
diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c index b597f896..c9b0ce09 100644 --- a/src/protocol/pubsub/pub.c +++ b/src/protocol/pubsub/pub.c @@ -37,8 +37,6 @@ struct nni_pub_pipe { int sigclose; }; -static void nni_pub_sock_send(void *); - static int nni_pub_sock_init(void **pubp, nni_sock *sock) { diff --git a/src/protocol/survey/survey.c b/src/protocol/survey/survey.c index d8ab065c..22baf2e8 100644 --- a/src/protocol/survey/survey.c +++ b/src/protocol/survey/survey.c @@ -143,11 +143,9 @@ static void nni_surv_pipe_sender(void *arg) { nni_surv_pipe *ppipe = arg; - nni_surv_sock *psock = ppipe->psock; nni_pipe *npipe = ppipe->npipe; nni_msgq *uwq = ppipe->sendq; - nni_msgq *urq = nni_sock_recvq(psock->nsock); - nni_mtx *mx = nni_sock_mtx(psock->nsock); + nni_msgq *urq = nni_sock_recvq(ppipe->psock->nsock); nni_msg *msg; int rv; |