?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Merge remote-tracking branch 'origin/master'
[unleashed/lotheac.git] / usr / src / uts / common / io / fibre-channel / fca / fcoei / fcoei.c
blob95312794782d401cda7f3db56faee5276a0d20c7
1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21
22 /*
23 * Copyright (c) 2009, 2010, Oracle and/or its affiliates. All rights reserved.
24 */
25
26 #include <sys/conf.h>
27 #include <sys/ddi.h>
28 #include <sys/stat.h>
29 #include <sys/pci.h>
30 #include <sys/sunddi.h>
31 #include <sys/modctl.h>
32 #include <sys/file.h>
33 #include <sys/cred.h>
34 #include <sys/byteorder.h>
35 #include <sys/atomic.h>
36 #include <sys/scsi/scsi.h>
37 #include <sys/mac_client.h>
38 #include <sys/modhash.h>
39
40 /*
41 * leadville header files
42 */
43 #include <sys/fibre-channel/fc.h>
44 #include <sys/fibre-channel/impl/fc_fcaif.h>
45
46 /*
47 * fcoe header files
48 */
49 #include <sys/fcoe/fcoe_common.h>
50
51 /*
52 * fcoei header files
53 */
54 #include <fcoei.h>
55
56 /*
57 * forward declaration of stack functions
58 */
59 static uint32_t fcoei_xch_check(
60 mod_hash_key_t key, mod_hash_val_t *val, void *arg);
61 static int fcoei_attach(dev_info_t *dip, ddi_attach_cmd_t cmd);
62 static int fcoei_detach(dev_info_t *dip, ddi_detach_cmd_t cmd);
63 static int fcoei_open(dev_t *devp, int flag, int otype, cred_t *credp);
64 static int fcoei_close(dev_t dev, int flag, int otype, cred_t *credp);
65 static int fcoei_ioctl(
66 dev_t dev, int cmd, intptr_t data, int mode, cred_t *credp, int *rval);
67 static int fcoei_attach_init(fcoei_soft_state_t *ss);
68 static int fcoei_detach_uninit(fcoei_soft_state_t *ss);
69 static void fcoei_watchdog(void *arg);
70 static void fcoei_process_events(fcoei_soft_state_t *ss);
71 static void fcoei_trigger_fp_attach(void *arg);
72 static void fcoei_abts_exchange(fcoei_exchange_t *xch);
73 static void fcoei_clear_watchdog_jobs(fcoei_soft_state_t *ss);
74
75 /*
76 * Driver identificaton stuff
77 */
78 static struct cb_ops fcoei_cb_ops = {
79 fcoei_open,
80 fcoei_close,
81 nodev,
82 nodev,
83 nodev,
84 nodev,
85 nodev,
86 fcoei_ioctl,
87 nodev,
88 nodev,
89 nodev,
90 nochpoll,
91 ddi_prop_op,
92 0,
93 D_MP | D_NEW | D_HOTPLUG,
94 CB_REV,
95 nodev,
96 nodev
97 };
98
99 static struct dev_ops fcoei_ops = {
100 DEVO_REV,
101 0,
102 nodev,
103 nulldev,
104 nulldev,
105 fcoei_attach,
106 fcoei_detach,
107 nodev,
108 &fcoei_cb_ops,
109 NULL,
110 ddi_power,
111 ddi_quiesce_not_needed
112 };
113
114 static struct modldrv modldrv = {
115 &mod_driverops,
116 FCOEI_NAME_VERSION,
117 &fcoei_ops,
118 };
119
120 static struct modlinkage modlinkage = {
121 MODREV_1,
122 &modldrv,
123 NULL
124 };
125
126 /*
127 * Driver's global variables
128 */
129 void *fcoei_state = NULL;
130 int fcoei_use_ext_log = 0;
131
132 /*
133 * Common loadable module entry points _init, _fini, _info
134 */
135 int
136 _init(void)
137 {
138 int ret;
139
140 ret = ddi_soft_state_init(&fcoei_state, sizeof (fcoei_soft_state_t), 0);
141 if (ret != DDI_SUCCESS) {
142 FCOEI_LOG(__FUNCTION__, "soft state init failed: %x", ret);
143 return (ret);
144 }
145
146 ret = mod_install(&modlinkage);
147 if (ret != 0) {
148 ddi_soft_state_fini(&fcoei_state);
149 FCOEI_LOG(__FUNCTION__, "fcoei mod_install failed: %x", ret);
150 return (ret);
151 }
152
153 /*
154 * Let FCTL initialize devo_bus_ops
155 */
156 fc_fca_init(&fcoei_ops);
157
158 FCOEI_LOG(__FUNCTION__, "fcoei _init succeeded");
159 return (ret);
160 }
161
162 int
163 _fini(void)
164 {
165 int ret;
166
167 ret = mod_remove(&modlinkage);
168 if (ret != 0) {
169 FCOEI_EXT_LOG(__FUNCTION__, "fcoei mod_remove failed: %x", ret);
170 return (ret);
171 }
172
173 ddi_soft_state_fini(&fcoei_state);
174 FCOEI_LOG(__FUNCTION__, "fcoei _fini succeeded");
175 return (ret);
176 }
177
178 int
179 _info(struct modinfo *modinfop)
180 {
181 return (mod_info(&modlinkage, modinfop));
182 }
183
184 /*
185 * Autoconfiguration entry points: attach, detach, getinfo
186 */
187
188 static int
189 fcoei_attach(dev_info_t *dip, ddi_attach_cmd_t cmd)
190 {
191 int ret;
192 int fcoe_ret;
193 int instance;
194 fcoei_soft_state_t *ss;
195
196 instance = ddi_get_instance(dip);
197 FCOEI_LOG(__FUNCTION__, "instance is %d", instance);
198 switch (cmd) {
199 case DDI_ATTACH:
200 ret = ddi_soft_state_zalloc(fcoei_state, instance);
201 if (ret != DDI_SUCCESS) {
202 FCOEI_LOG(__FUNCTION__, "ss zalloc failed: %x", ret);
203 return (ret);
204 }
205
206 /*
207 * Get the soft state, and do basic initialization with dip
208 */
209 ss = ddi_get_soft_state(fcoei_state, instance);
210 ss->ss_dip = dip;
211
212 fcoe_ret = fcoei_attach_init(ss);
213 if (fcoe_ret != FCOE_SUCCESS) {
214 ddi_soft_state_free(fcoei_state, instance);
215 FCOEI_LOG(__FUNCTION__, "fcoei_attach_init failed: "
216 "%x", fcoe_ret);
217 return (DDI_FAILURE);
218 }
219
220 ss->ss_flags |= SS_FLAG_TRIGGER_FP_ATTACH;
221 (void) timeout(fcoei_trigger_fp_attach, ss, FCOE_SEC2TICK(1));
222 FCOEI_LOG(__FUNCTION__, "fcoei_attach succeeded: dip-%p, "
223 "cmd-%x", dip, cmd);
224 return (DDI_SUCCESS);
225
226 case DDI_RESUME:
227 return (DDI_SUCCESS);
228
229 default:
230 FCOEI_LOG(__FUNCTION__, "unsupported attach cmd-%X", cmd);
231 return (DDI_FAILURE);
232 }
233 }
234
235 static int
236 fcoei_detach(dev_info_t *dip, ddi_detach_cmd_t cmd)
237 {
238 int fcoe_ret;
239 int instance;
240 fcoei_soft_state_t *ss;
241
242 instance = ddi_get_instance(dip);
243 ss = ddi_get_soft_state(fcoei_state, instance);
244 if (ss == NULL) {
245 FCOEI_LOG(__FUNCTION__, "get ss failed: dip-%p", dip);
246 return (DDI_FAILURE);
247 }
248
249 switch (cmd) {
250 case DDI_DETACH:
251 if (ss->ss_flags & SS_FLAG_TRIGGER_FP_ATTACH) {
252 FCOEI_LOG(__FUNCTION__, "still await fp attach");
253 return (DDI_FAILURE);
254 }
255
256 if (ss->ss_flags & SS_FLAG_LV_BOUND) {
257 FCOEI_LOG(__FUNCTION__, "fp is not detached yet");
258 return (DDI_FAILURE);
259 }
260
261 fcoe_ret = fcoei_detach_uninit(ss);
262 if (fcoe_ret != FCOE_SUCCESS) {
263 FCOEI_LOG(__FUNCTION__, "fcoei_detach_uninit failed:"
264 " dip-%p, fcoe_ret-%d", dip, fcoe_ret);
265 return (DDI_FAILURE);
266 }
267
268 FCOEI_LOG(__FUNCTION__, "succeeded: dip-%p, cmd-%x", dip, cmd);
269 return (DDI_SUCCESS);
270
271 case DDI_SUSPEND:
272 return (DDI_SUCCESS);
273
274 default:
275 FCOEI_LOG(__FUNCTION__, "unspported detach cmd-%X", cmd);
276 return (DDI_FAILURE);
277 }
278 }
279
280 /*
281 * Device access entry points: open, close, ioctl
282 */
283
284 static int
285 fcoei_open(dev_t *devp, int flag, int otype, cred_t *credp)
286 {
287 fcoei_soft_state_t *ss;
288
289 if (otype != OTYP_CHR) {
290 FCOEI_LOG(__FUNCTION__, "flag: %x", flag);
291 return (EINVAL);
292 }
293
294 if (drv_priv(credp)) {
295 return (EPERM);
296 }
297
298 /*
299 * First of all, get related soft state
300 */
301 ss = ddi_get_soft_state(fcoei_state, (int)getminor(*devp));
302 if (ss == NULL) {
303 return (ENXIO);
304 }
305
306 mutex_enter(&ss->ss_ioctl_mutex);
307 if (ss->ss_ioctl_flags & FCOEI_IOCTL_FLAG_OPEN) {
308 /*
309 * We don't support concurrent open
310 */
311 mutex_exit(&ss->ss_ioctl_mutex);
312 return (EBUSY);
313 }
314
315 ss->ss_ioctl_flags |= FCOEI_IOCTL_FLAG_OPEN;
316 mutex_exit(&ss->ss_ioctl_mutex);
317
318 return (0);
319 }
320
321 static int
322 fcoei_close(dev_t dev, int flag, int otype, cred_t *credp)
323 {
324 fcoei_soft_state_t *ss;
325
326 if (otype != OTYP_CHR) {
327 FCOEI_LOG(__FUNCTION__, "flag: %x, %p", flag, credp);
328 return (EINVAL);
329 }
330
331 /*
332 * First of all, get related soft state
333 */
334 ss = ddi_get_soft_state(fcoei_state, (int)getminor(dev));
335 if (ss == NULL) {
336 return (ENXIO);
337 }
338
339 mutex_enter(&ss->ss_ioctl_mutex);
340 if (!(ss->ss_ioctl_flags & FCOEI_IOCTL_FLAG_OPEN)) {
341 /*
342 * If it's not open, we can exit
343 */
344
345 mutex_exit(&ss->ss_ioctl_mutex);
346 return (ENODEV);
347 }
348
349 ss->ss_ioctl_flags &= ~FCOEI_IOCTL_FLAG_OPEN;
350 mutex_exit(&ss->ss_ioctl_mutex);
351
352 return (0);
353 }
354
355 static int
356 fcoei_ioctl(dev_t dev, int cmd, intptr_t data, int mode,
357 cred_t *credp, int *rval)
358 {
359 fcoei_soft_state_t *ss;
360 int ret = 0;
361
362 if (drv_priv(credp) != 0) {
363 FCOEI_LOG(__FUNCTION__, "data: %p, %x", data, mode);
364 return (EPERM);
365 }
366
367 /*
368 * Get related soft state
369 */
370 ss = ddi_get_soft_state(fcoei_state, (int32_t)getminor(dev));
371 if (!ss) {
372 return (ENXIO);
373 }
374
375 /*
376 * Process ioctl
377 */
378 switch (cmd) {
379
380 default:
381 FCOEI_LOG(__FUNCTION__, "ioctl-0x%02X", cmd);
382 ret = ENOTTY;
383 }
384
385 /*
386 * Set return value
387 */
388 *rval = ret;
389 return (ret);
390 }
391
392 /*
393 * fcoei_attach_init
394 * init related stuff of the soft state
395 *
396 * Input:
397 * ss = the soft state that will be processed
398 *
399 * Return:
400 * if it succeeded or not
401 *
402 * Comment:
403 * N/A
404 */
405 static int
406 fcoei_attach_init(fcoei_soft_state_t *ss)
407 {
408 fcoe_port_t *eport;
409 fcoe_client_t client_fcoei;
410 char taskq_name[32];
411 int ret;
412 la_els_logi_t *els = &ss->ss_els_logi;
413 svc_param_t *class3_param;
414
415 /*
416 * Register fcoei to FCOE as its client
417 */
418 client_fcoei.ect_eport_flags = EPORT_FLAG_INI_MODE |
419 EPORT_FLAG_IS_DIRECT_P2P;
420 client_fcoei.ect_max_fc_frame_size = FCOE_MAX_FC_FRAME_SIZE;
421 client_fcoei.ect_private_frame_struct_size = sizeof (fcoei_frame_t);
422 fcoei_init_ect_vectors(&client_fcoei);
423 client_fcoei.ect_client_port_struct = ss;
424 client_fcoei.ect_fcoe_ver = FCOE_VER_NOW;
425 FCOEI_LOG(__FUNCTION__, "version: %x %x", FCOE_VER_NOW, fcoe_ver_now);
426 ret = ddi_prop_get_int(DDI_DEV_T_ANY, ss->ss_dip,
427 DDI_PROP_DONTPASS | DDI_PROP_NOTPROM, "mac_id", -1);
428 if (ret == -1) {
429 FCOEI_LOG(__FUNCTION__, "get mac_id failed");
430 return (DDI_FAILURE);
431 } else {
432 client_fcoei.ect_channelid = ret;
433 }
434
435 /*
436 * It's fcoe's responsiblity to initialize eport's all elements,
437 * so we needn't do eport initialization
438 */
439 eport = fcoe_register_client(&client_fcoei);
440 if (eport == NULL) {
441 goto fail_register_client;
442 } else {
443 ss->ss_eport = eport;
444 FCOE_SET_DEFAULT_FPORT_ADDR(eport->eport_efh_dst);
445 }
446
447 /*
448 * Now it's time to register fca_tran to FCTL
449 * Remember fc_local_port is transparent to FCA (fcoei)
450 */
451 ss->ss_fca_tran.fca_version = FCTL_FCA_MODREV_5;
452 ss->ss_fca_tran.fca_numports = 1;
453 ss->ss_fca_tran.fca_pkt_size = sizeof (fcoei_exchange_t);
454 ss->ss_fca_tran.fca_cmd_max = 2048;
455
456 /*
457 * scsi_tran_hba_setup could need these stuff
458 */
459 ss->ss_fca_tran.fca_dma_lim = NULL;
460 ss->ss_fca_tran.fca_iblock = NULL;
461 ss->ss_fca_tran.fca_dma_attr = NULL;
462 ss->ss_fca_tran.fca_acc_attr = NULL;
463
464 /*
465 * Initialize vectors
466 */
467 fcoei_init_fcatran_vectors(&ss->ss_fca_tran);
468
469 /*
470 * fc_fca_attach only sets driver's private, it has nothing to with
471 * common port object between fcoei and leadville.
472 * After this attach, fp_attach will be triggered, and it will call
473 * fca_bind_port to let fcoei to know about common port object.
474 */
475 if (fc_fca_attach(ss->ss_dip, &ss->ss_fca_tran) != DDI_SUCCESS) {
476 goto fail_fca_attach;
477 }
478
479 /*
480 * It's time to do ss initialization
481 */
482 ret = ddi_create_minor_node(ss->ss_dip, "admin",
483 S_IFCHR, ddi_get_instance(ss->ss_dip), DDI_NT_NEXUS, 0);
484 if (ret != DDI_SUCCESS) {
485 goto fail_minor_node;
486 }
487
488 ss->ss_flags = 0;
489 ss->ss_port = NULL;
490 /*
491 * ss->ss_eport has been initialized
492 */
493
494 ss->ss_sol_oxid_hash = mod_hash_create_idhash(
495 "fcoei_sol_oxid_hash", FCOEI_SOL_HASH_SIZE,
496 mod_hash_null_valdtor);
497 ss->ss_unsol_rxid_hash = mod_hash_create_idhash(
498 "fcoei_unsol_rxid_hash", FCOEI_UNSOL_HASH_SIZE,
499 mod_hash_null_valdtor);
500 list_create(&ss->ss_comp_xch_list, sizeof (fcoei_exchange_t),
501 offsetof(fcoei_exchange_t, xch_comp_node));
502 ss->ss_next_sol_oxid = 0xFFFF;
503 ss->ss_next_unsol_rxid = 0xFFFF;
504
505 mutex_init(&ss->ss_watchdog_mutex, 0, MUTEX_DRIVER, 0);
506 cv_init(&ss->ss_watchdog_cv, NULL, CV_DRIVER, NULL);
507 (void) snprintf(taskq_name, 32, "leadville_fcoei_%d_taskq",
508 ddi_get_instance(ss->ss_dip));
509 taskq_name[31] = 0;
510 ss->ss_taskq = ddi_taskq_create(ss->ss_dip,
511 taskq_name, 64, TASKQ_DEFAULTPRI, DDI_SLEEP);
512
513 ss->ss_link_state = FC_STATE_OFFLINE;
514 ss->ss_link_speed = 0;
515 ss->ss_port_event_counter = 0;
516
517 list_create(&ss->ss_event_list, sizeof (fcoei_event_t),
518 offsetof(fcoei_event_t, ae_node));
519
520 ss->ss_sol_cnt1 = 0;
521 ss->ss_sol_cnt2 = 0;
522 ss->ss_sol_cnt = &ss->ss_sol_cnt1;
523 ss->ss_unsol_cnt1 = 0;
524 ss->ss_unsol_cnt2 = 0;
525 ss->ss_unsol_cnt = &ss->ss_unsol_cnt1;
526 ss->ss_ioctl_flags = 0;
527
528 mutex_init(&ss->ss_ioctl_mutex, 0, MUTEX_DRIVER, 0);
529
530 bcopy(eport->eport_portwwn, els->nport_ww_name.raw_wwn, 8);
531 bcopy(eport->eport_nodewwn, els->node_ww_name.raw_wwn, 8);
532 els->common_service.fcph_version = 0x2008;
533 els->common_service.btob_credit = 3;
534 els->common_service.cmn_features = 0x8800;
535 els->common_service.conc_sequences = 0xff;
536 els->common_service.relative_offset = 3;
537 els->common_service.e_d_tov = 0x07d0;
538 class3_param = (svc_param_t *)&els->class_3;
539 class3_param->class_opt = 0x8800;
540 class3_param->rcv_size = els->common_service.rx_bufsize = 2048;
541 class3_param->conc_sequences = 0xff;
542 class3_param->open_seq_per_xchng = 1;
543
544 /*
545 * Fill out RNID Management Information
546 */
547 bcopy(ss->ss_eport->eport_portwwn, ss->ss_rnid.global_id, 8);
548 ss->ss_rnid.unit_type = FCOEI_RNID_HBA;
549 ss->ss_rnid.ip_version = FCOEI_RNID_IPV4;
550
551 /*
552 * Start our watchdog
553 */
554 (void) ddi_taskq_dispatch(ss->ss_taskq,
555 fcoei_watchdog, ss, DDI_SLEEP);
556 while (!(ss->ss_flags & SS_FLAG_WATCHDOG_RUNNING)) {
557 delay(50);
558 }
559
560 /*
561 * Report the device to the system
562 */
563 ddi_report_dev(ss->ss_dip);
564 return (DDI_SUCCESS);
565
566
567 fail_minor_node:
568 FCOEI_LOG(__FUNCTION__, "fail_minor_node");
569 (void) fc_fca_detach(ss->ss_dip);
570
571 fail_fca_attach:
572 eport->eport_deregister_client(eport);
573 FCOEI_LOG(__FUNCTION__, "fail_fca_attach");
574
575 fail_register_client:
576 FCOEI_LOG(__FUNCTION__, "fail_register_client");
577 return (DDI_FAILURE);
578 }
579
580 /*
581 * fcoei_detach_uninit
582 * uninit related stuff of the soft state
583 *
584 * Input:
585 * ss = the soft state that will be processed
586 *
587 * Return:
588 * if it succeeded or not
589 *
590 * Comment:
591 * N/A
592 */
593 int
594 fcoei_detach_uninit(fcoei_soft_state_t *ss)
595 {
596 /*
597 * Stop watchdog first
598 */
599 if (ss->ss_flags & SS_FLAG_WATCHDOG_RUNNING) {
600 ss->ss_flags |= SS_FLAG_TERMINATE_WATCHDOG;
601 cv_broadcast(&ss->ss_watchdog_cv);
602 }
603
604 /*
605 * Destroy the taskq
606 */
607 ddi_taskq_wait(ss->ss_taskq);
608 ddi_taskq_destroy(ss->ss_taskq);
609
610 /*
611 * Release all allocated resources
612 */
613 mutex_destroy(&ss->ss_ioctl_mutex);
614 mutex_destroy(&ss->ss_watchdog_mutex);
615 cv_destroy(&ss->ss_watchdog_cv);
616 mod_hash_destroy_idhash(ss->ss_sol_oxid_hash);
617 mod_hash_destroy_idhash(ss->ss_unsol_rxid_hash);
618 list_destroy(&ss->ss_event_list);
619 ss->ss_eport->eport_deregister_client(ss->ss_eport);
620 ddi_remove_minor_node(ss->ss_dip, NULL);
621
622 /*
623 * Release itself
624 */
625 ddi_soft_state_free(fcoei_state, ddi_get_instance(ss->ss_dip));
626 return (FCOE_SUCCESS);
627 }
628
629 /*
630 * fcoei_watchdog
631 * Perform periodic checking and routine tasks
632 *
633 * Input:
634 * arg = the soft state that will be processed
635 *
636 * Return:
637 * N/A
638 *
639 * Comment:
640 * N/A
641 */
642 static void
643 fcoei_watchdog(void *arg)
644 {
645 fcoei_soft_state_t *ss;
646 clock_t tmp_delay;
647 clock_t start_clock;
648 clock_t last_clock;
649
650 /*
651 * For debugging
652 */
653 ss = (fcoei_soft_state_t *)arg;
654 FCOEI_LOG(__FUNCTION__, "ss %p", ss);
655 FCOEI_LOG(__FUNCTION__, "sol_hash %p", ss->ss_sol_oxid_hash);
656 FCOEI_LOG(__FUNCTION__, "unsol_hash %p", ss->ss_unsol_rxid_hash);
657 ss->ss_flags |= SS_FLAG_WATCHDOG_RUNNING;
658 tmp_delay = FCOE_SEC2TICK(1) / 2;
659 last_clock = CURRENT_CLOCK;
660
661 /*
662 * If nobody reqeusts to terminate the watchdog, we will work forever
663 */
664 while (!(ss->ss_flags & SS_FLAG_TERMINATE_WATCHDOG)) {
665 /*
666 * We handle all asynchronous events serially
667 */
668 fcoei_process_events(ss);
669
670 /*
671 * To avoid to check timing too freqently, we check
672 * if we need skip timing stuff.
673 */
674 start_clock = CURRENT_CLOCK;
675 if ((start_clock - last_clock) < tmp_delay) {
676 goto end_timing;
677 } else {
678 last_clock = start_clock;
679 }
680
681 /*
682 * It's time to do timeout checking of solicited exchanges
683 */
684 if (ss->ss_sol_cnt == (&ss->ss_sol_cnt1)) {
685 if (ss->ss_sol_cnt2 == 0) {
686 ss->ss_sol_cnt = &ss->ss_sol_cnt2;
687 } else {
688 mod_hash_walk(ss->ss_sol_oxid_hash,
689 fcoei_xch_check, ss);
690 }
691 } else {
692 if (ss->ss_sol_cnt1 == 0) {
693 ss->ss_sol_cnt = &ss->ss_sol_cnt1;
694 } else {
695 mod_hash_walk(ss->ss_sol_oxid_hash,
696 fcoei_xch_check, ss);
697 }
698 }
699
700 /*
701 * It's time to do timeout checking of unsolicited exchange
702 */
703 if (ss->ss_unsol_cnt == (&ss->ss_unsol_cnt1)) {
704 if (ss->ss_unsol_cnt2 == 0) {
705 ss->ss_unsol_cnt = &ss->ss_unsol_cnt2;
706 } else {
707 mod_hash_walk(ss->ss_unsol_rxid_hash,
708 fcoei_xch_check, ss);
709 }
710 } else {
711 if (ss->ss_unsol_cnt1 == 0) {
712 ss->ss_unsol_cnt = &ss->ss_unsol_cnt1;
713 } else {
714 mod_hash_walk(ss->ss_unsol_rxid_hash,
715 fcoei_xch_check, ss);
716 }
717 }
718
719 /*
720 * Check if there are exchanges which are ready to complete
721 */
722 fcoei_handle_comp_xch_list(ss);
723
724 end_timing:
725 /*
726 * Wait for next cycle
727 */
728 mutex_enter(&ss->ss_watchdog_mutex);
729 ss->ss_flags |= SS_FLAG_WATCHDOG_IDLE;
730 if (!list_is_empty(&ss->ss_event_list)) {
731 goto skip_wait;
732 }
733
734 (void) cv_timedwait(&ss->ss_watchdog_cv,
735 &ss->ss_watchdog_mutex, CURRENT_CLOCK +
736 (clock_t)tmp_delay);
737 skip_wait:
738 ss->ss_flags &= ~SS_FLAG_WATCHDOG_IDLE;
739 mutex_exit(&ss->ss_watchdog_mutex);
740 }
741
742 /*
743 * Do clear work before exit
744 */
745 fcoei_clear_watchdog_jobs(ss);
746
747 /*
748 * Watchdog has stopped
749 */
750 ss->ss_flags &= ~SS_FLAG_WATCHDOG_RUNNING;
751 }
752
753 static void
754 fcoei_clear_watchdog_jobs(fcoei_soft_state_t *ss)
755 {
756 fcoei_event_t *ae;
757 fcoe_frame_t *frm;
758
759 mutex_enter(&ss->ss_watchdog_mutex);
760 while (!list_is_empty(&ss->ss_event_list)) {
761 ae = (fcoei_event_t *)list_head(&ss->ss_event_list);
762 list_remove(&ss->ss_event_list, ae);
763 switch (ae->ae_type) {
764 case AE_EVENT_SOL_FRAME:
765 frm = (fcoe_frame_t *)ae->ae_obj;
766 frm->frm_eport->eport_release_frame(frm);
767 break;
768
769 case AE_EVENT_UNSOL_FRAME:
770 frm = (fcoe_frame_t *)ae->ae_obj;
771 frm->frm_eport->eport_free_netb(frm->frm_netb);
772 frm->frm_eport->eport_release_frame(frm);
773 break;
774
775 case AE_EVENT_PORT:
776 atomic_dec_32(&ss->ss_port_event_counter);
777 /* FALLTHROUGH */
778
779 case AE_EVENT_RESET:
780 kmem_free(ae, sizeof (fcoei_event_t));
781 break;
782
783 case AE_EVENT_EXCHANGE:
784 /* FALLTHROUGH */
785
786 default:
787 break;
788 }
789 }
790
791 mod_hash_clear(ss->ss_unsol_rxid_hash);
792 mod_hash_clear(ss->ss_sol_oxid_hash);
793
794 while (!list_is_empty(&ss->ss_comp_xch_list)) {
795 (void) list_remove_head(&ss->ss_comp_xch_list);
796 }
797 mutex_exit(&ss->ss_watchdog_mutex);
798 }
799
800 /*
801 * fcoei_process_events
802 * Process the events one by one
803 *
804 * Input:
805 * ss = the soft state that will be processed
806 *
807 * Return:
808 * N/A
809 *
810 * Comment:
811 * N/A
812 */
813 static void
814 fcoei_process_events(fcoei_soft_state_t *ss)
815 {
816 fcoei_event_t *ae = NULL;
817
818 /*
819 * It's the only place to delete node from ss_event_list, so we needn't
820 * hold mutex to check if the list is empty.
821 */
822 ASSERT(!MUTEX_HELD(&ss->ss_watchdog_mutex));
823 while (list_is_empty(&ss->ss_event_list) == B_FALSE) {
824 mutex_enter(&ss->ss_watchdog_mutex);
825 ae = (fcoei_event_t *)list_remove_head(&ss->ss_event_list);
826 mutex_exit(&ss->ss_watchdog_mutex);
827
828 switch (ae->ae_type) {
829 case AE_EVENT_SOL_FRAME:
830 fcoei_handle_sol_frame_done((fcoe_frame_t *)ae->ae_obj);
831 break;
832
833 case AE_EVENT_UNSOL_FRAME:
834 fcoei_process_unsol_frame((fcoe_frame_t *)ae->ae_obj);
835 break;
836
837 case AE_EVENT_EXCHANGE:
838 fcoei_process_event_exchange(ae);
839 break;
840
841 case AE_EVENT_PORT:
842 fcoei_process_event_port(ae);
843 break;
844
845 case AE_EVENT_RESET:
846 fcoei_process_event_reset(ae);
847 break;
848
849 default:
850 FCOEI_LOG(__FUNCTION__, "unsupported events");
851 }
852
853 }
854 }
855
856 /*
857 * fcoei_handle_tmout_xch_list
858 * Complete every exchange in the timed-out xch list of the soft state
859 *
860 * Input:
861 * ss = the soft state that need be handled
862 *
863 * Return:
864 * N/A
865 *
866 * Comment:
867 * When mod_hash_walk is in progress, we can't change the hashtable.
868 * This is post-walk handling of exchange timing
869 */
870 void
871 fcoei_handle_comp_xch_list(fcoei_soft_state_t *ss)
872 {
873 fcoei_exchange_t *xch = NULL;
874
875 while ((xch = list_remove_head(&ss->ss_comp_xch_list)) != NULL) {
876 fcoei_complete_xch(xch, NULL, xch->xch_fpkt->pkt_state,
877 xch->xch_fpkt->pkt_reason);
878 }
879 }
880
881 /*
882 * fcoei_xch_check
883 * Check if the exchange timed out or link is down
884 *
885 * Input:
886 * key = rxid of the unsolicited exchange
887 * val = the unsolicited exchange
888 * arg = the soft state
889 *
890 * Return:
891 * MH_WALK_CONTINUE = continue to walk
892 *
893 * Comment:
894 * We need send ABTS for timed-out for solicited exchange
895 * If it's solicited FLOGI, we need set SS_FLAG_FLOGI_FAILED
896 * If the link is down, we think it has timed out too.
897 */
898 /* ARGSUSED */
899 static uint32_t
900 fcoei_xch_check(mod_hash_key_t key, mod_hash_val_t *val, void *arg)
901 {
902 fcoei_exchange_t *xch = (fcoei_exchange_t *)val;
903
904 ASSERT(xch->xch_ss == arg);
905 if ((xch->xch_end_tick < CURRENT_CLOCK) &&
906 (xch->xch_ss->ss_link_state != FC_STATE_OFFLINE)) {
907 if (xch->xch_flags & XCH_FLAG_IN_SOL_HASH) {
908 ASSERT(xch->xch_oxid == CMHK(key));
909 /*
910 * It's solicited exchange
911 */
912 fcoei_abts_exchange(xch);
913 if (LA_ELS_FLOGI == ((ls_code_t *)(void *)
914 xch->xch_fpkt->pkt_cmd)->ls_code) {
915 /*
916 * It's solicited FLOGI
917 */
918 xch->xch_ss->ss_flags |= SS_FLAG_FLOGI_FAILED;
919 }
920 }
921
922 FCOEI_LOG(__FUNCTION__, "oxid-%x/rxid-%x timed out",
923 xch->xch_oxid, xch->xch_rxid);
924 xch->xch_flags |= XCH_FLAG_TMOUT;
925 xch->xch_fpkt->pkt_state = FC_PKT_TIMEOUT;
926 xch->xch_fpkt->pkt_reason = FC_REASON_ABORTED;
927 list_insert_tail(&xch->xch_ss->ss_comp_xch_list, xch);
928 } else if (xch->xch_ss->ss_link_state == FC_STATE_OFFLINE) {
929 FCOEI_LOG(__FUNCTION__, "oxid-%x/rxid-%x offline complete",
930 xch->xch_oxid, xch->xch_rxid);
931 xch->xch_flags |= XCH_FLAG_TMOUT;
932 xch->xch_fpkt->pkt_state = FC_PKT_PORT_OFFLINE;
933 xch->xch_fpkt->pkt_reason = FC_REASON_OFFLINE;
934 list_insert_tail(&xch->xch_ss->ss_comp_xch_list, xch);
935 }
936
937 return (MH_WALK_CONTINUE);
938 }
939
940 /*
941 * fcoei_init_ifm
942 * initialize fcoei_frame
943 *
944 * Input:
945 * frm = the frame that ifm need link to
946 * xch = the exchange that ifm need link to
947 *
948 * Return:
949 * N/A
950 *
951 * Comment:
952 * For solicited frames, it's called after FC frame header initialization
953 * For unsolicited frames, it's called just after the frame enters fcoei
954 */
955 void
956 fcoei_init_ifm(fcoe_frame_t *frm, fcoei_exchange_t *xch)
957 {
958 FRM2IFM(frm)->ifm_frm = frm;
959 FRM2IFM(frm)->ifm_xch = xch;
960 FRM2IFM(frm)->ifm_rctl = FRM_R_CTL(frm);
961 }
962
963 /*
964 * fcoei_trigger_fp_attach
965 * Trigger fp_attach for this fcoei port
966 *
967 * Input:
968 * arg = the soft state that fp will attach
969 *
970 * Return:
971 * N/A
972 *
973 * Comment:
974 * N/A
975 */
976 static void
977 fcoei_trigger_fp_attach(void * arg)
978 {
979 fcoei_soft_state_t *ss = (fcoei_soft_state_t *)arg;
980 dev_info_t *child = NULL;
981 int rval = NDI_FAILURE;
982
983 ndi_devi_alloc_sleep(ss->ss_dip, "fp", DEVI_PSEUDO_NODEID, &child);
984 if (child == NULL) {
985 FCOEI_LOG(__FUNCTION__, "can't alloc dev_info");
986 return;
987 }
988
989 /*
990 * fp/fctl need this property
991 */
992 if (ddi_prop_update_string(DDI_DEV_T_NONE, child,
993 "bus-addr", "0,0") != DDI_PROP_SUCCESS) {
994 FCOEI_LOG(__FUNCTION__, "update bus-addr failed");
995 (void) ndi_devi_free(child);
996 return;
997 }
998
999 /*
1000 * If it's physical HBA, fp.conf will register the property.
1001 * fcoei is one software HBA, so we need register it manually
1002 */
1003 if (ddi_prop_update_int(DDI_DEV_T_NONE, child,
1004 "port", 0) != DDI_PROP_SUCCESS) {
1005 FCOEI_LOG(__FUNCTION__, "update port failed");
1006 (void) ndi_devi_free(child);
1007 return;
1008 }
1009
1010 /*
1011 * It will call fp_attach eventually
1012 */
1013 rval = ndi_devi_online(child, NDI_ONLINE_ATTACH);
1014 ss->ss_flags &= ~SS_FLAG_TRIGGER_FP_ATTACH;
1015 if (rval != NDI_SUCCESS) {
1016 FCOEI_LOG(__FUNCTION__, "devi_online: %d", rval);
1017 } else {
1018 FCOEI_LOG(__FUNCTION__, "triggered successfully");
1019 }
1020 }
1021
1022 /*
1023 * fcoei_abts_exchange
1024 * Send ABTS to abort solicited exchange
1025 *
1026 * Input:
1027 * xch = the exchange that will be aborted
1028 *
1029 * Return:
1030 * N/A
1031 *
1032 * Comment:
1033 * ABTS frame uses the same oxid as the exchange
1034 */
1035 static void
1036 fcoei_abts_exchange(fcoei_exchange_t *xch)
1037 {
1038 fc_packet_t *fpkt = xch->xch_fpkt;
1039 fcoe_frame_t *frm = NULL;
1040
1041 /*
1042 * BLS_ABTS doesn't contain any other payload except FCFH
1043 */
1044 frm = xch->xch_ss->ss_eport->eport_alloc_frame(xch->xch_ss->ss_eport,
1045 FCFH_SIZE, NULL);
1046 if (frm == NULL) {
1047 FCOEI_LOG(__FUNCTION__, "can't alloc frame: %p", xch);
1048 return;
1049 }
1050
1051 FFM_R_CTL(0x81, frm);
1052 FFM_D_ID(fpkt->pkt_cmd_fhdr.d_id, frm);
1053 FFM_S_ID(fpkt->pkt_cmd_fhdr.s_id, frm);
1054 FFM_F_CTL(0x090000, frm);
1055 FFM_SEQ_ID(0x01, frm);
1056 FFM_OXID(xch->xch_oxid, frm);
1057 FFM_RXID(xch->xch_rxid, frm);
1058 fcoei_init_ifm(frm, xch);
1059 xch->xch_ss->ss_eport->eport_tx_frame(frm);
1060 }
1061
1062 /*
1063 * fcoei_complete_xch
1064 * Complete the exchange
1065 *
1066 * Input:
1067 * xch = the exchange that will be completed
1068 * frm = newly-allocated frame that has not been submitted
1069 * pkt_state = LV fpkt state
1070 * pkt_reason = LV fpkt reason
1071 *
1072 * Return:
1073 * N/A
1074 *
1075 * Comment:
1076 * N/A
1077 */
1078 void
1079 fcoei_complete_xch(fcoei_exchange_t *xch, fcoe_frame_t *frm,
1080 uint8_t pkt_state, uint8_t pkt_reason)
1081 {
1082 mod_hash_val_t val;
1083
1084 if (pkt_state != FC_PKT_SUCCESS) {
1085 FCOEI_LOG(__FUNCTION__, "FHDR: %x/%x/%x, %x/%x/%x",
1086 xch->xch_fpkt->pkt_cmd_fhdr.r_ctl,
1087 xch->xch_fpkt->pkt_cmd_fhdr.f_ctl,
1088 xch->xch_fpkt->pkt_cmd_fhdr.type,
1089 xch->xch_fpkt->pkt_resp_fhdr.r_ctl,
1090 xch->xch_fpkt->pkt_resp_fhdr.f_ctl,
1091 xch->xch_fpkt->pkt_resp_fhdr.type);
1092 FCOEI_LOG(__FUNCTION__, "%p/%p/%x/%x",
1093 xch, frm, pkt_state, pkt_reason);
1094 }
1095
1096 if (frm != NULL) {
1097 /*
1098 * It's newly-allocated frame , which we haven't sent out
1099 */
1100 xch->xch_ss->ss_eport->eport_free_netb(frm->frm_netb);
1101 xch->xch_ss->ss_eport->eport_release_frame(frm);
1102 FCOEI_LOG(__FUNCTION__, "xch: %p, not submitted", xch);
1103 }
1104
1105 /*
1106 * If xch is in hash table, we need remove it
1107 */
1108 if (xch->xch_flags & XCH_FLAG_IN_SOL_HASH) {
1109 (void) mod_hash_remove(xch->xch_ss->ss_sol_oxid_hash,
1110 FMHK(xch->xch_oxid), &val);
1111 ASSERT((fcoei_exchange_t *)val == xch);
1112 xch->xch_flags &= ~XCH_FLAG_IN_SOL_HASH;
1113 } else if (xch->xch_flags & XCH_FLAG_IN_UNSOL_HASH) {
1114 (void) mod_hash_remove(xch->xch_ss->ss_unsol_rxid_hash,
1115 FMHK(xch->xch_rxid), &val);
1116 ASSERT((fcoei_exchange_t *)val == xch);
1117 xch->xch_flags &= ~XCH_FLAG_IN_UNSOL_HASH;
1118 } else {
1119 FCOEI_LOG(__FUNCTION__, "xch not in any hash: %p", xch);
1120 }
1121
1122 xch->xch_fpkt->pkt_state = pkt_state;
1123 xch->xch_fpkt->pkt_reason = pkt_reason;
1124 if (xch->xch_fpkt->pkt_tran_flags & FC_TRAN_NO_INTR) {
1125 FCOEI_LOG(__FUNCTION__, "polled xch is done: %p", xch);
1126 sema_v(&xch->xch_sema);
1127 } else {
1128 xch->xch_fpkt->pkt_comp(xch->xch_fpkt);
1129 }
1130 }