This source file includes following definitions.
- fc_frame_drop
- fc_lport_rport_callback
- fc_lport_state
- fc_lport_ptp_setup
- fc_get_host_port_state
- fc_get_host_speed
- fc_get_host_stats
- fc_lport_flogi_fill
- fc_lport_add_fc4_type
- fc_lport_recv_rlir_req
- fc_lport_recv_echo_req
- fc_lport_recv_rnid_req
- fc_lport_recv_logo_req
- fc_fabric_login
- __fc_linkup
- fc_linkup
- __fc_linkdown
- fc_linkdown
- fc_fabric_logoff
- fc_lport_destroy
- fc_set_mfs
- fc_lport_disc_callback
- fc_lport_enter_ready
- fc_lport_set_port_id
- fc_lport_set_local_id
- fc_lport_recv_flogi_req
- fc_lport_recv_els_req
- fc_lport_els_prli
- fc_lport_recv
- fc_lport_reset
- fc_lport_reset_locked
- fc_lport_enter_reset
- fc_lport_enter_disabled
- fc_lport_error
- fc_lport_ns_resp
- fc_lport_ms_resp
- fc_lport_scr_resp
- fc_lport_enter_scr
- fc_lport_enter_ns
- fc_lport_enter_dns
- fc_lport_enter_ms
- fc_lport_enter_fdmi
- fc_lport_timeout
- fc_lport_logo_resp
- fc_lport_enter_logo
- fc_lport_flogi_resp
- fc_lport_enter_flogi
- fc_lport_config
- fc_lport_init
- fc_lport_bsg_resp
- fc_lport_els_request
- fc_lport_ct_request
- fc_lport_bsg_request
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78 #include <linux/timer.h>
79 #include <linux/delay.h>
80 #include <linux/module.h>
81 #include <linux/slab.h>
82 #include <asm/unaligned.h>
83
84 #include <scsi/fc/fc_gs.h>
85
86 #include <scsi/libfc.h>
87 #include <scsi/fc_encode.h>
88 #include <linux/scatterlist.h>
89
90 #include "fc_libfc.h"
91
92
93 #define FC_LOCAL_PTP_FID_LO 0x010101
94 #define FC_LOCAL_PTP_FID_HI 0x010102
95
96 #define DNS_DELAY 3
97
98 static void fc_lport_error(struct fc_lport *, struct fc_frame *);
99
100 static void fc_lport_enter_reset(struct fc_lport *);
101 static void fc_lport_enter_flogi(struct fc_lport *);
102 static void fc_lport_enter_dns(struct fc_lport *);
103 static void fc_lport_enter_ns(struct fc_lport *, enum fc_lport_state);
104 static void fc_lport_enter_scr(struct fc_lport *);
105 static void fc_lport_enter_ready(struct fc_lport *);
106 static void fc_lport_enter_logo(struct fc_lport *);
107 static void fc_lport_enter_fdmi(struct fc_lport *lport);
108 static void fc_lport_enter_ms(struct fc_lport *, enum fc_lport_state);
109
110 static const char *fc_lport_state_names[] = {
111 [LPORT_ST_DISABLED] = "disabled",
112 [LPORT_ST_FLOGI] = "FLOGI",
113 [LPORT_ST_DNS] = "dNS",
114 [LPORT_ST_RNN_ID] = "RNN_ID",
115 [LPORT_ST_RSNN_NN] = "RSNN_NN",
116 [LPORT_ST_RSPN_ID] = "RSPN_ID",
117 [LPORT_ST_RFT_ID] = "RFT_ID",
118 [LPORT_ST_RFF_ID] = "RFF_ID",
119 [LPORT_ST_FDMI] = "FDMI",
120 [LPORT_ST_RHBA] = "RHBA",
121 [LPORT_ST_RPA] = "RPA",
122 [LPORT_ST_DHBA] = "DHBA",
123 [LPORT_ST_DPRT] = "DPRT",
124 [LPORT_ST_SCR] = "SCR",
125 [LPORT_ST_READY] = "Ready",
126 [LPORT_ST_LOGO] = "LOGO",
127 [LPORT_ST_RESET] = "reset",
128 };
129
130
131
132
133
134
135
136
137
138
139 struct fc_bsg_info {
140 struct bsg_job *job;
141 struct fc_lport *lport;
142 u16 rsp_code;
143 struct scatterlist *sg;
144 u32 nents;
145 size_t offset;
146 };
147
148
149
150
151
152
153 static int fc_frame_drop(struct fc_lport *lport, struct fc_frame *fp)
154 {
155 fc_frame_free(fp);
156 return 0;
157 }
158
159
160
161
162
163
164
165
166
167
168 static void fc_lport_rport_callback(struct fc_lport *lport,
169 struct fc_rport_priv *rdata,
170 enum fc_rport_event event)
171 {
172 FC_LPORT_DBG(lport, "Received a %d event for port (%6.6x)\n", event,
173 rdata->ids.port_id);
174
175 mutex_lock(&lport->lp_mutex);
176 switch (event) {
177 case RPORT_EV_READY:
178 if (lport->state == LPORT_ST_DNS) {
179 lport->dns_rdata = rdata;
180 fc_lport_enter_ns(lport, LPORT_ST_RNN_ID);
181 } else if (lport->state == LPORT_ST_FDMI) {
182 lport->ms_rdata = rdata;
183 fc_lport_enter_ms(lport, LPORT_ST_DHBA);
184 } else {
185 FC_LPORT_DBG(lport, "Received an READY event "
186 "on port (%6.6x) for the directory "
187 "server, but the lport is not "
188 "in the DNS or FDMI state, it's in the "
189 "%d state", rdata->ids.port_id,
190 lport->state);
191 fc_rport_logoff(rdata);
192 }
193 break;
194 case RPORT_EV_LOGO:
195 case RPORT_EV_FAILED:
196 case RPORT_EV_STOP:
197 if (rdata->ids.port_id == FC_FID_DIR_SERV)
198 lport->dns_rdata = NULL;
199 else if (rdata->ids.port_id == FC_FID_MGMT_SERV)
200 lport->ms_rdata = NULL;
201 break;
202 case RPORT_EV_NONE:
203 break;
204 }
205 mutex_unlock(&lport->lp_mutex);
206 }
207
208
209
210
211
212 static const char *fc_lport_state(struct fc_lport *lport)
213 {
214 const char *cp;
215
216 cp = fc_lport_state_names[lport->state];
217 if (!cp)
218 cp = "unknown";
219 return cp;
220 }
221
222
223
224
225
226
227
228
229 static void fc_lport_ptp_setup(struct fc_lport *lport,
230 u32 remote_fid, u64 remote_wwpn,
231 u64 remote_wwnn)
232 {
233 lockdep_assert_held(&lport->lp_mutex);
234
235 if (lport->ptp_rdata) {
236 fc_rport_logoff(lport->ptp_rdata);
237 kref_put(&lport->ptp_rdata->kref, fc_rport_destroy);
238 }
239 mutex_lock(&lport->disc.disc_mutex);
240 lport->ptp_rdata = fc_rport_create(lport, remote_fid);
241 kref_get(&lport->ptp_rdata->kref);
242 lport->ptp_rdata->ids.port_name = remote_wwpn;
243 lport->ptp_rdata->ids.node_name = remote_wwnn;
244 mutex_unlock(&lport->disc.disc_mutex);
245
246 fc_rport_login(lport->ptp_rdata);
247
248 fc_lport_enter_ready(lport);
249 }
250
251
252
253
254
255 void fc_get_host_port_state(struct Scsi_Host *shost)
256 {
257 struct fc_lport *lport = shost_priv(shost);
258
259 mutex_lock(&lport->lp_mutex);
260 if (!lport->link_up)
261 fc_host_port_state(shost) = FC_PORTSTATE_LINKDOWN;
262 else
263 switch (lport->state) {
264 case LPORT_ST_READY:
265 fc_host_port_state(shost) = FC_PORTSTATE_ONLINE;
266 break;
267 default:
268 fc_host_port_state(shost) = FC_PORTSTATE_OFFLINE;
269 }
270 mutex_unlock(&lport->lp_mutex);
271 }
272 EXPORT_SYMBOL(fc_get_host_port_state);
273
274
275
276
277
278 void fc_get_host_speed(struct Scsi_Host *shost)
279 {
280 struct fc_lport *lport = shost_priv(shost);
281
282 fc_host_speed(shost) = lport->link_speed;
283 }
284 EXPORT_SYMBOL(fc_get_host_speed);
285
286
287
288
289
290 struct fc_host_statistics *fc_get_host_stats(struct Scsi_Host *shost)
291 {
292 struct fc_host_statistics *fc_stats;
293 struct fc_lport *lport = shost_priv(shost);
294 unsigned int cpu;
295 u64 fcp_in_bytes = 0;
296 u64 fcp_out_bytes = 0;
297
298 fc_stats = &lport->host_stats;
299 memset(fc_stats, 0, sizeof(struct fc_host_statistics));
300
301 fc_stats->seconds_since_last_reset = (jiffies - lport->boot_time) / HZ;
302
303 for_each_possible_cpu(cpu) {
304 struct fc_stats *stats;
305
306 stats = per_cpu_ptr(lport->stats, cpu);
307
308 fc_stats->tx_frames += stats->TxFrames;
309 fc_stats->tx_words += stats->TxWords;
310 fc_stats->rx_frames += stats->RxFrames;
311 fc_stats->rx_words += stats->RxWords;
312 fc_stats->error_frames += stats->ErrorFrames;
313 fc_stats->invalid_crc_count += stats->InvalidCRCCount;
314 fc_stats->fcp_input_requests += stats->InputRequests;
315 fc_stats->fcp_output_requests += stats->OutputRequests;
316 fc_stats->fcp_control_requests += stats->ControlRequests;
317 fcp_in_bytes += stats->InputBytes;
318 fcp_out_bytes += stats->OutputBytes;
319 fc_stats->fcp_packet_alloc_failures += stats->FcpPktAllocFails;
320 fc_stats->fcp_packet_aborts += stats->FcpPktAborts;
321 fc_stats->fcp_frame_alloc_failures += stats->FcpFrameAllocFails;
322 fc_stats->link_failure_count += stats->LinkFailureCount;
323 }
324 fc_stats->fcp_input_megabytes = div_u64(fcp_in_bytes, 1000000);
325 fc_stats->fcp_output_megabytes = div_u64(fcp_out_bytes, 1000000);
326 fc_stats->lip_count = -1;
327 fc_stats->nos_count = -1;
328 fc_stats->loss_of_sync_count = -1;
329 fc_stats->loss_of_signal_count = -1;
330 fc_stats->prim_seq_protocol_err_count = -1;
331 fc_stats->dumped_frames = -1;
332
333
334 fc_exch_update_stats(lport);
335
336 return fc_stats;
337 }
338 EXPORT_SYMBOL(fc_get_host_stats);
339
340
341
342
343
344
345
346 static void fc_lport_flogi_fill(struct fc_lport *lport,
347 struct fc_els_flogi *flogi,
348 unsigned int op)
349 {
350 struct fc_els_csp *sp;
351 struct fc_els_cssp *cp;
352
353 memset(flogi, 0, sizeof(*flogi));
354 flogi->fl_cmd = (u8) op;
355 put_unaligned_be64(lport->wwpn, &flogi->fl_wwpn);
356 put_unaligned_be64(lport->wwnn, &flogi->fl_wwnn);
357 sp = &flogi->fl_csp;
358 sp->sp_hi_ver = 0x20;
359 sp->sp_lo_ver = 0x20;
360 sp->sp_bb_cred = htons(10);
361 sp->sp_bb_data = htons((u16) lport->mfs);
362 cp = &flogi->fl_cssp[3 - 1];
363 cp->cp_class = htons(FC_CPC_VALID | FC_CPC_SEQ);
364 if (op != ELS_FLOGI) {
365 sp->sp_features = htons(FC_SP_FT_CIRO);
366 sp->sp_tot_seq = htons(255);
367 sp->sp_rel_off = htons(0x1f);
368 sp->sp_e_d_tov = htonl(lport->e_d_tov);
369
370 cp->cp_rdfs = htons((u16) lport->mfs);
371 cp->cp_con_seq = htons(255);
372 cp->cp_open_seq = 1;
373 }
374 }
375
376
377
378
379
380
381 static void fc_lport_add_fc4_type(struct fc_lport *lport, enum fc_fh_type type)
382 {
383 __be32 *mp;
384
385 mp = &lport->fcts.ff_type_map[type / FC_NS_BPW];
386 *mp = htonl(ntohl(*mp) | 1UL << (type % FC_NS_BPW));
387 }
388
389
390
391
392
393
394 static void fc_lport_recv_rlir_req(struct fc_lport *lport, struct fc_frame *fp)
395 {
396 lockdep_assert_held(&lport->lp_mutex);
397
398 FC_LPORT_DBG(lport, "Received RLIR request while in state %s\n",
399 fc_lport_state(lport));
400
401 fc_seq_els_rsp_send(fp, ELS_LS_ACC, NULL);
402 fc_frame_free(fp);
403 }
404
405
406
407
408
409
410 static void fc_lport_recv_echo_req(struct fc_lport *lport,
411 struct fc_frame *in_fp)
412 {
413 struct fc_frame *fp;
414 unsigned int len;
415 void *pp;
416 void *dp;
417
418 lockdep_assert_held(&lport->lp_mutex);
419
420 FC_LPORT_DBG(lport, "Received ECHO request while in state %s\n",
421 fc_lport_state(lport));
422
423 len = fr_len(in_fp) - sizeof(struct fc_frame_header);
424 pp = fc_frame_payload_get(in_fp, len);
425
426 if (len < sizeof(__be32))
427 len = sizeof(__be32);
428
429 fp = fc_frame_alloc(lport, len);
430 if (fp) {
431 dp = fc_frame_payload_get(fp, len);
432 memcpy(dp, pp, len);
433 *((__be32 *)dp) = htonl(ELS_LS_ACC << 24);
434 fc_fill_reply_hdr(fp, in_fp, FC_RCTL_ELS_REP, 0);
435 lport->tt.frame_send(lport, fp);
436 }
437 fc_frame_free(in_fp);
438 }
439
440
441
442
443
444
445 static void fc_lport_recv_rnid_req(struct fc_lport *lport,
446 struct fc_frame *in_fp)
447 {
448 struct fc_frame *fp;
449 struct fc_els_rnid *req;
450 struct {
451 struct fc_els_rnid_resp rnid;
452 struct fc_els_rnid_cid cid;
453 struct fc_els_rnid_gen gen;
454 } *rp;
455 struct fc_seq_els_data rjt_data;
456 u8 fmt;
457 size_t len;
458
459 lockdep_assert_held(&lport->lp_mutex);
460
461 FC_LPORT_DBG(lport, "Received RNID request while in state %s\n",
462 fc_lport_state(lport));
463
464 req = fc_frame_payload_get(in_fp, sizeof(*req));
465 if (!req) {
466 rjt_data.reason = ELS_RJT_LOGIC;
467 rjt_data.explan = ELS_EXPL_NONE;
468 fc_seq_els_rsp_send(in_fp, ELS_LS_RJT, &rjt_data);
469 } else {
470 fmt = req->rnid_fmt;
471 len = sizeof(*rp);
472 if (fmt != ELS_RNIDF_GEN ||
473 ntohl(lport->rnid_gen.rnid_atype) == 0) {
474 fmt = ELS_RNIDF_NONE;
475 len -= sizeof(rp->gen);
476 }
477 fp = fc_frame_alloc(lport, len);
478 if (fp) {
479 rp = fc_frame_payload_get(fp, len);
480 memset(rp, 0, len);
481 rp->rnid.rnid_cmd = ELS_LS_ACC;
482 rp->rnid.rnid_fmt = fmt;
483 rp->rnid.rnid_cid_len = sizeof(rp->cid);
484 rp->cid.rnid_wwpn = htonll(lport->wwpn);
485 rp->cid.rnid_wwnn = htonll(lport->wwnn);
486 if (fmt == ELS_RNIDF_GEN) {
487 rp->rnid.rnid_sid_len = sizeof(rp->gen);
488 memcpy(&rp->gen, &lport->rnid_gen,
489 sizeof(rp->gen));
490 }
491 fc_fill_reply_hdr(fp, in_fp, FC_RCTL_ELS_REP, 0);
492 lport->tt.frame_send(lport, fp);
493 }
494 }
495 fc_frame_free(in_fp);
496 }
497
498
499
500
501
502
503 static void fc_lport_recv_logo_req(struct fc_lport *lport, struct fc_frame *fp)
504 {
505 lockdep_assert_held(&lport->lp_mutex);
506
507 fc_seq_els_rsp_send(fp, ELS_LS_ACC, NULL);
508 fc_lport_enter_reset(lport);
509 fc_frame_free(fp);
510 }
511
512
513
514
515
516
517
518
519 int fc_fabric_login(struct fc_lport *lport)
520 {
521 int rc = -1;
522
523 mutex_lock(&lport->lp_mutex);
524 if (lport->state == LPORT_ST_DISABLED ||
525 lport->state == LPORT_ST_LOGO) {
526 fc_lport_state_enter(lport, LPORT_ST_RESET);
527 fc_lport_enter_reset(lport);
528 rc = 0;
529 }
530 mutex_unlock(&lport->lp_mutex);
531
532 return rc;
533 }
534 EXPORT_SYMBOL(fc_fabric_login);
535
536
537
538
539
540 void __fc_linkup(struct fc_lport *lport)
541 {
542 lockdep_assert_held(&lport->lp_mutex);
543
544 if (!lport->link_up) {
545 lport->link_up = 1;
546
547 if (lport->state == LPORT_ST_RESET)
548 fc_lport_enter_flogi(lport);
549 }
550 }
551
552
553
554
555
556 void fc_linkup(struct fc_lport *lport)
557 {
558 printk(KERN_INFO "host%d: libfc: Link up on port (%6.6x)\n",
559 lport->host->host_no, lport->port_id);
560
561 mutex_lock(&lport->lp_mutex);
562 __fc_linkup(lport);
563 mutex_unlock(&lport->lp_mutex);
564 }
565 EXPORT_SYMBOL(fc_linkup);
566
567
568
569
570
571 void __fc_linkdown(struct fc_lport *lport)
572 {
573 lockdep_assert_held(&lport->lp_mutex);
574
575 if (lport->link_up) {
576 lport->link_up = 0;
577 fc_lport_enter_reset(lport);
578 lport->tt.fcp_cleanup(lport);
579 }
580 }
581
582
583
584
585
586 void fc_linkdown(struct fc_lport *lport)
587 {
588 printk(KERN_INFO "host%d: libfc: Link down on port (%6.6x)\n",
589 lport->host->host_no, lport->port_id);
590
591 mutex_lock(&lport->lp_mutex);
592 __fc_linkdown(lport);
593 mutex_unlock(&lport->lp_mutex);
594 }
595 EXPORT_SYMBOL(fc_linkdown);
596
597
598
599
600
601
602
603
604 int fc_fabric_logoff(struct fc_lport *lport)
605 {
606 lport->tt.disc_stop_final(lport);
607 mutex_lock(&lport->lp_mutex);
608 if (lport->dns_rdata)
609 fc_rport_logoff(lport->dns_rdata);
610 mutex_unlock(&lport->lp_mutex);
611 fc_rport_flush_queue();
612 mutex_lock(&lport->lp_mutex);
613 fc_lport_enter_logo(lport);
614 mutex_unlock(&lport->lp_mutex);
615 cancel_delayed_work_sync(&lport->retry_work);
616 return 0;
617 }
618 EXPORT_SYMBOL(fc_fabric_logoff);
619
620
621
622
623
624
625
626
627
628
629
630 int fc_lport_destroy(struct fc_lport *lport)
631 {
632 mutex_lock(&lport->lp_mutex);
633 lport->state = LPORT_ST_DISABLED;
634 lport->link_up = 0;
635 lport->tt.frame_send = fc_frame_drop;
636 mutex_unlock(&lport->lp_mutex);
637
638 lport->tt.fcp_abort_io(lport);
639 lport->tt.disc_stop_final(lport);
640 lport->tt.exch_mgr_reset(lport, 0, 0);
641 cancel_delayed_work_sync(&lport->retry_work);
642 fc_fc4_del_lport(lport);
643 return 0;
644 }
645 EXPORT_SYMBOL(fc_lport_destroy);
646
647
648
649
650
651
652 int fc_set_mfs(struct fc_lport *lport, u32 mfs)
653 {
654 unsigned int old_mfs;
655 int rc = -EINVAL;
656
657 mutex_lock(&lport->lp_mutex);
658
659 old_mfs = lport->mfs;
660
661 if (mfs >= FC_MIN_MAX_FRAME) {
662 mfs &= ~3;
663 if (mfs > FC_MAX_FRAME)
664 mfs = FC_MAX_FRAME;
665 mfs -= sizeof(struct fc_frame_header);
666 lport->mfs = mfs;
667 rc = 0;
668 }
669
670 if (!rc && mfs < old_mfs)
671 fc_lport_enter_reset(lport);
672
673 mutex_unlock(&lport->lp_mutex);
674
675 return rc;
676 }
677 EXPORT_SYMBOL(fc_set_mfs);
678
679
680
681
682
683
684 static void fc_lport_disc_callback(struct fc_lport *lport,
685 enum fc_disc_event event)
686 {
687 switch (event) {
688 case DISC_EV_SUCCESS:
689 FC_LPORT_DBG(lport, "Discovery succeeded\n");
690 break;
691 case DISC_EV_FAILED:
692 printk(KERN_ERR "host%d: libfc: "
693 "Discovery failed for port (%6.6x)\n",
694 lport->host->host_no, lport->port_id);
695 mutex_lock(&lport->lp_mutex);
696 fc_lport_enter_reset(lport);
697 mutex_unlock(&lport->lp_mutex);
698 break;
699 case DISC_EV_NONE:
700 WARN_ON(1);
701 break;
702 }
703 }
704
705
706
707
708
709 static void fc_lport_enter_ready(struct fc_lport *lport)
710 {
711 lockdep_assert_held(&lport->lp_mutex);
712
713 FC_LPORT_DBG(lport, "Entered READY from state %s\n",
714 fc_lport_state(lport));
715
716 fc_lport_state_enter(lport, LPORT_ST_READY);
717 if (lport->vport)
718 fc_vport_set_state(lport->vport, FC_VPORT_ACTIVE);
719 fc_vports_linkchange(lport);
720
721 if (!lport->ptp_rdata)
722 lport->tt.disc_start(fc_lport_disc_callback, lport);
723 }
724
725
726
727
728
729
730
731 static void fc_lport_set_port_id(struct fc_lport *lport, u32 port_id,
732 struct fc_frame *fp)
733 {
734 lockdep_assert_held(&lport->lp_mutex);
735
736 if (port_id)
737 printk(KERN_INFO "host%d: Assigned Port ID %6.6x\n",
738 lport->host->host_no, port_id);
739
740 lport->port_id = port_id;
741
742
743 fc_host_port_id(lport->host) = port_id;
744
745 if (lport->tt.lport_set_port_id)
746 lport->tt.lport_set_port_id(lport, port_id, fp);
747 }
748
749
750
751
752
753
754
755
756
757
758 void fc_lport_set_local_id(struct fc_lport *lport, u32 port_id)
759 {
760 mutex_lock(&lport->lp_mutex);
761
762 fc_lport_set_port_id(lport, port_id, NULL);
763
764 switch (lport->state) {
765 case LPORT_ST_RESET:
766 case LPORT_ST_FLOGI:
767 if (port_id)
768 fc_lport_enter_ready(lport);
769 break;
770 default:
771 break;
772 }
773 mutex_unlock(&lport->lp_mutex);
774 }
775 EXPORT_SYMBOL(fc_lport_set_local_id);
776
777
778
779
780
781
782
783
784
785
786 static void fc_lport_recv_flogi_req(struct fc_lport *lport,
787 struct fc_frame *rx_fp)
788 {
789 struct fc_frame *fp;
790 struct fc_frame_header *fh;
791 struct fc_els_flogi *flp;
792 struct fc_els_flogi *new_flp;
793 u64 remote_wwpn;
794 u32 remote_fid;
795 u32 local_fid;
796
797 lockdep_assert_held(&lport->lp_mutex);
798
799 FC_LPORT_DBG(lport, "Received FLOGI request while in state %s\n",
800 fc_lport_state(lport));
801
802 remote_fid = fc_frame_sid(rx_fp);
803 flp = fc_frame_payload_get(rx_fp, sizeof(*flp));
804 if (!flp)
805 goto out;
806 remote_wwpn = get_unaligned_be64(&flp->fl_wwpn);
807 if (remote_wwpn == lport->wwpn) {
808 printk(KERN_WARNING "host%d: libfc: Received FLOGI from port "
809 "with same WWPN %16.16llx\n",
810 lport->host->host_no, remote_wwpn);
811 goto out;
812 }
813 FC_LPORT_DBG(lport, "FLOGI from port WWPN %16.16llx\n", remote_wwpn);
814
815
816
817
818
819
820 local_fid = FC_LOCAL_PTP_FID_LO;
821 if (remote_wwpn < lport->wwpn) {
822 local_fid = FC_LOCAL_PTP_FID_HI;
823 if (!remote_fid || remote_fid == local_fid)
824 remote_fid = FC_LOCAL_PTP_FID_LO;
825 } else if (!remote_fid) {
826 remote_fid = FC_LOCAL_PTP_FID_HI;
827 }
828
829 fc_lport_set_port_id(lport, local_fid, rx_fp);
830
831 fp = fc_frame_alloc(lport, sizeof(*flp));
832 if (fp) {
833 new_flp = fc_frame_payload_get(fp, sizeof(*flp));
834 fc_lport_flogi_fill(lport, new_flp, ELS_FLOGI);
835 new_flp->fl_cmd = (u8) ELS_LS_ACC;
836
837
838
839
840
841 fc_fill_reply_hdr(fp, rx_fp, FC_RCTL_ELS_REP, 0);
842 fh = fc_frame_header_get(fp);
843 hton24(fh->fh_s_id, local_fid);
844 hton24(fh->fh_d_id, remote_fid);
845 lport->tt.frame_send(lport, fp);
846
847 } else {
848 fc_lport_error(lport, fp);
849 }
850 fc_lport_ptp_setup(lport, remote_fid, remote_wwpn,
851 get_unaligned_be64(&flp->fl_wwnn));
852 out:
853 fc_frame_free(rx_fp);
854 }
855
856
857
858
859
860
861
862
863
864
865
866
867 static void fc_lport_recv_els_req(struct fc_lport *lport,
868 struct fc_frame *fp)
869 {
870 mutex_lock(&lport->lp_mutex);
871
872
873
874
875
876
877 if (!lport->link_up)
878 fc_frame_free(fp);
879 else {
880
881
882
883 switch (fc_frame_payload_op(fp)) {
884 case ELS_FLOGI:
885 if (!lport->point_to_multipoint)
886 fc_lport_recv_flogi_req(lport, fp);
887 else
888 fc_rport_recv_req(lport, fp);
889 break;
890 case ELS_LOGO:
891 if (fc_frame_sid(fp) == FC_FID_FLOGI)
892 fc_lport_recv_logo_req(lport, fp);
893 else
894 fc_rport_recv_req(lport, fp);
895 break;
896 case ELS_RSCN:
897 lport->tt.disc_recv_req(lport, fp);
898 break;
899 case ELS_ECHO:
900 fc_lport_recv_echo_req(lport, fp);
901 break;
902 case ELS_RLIR:
903 fc_lport_recv_rlir_req(lport, fp);
904 break;
905 case ELS_RNID:
906 fc_lport_recv_rnid_req(lport, fp);
907 break;
908 default:
909 fc_rport_recv_req(lport, fp);
910 break;
911 }
912 }
913 mutex_unlock(&lport->lp_mutex);
914 }
915
916 static int fc_lport_els_prli(struct fc_rport_priv *rdata, u32 spp_len,
917 const struct fc_els_spp *spp_in,
918 struct fc_els_spp *spp_out)
919 {
920 return FC_SPP_RESP_INVL;
921 }
922
923 struct fc4_prov fc_lport_els_prov = {
924 .prli = fc_lport_els_prli,
925 .recv = fc_lport_recv_els_req,
926 };
927
928
929
930
931
932
933
934
935
936 void fc_lport_recv(struct fc_lport *lport, struct fc_frame *fp)
937 {
938 struct fc_frame_header *fh = fc_frame_header_get(fp);
939 struct fc_seq *sp = fr_seq(fp);
940 struct fc4_prov *prov;
941
942
943
944
945
946
947
948
949
950 rcu_read_lock();
951 if (fh->fh_type >= FC_FC4_PROV_SIZE)
952 goto drop;
953 prov = rcu_dereference(fc_passive_prov[fh->fh_type]);
954 if (!prov || !try_module_get(prov->module))
955 goto drop;
956 rcu_read_unlock();
957 prov->recv(lport, fp);
958 module_put(prov->module);
959 return;
960 drop:
961 rcu_read_unlock();
962 FC_LPORT_DBG(lport, "dropping unexpected frame type %x\n", fh->fh_type);
963 fc_frame_free(fp);
964 if (sp)
965 fc_exch_done(sp);
966 }
967 EXPORT_SYMBOL(fc_lport_recv);
968
969
970
971
972
973
974
975
976 int fc_lport_reset(struct fc_lport *lport)
977 {
978 cancel_delayed_work_sync(&lport->retry_work);
979 mutex_lock(&lport->lp_mutex);
980 fc_lport_enter_reset(lport);
981 mutex_unlock(&lport->lp_mutex);
982 return 0;
983 }
984 EXPORT_SYMBOL(fc_lport_reset);
985
986
987
988
989
990 static void fc_lport_reset_locked(struct fc_lport *lport)
991 {
992 lockdep_assert_held(&lport->lp_mutex);
993
994 if (lport->dns_rdata) {
995 fc_rport_logoff(lport->dns_rdata);
996 lport->dns_rdata = NULL;
997 }
998
999 if (lport->ptp_rdata) {
1000 fc_rport_logoff(lport->ptp_rdata);
1001 kref_put(&lport->ptp_rdata->kref, fc_rport_destroy);
1002 lport->ptp_rdata = NULL;
1003 }
1004
1005 lport->tt.disc_stop(lport);
1006
1007 lport->tt.exch_mgr_reset(lport, 0, 0);
1008 fc_host_fabric_name(lport->host) = 0;
1009
1010 if (lport->port_id && (!lport->point_to_multipoint || !lport->link_up))
1011 fc_lport_set_port_id(lport, 0, NULL);
1012 }
1013
1014
1015
1016
1017
1018 static void fc_lport_enter_reset(struct fc_lport *lport)
1019 {
1020 lockdep_assert_held(&lport->lp_mutex);
1021
1022 FC_LPORT_DBG(lport, "Entered RESET state from %s state\n",
1023 fc_lport_state(lport));
1024
1025 if (lport->state == LPORT_ST_DISABLED || lport->state == LPORT_ST_LOGO)
1026 return;
1027
1028 if (lport->vport) {
1029 if (lport->link_up)
1030 fc_vport_set_state(lport->vport, FC_VPORT_INITIALIZING);
1031 else
1032 fc_vport_set_state(lport->vport, FC_VPORT_LINKDOWN);
1033 }
1034 fc_lport_state_enter(lport, LPORT_ST_RESET);
1035 fc_host_post_event(lport->host, fc_get_event_number(),
1036 FCH_EVT_LIPRESET, 0);
1037 fc_vports_linkchange(lport);
1038 fc_lport_reset_locked(lport);
1039 if (lport->link_up)
1040 fc_lport_enter_flogi(lport);
1041 }
1042
1043
1044
1045
1046
1047 static void fc_lport_enter_disabled(struct fc_lport *lport)
1048 {
1049 lockdep_assert_held(&lport->lp_mutex);
1050
1051 FC_LPORT_DBG(lport, "Entered disabled state from %s state\n",
1052 fc_lport_state(lport));
1053
1054 fc_lport_state_enter(lport, LPORT_ST_DISABLED);
1055 fc_vports_linkchange(lport);
1056 fc_lport_reset_locked(lport);
1057 }
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068 static void fc_lport_error(struct fc_lport *lport, struct fc_frame *fp)
1069 {
1070 unsigned long delay = 0;
1071 FC_LPORT_DBG(lport, "Error %ld in state %s, retries %d\n",
1072 IS_ERR(fp) ? -PTR_ERR(fp) : 0, fc_lport_state(lport),
1073 lport->retry_count);
1074
1075 if (PTR_ERR(fp) == -FC_EX_CLOSED)
1076 return;
1077
1078
1079
1080
1081
1082
1083 if (lport->retry_count < lport->max_retry_count) {
1084 lport->retry_count++;
1085 if (!fp)
1086 delay = msecs_to_jiffies(500);
1087 else
1088 delay = msecs_to_jiffies(lport->e_d_tov);
1089
1090 schedule_delayed_work(&lport->retry_work, delay);
1091 } else
1092 fc_lport_enter_reset(lport);
1093 }
1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
1106 static void fc_lport_ns_resp(struct fc_seq *sp, struct fc_frame *fp,
1107 void *lp_arg)
1108 {
1109 struct fc_lport *lport = lp_arg;
1110 struct fc_frame_header *fh;
1111 struct fc_ct_hdr *ct;
1112
1113 FC_LPORT_DBG(lport, "Received a ns %s\n", fc_els_resp_type(fp));
1114
1115 if (fp == ERR_PTR(-FC_EX_CLOSED))
1116 return;
1117
1118 mutex_lock(&lport->lp_mutex);
1119
1120 if (lport->state < LPORT_ST_RNN_ID || lport->state > LPORT_ST_RFF_ID) {
1121 FC_LPORT_DBG(lport, "Received a name server response, "
1122 "but in state %s\n", fc_lport_state(lport));
1123 if (IS_ERR(fp))
1124 goto err;
1125 goto out;
1126 }
1127
1128 if (IS_ERR(fp)) {
1129 fc_lport_error(lport, fp);
1130 goto err;
1131 }
1132
1133 fh = fc_frame_header_get(fp);
1134 ct = fc_frame_payload_get(fp, sizeof(*ct));
1135
1136 if (fh && ct && fh->fh_type == FC_TYPE_CT &&
1137 ct->ct_fs_type == FC_FST_DIR &&
1138 ct->ct_fs_subtype == FC_NS_SUBTYPE &&
1139 ntohs(ct->ct_cmd) == FC_FS_ACC)
1140 switch (lport->state) {
1141 case LPORT_ST_RNN_ID:
1142 fc_lport_enter_ns(lport, LPORT_ST_RSNN_NN);
1143 break;
1144 case LPORT_ST_RSNN_NN:
1145 fc_lport_enter_ns(lport, LPORT_ST_RSPN_ID);
1146 break;
1147 case LPORT_ST_RSPN_ID:
1148 fc_lport_enter_ns(lport, LPORT_ST_RFT_ID);
1149 break;
1150 case LPORT_ST_RFT_ID:
1151 fc_lport_enter_ns(lport, LPORT_ST_RFF_ID);
1152 break;
1153 case LPORT_ST_RFF_ID:
1154 if (lport->fdmi_enabled)
1155 fc_lport_enter_fdmi(lport);
1156 else
1157 fc_lport_enter_scr(lport);
1158 break;
1159 default:
1160
1161 break;
1162 }
1163 else
1164 fc_lport_error(lport, fp);
1165 out:
1166 fc_frame_free(fp);
1167 err:
1168 mutex_unlock(&lport->lp_mutex);
1169 }
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182 static void fc_lport_ms_resp(struct fc_seq *sp, struct fc_frame *fp,
1183 void *lp_arg)
1184 {
1185 struct fc_lport *lport = lp_arg;
1186 struct fc_frame_header *fh;
1187 struct fc_ct_hdr *ct;
1188
1189 FC_LPORT_DBG(lport, "Received a ms %s\n", fc_els_resp_type(fp));
1190
1191 if (fp == ERR_PTR(-FC_EX_CLOSED))
1192 return;
1193
1194 mutex_lock(&lport->lp_mutex);
1195
1196 if (lport->state < LPORT_ST_RHBA || lport->state > LPORT_ST_DPRT) {
1197 FC_LPORT_DBG(lport, "Received a management server response, "
1198 "but in state %s\n", fc_lport_state(lport));
1199 if (IS_ERR(fp))
1200 goto err;
1201 goto out;
1202 }
1203
1204 if (IS_ERR(fp)) {
1205 fc_lport_error(lport, fp);
1206 goto err;
1207 }
1208
1209 fh = fc_frame_header_get(fp);
1210 ct = fc_frame_payload_get(fp, sizeof(*ct));
1211
1212 if (fh && ct && fh->fh_type == FC_TYPE_CT &&
1213 ct->ct_fs_type == FC_FST_MGMT &&
1214 ct->ct_fs_subtype == FC_FDMI_SUBTYPE) {
1215 FC_LPORT_DBG(lport, "Received a management server response, "
1216 "reason=%d explain=%d\n",
1217 ct->ct_reason,
1218 ct->ct_explan);
1219
1220 switch (lport->state) {
1221 case LPORT_ST_RHBA:
1222 if (ntohs(ct->ct_cmd) == FC_FS_ACC)
1223 fc_lport_enter_ms(lport, LPORT_ST_RPA);
1224 else
1225 fc_lport_enter_scr(lport);
1226 break;
1227 case LPORT_ST_RPA:
1228 fc_lport_enter_scr(lport);
1229 break;
1230 case LPORT_ST_DPRT:
1231 fc_lport_enter_ms(lport, LPORT_ST_RHBA);
1232 break;
1233 case LPORT_ST_DHBA:
1234 fc_lport_enter_ms(lport, LPORT_ST_DPRT);
1235 break;
1236 default:
1237
1238 break;
1239 }
1240 } else {
1241
1242 fc_lport_error(lport, fp);
1243 }
1244 out:
1245 fc_frame_free(fp);
1246 err:
1247 mutex_unlock(&lport->lp_mutex);
1248 }
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260 static void fc_lport_scr_resp(struct fc_seq *sp, struct fc_frame *fp,
1261 void *lp_arg)
1262 {
1263 struct fc_lport *lport = lp_arg;
1264 u8 op;
1265
1266 FC_LPORT_DBG(lport, "Received a SCR %s\n", fc_els_resp_type(fp));
1267
1268 if (fp == ERR_PTR(-FC_EX_CLOSED))
1269 return;
1270
1271 mutex_lock(&lport->lp_mutex);
1272
1273 if (lport->state != LPORT_ST_SCR) {
1274 FC_LPORT_DBG(lport, "Received a SCR response, but in state "
1275 "%s\n", fc_lport_state(lport));
1276 if (IS_ERR(fp))
1277 goto err;
1278 goto out;
1279 }
1280
1281 if (IS_ERR(fp)) {
1282 fc_lport_error(lport, fp);
1283 goto err;
1284 }
1285
1286 op = fc_frame_payload_op(fp);
1287 if (op == ELS_LS_ACC)
1288 fc_lport_enter_ready(lport);
1289 else
1290 fc_lport_error(lport, fp);
1291
1292 out:
1293 fc_frame_free(fp);
1294 err:
1295 mutex_unlock(&lport->lp_mutex);
1296 }
1297
1298
1299
1300
1301
1302 static void fc_lport_enter_scr(struct fc_lport *lport)
1303 {
1304 struct fc_frame *fp;
1305
1306 lockdep_assert_held(&lport->lp_mutex);
1307
1308 FC_LPORT_DBG(lport, "Entered SCR state from %s state\n",
1309 fc_lport_state(lport));
1310
1311 fc_lport_state_enter(lport, LPORT_ST_SCR);
1312
1313 fp = fc_frame_alloc(lport, sizeof(struct fc_els_scr));
1314 if (!fp) {
1315 fc_lport_error(lport, fp);
1316 return;
1317 }
1318
1319 if (!lport->tt.elsct_send(lport, FC_FID_FCTRL, fp, ELS_SCR,
1320 fc_lport_scr_resp, lport,
1321 2 * lport->r_a_tov))
1322 fc_lport_error(lport, NULL);
1323 }
1324
1325
1326
1327
1328
1329 static void fc_lport_enter_ns(struct fc_lport *lport, enum fc_lport_state state)
1330 {
1331 struct fc_frame *fp;
1332 enum fc_ns_req cmd;
1333 int size = sizeof(struct fc_ct_hdr);
1334 size_t len;
1335
1336 lockdep_assert_held(&lport->lp_mutex);
1337
1338 FC_LPORT_DBG(lport, "Entered %s state from %s state\n",
1339 fc_lport_state_names[state],
1340 fc_lport_state(lport));
1341
1342 fc_lport_state_enter(lport, state);
1343
1344 switch (state) {
1345 case LPORT_ST_RNN_ID:
1346 cmd = FC_NS_RNN_ID;
1347 size += sizeof(struct fc_ns_rn_id);
1348 break;
1349 case LPORT_ST_RSNN_NN:
1350 len = strnlen(fc_host_symbolic_name(lport->host), 255);
1351
1352 if (!len)
1353 return fc_lport_enter_ns(lport, LPORT_ST_RFT_ID);
1354 cmd = FC_NS_RSNN_NN;
1355 size += sizeof(struct fc_ns_rsnn) + len;
1356 break;
1357 case LPORT_ST_RSPN_ID:
1358 len = strnlen(fc_host_symbolic_name(lport->host), 255);
1359
1360 if (!len)
1361 return fc_lport_enter_ns(lport, LPORT_ST_RFT_ID);
1362 cmd = FC_NS_RSPN_ID;
1363 size += sizeof(struct fc_ns_rspn) + len;
1364 break;
1365 case LPORT_ST_RFT_ID:
1366 cmd = FC_NS_RFT_ID;
1367 size += sizeof(struct fc_ns_rft);
1368 break;
1369 case LPORT_ST_RFF_ID:
1370 cmd = FC_NS_RFF_ID;
1371 size += sizeof(struct fc_ns_rff_id);
1372 break;
1373 default:
1374 fc_lport_error(lport, NULL);
1375 return;
1376 }
1377
1378 fp = fc_frame_alloc(lport, size);
1379 if (!fp) {
1380 fc_lport_error(lport, fp);
1381 return;
1382 }
1383
1384 if (!lport->tt.elsct_send(lport, FC_FID_DIR_SERV, fp, cmd,
1385 fc_lport_ns_resp,
1386 lport, 3 * lport->r_a_tov))
1387 fc_lport_error(lport, fp);
1388 }
1389
1390 static struct fc_rport_operations fc_lport_rport_ops = {
1391 .event_callback = fc_lport_rport_callback,
1392 };
1393
1394
1395
1396
1397
1398 static void fc_lport_enter_dns(struct fc_lport *lport)
1399 {
1400 struct fc_rport_priv *rdata;
1401
1402 lockdep_assert_held(&lport->lp_mutex);
1403
1404 FC_LPORT_DBG(lport, "Entered DNS state from %s state\n",
1405 fc_lport_state(lport));
1406
1407 fc_lport_state_enter(lport, LPORT_ST_DNS);
1408
1409 mutex_lock(&lport->disc.disc_mutex);
1410 rdata = fc_rport_create(lport, FC_FID_DIR_SERV);
1411 mutex_unlock(&lport->disc.disc_mutex);
1412 if (!rdata)
1413 goto err;
1414
1415 rdata->ops = &fc_lport_rport_ops;
1416 fc_rport_login(rdata);
1417 return;
1418
1419 err:
1420 fc_lport_error(lport, NULL);
1421 }
1422
1423
1424
1425
1426
1427 static void fc_lport_enter_ms(struct fc_lport *lport, enum fc_lport_state state)
1428 {
1429 struct fc_frame *fp;
1430 enum fc_fdmi_req cmd;
1431 int size = sizeof(struct fc_ct_hdr);
1432 size_t len;
1433 int numattrs;
1434
1435 lockdep_assert_held(&lport->lp_mutex);
1436
1437 FC_LPORT_DBG(lport, "Entered %s state from %s state\n",
1438 fc_lport_state_names[state],
1439 fc_lport_state(lport));
1440
1441 fc_lport_state_enter(lport, state);
1442
1443 switch (state) {
1444 case LPORT_ST_RHBA:
1445 cmd = FC_FDMI_RHBA;
1446
1447 numattrs = 10;
1448 len = sizeof(struct fc_fdmi_rhba);
1449 len -= sizeof(struct fc_fdmi_attr_entry);
1450 len += (numattrs * FC_FDMI_ATTR_ENTRY_HEADER_LEN);
1451 len += FC_FDMI_HBA_ATTR_NODENAME_LEN;
1452 len += FC_FDMI_HBA_ATTR_MANUFACTURER_LEN;
1453 len += FC_FDMI_HBA_ATTR_SERIALNUMBER_LEN;
1454 len += FC_FDMI_HBA_ATTR_MODEL_LEN;
1455 len += FC_FDMI_HBA_ATTR_MODELDESCR_LEN;
1456 len += FC_FDMI_HBA_ATTR_HARDWAREVERSION_LEN;
1457 len += FC_FDMI_HBA_ATTR_DRIVERVERSION_LEN;
1458 len += FC_FDMI_HBA_ATTR_OPTIONROMVERSION_LEN;
1459 len += FC_FDMI_HBA_ATTR_FIRMWAREVERSION_LEN;
1460 len += FC_FDMI_HBA_ATTR_OSNAMEVERSION_LEN;
1461
1462 size += len;
1463 break;
1464 case LPORT_ST_RPA:
1465 cmd = FC_FDMI_RPA;
1466
1467 numattrs = 6;
1468 len = sizeof(struct fc_fdmi_rpa);
1469 len -= sizeof(struct fc_fdmi_attr_entry);
1470 len += (numattrs * FC_FDMI_ATTR_ENTRY_HEADER_LEN);
1471 len += FC_FDMI_PORT_ATTR_FC4TYPES_LEN;
1472 len += FC_FDMI_PORT_ATTR_SUPPORTEDSPEED_LEN;
1473 len += FC_FDMI_PORT_ATTR_CURRENTPORTSPEED_LEN;
1474 len += FC_FDMI_PORT_ATTR_MAXFRAMESIZE_LEN;
1475 len += FC_FDMI_PORT_ATTR_OSDEVICENAME_LEN;
1476 len += FC_FDMI_PORT_ATTR_HOSTNAME_LEN;
1477
1478 size += len;
1479 break;
1480 case LPORT_ST_DPRT:
1481 cmd = FC_FDMI_DPRT;
1482 len = sizeof(struct fc_fdmi_dprt);
1483 size += len;
1484 break;
1485 case LPORT_ST_DHBA:
1486 cmd = FC_FDMI_DHBA;
1487 len = sizeof(struct fc_fdmi_dhba);
1488 size += len;
1489 break;
1490 default:
1491 fc_lport_error(lport, NULL);
1492 return;
1493 }
1494
1495 FC_LPORT_DBG(lport, "Cmd=0x%x Len %d size %d\n",
1496 cmd, (int)len, size);
1497 fp = fc_frame_alloc(lport, size);
1498 if (!fp) {
1499 fc_lport_error(lport, fp);
1500 return;
1501 }
1502
1503 if (!lport->tt.elsct_send(lport, FC_FID_MGMT_SERV, fp, cmd,
1504 fc_lport_ms_resp,
1505 lport, 3 * lport->r_a_tov))
1506 fc_lport_error(lport, fp);
1507 }
1508
1509
1510
1511
1512
1513 static void fc_lport_enter_fdmi(struct fc_lport *lport)
1514 {
1515 struct fc_rport_priv *rdata;
1516
1517 lockdep_assert_held(&lport->lp_mutex);
1518
1519 FC_LPORT_DBG(lport, "Entered FDMI state from %s state\n",
1520 fc_lport_state(lport));
1521
1522 fc_lport_state_enter(lport, LPORT_ST_FDMI);
1523
1524 mutex_lock(&lport->disc.disc_mutex);
1525 rdata = fc_rport_create(lport, FC_FID_MGMT_SERV);
1526 mutex_unlock(&lport->disc.disc_mutex);
1527 if (!rdata)
1528 goto err;
1529
1530 rdata->ops = &fc_lport_rport_ops;
1531 fc_rport_login(rdata);
1532 return;
1533
1534 err:
1535 fc_lport_error(lport, NULL);
1536 }
1537
1538
1539
1540
1541
1542 static void fc_lport_timeout(struct work_struct *work)
1543 {
1544 struct fc_lport *lport =
1545 container_of(work, struct fc_lport,
1546 retry_work.work);
1547
1548 mutex_lock(&lport->lp_mutex);
1549
1550 switch (lport->state) {
1551 case LPORT_ST_DISABLED:
1552 break;
1553 case LPORT_ST_READY:
1554 break;
1555 case LPORT_ST_RESET:
1556 break;
1557 case LPORT_ST_FLOGI:
1558 fc_lport_enter_flogi(lport);
1559 break;
1560 case LPORT_ST_DNS:
1561 fc_lport_enter_dns(lport);
1562 break;
1563 case LPORT_ST_RNN_ID:
1564 case LPORT_ST_RSNN_NN:
1565 case LPORT_ST_RSPN_ID:
1566 case LPORT_ST_RFT_ID:
1567 case LPORT_ST_RFF_ID:
1568 fc_lport_enter_ns(lport, lport->state);
1569 break;
1570 case LPORT_ST_FDMI:
1571 fc_lport_enter_fdmi(lport);
1572 break;
1573 case LPORT_ST_RHBA:
1574 case LPORT_ST_RPA:
1575 case LPORT_ST_DHBA:
1576 case LPORT_ST_DPRT:
1577 FC_LPORT_DBG(lport, "Skipping lport state %s to SCR\n",
1578 fc_lport_state(lport));
1579
1580 case LPORT_ST_SCR:
1581 fc_lport_enter_scr(lport);
1582 break;
1583 case LPORT_ST_LOGO:
1584 fc_lport_enter_logo(lport);
1585 break;
1586 }
1587
1588 mutex_unlock(&lport->lp_mutex);
1589 }
1590
1591
1592
1593
1594
1595
1596
1597
1598
1599
1600
1601 void fc_lport_logo_resp(struct fc_seq *sp, struct fc_frame *fp,
1602 void *lp_arg)
1603 {
1604 struct fc_lport *lport = lp_arg;
1605 u8 op;
1606
1607 FC_LPORT_DBG(lport, "Received a LOGO %s\n", fc_els_resp_type(fp));
1608
1609 if (fp == ERR_PTR(-FC_EX_CLOSED))
1610 return;
1611
1612 mutex_lock(&lport->lp_mutex);
1613
1614 if (lport->state != LPORT_ST_LOGO) {
1615 FC_LPORT_DBG(lport, "Received a LOGO response, but in state "
1616 "%s\n", fc_lport_state(lport));
1617 if (IS_ERR(fp))
1618 goto err;
1619 goto out;
1620 }
1621
1622 if (IS_ERR(fp)) {
1623 fc_lport_error(lport, fp);
1624 goto err;
1625 }
1626
1627 op = fc_frame_payload_op(fp);
1628 if (op == ELS_LS_ACC)
1629 fc_lport_enter_disabled(lport);
1630 else
1631 fc_lport_error(lport, fp);
1632
1633 out:
1634 fc_frame_free(fp);
1635 err:
1636 mutex_unlock(&lport->lp_mutex);
1637 }
1638 EXPORT_SYMBOL(fc_lport_logo_resp);
1639
1640
1641
1642
1643
1644 static void fc_lport_enter_logo(struct fc_lport *lport)
1645 {
1646 struct fc_frame *fp;
1647 struct fc_els_logo *logo;
1648
1649 lockdep_assert_held(&lport->lp_mutex);
1650
1651 FC_LPORT_DBG(lport, "Entered LOGO state from %s state\n",
1652 fc_lport_state(lport));
1653
1654 fc_lport_state_enter(lport, LPORT_ST_LOGO);
1655 fc_vports_linkchange(lport);
1656
1657 fp = fc_frame_alloc(lport, sizeof(*logo));
1658 if (!fp) {
1659 fc_lport_error(lport, fp);
1660 return;
1661 }
1662
1663 if (!lport->tt.elsct_send(lport, FC_FID_FLOGI, fp, ELS_LOGO,
1664 fc_lport_logo_resp, lport,
1665 2 * lport->r_a_tov))
1666 fc_lport_error(lport, NULL);
1667 }
1668
1669
1670
1671
1672
1673
1674
1675
1676
1677
1678
1679 void fc_lport_flogi_resp(struct fc_seq *sp, struct fc_frame *fp,
1680 void *lp_arg)
1681 {
1682 struct fc_lport *lport = lp_arg;
1683 struct fc_frame_header *fh;
1684 struct fc_els_flogi *flp;
1685 u32 did;
1686 u16 csp_flags;
1687 unsigned int r_a_tov;
1688 unsigned int e_d_tov;
1689 u16 mfs;
1690
1691 FC_LPORT_DBG(lport, "Received a FLOGI %s\n", fc_els_resp_type(fp));
1692
1693 if (fp == ERR_PTR(-FC_EX_CLOSED))
1694 return;
1695
1696 mutex_lock(&lport->lp_mutex);
1697
1698 if (lport->state != LPORT_ST_FLOGI) {
1699 FC_LPORT_DBG(lport, "Received a FLOGI response, but in state "
1700 "%s\n", fc_lport_state(lport));
1701 if (IS_ERR(fp))
1702 goto err;
1703 goto out;
1704 }
1705
1706 if (IS_ERR(fp)) {
1707 fc_lport_error(lport, fp);
1708 goto err;
1709 }
1710
1711 fh = fc_frame_header_get(fp);
1712 did = fc_frame_did(fp);
1713 if (fh->fh_r_ctl != FC_RCTL_ELS_REP || did == 0 ||
1714 fc_frame_payload_op(fp) != ELS_LS_ACC) {
1715 FC_LPORT_DBG(lport, "FLOGI not accepted or bad response\n");
1716 fc_lport_error(lport, fp);
1717 goto out;
1718 }
1719
1720 flp = fc_frame_payload_get(fp, sizeof(*flp));
1721 if (!flp) {
1722 FC_LPORT_DBG(lport, "FLOGI bad response\n");
1723 fc_lport_error(lport, fp);
1724 goto out;
1725 }
1726
1727 mfs = ntohs(flp->fl_csp.sp_bb_data) &
1728 FC_SP_BB_DATA_MASK;
1729
1730 if (mfs < FC_SP_MIN_MAX_PAYLOAD || mfs > FC_SP_MAX_MAX_PAYLOAD) {
1731 FC_LPORT_DBG(lport, "FLOGI bad mfs:%hu response, "
1732 "lport->mfs:%hu\n", mfs, lport->mfs);
1733 fc_lport_error(lport, fp);
1734 goto out;
1735 }
1736
1737 if (mfs <= lport->mfs) {
1738 lport->mfs = mfs;
1739 fc_host_maxframe_size(lport->host) = mfs;
1740 }
1741
1742 csp_flags = ntohs(flp->fl_csp.sp_features);
1743 r_a_tov = ntohl(flp->fl_csp.sp_r_a_tov);
1744 e_d_tov = ntohl(flp->fl_csp.sp_e_d_tov);
1745 if (csp_flags & FC_SP_FT_EDTR)
1746 e_d_tov /= 1000000;
1747
1748 lport->npiv_enabled = !!(csp_flags & FC_SP_FT_NPIV_ACC);
1749
1750 if ((csp_flags & FC_SP_FT_FPORT) == 0) {
1751 if (e_d_tov > lport->e_d_tov)
1752 lport->e_d_tov = e_d_tov;
1753 lport->r_a_tov = 2 * lport->e_d_tov;
1754 fc_lport_set_port_id(lport, did, fp);
1755 printk(KERN_INFO "host%d: libfc: "
1756 "Port (%6.6x) entered "
1757 "point-to-point mode\n",
1758 lport->host->host_no, did);
1759 fc_lport_ptp_setup(lport, fc_frame_sid(fp),
1760 get_unaligned_be64(
1761 &flp->fl_wwpn),
1762 get_unaligned_be64(
1763 &flp->fl_wwnn));
1764 } else {
1765 if (e_d_tov > lport->e_d_tov)
1766 lport->e_d_tov = e_d_tov;
1767 if (r_a_tov > lport->r_a_tov)
1768 lport->r_a_tov = r_a_tov;
1769 fc_host_fabric_name(lport->host) =
1770 get_unaligned_be64(&flp->fl_wwnn);
1771 fc_lport_set_port_id(lport, did, fp);
1772 fc_lport_enter_dns(lport);
1773 }
1774
1775 out:
1776 fc_frame_free(fp);
1777 err:
1778 mutex_unlock(&lport->lp_mutex);
1779 }
1780 EXPORT_SYMBOL(fc_lport_flogi_resp);
1781
1782
1783
1784
1785
1786 static void fc_lport_enter_flogi(struct fc_lport *lport)
1787 {
1788 struct fc_frame *fp;
1789
1790 lockdep_assert_held(&lport->lp_mutex);
1791
1792 FC_LPORT_DBG(lport, "Entered FLOGI state from %s state\n",
1793 fc_lport_state(lport));
1794
1795 fc_lport_state_enter(lport, LPORT_ST_FLOGI);
1796
1797 if (lport->point_to_multipoint) {
1798 if (lport->port_id)
1799 fc_lport_enter_ready(lport);
1800 return;
1801 }
1802
1803 fp = fc_frame_alloc(lport, sizeof(struct fc_els_flogi));
1804 if (!fp)
1805 return fc_lport_error(lport, fp);
1806
1807 if (!lport->tt.elsct_send(lport, FC_FID_FLOGI, fp,
1808 lport->vport ? ELS_FDISC : ELS_FLOGI,
1809 fc_lport_flogi_resp, lport,
1810 lport->vport ? 2 * lport->r_a_tov :
1811 lport->e_d_tov))
1812 fc_lport_error(lport, NULL);
1813 }
1814
1815
1816
1817
1818
1819 int fc_lport_config(struct fc_lport *lport)
1820 {
1821 INIT_DELAYED_WORK(&lport->retry_work, fc_lport_timeout);
1822 mutex_init(&lport->lp_mutex);
1823
1824 fc_lport_state_enter(lport, LPORT_ST_DISABLED);
1825
1826 fc_lport_add_fc4_type(lport, FC_TYPE_FCP);
1827 fc_lport_add_fc4_type(lport, FC_TYPE_CT);
1828 fc_fc4_conf_lport_params(lport, FC_TYPE_FCP);
1829
1830 return 0;
1831 }
1832 EXPORT_SYMBOL(fc_lport_config);
1833
1834
1835
1836
1837
1838 int fc_lport_init(struct fc_lport *lport)
1839 {
1840 fc_host_port_type(lport->host) = FC_PORTTYPE_NPORT;
1841 fc_host_node_name(lport->host) = lport->wwnn;
1842 fc_host_port_name(lport->host) = lport->wwpn;
1843 fc_host_supported_classes(lport->host) = FC_COS_CLASS3;
1844 memset(fc_host_supported_fc4s(lport->host), 0,
1845 sizeof(fc_host_supported_fc4s(lport->host)));
1846 fc_host_supported_fc4s(lport->host)[2] = 1;
1847 fc_host_supported_fc4s(lport->host)[7] = 1;
1848
1849
1850 memset(fc_host_active_fc4s(lport->host), 0,
1851 sizeof(fc_host_active_fc4s(lport->host)));
1852 fc_host_active_fc4s(lport->host)[2] = 1;
1853 fc_host_active_fc4s(lport->host)[7] = 1;
1854 fc_host_maxframe_size(lport->host) = lport->mfs;
1855 fc_host_supported_speeds(lport->host) = 0;
1856 if (lport->link_supported_speeds & FC_PORTSPEED_1GBIT)
1857 fc_host_supported_speeds(lport->host) |= FC_PORTSPEED_1GBIT;
1858 if (lport->link_supported_speeds & FC_PORTSPEED_10GBIT)
1859 fc_host_supported_speeds(lport->host) |= FC_PORTSPEED_10GBIT;
1860 fc_fc4_add_lport(lport);
1861
1862 return 0;
1863 }
1864 EXPORT_SYMBOL(fc_lport_init);
1865
1866
1867
1868
1869
1870
1871
1872 static void fc_lport_bsg_resp(struct fc_seq *sp, struct fc_frame *fp,
1873 void *info_arg)
1874 {
1875 struct fc_bsg_info *info = info_arg;
1876 struct bsg_job *job = info->job;
1877 struct fc_bsg_reply *bsg_reply = job->reply;
1878 struct fc_lport *lport = info->lport;
1879 struct fc_frame_header *fh;
1880 size_t len;
1881 void *buf;
1882
1883 if (IS_ERR(fp)) {
1884 bsg_reply->result = (PTR_ERR(fp) == -FC_EX_CLOSED) ?
1885 -ECONNABORTED : -ETIMEDOUT;
1886 job->reply_len = sizeof(uint32_t);
1887 bsg_job_done(job, bsg_reply->result,
1888 bsg_reply->reply_payload_rcv_len);
1889 kfree(info);
1890 return;
1891 }
1892
1893 mutex_lock(&lport->lp_mutex);
1894 fh = fc_frame_header_get(fp);
1895 len = fr_len(fp) - sizeof(*fh);
1896 buf = fc_frame_payload_get(fp, 0);
1897
1898 if (fr_sof(fp) == FC_SOF_I3 && !ntohs(fh->fh_seq_cnt)) {
1899
1900 unsigned short cmd = (info->rsp_code == FC_FS_ACC) ?
1901 ntohs(((struct fc_ct_hdr *)buf)->ct_cmd) :
1902 (unsigned short)fc_frame_payload_op(fp);
1903
1904
1905 bsg_reply->reply_data.ctels_reply.status =
1906 (cmd == info->rsp_code) ?
1907 FC_CTELS_STATUS_OK : FC_CTELS_STATUS_REJECT;
1908 }
1909
1910 bsg_reply->reply_payload_rcv_len +=
1911 fc_copy_buffer_to_sglist(buf, len, info->sg, &info->nents,
1912 &info->offset, NULL);
1913
1914 if (fr_eof(fp) == FC_EOF_T &&
1915 (ntoh24(fh->fh_f_ctl) & (FC_FC_LAST_SEQ | FC_FC_END_SEQ)) ==
1916 (FC_FC_LAST_SEQ | FC_FC_END_SEQ)) {
1917 if (bsg_reply->reply_payload_rcv_len >
1918 job->reply_payload.payload_len)
1919 bsg_reply->reply_payload_rcv_len =
1920 job->reply_payload.payload_len;
1921 bsg_reply->result = 0;
1922 bsg_job_done(job, bsg_reply->result,
1923 bsg_reply->reply_payload_rcv_len);
1924 kfree(info);
1925 }
1926 fc_frame_free(fp);
1927 mutex_unlock(&lport->lp_mutex);
1928 }
1929
1930
1931
1932
1933
1934
1935
1936 static int fc_lport_els_request(struct bsg_job *job,
1937 struct fc_lport *lport,
1938 u32 did, u32 tov)
1939 {
1940 struct fc_bsg_info *info;
1941 struct fc_frame *fp;
1942 struct fc_frame_header *fh;
1943 char *pp;
1944 int len;
1945
1946 lockdep_assert_held(&lport->lp_mutex);
1947
1948 fp = fc_frame_alloc(lport, job->request_payload.payload_len);
1949 if (!fp)
1950 return -ENOMEM;
1951
1952 len = job->request_payload.payload_len;
1953 pp = fc_frame_payload_get(fp, len);
1954
1955 sg_copy_to_buffer(job->request_payload.sg_list,
1956 job->request_payload.sg_cnt,
1957 pp, len);
1958
1959 fh = fc_frame_header_get(fp);
1960 fh->fh_r_ctl = FC_RCTL_ELS_REQ;
1961 hton24(fh->fh_d_id, did);
1962 hton24(fh->fh_s_id, lport->port_id);
1963 fh->fh_type = FC_TYPE_ELS;
1964 hton24(fh->fh_f_ctl, FC_FCTL_REQ);
1965 fh->fh_cs_ctl = 0;
1966 fh->fh_df_ctl = 0;
1967 fh->fh_parm_offset = 0;
1968
1969 info = kzalloc(sizeof(struct fc_bsg_info), GFP_KERNEL);
1970 if (!info) {
1971 fc_frame_free(fp);
1972 return -ENOMEM;
1973 }
1974
1975 info->job = job;
1976 info->lport = lport;
1977 info->rsp_code = ELS_LS_ACC;
1978 info->nents = job->reply_payload.sg_cnt;
1979 info->sg = job->reply_payload.sg_list;
1980
1981 if (!fc_exch_seq_send(lport, fp, fc_lport_bsg_resp,
1982 NULL, info, tov)) {
1983 kfree(info);
1984 return -ECOMM;
1985 }
1986 return 0;
1987 }
1988
1989
1990
1991
1992
1993
1994
1995
1996 static int fc_lport_ct_request(struct bsg_job *job,
1997 struct fc_lport *lport, u32 did, u32 tov)
1998 {
1999 struct fc_bsg_info *info;
2000 struct fc_frame *fp;
2001 struct fc_frame_header *fh;
2002 struct fc_ct_req *ct;
2003 size_t len;
2004
2005 lockdep_assert_held(&lport->lp_mutex);
2006
2007 fp = fc_frame_alloc(lport, sizeof(struct fc_ct_hdr) +
2008 job->request_payload.payload_len);
2009 if (!fp)
2010 return -ENOMEM;
2011
2012 len = job->request_payload.payload_len;
2013 ct = fc_frame_payload_get(fp, len);
2014
2015 sg_copy_to_buffer(job->request_payload.sg_list,
2016 job->request_payload.sg_cnt,
2017 ct, len);
2018
2019 fh = fc_frame_header_get(fp);
2020 fh->fh_r_ctl = FC_RCTL_DD_UNSOL_CTL;
2021 hton24(fh->fh_d_id, did);
2022 hton24(fh->fh_s_id, lport->port_id);
2023 fh->fh_type = FC_TYPE_CT;
2024 hton24(fh->fh_f_ctl, FC_FCTL_REQ);
2025 fh->fh_cs_ctl = 0;
2026 fh->fh_df_ctl = 0;
2027 fh->fh_parm_offset = 0;
2028
2029 info = kzalloc(sizeof(struct fc_bsg_info), GFP_KERNEL);
2030 if (!info) {
2031 fc_frame_free(fp);
2032 return -ENOMEM;
2033 }
2034
2035 info->job = job;
2036 info->lport = lport;
2037 info->rsp_code = FC_FS_ACC;
2038 info->nents = job->reply_payload.sg_cnt;
2039 info->sg = job->reply_payload.sg_list;
2040
2041 if (!fc_exch_seq_send(lport, fp, fc_lport_bsg_resp,
2042 NULL, info, tov)) {
2043 kfree(info);
2044 return -ECOMM;
2045 }
2046 return 0;
2047 }
2048
2049
2050
2051
2052
2053
2054 int fc_lport_bsg_request(struct bsg_job *job)
2055 {
2056 struct fc_bsg_request *bsg_request = job->request;
2057 struct fc_bsg_reply *bsg_reply = job->reply;
2058 struct Scsi_Host *shost = fc_bsg_to_shost(job);
2059 struct fc_lport *lport = shost_priv(shost);
2060 struct fc_rport *rport;
2061 struct fc_rport_priv *rdata;
2062 int rc = -EINVAL;
2063 u32 did, tov;
2064
2065 bsg_reply->reply_payload_rcv_len = 0;
2066
2067 mutex_lock(&lport->lp_mutex);
2068
2069 switch (bsg_request->msgcode) {
2070 case FC_BSG_RPT_ELS:
2071 rport = fc_bsg_to_rport(job);
2072 if (!rport)
2073 break;
2074
2075 rdata = rport->dd_data;
2076 rc = fc_lport_els_request(job, lport, rport->port_id,
2077 rdata->e_d_tov);
2078 break;
2079
2080 case FC_BSG_RPT_CT:
2081 rport = fc_bsg_to_rport(job);
2082 if (!rport)
2083 break;
2084
2085 rdata = rport->dd_data;
2086 rc = fc_lport_ct_request(job, lport, rport->port_id,
2087 rdata->e_d_tov);
2088 break;
2089
2090 case FC_BSG_HST_CT:
2091 did = ntoh24(bsg_request->rqst_data.h_ct.port_id);
2092 if (did == FC_FID_DIR_SERV) {
2093 rdata = lport->dns_rdata;
2094 if (!rdata)
2095 break;
2096 tov = rdata->e_d_tov;
2097 } else {
2098 rdata = fc_rport_lookup(lport, did);
2099 if (!rdata)
2100 break;
2101 tov = rdata->e_d_tov;
2102 kref_put(&rdata->kref, fc_rport_destroy);
2103 }
2104
2105 rc = fc_lport_ct_request(job, lport, did, tov);
2106 break;
2107
2108 case FC_BSG_HST_ELS_NOLOGIN:
2109 did = ntoh24(bsg_request->rqst_data.h_els.port_id);
2110 rc = fc_lport_els_request(job, lport, did, lport->e_d_tov);
2111 break;
2112 }
2113
2114 mutex_unlock(&lport->lp_mutex);
2115 return rc;
2116 }
2117 EXPORT_SYMBOL(fc_lport_bsg_request);