Searched refs:sendq_token (Results 1 – 3 of 3) sorted by relevance
132 typedef struct sendq_token { struct133 struct sendq_token *next; argument154 sendq_token_t sendq_token; argument237 ((path_t *)((char *)(token) - ((char *)(&((path_t *)0)->sendq_token))))303 (path)->sendq_token.ref_cnt++; \304 ASSERT((path)->sendq_token.ref_cnt != 0); \308 (path)->sendq_token.ref_cnt--; \309 ASSERT((path)->sendq_token.ref_cnt >= 0); \310 if ((path)->sendq_token.ref_cnt == 0) \311 cv_signal(&(path)->sendq_token.sendq_cv); \
373 sendq_handle = path->sendq_token. in do_deferred_work()375 path->sendq_token.rsmpi_sendq_handle = in do_deferred_work()413 path->sendq_token.msgbuf_avail = 0; in do_deferred_work()484 cv_broadcast(&path->sendq_token.sendq_cv); in do_deferred_work()523 while (path->sendq_token.ref_cnt != 0) in do_deferred_work()524 cv_wait(&path->sendq_token.sendq_cv, in do_deferred_work()527 sendq_handle = path->sendq_token.rsmpi_sendq_handle; in do_deferred_work()528 path->sendq_token.rsmpi_sendq_handle = NULL; in do_deferred_work()919 cv_init(&path->sendq_token.sendq_cv, NULL, CV_DEFAULT, NULL); in rsmka_add_path()926 link_sendq_token(&path->sendq_token, remote_node); in rsmka_add_path()[all …]
3770 path->sendq_token.msgbuf_avail = RSMIPC_MAX_MESSAGES; in rsm_sqready_ack_deferred()3773 cv_broadcast(&path->sendq_token.sendq_cv); in rsm_sqready_ack_deferred()3846 path->sendq_token.msgbuf_avail = 0; in rsm_proc_sqready()3934 path->sendq_token.msgbuf_avail = RSMIPC_MAX_MESSAGES; in rsm_proc_sqready_ack()3937 cv_broadcast(&path->sendq_token.sendq_cv); in rsm_proc_sqready_ack()3999 path->sendq_token.msgbuf_avail, msghdr->rsmipc_src, in rsm_add_credits()4004 path->sendq_token.msgbuf_avail += msg->rsmipc_credits; in rsm_add_credits()4006 ASSERT(path->sendq_token.msgbuf_avail <= RSMIPC_MAX_MESSAGES); in rsm_add_credits()4009 cv_broadcast(&path->sendq_token.sendq_cv); in rsm_add_credits()5300 sendq_token_t *sendq_token; in rsmipc_send() local[all …]