lib9p_srv: Re-think flush semantics

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();