Lines Matching refs:rrq
986 struct lpfc_node_rrq *rrq) in lpfc_clr_rrq_active() argument
991 if (rrq->vport) in lpfc_clr_rrq_active()
992 ndlp = lpfc_findnode_did(rrq->vport, rrq->nlp_DID); in lpfc_clr_rrq_active()
998 rrq->send_rrq = 0; in lpfc_clr_rrq_active()
999 rrq->xritag = 0; in lpfc_clr_rrq_active()
1000 rrq->rrq_stop_time = 0; in lpfc_clr_rrq_active()
1003 mempool_free(rrq, phba->rrq_pool); in lpfc_clr_rrq_active()
1023 struct lpfc_node_rrq *rrq; in lpfc_handle_rrq_active() local
1032 list_for_each_entry_safe(rrq, nextrrq, in lpfc_handle_rrq_active()
1034 if (time_after(jiffies, rrq->rrq_stop_time)) in lpfc_handle_rrq_active()
1035 list_move(&rrq->list, &send_rrq); in lpfc_handle_rrq_active()
1036 else if (time_before(rrq->rrq_stop_time, next_time)) in lpfc_handle_rrq_active()
1037 next_time = rrq->rrq_stop_time; in lpfc_handle_rrq_active()
1043 list_for_each_entry_safe(rrq, nextrrq, &send_rrq, list) { in lpfc_handle_rrq_active()
1044 list_del(&rrq->list); in lpfc_handle_rrq_active()
1045 if (!rrq->send_rrq) { in lpfc_handle_rrq_active()
1047 lpfc_clr_rrq_active(phba, rrq->xritag, rrq); in lpfc_handle_rrq_active()
1048 } else if (lpfc_send_rrq(phba, rrq)) { in lpfc_handle_rrq_active()
1052 lpfc_clr_rrq_active(phba, rrq->xritag, in lpfc_handle_rrq_active()
1053 rrq); in lpfc_handle_rrq_active()
1071 struct lpfc_node_rrq *rrq; in lpfc_get_active_rrq() local
1078 list_for_each_entry_safe(rrq, nextrrq, &phba->active_rrq_list, list) { in lpfc_get_active_rrq()
1079 if (rrq->vport == vport && rrq->xritag == xri && in lpfc_get_active_rrq()
1080 rrq->nlp_DID == did){ in lpfc_get_active_rrq()
1081 list_del(&rrq->list); in lpfc_get_active_rrq()
1083 return rrq; in lpfc_get_active_rrq()
1103 struct lpfc_node_rrq *rrq; in lpfc_cleanup_vports_rrqs() local
1115 list_for_each_entry_safe(rrq, nextrrq, &phba->active_rrq_list, list) { in lpfc_cleanup_vports_rrqs()
1116 if (rrq->vport != vport) in lpfc_cleanup_vports_rrqs()
1119 if (!ndlp || ndlp == lpfc_findnode_did(vport, rrq->nlp_DID)) in lpfc_cleanup_vports_rrqs()
1120 list_move(&rrq->list, &rrq_list); in lpfc_cleanup_vports_rrqs()
1125 list_for_each_entry_safe(rrq, nextrrq, &rrq_list, list) { in lpfc_cleanup_vports_rrqs()
1126 list_del(&rrq->list); in lpfc_cleanup_vports_rrqs()
1127 lpfc_clr_rrq_active(phba, rrq->xritag, rrq); in lpfc_cleanup_vports_rrqs()
1175 struct lpfc_node_rrq *rrq; in lpfc_set_rrq_active() local
1200 rrq = mempool_alloc(phba->rrq_pool, GFP_ATOMIC); in lpfc_set_rrq_active()
1201 if (!rrq) { in lpfc_set_rrq_active()
1209 rrq->send_rrq = send_rrq; in lpfc_set_rrq_active()
1211 rrq->send_rrq = 0; in lpfc_set_rrq_active()
1212 rrq->xritag = xritag; in lpfc_set_rrq_active()
1213 rrq->rrq_stop_time = jiffies + in lpfc_set_rrq_active()
1215 rrq->nlp_DID = ndlp->nlp_DID; in lpfc_set_rrq_active()
1216 rrq->vport = ndlp->vport; in lpfc_set_rrq_active()
1217 rrq->rxid = rxid; in lpfc_set_rrq_active()
1220 list_add_tail(&rrq->list, &phba->active_rrq_list); in lpfc_set_rrq_active()