diff options
| author | Garrett D'Amore <garrett@damore.org> | 2023-12-29 15:37:45 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2023-12-29 15:37:45 -0800 |
| commit | 0c6f6b822959ab1f5e9fdf2b9cc5e1a1ea857708 (patch) | |
| tree | 95a68e967de5f145452b80adb61e1449a24ecae8 | |
| parent | 25bde0dcefca6da42d4168f54692204c83fe2ba4 (diff) | |
| download | nng-0c6f6b822959ab1f5e9fdf2b9cc5e1a1ea857708.tar.gz nng-0c6f6b822959ab1f5e9fdf2b9cc5e1a1ea857708.tar.bz2 nng-0c6f6b822959ab1f5e9fdf2b9cc5e1a1ea857708.zip | |
ipc: changing ep receive max should not affect established pipes
This code was not well tested, and is racy as well.
| -rw-r--r-- | src/sp/transport/ipc/ipc.c | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/src/sp/transport/ipc/ipc.c b/src/sp/transport/ipc/ipc.c index a8fc954b..5cde10f0 100644 --- a/src/sp/transport/ipc/ipc.c +++ b/src/sp/transport/ipc/ipc.c @@ -953,18 +953,8 @@ ipc_ep_set_recv_max_sz(void *arg, const void *v, size_t sz, nni_type t) int rv; if ((rv = nni_copyin_size(&val, v, sz, 0, NNI_MAXSZ, t)) == 0) { - ipc_pipe *p; nni_mtx_lock(&ep->mtx); ep->rcv_max = val; - NNI_LIST_FOREACH (&ep->wait_pipes, p) { - p->rcv_max = val; - } - NNI_LIST_FOREACH (&ep->neg_pipes, p) { - p->rcv_max = val; - } - NNI_LIST_FOREACH (&ep->busy_pipes, p) { - p->rcv_max = val; - } nni_mtx_unlock(&ep->mtx); #ifdef NNG_ENABLE_STATS nni_stat_set_value(&ep->st_rcv_max, val); |