107 	struct fc_rport_priv *rdata = NULL, *tmp_rdata;  in fc_rport_lookup()  local
113 			rdata = tmp_rdata;  in fc_rport_lookup()
117 	return rdata;  in fc_rport_lookup()
130 	struct fc_rport_priv *rdata;  in fc_rport_create()  local
131 	size_t rport_priv_size = sizeof(*rdata);  in fc_rport_create()
135 	rdata = fc_rport_lookup(lport, port_id);  in fc_rport_create()
136 	if (rdata) {  in fc_rport_create()
137 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_create()
138 		return rdata;  in fc_rport_create()
143 	rdata = kzalloc(rport_priv_size, GFP_KERNEL);  in fc_rport_create()
144 	if (!rdata)  in fc_rport_create()
147 	rdata->ids.node_name = -1;  in fc_rport_create()
148 	rdata->ids.port_name = -1;  in fc_rport_create()
149 	rdata->ids.port_id = port_id;  in fc_rport_create()
150 	rdata->ids.roles = FC_RPORT_ROLE_UNKNOWN;  in fc_rport_create()
152 	kref_init(&rdata->kref);  in fc_rport_create()
153 	mutex_init(&rdata->rp_mutex);  in fc_rport_create()
154 	rdata->local_port = lport;  in fc_rport_create()
155 	rdata->rp_state = RPORT_ST_INIT;  in fc_rport_create()
156 	rdata->event = RPORT_EV_NONE;  in fc_rport_create()
157 	rdata->flags = FC_RP_FLAGS_REC_SUPPORTED;  in fc_rport_create()
158 	rdata->e_d_tov = lport->e_d_tov;  in fc_rport_create()
159 	rdata->r_a_tov = lport->r_a_tov;  in fc_rport_create()
160 	rdata->maxframe_size = FC_MIN_MAX_PAYLOAD;  in fc_rport_create()
161 	INIT_DELAYED_WORK(&rdata->retry_work, fc_rport_timeout);  in fc_rport_create()
162 	INIT_WORK(&rdata->event_work, fc_rport_work);  in fc_rport_create()
164 		rdata->lld_event_callback = lport->tt.rport_event_callback;  in fc_rport_create()
165 		list_add_rcu(&rdata->peers, &lport->disc.rports);  in fc_rport_create()
167 	return rdata;  in fc_rport_create()
177 	struct fc_rport_priv *rdata;  in fc_rport_destroy()  local
179 	rdata = container_of(kref, struct fc_rport_priv, kref);  in fc_rport_destroy()
180 	kfree_rcu(rdata, rcu);  in fc_rport_destroy()
188 static const char *fc_rport_state(struct fc_rport_priv *rdata)  in fc_rport_state()  argument
192 	cp = fc_rport_state_names[rdata->rp_state];  in fc_rport_state()
242 static void fc_rport_state_enter(struct fc_rport_priv *rdata,  in fc_rport_state_enter()  argument
245 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_state_enter()
247 	if (rdata->rp_state != new)  in fc_rport_state_enter()
248 		rdata->retries = 0;  in fc_rport_state_enter()
249 	rdata->rp_state = new;  in fc_rport_state_enter()
261 	struct fc_rport_priv *rdata =  in fc_rport_work()  local
265 	struct fc_lport *lport = rdata->local_port;  in fc_rport_work()
272 	mutex_lock(&rdata->rp_mutex);  in fc_rport_work()
273 	event = rdata->event;  in fc_rport_work()
274 	rport_ops = rdata->ops;  in fc_rport_work()
275 	rport = rdata->rport;  in fc_rport_work()
277 	FC_RPORT_DBG(rdata, "work event %u\n", event);  in fc_rport_work()
281 		ids = rdata->ids;  in fc_rport_work()
282 		rdata->event = RPORT_EV_NONE;  in fc_rport_work()
283 		rdata->major_retries = 0;  in fc_rport_work()
284 		kref_get(&rdata->kref);  in fc_rport_work()
285 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
288 			FC_RPORT_DBG(rdata, "No rport!\n");  in fc_rport_work()
292 			FC_RPORT_DBG(rdata, "Failed to add the rport\n");  in fc_rport_work()
293 			fc_rport_logoff(rdata);  in fc_rport_work()
294 			kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_work()
297 		mutex_lock(&rdata->rp_mutex);  in fc_rport_work()
298 		if (rdata->rport)  in fc_rport_work()
299 			FC_RPORT_DBG(rdata, "rport already allocated\n");  in fc_rport_work()
300 		rdata->rport = rport;  in fc_rport_work()
301 		rport->maxframe_size = rdata->maxframe_size;  in fc_rport_work()
302 		rport->supported_classes = rdata->supported_classes;  in fc_rport_work()
306 		rpriv->rp_state = rdata->rp_state;  in fc_rport_work()
307 		rpriv->flags = rdata->flags;  in fc_rport_work()
308 		rpriv->e_d_tov = rdata->e_d_tov;  in fc_rport_work()
309 		rpriv->r_a_tov = rdata->r_a_tov;  in fc_rport_work()
310 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
313 			FC_RPORT_DBG(rdata, "callback ev %d\n", event);  in fc_rport_work()
314 			rport_ops->event_callback(lport, rdata, event);  in fc_rport_work()
316 		if (rdata->lld_event_callback) {  in fc_rport_work()
317 			FC_RPORT_DBG(rdata, "lld callback ev %d\n", event);  in fc_rport_work()
318 			rdata->lld_event_callback(lport, rdata, event);  in fc_rport_work()
320 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_work()
326 		if (rdata->prli_count) {  in fc_rport_work()
331 					prov->prlo(rdata);  in fc_rport_work()
335 		port_id = rdata->ids.port_id;  in fc_rport_work()
336 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
339 			FC_RPORT_DBG(rdata, "callback ev %d\n", event);  in fc_rport_work()
340 			rport_ops->event_callback(lport, rdata, event);  in fc_rport_work()
342 		if (rdata->lld_event_callback) {  in fc_rport_work()
343 			FC_RPORT_DBG(rdata, "lld callback ev %d\n", event);  in fc_rport_work()
344 			rdata->lld_event_callback(lport, rdata, event);  in fc_rport_work()
346 		if (cancel_delayed_work_sync(&rdata->retry_work))  in fc_rport_work()
347 			kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_work()
358 			mutex_lock(&rdata->rp_mutex);  in fc_rport_work()
359 			rdata->rport = NULL;  in fc_rport_work()
360 			mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
364 		mutex_lock(&rdata->rp_mutex);  in fc_rport_work()
365 		if (rdata->rp_state == RPORT_ST_DELETE) {  in fc_rport_work()
367 				rdata->event = RPORT_EV_NONE;  in fc_rport_work()
368 				mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
369 				kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_work()
370 			} else if ((rdata->flags & FC_RP_STARTED) &&  in fc_rport_work()
371 				   rdata->major_retries <  in fc_rport_work()
373 				rdata->major_retries++;  in fc_rport_work()
374 				rdata->event = RPORT_EV_NONE;  in fc_rport_work()
375 				FC_RPORT_DBG(rdata, "work restart\n");  in fc_rport_work()
376 				fc_rport_enter_flogi(rdata);  in fc_rport_work()
377 				mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
379 				mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
380 				FC_RPORT_DBG(rdata, "work delete\n");  in fc_rport_work()
382 				list_del_rcu(&rdata->peers);  in fc_rport_work()
384 				kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_work()
390 			rdata->event = RPORT_EV_NONE;  in fc_rport_work()
391 			if (rdata->rp_state == RPORT_ST_READY) {  in fc_rport_work()
392 				FC_RPORT_DBG(rdata, "work reopen\n");  in fc_rport_work()
393 				fc_rport_enter_ready(rdata);  in fc_rport_work()
395 			mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
400 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_work()
403 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_work()
426 int fc_rport_login(struct fc_rport_priv *rdata)  in fc_rport_login()  argument
428 	mutex_lock(&rdata->rp_mutex);  in fc_rport_login()
430 	if (rdata->flags & FC_RP_STARTED) {  in fc_rport_login()
431 		FC_RPORT_DBG(rdata, "port already started\n");  in fc_rport_login()
432 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_login()
436 	rdata->flags |= FC_RP_STARTED;  in fc_rport_login()
437 	switch (rdata->rp_state) {  in fc_rport_login()
439 		FC_RPORT_DBG(rdata, "ADISC port\n");  in fc_rport_login()
440 		fc_rport_enter_adisc(rdata);  in fc_rport_login()
443 		FC_RPORT_DBG(rdata, "Restart deleted port\n");  in fc_rport_login()
446 		FC_RPORT_DBG(rdata, "Login to port\n");  in fc_rport_login()
447 		fc_rport_enter_flogi(rdata);  in fc_rport_login()
450 		FC_RPORT_DBG(rdata, "Login in progress, state %s\n",  in fc_rport_login()
451 			     fc_rport_state(rdata));  in fc_rport_login()
454 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_login()
474 static void fc_rport_enter_delete(struct fc_rport_priv *rdata,  in fc_rport_enter_delete()  argument
477 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_delete()
479 	if (rdata->rp_state == RPORT_ST_DELETE)  in fc_rport_enter_delete()
482 	FC_RPORT_DBG(rdata, "Delete port\n");  in fc_rport_enter_delete()
484 	fc_rport_state_enter(rdata, RPORT_ST_DELETE);  in fc_rport_enter_delete()
486 	if (rdata->event == RPORT_EV_NONE) {  in fc_rport_enter_delete()
487 		kref_get(&rdata->kref);  in fc_rport_enter_delete()
488 		if (!queue_work(rport_event_queue, &rdata->event_work))  in fc_rport_enter_delete()
489 			kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_delete()
492 	rdata->event = event;  in fc_rport_enter_delete()
503 int fc_rport_logoff(struct fc_rport_priv *rdata)  in fc_rport_logoff()  argument
505 	struct fc_lport *lport = rdata->local_port;  in fc_rport_logoff()
506 	u32 port_id = rdata->ids.port_id;  in fc_rport_logoff()
508 	mutex_lock(&rdata->rp_mutex);  in fc_rport_logoff()
510 	FC_RPORT_DBG(rdata, "Remove port\n");  in fc_rport_logoff()
512 	rdata->flags &= ~FC_RP_STARTED;  in fc_rport_logoff()
513 	if (rdata->rp_state == RPORT_ST_DELETE) {  in fc_rport_logoff()
514 		FC_RPORT_DBG(rdata, "Port in Delete state, not removing\n");  in fc_rport_logoff()
526 	fc_rport_enter_logo(rdata);  in fc_rport_logoff()
532 	fc_rport_enter_delete(rdata, RPORT_EV_STOP);  in fc_rport_logoff()
534 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_logoff()
545 static void fc_rport_enter_ready(struct fc_rport_priv *rdata)  in fc_rport_enter_ready()  argument
547 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_ready()
549 	fc_rport_state_enter(rdata, RPORT_ST_READY);  in fc_rport_enter_ready()
551 	FC_RPORT_DBG(rdata, "Port is Ready\n");  in fc_rport_enter_ready()
553 	kref_get(&rdata->kref);  in fc_rport_enter_ready()
554 	if (rdata->event == RPORT_EV_NONE &&  in fc_rport_enter_ready()
555 	    !queue_work(rport_event_queue, &rdata->event_work))  in fc_rport_enter_ready()
556 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_ready()
558 	rdata->event = RPORT_EV_READY;  in fc_rport_enter_ready()
573 	struct fc_rport_priv *rdata =  in fc_rport_timeout()  local
576 	mutex_lock(&rdata->rp_mutex);  in fc_rport_timeout()
577 	FC_RPORT_DBG(rdata, "Port timeout, state %s\n", fc_rport_state(rdata));  in fc_rport_timeout()
579 	switch (rdata->rp_state) {  in fc_rport_timeout()
581 		fc_rport_enter_flogi(rdata);  in fc_rport_timeout()
584 		fc_rport_enter_plogi(rdata);  in fc_rport_timeout()
587 		fc_rport_enter_prli(rdata);  in fc_rport_timeout()
590 		fc_rport_enter_rtv(rdata);  in fc_rport_timeout()
593 		fc_rport_enter_adisc(rdata);  in fc_rport_timeout()
602 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_timeout()
603 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_timeout()
613 static void fc_rport_error(struct fc_rport_priv *rdata, int err)  in fc_rport_error()  argument
615 	struct fc_lport *lport = rdata->local_port;  in fc_rport_error()
617 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_error()
619 	FC_RPORT_DBG(rdata, "Error %d in state %s, retries %d\n",  in fc_rport_error()
620 		     -err, fc_rport_state(rdata), rdata->retries);  in fc_rport_error()
622 	switch (rdata->rp_state) {  in fc_rport_error()
624 		rdata->flags &= ~FC_RP_STARTED;  in fc_rport_error()
625 		fc_rport_enter_delete(rdata, RPORT_EV_FAILED);  in fc_rport_error()
629 			rdata->flags &= ~FC_RP_STARTED;  in fc_rport_error()
630 			fc_rport_enter_delete(rdata, RPORT_EV_FAILED);  in fc_rport_error()
632 			fc_rport_enter_logo(rdata);  in fc_rport_error()
635 		fc_rport_enter_ready(rdata);  in fc_rport_error()
638 		fc_rport_enter_plogi(rdata);  in fc_rport_error()
641 		fc_rport_enter_logo(rdata);  in fc_rport_error()
661 static void fc_rport_error_retry(struct fc_rport_priv *rdata, int err)  in fc_rport_error_retry()  argument
663 	unsigned long delay = msecs_to_jiffies(rdata->e_d_tov);  in fc_rport_error_retry()
665 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_error_retry()
671 	if (rdata->retries < rdata->local_port->max_rport_retry_count) {  in fc_rport_error_retry()
672 		FC_RPORT_DBG(rdata, "Error %d in state %s, retrying\n",  in fc_rport_error_retry()
673 			     err, fc_rport_state(rdata));  in fc_rport_error_retry()
674 		rdata->retries++;  in fc_rport_error_retry()
678 		kref_get(&rdata->kref);  in fc_rport_error_retry()
679 		if (!schedule_delayed_work(&rdata->retry_work, delay))  in fc_rport_error_retry()
680 			kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_error_retry()
685 	fc_rport_error(rdata, err);  in fc_rport_error_retry()
698 static int fc_rport_login_complete(struct fc_rport_priv *rdata,  in fc_rport_login_complete()  argument
701 	struct fc_lport *lport = rdata->local_port;  in fc_rport_login_complete()
714 			FC_RPORT_DBG(rdata, "Fabric bit set in FLOGI\n");  in fc_rport_login_complete()
725 		if (e_d_tov > rdata->e_d_tov)  in fc_rport_login_complete()
726 			rdata->e_d_tov = e_d_tov;  in fc_rport_login_complete()
728 	rdata->maxframe_size = fc_plogi_get_maxframe(flogi, lport->mfs);  in fc_rport_login_complete()
741 	struct fc_rport_priv *rdata = rp_arg;  in fc_rport_flogi_resp()  local
742 	struct fc_lport *lport = rdata->local_port;  in fc_rport_flogi_resp()
748 	FC_RPORT_DBG(rdata, "Received a FLOGI %s\n",  in fc_rport_flogi_resp()
754 	mutex_lock(&rdata->rp_mutex);  in fc_rport_flogi_resp()
756 	if (rdata->rp_state != RPORT_ST_FLOGI) {  in fc_rport_flogi_resp()
757 		FC_RPORT_DBG(rdata, "Received a FLOGI response, but in state "  in fc_rport_flogi_resp()
758 			     "%s\n", fc_rport_state(rdata));  in fc_rport_flogi_resp()
765 		fc_rport_error(rdata, PTR_ERR(fp));  in fc_rport_flogi_resp()
773 		FC_RPORT_DBG(rdata, "FLOGI ELS rejected, reason %x expl %x\n",  in fc_rport_flogi_resp()
778 		FC_RPORT_DBG(rdata, "FLOGI ELS invalid opcode %x\n", opcode);  in fc_rport_flogi_resp()
782 	if (fc_rport_login_complete(rdata, fp)) {  in fc_rport_flogi_resp()
783 		FC_RPORT_DBG(rdata, "FLOGI failed, no login\n");  in fc_rport_flogi_resp()
794 	if (r_a_tov > rdata->r_a_tov)  in fc_rport_flogi_resp()
795 		rdata->r_a_tov = r_a_tov;  in fc_rport_flogi_resp()
797 	if (rdata->ids.port_name < lport->wwpn)  in fc_rport_flogi_resp()
798 		fc_rport_enter_plogi(rdata);  in fc_rport_flogi_resp()
800 		fc_rport_state_enter(rdata, RPORT_ST_PLOGI_WAIT);  in fc_rport_flogi_resp()
804 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_flogi_resp()
806 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_flogi_resp()
809 	FC_RPORT_DBG(rdata, "Bad FLOGI response\n");  in fc_rport_flogi_resp()
810 	fc_rport_error_retry(rdata, err);  in fc_rport_flogi_resp()
820 static void fc_rport_enter_flogi(struct fc_rport_priv *rdata)  in fc_rport_enter_flogi()  argument
822 	struct fc_lport *lport = rdata->local_port;  in fc_rport_enter_flogi()
825 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_flogi()
828 		return fc_rport_enter_plogi(rdata);  in fc_rport_enter_flogi()
830 	FC_RPORT_DBG(rdata, "Entered FLOGI state from %s state\n",  in fc_rport_enter_flogi()
831 		     fc_rport_state(rdata));  in fc_rport_enter_flogi()
833 	fc_rport_state_enter(rdata, RPORT_ST_FLOGI);  in fc_rport_enter_flogi()
837 		return fc_rport_error_retry(rdata, -FC_EX_ALLOC_ERR);  in fc_rport_enter_flogi()
839 	kref_get(&rdata->kref);  in fc_rport_enter_flogi()
840 	if (!lport->tt.elsct_send(lport, rdata->ids.port_id, fp, ELS_FLOGI,  in fc_rport_enter_flogi()
841 				  fc_rport_flogi_resp, rdata,  in fc_rport_enter_flogi()
843 		fc_rport_error_retry(rdata, -FC_EX_XMIT_ERR);  in fc_rport_enter_flogi()
844 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_flogi()
859 	struct fc_rport_priv *rdata;  in fc_rport_recv_flogi_req()  local
881 	rdata = fc_rport_lookup(lport, sid);  in fc_rport_recv_flogi_req()
882 	if (!rdata) {  in fc_rport_recv_flogi_req()
887 	mutex_lock(&rdata->rp_mutex);  in fc_rport_recv_flogi_req()
889 	FC_RPORT_DBG(rdata, "Received FLOGI in %s state\n",  in fc_rport_recv_flogi_req()
890 		     fc_rport_state(rdata));  in fc_rport_recv_flogi_req()
892 	switch (rdata->rp_state) {  in fc_rport_recv_flogi_req()
908 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_flogi_req()
924 		fc_rport_enter_delete(rdata, RPORT_EV_LOGO);  in fc_rport_recv_flogi_req()
925 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_flogi_req()
930 	if (fc_rport_login_complete(rdata, fp)) {  in fc_rport_recv_flogi_req()
931 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_flogi_req()
953 	if (rdata->rp_state != RPORT_ST_FLOGI) {  in fc_rport_recv_flogi_req()
954 		if (rdata->ids.port_name < lport->wwpn)  in fc_rport_recv_flogi_req()
955 			fc_rport_enter_plogi(rdata);  in fc_rport_recv_flogi_req()
957 			fc_rport_state_enter(rdata, RPORT_ST_PLOGI_WAIT);  in fc_rport_recv_flogi_req()
960 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_flogi_req()
961 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_recv_flogi_req()
966 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_recv_flogi_req()
985 	struct fc_rport_priv *rdata = rdata_arg;  in fc_rport_plogi_resp()  local
986 	struct fc_lport *lport = rdata->local_port;  in fc_rport_plogi_resp()
992 	FC_RPORT_DBG(rdata, "Received a PLOGI %s\n", fc_els_resp_type(fp));  in fc_rport_plogi_resp()
997 	mutex_lock(&rdata->rp_mutex);  in fc_rport_plogi_resp()
999 	if (rdata->rp_state != RPORT_ST_PLOGI) {  in fc_rport_plogi_resp()
1000 		FC_RPORT_DBG(rdata, "Received a PLOGI response, but in state "  in fc_rport_plogi_resp()
1001 			     "%s\n", fc_rport_state(rdata));  in fc_rport_plogi_resp()
1008 		fc_rport_error_retry(rdata, PTR_ERR(fp));  in fc_rport_plogi_resp()
1015 		rdata->ids.port_name = get_unaligned_be64(&plp->fl_wwpn);  in fc_rport_plogi_resp()
1016 		rdata->ids.node_name = get_unaligned_be64(&plp->fl_wwnn);  in fc_rport_plogi_resp()
1019 		rdata->sp_features = ntohs(plp->fl_csp.sp_features);  in fc_rport_plogi_resp()
1022 			fc_rport_login_complete(rdata, fp);  in fc_rport_plogi_resp()
1027 		rdata->max_seq = csp_seq;  in fc_rport_plogi_resp()
1028 		rdata->maxframe_size = fc_plogi_get_maxframe(plp, lport->mfs);  in fc_rport_plogi_resp()
1029 		fc_rport_enter_prli(rdata);  in fc_rport_plogi_resp()
1035 			FC_RPORT_DBG(rdata, "PLOGI bad response\n");  in fc_rport_plogi_resp()
1037 			FC_RPORT_DBG(rdata, "PLOGI ELS rejected, reason %x expl %x\n",  in fc_rport_plogi_resp()
1039 		fc_rport_error_retry(rdata, -FC_EX_ELS_RJT);  in fc_rport_plogi_resp()
1044 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_plogi_resp()
1046 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_plogi_resp()
1050 fc_rport_compatible_roles(struct fc_lport *lport, struct fc_rport_priv *rdata)  in fc_rport_compatible_roles()  argument
1052 	if (rdata->ids.roles == FC_PORT_ROLE_UNKNOWN)  in fc_rport_compatible_roles()
1054 	if ((rdata->ids.roles & FC_PORT_ROLE_FCP_TARGET) &&  in fc_rport_compatible_roles()
1057 	if ((rdata->ids.roles & FC_PORT_ROLE_FCP_INITIATOR) &&  in fc_rport_compatible_roles()
1069 static void fc_rport_enter_plogi(struct fc_rport_priv *rdata)  in fc_rport_enter_plogi()  argument
1071 	struct fc_lport *lport = rdata->local_port;  in fc_rport_enter_plogi()
1074 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_plogi()
1076 	if (!fc_rport_compatible_roles(lport, rdata)) {  in fc_rport_enter_plogi()
1077 		FC_RPORT_DBG(rdata, "PLOGI suppressed for incompatible role\n");  in fc_rport_enter_plogi()
1078 		fc_rport_state_enter(rdata, RPORT_ST_PLOGI_WAIT);  in fc_rport_enter_plogi()
1082 	FC_RPORT_DBG(rdata, "Port entered PLOGI state from %s state\n",  in fc_rport_enter_plogi()
1083 		     fc_rport_state(rdata));  in fc_rport_enter_plogi()
1085 	fc_rport_state_enter(rdata, RPORT_ST_PLOGI);  in fc_rport_enter_plogi()
1087 	rdata->maxframe_size = FC_MIN_MAX_PAYLOAD;  in fc_rport_enter_plogi()
1090 		FC_RPORT_DBG(rdata, "%s frame alloc failed\n", __func__);  in fc_rport_enter_plogi()
1091 		fc_rport_error_retry(rdata, -FC_EX_ALLOC_ERR);  in fc_rport_enter_plogi()
1094 	rdata->e_d_tov = lport->e_d_tov;  in fc_rport_enter_plogi()
1096 	kref_get(&rdata->kref);  in fc_rport_enter_plogi()
1097 	if (!lport->tt.elsct_send(lport, rdata->ids.port_id, fp, ELS_PLOGI,  in fc_rport_enter_plogi()
1098 				  fc_rport_plogi_resp, rdata,  in fc_rport_enter_plogi()
1100 		fc_rport_error_retry(rdata, -FC_EX_XMIT_ERR);  in fc_rport_enter_plogi()
1101 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_plogi()
1118 	struct fc_rport_priv *rdata = rdata_arg;  in fc_rport_prli_resp()  local
1131 	FC_RPORT_DBG(rdata, "Received a PRLI %s\n", fc_els_resp_type(fp));  in fc_rport_prli_resp()
1136 	mutex_lock(&rdata->rp_mutex);  in fc_rport_prli_resp()
1138 	if (rdata->rp_state != RPORT_ST_PRLI) {  in fc_rport_prli_resp()
1139 		FC_RPORT_DBG(rdata, "Received a PRLI response, but in state "  in fc_rport_prli_resp()
1140 			     "%s\n", fc_rport_state(rdata));  in fc_rport_prli_resp()
1147 		fc_rport_error_retry(rdata, PTR_ERR(fp));  in fc_rport_prli_resp()
1152 	rdata->ids.roles = FC_RPORT_ROLE_UNKNOWN;  in fc_rport_prli_resp()
1158 			fc_rport_error_retry(rdata, -FC_EX_SEQ_ERR);  in fc_rport_prli_resp()
1163 		FC_RPORT_DBG(rdata, "PRLI spp_flags = 0x%x spp_type 0x%x\n",  in fc_rport_prli_resp()
1166 		rdata->spp_type = pp->spp.spp_type;  in fc_rport_prli_resp()
1169 				fc_rport_error(rdata, -FC_EX_SEQ_ERR);  in fc_rport_prli_resp()
1171 				fc_rport_error_retry(rdata, -FC_EX_SEQ_ERR);  in fc_rport_prli_resp()
1175 			fc_rport_error_retry(rdata, -FC_EX_SEQ_ERR);  in fc_rport_prli_resp()
1181 			rdata->flags |= FC_RP_FLAGS_RETRY;  in fc_rport_prli_resp()
1183 			rdata->flags |= FC_RP_FLAGS_CONF_REQ;  in fc_rport_prli_resp()
1188 		if (rdata->spp_type < FC_FC4_PROV_SIZE) {  in fc_rport_prli_resp()
1189 			prov = fc_passive_prov[rdata->spp_type];  in fc_rport_prli_resp()
1192 				prov->prli(rdata, pp->prli.prli_spp_len,  in fc_rport_prli_resp()
1199 		if (rdata->spp_type != FC_TYPE_FCP ||  in fc_rport_prli_resp()
1206 		rdata->supported_classes = FC_COS_CLASS3;  in fc_rport_prli_resp()
1212 		rdata->ids.roles = roles;  in fc_rport_prli_resp()
1213 		fc_rport_enter_rtv(rdata);  in fc_rport_prli_resp()
1218 			FC_RPORT_DBG(rdata, "PRLI bad response\n");  in fc_rport_prli_resp()
1220 			FC_RPORT_DBG(rdata, "PRLI ELS rejected, reason %x expl %x\n",  in fc_rport_prli_resp()
1224 				fc_rport_enter_plogi(rdata);  in fc_rport_prli_resp()
1228 		fc_rport_error_retry(rdata, FC_EX_ELS_RJT);  in fc_rport_prli_resp()
1234 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_prli_resp()
1236 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_prli_resp()
1245 static void fc_rport_enter_prli(struct fc_rport_priv *rdata)  in fc_rport_enter_prli()  argument
1247 	struct fc_lport *lport = rdata->local_port;  in fc_rport_enter_prli()
1255 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_prli()
1261 	if (rdata->ids.port_id >= FC_FID_DOM_MGR) {  in fc_rport_enter_prli()
1262 		fc_rport_enter_ready(rdata);  in fc_rport_enter_prli()
1271 		    fc_rport_enter_ready(rdata);  in fc_rport_enter_prli()
1275 	FC_RPORT_DBG(rdata, "Port entered PRLI state from %s state\n",  in fc_rport_enter_prli()
1276 		     fc_rport_state(rdata));  in fc_rport_enter_prli()
1278 	fc_rport_state_enter(rdata, RPORT_ST_PRLI);  in fc_rport_enter_prli()
1282 		fc_rport_error_retry(rdata, -FC_EX_ALLOC_ERR);  in fc_rport_enter_prli()
1291 		prov->prli(rdata, sizeof(pp->spp), NULL, &pp->spp);  in fc_rport_enter_prli()
1294 	fc_fill_fc_hdr(fp, FC_RCTL_ELS_REQ, rdata->ids.port_id,  in fc_rport_enter_prli()
1298 	kref_get(&rdata->kref);  in fc_rport_enter_prli()
1300 			      NULL, rdata, 2 * lport->r_a_tov)) {  in fc_rport_enter_prli()
1301 		fc_rport_error_retry(rdata, -FC_EX_XMIT_ERR);  in fc_rport_enter_prli()
1302 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_prli()
1321 	struct fc_rport_priv *rdata = rdata_arg;  in fc_rport_rtv_resp()  local
1324 	FC_RPORT_DBG(rdata, "Received a RTV %s\n", fc_els_resp_type(fp));  in fc_rport_rtv_resp()
1329 	mutex_lock(&rdata->rp_mutex);  in fc_rport_rtv_resp()
1331 	if (rdata->rp_state != RPORT_ST_RTV) {  in fc_rport_rtv_resp()
1332 		FC_RPORT_DBG(rdata, "Received a RTV response, but in state "  in fc_rport_rtv_resp()
1333 			     "%s\n", fc_rport_state(rdata));  in fc_rport_rtv_resp()
1340 		fc_rport_error(rdata, PTR_ERR(fp));  in fc_rport_rtv_resp()
1356 			if (tov > rdata->r_a_tov)  in fc_rport_rtv_resp()
1357 				rdata->r_a_tov = tov;  in fc_rport_rtv_resp()
1363 			if (tov > rdata->e_d_tov)  in fc_rport_rtv_resp()
1364 				rdata->e_d_tov = tov;  in fc_rport_rtv_resp()
1368 	fc_rport_enter_ready(rdata);  in fc_rport_rtv_resp()
1373 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_rtv_resp()
1375 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_rtv_resp()
1384 static void fc_rport_enter_rtv(struct fc_rport_priv *rdata)  in fc_rport_enter_rtv()  argument
1387 	struct fc_lport *lport = rdata->local_port;  in fc_rport_enter_rtv()
1389 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_rtv()
1391 	FC_RPORT_DBG(rdata, "Port entered RTV state from %s state\n",  in fc_rport_enter_rtv()
1392 		     fc_rport_state(rdata));  in fc_rport_enter_rtv()
1394 	fc_rport_state_enter(rdata, RPORT_ST_RTV);  in fc_rport_enter_rtv()
1398 		fc_rport_error_retry(rdata, -FC_EX_ALLOC_ERR);  in fc_rport_enter_rtv()
1402 	kref_get(&rdata->kref);  in fc_rport_enter_rtv()
1403 	if (!lport->tt.elsct_send(lport, rdata->ids.port_id, fp, ELS_RTV,  in fc_rport_enter_rtv()
1404 				  fc_rport_rtv_resp, rdata,  in fc_rport_enter_rtv()
1406 		fc_rport_error_retry(rdata, -FC_EX_XMIT_ERR);  in fc_rport_enter_rtv()
1407 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_rtv()
1416 static void fc_rport_recv_rtv_req(struct fc_rport_priv *rdata,  in fc_rport_recv_rtv_req()  argument
1419 	struct fc_lport *lport = rdata->local_port;  in fc_rport_recv_rtv_req()
1424 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_recv_rtv_req()
1427 	FC_RPORT_DBG(rdata, "Received RTV request\n");  in fc_rport_recv_rtv_req()
1456 	struct fc_rport_priv *rdata = rdata_arg;  in fc_rport_logo_resp()  local
1457 	struct fc_lport *lport = rdata->local_port;  in fc_rport_logo_resp()
1463 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_logo_resp()
1472 static void fc_rport_enter_logo(struct fc_rport_priv *rdata)  in fc_rport_enter_logo()  argument
1474 	struct fc_lport *lport = rdata->local_port;  in fc_rport_enter_logo()
1477 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_logo()
1479 	FC_RPORT_DBG(rdata, "Port sending LOGO from %s state\n",  in fc_rport_enter_logo()
1480 		     fc_rport_state(rdata));  in fc_rport_enter_logo()
1485 	kref_get(&rdata->kref);  in fc_rport_enter_logo()
1486 	if (!lport->tt.elsct_send(lport, rdata->ids.port_id, fp, ELS_LOGO,  in fc_rport_enter_logo()
1487 				  fc_rport_logo_resp, rdata, 0))  in fc_rport_enter_logo()
1488 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_logo()
1504 	struct fc_rport_priv *rdata = rdata_arg;  in fc_rport_adisc_resp()  local
1508 	FC_RPORT_DBG(rdata, "Received a ADISC response\n");  in fc_rport_adisc_resp()
1513 	mutex_lock(&rdata->rp_mutex);  in fc_rport_adisc_resp()
1515 	if (rdata->rp_state != RPORT_ST_ADISC) {  in fc_rport_adisc_resp()
1516 		FC_RPORT_DBG(rdata, "Received a ADISC resp but in state %s\n",  in fc_rport_adisc_resp()
1517 			     fc_rport_state(rdata));  in fc_rport_adisc_resp()
1524 		fc_rport_error(rdata, PTR_ERR(fp));  in fc_rport_adisc_resp()
1536 	    ntoh24(adisc->adisc_port_id) != rdata->ids.port_id ||  in fc_rport_adisc_resp()
1537 	    get_unaligned_be64(&adisc->adisc_wwpn) != rdata->ids.port_name ||  in fc_rport_adisc_resp()
1538 	    get_unaligned_be64(&adisc->adisc_wwnn) != rdata->ids.node_name) {  in fc_rport_adisc_resp()
1539 		FC_RPORT_DBG(rdata, "ADISC error or mismatch\n");  in fc_rport_adisc_resp()
1540 		fc_rport_enter_flogi(rdata);  in fc_rport_adisc_resp()
1542 		FC_RPORT_DBG(rdata, "ADISC OK\n");  in fc_rport_adisc_resp()
1543 		fc_rport_enter_ready(rdata);  in fc_rport_adisc_resp()
1548 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_adisc_resp()
1550 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_adisc_resp()
1559 static void fc_rport_enter_adisc(struct fc_rport_priv *rdata)  in fc_rport_enter_adisc()  argument
1561 	struct fc_lport *lport = rdata->local_port;  in fc_rport_enter_adisc()
1564 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_enter_adisc()
1566 	FC_RPORT_DBG(rdata, "sending ADISC from %s state\n",  in fc_rport_enter_adisc()
1567 		     fc_rport_state(rdata));  in fc_rport_enter_adisc()
1569 	fc_rport_state_enter(rdata, RPORT_ST_ADISC);  in fc_rport_enter_adisc()
1573 		fc_rport_error_retry(rdata, -FC_EX_ALLOC_ERR);  in fc_rport_enter_adisc()
1576 	kref_get(&rdata->kref);  in fc_rport_enter_adisc()
1577 	if (!lport->tt.elsct_send(lport, rdata->ids.port_id, fp, ELS_ADISC,  in fc_rport_enter_adisc()
1578 				  fc_rport_adisc_resp, rdata,  in fc_rport_enter_adisc()
1580 		fc_rport_error_retry(rdata, -FC_EX_XMIT_ERR);  in fc_rport_enter_adisc()
1581 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_enter_adisc()
1590 static void fc_rport_recv_adisc_req(struct fc_rport_priv *rdata,  in fc_rport_recv_adisc_req()  argument
1593 	struct fc_lport *lport = rdata->local_port;  in fc_rport_recv_adisc_req()
1598 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_recv_adisc_req()
1601 	FC_RPORT_DBG(rdata, "Received ADISC request\n");  in fc_rport_recv_adisc_req()
1628 static void fc_rport_recv_rls_req(struct fc_rport_priv *rdata,  in fc_rport_recv_rls_req()  argument
1632 	struct fc_lport *lport = rdata->local_port;  in fc_rport_recv_rls_req()
1640 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_recv_rls_req()
1642 	FC_RPORT_DBG(rdata, "Received RLS request while in state %s\n",  in fc_rport_recv_rls_req()
1643 		     fc_rport_state(rdata));  in fc_rport_recv_rls_req()
1699 	struct fc_rport_priv *rdata;  in fc_rport_recv_els_req()  local
1704 	rdata = fc_rport_lookup(lport, fc_frame_sid(fp));  in fc_rport_recv_els_req()
1705 	if (!rdata) {  in fc_rport_recv_els_req()
1712 	mutex_lock(&rdata->rp_mutex);  in fc_rport_recv_els_req()
1714 	switch (rdata->rp_state) {  in fc_rport_recv_els_req()
1722 			FC_RPORT_DBG(rdata, "Reject ELS PRLI "  in fc_rport_recv_els_req()
1724 				     fc_rport_state(rdata));  in fc_rport_recv_els_req()
1725 			mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_els_req()
1726 			kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_recv_els_req()
1731 		FC_RPORT_DBG(rdata,  in fc_rport_recv_els_req()
1733 			     fc_frame_payload_op(fp), fc_rport_state(rdata));  in fc_rport_recv_els_req()
1734 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_els_req()
1735 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_recv_els_req()
1741 		fc_rport_recv_prli_req(rdata, fp);  in fc_rport_recv_els_req()
1744 		fc_rport_recv_prlo_req(rdata, fp);  in fc_rport_recv_els_req()
1747 		fc_rport_recv_adisc_req(rdata, fp);  in fc_rport_recv_els_req()
1758 		fc_rport_recv_rls_req(rdata, fp);  in fc_rport_recv_els_req()
1761 		fc_rport_recv_rtv_req(rdata, fp);  in fc_rport_recv_els_req()
1768 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_els_req()
1769 	kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_recv_els_req()
1846 	struct fc_rport_priv *rdata;  in fc_rport_recv_plogi_req()  local
1868 	rdata = fc_rport_create(lport, sid);  in fc_rport_recv_plogi_req()
1869 	if (!rdata) {  in fc_rport_recv_plogi_req()
1876 	mutex_lock(&rdata->rp_mutex);  in fc_rport_recv_plogi_req()
1879 	rdata->ids.port_name = get_unaligned_be64(&pl->fl_wwpn);  in fc_rport_recv_plogi_req()
1880 	rdata->ids.node_name = get_unaligned_be64(&pl->fl_wwnn);  in fc_rport_recv_plogi_req()
1893 	switch (rdata->rp_state) {  in fc_rport_recv_plogi_req()
1895 		FC_RPORT_DBG(rdata, "Received PLOGI in INIT state\n");  in fc_rport_recv_plogi_req()
1898 		FC_RPORT_DBG(rdata, "Received PLOGI in PLOGI_WAIT state\n");  in fc_rport_recv_plogi_req()
1901 		FC_RPORT_DBG(rdata, "Received PLOGI in PLOGI state\n");  in fc_rport_recv_plogi_req()
1902 		if (rdata->ids.port_name < lport->wwpn) {  in fc_rport_recv_plogi_req()
1903 			mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_plogi_req()
1913 		FC_RPORT_DBG(rdata, "Received PLOGI in logged-in state %d "  in fc_rport_recv_plogi_req()
1914 			     "- ignored for now\n", rdata->rp_state);  in fc_rport_recv_plogi_req()
1919 		FC_RPORT_DBG(rdata, "Received PLOGI in state %s - send busy\n",  in fc_rport_recv_plogi_req()
1920 			     fc_rport_state(rdata));  in fc_rport_recv_plogi_req()
1921 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_plogi_req()
1926 	if (!fc_rport_compatible_roles(lport, rdata)) {  in fc_rport_recv_plogi_req()
1927 		FC_RPORT_DBG(rdata, "Received PLOGI for incompatible role\n");  in fc_rport_recv_plogi_req()
1928 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_plogi_req()
1937 	rdata->maxframe_size = fc_plogi_get_maxframe(pl, lport->mfs);  in fc_rport_recv_plogi_req()
1949 	fc_rport_enter_prli(rdata);  in fc_rport_recv_plogi_req()
1951 	mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_plogi_req()
1965 static void fc_rport_recv_prli_req(struct fc_rport_priv *rdata,  in fc_rport_recv_prli_req()  argument
1968 	struct fc_lport *lport = rdata->local_port;  in fc_rport_recv_prli_req()
1982 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_recv_prli_req()
1984 	FC_RPORT_DBG(rdata, "Received PRLI request while in state %s\n",  in fc_rport_recv_prli_req()
1985 		     fc_rport_state(rdata));  in fc_rport_recv_prli_req()
2024 		rdata->spp_type = rspp->spp_type;  in fc_rport_recv_prli_req()
2034 				active = prov->prli(rdata, plen, rspp, spp);  in fc_rport_recv_prli_req()
2037 				passive = prov->prli(rdata, plen, rspp, spp);  in fc_rport_recv_prli_req()
2042 			FC_RPORT_DBG(rdata, "PRLI rspp type %x "  in fc_rport_recv_prli_req()
2081 static void fc_rport_recv_prlo_req(struct fc_rport_priv *rdata,  in fc_rport_recv_prlo_req()  argument
2084 	struct fc_lport *lport = rdata->local_port;  in fc_rport_recv_prlo_req()
2096 	lockdep_assert_held(&rdata->rp_mutex);  in fc_rport_recv_prlo_req()
2098 	FC_RPORT_DBG(rdata, "Received PRLO request while in state %s\n",  in fc_rport_recv_prlo_req()
2099 		     fc_rport_state(rdata));  in fc_rport_recv_prlo_req()
2131 	fc_rport_enter_prli(rdata);  in fc_rport_recv_prlo_req()
2155 	struct fc_rport_priv *rdata;  in fc_rport_recv_logo_req()  local
2164 	rdata = fc_rport_lookup(lport, sid);  in fc_rport_recv_logo_req()
2165 	if (rdata) {  in fc_rport_recv_logo_req()
2166 		mutex_lock(&rdata->rp_mutex);  in fc_rport_recv_logo_req()
2167 		FC_RPORT_DBG(rdata, "Received LOGO request while in state %s\n",  in fc_rport_recv_logo_req()
2168 			     fc_rport_state(rdata));  in fc_rport_recv_logo_req()
2170 		fc_rport_enter_delete(rdata, RPORT_EV_STOP);  in fc_rport_recv_logo_req()
2171 		mutex_unlock(&rdata->rp_mutex);  in fc_rport_recv_logo_req()
2172 		kref_put(&rdata->kref, fc_rport_destroy);  in fc_rport_recv_logo_req()
2198 static int fc_rport_fcp_prli(struct fc_rport_priv *rdata, u32 spp_len,  in fc_rport_fcp_prli()  argument
2202 	struct fc_lport *lport = rdata->local_port;  in fc_rport_fcp_prli()
2206 	rdata->ids.roles = FC_RPORT_ROLE_UNKNOWN;  in fc_rport_fcp_prli()
2208 		rdata->ids.roles |= FC_RPORT_ROLE_FCP_INITIATOR;  in fc_rport_fcp_prli()
2210 		rdata->ids.roles |= FC_RPORT_ROLE_FCP_TARGET;  in fc_rport_fcp_prli()
2212 		rdata->flags |= FC_RP_FLAGS_RETRY;  in fc_rport_fcp_prli()
2213 	rdata->supported_classes = FC_COS_CLASS3;  in fc_rport_fcp_prli()
2242 static int fc_rport_t0_prli(struct fc_rport_priv *rdata, u32 spp_len,  in fc_rport_t0_prli()  argument