lib/thc/thcstubs.c

167   struct thc_receive_cancel_info *cinf = (struct thc_receive_cancel_info *)c;
169   thc_lock_acquire(&cinf->thc->thc_binding_lock);
170   assert(!cinf->was_canceled);
171   if (cinf->rxi->waiter == NULL) {
173     thc_lock_release(&cinf->thc->thc_binding_lock);
177     cinf->was_canceled = 1;
178     awe_t *awe = cinf->rxi->waiter;
179     cinf->rxi->waiter = NULL;
189   struct thc_receive_cancel_info cinf;
219   cinf.thc = thc;
220   cinf.rxi = rxi;
221   cinf.was_canceled = 0;
222   THCAddCancelItem(&ci, &thc_receive_x_cancel_fn, (void*)&cinf);
224   canceled = cinf.was_canceled;
320   struct thc_receive_cancel_info cinf;
342   cinf.thc = thc;
343   cinf.rxi = rxi;
344   cinf.was_canceled = 0;
345   THCAddCancelItem(&ci, &thc_receive_x_cancel_fn, (void*)&cinf);
347   canceled = cinf.was_canceled;
461   struct thc_receive_cancel_info cinf;
467   cinf.thc = thc;
468   cinf.rxi = rxi;
469   cinf.was_canceled = 0;
470   THCAddCancelItem(&ci, &thc_receive_x_cancel_fn, (void*)&cinf);
474   canceled = cinf.was_canceled;
532   struct thc_await_send_cancel_info *cinf = (struct thc_await_send_cancel_info*)c;
533   struct thc_per_binding_state_t *thc = cinf->thc;
542     assert(!cinf->was_canceled);
543     cinf->was_canceled = 1;
544     awe_t *awe = cinf->thc->waiting_sender;
545     cinf->thc->waiting_sender = NULL;
593   struct thc_await_send_cancel_info cinf;
626   cinf.thc = thc;
627   cinf.was_canceled = 0;
628   THCAddCancelItem(&ci, &thc_await_send_x_cancel_fn, (void*)&cinf);
632   canceled = cinf.was_canceled;