diff options
| author | Garrett D'Amore <garrett@damore.org> | 2018-05-09 12:19:28 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2018-05-09 12:19:28 -0700 |
| commit | 25e801be9c4889b8df48cce842bbf2e2628d38db (patch) | |
| tree | 92e8e3d2087480c68313ebf05ccdfe43b3f25382 /src/protocol/reqrep0 | |
| parent | 7f7d4eee9a51cbe2088d465aa725aaf8f8424917 (diff) | |
| download | nng-25e801be9c4889b8df48cce842bbf2e2628d38db.tar.gz nng-25e801be9c4889b8df48cce842bbf2e2628d38db.tar.bz2 nng-25e801be9c4889b8df48cce842bbf2e2628d38db.zip | |
fixes #424 reqstress low frequency crash
Diffstat (limited to 'src/protocol/reqrep0')
| -rw-r--r-- | src/protocol/reqrep0/rep.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/protocol/reqrep0/rep.c b/src/protocol/reqrep0/rep.c index 385860cd..019727be 100644 --- a/src/protocol/reqrep0/rep.c +++ b/src/protocol/reqrep0/rep.c @@ -355,6 +355,10 @@ rep0_pipe_stop(void *arg) rep0_ctx * ctx; nni_mtx_lock(&s->lk); + if (nni_list_active(&s->recvpipes, p)) { + // We are no longer "receivable". + nni_list_remove(&s->recvpipes, p); + } while ((ctx = nni_list_first(&p->sendq)) != NULL) { nni_aio *aio; nni_msg *msg; |