Home
last modified time | relevance | path

Searched refs:msg_list (Results 1 – 5 of 5) sorted by relevance

/drivers/staging/lustre/lnet/lnet/
Dnet_fault.c516 list_add_tail(&msg->msg_list, &rule->dl_msg_list); in delay_rule_match()
563 struct list_head *msg_list) in delayed_msg_check() argument
573 list_for_each_entry_safe(msg, tmp, &rule->dl_msg_list, msg_list) { in delayed_msg_check()
578 list_move_tail(&msg->msg_list, msg_list); in delayed_msg_check()
585 } else if (!list_empty(msg_list)) { in delayed_msg_check()
591 struct lnet_msg, msg_list); in delayed_msg_check()
599 delayed_msg_process(struct list_head *msg_list, bool drop) in delayed_msg_process() argument
603 while (!list_empty(msg_list)) { in delayed_msg_process()
608 msg = list_entry(msg_list->next, struct lnet_msg, msg_list); in delayed_msg_process()
614 list_del_init(&msg->msg_list); in delayed_msg_process()
[all …]
Dlib-ptl.c454 list_add_tail(&msg->msg_list, in lnet_ptl_match_early()
497 list_add_tail(&msg->msg_list, in lnet_ptl_match_delay()
501 if (!list_empty(&msg->msg_list)) { in lnet_ptl_match_delay()
511 list_del_init(&msg->msg_list); in lnet_ptl_match_delay()
524 list_del_init(&msg->msg_list); in lnet_ptl_match_delay()
528 list_add_tail(&msg->msg_list, in lnet_ptl_match_delay()
617 list_add_tail(&msg->msg_list, &ptl->ptl_msg_delayed); in lnet_ptl_match_md()
681 list_for_each_entry_safe(msg, tmp, head, msg_list) { in lnet_ptl_attach_md()
708 list_del_init(&msg->msg_list); in lnet_ptl_attach_md()
718 list_add_tail(&msg->msg_list, matches); in lnet_ptl_attach_md()
[all …]
Dlib-move.c651 list_add_tail(&msg->msg_list, &lp->lp_txq); in lnet_post_send_locked()
668 list_add_tail(&msg->msg_list, &tq->tq_delayed); in lnet_post_send_locked()
737 list_add_tail(&msg->msg_list, &lp->lp_rtrq); in lnet_post_routed_recv_locked()
754 list_add_tail(&msg->msg_list, &rbp->rbp_msgs); in lnet_post_routed_recv_locked()
796 lnet_msg_t, msg_list); in lnet_return_tx_credits_locked()
797 list_del(&msg2->msg_list); in lnet_return_tx_credits_locked()
819 lnet_msg_t, msg_list); in lnet_return_tx_credits_locked()
820 list_del(&msg2->msg_list); in lnet_return_tx_credits_locked()
843 lnet_msg_t, msg_list); in lnet_schedule_blocked_locked()
844 list_del(&msg->msg_list); in lnet_schedule_blocked_locked()
[all …]
Dlib-msg.c481 list_add_tail(&msg->msg_list, &container->msc_finalizing); in lnet_finalize()
505 lnet_msg_t, msg_list); in lnet_finalize()
507 list_del(&msg->msg_list); in lnet_finalize()
/drivers/staging/lustre/include/linux/lnet/
Dlib-types.h59 struct list_head msg_list; /* Q for credits/MD */ member