From 0c6f6b822959ab1f5e9fdf2b9cc5e1a1ea857708 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Fri, 29 Dec 2023 15:37:45 -0800 Subject: ipc: changing ep receive max should not affect established pipes This code was not well tested, and is racy as well. --- src/sp/transport/ipc/ipc.c | 10 ---------- 1 file changed, 10 deletions(-) (limited to 'src') 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); -- cgit v1.2.3-70-g09d2