Lines Matching refs:rrq

859 		    struct lpfc_node_rrq *rrq)  in lpfc_clr_rrq_active()  argument
863 if ((rrq->vport) && NLP_CHK_NODE_ACT(rrq->ndlp)) in lpfc_clr_rrq_active()
864 ndlp = lpfc_findnode_did(rrq->vport, rrq->nlp_DID); in lpfc_clr_rrq_active()
870 if ((!ndlp) && rrq->ndlp) in lpfc_clr_rrq_active()
871 ndlp = rrq->ndlp; in lpfc_clr_rrq_active()
877 rrq->send_rrq = 0; in lpfc_clr_rrq_active()
878 rrq->xritag = 0; in lpfc_clr_rrq_active()
879 rrq->rrq_stop_time = 0; in lpfc_clr_rrq_active()
882 mempool_free(rrq, phba->rrq_pool); in lpfc_clr_rrq_active()
902 struct lpfc_node_rrq *rrq; in lpfc_handle_rrq_active() local
911 list_for_each_entry_safe(rrq, nextrrq, in lpfc_handle_rrq_active()
913 if (time_after(jiffies, rrq->rrq_stop_time)) in lpfc_handle_rrq_active()
914 list_move(&rrq->list, &send_rrq); in lpfc_handle_rrq_active()
915 else if (time_before(rrq->rrq_stop_time, next_time)) in lpfc_handle_rrq_active()
916 next_time = rrq->rrq_stop_time; in lpfc_handle_rrq_active()
922 list_for_each_entry_safe(rrq, nextrrq, &send_rrq, list) { in lpfc_handle_rrq_active()
923 list_del(&rrq->list); in lpfc_handle_rrq_active()
924 if (!rrq->send_rrq) { in lpfc_handle_rrq_active()
926 lpfc_clr_rrq_active(phba, rrq->xritag, rrq); in lpfc_handle_rrq_active()
927 } else if (lpfc_send_rrq(phba, rrq)) { in lpfc_handle_rrq_active()
931 lpfc_clr_rrq_active(phba, rrq->xritag, in lpfc_handle_rrq_active()
932 rrq); in lpfc_handle_rrq_active()
950 struct lpfc_node_rrq *rrq; in lpfc_get_active_rrq() local
957 list_for_each_entry_safe(rrq, nextrrq, &phba->active_rrq_list, list) { in lpfc_get_active_rrq()
958 if (rrq->vport == vport && rrq->xritag == xri && in lpfc_get_active_rrq()
959 rrq->nlp_DID == did){ in lpfc_get_active_rrq()
960 list_del(&rrq->list); in lpfc_get_active_rrq()
962 return rrq; in lpfc_get_active_rrq()
982 struct lpfc_node_rrq *rrq; in lpfc_cleanup_vports_rrqs() local
994 list_for_each_entry_safe(rrq, nextrrq, &phba->active_rrq_list, list) in lpfc_cleanup_vports_rrqs()
995 if ((rrq->vport == vport) && (!ndlp || rrq->ndlp == ndlp)) in lpfc_cleanup_vports_rrqs()
996 list_move(&rrq->list, &rrq_list); in lpfc_cleanup_vports_rrqs()
999 list_for_each_entry_safe(rrq, nextrrq, &rrq_list, list) { in lpfc_cleanup_vports_rrqs()
1000 list_del(&rrq->list); in lpfc_cleanup_vports_rrqs()
1001 lpfc_clr_rrq_active(phba, rrq->xritag, rrq); in lpfc_cleanup_vports_rrqs()
1049 struct lpfc_node_rrq *rrq; in lpfc_set_rrq_active() local
1080 rrq = mempool_alloc(phba->rrq_pool, GFP_ATOMIC); in lpfc_set_rrq_active()
1081 if (!rrq) { in lpfc_set_rrq_active()
1089 rrq->send_rrq = send_rrq; in lpfc_set_rrq_active()
1091 rrq->send_rrq = 0; in lpfc_set_rrq_active()
1092 rrq->xritag = xritag; in lpfc_set_rrq_active()
1093 rrq->rrq_stop_time = jiffies + in lpfc_set_rrq_active()
1095 rrq->ndlp = ndlp; in lpfc_set_rrq_active()
1096 rrq->nlp_DID = ndlp->nlp_DID; in lpfc_set_rrq_active()
1097 rrq->vport = ndlp->vport; in lpfc_set_rrq_active()
1098 rrq->rxid = rxid; in lpfc_set_rrq_active()
1101 list_add_tail(&rrq->list, &phba->active_rrq_list); in lpfc_set_rrq_active()