diff options
Diffstat (limited to 'libcr_ipc/chan.c')
| -rw-r--r-- | libcr_ipc/chan.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/libcr_ipc/chan.c b/libcr_ipc/chan.c index 7708fe4..b7ecfc8 100644 --- a/libcr_ipc/chan.c +++ b/libcr_ipc/chan.c @@ -100,6 +100,7 @@ size_t cr_select_v(size_t arg_cnt, struct _cr_select_arg_list_node arg_vec[]) { } struct _cr_select_waiter *waiter = other->waiter; for (size_t i = 0; i < waiter->arg_cnt; i++) { + waiter->arg_vec[i].val.ch->nwaiters--; dlist_remove(&waiter->arg_vec[i].val.ch->waiters, &waiter->arg_vec[i]); if (&waiter->arg_vec[i].val == other) waiter->ret = i; @@ -125,6 +126,7 @@ size_t cr_select_v(size_t arg_cnt, struct _cr_select_arg_list_node arg_vec[]) { }; for (size_t i = 0; i < arg_cnt; i++) { arg_vec[i].val.waiter = &waiter; + arg_vec[i].val.ch->nwaiters++; dlist_push_to_rear(&arg_vec[i].val.ch->waiters, &arg_vec[i]); } cr_pause_and_yield(); |