Skip to content

Commit 0c6f6b8

Browse files
committed
ipc: changing ep receive max should not affect established pipes
This code was not well tested, and is racy as well.
1 parent 25bde0d commit 0c6f6b8

File tree

1 file changed

+0
-10
lines changed
  • src/sp/transport/ipc

1 file changed

+0
-10
lines changed

src/sp/transport/ipc/ipc.c

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -953,18 +953,8 @@ ipc_ep_set_recv_max_sz(void *arg, const void *v, size_t sz, nni_type t)
953953
int rv;
954954
if ((rv = nni_copyin_size(&val, v, sz, 0, NNI_MAXSZ, t)) == 0) {
955955

956-
ipc_pipe *p;
957956
nni_mtx_lock(&ep->mtx);
958957
ep->rcv_max = val;
959-
NNI_LIST_FOREACH (&ep->wait_pipes, p) {
960-
p->rcv_max = val;
961-
}
962-
NNI_LIST_FOREACH (&ep->neg_pipes, p) {
963-
p->rcv_max = val;
964-
}
965-
NNI_LIST_FOREACH (&ep->busy_pipes, p) {
966-
p->rcv_max = val;
967-
}
968958
nni_mtx_unlock(&ep->mtx);
969959
#ifdef NNG_ENABLE_STATS
970960
nni_stat_set_value(&ep->st_rcv_max, val);

0 commit comments

Comments
 (0)