diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-02 11:54:33 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-02 11:54:33 -0800 |
| commit | 9eb080db1c450228169cc58f14d946211378fcf7 (patch) | |
| tree | fcbbe3840b25c9651badd75950599f65e82caf01 /src/protocol/pair/pair.c | |
| parent | cceda25b65423de694f34b3decc7812eb46a4c1e (diff) | |
| download | nng-9eb080db1c450228169cc58f14d946211378fcf7.tar.gz nng-9eb080db1c450228169cc58f14d946211378fcf7.tar.bz2 nng-9eb080db1c450228169cc58f14d946211378fcf7.zip | |
Change msgqueue -> msgq.
Diffstat (limited to 'src/protocol/pair/pair.c')
| -rw-r--r-- | src/protocol/pair/pair.c | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/protocol/pair/pair.c b/src/protocol/pair/pair.c index 6ca891f0..642f2845 100644 --- a/src/protocol/pair/pair.c +++ b/src/protocol/pair/pair.c @@ -24,8 +24,8 @@ struct nni_pair_sock { nni_socket * sock; nni_pair_pipe * pipe; nni_mtx mx; - nni_msgqueue * uwq; - nni_msgqueue * urq; + nni_msgq * uwq; + nni_msgq * urq; }; // An nni_pair_pipe is our per-pipe protocol private structure. We keep @@ -118,14 +118,14 @@ nni_pair_sender(void *arg) { nni_pair_pipe *pp = arg; nni_pair_sock *pair = pp->pair; - nni_msgqueue *uwq = pair->uwq; - nni_msgqueue *urq = pair->urq; + nni_msgq *uwq = pair->uwq; + nni_msgq *urq = pair->urq; nni_pipe *pipe = pp->pipe; nni_msg *msg; int rv; for (;;) { - rv = nni_msgqueue_get_sig(uwq, &msg, &pp->sigclose); + rv = nni_msgq_get_sig(uwq, &msg, &pp->sigclose); if (rv != 0) { break; } @@ -135,7 +135,7 @@ nni_pair_sender(void *arg) break; } } - nni_msgqueue_signal(urq, &pp->sigclose); + nni_msgq_signal(urq, &pp->sigclose); nni_pipe_close(pipe); } @@ -145,8 +145,8 @@ nni_pair_receiver(void *arg) { nni_pair_pipe *pp = arg; nni_pair_sock *pair = pp->pair; - nni_msgqueue *urq = pair->urq; - nni_msgqueue *uwq = pair->uwq; + nni_msgq *urq = pair->urq; + nni_msgq *uwq = pair->uwq; nni_pipe *pipe = pp->pipe; nni_msg *msg; int rv; @@ -156,13 +156,13 @@ nni_pair_receiver(void *arg) if (rv != 0) { break; } - rv = nni_msgqueue_put_sig(urq, msg, &pp->sigclose); + rv = nni_msgq_put_sig(urq, msg, &pp->sigclose); if (rv != 0) { nni_msg_free(msg); break; } } - nni_msgqueue_signal(uwq, &pp->sigclose); + nni_msgq_signal(uwq, &pp->sigclose); nni_pipe_close(pipe); } |