diff options
| author | Garrett D'Amore <garrett@damore.org> | 2019-02-17 10:17:26 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2019-02-17 10:17:26 -0800 |
| commit | 8ac664fdbab302c9e8cd16a1d45ace5bd00046e5 (patch) | |
| tree | 060f462549182d1b56c8868b70d238989764491b /src/protocol/reqrep0/rep.c | |
| parent | 60231f0600461a9593a8f876518874866df3387a (diff) | |
| download | nng-8ac664fdbab302c9e8cd16a1d45ace5bd00046e5.tar.gz nng-8ac664fdbab302c9e8cd16a1d45ace5bd00046e5.tar.bz2 nng-8ac664fdbab302c9e8cd16a1d45ace5bd00046e5.zip | |
fixes #871 panic when sharing rep between threads
Diffstat (limited to 'src/protocol/reqrep0/rep.c')
| -rw-r--r-- | src/protocol/reqrep0/rep.c | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/protocol/reqrep0/rep.c b/src/protocol/reqrep0/rep.c index 5f856f8e..2d00b65f 100644 --- a/src/protocol/reqrep0/rep.c +++ b/src/protocol/reqrep0/rep.c @@ -1,5 +1,5 @@ // -// Copyright 2018 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2019 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // // This software is supplied under the terms of the MIT License, a @@ -482,6 +482,14 @@ rep0_ctx_recv(void *arg, nni_aio *aio) nni_aio_finish_error(aio, rv); return; } + if (ctx->raio != NULL) { + // Cannot have a second receive operation pending. + // This could be ESTATE, or we could cancel the first + // with ECANCELED. We elect the former. + nni_mtx_unlock(&s->lk); + nni_aio_finish_error(aio, NNG_ESTATE); + return; + } ctx->raio = aio; nni_list_append(&s->recvq, ctx); nni_mtx_unlock(&s->lk); |