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 * Copyright 2010 Sun Microsystems, Inc. All rights reserved.
23 * Use is subject to license terms.
24 */
25 /*
26 * Copyright 2012 Garrett D'Amore <garrett@damore.org>. All rights reserved.
27 */
28 /*
29 * Fibre channel Transport Library (fctl)
30 *
31 * Function naming conventions:
32 * Functions called from ULPs begin with fc_ulp_
33 * Functions called from FCAs begin with fc_fca_
34 * Internal functions begin with fctl_
35 *
36 * Fibre channel packet layout:
37 * +---------------------+<--------+
38 * | | |
39 * | ULP Packet private | |
40 * | | |
41 * +---------------------+ |
42 * | |---------+
43 * | struct fc_packet |---------+
44 * | | |
45 * +---------------------+<--------+
46 * | |
47 * | FCA Packet private |
48 * | |
49 * +---------------------+
50 *
51 * So you loved the ascii art ? It's strongly desirable to cache
52 * allocate the entire packet in one common place. So we define a set a
53 * of rules. In a contiguous block of memory, the top portion of the
54 * block points to ulp packet private area, next follows the fc_packet
55 * structure used extensively by all the consumers and what follows this
56 * is the FCA packet private. Note that given a packet structure, it is
57 * possible to get to the ULP and FCA Packet private fields using
58 * ulp_private and fca_private fields (which hold pointers) respectively.
59 *
60 * It should be noted with a grain of salt that ULP Packet private size
61 * varies between two different ULP types, So this poses a challenge to
62 * compute the correct size of the whole block on a per port basis. The
63 * transport layer doesn't have a problem in dealing with FCA packet
64 * private sizes as it is the sole manager of ports underneath. Since
65 * it's not a good idea to cache allocate different sizes of memory for
66 * different ULPs and have the ability to choose from one of these caches
67 * based on ULP type during every packet allocation, the transport some
68 * what wisely (?) hands off this job of cache allocation to the ULPs
69 * themselves.
70 *
71 * That means FCAs need to make their packet private size known to the
72 * transport to pass it up to the ULPs. This is done during
73 * fc_fca_attach(). And the transport passes this size up to ULPs during
74 * fc_ulp_port_attach() of each ULP.
75 *
76 * This leaves us with another possible question; How are packets
77 * allocated for ELS's started by the transport itself ? Well, the port
78 * driver during attach time, cache allocates on a per port basis to
79 * handle ELSs too.
80 */
81
82 #include <sys/note.h>
83 #include <sys/types.h>
84 #include <sys/varargs.h>
85 #include <sys/param.h>
86 #include <sys/errno.h>
87 #include <sys/uio.h>
88 #include <sys/buf.h>
89 #include <sys/modctl.h>
90 #include <sys/open.h>
91 #include <sys/kmem.h>
92 #include <sys/poll.h>
93 #include <sys/conf.h>
94 #include <sys/cmn_err.h>
95 #include <sys/stat.h>
96 #include <sys/ddi.h>
97 #include <sys/sunddi.h>
98 #include <sys/promif.h>
99 #include <sys/byteorder.h>
100 #include <sys/fibre-channel/fc.h>
101 #include <sys/fibre-channel/impl/fc_ulpif.h>
102 #include <sys/fibre-channel/impl/fc_fcaif.h>
103 #include <sys/fibre-channel/impl/fctl_private.h>
104 #include <sys/fibre-channel/impl/fc_portif.h>
105
106 /* These are referenced by fp.c! */
107 int did_table_size = D_ID_HASH_TABLE_SIZE;
108 int pwwn_table_size = PWWN_HASH_TABLE_SIZE;
109
110 static fc_ulp_module_t *fctl_ulp_modules;
111 static fc_fca_port_t *fctl_fca_portlist;
112 static fc_ulp_list_t *fctl_ulp_list;
113
114 static char fctl_greeting[] =
115 "fctl: %s ULP same type (0x%x) as existing module.\n";
116
117 static char *fctl_undefined = "Undefined";
118
119 /*
120 * This lock protects the fc_ulp_module_t linked list (i.e. mod_next field)
121 */
122
123 static krwlock_t fctl_ulp_lock;
124
125 /*
126 * The fctl_mod_ports_lock protects the mod_ports element in the
127 * fc_ulp_ports_t structure
128 */
129
130 static krwlock_t fctl_mod_ports_lock;
131
132 /*
133 * fctl_port_lock protects the linked list of local port structures
134 * (fctl_fca_portlist). When walking the list, this lock must be obtained
135 * prior to any local port locks.
136 */
137
138 static kmutex_t fctl_port_lock;
139 static kmutex_t fctl_ulp_list_mutex;
140
141 static fctl_nwwn_list_t *fctl_nwwn_hash_table;
142 static kmutex_t fctl_nwwn_hash_mutex;
143 int fctl_nwwn_table_size = NWWN_HASH_TABLE_SIZE;
144
145 #if !defined(lint)
146 _NOTE(MUTEX_PROTECTS_DATA(fctl_nwwn_hash_mutex, fctl_nwwn_hash_table))
147 _NOTE(MUTEX_PROTECTS_DATA(fctl_ulp_list_mutex, fctl_ulp_list))
148 _NOTE(RWLOCK_PROTECTS_DATA(fctl_ulp_lock, ulp_module::mod_next))
149 _NOTE(RWLOCK_PROTECTS_DATA(fctl_mod_ports_lock, ulp_module::mod_ports
150 ulp_ports::port_handle))
151 _NOTE(DATA_READABLE_WITHOUT_LOCK(ulp_module::mod_info))
152 _NOTE(MUTEX_PROTECTS_DATA(ulp_ports::port_mutex, ulp_ports::port_statec
153 ulp_ports::port_dstate))
154 #endif /* lint */
155
156 #define FCTL_VERSION "20090729-1.70"
157 #define FCTL_NAME_VERSION "SunFC Transport v" FCTL_VERSION
158
159 char *fctl_version = FCTL_NAME_VERSION;
160
161 extern struct mod_ops mod_miscops;
162
163 static struct modlmisc modlmisc = {
164 &mod_miscops, /* type of module */
165 FCTL_NAME_VERSION /* Module name */
166 };
167
168 static struct modlinkage modlinkage = {
169 MODREV_1, (void *)&modlmisc, NULL
170 };
171
172 static struct bus_ops fctl_fca_busops = {
173 BUSO_REV,
174 nullbusmap, /* bus_map */
175 NULL, /* bus_get_intrspec */
176 NULL, /* bus_add_intrspec */
177 NULL, /* bus_remove_intrspec */
178 i_ddi_map_fault, /* bus_map_fault */
179 NULL, /* bus_dma_map */
180 ddi_dma_allochdl, /* bus_dma_allochdl */
181 ddi_dma_freehdl, /* bus_dma_freehdl */
182 ddi_dma_bindhdl, /* bus_dma_bindhdl */
183 ddi_dma_unbindhdl, /* bus_unbindhdl */
184 ddi_dma_flush, /* bus_dma_flush */
185 ddi_dma_win, /* bus_dma_win */
186 ddi_dma_mctl, /* bus_dma_ctl */
187 fctl_fca_bus_ctl, /* bus_ctl */
188 ddi_bus_prop_op, /* bus_prop_op */
189 NULL, /* bus_get_eventcookie */
190 NULL, /* bus_add_eventcall */
191 NULL, /* bus_remove_event */
192 NULL, /* bus_post_event */
193 NULL, /* bus_intr_ctl */
194 NULL, /* bus_config */
195 NULL, /* bus_unconfig */
196 NULL, /* bus_fm_init */
197 NULL, /* bus_fm_fini */
198 NULL, /* bus_fm_access_enter */
199 NULL, /* bus_fm_access_exit */
200 NULL, /* bus_power */
201 NULL
202 };
203
204 struct kmem_cache *fctl_job_cache;
205
206 static fc_errmap_t fc_errlist [] = {
207 { FC_FAILURE, "Operation failed" },
208 { FC_SUCCESS, "Operation success" },
209 { FC_CAP_ERROR, "Capability error" },
210 { FC_CAP_FOUND, "Capability found" },
211 { FC_CAP_SETTABLE, "Capability settable" },
212 { FC_UNBOUND, "Port not bound" },
213 { FC_NOMEM, "No memory" },
214 { FC_BADPACKET, "Bad packet" },
215 { FC_OFFLINE, "Port offline" },
216 { FC_OLDPORT, "Old Port" },
217 { FC_NO_MAP, "No map available" },
218 { FC_TRANSPORT_ERROR, "Transport error" },
219 { FC_ELS_FREJECT, "ELS Frejected" },
220 { FC_ELS_PREJECT, "ELS PRejected" },
221 { FC_ELS_BAD, "Bad ELS request" },
222 { FC_ELS_MALFORMED, "Malformed ELS request" },
223 { FC_TOOMANY, "Too many commands" },
224 { FC_UB_BADTOKEN, "Bad Unsolicited buffer token" },
225 { FC_UB_ERROR, "Unsolicited buffer error" },
226 { FC_UB_BUSY, "Unsolicited buffer busy" },
227 { FC_BADULP, "Bad ULP" },
228 { FC_BADTYPE, "Bad Type" },
229 { FC_UNCLAIMED, "Not Claimed" },
230 { FC_ULP_SAMEMODULE, "Same ULP Module" },
231 { FC_ULP_SAMETYPE, "Same ULP Type" },
232 { FC_ABORTED, "Command Aborted" },
233 { FC_ABORT_FAILED, "Abort Failed" },
234 { FC_BADEXCHANGE, "Bad Exchange" },
235 { FC_BADWWN, "Bad World Wide Name" },
236 { FC_BADDEV, "Bad Device" },
237 { FC_BADCMD, "Bad Command" },
238 { FC_BADOBJECT, "Bad Object" },
239 { FC_BADPORT, "Bad Port" },
240 { FC_NOTTHISPORT, "Not on this Port" },
241 { FC_PREJECT, "Operation Prejected" },
242 { FC_FREJECT, "Operation Frejected" },
243 { FC_PBUSY, "Operation Pbusyed" },
244 { FC_FBUSY, "Operation Fbusyed" },
245 { FC_ALREADY, "Already done" },
246 { FC_LOGINREQ, "PLOGI Required" },
247 { FC_RESETFAIL, "Reset operation failed" },
248 { FC_INVALID_REQUEST, "Invalid Request" },
249 { FC_OUTOFBOUNDS, "Out of Bounds" },
250 { FC_TRAN_BUSY, "Command transport Busy" },
251 { FC_STATEC_BUSY, "State change Busy" },
252 { FC_DEVICE_BUSY, "Port driver is working on this device" }
253 };
254
255 fc_pkt_reason_t remote_stop_reasons [] = {
256 { FC_REASON_ABTS, "Abort Sequence" },
257 { FC_REASON_ABTX, "Abort Exchange" },
258 { FC_REASON_INVALID, NULL }
259 };
260
261 fc_pkt_reason_t general_reasons [] = {
262 { FC_REASON_HW_ERROR, "Hardware Error" },
263 { FC_REASON_SEQ_TIMEOUT, "Sequence Timeout" },
264 { FC_REASON_ABORTED, "Aborted" },
265 { FC_REASON_ABORT_FAILED, "Abort Failed" },
266 { FC_REASON_NO_CONNECTION, "No Connection" },
267 { FC_REASON_XCHG_DROPPED, "Exchange Dropped" },
268 { FC_REASON_ILLEGAL_FRAME, "Illegal Frame" },
269 { FC_REASON_ILLEGAL_LENGTH, "Illegal Length" },
270 { FC_REASON_UNSUPPORTED, "Unsuported" },
271 { FC_REASON_RX_BUF_TIMEOUT, "Receive Buffer Timeout" },
272 { FC_REASON_FCAL_OPN_FAIL, "FC AL Open Failed" },
273 { FC_REASON_OVERRUN, "Over run" },
274 { FC_REASON_QFULL, "Queue Full" },
275 { FC_REASON_ILLEGAL_REQ, "Illegal Request", },
276 { FC_REASON_PKT_BUSY, "Busy" },
277 { FC_REASON_OFFLINE, "Offline" },
278 { FC_REASON_BAD_XID, "Bad Exchange Id" },
279 { FC_REASON_XCHG_BSY, "Exchange Busy" },
280 { FC_REASON_NOMEM, "No Memory" },
281 { FC_REASON_BAD_SID, "Bad S_ID" },
282 { FC_REASON_NO_SEQ_INIT, "No Sequence Initiative" },
283 { FC_REASON_DIAG_BUSY, "Diagnostic Busy" },
284 { FC_REASON_DMA_ERROR, "DMA Error" },
285 { FC_REASON_CRC_ERROR, "CRC Error" },
286 { FC_REASON_ABORT_TIMEOUT, "Abort Timeout" },
287 { FC_REASON_FCA_UNIQUE, "FCA Unique" },
288 { FC_REASON_INVALID, NULL }
289 };
290
291 fc_pkt_reason_t rjt_reasons [] = {
292 { FC_REASON_INVALID_D_ID, "Invalid D_ID" },
293 { FC_REASON_INVALID_S_ID, "Invalid S_ID" },
294 { FC_REASON_TEMP_UNAVAILABLE, "Temporarily Unavailable" },
295 { FC_REASON_PERM_UNAVAILABLE, "Permamnently Unavailable" },
296 { FC_REASON_CLASS_NOT_SUPP, "Class Not Supported", },
297 { FC_REASON_DELIMTER_USAGE_ERROR,
298 "Delimeter Usage Error" },
299 { FC_REASON_TYPE_NOT_SUPP, "Type Not Supported" },
300 { FC_REASON_INVALID_LINK_CTRL, "Invalid Link Control" },
301 { FC_REASON_INVALID_R_CTL, "Invalid R_CTL" },
302 { FC_REASON_INVALID_F_CTL, "Invalid F_CTL" },
303 { FC_REASON_INVALID_OX_ID, "Invalid OX_ID" },
304 { FC_REASON_INVALID_RX_ID, "Invalid RX_ID" },
305 { FC_REASON_INVALID_SEQ_ID, "Invalid Sequence ID" },
306 { FC_REASON_INVALID_DF_CTL, "Invalid DF_CTL" },
307 { FC_REASON_INVALID_SEQ_CNT, "Invalid Sequence count" },
308 { FC_REASON_INVALID_PARAM, "Invalid Parameter" },
309 { FC_REASON_EXCH_ERROR, "Exchange Error" },
310 { FC_REASON_PROTOCOL_ERROR, "Protocol Error" },
311 { FC_REASON_INCORRECT_LENGTH, "Incorrect Length" },
312 { FC_REASON_UNEXPECTED_ACK, "Unexpected Ack" },
313 { FC_REASON_UNEXPECTED_LR, "Unexpected Link reset" },
314 { FC_REASON_LOGIN_REQUIRED, "Login Required" },
315 { FC_REASON_EXCESSIVE_SEQS, "Excessive Sequences"
316 " Attempted" },
317 { FC_REASON_EXCH_UNABLE, "Exchange incapable" },
318 { FC_REASON_ESH_NOT_SUPP, "Expiration Security Header "
319 "Not Supported" },
320 { FC_REASON_NO_FABRIC_PATH, "No Fabric Path" },
321 { FC_REASON_VENDOR_UNIQUE, "Vendor Unique" },
322 { FC_REASON_INVALID, NULL }
323 };
324
325 fc_pkt_reason_t n_port_busy_reasons [] = {
326 { FC_REASON_PHYSICAL_BUSY, "Physical Busy" },
327 { FC_REASON_N_PORT_RESOURCE_BSY, "Resource Busy" },
328 { FC_REASON_N_PORT_VENDOR_UNIQUE, "Vendor Unique" },
329 { FC_REASON_INVALID, NULL }
330 };
331
332 fc_pkt_reason_t f_busy_reasons [] = {
333 { FC_REASON_FABRIC_BSY, "Fabric Busy" },
334 { FC_REASON_N_PORT_BSY, "N_Port Busy" },
335 { FC_REASON_INVALID, NULL }
336 };
337
338 fc_pkt_reason_t ls_ba_rjt_reasons [] = {
339 { FC_REASON_INVALID_LA_CODE, "Invalid Link Application Code" },
340 { FC_REASON_LOGICAL_ERROR, "Logical Error" },
341 { FC_REASON_LOGICAL_BSY, "Logical Busy" },
342 { FC_REASON_PROTOCOL_ERROR_RJT, "Protocol Error Reject" },
343 { FC_REASON_CMD_UNABLE, "Unable to Perform Command" },
344 { FC_REASON_CMD_UNSUPPORTED, "Unsupported Command" },
345 { FC_REASON_VU_RJT, "Vendor Unique" },
346 { FC_REASON_INVALID, NULL }
347 };
348
349 fc_pkt_reason_t fs_rjt_reasons [] = {
350 { FC_REASON_FS_INVALID_CMD, "Invalid Command" },
351 { FC_REASON_FS_INVALID_VER, "Invalid Version" },
352 { FC_REASON_FS_LOGICAL_ERR, "Logical Error" },
353 { FC_REASON_FS_INVALID_IUSIZE, "Invalid IU Size" },
354 { FC_REASON_FS_LOGICAL_BUSY, "Logical Busy" },
355 { FC_REASON_FS_PROTOCOL_ERR, "Protocol Error" },
356 { FC_REASON_FS_CMD_UNABLE, "Unable to Perform Command" },
357 { FC_REASON_FS_CMD_UNSUPPORTED, "Unsupported Command" },
358 { FC_REASON_FS_VENDOR_UNIQUE, "Vendor Unique" },
359 { FC_REASON_INVALID, NULL }
360 };
361
362 fc_pkt_action_t n_port_busy_actions [] = {
363 { FC_ACTION_SEQ_TERM_RETRY, "Retry terminated Sequence" },
364 { FC_ACTION_SEQ_ACTIVE_RETRY, "Retry Active Sequence" },
365 { FC_REASON_INVALID, NULL }
366 };
367
368 fc_pkt_action_t rjt_timeout_actions [] = {
369 { FC_ACTION_RETRYABLE, "Retryable" },
370 { FC_ACTION_NON_RETRYABLE, "Non Retryable" },
371 { FC_REASON_INVALID, NULL }
372 };
373
374 fc_pkt_expln_t ba_rjt_explns [] = {
375 { FC_EXPLN_NONE, "No Explanation" },
376 { FC_EXPLN_INVALID_OX_RX_ID, "Invalid X_ID" },
377 { FC_EXPLN_SEQ_ABORTED, "Sequence Aborted" },
378 { FC_EXPLN_INVALID, NULL }
379 };
380
381 fc_pkt_error_t fc_pkt_errlist[] = {
382 {
383 FC_PKT_SUCCESS,
384 "Operation Success",
385 NULL,
386 NULL,
387 NULL
388 },
389 { FC_PKT_REMOTE_STOP,
390 "Remote Stop",
391 remote_stop_reasons,
392 NULL,
393 NULL
394 },
395 {
396 FC_PKT_LOCAL_RJT,
397 "Local Reject",
398 general_reasons,
399 rjt_timeout_actions,
400 NULL
401 },
402 {
403 FC_PKT_NPORT_RJT,
404 "N_Port Reject",
405 rjt_reasons,
406 rjt_timeout_actions,
407 NULL
408 },
409 {
410 FC_PKT_FABRIC_RJT,
411 "Fabric Reject",
412 rjt_reasons,
413 rjt_timeout_actions,
414 NULL
415 },
416 {
417 FC_PKT_LOCAL_BSY,
418 "Local Busy",
419 general_reasons,
420 NULL,
421 NULL,
422 },
423 {
424 FC_PKT_TRAN_BSY,
425 "Transport Busy",
426 general_reasons,
427 NULL,
428 NULL,
429 },
430 {
431 FC_PKT_NPORT_BSY,
432 "N_Port Busy",
433 n_port_busy_reasons,
434 n_port_busy_actions,
435 NULL
436 },
437 {
438 FC_PKT_FABRIC_BSY,
439 "Fabric Busy",
440 f_busy_reasons,
441 NULL,
442 NULL,
443 },
444 {
445 FC_PKT_LS_RJT,
446 "Link Service Reject",
447 ls_ba_rjt_reasons,
448 NULL,
449 NULL,
450 },
451 {
452 FC_PKT_BA_RJT,
453 "Basic Reject",
454 ls_ba_rjt_reasons,
455 NULL,
456 ba_rjt_explns,
457 },
458 {
459 FC_PKT_TIMEOUT,
460 "Timeout",
461 general_reasons,
462 rjt_timeout_actions,
463 NULL
464 },
465 {
466 FC_PKT_FS_RJT,
467 "Fabric Switch Reject",
468 fs_rjt_reasons,
469 NULL,
470 NULL
471 },
472 {
473 FC_PKT_TRAN_ERROR,
474 "Packet Transport error",
475 general_reasons,
476 NULL,
477 NULL
478 },
479 {
480 FC_PKT_FAILURE,
481 "Packet Failure",
482 general_reasons,
483 NULL,
484 NULL
485 },
486 {
487 FC_PKT_PORT_OFFLINE,
488 "Port Offline",
489 NULL,
490 NULL,
491 NULL
492 },
493 {
494 FC_PKT_ELS_IN_PROGRESS,
495 "ELS is in Progress",
496 NULL,
497 NULL,
498 NULL
499 }
500 };
501
502 int
503 _init()
504 {
505 int rval;
506
507 rw_init(&fctl_ulp_lock, NULL, RW_DRIVER, NULL);
508 rw_init(&fctl_mod_ports_lock, NULL, RW_DRIVER, NULL);
509 mutex_init(&fctl_port_lock, NULL, MUTEX_DRIVER, NULL);
510 mutex_init(&fctl_nwwn_hash_mutex, NULL, MUTEX_DRIVER, NULL);
511
512 fctl_nwwn_hash_table = kmem_zalloc(sizeof (*fctl_nwwn_hash_table) *
513 fctl_nwwn_table_size, KM_SLEEP);
514
515 fctl_ulp_modules = NULL;
516 fctl_fca_portlist = NULL;
517
518 fctl_job_cache = kmem_cache_create("fctl_cache",
519 sizeof (job_request_t), 8, fctl_cache_constructor,
520 fctl_cache_destructor, NULL, NULL, NULL, 0);
521
522 if (fctl_job_cache == NULL) {
523 kmem_free(fctl_nwwn_hash_table,
524 sizeof (*fctl_nwwn_hash_table) * fctl_nwwn_table_size);
525 mutex_destroy(&fctl_nwwn_hash_mutex);
526 mutex_destroy(&fctl_port_lock);
527 rw_destroy(&fctl_ulp_lock);
528 rw_destroy(&fctl_mod_ports_lock);
529 return (ENOMEM);
530 }
531
532 if ((rval = mod_install(&modlinkage)) != 0) {
533 kmem_cache_destroy(fctl_job_cache);
534 kmem_free(fctl_nwwn_hash_table,
535 sizeof (*fctl_nwwn_hash_table) * fctl_nwwn_table_size);
536 mutex_destroy(&fctl_nwwn_hash_mutex);
537 mutex_destroy(&fctl_port_lock);
538 rw_destroy(&fctl_ulp_lock);
539 rw_destroy(&fctl_mod_ports_lock);
540 }
541
542 return (rval);
543 }
544
545
546 /*
547 * The mod_uninstall code doesn't call _fini when
548 * there is living dependent module on fctl. So
549 * there is no need to be extra careful here ?
550 */
551 int
552 _fini()
553 {
554 int rval;
555
556 if ((rval = mod_remove(&modlinkage)) != 0) {
557 return (rval);
558 }
559
560 kmem_cache_destroy(fctl_job_cache);
561 kmem_free(fctl_nwwn_hash_table,
562 sizeof (*fctl_nwwn_hash_table) * fctl_nwwn_table_size);
563 mutex_destroy(&fctl_nwwn_hash_mutex);
564 mutex_destroy(&fctl_port_lock);
565 rw_destroy(&fctl_ulp_lock);
566 rw_destroy(&fctl_mod_ports_lock);
567
568 return (rval);
569 }
570
571
572 int
573 _info(struct modinfo *modinfo_p)
574 {
575 return (mod_info(&modlinkage, modinfo_p));
576 }
577
578
579 /* ARGSUSED */
580 static int
581 fctl_cache_constructor(void *buf, void *cdarg, int kmflag)
582 {
583 job_request_t *job = (job_request_t *)buf;
584
585 mutex_init(&job->job_mutex, NULL, MUTEX_DRIVER, NULL);
586 sema_init(&job->job_fctl_sema, 0, NULL, SEMA_DEFAULT, NULL);
587 sema_init(&job->job_port_sema, 0, NULL, SEMA_DEFAULT, NULL);
588
589 return (0);
590 }
591
592
593 /* ARGSUSED */
594 static void
595 fctl_cache_destructor(void *buf, void *cdarg)
596 {
597 job_request_t *job = (job_request_t *)buf;
598
599 sema_destroy(&job->job_fctl_sema);
600 sema_destroy(&job->job_port_sema);
601 mutex_destroy(&job->job_mutex);
602 }
603
604
605 /*
606 * fc_ulp_add:
607 * Add a ULP module
608 *
609 * Return Codes:
610 * FC_ULP_SAMEMODULE
611 * FC_SUCCESS
612 * FC_FAILURE
613 *
614 * fc_ulp_add prints a warning message if there is already a
615 * similar ULP type attached and this is unlikely to change as
616 * we trudge along. Further, this function returns a failure
617 * code if the same module attempts to add more than once for
618 * the same FC-4 type.
619 */
620 int
621 fc_ulp_add(fc_ulp_modinfo_t *ulp_info)
622 {
623 fc_ulp_module_t *mod;
624 fc_ulp_module_t *prev;
625 job_request_t *job;
626 fc_ulp_list_t *new;
627 fc_fca_port_t *fca_port;
628 int ntry = 0;
629
630 ASSERT(ulp_info != NULL);
631
632 /*
633 * Make sure ulp_rev matches fctl version.
634 * Whenever non-private data structure or non-static interface changes,
635 * we should use an increased FCTL_ULP_MODREV_# number here and in all
636 * ulps to prevent version mismatch.
637 */
638 if (ulp_info->ulp_rev != FCTL_ULP_MODREV_4) {
639 cmn_err(CE_WARN, "fctl: ULP %s version mismatch;"
640 " ULP %s would not be loaded", ulp_info->ulp_name,
641 ulp_info->ulp_name);
642 return (FC_BADULP);
643 }
644
645 new = kmem_zalloc(sizeof (*new), KM_SLEEP);
646 ASSERT(new != NULL);
647
648 mutex_enter(&fctl_ulp_list_mutex);
649 new->ulp_info = ulp_info;
650 if (fctl_ulp_list != NULL) {
651 new->ulp_next = fctl_ulp_list;
652 }
653 fctl_ulp_list = new;
654 mutex_exit(&fctl_ulp_list_mutex);
655
656 while (rw_tryenter(&fctl_ulp_lock, RW_WRITER) == 0) {
657 delay(drv_usectohz(1000000));
658 if (ntry++ > FC_ULP_ADD_RETRY_COUNT) {
659 fc_ulp_list_t *list;
660 fc_ulp_list_t *last;
661 mutex_enter(&fctl_ulp_list_mutex);
662 for (last = NULL, list = fctl_ulp_list; list != NULL;
663 list = list->ulp_next) {
664 if (list->ulp_info == ulp_info) {
665 break;
666 }
667 last = list;
668 }
669
670 if (list) {
671 if (last) {
672 last->ulp_next = list->ulp_next;
673 } else {
674 fctl_ulp_list = list->ulp_next;
675 }
676 kmem_free(list, sizeof (*list));
677 }
678 mutex_exit(&fctl_ulp_list_mutex);
679 cmn_err(CE_WARN, "fctl: ULP %s unable to load",
680 ulp_info->ulp_name);
681 return (FC_FAILURE);
682 }
683 }
684
685 for (mod = fctl_ulp_modules, prev = NULL; mod; mod = mod->mod_next) {
686 ASSERT(mod->mod_info != NULL);
687
688 if (ulp_info == mod->mod_info &&
689 ulp_info->ulp_type == mod->mod_info->ulp_type) {
690 rw_exit(&fctl_ulp_lock);
691 return (FC_ULP_SAMEMODULE);
692 }
693
694 if (ulp_info->ulp_type == mod->mod_info->ulp_type) {
695 cmn_err(CE_NOTE, fctl_greeting, ulp_info->ulp_name,
696 ulp_info->ulp_type);
697 }
698 prev = mod;
699 }
700
701 mod = kmem_zalloc(sizeof (*mod), KM_SLEEP);
702 mod->mod_info = ulp_info;
703 mod->mod_next = NULL;
704
705 if (prev) {
706 prev->mod_next = mod;
707 } else {
708 fctl_ulp_modules = mod;
709 }
710
711 /*
712 * Schedule a job to each port's job_handler
713 * thread to attach their ports with this ULP.
714 */
715 mutex_enter(&fctl_port_lock);
716 for (fca_port = fctl_fca_portlist; fca_port != NULL;
717 fca_port = fca_port->port_next) {
718 job = fctl_alloc_job(JOB_ATTACH_ULP, JOB_TYPE_FCTL_ASYNC,
719 NULL, NULL, KM_SLEEP);
720
721 fctl_enque_job(fca_port->port_handle, job);
722 }
723 mutex_exit(&fctl_port_lock);
724
725 rw_exit(&fctl_ulp_lock);
726
727 return (FC_SUCCESS);
728 }
729
730
731 /*
732 * fc_ulp_remove
733 * Remove a ULP module
734 *
735 * A misbehaving ULP may call this routine while I/Os are in progress.
736 * Currently there is no mechanism to detect it to fail such a request.
737 *
738 * Return Codes:
739 * FC_SUCCESS
740 * FC_FAILURE
741 */
742 int
743 fc_ulp_remove(fc_ulp_modinfo_t *ulp_info)
744 {
745 fc_ulp_module_t *mod;
746 fc_ulp_list_t *list;
747 fc_ulp_list_t *last;
748 fc_ulp_module_t *prev;
749
750 mutex_enter(&fctl_ulp_list_mutex);
751
752 for (last = NULL, list = fctl_ulp_list; list != NULL;
753 list = list->ulp_next) {
754 if (list->ulp_info == ulp_info) {
755 break;
756 }
757 last = list;
758 }
759
760 if (list) {
761 if (last) {
762 last->ulp_next = list->ulp_next;
763 } else {
764 fctl_ulp_list = list->ulp_next;
765 }
766 kmem_free(list, sizeof (*list));
767 }
768
769 mutex_exit(&fctl_ulp_list_mutex);
770
771 rw_enter(&fctl_ulp_lock, RW_WRITER);
772
773 for (mod = fctl_ulp_modules, prev = NULL; mod != NULL;
774 mod = mod->mod_next) {
775 if (mod->mod_info == ulp_info) {
776 break;
777 }
778 prev = mod;
779 }
780
781 if (mod) {
782 fc_ulp_ports_t *next;
783
784 if (prev) {
785 prev->mod_next = mod->mod_next;
786 } else {
787 fctl_ulp_modules = mod->mod_next;
788 }
789
790 rw_enter(&fctl_mod_ports_lock, RW_WRITER);
791
792 while ((next = mod->mod_ports) != NULL) {
793 mod->mod_ports = next->port_next;
794 fctl_dealloc_ulp_port(next);
795 }
796
797 rw_exit(&fctl_mod_ports_lock);
798 rw_exit(&fctl_ulp_lock);
799
800 kmem_free(mod, sizeof (*mod));
801
802 return (FC_SUCCESS);
803 }
804 rw_exit(&fctl_ulp_lock);
805
806 return (FC_FAILURE);
807 }
808
809
810 /*
811 * The callers typically cache allocate the packet, complete the
812 * DMA setup for pkt_cmd and pkt_resp fields of the packet and
813 * call this function to see if the FCA is interested in doing
814 * its own intialization. For example, socal may like to initialize
815 * the soc_hdr which is pointed to by the pkt_fca_private field
816 * and sitting right below fc_packet_t in memory.
817 *
818 * The caller is required to ensure that pkt_pd is populated with the
819 * handle that it was given when the transport notified it about the
820 * device this packet is associated with. If there is no associated
821 * device, pkt_pd must be set to NULL. A non-NULL pkt_pd will cause an
822 * increment of the reference count for said pd. When the packet is freed,
823 * the reference count will be decremented. This reference count, in
824 * combination with the PD_GIVEN_TO_ULPS flag guarantees that the pd
825 * will not wink out of existence while there is a packet outstanding.
826 *
827 * This function and fca_init_pkt must not perform any operations that
828 * would result in a call back to the ULP, as the ULP may be required
829 * to hold a mutex across this call to ensure that the pd in question
830 * won't go away prior the call to fc_ulp_transport.
831 *
832 * ULPs are responsible for using the handles they are given during state
833 * change callback processing in a manner that ensures consistency. That
834 * is, they must be aware that they could be processing a state change
835 * notification that tells them the device associated with a particular
836 * handle has gone away at the same time they are being asked to
837 * initialize a packet using that handle. ULPs must therefore ensure
838 * that their state change processing and packet initialization code
839 * paths are sufficiently synchronized to avoid the use of an
840 * invalidated handle in any fc_packet_t struct that is passed to the
841 * fc_ulp_init_packet() function.
842 */
843 int
844 fc_ulp_init_packet(opaque_t port_handle, fc_packet_t *pkt, int sleep)
845 {
846 int rval;
847 fc_local_port_t *port = port_handle;
848 fc_remote_port_t *pd;
849
850 ASSERT(pkt != NULL);
851
852 pd = pkt->pkt_pd;
853
854 /* Call the FCA driver's fca_init_pkt entry point function. */
855 rval = port->fp_fca_tran->fca_init_pkt(port->fp_fca_handle, pkt, sleep);
856
857 if ((rval == FC_SUCCESS) && (pd != NULL)) {
858 /*
859 * A !NULL pd here must still be a valid
860 * reference to the fc_remote_port_t.
861 */
862 mutex_enter(&pd->pd_mutex);
863 ASSERT(pd->pd_ref_count >= 0);
864 pd->pd_ref_count++;
865 mutex_exit(&pd->pd_mutex);
866 }
867
868 return (rval);
869 }
870
871
872 /*
873 * This function is called before destroying the cache allocated
874 * fc_packet to free up (and uninitialize) any resource specially
875 * allocated by the FCA driver during tran_init_pkt().
876 *
877 * If the pkt_pd field in the given fc_packet_t struct is not NULL, then
878 * the pd_ref_count reference count is decremented for the indicated
879 * fc_remote_port_t struct.
880 */
881 int
882 fc_ulp_uninit_packet(opaque_t port_handle, fc_packet_t *pkt)
883 {
884 int rval;
885 fc_local_port_t *port = port_handle;
886 fc_remote_port_t *pd;
887
888 ASSERT(pkt != NULL);
889
890 pd = pkt->pkt_pd;
891
892 /* Call the FCA driver's fca_un_init_pkt entry point function */
893 rval = port->fp_fca_tran->fca_un_init_pkt(port->fp_fca_handle, pkt);
894
895 if ((rval == FC_SUCCESS) && (pd != NULL)) {
896 mutex_enter(&pd->pd_mutex);
897
898 ASSERT(pd->pd_ref_count > 0);
899 pd->pd_ref_count--;
900
901 /*
902 * If at this point the state of this fc_remote_port_t
903 * struct is PORT_DEVICE_INVALID, it probably means somebody
904 * is cleaning up old (e.g. retried) packets. If the
905 * pd_ref_count has also dropped to zero, it's time to
906 * deallocate this fc_remote_port_t struct.
907 */
908 if (pd->pd_state == PORT_DEVICE_INVALID &&
909 pd->pd_ref_count == 0) {
910 fc_remote_node_t *node = pd->pd_remote_nodep;
911
912 mutex_exit(&pd->pd_mutex);
913
914 /*
915 * Also deallocate the associated fc_remote_node_t
916 * struct if it has no other associated
917 * fc_remote_port_t structs.
918 */
919 if ((fctl_destroy_remote_port(port, pd) == 0) &&
920 (node != NULL)) {
921 fctl_destroy_remote_node(node);
922 }
923 return (rval);
924 }
925
926 mutex_exit(&pd->pd_mutex);
927 }
928
929 return (rval);
930 }
931
932
933 int
934 fc_ulp_getportmap(opaque_t port_handle, fc_portmap_t **map, uint32_t *len,
935 int flag)
936 {
937 int job_code;
938 fc_local_port_t *port;
939 job_request_t *job;
940 fc_portmap_t *tmp_map;
941 uint32_t tmp_len;
942 fc_portmap_t *change_list = NULL;
943 uint32_t listlen = 0;
944
945 port = port_handle;
946
947 mutex_enter(&port->fp_mutex);
948 if (port->fp_statec_busy) {
949 mutex_exit(&port->fp_mutex);
950 return (FC_STATEC_BUSY);
951 }
952
953 if (FC_PORT_STATE_MASK(port->fp_state) == FC_STATE_OFFLINE) {
954 mutex_exit(&port->fp_mutex);
955 return (FC_OFFLINE);
956 }
957
958 if (port->fp_dev_count && (port->fp_dev_count ==
959 port->fp_total_devices)) {
960 mutex_exit(&port->fp_mutex);
961 fctl_fillout_map(port, &change_list, &listlen, 1, 1, 0);
962 if (listlen > *len) {
963 tmp_map = (fc_portmap_t *)kmem_zalloc(
964 listlen * sizeof (fc_portmap_t), KM_NOSLEEP);
965 if (tmp_map == NULL) {
966 return (FC_NOMEM);
967 }
968 if (*map) {
969 kmem_free(*map, (*len) * sizeof (fc_portmap_t));
970 }
971 *map = tmp_map;
972 }
973 if (change_list) {
974 bcopy(change_list, *map,
975 listlen * sizeof (fc_portmap_t));
976 kmem_free(change_list, listlen * sizeof (fc_portmap_t));
977 }
978 *len = listlen;
979 } else {
980 mutex_exit(&port->fp_mutex);
981
982 switch (flag) {
983 case FC_ULP_PLOGI_DONTCARE:
984 job_code = JOB_PORT_GETMAP;
985 break;
986
987 case FC_ULP_PLOGI_PRESERVE:
988 job_code = JOB_PORT_GETMAP_PLOGI_ALL;
989 break;
990
991 default:
992 return (FC_INVALID_REQUEST);
993 }
994 /*
995 * Submit a job request to the job handler
996 * thread to get the map and wait
997 */
998 job = fctl_alloc_job(job_code, 0, NULL, NULL, KM_SLEEP);
999 job->job_private = (opaque_t)map;
1000 job->job_arg = (opaque_t)len;
1001 fctl_enque_job(port, job);
1002
1003 fctl_jobwait(job);
1004 /*
1005 * The result of the last I/O operation is
1006 * in job_code. We don't care to look at it
1007 * Rather we look at the number of devices
1008 * that are found to fill out the map for
1009 * ULPs.
1010 */
1011 fctl_dealloc_job(job);
1012 }
1013
1014 /*
1015 * If we're here, we're returning a map to the caller, which means
1016 * we'd better make sure every pd in that map has the
1017 * PD_GIVEN_TO_ULPS flag set.
1018 */
1019
1020 tmp_len = *len;
1021 tmp_map = *map;
1022
1023 while (tmp_len-- != 0) {
1024 if (tmp_map->map_state != PORT_DEVICE_INVALID) {
1025 fc_remote_port_t *pd =
1026 (fc_remote_port_t *)tmp_map->map_pd;
1027 mutex_enter(&pd->pd_mutex);
1028 pd->pd_aux_flags |= PD_GIVEN_TO_ULPS;
1029 mutex_exit(&pd->pd_mutex);
1030 }
1031 tmp_map++;
1032 }
1033
1034 return (FC_SUCCESS);
1035 }
1036
1037
1038 int
1039 fc_ulp_login(opaque_t port_handle, fc_packet_t **ulp_pkt, uint32_t listlen)
1040 {
1041 int rval = FC_SUCCESS;
1042 int job_flags;
1043 uint32_t count;
1044 fc_packet_t **tmp_array;
1045 job_request_t *job;
1046 fc_local_port_t *port = port_handle;
1047 fc_ulp_rscn_info_t *rscnp =
1048 (fc_ulp_rscn_info_t *)(ulp_pkt[0])->pkt_ulp_rscn_infop;
1049
1050 /*
1051 * If the port is OFFLINE, or if the port driver is
1052 * being SUSPENDED/PM_SUSPENDED/DETACHED, block all
1053 * PLOGI operations
1054 */
1055 mutex_enter(&port->fp_mutex);
1056 if (port->fp_statec_busy) {
1057 mutex_exit(&port->fp_mutex);
1058 return (FC_STATEC_BUSY);
1059 }
1060
1061 if ((FC_PORT_STATE_MASK(port->fp_state) == FC_STATE_OFFLINE) ||
1062 (port->fp_soft_state &
1063 (FP_SOFT_IN_DETACH | FP_SOFT_SUSPEND | FP_SOFT_POWER_DOWN))) {
1064 mutex_exit(&port->fp_mutex);
1065 return (FC_OFFLINE);
1066 }
1067
1068 /*
1069 * If the rscn count in the packet is not the same as the rscn count
1070 * in the fc_local_port_t, then one or more new RSCNs has occurred.
1071 */
1072 if ((rscnp != NULL) &&
1073 (rscnp->ulp_rscn_count != FC_INVALID_RSCN_COUNT) &&
1074 (rscnp->ulp_rscn_count != port->fp_rscn_count)) {
1075 mutex_exit(&port->fp_mutex);
1076 return (FC_DEVICE_BUSY_NEW_RSCN);
1077 }
1078
1079 mutex_exit(&port->fp_mutex);
1080
1081 tmp_array = kmem_zalloc(sizeof (*tmp_array) * listlen, KM_SLEEP);
1082 for (count = 0; count < listlen; count++) {
1083 tmp_array[count] = ulp_pkt[count];
1084 }
1085
1086 job_flags = ((ulp_pkt[0]->pkt_tran_flags) & FC_TRAN_NO_INTR)
1087 ? 0 : JOB_TYPE_FCTL_ASYNC;
1088
1089 #ifdef DEBUG
1090 {
1091 int next;
1092 int count;
1093 int polled;
1094
1095 polled = ((ulp_pkt[0]->pkt_tran_flags) &
1096 FC_TRAN_NO_INTR) ? 0 : JOB_TYPE_FCTL_ASYNC;
1097
1098 for (count = 0; count < listlen; count++) {
1099 next = ((ulp_pkt[count]->pkt_tran_flags)
1100 & FC_TRAN_NO_INTR) ? 0 : JOB_TYPE_FCTL_ASYNC;
1101 ASSERT(next == polled);
1102 }
1103 }
1104 #endif
1105
1106 job = fctl_alloc_job(JOB_PLOGI_GROUP, job_flags, NULL, NULL, KM_SLEEP);
1107 job->job_ulp_pkts = tmp_array;
1108 job->job_ulp_listlen = listlen;
1109
1110 while (listlen--) {
1111 fc_packet_t *pkt;
1112
1113 pkt = tmp_array[listlen];
1114 if (pkt->pkt_pd == NULL) {
1115 pkt->pkt_state = FC_PKT_SUCCESS;
1116 continue;
1117 }
1118
1119 mutex_enter(&pkt->pkt_pd->pd_mutex);
1120 if (pkt->pkt_pd->pd_flags == PD_ELS_IN_PROGRESS ||
1121 pkt->pkt_pd->pd_flags == PD_ELS_MARK) {
1122 /*
1123 * Set the packet state and let the port
1124 * driver call the completion routine
1125 * from its thread
1126 */
1127 mutex_exit(&pkt->pkt_pd->pd_mutex);
1128 pkt->pkt_state = FC_PKT_ELS_IN_PROGRESS;
1129 continue;
1130 }
1131
1132 if (pkt->pkt_pd->pd_state == PORT_DEVICE_INVALID ||
1133 pkt->pkt_pd->pd_type == PORT_DEVICE_OLD) {
1134 mutex_exit(&pkt->pkt_pd->pd_mutex);
1135 pkt->pkt_state = FC_PKT_LOCAL_RJT;
1136 continue;
1137 }
1138 mutex_exit(&pkt->pkt_pd->pd_mutex);
1139 pkt->pkt_state = FC_PKT_SUCCESS;
1140 }
1141
1142 fctl_enque_job(port, job);
1143
1144 if (!(job_flags & JOB_TYPE_FCTL_ASYNC)) {
1145 fctl_jobwait(job);
1146 rval = job->job_result;
1147 fctl_dealloc_job(job);
1148 }
1149
1150 return (rval);
1151 }
1152
1153
1154 opaque_t
1155 fc_ulp_get_remote_port(opaque_t port_handle, la_wwn_t *pwwn, int *error,
1156 int create)
1157 {
1158 fc_local_port_t *port;
1159 job_request_t *job;
1160 fc_remote_port_t *pd;
1161
1162 port = port_handle;
1163 pd = fctl_get_remote_port_by_pwwn(port, pwwn);
1164
1165 if (pd != NULL) {
1166 *error = FC_SUCCESS;
1167 /*
1168 * A ULP now knows about this pd, so mark it
1169 */
1170 mutex_enter(&pd->pd_mutex);
1171 pd->pd_aux_flags |= PD_GIVEN_TO_ULPS;
1172 mutex_exit(&pd->pd_mutex);
1173 return (pd);
1174 }
1175
1176 mutex_enter(&port->fp_mutex);
1177 if (FC_IS_TOP_SWITCH(port->fp_topology) && create) {
1178 uint32_t d_id;
1179 fctl_ns_req_t *ns_cmd;
1180
1181 mutex_exit(&port->fp_mutex);
1182
1183 job = fctl_alloc_job(JOB_NS_CMD, 0, NULL, NULL, KM_SLEEP);
1184
1185 if (job == NULL) {
1186 *error = FC_NOMEM;
1187 return (pd);
1188 }
1189
1190 ns_cmd = fctl_alloc_ns_cmd(sizeof (ns_req_gid_pn_t),
1191 sizeof (ns_resp_gid_pn_t), sizeof (ns_resp_gid_pn_t),
1192 0, KM_SLEEP);
1193
1194 if (ns_cmd == NULL) {
1195 fctl_dealloc_job(job);
1196 *error = FC_NOMEM;
1197 return (pd);
1198 }
1199 ns_cmd->ns_cmd_code = NS_GID_PN;
1200 ((ns_req_gid_pn_t *)(ns_cmd->ns_cmd_buf))->pwwn = *pwwn;
1201
1202 job->job_result = FC_SUCCESS;
1203 job->job_private = (void *)ns_cmd;
1204 job->job_counter = 1;
1205 fctl_enque_job(port, job);
1206 fctl_jobwait(job);
1207
1208 if (job->job_result != FC_SUCCESS) {
1209 *error = job->job_result;
1210 fctl_free_ns_cmd(ns_cmd);
1211 fctl_dealloc_job(job);
1212 return (pd);
1213 }
1214 d_id = ((ns_resp_gid_pn_t *)ns_cmd->ns_data_buf)->pid.port_id;
1215 fctl_free_ns_cmd(ns_cmd);
1216
1217 ns_cmd = fctl_alloc_ns_cmd(sizeof (ns_req_gan_t),
1218 sizeof (ns_resp_gan_t), 0, FCTL_NS_CREATE_DEVICE,
1219 KM_SLEEP);
1220 ASSERT(ns_cmd != NULL);
1221
1222 ns_cmd->ns_gan_max = 1;
1223 ns_cmd->ns_cmd_code = NS_GA_NXT;
1224 ns_cmd->ns_gan_sid = FCTL_GAN_START_ID;
1225 ((ns_req_gan_t *)(ns_cmd->ns_cmd_buf))->pid.port_id = d_id - 1;
1226 ((ns_req_gan_t *)(ns_cmd->ns_cmd_buf))->pid.priv_lilp_posit = 0;
1227
1228 job->job_result = FC_SUCCESS;
1229 job->job_private = (void *)ns_cmd;
1230 job->job_counter = 1;
1231 fctl_enque_job(port, job);
1232 fctl_jobwait(job);
1233
1234 fctl_free_ns_cmd(ns_cmd);
1235 if (job->job_result != FC_SUCCESS) {
1236 *error = job->job_result;
1237 fctl_dealloc_job(job);
1238 return (pd);
1239 }
1240 fctl_dealloc_job(job);
1241
1242 /*
1243 * Check if the port device is created now.
1244 */
1245 pd = fctl_get_remote_port_by_pwwn(port, pwwn);
1246
1247 if (pd == NULL) {
1248 *error = FC_FAILURE;
1249 } else {
1250 *error = FC_SUCCESS;
1251
1252 /*
1253 * A ULP now knows about this pd, so mark it
1254 */
1255 mutex_enter(&pd->pd_mutex);
1256 pd->pd_aux_flags |= PD_GIVEN_TO_ULPS;
1257 mutex_exit(&pd->pd_mutex);
1258 }
1259 } else {
1260 mutex_exit(&port->fp_mutex);
1261 *error = FC_FAILURE;
1262 }
1263
1264 return (pd);
1265 }
1266
1267
1268 /*
1269 * If a NS object exists in the host and query is performed
1270 * on that object, we should retrieve it from our basket
1271 * and return it right here, there by saving a request going
1272 * all the up to the Name Server.
1273 */
1274 int
1275 fc_ulp_port_ns(opaque_t port_handle, opaque_t pd, fc_ns_cmd_t *ns_req)
1276 {
1277 int rval;
1278 int fabric;
1279 job_request_t *job;
1280 fctl_ns_req_t *ns_cmd;
1281 fc_local_port_t *port = port_handle;
1282
1283 mutex_enter(&port->fp_mutex);
1284 fabric = FC_IS_TOP_SWITCH(port->fp_topology) ? 1 : 0;
1285 mutex_exit(&port->fp_mutex);
1286
1287 /*
1288 * Name server query can't be performed for devices not in Fabric
1289 */
1290 if (!fabric && pd) {
1291 return (FC_BADOBJECT);
1292 }
1293
1294 if (FC_IS_CMD_A_REG(ns_req->ns_cmd)) {
1295 if (pd == NULL) {
1296 rval = fctl_update_host_ns_values(port, ns_req);
1297 if (rval != FC_SUCCESS) {
1298 return (rval);
1299 }
1300 } else {
1301 /*
1302 * Guess what, FC-GS-2 currently prohibits (not
1303 * in the strongest language though) setting of
1304 * NS object values by other ports. But we might
1305 * get that changed to at least accommodate setting
1306 * symbolic node/port names - But if disks/tapes
1307 * were going to provide a method to set these
1308 * values directly (which in turn might register
1309 * with the NS when they come up; yep, for that
1310 * to happen the disks will have to be very well
1311 * behaved Fabric citizen) we won't need to
1312 * register the symbolic port/node names for
1313 * other ports too (rather send down SCSI commands
1314 * to the devices to set the names)
1315 *
1316 * Be that as it may, let's continue to fail
1317 * registration requests for other ports. period.
1318 */
1319 return (FC_BADOBJECT);
1320 }
1321
1322 if (!fabric) {
1323 return (FC_SUCCESS);
1324 }
1325 } else if (!fabric) {
1326 return (fctl_retrieve_host_ns_values(port, ns_req));
1327 }
1328
1329 job = fctl_alloc_job(JOB_NS_CMD, 0, NULL, NULL, KM_SLEEP);
1330 ASSERT(job != NULL);
1331
1332 ns_cmd = fctl_alloc_ns_cmd(ns_req->ns_req_len,
1333 ns_req->ns_resp_len, ns_req->ns_resp_len, 0, KM_SLEEP);
1334 ASSERT(ns_cmd != NULL);
1335 ns_cmd->ns_cmd_code = ns_req->ns_cmd;
1336 bcopy(ns_req->ns_req_payload, ns_cmd->ns_cmd_buf,
1337 ns_req->ns_req_len);
1338
1339 job->job_private = (void *)ns_cmd;
1340 fctl_enque_job(port, job);
1341 fctl_jobwait(job);
1342 rval = job->job_result;
1343
1344 if (ns_req->ns_resp_len >= ns_cmd->ns_data_len) {
1345 bcopy(ns_cmd->ns_data_buf, ns_req->ns_resp_payload,
1346 ns_cmd->ns_data_len);
1347 }
1348 bcopy(&ns_cmd->ns_resp_hdr, &ns_req->ns_resp_hdr,
1349 sizeof (fc_ct_header_t));
1350
1351 fctl_free_ns_cmd(ns_cmd);
1352 fctl_dealloc_job(job);
1353
1354 return (rval);
1355 }
1356
1357
1358 int
1359 fc_ulp_transport(opaque_t port_handle, fc_packet_t *pkt)
1360 {
1361 int rval;
1362 fc_local_port_t *port;
1363 fc_remote_port_t *pd, *newpd;
1364 fc_ulp_rscn_info_t *rscnp =
1365 (fc_ulp_rscn_info_t *)pkt->pkt_ulp_rscn_infop;
1366
1367 port = port_handle;
1368
1369 if (pkt->pkt_tran_flags & FC_TRAN_DUMPING) {
1370 return (port->fp_fca_tran->fca_transport(
1371 port->fp_fca_handle, pkt));
1372 }
1373
1374 mutex_enter(&port->fp_mutex);
1375 if (port->fp_statec_busy) {
1376 mutex_exit(&port->fp_mutex);
1377 return (FC_STATEC_BUSY);
1378 }
1379
1380 /* A locus of race conditions */
1381 if (((FC_PORT_STATE_MASK(port->fp_state)) == FC_STATE_OFFLINE) ||
1382 (port->fp_soft_state &
1383 (FP_SOFT_IN_DETACH | FP_SOFT_SUSPEND | FP_SOFT_POWER_DOWN))) {
1384 mutex_exit(&port->fp_mutex);
1385 return (FC_OFFLINE);
1386 }
1387
1388 /*
1389 * If the rscn count in the packet is not the same as the rscn count
1390 * in the fc_local_port_t, then one or more new RSCNs has occurred.
1391 */
1392 if ((rscnp != NULL) &&
1393 (rscnp->ulp_rscn_count != FC_INVALID_RSCN_COUNT) &&
1394 (rscnp->ulp_rscn_count != port->fp_rscn_count)) {
1395 mutex_exit(&port->fp_mutex);
1396 return (FC_DEVICE_BUSY_NEW_RSCN);
1397 }
1398
1399 pd = pkt->pkt_pd;
1400 if (pd) {
1401 if (pd->pd_type == PORT_DEVICE_OLD ||
1402 pd->pd_state == PORT_DEVICE_INVALID) {
1403
1404 newpd = fctl_get_remote_port_by_pwwn_mutex_held(port,
1405 &pd->pd_port_name);
1406
1407 /*
1408 * The remote port (pd) in the packet is no longer
1409 * usable, as the old pd still exists we can use the
1410 * WWN to check if we have a current pd for the device
1411 * we want. Either way we continue with the old logic
1412 * whether we have a new pd or not, as the new pd
1413 * could be bad, or have become unusable.
1414 */
1415 if ((newpd) && (newpd != pd)) {
1416
1417 /*
1418 * There is a better remote port (pd) to try,
1419 * so we need to fix the reference counts, etc.
1420 */
1421 mutex_enter(&newpd->pd_mutex);
1422 newpd->pd_ref_count++;
1423 pkt->pkt_pd = newpd;
1424 mutex_exit(&newpd->pd_mutex);
1425
1426 mutex_enter(&pd->pd_mutex);
1427 pd->pd_ref_count--;
1428 if ((pd->pd_state == PORT_DEVICE_INVALID) &&
1429 (pd->pd_ref_count == 0)) {
1430 fc_remote_node_t *node =
1431 pd->pd_remote_nodep;
1432
1433 mutex_exit(&pd->pd_mutex);
1434 mutex_exit(&port->fp_mutex);
1435
1436 /*
1437 * This will create another PD hole
1438 * where we have a reference to a pd,
1439 * but someone else could remove it.
1440 */
1441 if ((fctl_destroy_remote_port(port, pd)
1442 == 0) && (node != NULL)) {
1443 fctl_destroy_remote_node(node);
1444 }
1445 mutex_enter(&port->fp_mutex);
1446 } else {
1447 mutex_exit(&pd->pd_mutex);
1448 }
1449 pd = newpd;
1450 }
1451 }
1452
1453 if (pd->pd_state != PORT_DEVICE_LOGGED_IN) {
1454 rval = (pd->pd_state == PORT_DEVICE_VALID) ?
1455 FC_LOGINREQ : FC_BADDEV;
1456 mutex_exit(&port->fp_mutex);
1457 return (rval);
1458 }
1459
1460 if (pd->pd_flags != PD_IDLE) {
1461 mutex_exit(&port->fp_mutex);
1462 return (FC_DEVICE_BUSY);
1463 }
1464
1465 if (pd->pd_type == PORT_DEVICE_OLD ||
1466 pd->pd_state == PORT_DEVICE_INVALID) {
1467 mutex_exit(&port->fp_mutex);
1468 return (FC_BADDEV);
1469 }
1470
1471 } else if (FC_IS_REAL_DEVICE(pkt->pkt_cmd_fhdr.d_id)) {
1472 mutex_exit(&port->fp_mutex);
1473 return (FC_BADPACKET);
1474 }
1475 mutex_exit(&port->fp_mutex);
1476
1477 return (port->fp_fca_tran->fca_transport(port->fp_fca_handle, pkt));
1478 }
1479
1480
1481 int
1482 fc_ulp_issue_els(opaque_t port_handle, fc_packet_t *pkt)
1483 {
1484 int rval;
1485 fc_local_port_t *port = port_handle;
1486 fc_remote_port_t *pd;
1487 fc_ulp_rscn_info_t *rscnp =
1488 (fc_ulp_rscn_info_t *)pkt->pkt_ulp_rscn_infop;
1489
1490 /*
1491 * If the port is OFFLINE, or if the port driver is
1492 * being SUSPENDED/PM_SUSPENDED/DETACHED, block all
1493 * ELS operations
1494 */
1495 mutex_enter(&port->fp_mutex);
1496 if ((FC_PORT_STATE_MASK(port->fp_state) == FC_STATE_OFFLINE) ||
1497 (port->fp_soft_state &
1498 (FP_SOFT_IN_DETACH | FP_SOFT_SUSPEND | FP_SOFT_POWER_DOWN))) {
1499 mutex_exit(&port->fp_mutex);
1500 return (FC_OFFLINE);
1501 }
1502
1503 if (port->fp_statec_busy) {
1504 mutex_exit(&port->fp_mutex);
1505 return (FC_STATEC_BUSY);
1506 }
1507
1508 /*
1509 * If the rscn count in the packet is not the same as the rscn count
1510 * in the fc_local_port_t, then one or more new RSCNs has occurred.
1511 */
1512 if ((rscnp != NULL) &&
1513 (rscnp->ulp_rscn_count != FC_INVALID_RSCN_COUNT) &&
1514 (rscnp->ulp_rscn_count != port->fp_rscn_count)) {
1515 mutex_exit(&port->fp_mutex);
1516 return (FC_DEVICE_BUSY_NEW_RSCN);
1517 }
1518
1519 mutex_exit(&port->fp_mutex);
1520
1521 if ((pd = pkt->pkt_pd) != NULL) {
1522 mutex_enter(&pd->pd_mutex);
1523 if (pd->pd_state != PORT_DEVICE_LOGGED_IN) {
1524 rval = (pd->pd_state == PORT_DEVICE_VALID) ?
1525 FC_LOGINREQ : FC_BADDEV;
1526 mutex_exit(&pd->pd_mutex);
1527 return (rval);
1528 }
1529
1530 if (pd->pd_flags != PD_IDLE) {
1531 mutex_exit(&pd->pd_mutex);
1532 return (FC_DEVICE_BUSY);
1533 }
1534 if (pd->pd_type == PORT_DEVICE_OLD ||
1535 pd->pd_state == PORT_DEVICE_INVALID) {
1536 mutex_exit(&pd->pd_mutex);
1537 return (FC_BADDEV);
1538 }
1539 mutex_exit(&pd->pd_mutex);
1540 }
1541
1542 return (port->fp_fca_tran->fca_els_send(port->fp_fca_handle, pkt));
1543 }
1544
1545
1546 int
1547 fc_ulp_uballoc(opaque_t port_handle, uint32_t *count, uint32_t size,
1548 uint32_t type, uint64_t *tokens)
1549 {
1550 fc_local_port_t *port = port_handle;
1551
1552 return (port->fp_fca_tran->fca_ub_alloc(port->fp_fca_handle,
1553 tokens, size, count, type));
1554 }
1555
1556
1557 int
1558 fc_ulp_ubfree(opaque_t port_handle, uint32_t count, uint64_t *tokens)
1559 {
1560 fc_local_port_t *port = port_handle;
1561
1562 return (port->fp_fca_tran->fca_ub_free(port->fp_fca_handle,
1563 count, tokens));
1564 }
1565
1566
1567 int
1568 fc_ulp_ubrelease(opaque_t port_handle, uint32_t count, uint64_t *tokens)
1569 {
1570 fc_local_port_t *port = port_handle;
1571
1572 return (port->fp_fca_tran->fca_ub_release(port->fp_fca_handle,
1573 count, tokens));
1574 }
1575
1576
1577 int
1578 fc_ulp_abort(opaque_t port_handle, fc_packet_t *pkt, int flags)
1579 {
1580 fc_local_port_t *port = port_handle;
1581
1582 return (port->fp_fca_tran->fca_abort(port->fp_fca_handle, pkt, flags));
1583 }
1584
1585
1586 /*
1587 * Submit an asynchronous request to the job handler if the sleep
1588 * flag is set to KM_NOSLEEP, as such calls could have been made
1589 * in interrupt contexts, and the goal is to avoid busy waiting,
1590 * blocking on a conditional variable, a semaphore or any of the
1591 * synchronization primitives. A noticeable draw back with this
1592 * asynchronous request is that an FC_SUCCESS is returned long
1593 * before the reset is complete (successful or not).
1594 */
1595 int
1596 fc_ulp_linkreset(opaque_t port_handle, la_wwn_t *pwwn, int sleep)
1597 {
1598 int rval;
1599 fc_local_port_t *port;
1600 job_request_t *job;
1601
1602 port = port_handle;
1603 /*
1604 * Many a times, this function is called from interrupt
1605 * contexts and there have been several dead locks and
1606 * hangs - One of the simplest work arounds is to fib
1607 * if a RESET is in progress.
1608 */
1609 mutex_enter(&port->fp_mutex);
1610 if (port->fp_soft_state & FP_SOFT_IN_LINK_RESET) {
1611 mutex_exit(&port->fp_mutex);
1612 return (FC_SUCCESS);
1613 }
1614
1615 /*
1616 * Ward off this reset if a state change is in progress.
1617 */
1618 if (port->fp_statec_busy) {
1619 mutex_exit(&port->fp_mutex);
1620 return (FC_STATEC_BUSY);
1621 }
1622 port->fp_soft_state |= FP_SOFT_IN_LINK_RESET;
1623 mutex_exit(&port->fp_mutex);
1624
1625 if (fctl_busy_port(port) != 0) {
1626 mutex_enter(&port->fp_mutex);
1627 port->fp_soft_state &= ~FP_SOFT_IN_LINK_RESET;
1628 mutex_exit(&port->fp_mutex);
1629 return (FC_FAILURE);
1630 }
1631
1632 if (sleep == KM_SLEEP) {
1633 job = fctl_alloc_job(JOB_LINK_RESET, 0, NULL, NULL, sleep);
1634 ASSERT(job != NULL);
1635
1636 job->job_private = (void *)pwwn;
1637 job->job_counter = 1;
1638 fctl_enque_job(port, job);
1639 fctl_jobwait(job);
1640
1641 mutex_enter(&port->fp_mutex);
1642 port->fp_soft_state &= ~FP_SOFT_IN_LINK_RESET;
1643 mutex_exit(&port->fp_mutex);
1644
1645 fctl_idle_port(port);
1646
1647 rval = job->job_result;
1648 fctl_dealloc_job(job);
1649 } else {
1650 job = fctl_alloc_job(JOB_LINK_RESET, JOB_TYPE_FCTL_ASYNC,
1651 fctl_link_reset_done, port, sleep);
1652 if (job == NULL) {
1653 mutex_enter(&port->fp_mutex);
1654 port->fp_soft_state &= ~FP_SOFT_IN_LINK_RESET;
1655 mutex_exit(&port->fp_mutex);
1656 fctl_idle_port(port);
1657 return (FC_NOMEM);
1658 }
1659 job->job_private = (void *)pwwn;
1660 job->job_counter = 1;
1661 fctl_priority_enque_job(port, job);
1662 rval = FC_SUCCESS;
1663 }
1664
1665 return (rval);
1666 }
1667
1668
1669 int
1670 fc_ulp_port_reset(opaque_t port_handle, uint32_t cmd)
1671 {
1672 int rval = FC_SUCCESS;
1673 fc_local_port_t *port = port_handle;
1674
1675 switch (cmd) {
1676 case FC_RESET_PORT:
1677 rval = port->fp_fca_tran->fca_reset(
1678 port->fp_fca_handle, FC_FCA_LINK_RESET);
1679 break;
1680
1681 case FC_RESET_ADAPTER:
1682 rval = port->fp_fca_tran->fca_reset(
1683 port->fp_fca_handle, FC_FCA_RESET);
1684 break;
1685
1686 case FC_RESET_DUMP:
1687 rval = port->fp_fca_tran->fca_reset(
1688 port->fp_fca_handle, FC_FCA_CORE);
1689 break;
1690
1691 case FC_RESET_CRASH:
1692 rval = port->fp_fca_tran->fca_reset(
1693 port->fp_fca_handle, FC_FCA_RESET_CORE);
1694 break;
1695
1696 default:
1697 rval = FC_FAILURE;
1698 }
1699
1700 return (rval);
1701 }
1702
1703
1704 int
1705 fc_ulp_get_port_login_params(opaque_t port_handle, la_els_logi_t *login_params)
1706 {
1707 fc_local_port_t *port = port_handle;
1708
1709 /* Copy the login parameters */
1710 *login_params = port->fp_service_params;
1711 return (FC_SUCCESS);
1712 }
1713
1714
1715 int
1716 fc_ulp_get_port_instance(opaque_t port_handle)
1717 {
1718 fc_local_port_t *port = port_handle;
1719
1720 return (port->fp_instance);
1721 }
1722
1723
1724 opaque_t
1725 fc_ulp_get_port_handle(int port_instance)
1726 {
1727 opaque_t port_handle = NULL;
1728 fc_fca_port_t *cur;
1729
1730 mutex_enter(&fctl_port_lock);
1731 for (cur = fctl_fca_portlist; cur; cur = cur->port_next) {
1732 if (cur->port_handle->fp_instance == port_instance) {
1733 port_handle = (opaque_t)cur->port_handle;
1734 break;
1735 }
1736 }
1737 mutex_exit(&fctl_port_lock);
1738
1739 return (port_handle);
1740 }
1741
1742
1743 int
1744 fc_ulp_error(int fc_errno, char **errmsg)
1745 {
1746 return (fctl_error(fc_errno, errmsg));
1747 }
1748
1749
1750 int
1751 fc_ulp_pkt_error(fc_packet_t *pkt, char **state, char **reason,
1752 char **action, char **expln)
1753 {
1754 return (fctl_pkt_error(pkt, state, reason, action, expln));
1755 }
1756
1757
1758 /*
1759 * If an ULP by the specified name exists, return FC_SUCCESS, else FC_FAILURE
1760 */
1761 int
1762 fc_ulp_is_name_present(caddr_t ulp_name)
1763 {
1764 int rval = FC_FAILURE;
1765 fc_ulp_list_t *list;
1766
1767 mutex_enter(&fctl_ulp_list_mutex);
1768 for (list = fctl_ulp_list; list != NULL; list = list->ulp_next) {
1769 if (strcmp(list->ulp_info->ulp_name, ulp_name) == 0) {
1770 rval = FC_SUCCESS;
1771 break;
1772 }
1773 }
1774 mutex_exit(&fctl_ulp_list_mutex);
1775
1776 return (rval);
1777 }
1778
1779
1780 /*
1781 * Return port WWN for a port Identifier
1782 */
1783 int
1784 fc_ulp_get_pwwn_by_did(opaque_t port_handle, fc_portid_t d_id, la_wwn_t *pwwn)
1785 {
1786 int rval = FC_FAILURE;
1787 fc_remote_port_t *pd;
1788 fc_local_port_t *port = port_handle;
1789
1790 pd = fctl_get_remote_port_by_did(port, d_id.port_id);
1791 if (pd != NULL) {
1792 mutex_enter(&pd->pd_mutex);
1793 *pwwn = pd->pd_port_name;
1794 mutex_exit(&pd->pd_mutex);
1795 rval = FC_SUCCESS;
1796 }
1797
1798 return (rval);
1799 }
1800
1801
1802 /*
1803 * Return a port map for a port WWN
1804 */
1805 int
1806 fc_ulp_pwwn_to_portmap(opaque_t port_handle, la_wwn_t *bytes, fc_portmap_t *map)
1807 {
1808 fc_local_port_t *port = port_handle;
1809 fc_remote_node_t *node;
1810 fc_remote_port_t *pd;
1811
1812 pd = fctl_get_remote_port_by_pwwn(port, bytes);
1813 if (pd == NULL) {
1814 return (FC_FAILURE);
1815 }
1816
1817 mutex_enter(&pd->pd_mutex);
1818 map->map_pwwn = pd->pd_port_name;
1819 map->map_did = pd->pd_port_id;
1820 map->map_hard_addr = pd->pd_hard_addr;
1821 map->map_state = pd->pd_state;
1822 map->map_type = pd->pd_type;
1823 map->map_flags = 0;
1824
1825 ASSERT(map->map_type <= PORT_DEVICE_DELETE);
1826
1827 bcopy(pd->pd_fc4types, map->map_fc4_types, sizeof (pd->pd_fc4types));
1828
1829 node = pd->pd_remote_nodep;
1830 mutex_exit(&pd->pd_mutex);
1831
1832 if (node) {
1833 mutex_enter(&node->fd_mutex);
1834 map->map_nwwn = node->fd_node_name;
1835 mutex_exit(&node->fd_mutex);
1836 }
1837 map->map_pd = pd;
1838
1839 return (FC_SUCCESS);
1840 }
1841
1842
1843 opaque_t
1844 fc_ulp_get_fca_device(opaque_t port_handle, fc_portid_t d_id)
1845 {
1846 fc_local_port_t *port = port_handle;
1847
1848 if (port->fp_fca_tran->fca_get_device == NULL) {
1849 return (NULL);
1850 }
1851
1852 return (port->fp_fca_tran->fca_get_device(port->fp_fca_handle, d_id));
1853 }
1854
1855
1856 int
1857 fc_ulp_port_notify(opaque_t port_handle, uint32_t cmd)
1858 {
1859 int rval = FC_SUCCESS;
1860 fc_local_port_t *port = port_handle;
1861
1862 if (port->fp_fca_tran->fca_notify) {
1863 mutex_enter(&port->fp_mutex);
1864 switch (cmd) {
1865 case FC_NOTIFY_TARGET_MODE:
1866 port->fp_options |= FP_TARGET_MODE;
1867 break;
1868 case FC_NOTIFY_NO_TARGET_MODE:
1869 port->fp_options &= ~FP_TARGET_MODE;
1870 break;
1871 }
1872 mutex_exit(&port->fp_mutex);
1873 rval = port->fp_fca_tran->fca_notify(port->fp_fca_handle, cmd);
1874 }
1875
1876 return (rval);
1877 }
1878
1879
1880 void
1881 fc_ulp_disable_relogin(opaque_t *fc_port, la_wwn_t *pwwn)
1882 {
1883 fc_remote_port_t *pd =
1884 fctl_get_remote_port_by_pwwn((fc_local_port_t *)fc_port, pwwn);
1885
1886 if (pd) {
1887 mutex_enter(&pd->pd_mutex);
1888 pd->pd_aux_flags |= PD_DISABLE_RELOGIN;
1889 mutex_exit(&pd->pd_mutex);
1890 }
1891 }
1892
1893
1894 void
1895 fc_ulp_enable_relogin(opaque_t *fc_port, la_wwn_t *pwwn)
1896 {
1897 fc_remote_port_t *pd =
1898 fctl_get_remote_port_by_pwwn((fc_local_port_t *)fc_port, pwwn);
1899
1900 if (pd) {
1901 mutex_enter(&pd->pd_mutex);
1902 pd->pd_aux_flags &= ~PD_DISABLE_RELOGIN;
1903 mutex_exit(&pd->pd_mutex);
1904 }
1905 }
1906
1907
1908 /*
1909 * fc_fca_init
1910 * Overload the FCA bus_ops vector in its dev_ops with
1911 * fctl_fca_busops to handle all the INITchilds for "sf"
1912 * in one common place.
1913 *
1914 * Should be called from FCA _init routine.
1915 */
1916 void
1917 fc_fca_init(struct dev_ops *fca_devops_p)
1918 {
1919 #ifndef __lock_lint
1920 fca_devops_p->devo_bus_ops = &fctl_fca_busops;
1921 #endif /* __lock_lint */
1922 }
1923
1924
1925 /*
1926 * fc_fca_attach
1927 */
1928 int
1929 fc_fca_attach(dev_info_t *fca_dip, fc_fca_tran_t *tran)
1930 {
1931 /*
1932 * When we are in a position to offer downward compatibility
1933 * we should change the following check to allow lower revision
1934 * of FCAs; But we aren't there right now.
1935 */
1936 if (tran->fca_version != FCTL_FCA_MODREV_5) {
1937 const char *name = ddi_driver_name(fca_dip);
1938
1939 ASSERT(name != NULL);
1940
1941 cmn_err(CE_WARN, "fctl: FCA %s version mismatch"
1942 " please upgrade %s", name, name);
1943 return (DDI_FAILURE);
1944 }
1945
1946 ddi_set_driver_private(fca_dip, (caddr_t)tran);
1947 return (DDI_SUCCESS);
1948 }
1949
1950
1951 /*
1952 * fc_fca_detach
1953 */
1954 int
1955 fc_fca_detach(dev_info_t *fca_dip)
1956 {
1957 ddi_set_driver_private(fca_dip, NULL);
1958 return (DDI_SUCCESS);
1959 }
1960
1961
1962 /*
1963 * Check if the frame is a Link response Frame; Handle all cases (P_RJT,
1964 * F_RJT, P_BSY, F_BSY fall into this category). Check also for some Basic
1965 * Link Service responses such as BA_RJT and Extended Link Service response
1966 * such as LS_RJT. If the response is a Link_Data Frame or something that
1967 * this function doesn't understand return FC_FAILURE; Otherwise, fill out
1968 * various fields (state, action, reason, expln) from the response gotten
1969 * in the packet and return FC_SUCCESS.
1970 */
1971 int
1972 fc_fca_update_errors(fc_packet_t *pkt)
1973 {
1974 int ret = FC_SUCCESS;
1975
1976 switch (pkt->pkt_resp_fhdr.r_ctl) {
1977 case R_CTL_P_RJT: {
1978 uint32_t prjt;
1979
1980 prjt = pkt->pkt_resp_fhdr.ro;
1981 pkt->pkt_state = FC_PKT_NPORT_RJT;
1982 pkt->pkt_action = (prjt & 0xFF000000) >> 24;
1983 pkt->pkt_reason = (prjt & 0xFF0000) >> 16;
1984 break;
1985 }
1986
1987 case R_CTL_F_RJT: {
1988 uint32_t frjt;
1989
1990 frjt = pkt->pkt_resp_fhdr.ro;
1991 pkt->pkt_state = FC_PKT_FABRIC_RJT;
1992 pkt->pkt_action = (frjt & 0xFF000000) >> 24;
1993 pkt->pkt_reason = (frjt & 0xFF0000) >> 16;
1994 break;
1995 }
1996
1997 case R_CTL_P_BSY: {
1998 uint32_t pbsy;
1999
2000 pbsy = pkt->pkt_resp_fhdr.ro;
2001 pkt->pkt_state = FC_PKT_NPORT_BSY;
2002 pkt->pkt_action = (pbsy & 0xFF000000) >> 24;
2003 pkt->pkt_reason = (pbsy & 0xFF0000) >> 16;
2004 break;
2005 }
2006
2007 case R_CTL_F_BSY_LC:
2008 case R_CTL_F_BSY_DF: {
2009 uchar_t fbsy;
2010
2011 fbsy = pkt->pkt_resp_fhdr.type;
2012 pkt->pkt_state = FC_PKT_FABRIC_BSY;
2013 pkt->pkt_reason = (fbsy & 0xF0) >> 4;
2014 break;
2015 }
2016
2017 case R_CTL_LS_BA_RJT: {
2018 uint32_t brjt;
2019
2020 brjt = *(uint32_t *)pkt->pkt_resp;
2021 pkt->pkt_state = FC_PKT_BA_RJT;
2022 pkt->pkt_reason = (brjt & 0xFF0000) >> 16;
2023 pkt->pkt_expln = (brjt & 0xFF00) >> 8;
2024 break;
2025 }
2026
2027 case R_CTL_ELS_RSP: {
2028 la_els_rjt_t *lsrjt;
2029
2030 lsrjt = (la_els_rjt_t *)pkt->pkt_resp;
2031 if (lsrjt->ls_code.ls_code == LA_ELS_RJT) {
2032 pkt->pkt_state = FC_PKT_LS_RJT;
2033 pkt->pkt_reason = lsrjt->reason;
2034 pkt->pkt_action = lsrjt->action;
2035 break;
2036 }
2037 /* FALLTHROUGH */
2038 }
2039
2040 default:
2041 ret = FC_FAILURE;
2042 break;
2043 }
2044
2045 return (ret);
2046 }
2047
2048
2049 int
2050 fc_fca_error(int fc_errno, char **errmsg)
2051 {
2052 return (fctl_error(fc_errno, errmsg));
2053 }
2054
2055
2056 int
2057 fc_fca_pkt_error(fc_packet_t *pkt, char **state, char **reason,
2058 char **action, char **expln)
2059 {
2060 return (fctl_pkt_error(pkt, state, reason, action, expln));
2061 }
2062
2063
2064 /*
2065 * WWN to string goodie. Unpredictable results will happen
2066 * if enough memory isn't supplied in str argument. If you
2067 * are wondering how much does this routine need, it is just
2068 * (2 * WWN size + 1). So for a WWN size of 8 bytes the str
2069 * argument should have atleast 17 bytes allocated.
2070 */
2071 void
2072 fc_wwn_to_str(la_wwn_t *wwn, caddr_t str)
2073 {
2074 int count;
2075
2076 for (count = 0; count < FCTL_WWN_SIZE(wwn); count++, str += 2) {
2077 (void) sprintf(str, "%02x", wwn->raw_wwn[count]);
2078 }
2079 *str = '\0';
2080 }
2081
2082 #define FC_ATOB(x) (((x) >= '0' && (x) <= '9') ? ((x) - '0') : \
2083 ((x) >= 'a' && (x) <= 'f') ? \
2084 ((x) - 'a' + 10) : ((x) - 'A' + 10))
2085
2086 void
2087 fc_str_to_wwn(caddr_t str, la_wwn_t *wwn)
2088 {
2089 int count = 0;
2090 uchar_t byte;
2091
2092 while (*str) {
2093 byte = FC_ATOB(*str);
2094 str++;
2095 byte = byte << 4 | FC_ATOB(*str);
2096 str++;
2097 wwn->raw_wwn[count++] = byte;
2098 }
2099 }
2100
2101 /*
2102 * FCA driver's intercepted bus control operations.
2103 */
2104 static int
2105 fctl_fca_bus_ctl(dev_info_t *fca_dip, dev_info_t *rip,
2106 ddi_ctl_enum_t op, void *arg, void *result)
2107 {
2108 switch (op) {
2109 case DDI_CTLOPS_REPORTDEV:
2110 break;
2111
2112 case DDI_CTLOPS_IOMIN:
2113 break;
2114
2115 case DDI_CTLOPS_INITCHILD:
2116 return (fctl_initchild(fca_dip, (dev_info_t *)arg));
2117
2118 case DDI_CTLOPS_UNINITCHILD:
2119 return (fctl_uninitchild(fca_dip, (dev_info_t *)arg));
2120
2121 default:
2122 return (ddi_ctlops(fca_dip, rip, op, arg, result));
2123 }
2124
2125 return (DDI_SUCCESS);
2126 }
2127
2128
2129 /*
2130 * FCAs indicate the maximum number of ports supported in their
2131 * tran structure. Fail the INITCHILD if the child port number
2132 * is any greater than the maximum number of ports supported
2133 * by the FCA.
2134 */
2135 static int
2136 fctl_initchild(dev_info_t *fca_dip, dev_info_t *port_dip)
2137 {
2138 int rval;
2139 int port_no;
2140 int port_len;
2141 char name[20];
2142 fc_fca_tran_t *tran;
2143 dev_info_t *dip;
2144 int portprop;
2145
2146 port_len = sizeof (port_no);
2147
2148 /* physical port do not has this property */
2149 portprop = ddi_prop_get_int(DDI_DEV_T_ANY, port_dip,
2150 DDI_PROP_DONTPASS | DDI_PROP_NOTPROM,
2151 "phyport-instance", -1);
2152
2153 if ((portprop == -1) && ndi_dev_is_persistent_node(port_dip)) {
2154 /*
2155 * Clear any addr bindings created by fcode interpreter
2156 * in devi_last_addr so that a ndi_devi_find should never
2157 * return this fcode node.
2158 */
2159 ddi_set_name_addr(port_dip, NULL);
2160 return (DDI_FAILURE);
2161 }
2162
2163 rval = ddi_prop_op(DDI_DEV_T_ANY, port_dip, PROP_LEN_AND_VAL_BUF,
2164 DDI_PROP_DONTPASS | DDI_PROP_CANSLEEP, "port",
2165 (caddr_t)&port_no, &port_len);
2166
2167 if (rval != DDI_SUCCESS) {
2168 return (DDI_FAILURE);
2169 }
2170
2171 tran = (fc_fca_tran_t *)ddi_get_driver_private(fca_dip);
2172 ASSERT(tran != NULL);
2173
2174 (void) sprintf((char *)name, "%x,0", port_no);
2175 ddi_set_name_addr(port_dip, name);
2176
2177 dip = ndi_devi_find(fca_dip, ddi_binding_name(port_dip), name);
2178
2179 /*
2180 * Even though we never initialize FCode nodes of fp, such a node
2181 * could still be there after a DR operation. There will only be
2182 * one FCode node, so if this is the one, clear it and issue a
2183 * ndi_devi_find again.
2184 */
2185 if ((portprop == -1) && dip && ndi_dev_is_persistent_node(dip)) {
2186 ddi_set_name_addr(dip, NULL);
2187 dip = ndi_devi_find(fca_dip, ddi_binding_name(port_dip), name);
2188 }
2189
2190 if ((portprop == -1) && dip && (dip != port_dip)) {
2191 /*
2192 * Here we have a duplicate .conf entry. Clear the addr
2193 * set previously and return failure.
2194 */
2195 ddi_set_name_addr(port_dip, NULL);
2196 return (DDI_FAILURE);
2197 }
2198
2199 return (DDI_SUCCESS);
2200 }
2201
2202
2203 /* ARGSUSED */
2204 static int
2205 fctl_uninitchild(dev_info_t *fca_dip, dev_info_t *port_dip)
2206 {
2207 ddi_set_name_addr(port_dip, NULL);
2208 return (DDI_SUCCESS);
2209 }
2210
2211
2212 static dev_info_t *
2213 fctl_findchild(dev_info_t *pdip, char *cname, char *caddr)
2214 {
2215 dev_info_t *dip;
2216 char *addr;
2217
2218 ASSERT(cname != NULL && caddr != NULL);
2219 /* ASSERT(DEVI_BUSY_OWNED(pdip)); */
2220
2221 for (dip = ddi_get_child(pdip); dip != NULL;
2222 dip = ddi_get_next_sibling(dip)) {
2223 if (strcmp(cname, ddi_node_name(dip)) != 0) {
2224 continue;
2225 }
2226
2227 if ((addr = ddi_get_name_addr(dip)) == NULL) {
2228 if (ddi_prop_lookup_string(DDI_DEV_T_ANY, dip,
2229 DDI_PROP_DONTPASS | DDI_PROP_NOTPROM,
2230 "bus-addr", &addr) == DDI_PROP_SUCCESS) {
2231 if (strcmp(caddr, addr) == 0) {
2232 ddi_prop_free(addr);
2233 return (dip);
2234 }
2235 ddi_prop_free(addr);
2236 }
2237 } else {
2238 if (strcmp(caddr, addr) == 0) {
2239 return (dip);
2240 }
2241 }
2242 }
2243
2244 return (NULL);
2245 }
2246
2247 int
2248 fctl_check_npiv_portindex(dev_info_t *dip, int vindex)
2249 {
2250 int i, instance;
2251 fc_local_port_t *port;
2252
2253 instance = ddi_get_instance(dip);
2254 port = (fc_local_port_t *)fc_ulp_get_port_handle(instance);
2255 if ((!port) || (vindex <= 0) || (vindex >= FC_NPIV_MAX_PORT)) {
2256 return (0);
2257 }
2258
2259 i = vindex-1;
2260 mutex_enter(&port->fp_mutex);
2261 if (port->fp_npiv_portindex[i] == 0) {
2262 mutex_exit(&port->fp_mutex);
2263 return (vindex);
2264 }
2265 mutex_exit(&port->fp_mutex);
2266 return (0);
2267 }
2268
2269 int
2270 fctl_get_npiv_portindex(dev_info_t *dip)
2271 {
2272 int i, instance;
2273 fc_local_port_t *port;
2274
2275 instance = ddi_get_instance(dip);
2276 port = (fc_local_port_t *)fc_ulp_get_port_handle(instance);
2277 if (!port) {
2278 return (0);
2279 }
2280
2281 mutex_enter(&port->fp_mutex);
2282 for (i = 0; i < FC_NPIV_MAX_PORT; i++) {
2283 if (port->fp_npiv_portindex[i] == 0) {
2284 mutex_exit(&port->fp_mutex);
2285 return (i+1);
2286 }
2287 }
2288 mutex_exit(&port->fp_mutex);
2289 return (0);
2290 }
2291
2292
2293 void
2294 fctl_set_npiv_portindex(dev_info_t *dip, int index)
2295 {
2296 int instance;
2297 fc_local_port_t *port;
2298
2299 instance = ddi_get_instance(dip);
2300 port = (fc_local_port_t *)fc_ulp_get_port_handle(instance);
2301 if (!port) {
2302 return;
2303 }
2304 mutex_enter(&port->fp_mutex);
2305 port->fp_npiv_portindex[index - 1] = 1;
2306 mutex_exit(&port->fp_mutex);
2307 }
2308
2309
2310 int
2311 fctl_fca_create_npivport(dev_info_t *parent,
2312 dev_info_t *phydip, char *nname, char *pname, uint32_t *vindex)
2313 {
2314 int rval = 0, devstrlen;
2315 char *devname, *cname, *caddr, *devstr;
2316 dev_info_t *child = NULL;
2317 int portnum;
2318
2319 if (*vindex == 0) {
2320 portnum = fctl_get_npiv_portindex(phydip);
2321 *vindex = portnum;
2322 } else {
2323 portnum = fctl_check_npiv_portindex(phydip, *vindex);
2324 }
2325
2326 if (portnum == 0) {
2327 cmn_err(CE_WARN,
2328 "Cann't find valid port index, fail to create devnode");
2329 return (NDI_FAILURE);
2330 }
2331
2332 devname = kmem_zalloc(MAXNAMELEN, KM_SLEEP);
2333 (void) sprintf(devname, "fp@%x,0", portnum);
2334 devstrlen = strlen(devname) + 1;
2335 devstr = i_ddi_strdup(devname, KM_SLEEP);
2336 i_ddi_parse_name(devstr, &cname, &caddr, NULL);
2337
2338 if (fctl_findchild(parent, cname, caddr) != NULL) {
2339 rval = NDI_FAILURE;
2340 goto freememory;
2341 }
2342
2343 ndi_devi_alloc_sleep(parent, cname, DEVI_PSEUDO_NODEID, &child);
2344 if (child == NULL) {
2345 cmn_err(CE_WARN,
2346 "fctl_create_npiv_port fail to create new devinfo");
2347 rval = NDI_FAILURE;
2348 goto freememory;
2349 }
2350
2351 if (ndi_prop_update_string(DDI_DEV_T_NONE, child,
2352 "bus-addr", caddr) != DDI_PROP_SUCCESS) {
2353 cmn_err(CE_WARN, "fctl%d: prop update bus-addr %s@%s failed",
2354 ddi_get_instance(parent), cname, caddr);
2355 (void) ndi_devi_free(child);
2356 rval = NDI_FAILURE;
2357 goto freememory;
2358 }
2359
2360 if (strlen(nname) != 0) {
2361 if (ndi_prop_update_string(DDI_DEV_T_NONE, child,
2362 "node-name", nname) != DDI_PROP_SUCCESS) {
2363 (void) ndi_devi_free(child);
2364 rval = NDI_FAILURE;
2365 goto freememory;
2366 }
2367 }
2368
2369 if (strlen(pname) != 0) {
2370 if (ndi_prop_update_string(DDI_DEV_T_NONE, child,
2371 "port-name", pname) != DDI_PROP_SUCCESS) {
2372 (void) ndi_devi_free(child);
2373 rval = NDI_FAILURE;
2374 goto freememory;
2375 }
2376 }
2377
2378 if (ddi_prop_update_int(DDI_DEV_T_NONE, child,
2379 "port", portnum) != DDI_PROP_SUCCESS) {
2380 cmn_err(CE_WARN, "fp%d: prop_update port %s@%s failed",
2381 ddi_get_instance(parent), cname, caddr);
2382 (void) ndi_devi_free(child);
2383 rval = NDI_FAILURE;
2384 goto freememory;
2385 }
2386
2387 if (ddi_prop_update_int(DDI_DEV_T_NONE, child,
2388 "phyport-instance", ddi_get_instance(phydip)) != DDI_PROP_SUCCESS) {
2389 cmn_err(CE_WARN,
2390 "fp%d: prop_update phyport-instance %s@%s failed",
2391 ddi_get_instance(parent), cname, caddr);
2392 (void) ndi_devi_free(child);
2393 rval = NDI_FAILURE;
2394 goto freememory;
2395 }
2396
2397 rval = ndi_devi_online(child, NDI_ONLINE_ATTACH);
2398 if (rval != NDI_SUCCESS) {
2399 cmn_err(CE_WARN, "fp%d: online_driver %s failed",
2400 ddi_get_instance(parent), cname);
2401 rval = NDI_FAILURE;
2402 goto freememory;
2403 }
2404
2405 fctl_set_npiv_portindex(phydip, portnum);
2406 freememory:
2407 kmem_free(devstr, devstrlen);
2408 kmem_free(devname, MAXNAMELEN);
2409
2410 return (rval);
2411 }
2412
2413
2414 void
2415 fctl_add_port(fc_local_port_t *port)
2416 {
2417 fc_fca_port_t *new;
2418
2419 new = kmem_zalloc(sizeof (*new), KM_SLEEP);
2420
2421 mutex_enter(&fctl_port_lock);
2422 new->port_handle = port;
2423 new->port_next = fctl_fca_portlist;
2424 fctl_fca_portlist = new;
2425 mutex_exit(&fctl_port_lock);
2426 }
2427
2428
2429 void
2430 fctl_remove_port(fc_local_port_t *port)
2431 {
2432 fc_ulp_module_t *mod;
2433 fc_fca_port_t *prev;
2434 fc_fca_port_t *list;
2435 fc_ulp_ports_t *ulp_port;
2436
2437 rw_enter(&fctl_ulp_lock, RW_WRITER);
2438 rw_enter(&fctl_mod_ports_lock, RW_WRITER);
2439
2440 for (mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
2441 ulp_port = fctl_get_ulp_port(mod, port);
2442 if (ulp_port == NULL) {
2443 continue;
2444 }
2445
2446 #ifndef __lock_lint
2447 ASSERT((ulp_port->port_dstate & ULP_PORT_ATTACH) == 0);
2448 #endif /* __lock_lint */
2449
2450 (void) fctl_remove_ulp_port(mod, port);
2451 }
2452
2453 rw_exit(&fctl_mod_ports_lock);
2454 rw_exit(&fctl_ulp_lock);
2455
2456 mutex_enter(&fctl_port_lock);
2457
2458 list = fctl_fca_portlist;
2459 prev = NULL;
2460 while (list != NULL) {
2461 if (list->port_handle == port) {
2462 if (prev == NULL) {
2463 fctl_fca_portlist = list->port_next;
2464 } else {
2465 prev->port_next = list->port_next;
2466 }
2467 kmem_free(list, sizeof (*list));
2468 break;
2469 }
2470 prev = list;
2471 list = list->port_next;
2472 }
2473 mutex_exit(&fctl_port_lock);
2474 }
2475
2476
2477 void
2478 fctl_attach_ulps(fc_local_port_t *port, fc_attach_cmd_t cmd,
2479 struct modlinkage *linkage)
2480 {
2481 int rval;
2482 uint32_t s_id;
2483 uint32_t state;
2484 fc_ulp_module_t *mod;
2485 fc_ulp_port_info_t info;
2486 fc_ulp_ports_t *ulp_port;
2487
2488 ASSERT(!MUTEX_HELD(&port->fp_mutex));
2489
2490 info.port_linkage = linkage;
2491 info.port_dip = port->fp_port_dip;
2492 info.port_handle = (opaque_t)port;
2493 info.port_dma_behavior = port->fp_dma_behavior;
2494 info.port_fcp_dma = port->fp_fcp_dma;
2495 info.port_acc_attr = port->fp_fca_tran->fca_acc_attr;
2496 info.port_fca_pkt_size = port->fp_fca_tran->fca_pkt_size;
2497 info.port_reset_action = port->fp_reset_action;
2498
2499 mutex_enter(&port->fp_mutex);
2500
2501 /*
2502 * It is still possible that another thread could have gotten
2503 * into the detach process before we got here.
2504 */
2505 if (port->fp_soft_state & FP_SOFT_IN_DETACH) {
2506 mutex_exit(&port->fp_mutex);
2507 return;
2508 }
2509
2510 s_id = port->fp_port_id.port_id;
2511 if (port->fp_statec_busy) {
2512 info.port_state = port->fp_bind_state;
2513 } else {
2514 info.port_state = port->fp_state;
2515 }
2516
2517 switch (state = FC_PORT_STATE_MASK(info.port_state)) {
2518 case FC_STATE_LOOP:
2519 case FC_STATE_NAMESERVICE:
2520 info.port_state &= ~state;
2521 info.port_state |= FC_STATE_ONLINE;
2522 break;
2523
2524 default:
2525 break;
2526 }
2527 ASSERT((info.port_state & FC_STATE_LOOP) == 0);
2528
2529 info.port_flags = port->fp_topology;
2530 info.port_pwwn = port->fp_service_params.nport_ww_name;
2531 info.port_nwwn = port->fp_service_params.node_ww_name;
2532 mutex_exit(&port->fp_mutex);
2533
2534 rw_enter(&fctl_ulp_lock, RW_READER);
2535 rw_enter(&fctl_mod_ports_lock, RW_WRITER);
2536
2537 for (mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
2538 if ((port->fp_soft_state & FP_SOFT_FCA_IS_NODMA) &&
2539 (mod->mod_info->ulp_type == FC_TYPE_IS8802_SNAP)) {
2540 /*
2541 * We don't support IP over FC on FCOE HBA
2542 */
2543 continue;
2544 }
2545
2546 if ((ulp_port = fctl_get_ulp_port(mod, port)) == NULL) {
2547 ulp_port = fctl_add_ulp_port(mod, port, KM_SLEEP);
2548 ASSERT(ulp_port != NULL);
2549
2550 mutex_enter(&ulp_port->port_mutex);
2551 ulp_port->port_statec = ((info.port_state &
2552 FC_STATE_ONLINE) ? FC_ULP_STATEC_ONLINE :
2553 FC_ULP_STATEC_OFFLINE);
2554 mutex_exit(&ulp_port->port_mutex);
2555 }
2556 }
2557
2558 rw_downgrade(&fctl_mod_ports_lock);
2559
2560 for (mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
2561 if ((port->fp_soft_state & FP_SOFT_FCA_IS_NODMA) &&
2562 (mod->mod_info->ulp_type == FC_TYPE_IS8802_SNAP)) {
2563 /*
2564 * We don't support IP over FC on FCOE HBA
2565 */
2566 continue;
2567 }
2568
2569 ulp_port = fctl_get_ulp_port(mod, port);
2570 ASSERT(ulp_port != NULL);
2571
2572 if (fctl_pre_attach(ulp_port, cmd) == FC_FAILURE) {
2573 continue;
2574 }
2575
2576 fctl_init_dma_attr(port, mod, &info);
2577
2578 rval = mod->mod_info->ulp_port_attach(
2579 mod->mod_info->ulp_handle, &info, cmd, s_id);
2580
2581 fctl_post_attach(mod, ulp_port, cmd, rval);
2582
2583 if (rval == FC_SUCCESS && cmd == FC_CMD_ATTACH &&
2584 strcmp(mod->mod_info->ulp_name, "fcp") == 0) {
2585 ASSERT(ddi_get_driver_private(info.port_dip) != NULL);
2586 }
2587 }
2588
2589 rw_exit(&fctl_mod_ports_lock);
2590 rw_exit(&fctl_ulp_lock);
2591 }
2592
2593
2594 static int
2595 fctl_pre_attach(fc_ulp_ports_t *ulp_port, fc_attach_cmd_t cmd)
2596 {
2597 int rval = FC_SUCCESS;
2598
2599 mutex_enter(&ulp_port->port_mutex);
2600
2601 switch (cmd) {
2602 case FC_CMD_ATTACH:
2603 if (ulp_port->port_dstate & ULP_PORT_ATTACH) {
2604 rval = FC_FAILURE;
2605 }
2606 break;
2607
2608 case FC_CMD_RESUME:
2609 ASSERT((ulp_port->port_dstate & ULP_PORT_POWER_DOWN) == 0);
2610 if (!(ulp_port->port_dstate & ULP_PORT_ATTACH) ||
2611 !(ulp_port->port_dstate & ULP_PORT_SUSPEND)) {
2612 rval = FC_FAILURE;
2613 }
2614 break;
2615
2616 case FC_CMD_POWER_UP:
2617 if (!(ulp_port->port_dstate & ULP_PORT_ATTACH) ||
2618 !(ulp_port->port_dstate & ULP_PORT_POWER_DOWN)) {
2619 rval = FC_FAILURE;
2620 }
2621 break;
2622 }
2623
2624 if (rval == FC_SUCCESS) {
2625 ulp_port->port_dstate |= ULP_PORT_BUSY;
2626 }
2627 mutex_exit(&ulp_port->port_mutex);
2628
2629 return (rval);
2630 }
2631
2632
2633 static void
2634 fctl_post_attach(fc_ulp_module_t *mod, fc_ulp_ports_t *ulp_port,
2635 fc_attach_cmd_t cmd, int rval)
2636 {
2637 int be_chatty;
2638
2639 ASSERT(cmd == FC_CMD_ATTACH || cmd == FC_CMD_RESUME ||
2640 cmd == FC_CMD_POWER_UP);
2641
2642 mutex_enter(&ulp_port->port_mutex);
2643 ulp_port->port_dstate &= ~ULP_PORT_BUSY;
2644
2645 be_chatty = (rval == FC_FAILURE_SILENT) ? 0 : 1;
2646
2647 if (rval != FC_SUCCESS) {
2648 caddr_t op;
2649 fc_local_port_t *port = ulp_port->port_handle;
2650
2651 mutex_exit(&ulp_port->port_mutex);
2652
2653 switch (cmd) {
2654 case FC_CMD_ATTACH:
2655 op = "attach";
2656 break;
2657
2658 case FC_CMD_RESUME:
2659 op = "resume";
2660 break;
2661
2662 case FC_CMD_POWER_UP:
2663 op = "power up";
2664 break;
2665 }
2666
2667 if (be_chatty) {
2668 cmn_err(CE_WARN, "!fctl(%d): %s failed for %s",
2669 port->fp_instance, op, mod->mod_info->ulp_name);
2670 }
2671
2672 return;
2673 }
2674
2675 switch (cmd) {
2676 case FC_CMD_ATTACH:
2677 ulp_port->port_dstate |= ULP_PORT_ATTACH;
2678 break;
2679
2680 case FC_CMD_RESUME:
2681 ulp_port->port_dstate &= ~ULP_PORT_SUSPEND;
2682 break;
2683
2684 case FC_CMD_POWER_UP:
2685 ulp_port->port_dstate &= ~ULP_PORT_POWER_DOWN;
2686 break;
2687 }
2688 mutex_exit(&ulp_port->port_mutex);
2689 }
2690
2691
2692 int
2693 fctl_detach_ulps(fc_local_port_t *port, fc_detach_cmd_t cmd,
2694 struct modlinkage *linkage)
2695 {
2696 int rval = FC_SUCCESS;
2697 fc_ulp_module_t *mod;
2698 fc_ulp_port_info_t info;
2699 fc_ulp_ports_t *ulp_port;
2700
2701 ASSERT(!MUTEX_HELD(&port->fp_mutex));
2702
2703 info.port_linkage = linkage;
2704 info.port_dip = port->fp_port_dip;
2705 info.port_handle = (opaque_t)port;
2706 info.port_acc_attr = port->fp_fca_tran->fca_acc_attr;
2707 info.port_fca_pkt_size = port->fp_fca_tran->fca_pkt_size;
2708
2709 rw_enter(&fctl_ulp_lock, RW_READER);
2710 rw_enter(&fctl_mod_ports_lock, RW_READER);
2711
2712 for (mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
2713 if ((ulp_port = fctl_get_ulp_port(mod, port)) == NULL) {
2714 continue;
2715 }
2716
2717 if (fctl_pre_detach(ulp_port, cmd) != FC_SUCCESS) {
2718 continue;
2719 }
2720
2721 fctl_init_dma_attr(port, mod, &info);
2722
2723 rval = mod->mod_info->ulp_port_detach(
2724 mod->mod_info->ulp_handle, &info, cmd);
2725
2726 fctl_post_detach(mod, ulp_port, cmd, rval);
2727
2728 if (rval != FC_SUCCESS) {
2729 break;
2730 }
2731
2732 if (cmd == FC_CMD_DETACH && strcmp(mod->mod_info->ulp_name,
2733 "fcp") == 0) {
2734 ASSERT(ddi_get_driver_private(info.port_dip) == NULL);
2735 }
2736
2737 mutex_enter(&ulp_port->port_mutex);
2738 ulp_port->port_statec = FC_ULP_STATEC_DONT_CARE;
2739 mutex_exit(&ulp_port->port_mutex);
2740 }
2741
2742 rw_exit(&fctl_mod_ports_lock);
2743 rw_exit(&fctl_ulp_lock);
2744
2745 return (rval);
2746 }
2747
2748 static void
2749 fctl_init_dma_attr(fc_local_port_t *port, fc_ulp_module_t *mod,
2750 fc_ulp_port_info_t *info)
2751 {
2752
2753 if ((strcmp(mod->mod_info->ulp_name, "fcp") == 0) ||
2754 (strcmp(mod->mod_info->ulp_name, "ltct") == 0)) {
2755 info->port_cmd_dma_attr =
2756 port->fp_fca_tran->fca_dma_fcp_cmd_attr;
2757 info->port_data_dma_attr =
2758 port->fp_fca_tran->fca_dma_fcp_data_attr;
2759 info->port_resp_dma_attr =
2760 port->fp_fca_tran->fca_dma_fcp_rsp_attr;
2761 } else if (strcmp(mod->mod_info->ulp_name, "fcsm") == 0) {
2762 info->port_cmd_dma_attr =
2763 port->fp_fca_tran->fca_dma_fcsm_cmd_attr;
2764 info->port_data_dma_attr =
2765 port->fp_fca_tran->fca_dma_attr;
2766 info->port_resp_dma_attr =
2767 port->fp_fca_tran->fca_dma_fcsm_rsp_attr;
2768 } else if (strcmp(mod->mod_info->ulp_name, "fcip") == 0) {
2769 info->port_cmd_dma_attr =
2770 port->fp_fca_tran->fca_dma_fcip_cmd_attr;
2771 info->port_data_dma_attr =
2772 port->fp_fca_tran->fca_dma_attr;
2773 info->port_resp_dma_attr =
2774 port->fp_fca_tran->fca_dma_fcip_rsp_attr;
2775 } else {
2776 info->port_cmd_dma_attr = info->port_data_dma_attr =
2777 info->port_resp_dma_attr =
2778 port->fp_fca_tran->fca_dma_attr; /* default */
2779 }
2780 }
2781
2782 static int
2783 fctl_pre_detach(fc_ulp_ports_t *ulp_port, fc_detach_cmd_t cmd)
2784 {
2785 int rval = FC_SUCCESS;
2786
2787 mutex_enter(&ulp_port->port_mutex);
2788
2789 switch (cmd) {
2790 case FC_CMD_DETACH:
2791 if ((ulp_port->port_dstate & ULP_PORT_ATTACH) == 0) {
2792 rval = FC_FAILURE;
2793 }
2794 break;
2795
2796 case FC_CMD_SUSPEND:
2797 if (!(ulp_port->port_dstate & ULP_PORT_ATTACH) ||
2798 ulp_port->port_dstate & ULP_PORT_SUSPEND) {
2799 rval = FC_FAILURE;
2800 }
2801 break;
2802
2803 case FC_CMD_POWER_DOWN:
2804 if (!(ulp_port->port_dstate & ULP_PORT_ATTACH) ||
2805 ulp_port->port_dstate & ULP_PORT_POWER_DOWN) {
2806 rval = FC_FAILURE;
2807 }
2808 break;
2809 }
2810
2811 if (rval == FC_SUCCESS) {
2812 ulp_port->port_dstate |= ULP_PORT_BUSY;
2813 }
2814 mutex_exit(&ulp_port->port_mutex);
2815
2816 return (rval);
2817 }
2818
2819
2820 static void
2821 fctl_post_detach(fc_ulp_module_t *mod, fc_ulp_ports_t *ulp_port,
2822 fc_detach_cmd_t cmd, int rval)
2823 {
2824 ASSERT(cmd == FC_CMD_DETACH || cmd == FC_CMD_SUSPEND ||
2825 cmd == FC_CMD_POWER_DOWN);
2826
2827 mutex_enter(&ulp_port->port_mutex);
2828 ulp_port->port_dstate &= ~ULP_PORT_BUSY;
2829
2830 if (rval != FC_SUCCESS) {
2831 caddr_t op;
2832 fc_local_port_t *port = ulp_port->port_handle;
2833
2834 mutex_exit(&ulp_port->port_mutex);
2835
2836 switch (cmd) {
2837 case FC_CMD_DETACH:
2838 op = "detach";
2839 break;
2840
2841 case FC_CMD_SUSPEND:
2842 op = "suspend";
2843 break;
2844
2845 case FC_CMD_POWER_DOWN:
2846 op = "power down";
2847 break;
2848 }
2849
2850 cmn_err(CE_WARN, "!fctl(%d): %s failed for %s",
2851 port->fp_instance, op, mod->mod_info->ulp_name);
2852
2853 return;
2854 }
2855
2856 switch (cmd) {
2857 case FC_CMD_DETACH:
2858 ulp_port->port_dstate &= ~ULP_PORT_ATTACH;
2859 break;
2860
2861 case FC_CMD_SUSPEND:
2862 ulp_port->port_dstate |= ULP_PORT_SUSPEND;
2863 break;
2864
2865 case FC_CMD_POWER_DOWN:
2866 ulp_port->port_dstate |= ULP_PORT_POWER_DOWN;
2867 break;
2868 }
2869 mutex_exit(&ulp_port->port_mutex);
2870 }
2871
2872
2873 static fc_ulp_ports_t *
2874 fctl_add_ulp_port(fc_ulp_module_t *ulp_module, fc_local_port_t *port_handle,
2875 int sleep)
2876 {
2877 fc_ulp_ports_t *last;
2878 fc_ulp_ports_t *next;
2879 fc_ulp_ports_t *new;
2880
2881 ASSERT(RW_READ_HELD(&fctl_ulp_lock));
2882 ASSERT(RW_WRITE_HELD(&fctl_mod_ports_lock));
2883
2884 last = NULL;
2885 next = ulp_module->mod_ports;
2886
2887 while (next != NULL) {
2888 last = next;
2889 next = next->port_next;
2890 }
2891
2892 new = fctl_alloc_ulp_port(sleep);
2893 if (new == NULL) {
2894 return (new);
2895 }
2896
2897 new->port_handle = port_handle;
2898 if (last == NULL) {
2899 ulp_module->mod_ports = new;
2900 } else {
2901 last->port_next = new;
2902 }
2903
2904 return (new);
2905 }
2906
2907
2908 static fc_ulp_ports_t *
2909 fctl_alloc_ulp_port(int sleep)
2910 {
2911 fc_ulp_ports_t *new;
2912
2913 new = kmem_zalloc(sizeof (*new), sleep);
2914 if (new == NULL) {
2915 return (new);
2916 }
2917 mutex_init(&new->port_mutex, NULL, MUTEX_DRIVER, NULL);
2918
2919 return (new);
2920 }
2921
2922
2923 static int
2924 fctl_remove_ulp_port(struct ulp_module *ulp_module,
2925 fc_local_port_t *port_handle)
2926 {
2927 fc_ulp_ports_t *last;
2928 fc_ulp_ports_t *next;
2929
2930 ASSERT(RW_WRITE_HELD(&fctl_ulp_lock));
2931 ASSERT(RW_WRITE_HELD(&fctl_mod_ports_lock));
2932
2933 last = NULL;
2934 next = ulp_module->mod_ports;
2935
2936 while (next != NULL) {
2937 if (next->port_handle == port_handle) {
2938 if (next->port_dstate & ULP_PORT_ATTACH) {
2939 return (FC_FAILURE);
2940 }
2941 break;
2942 }
2943 last = next;
2944 next = next->port_next;
2945 }
2946
2947 if (next != NULL) {
2948 ASSERT((next->port_dstate & ULP_PORT_ATTACH) == 0);
2949
2950 if (last == NULL) {
2951 ulp_module->mod_ports = next->port_next;
2952 } else {
2953 last->port_next = next->port_next;
2954 }
2955 fctl_dealloc_ulp_port(next);
2956
2957 return (FC_SUCCESS);
2958 } else {
2959 return (FC_FAILURE);
2960 }
2961 }
2962
2963
2964 static void
2965 fctl_dealloc_ulp_port(fc_ulp_ports_t *next)
2966 {
2967 mutex_destroy(&next->port_mutex);
2968 kmem_free(next, sizeof (*next));
2969 }
2970
2971
2972 static fc_ulp_ports_t *
2973 fctl_get_ulp_port(struct ulp_module *ulp_module, fc_local_port_t *port_handle)
2974 {
2975 fc_ulp_ports_t *next;
2976
2977 ASSERT(RW_LOCK_HELD(&fctl_ulp_lock));
2978 ASSERT(RW_LOCK_HELD(&fctl_mod_ports_lock));
2979
2980 for (next = ulp_module->mod_ports; next != NULL;
2981 next = next->port_next) {
2982 if (next->port_handle == port_handle) {
2983 return (next);
2984 }
2985 }
2986
2987 return (NULL);
2988 }
2989
2990
2991 /*
2992 * Pass state change notfications on to registered ULPs.
2993 *
2994 * Can issue wakeups to client callers who might be waiting for completions
2995 * on other threads.
2996 *
2997 * Caution: will silently deallocate any fc_remote_port_t and/or
2998 * fc_remote_node_t structs it finds that are not in use.
2999 */
3000 void
3001 fctl_ulp_statec_cb(void *arg)
3002 {
3003 uint32_t s_id;
3004 uint32_t new_state;
3005 fc_local_port_t *port;
3006 fc_ulp_ports_t *ulp_port;
3007 fc_ulp_module_t *mod;
3008 fc_port_clist_t *clist = (fc_port_clist_t *)arg;
3009
3010 ASSERT(clist != NULL);
3011
3012 port = clist->clist_port;
3013
3014 mutex_enter(&port->fp_mutex);
3015 s_id = port->fp_port_id.port_id;
3016 mutex_exit(&port->fp_mutex);
3017
3018 switch (clist->clist_state) {
3019 case FC_STATE_ONLINE:
3020 new_state = FC_ULP_STATEC_ONLINE;
3021 break;
3022
3023 case FC_STATE_OFFLINE:
3024 if (clist->clist_len) {
3025 new_state = FC_ULP_STATEC_OFFLINE_TIMEOUT;
3026 } else {
3027 new_state = FC_ULP_STATEC_OFFLINE;
3028 }
3029 break;
3030
3031 default:
3032 new_state = FC_ULP_STATEC_DONT_CARE;
3033 break;
3034 }
3035
3036 #ifdef DEBUG
3037 /*
3038 * sanity check for presence of OLD devices in the hash lists
3039 */
3040 if (clist->clist_size) {
3041 int count;
3042 fc_remote_port_t *pd;
3043
3044 ASSERT(clist->clist_map != NULL);
3045 for (count = 0; count < clist->clist_len; count++) {
3046 if (clist->clist_map[count].map_state ==
3047 PORT_DEVICE_INVALID) {
3048 la_wwn_t pwwn;
3049 fc_portid_t d_id;
3050
3051 pd = clist->clist_map[count].map_pd;
3052 if (pd != NULL) {
3053 mutex_enter(&pd->pd_mutex);
3054 pwwn = pd->pd_port_name;
3055 d_id = pd->pd_port_id;
3056 mutex_exit(&pd->pd_mutex);
3057
3058 pd = fctl_get_remote_port_by_pwwn(port,
3059 &pwwn);
3060
3061 ASSERT(pd != clist->clist_map[count].
3062 map_pd);
3063
3064 pd = fctl_get_remote_port_by_did(port,
3065 d_id.port_id);
3066 ASSERT(pd != clist->clist_map[count].
3067 map_pd);
3068 }
3069 }
3070 }
3071 }
3072 #endif
3073
3074 /*
3075 * Check for duplicate map entries
3076 */
3077 if (clist->clist_size) {
3078 int count;
3079 fc_remote_port_t *pd1, *pd2;
3080
3081 ASSERT(clist->clist_map != NULL);
3082 for (count = 0; count < clist->clist_len-1; count++) {
3083 int count2;
3084
3085 pd1 = clist->clist_map[count].map_pd;
3086 if (pd1 == NULL) {
3087 continue;
3088 }
3089
3090 for (count2 = count+1;
3091 count2 < clist->clist_len;
3092 count2++) {
3093
3094 pd2 = clist->clist_map[count2].map_pd;
3095 if (pd2 == NULL) {
3096 continue;
3097 }
3098
3099 if (pd1 == pd2) {
3100 clist->clist_map[count].map_flags |=
3101 PORT_DEVICE_DUPLICATE_MAP_ENTRY;
3102 break;
3103 }
3104 }
3105 }
3106 }
3107
3108
3109 rw_enter(&fctl_ulp_lock, RW_READER);
3110 for (mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
3111 rw_enter(&fctl_mod_ports_lock, RW_READER);
3112 ulp_port = fctl_get_ulp_port(mod, port);
3113 rw_exit(&fctl_mod_ports_lock);
3114
3115 if (ulp_port == NULL) {
3116 continue;
3117 }
3118
3119 mutex_enter(&ulp_port->port_mutex);
3120 if (FCTL_DISALLOW_CALLBACKS(ulp_port->port_dstate)) {
3121 mutex_exit(&ulp_port->port_mutex);
3122 continue;
3123 }
3124
3125 switch (ulp_port->port_statec) {
3126 case FC_ULP_STATEC_DONT_CARE:
3127 if (ulp_port->port_statec != new_state) {
3128 ulp_port->port_statec = new_state;
3129 }
3130 break;
3131
3132 case FC_ULP_STATEC_ONLINE:
3133 case FC_ULP_STATEC_OFFLINE:
3134 if (ulp_port->port_statec == new_state) {
3135 mutex_exit(&ulp_port->port_mutex);
3136 continue;
3137 }
3138 ulp_port->port_statec = new_state;
3139 break;
3140
3141 case FC_ULP_STATEC_OFFLINE_TIMEOUT:
3142 if (ulp_port->port_statec == new_state ||
3143 new_state == FC_ULP_STATEC_OFFLINE) {
3144 mutex_exit(&ulp_port->port_mutex);
3145 continue;
3146 }
3147 ulp_port->port_statec = new_state;
3148 break;
3149
3150 default:
3151 ASSERT(0);
3152 break;
3153 }
3154
3155 mod->mod_info->ulp_statec_callback(
3156 mod->mod_info->ulp_handle, (opaque_t)port,
3157 clist->clist_state, clist->clist_flags,
3158 clist->clist_map, clist->clist_len, s_id);
3159
3160 mutex_exit(&ulp_port->port_mutex);
3161 }
3162 rw_exit(&fctl_ulp_lock);
3163
3164 if (clist->clist_size) {
3165 int count;
3166 fc_remote_node_t *node;
3167 fc_remote_port_t *pd;
3168
3169 ASSERT(clist->clist_map != NULL);
3170 for (count = 0; count < clist->clist_len; count++) {
3171
3172 if ((pd = clist->clist_map[count].map_pd) == NULL) {
3173 continue;
3174 }
3175
3176 mutex_enter(&pd->pd_mutex);
3177
3178 pd->pd_ref_count--;
3179 ASSERT(pd->pd_ref_count >= 0);
3180
3181 if (clist->clist_map[count].map_state !=
3182 PORT_DEVICE_INVALID) {
3183 mutex_exit(&pd->pd_mutex);
3184 continue;
3185 }
3186
3187 node = pd->pd_remote_nodep;
3188 pd->pd_aux_flags &= ~PD_GIVEN_TO_ULPS;
3189
3190 mutex_exit(&pd->pd_mutex);
3191
3192 /*
3193 * This fc_remote_port_t is no longer referenced
3194 * by any ULPs. Deallocate it if its pd_ref_count
3195 * has reached zero.
3196 */
3197 if ((fctl_destroy_remote_port(port, pd) == 0) &&
3198 (node != NULL)) {
3199 fctl_destroy_remote_node(node);
3200 }
3201 }
3202
3203 kmem_free(clist->clist_map,
3204 sizeof (*(clist->clist_map)) * clist->clist_size);
3205 }
3206
3207 if (clist->clist_wait) {
3208 mutex_enter(&clist->clist_mutex);
3209 clist->clist_wait = 0;
3210 cv_signal(&clist->clist_cv);
3211 mutex_exit(&clist->clist_mutex);
3212 } else {
3213 kmem_free(clist, sizeof (*clist));
3214 }
3215 }
3216
3217
3218 /*
3219 * Allocate an fc_remote_node_t struct to represent a remote node for the
3220 * given nwwn. This will also add the nwwn to the global nwwn table.
3221 *
3222 * Returns a pointer to the newly-allocated struct. Returns NULL if
3223 * the kmem_zalloc fails or if the enlist_wwn attempt fails.
3224 */
3225 fc_remote_node_t *
3226 fctl_create_remote_node(la_wwn_t *nwwn, int sleep)
3227 {
3228 fc_remote_node_t *rnodep;
3229
3230 if ((rnodep = kmem_zalloc(sizeof (*rnodep), sleep)) == NULL) {
3231 return (NULL);
3232 }
3233
3234 mutex_init(&rnodep->fd_mutex, NULL, MUTEX_DRIVER, NULL);
3235
3236 rnodep->fd_node_name = *nwwn;
3237 rnodep->fd_flags = FC_REMOTE_NODE_VALID;
3238 rnodep->fd_numports = 1;
3239
3240 if (fctl_enlist_nwwn_table(rnodep, sleep) != FC_SUCCESS) {
3241 mutex_destroy(&rnodep->fd_mutex);
3242 kmem_free(rnodep, sizeof (*rnodep));
3243 return (NULL);
3244 }
3245
3246 return (rnodep);
3247 }
3248
3249 /*
3250 * Deconstruct and free the given fc_remote_node_t struct (remote node struct).
3251 * Silently skips the deconstruct/free if there are any fc_remote_port_t
3252 * (remote port device) structs still referenced by the given
3253 * fc_remote_node_t struct.
3254 */
3255 void
3256 fctl_destroy_remote_node(fc_remote_node_t *rnodep)
3257 {
3258 mutex_enter(&rnodep->fd_mutex);
3259
3260 /*
3261 * Look at the count and linked list of of remote ports
3262 * (fc_remote_port_t structs); bail if these indicate that
3263 * given fc_remote_node_t may be in use.
3264 */
3265 if (rnodep->fd_numports != 0 || rnodep->fd_portlistp) {
3266 mutex_exit(&rnodep->fd_mutex);
3267 return;
3268 }
3269
3270 mutex_exit(&rnodep->fd_mutex);
3271
3272 mutex_destroy(&rnodep->fd_mutex);
3273 kmem_free(rnodep, sizeof (*rnodep));
3274 }
3275
3276
3277 /*
3278 * Add the given fc_remote_node_t to the global fctl_nwwn_hash_table[]. This
3279 * uses the nwwn in the fd_node_name.raw_wwn of the given struct.
3280 * This only fails if the kmem_zalloc fails. This does not check for a
3281 * unique or pre-existing nwwn in the fctl_nwwn_hash_table[].
3282 * This is only called from fctl_create_remote_node().
3283 */
3284 int
3285 fctl_enlist_nwwn_table(fc_remote_node_t *rnodep, int sleep)
3286 {
3287 int index;
3288 fctl_nwwn_elem_t *new;
3289 fctl_nwwn_list_t *head;
3290
3291 ASSERT(!MUTEX_HELD(&rnodep->fd_mutex));
3292
3293 if ((new = kmem_zalloc(sizeof (*new), sleep)) == NULL) {
3294 return (FC_FAILURE);
3295 }
3296
3297 mutex_enter(&fctl_nwwn_hash_mutex);
3298 new->fne_nodep = rnodep;
3299
3300 mutex_enter(&rnodep->fd_mutex);
3301 ASSERT(fctl_is_wwn_zero(&rnodep->fd_node_name) == FC_FAILURE);
3302 index = HASH_FUNC(WWN_HASH_KEY(rnodep->fd_node_name.raw_wwn),
3303 fctl_nwwn_table_size);
3304 mutex_exit(&rnodep->fd_mutex);
3305
3306 head = &fctl_nwwn_hash_table[index];
3307
3308 /* Link it in at the head of the hash list */
3309 new->fne_nextp = head->fnl_headp;
3310 head->fnl_headp = new;
3311
3312 mutex_exit(&fctl_nwwn_hash_mutex);
3313
3314 return (FC_SUCCESS);
3315 }
3316
3317
3318 /*
3319 * Remove the given fc_remote_node_t from the global fctl_nwwn_hash_table[].
3320 * This uses the nwwn in the fd_node_name.raw_wwn of the given struct.
3321 */
3322 void
3323 fctl_delist_nwwn_table(fc_remote_node_t *rnodep)
3324 {
3325 int index;
3326 fctl_nwwn_list_t *head;
3327 fctl_nwwn_elem_t *elem;
3328 fctl_nwwn_elem_t *prev;
3329
3330 ASSERT(MUTEX_HELD(&fctl_nwwn_hash_mutex));
3331 ASSERT(MUTEX_HELD(&rnodep->fd_mutex));
3332
3333 index = HASH_FUNC(WWN_HASH_KEY(rnodep->fd_node_name.raw_wwn),
3334 fctl_nwwn_table_size);
3335
3336 head = &fctl_nwwn_hash_table[index];
3337 elem = head->fnl_headp;
3338 prev = NULL;
3339
3340 while (elem != NULL) {
3341 if (elem->fne_nodep == rnodep) {
3342 /*
3343 * Found it -- unlink it from the list & decrement
3344 * the count for the hash chain.
3345 */
3346 if (prev == NULL) {
3347 head->fnl_headp = elem->fne_nextp;
3348 } else {
3349 prev->fne_nextp = elem->fne_nextp;
3350 }
3351 break;
3352 }
3353 prev = elem;
3354 elem = elem->fne_nextp;
3355 }
3356
3357 if (elem != NULL) {
3358 kmem_free(elem, sizeof (*elem));
3359 }
3360 }
3361
3362
3363 /*
3364 * Returns a reference to an fc_remote_node_t struct for the given node_wwn.
3365 * Looks in the global fctl_nwwn_hash_table[]. Identical to the
3366 * fctl_lock_remote_node_by_nwwn() function, except that this does NOT increment
3367 * the fc_count reference count in the f_device_t before returning.
3368 *
3369 * This function is called by: fctl_create_remote_port_t().
3370 *
3371 * OLD COMMENT:
3372 * Note: The calling thread needs to make sure it isn't holding any device
3373 * mutex (more so the fc_remote_node_t that could potentially have this wwn).
3374 */
3375 fc_remote_node_t *
3376 fctl_get_remote_node_by_nwwn(la_wwn_t *node_wwn)
3377 {
3378 int index;
3379 fctl_nwwn_elem_t *elem;
3380 fc_remote_node_t *next;
3381 fc_remote_node_t *rnodep = NULL;
3382
3383 index = HASH_FUNC(WWN_HASH_KEY(node_wwn->raw_wwn),
3384 fctl_nwwn_table_size);
3385 ASSERT(index >= 0 && index < fctl_nwwn_table_size);
3386
3387 mutex_enter(&fctl_nwwn_hash_mutex);
3388 elem = fctl_nwwn_hash_table[index].fnl_headp;
3389 while (elem != NULL) {
3390 next = elem->fne_nodep;
3391 if (next != NULL) {
3392 mutex_enter(&next->fd_mutex);
3393 if (fctl_wwn_cmp(node_wwn, &next->fd_node_name) == 0) {
3394 rnodep = next;
3395 mutex_exit(&next->fd_mutex);
3396 break;
3397 }
3398 mutex_exit(&next->fd_mutex);
3399 }
3400 elem = elem->fne_nextp;
3401 }
3402 mutex_exit(&fctl_nwwn_hash_mutex);
3403
3404 return (rnodep);
3405 }
3406
3407
3408 /*
3409 * Returns a reference to an fc_remote_node_t struct for the given node_wwn.
3410 * Looks in the global fctl_nwwn_hash_table[]. Increments the fd_numports
3411 * reference count in the f_device_t before returning.
3412 *
3413 * This function is only called by fctl_create_remote_port_t().
3414 */
3415 fc_remote_node_t *
3416 fctl_lock_remote_node_by_nwwn(la_wwn_t *node_wwn)
3417 {
3418 int index;
3419 fctl_nwwn_elem_t *elem;
3420 fc_remote_node_t *next;
3421 fc_remote_node_t *rnodep = NULL;
3422
3423 index = HASH_FUNC(WWN_HASH_KEY(node_wwn->raw_wwn),
3424 fctl_nwwn_table_size);
3425 ASSERT(index >= 0 && index < fctl_nwwn_table_size);
3426
3427 mutex_enter(&fctl_nwwn_hash_mutex);
3428 elem = fctl_nwwn_hash_table[index].fnl_headp;
3429 while (elem != NULL) {
3430 next = elem->fne_nodep;
3431 if (next != NULL) {
3432 mutex_enter(&next->fd_mutex);
3433 if (fctl_wwn_cmp(node_wwn, &next->fd_node_name) == 0) {
3434 rnodep = next;
3435 rnodep->fd_numports++;
3436 mutex_exit(&next->fd_mutex);
3437 break;
3438 }
3439 mutex_exit(&next->fd_mutex);
3440 }
3441 elem = elem->fne_nextp;
3442 }
3443 mutex_exit(&fctl_nwwn_hash_mutex);
3444
3445 return (rnodep);
3446 }
3447
3448
3449 /*
3450 * Allocate and initialize an fc_remote_port_t struct & returns a pointer to
3451 * the newly allocated struct. Only fails if the kmem_zalloc() fails.
3452 */
3453 fc_remote_port_t *
3454 fctl_alloc_remote_port(fc_local_port_t *port, la_wwn_t *port_wwn,
3455 uint32_t d_id, uchar_t recepient, int sleep)
3456 {
3457 fc_remote_port_t *pd;
3458
3459 ASSERT(MUTEX_HELD(&port->fp_mutex));
3460 ASSERT(FC_IS_REAL_DEVICE(d_id));
3461
3462 if ((pd = kmem_zalloc(sizeof (*pd), sleep)) == NULL) {
3463 return (NULL);
3464 }
3465 fctl_tc_constructor(&pd->pd_logo_tc, FC_LOGO_TOLERANCE_LIMIT,
3466 FC_LOGO_TOLERANCE_TIME_LIMIT);
3467
3468 mutex_init(&pd->pd_mutex, NULL, MUTEX_DRIVER, NULL);
3469
3470 pd->pd_port_id.port_id = d_id;
3471 pd->pd_port_name = *port_wwn;
3472 pd->pd_port = port;
3473 pd->pd_state = PORT_DEVICE_VALID;
3474 pd->pd_type = PORT_DEVICE_NEW;
3475 pd->pd_recepient = recepient;
3476
3477 return (pd);
3478 }
3479
3480
3481 /*
3482 * Deconstruct and free the given fc_remote_port_t struct (unconditionally).
3483 */
3484 void
3485 fctl_dealloc_remote_port(fc_remote_port_t *pd)
3486 {
3487 ASSERT(!MUTEX_HELD(&pd->pd_mutex));
3488
3489 fctl_tc_destructor(&pd->pd_logo_tc);
3490 mutex_destroy(&pd->pd_mutex);
3491 kmem_free(pd, sizeof (*pd));
3492 }
3493
3494 /*
3495 * Add the given fc_remote_port_t onto the linked list of remote port
3496 * devices associated with the given fc_remote_node_t. Does NOT add the
3497 * fc_remote_port_t to the list if already exists on the list.
3498 */
3499 void
3500 fctl_link_remote_port_to_remote_node(fc_remote_node_t *rnodep,
3501 fc_remote_port_t *pd)
3502 {
3503 fc_remote_port_t *last;
3504 fc_remote_port_t *ports;
3505
3506 mutex_enter(&rnodep->fd_mutex);
3507
3508 last = NULL;
3509 for (ports = rnodep->fd_portlistp; ports != NULL;
3510 ports = ports->pd_port_next) {
3511 if (ports == pd) {
3512 /*
3513 * The given fc_remote_port_t is already on the linked
3514 * list chain for the given remote node, so bail now.
3515 */
3516 mutex_exit(&rnodep->fd_mutex);
3517 return;
3518 }
3519 last = ports;
3520 }
3521
3522 /* Add the fc_remote_port_t to the tail of the linked list */
3523 if (last != NULL) {
3524 last->pd_port_next = pd;
3525 } else {
3526 rnodep->fd_portlistp = pd;
3527 }
3528 pd->pd_port_next = NULL;
3529
3530 /*
3531 * Link the fc_remote_port_t back to the associated fc_remote_node_t.
3532 */
3533 mutex_enter(&pd->pd_mutex);
3534 pd->pd_remote_nodep = rnodep;
3535 mutex_exit(&pd->pd_mutex);
3536
3537 mutex_exit(&rnodep->fd_mutex);
3538 }
3539
3540
3541 /*
3542 * Remove the specified fc_remote_port_t from the linked list of remote ports
3543 * for the given fc_remote_node_t.
3544 *
3545 * Returns a count of the _remaining_ fc_remote_port_t structs on the linked
3546 * list of the fc_remote_node_t.
3547 *
3548 * The fd_numports on the given fc_remote_node_t is decremented, and if
3549 * it hits zero then this function also removes the fc_remote_node_t from the
3550 * global fctl_nwwn_hash_table[]. This appears to be the ONLY WAY that entries
3551 * are removed from the fctl_nwwn_hash_table[].
3552 */
3553 int
3554 fctl_unlink_remote_port_from_remote_node(fc_remote_node_t *rnodep,
3555 fc_remote_port_t *pd)
3556 {
3557 int rcount = 0;
3558 fc_remote_port_t *last;
3559 fc_remote_port_t *ports;
3560
3561 ASSERT(!MUTEX_HELD(&rnodep->fd_mutex));
3562 ASSERT(!MUTEX_HELD(&pd->pd_mutex));
3563
3564 last = NULL;
3565
3566 mutex_enter(&fctl_nwwn_hash_mutex);
3567
3568 mutex_enter(&rnodep->fd_mutex);
3569
3570 /*
3571 * Go thru the linked list of fc_remote_port_t structs for the given
3572 * fc_remote_node_t; try to find the specified fc_remote_port_t (pd).
3573 */
3574 ports = rnodep->fd_portlistp;
3575 while (ports != NULL) {
3576 if (ports == pd) {
3577 break; /* Found the requested fc_remote_port_t */
3578 }
3579 last = ports;
3580 ports = ports->pd_port_next;
3581 }
3582
3583 if (ports) {
3584 rcount = --rnodep->fd_numports;
3585 if (rcount == 0) {
3586 /* Note: this is only ever called from here */
3587 fctl_delist_nwwn_table(rnodep);
3588 }
3589 if (last) {
3590 last->pd_port_next = pd->pd_port_next;
3591 } else {
3592 rnodep->fd_portlistp = pd->pd_port_next;
3593 }
3594 mutex_enter(&pd->pd_mutex);
3595 pd->pd_remote_nodep = NULL;
3596 mutex_exit(&pd->pd_mutex);
3597 }
3598
3599 pd->pd_port_next = NULL;
3600
3601 mutex_exit(&rnodep->fd_mutex);
3602 mutex_exit(&fctl_nwwn_hash_mutex);
3603
3604 return (rcount);
3605 }
3606
3607
3608 /*
3609 * Add the given fc_remote_port_t struct to the d_id table in the given
3610 * fc_local_port_t struct. Hashes based upon the pd->pd_port_id.port_id in the
3611 * fc_remote_port_t.
3612 *
3613 * No memory allocs are required, so this never fails, but it does use the
3614 * (pd->pd_aux_flags & PD_IN_DID_QUEUE) to keep duplicates off the list.
3615 * (There does not seem to be a way to tell the caller that a duplicate
3616 * exists.)
3617 */
3618 void
3619 fctl_enlist_did_table(fc_local_port_t *port, fc_remote_port_t *pd)
3620 {
3621 struct d_id_hash *head;
3622
3623 ASSERT(MUTEX_HELD(&port->fp_mutex));
3624 ASSERT(MUTEX_HELD(&pd->pd_mutex));
3625
3626 if (pd->pd_aux_flags & PD_IN_DID_QUEUE) {
3627 return;
3628 }
3629
3630 head = &port->fp_did_table[D_ID_HASH_FUNC(pd->pd_port_id.port_id,
3631 did_table_size)];
3632
3633 #ifdef DEBUG
3634 {
3635 int index;
3636 fc_remote_port_t *tmp_pd;
3637 struct d_id_hash *tmp_head;
3638
3639 /*
3640 * Search down in each bucket for a duplicate pd
3641 * Also search for duplicate D_IDs
3642 * This DEBUG code will force an ASSERT if a duplicate
3643 * is ever found.
3644 */
3645 for (index = 0; index < did_table_size; index++) {
3646 tmp_head = &port->fp_did_table[index];
3647
3648 tmp_pd = tmp_head->d_id_head;
3649 while (tmp_pd != NULL) {
3650 ASSERT(tmp_pd != pd);
3651
3652 if (tmp_pd->pd_state != PORT_DEVICE_INVALID &&
3653 tmp_pd->pd_type != PORT_DEVICE_OLD) {
3654 ASSERT(tmp_pd->pd_port_id.port_id !=
3655 pd->pd_port_id.port_id);
3656 }
3657
3658 tmp_pd = tmp_pd->pd_did_hnext;
3659 }
3660 }
3661 }
3662
3663 bzero(pd->pd_d_stack, sizeof (pd->pd_d_stack));
3664 pd->pd_d_depth = getpcstack(pd->pd_d_stack, FC_STACK_DEPTH);
3665 #endif
3666
3667 pd->pd_did_hnext = head->d_id_head;
3668 head->d_id_head = pd;
3669
3670 pd->pd_aux_flags |= PD_IN_DID_QUEUE;
3671 head->d_id_count++;
3672 }
3673
3674
3675 /*
3676 * Remove the given fc_remote_port_t struct from the d_id table in the given
3677 * fc_local_port_t struct. Hashes based upon the pd->pd_port_id.port_id in the
3678 * fc_remote_port_t.
3679 *
3680 * Does nothing if the requested fc_remote_port_t was not found.
3681 */
3682 void
3683 fctl_delist_did_table(fc_local_port_t *port, fc_remote_port_t *pd)
3684 {
3685 uint32_t d_id;
3686 struct d_id_hash *head;
3687 fc_remote_port_t *pd_next;
3688 fc_remote_port_t *last;
3689
3690 ASSERT(MUTEX_HELD(&port->fp_mutex));
3691 ASSERT(MUTEX_HELD(&pd->pd_mutex));
3692
3693 d_id = pd->pd_port_id.port_id;
3694 head = &port->fp_did_table[D_ID_HASH_FUNC(d_id, did_table_size)];
3695
3696 pd_next = head->d_id_head;
3697 last = NULL;
3698 while (pd_next != NULL) {
3699 if (pd == pd_next) {
3700 break; /* Found the given fc_remote_port_t */
3701 }
3702 last = pd_next;
3703 pd_next = pd_next->pd_did_hnext;
3704 }
3705
3706 if (pd_next) {
3707 /*
3708 * Found the given fc_remote_port_t; now remove it from the
3709 * d_id list.
3710 */
3711 head->d_id_count--;
3712 if (last == NULL) {
3713 head->d_id_head = pd->pd_did_hnext;
3714 } else {
3715 last->pd_did_hnext = pd->pd_did_hnext;
3716 }
3717 pd->pd_aux_flags &= ~PD_IN_DID_QUEUE;
3718 pd->pd_did_hnext = NULL;
3719 }
3720 }
3721
3722
3723 /*
3724 * Add the given fc_remote_port_t struct to the pwwn table in the given
3725 * fc_local_port_t struct. Hashes based upon the pd->pd_port_name.raw_wwn
3726 * in the fc_remote_port_t.
3727 *
3728 * No memory allocs are required, so this never fails.
3729 */
3730 void
3731 fctl_enlist_pwwn_table(fc_local_port_t *port, fc_remote_port_t *pd)
3732 {
3733 int index;
3734 struct pwwn_hash *head;
3735
3736 ASSERT(MUTEX_HELD(&port->fp_mutex));
3737 ASSERT(MUTEX_HELD(&pd->pd_mutex));
3738
3739 ASSERT(fctl_is_wwn_zero(&pd->pd_port_name) == FC_FAILURE);
3740
3741 index = HASH_FUNC(WWN_HASH_KEY(pd->pd_port_name.raw_wwn),
3742 pwwn_table_size);
3743
3744 head = &port->fp_pwwn_table[index];
3745
3746 #ifdef DEBUG
3747 {
3748 int index;
3749 fc_remote_port_t *tmp_pd;
3750 struct pwwn_hash *tmp_head;
3751
3752 /*
3753 * Search down in each bucket for a duplicate pd
3754 * Search also for a duplicate WWN
3755 * Throw an ASSERT if any duplicate is found.
3756 */
3757 for (index = 0; index < pwwn_table_size; index++) {
3758 tmp_head = &port->fp_pwwn_table[index];
3759
3760 tmp_pd = tmp_head->pwwn_head;
3761 while (tmp_pd != NULL) {
3762 ASSERT(tmp_pd != pd);
3763
3764 if (tmp_pd->pd_state != PORT_DEVICE_INVALID &&
3765 tmp_pd->pd_type != PORT_DEVICE_OLD) {
3766 ASSERT(fctl_wwn_cmp(
3767 &tmp_pd->pd_port_name,
3768 &pd->pd_port_name) != 0);
3769 }
3770
3771 tmp_pd = tmp_pd->pd_wwn_hnext;
3772 }
3773 }
3774 }
3775
3776 bzero(pd->pd_w_stack, sizeof (pd->pd_w_stack));
3777 pd->pd_w_depth = getpcstack(pd->pd_w_stack, FC_STACK_DEPTH);
3778 #endif /* DEBUG */
3779
3780 pd->pd_wwn_hnext = head->pwwn_head;
3781 head->pwwn_head = pd;
3782
3783 head->pwwn_count++;
3784 /*
3785 * Make sure we tie fp_dev_count to the size of the
3786 * pwwn_table
3787 */
3788 port->fp_dev_count++;
3789 }
3790
3791
3792 /*
3793 * Remove the given fc_remote_port_t struct from the pwwn table in the given
3794 * fc_local_port_t struct. Hashes based upon the pd->pd_port_name.raw_wwn
3795 * in the fc_remote_port_t.
3796 *
3797 * Does nothing if the requested fc_remote_port_t was not found.
3798 */
3799 void
3800 fctl_delist_pwwn_table(fc_local_port_t *port, fc_remote_port_t *pd)
3801 {
3802 int index;
3803 la_wwn_t pwwn;
3804 struct pwwn_hash *head;
3805 fc_remote_port_t *pd_next;
3806 fc_remote_port_t *last;
3807
3808 ASSERT(MUTEX_HELD(&port->fp_mutex));
3809 ASSERT(MUTEX_HELD(&pd->pd_mutex));
3810
3811 pwwn = pd->pd_port_name;
3812 index = HASH_FUNC(WWN_HASH_KEY(pwwn.raw_wwn), pwwn_table_size);
3813
3814 head = &port->fp_pwwn_table[index];
3815
3816 last = NULL;
3817 pd_next = head->pwwn_head;
3818 while (pd_next != NULL) {
3819 if (pd_next == pd) {
3820 break; /* Found the given fc_remote_port_t */
3821 }
3822 last = pd_next;
3823 pd_next = pd_next->pd_wwn_hnext;
3824 }
3825
3826 if (pd_next) {
3827 /*
3828 * Found the given fc_remote_port_t; now remove it from the
3829 * pwwn list.
3830 */
3831 head->pwwn_count--;
3832 /*
3833 * Make sure we tie fp_dev_count to the size of the
3834 * pwwn_table
3835 */
3836 port->fp_dev_count--;
3837 if (last == NULL) {
3838 head->pwwn_head = pd->pd_wwn_hnext;
3839 } else {
3840 last->pd_wwn_hnext = pd->pd_wwn_hnext;
3841 }
3842 pd->pd_wwn_hnext = NULL;
3843 }
3844 }
3845
3846
3847 /*
3848 * Looks in the d_id table of the specified fc_local_port_t for the
3849 * fc_remote_port_t that matches the given d_id. Hashes based upon
3850 * the given d_id.
3851 * Returns a pointer to the fc_remote_port_t struct, but does not update any
3852 * reference counts or otherwise indicate that the fc_remote_port_t is in
3853 * use.
3854 */
3855 fc_remote_port_t *
3856 fctl_get_remote_port_by_did(fc_local_port_t *port, uint32_t d_id)
3857 {
3858 struct d_id_hash *head;
3859 fc_remote_port_t *pd;
3860
3861 ASSERT(!MUTEX_HELD(&port->fp_mutex));
3862
3863 mutex_enter(&port->fp_mutex);
3864
3865 head = &port->fp_did_table[D_ID_HASH_FUNC(d_id, did_table_size)];
3866
3867 pd = head->d_id_head;
3868 while (pd != NULL) {
3869 mutex_enter(&pd->pd_mutex);
3870 if (pd->pd_port_id.port_id == d_id) {
3871 /* Match found -- break out of the loop */
3872 mutex_exit(&pd->pd_mutex);
3873 break;
3874 }
3875 mutex_exit(&pd->pd_mutex);
3876 pd = pd->pd_did_hnext;
3877 }
3878
3879 mutex_exit(&port->fp_mutex);
3880
3881 return (pd);
3882 }
3883
3884
3885 #ifndef __lock_lint /* uncomment when there is a consumer */
3886
3887 void
3888 fc_ulp_hold_remote_port(opaque_t port_handle)
3889 {
3890 fc_remote_port_t *pd = port_handle;
3891
3892 mutex_enter(&pd->pd_mutex);
3893 pd->pd_ref_count++;
3894 mutex_exit(&pd->pd_mutex);
3895 }
3896
3897 /*
3898 * Looks in the d_id table of the specified fc_local_port_t for the
3899 * fc_remote_port_t that matches the given d_id. Hashes based upon
3900 * the given d_id. Returns a pointer to the fc_remote_port_t struct.
3901 *
3902 * Increments pd_ref_count in the fc_remote_port_t if the
3903 * fc_remote_port_t is found at the given d_id.
3904 *
3905 * The fc_remote_port_t is ignored (treated as non-existent) if either
3906 * its pd_state == PORT_DEVICE_INVALID _OR_ its pd_type == PORT_DEVICE_OLD.
3907 */
3908 fc_remote_port_t *
3909 fctl_hold_remote_port_by_did(fc_local_port_t *port, uint32_t d_id)
3910 {
3911 struct d_id_hash *head;
3912 fc_remote_port_t *pd;
3913
3914 ASSERT(!MUTEX_HELD(&port->fp_mutex));
3915
3916 mutex_enter(&port->fp_mutex);
3917
3918 head = &port->fp_did_table[D_ID_HASH_FUNC(d_id, did_table_size)];
3919
3920 pd = head->d_id_head;
3921 while (pd != NULL) {
3922 mutex_enter(&pd->pd_mutex);
3923 if (pd->pd_port_id.port_id == d_id && pd->pd_state !=
3924 PORT_DEVICE_INVALID && pd->pd_type != PORT_DEVICE_OLD) {
3925 ASSERT(pd->pd_ref_count >= 0);
3926 pd->pd_ref_count++;
3927 mutex_exit(&pd->pd_mutex);
3928 break;
3929 }
3930 mutex_exit(&pd->pd_mutex);
3931 pd = pd->pd_did_hnext;
3932 }
3933
3934 mutex_exit(&port->fp_mutex);
3935
3936 return (pd);
3937 }
3938
3939 #endif /* __lock_lint */
3940
3941 /*
3942 * Looks in the pwwn table of the specified fc_local_port_t for the
3943 * fc_remote_port_t that matches the given pwwn. Hashes based upon the
3944 * given pwwn->raw_wwn. Returns a pointer to the fc_remote_port_t struct,
3945 * but does not update any reference counts or otherwise indicate that
3946 * the fc_remote_port_t is in use.
3947 */
3948 fc_remote_port_t *
3949 fctl_get_remote_port_by_pwwn(fc_local_port_t *port, la_wwn_t *pwwn)
3950 {
3951 int index;
3952 struct pwwn_hash *head;
3953 fc_remote_port_t *pd;
3954
3955 ASSERT(!MUTEX_HELD(&port->fp_mutex));
3956
3957 mutex_enter(&port->fp_mutex);
3958
3959 index = HASH_FUNC(WWN_HASH_KEY(pwwn->raw_wwn), pwwn_table_size);
3960 head = &port->fp_pwwn_table[index];
3961
3962 pd = head->pwwn_head;
3963 while (pd != NULL) {
3964 mutex_enter(&pd->pd_mutex);
3965 if (fctl_wwn_cmp(&pd->pd_port_name, pwwn) == 0) {
3966 mutex_exit(&pd->pd_mutex);
3967 break;
3968 }
3969 mutex_exit(&pd->pd_mutex);
3970 pd = pd->pd_wwn_hnext;
3971 }
3972
3973 mutex_exit(&port->fp_mutex);
3974
3975 return (pd);
3976 }
3977
3978
3979 /*
3980 * Basically the same as fctl_get_remote_port_by_pwwn(), but requires that
3981 * the caller already hold the fp_mutex in the fc_local_port_t struct.
3982 */
3983 fc_remote_port_t *
3984 fctl_get_remote_port_by_pwwn_mutex_held(fc_local_port_t *port, la_wwn_t *pwwn)
3985 {
3986 int index;
3987 struct pwwn_hash *head;
3988 fc_remote_port_t *pd;
3989
3990 ASSERT(MUTEX_HELD(&port->fp_mutex));
3991
3992 index = HASH_FUNC(WWN_HASH_KEY(pwwn->raw_wwn), pwwn_table_size);
3993 head = &port->fp_pwwn_table[index];
3994
3995 pd = head->pwwn_head;
3996 while (pd != NULL) {
3997 mutex_enter(&pd->pd_mutex);
3998 if (fctl_wwn_cmp(&pd->pd_port_name, pwwn) == 0) {
3999 mutex_exit(&pd->pd_mutex);
4000 break;
4001 }
4002 mutex_exit(&pd->pd_mutex);
4003 pd = pd->pd_wwn_hnext;
4004 }
4005
4006 return (pd);
4007 }
4008
4009
4010 /*
4011 * Looks in the pwwn table of the specified fc_local_port_t for the
4012 * fc_remote_port_t that matches the given d_id. Hashes based upon the
4013 * given pwwn->raw_wwn. Returns a pointer to the fc_remote_port_t struct.
4014 *
4015 * Increments pd_ref_count in the fc_remote_port_t if the
4016 * fc_remote_port_t is found at the given pwwn.
4017 *
4018 * The fc_remote_port_t is ignored (treated as non-existent) if either
4019 * its pd_state == PORT_DEVICE_INVALID _OR_ its pd_type == PORT_DEVICE_OLD.
4020 */
4021 fc_remote_port_t *
4022 fctl_hold_remote_port_by_pwwn(fc_local_port_t *port, la_wwn_t *pwwn)
4023 {
4024 int index;
4025 struct pwwn_hash *head;
4026 fc_remote_port_t *pd;
4027
4028 ASSERT(!MUTEX_HELD(&port->fp_mutex));
4029
4030 mutex_enter(&port->fp_mutex);
4031
4032 index = HASH_FUNC(WWN_HASH_KEY(pwwn->raw_wwn), pwwn_table_size);
4033 head = &port->fp_pwwn_table[index];
4034
4035 pd = head->pwwn_head;
4036 while (pd != NULL) {
4037 mutex_enter(&pd->pd_mutex);
4038 if (fctl_wwn_cmp(&pd->pd_port_name, pwwn) == 0 &&
4039 pd->pd_state != PORT_DEVICE_INVALID &&
4040 pd->pd_type != PORT_DEVICE_OLD) {
4041 ASSERT(pd->pd_ref_count >= 0);
4042 pd->pd_ref_count++;
4043 mutex_exit(&pd->pd_mutex);
4044 break;
4045 }
4046 mutex_exit(&pd->pd_mutex);
4047 pd = pd->pd_wwn_hnext;
4048 }
4049
4050 mutex_exit(&port->fp_mutex);
4051
4052 return (pd);
4053 }
4054
4055
4056 /*
4057 * Unconditionally decrement pd_ref_count in the given fc_remote_port_t
4058 * struct.
4059 *
4060 * If pd_ref_count reaches zero, then this function will see if the
4061 * fc_remote_port_t has been marked for deallocation. If so (and also if there
4062 * are no other potential operations in progress, as indicated by the
4063 * PD_ELS_IN_PROGRESS & PD_ELS_MARK settings in the pd_flags), then
4064 * fctl_destroy_remote_port_t() is called to deconstruct/free the given
4065 * fc_remote_port_t (which will also remove it from the d_id and pwwn tables
4066 * on the associated fc_local_port_t). If the associated fc_remote_node_t is no
4067 * longer in use, then it too is deconstructed/freed.
4068 */
4069 void
4070 fctl_release_remote_port(fc_remote_port_t *pd)
4071 {
4072 int remove = 0;
4073 fc_remote_node_t *node;
4074 fc_local_port_t *port;
4075
4076 mutex_enter(&pd->pd_mutex);
4077 port = pd->pd_port;
4078
4079 ASSERT(pd->pd_ref_count > 0);
4080 pd->pd_ref_count--;
4081 if (pd->pd_ref_count == 0 &&
4082 (pd->pd_aux_flags & PD_NEEDS_REMOVAL) &&
4083 (pd->pd_flags != PD_ELS_IN_PROGRESS) &&
4084 (pd->pd_flags != PD_ELS_MARK)) {
4085 remove = 1;
4086 pd->pd_aux_flags &= ~PD_NEEDS_REMOVAL;
4087 }
4088 node = pd->pd_remote_nodep;
4089 ASSERT(node != NULL);
4090
4091 mutex_exit(&pd->pd_mutex);
4092
4093 if (remove) {
4094 /*
4095 * The fc_remote_port_t struct has to go away now, so call the
4096 * cleanup function to get it off the various lists and remove
4097 * references to it in any other associated structs.
4098 */
4099 if (fctl_destroy_remote_port(port, pd) == 0) {
4100 /*
4101 * No more fc_remote_port_t references found in the
4102 * associated fc_remote_node_t, so deallocate the
4103 * fc_remote_node_t (if it even exists).
4104 */
4105 if (node) {
4106 fctl_destroy_remote_node(node);
4107 }
4108 }
4109 }
4110 }
4111
4112
4113 void
4114 fctl_fillout_map(fc_local_port_t *port, fc_portmap_t **map, uint32_t *len,
4115 int whole_map, int justcopy, int orphan)
4116 {
4117 int index;
4118 int listlen;
4119 int full_list;
4120 int initiator;
4121 uint32_t topology;
4122 struct pwwn_hash *head;
4123 fc_remote_port_t *pd;
4124 fc_remote_port_t *old_pd;
4125 fc_remote_port_t *last_pd;
4126 fc_portmap_t *listptr;
4127
4128 ASSERT(!MUTEX_HELD(&port->fp_mutex));
4129
4130 mutex_enter(&port->fp_mutex);
4131
4132 topology = port->fp_topology;
4133
4134 if (orphan) {
4135 ASSERT(!FC_IS_TOP_SWITCH(topology));
4136 }
4137
4138 for (full_list = listlen = index = 0;
4139 index < pwwn_table_size; index++) {
4140 head = &port->fp_pwwn_table[index];
4141 pd = head->pwwn_head;
4142 while (pd != NULL) {
4143 full_list++;
4144 mutex_enter(&pd->pd_mutex);
4145 if (pd->pd_type != PORT_DEVICE_NOCHANGE) {
4146 listlen++;
4147 }
4148 mutex_exit(&pd->pd_mutex);
4149 pd = pd->pd_wwn_hnext;
4150 }
4151 }
4152
4153 if (whole_map == 0) {
4154 if (listlen == 0 && *len == 0) {
4155 *map = NULL;
4156 *len = listlen;
4157 mutex_exit(&port->fp_mutex);
4158 return;
4159 }
4160 } else {
4161 if (full_list == 0 && *len == 0) {
4162 *map = NULL;
4163 *len = full_list;
4164 mutex_exit(&port->fp_mutex);
4165 return;
4166 }
4167 }
4168
4169 if (*len == 0) {
4170 ASSERT(*map == NULL);
4171 if (whole_map == 0) {
4172 listptr = *map = kmem_zalloc(
4173 sizeof (*listptr) * listlen, KM_SLEEP);
4174 *len = listlen;
4175 } else {
4176 listptr = *map = kmem_zalloc(
4177 sizeof (*listptr) * full_list, KM_SLEEP);
4178 *len = full_list;
4179 }
4180 } else {
4181 /*
4182 * By design this routine mandates the callers to
4183 * ask for a whole map when they specify the length
4184 * and the listptr.
4185 */
4186 ASSERT(whole_map == 1);
4187 if (*len < full_list) {
4188 *len = full_list;
4189 mutex_exit(&port->fp_mutex);
4190 return;
4191 }
4192 listptr = *map;
4193 *len = full_list;
4194 }
4195
4196 for (index = 0; index < pwwn_table_size; index++) {
4197 head = &port->fp_pwwn_table[index];
4198 last_pd = NULL;
4199 pd = head->pwwn_head;
4200 while (pd != NULL) {
4201 mutex_enter(&pd->pd_mutex);
4202 if ((whole_map == 0 &&
4203 pd->pd_type == PORT_DEVICE_NOCHANGE) ||
4204 pd->pd_state == PORT_DEVICE_INVALID) {
4205 mutex_exit(&pd->pd_mutex);
4206 last_pd = pd;
4207 pd = pd->pd_wwn_hnext;
4208 continue;
4209 }
4210 mutex_exit(&pd->pd_mutex);
4211
4212 fctl_copy_portmap(listptr, pd);
4213
4214 if (justcopy) {
4215 last_pd = pd;
4216 pd = pd->pd_wwn_hnext;
4217 listptr++;
4218 continue;
4219 }
4220
4221 mutex_enter(&pd->pd_mutex);
4222 ASSERT(pd->pd_state != PORT_DEVICE_INVALID);
4223 if (pd->pd_type == PORT_DEVICE_OLD) {
4224 listptr->map_pd = pd;
4225 listptr->map_state = pd->pd_state =
4226 PORT_DEVICE_INVALID;
4227 /*
4228 * Remove this from the PWWN hash table.
4229 */
4230 old_pd = pd;
4231 pd = old_pd->pd_wwn_hnext;
4232
4233 if (last_pd == NULL) {
4234 ASSERT(old_pd == head->pwwn_head);
4235
4236 head->pwwn_head = pd;
4237 } else {
4238 last_pd->pd_wwn_hnext = pd;
4239 }
4240 head->pwwn_count--;
4241 /*
4242 * Make sure we tie fp_dev_count to the size
4243 * of the pwwn_table
4244 */
4245 port->fp_dev_count--;
4246 old_pd->pd_wwn_hnext = NULL;
4247
4248 if (port->fp_topology == FC_TOP_PRIVATE_LOOP &&
4249 port->fp_statec_busy && !orphan) {
4250 fctl_check_alpa_list(port, old_pd);
4251 }
4252
4253 /*
4254 * Remove if the port device has stealthily
4255 * present in the D_ID hash table
4256 */
4257 fctl_delist_did_table(port, old_pd);
4258
4259 ASSERT(old_pd->pd_remote_nodep != NULL);
4260
4261 initiator = (old_pd->pd_recepient ==
4262 PD_PLOGI_INITIATOR) ? 1 : 0;
4263
4264 mutex_exit(&old_pd->pd_mutex);
4265 mutex_exit(&port->fp_mutex);
4266
4267 if (orphan) {
4268 fctl_print_if_not_orphan(port, old_pd);
4269
4270 (void) fctl_add_orphan(port, old_pd,
4271 KM_NOSLEEP);
4272 }
4273
4274 if (FC_IS_TOP_SWITCH(topology) && initiator) {
4275 (void) fctl_add_orphan(port, old_pd,
4276 KM_NOSLEEP);
4277 }
4278 mutex_enter(&port->fp_mutex);
4279 } else {
4280 listptr->map_pd = pd;
4281 pd->pd_type = PORT_DEVICE_NOCHANGE;
4282 mutex_exit(&pd->pd_mutex);
4283 last_pd = pd;
4284 pd = pd->pd_wwn_hnext;
4285 }
4286 listptr++;
4287 }
4288 }
4289 mutex_exit(&port->fp_mutex);
4290 }
4291
4292
4293 job_request_t *
4294 fctl_alloc_job(int job_code, int job_flags, void (*comp) (opaque_t, uchar_t),
4295 opaque_t arg, int sleep)
4296 {
4297 job_request_t *job;
4298
4299 job = (job_request_t *)kmem_cache_alloc(fctl_job_cache, sleep);
4300 if (job != NULL) {
4301 job->job_result = FC_SUCCESS;
4302 job->job_code = job_code;
4303 job->job_flags = job_flags;
4304 job->job_cb_arg = arg;
4305 job->job_comp = comp;
4306 job->job_private = NULL;
4307 job->job_ulp_pkts = NULL;
4308 job->job_ulp_listlen = 0;
4309 #ifndef __lock_lint
4310 job->job_counter = 0;
4311 job->job_next = NULL;
4312 #endif /* __lock_lint */
4313 }
4314
4315 return (job);
4316 }
4317
4318
4319 void
4320 fctl_dealloc_job(job_request_t *job)
4321 {
4322 kmem_cache_free(fctl_job_cache, (void *)job);
4323 }
4324
4325
4326 void
4327 fctl_enque_job(fc_local_port_t *port, job_request_t *job)
4328 {
4329 ASSERT(!MUTEX_HELD(&port->fp_mutex));
4330
4331 mutex_enter(&port->fp_mutex);
4332
4333 if (port->fp_job_tail == NULL) {
4334 ASSERT(port->fp_job_head == NULL);
4335 port->fp_job_head = port->fp_job_tail = job;
4336 } else {
4337 port->fp_job_tail->job_next = job;
4338 port->fp_job_tail = job;
4339 }
4340 job->job_next = NULL;
4341
4342 cv_signal(&port->fp_cv);
4343 mutex_exit(&port->fp_mutex);
4344 }
4345
4346
4347 job_request_t *
4348 fctl_deque_job(fc_local_port_t *port)
4349 {
4350 job_request_t *job;
4351
4352 ASSERT(MUTEX_HELD(&port->fp_mutex));
4353
4354 if (port->fp_job_head == NULL) {
4355 ASSERT(port->fp_job_tail == NULL);
4356 job = NULL;
4357 } else {
4358 job = port->fp_job_head;
4359 if (job->job_next == NULL) {
4360 ASSERT(job == port->fp_job_tail);
4361 port->fp_job_tail = NULL;
4362 }
4363 port->fp_job_head = job->job_next;
4364 }
4365
4366 return (job);
4367 }
4368
4369
4370 void
4371 fctl_priority_enque_job(fc_local_port_t *port, job_request_t *job)
4372 {
4373 ASSERT(!MUTEX_HELD(&port->fp_mutex));
4374
4375 mutex_enter(&port->fp_mutex);
4376 if (port->fp_job_tail == NULL) {
4377 ASSERT(port->fp_job_head == NULL);
4378 port->fp_job_head = port->fp_job_tail = job;
4379 job->job_next = NULL;
4380 } else {
4381 job->job_next = port->fp_job_head;
4382 port->fp_job_head = job;
4383 }
4384 cv_signal(&port->fp_cv);
4385 mutex_exit(&port->fp_mutex);
4386 }
4387
4388
4389 void
4390 fctl_jobwait(job_request_t *job)
4391 {
4392 ASSERT(!(job->job_flags & JOB_TYPE_FCTL_ASYNC));
4393 sema_p(&job->job_fctl_sema);
4394 ASSERT(!MUTEX_HELD(&job->job_mutex));
4395 }
4396
4397
4398 void
4399 fctl_jobdone(job_request_t *job)
4400 {
4401 if (job->job_flags & JOB_TYPE_FCTL_ASYNC) {
4402 if (job->job_comp) {
4403 job->job_comp(job->job_cb_arg, job->job_result);
4404 }
4405 fctl_dealloc_job(job);
4406 } else {
4407 sema_v(&job->job_fctl_sema);
4408 }
4409 }
4410
4411
4412 /*
4413 * Compare two WWNs.
4414 * The NAA can't be omitted for comparison.
4415 *
4416 * Return Values:
4417 * if src == dst return 0
4418 * if src > dst return 1
4419 * if src < dst return -1
4420 */
4421 int
4422 fctl_wwn_cmp(la_wwn_t *src, la_wwn_t *dst)
4423 {
4424 uint8_t *l, *r;
4425 int i;
4426 uint64_t wl, wr;
4427
4428 l = (uint8_t *)src;
4429 r = (uint8_t *)dst;
4430
4431 for (i = 0, wl = 0; i < 8; i++) {
4432 wl <<= 8;
4433 wl |= l[i];
4434 }
4435 for (i = 0, wr = 0; i < 8; i++) {
4436 wr <<= 8;
4437 wr |= r[i];
4438 }
4439
4440 if (wl > wr) {
4441 return (1);
4442 } else if (wl == wr) {
4443 return (0);
4444 } else {
4445 return (-1);
4446 }
4447 }
4448
4449
4450 /*
4451 * ASCII to Integer goodie with support for base 16, 10, 2 and 8
4452 */
4453 int
4454 fctl_atoi(char *s, int base)
4455 {
4456 int val;
4457 int ch;
4458
4459 for (val = 0; *s != '\0'; s++) {
4460 switch (base) {
4461 case 16:
4462 if (*s >= '0' && *s <= '9') {
4463 ch = *s - '0';
4464 } else if (*s >= 'a' && *s <= 'f') {
4465 ch = *s - 'a' + 10;
4466 } else if (*s >= 'A' && *s <= 'F') {
4467 ch = *s - 'A' + 10;
4468 } else {
4469 return (-1);
4470 }
4471 break;
4472
4473 case 10:
4474 if (*s < '0' || *s > '9') {
4475 return (-1);
4476 }
4477 ch = *s - '0';
4478 break;
4479
4480 case 2:
4481 if (*s < '0' || *s > '1') {
4482 return (-1);
4483 }
4484 ch = *s - '0';
4485 break;
4486
4487 case 8:
4488 if (*s < '0' || *s > '7') {
4489 return (-1);
4490 }
4491 ch = *s - '0';
4492 break;
4493
4494 default:
4495 return (-1);
4496 }
4497 val = (val * base) + ch;
4498 }
4499 return (val);
4500 }
4501
4502
4503 /*
4504 * Create the fc_remote_port_t struct for the given port_wwn and d_id.
4505 *
4506 * If the struct already exists (and is "valid"), then use it. Before using
4507 * it, the code below also checks: (a) if the d_id has changed, and (b) if
4508 * the device is maked as PORT_DEVICE_OLD.
4509 *
4510 * If no fc_remote_node_t struct exists for the given node_wwn, then that
4511 * struct is also created (and linked with the fc_remote_port_t).
4512 *
4513 * The given fc_local_port_t struct is updated with the info on the new
4514 * struct(s). The d_id and pwwn hash tables in the port_wwn are updated.
4515 * The global node_hash_table[] is updated (if necessary).
4516 */
4517 fc_remote_port_t *
4518 fctl_create_remote_port(fc_local_port_t *port, la_wwn_t *node_wwn,
4519 la_wwn_t *port_wwn, uint32_t d_id, uchar_t recepient, int sleep)
4520 {
4521 int invalid = 0;
4522 fc_remote_node_t *rnodep;
4523 fc_remote_port_t *pd;
4524
4525 rnodep = fctl_get_remote_node_by_nwwn(node_wwn);
4526 if (rnodep) {
4527 /*
4528 * We found an fc_remote_node_t for the remote node -- see if
4529 * anyone has marked it as going away or gone.
4530 */
4531 mutex_enter(&rnodep->fd_mutex);
4532 invalid = (rnodep->fd_flags == FC_REMOTE_NODE_INVALID) ? 1 : 0;
4533 mutex_exit(&rnodep->fd_mutex);
4534 }
4535 if (rnodep == NULL || invalid) {
4536 /*
4537 * No valid remote node struct found -- create it.
4538 * Note: this is the only place that this func is called.
4539 */
4540 rnodep = fctl_create_remote_node(node_wwn, sleep);
4541 if (rnodep == NULL) {
4542 return (NULL);
4543 }
4544 }
4545
4546 mutex_enter(&port->fp_mutex);
4547
4548 /*
4549 * See if there already is an fc_remote_port_t struct in existence
4550 * on the specified fc_local_port_t for the given pwwn. If so, then
4551 * grab a reference to it. The 'held' here just means that fp_mutex
4552 * is held by the caller -- no reference counts are updated.
4553 */
4554 pd = fctl_get_remote_port_by_pwwn_mutex_held(port, port_wwn);
4555 if (pd) {
4556 /*
4557 * An fc_remote_port_t struct was found -- see if anyone has
4558 * marked it as "invalid", which means that it is in the
4559 * process of going away & we don't want to use it.
4560 */
4561 mutex_enter(&pd->pd_mutex);
4562 invalid = (pd->pd_state == PORT_DEVICE_INVALID) ? 1 : 0;
4563 mutex_exit(&pd->pd_mutex);
4564 }
4565
4566 if (pd == NULL || invalid) {
4567 /*
4568 * No fc_remote_port_t was found (or the existing one is
4569 * marked as "invalid".) Allocate a new one and use that.
4570 * This call will also update the d_id and pwwn hash tables
4571 * in the given fc_local_port_t struct with the newly allocated
4572 * fc_remote_port_t.
4573 */
4574 if ((pd = fctl_alloc_remote_port(port, port_wwn, d_id,
4575 recepient, sleep)) == NULL) {
4576 /* Just give up if the allocation fails. */
4577 mutex_exit(&port->fp_mutex);
4578 fctl_destroy_remote_node(rnodep);
4579 return (pd);
4580 }
4581
4582 /*
4583 * Add the new fc_remote_port_t struct to the d_id and pwwn
4584 * hash tables on the associated fc_local_port_t struct.
4585 */
4586 mutex_enter(&pd->pd_mutex);
4587 pd->pd_remote_nodep = rnodep;
4588 fctl_enlist_did_table(port, pd);
4589 fctl_enlist_pwwn_table(port, pd);
4590 mutex_exit(&pd->pd_mutex);
4591 mutex_exit(&port->fp_mutex);
4592
4593 /*
4594 * Retrieve a pointer to the fc_remote_node_t (i.e., remote
4595 * node) specified by the given node_wwn. This looks in the
4596 * global fctl_nwwn_hash_table[]. The fd_numports reference
4597 * count in the fc_remote_node_t struct is incremented.
4598 */
4599 rnodep = fctl_lock_remote_node_by_nwwn(node_wwn);
4600
4601 } else {
4602 /*
4603 * An existing and valid fc_remote_port_t struct already
4604 * exists on the fc_local_port_t for the given pwwn.
4605 */
4606
4607 mutex_enter(&pd->pd_mutex);
4608 ASSERT(pd->pd_remote_nodep != NULL);
4609
4610 if (pd->pd_port_id.port_id != d_id) {
4611 /*
4612 * A very unlikely occurance in a well
4613 * behaved environment.
4614 */
4615
4616 /*
4617 * The existing fc_remote_port_t has a different
4618 * d_id than what we were given. This code will
4619 * update the existing one with the one that was
4620 * just given.
4621 */
4622 char string[(FCTL_WWN_SIZE(port_wwn) << 1) + 1];
4623 uint32_t old_id;
4624
4625 fc_wwn_to_str(port_wwn, string);
4626
4627 old_id = pd->pd_port_id.port_id;
4628
4629 fctl_delist_did_table(port, pd);
4630
4631 cmn_err(CE_NOTE, "!fctl(%d): D_ID of a device"
4632 " with PWWN %s changed. New D_ID = %x,"
4633 " OLD D_ID = %x", port->fp_instance, string,
4634 d_id, old_id);
4635
4636 pd->pd_port_id.port_id = d_id;
4637
4638 /*
4639 * Looks like we have to presume here that the
4640 * remote port could be something entirely different
4641 * from what was previously existing & valid at this
4642 * pwwn.
4643 */
4644 pd->pd_type = PORT_DEVICE_CHANGED;
4645
4646 /* Record (update) the new d_id for the remote port */
4647 fctl_enlist_did_table(port, pd);
4648
4649 } else if (pd->pd_type == PORT_DEVICE_OLD) {
4650 /*
4651 * OK at least the old & new d_id's match. So for
4652 * PORT_DEVICE_OLD, this assumes that the remote
4653 * port had disappeared but now has come back.
4654 * Update the pd_type and pd_state to put the
4655 * remote port back into service.
4656 */
4657 pd->pd_type = PORT_DEVICE_NOCHANGE;
4658 pd->pd_state = PORT_DEVICE_VALID;
4659
4660 fctl_enlist_did_table(port, pd);
4661
4662 } else {
4663 /*
4664 * OK the old & new d_id's match, and the remote
4665 * port struct is not marked as PORT_DEVICE_OLD, so
4666 * presume that it's still the same device and is
4667 * still in good shape. Also this presumes that we
4668 * do not need to update d_id or pwwn hash tables.
4669 */
4670 /* sanitize device values */
4671 pd->pd_type = PORT_DEVICE_NOCHANGE;
4672 pd->pd_state = PORT_DEVICE_VALID;
4673 }
4674
4675 mutex_exit(&pd->pd_mutex);
4676 mutex_exit(&port->fp_mutex);
4677
4678 if (rnodep != pd->pd_remote_nodep) {
4679 if ((rnodep != NULL) &&
4680 (fctl_wwn_cmp(&pd->pd_remote_nodep->fd_node_name,
4681 node_wwn) != 0)) {
4682 /*
4683 * Rut-roh, there is an fc_remote_node_t remote
4684 * node struct for the given node_wwn, but the
4685 * fc_remote_port_t remote port struct doesn't
4686 * know about it. This just prints a warning
4687 * message & fails the fc_remote_port_t
4688 * allocation (possible leak here?).
4689 */
4690 char ww1_name[17];
4691 char ww2_name[17];
4692
4693 fc_wwn_to_str(
4694 &pd->pd_remote_nodep->fd_node_name,
4695 ww1_name);
4696 fc_wwn_to_str(node_wwn, ww2_name);
4697
4698 cmn_err(CE_WARN, "fctl(%d) NWWN Mismatch: "
4699 "Expected %s Got %s", port->fp_instance,
4700 ww1_name, ww2_name);
4701 }
4702
4703 return (NULL);
4704 }
4705 }
4706
4707 /*
4708 * Add the fc_remote_port_t onto the linked list of remote port
4709 * devices associated with the given fc_remote_node_t (remote node).
4710 */
4711 fctl_link_remote_port_to_remote_node(rnodep, pd);
4712
4713 return (pd);
4714 }
4715
4716
4717 /*
4718 * Disassociate the given fc_local_port_t and fc_remote_port_t structs. Removes
4719 * the fc_remote_port_t from the associated fc_remote_node_t. Also removes any
4720 * references to the fc_remote_port_t from the d_id and pwwn tables in the
4721 * given fc_local_port_t. Deallocates the given fc_remote_port_t.
4722 *
4723 * Returns a count of the number of remaining fc_remote_port_t structs
4724 * associated with the fc_remote_node_t struct.
4725 *
4726 * If pd_ref_count in the given fc_remote_port_t is nonzero, then this
4727 * function just sets the pd->pd_aux_flags |= PD_NEEDS_REMOVAL and the
4728 * pd->pd_type = PORT_DEVICE_OLD and lets some other function(s) worry about
4729 * the cleanup. The function then also returns '1'
4730 * instead of the actual number of remaining fc_remote_port_t structs
4731 *
4732 * If there are no more remote ports on the remote node, return 0.
4733 * Otherwise, return non-zero.
4734 */
4735 int
4736 fctl_destroy_remote_port(fc_local_port_t *port, fc_remote_port_t *pd)
4737 {
4738 fc_remote_node_t *rnodep;
4739 int rcount = 0;
4740
4741 mutex_enter(&pd->pd_mutex);
4742
4743 /*
4744 * If pd_ref_count > 0, we can't pull the rug out from any
4745 * current users of this fc_remote_port_t. We'll mark it as old
4746 * and in need of removal. The same goes for any fc_remote_port_t
4747 * that has a reference handle(s) in a ULP(s) but for which the ULP(s)
4748 * have not yet been notified that the handle is no longer valid
4749 * (i.e., PD_GIVEN_TO_ULPS is set).
4750 */
4751 if ((pd->pd_ref_count > 0) ||
4752 (pd->pd_aux_flags & PD_GIVEN_TO_ULPS)) {
4753 pd->pd_aux_flags |= PD_NEEDS_REMOVAL;
4754 pd->pd_type = PORT_DEVICE_OLD;
4755 mutex_exit(&pd->pd_mutex);
4756 return (1);
4757 }
4758
4759 pd->pd_type = PORT_DEVICE_OLD;
4760
4761 rnodep = pd->pd_remote_nodep;
4762
4763 mutex_exit(&pd->pd_mutex);
4764
4765 if (rnodep != NULL) {
4766 /*
4767 * Remove the fc_remote_port_t from the linked list of remote
4768 * ports for the given fc_remote_node_t. This is only called
4769 * here and in fctl_destroy_all_remote_ports().
4770 */
4771 rcount = fctl_unlink_remote_port_from_remote_node(rnodep, pd);
4772 }
4773
4774 mutex_enter(&port->fp_mutex);
4775 mutex_enter(&pd->pd_mutex);
4776
4777 fctl_delist_did_table(port, pd);
4778 fctl_delist_pwwn_table(port, pd);
4779
4780 mutex_exit(&pd->pd_mutex);
4781
4782 /*
4783 * Deconstruct & free the fc_remote_port_t. This is only called
4784 * here and in fctl_destroy_all_remote_ports().
4785 */
4786 fctl_dealloc_remote_port(pd);
4787
4788 mutex_exit(&port->fp_mutex);
4789
4790 return (rcount);
4791 }
4792
4793
4794 /*
4795 * This goes thru the d_id table on the given fc_local_port_t.
4796 * For each fc_remote_port_t found, this will:
4797 *
4798 * - Remove the fc_remote_port_t from the linked list of remote ports for
4799 * the associated fc_remote_node_t. If the linked list goes empty, then this
4800 * tries to deconstruct & free the fc_remote_node_t (that also removes the
4801 * fc_remote_node_t from the global fctl_nwwn_hash_table[]).
4802 *
4803 * - Remove the fc_remote_port_t from the pwwn list on the given
4804 * fc_local_port_t.
4805 *
4806 * - Deconstruct and free the fc_remote_port_t.
4807 *
4808 * - Removes the link to the fc_remote_port_t in the d_id table. Note, this
4809 * does not appear to correctle decrement the d_id_count tho.
4810 */
4811 void
4812 fctl_destroy_all_remote_ports(fc_local_port_t *port)
4813 {
4814 int index;
4815 fc_remote_port_t *pd;
4816 fc_remote_node_t *rnodep;
4817 struct d_id_hash *head;
4818
4819 mutex_enter(&port->fp_mutex);
4820
4821 for (index = 0; index < did_table_size; index++) {
4822
4823 head = &port->fp_did_table[index];
4824
4825 while (head->d_id_head != NULL) {
4826 pd = head->d_id_head;
4827
4828 /*
4829 * See if this remote port (fc_remote_port_t) has a
4830 * reference to a remote node (fc_remote_node_t) in its
4831 * pd->pd_remote_nodep pointer.
4832 */
4833 mutex_enter(&pd->pd_mutex);
4834 rnodep = pd->pd_remote_nodep;
4835 mutex_exit(&pd->pd_mutex);
4836
4837 if (rnodep != NULL) {
4838 /*
4839 * An fc_remote_node_t reference exists. Remove
4840 * the fc_remote_port_t from the linked list of
4841 * remote ports for fc_remote_node_t.
4842 */
4843 if (fctl_unlink_remote_port_from_remote_node(
4844 rnodep, pd) == 0) {
4845 /*
4846 * The fd_numports reference count
4847 * in the fc_remote_node_t has come
4848 * back as zero, so we can free the
4849 * fc_remote_node_t. This also means
4850 * that the fc_remote_node_t was
4851 * removed from the
4852 * fctl_nwwn_hash_table[].
4853 *
4854 * This will silently skip the
4855 * kmem_free() if either the
4856 * fd_numports is nonzero or
4857 * the fd_port is not NULL in
4858 * the fc_remote_node_t.
4859 */
4860 fctl_destroy_remote_node(rnodep);
4861 }
4862 }
4863
4864 /*
4865 * Clean up the entry in the fc_local_port_t's pwwn
4866 * table for the given fc_remote_port_t (i.e., the pd).
4867 */
4868 mutex_enter(&pd->pd_mutex);
4869 fctl_delist_pwwn_table(port, pd);
4870 pd->pd_aux_flags &= ~PD_IN_DID_QUEUE;
4871 mutex_exit(&pd->pd_mutex);
4872
4873 /*
4874 * Remove the current entry from the d_id list.
4875 */
4876 head->d_id_head = pd->pd_did_hnext;
4877
4878 /*
4879 * Deconstruct & free the fc_remote_port_t (pd)
4880 * Note: this is only called here and in
4881 * fctl_destroy_remote_port_t().
4882 */
4883 fctl_dealloc_remote_port(pd);
4884 }
4885 }
4886
4887 mutex_exit(&port->fp_mutex);
4888 }
4889
4890
4891 int
4892 fctl_is_wwn_zero(la_wwn_t *wwn)
4893 {
4894 int count;
4895
4896 for (count = 0; count < sizeof (la_wwn_t); count++) {
4897 if (wwn->raw_wwn[count] != 0) {
4898 return (FC_FAILURE);
4899 }
4900 }
4901
4902 return (FC_SUCCESS);
4903 }
4904
4905
4906 void
4907 fctl_ulp_unsol_cb(fc_local_port_t *port, fc_unsol_buf_t *buf, uchar_t type)
4908 {
4909 int data_cb;
4910 int check_type;
4911 int rval;
4912 uint32_t claimed;
4913 fc_ulp_module_t *mod;
4914 fc_ulp_ports_t *ulp_port;
4915
4916 claimed = 0;
4917 check_type = 1;
4918
4919 switch ((buf->ub_frame.r_ctl) & R_CTL_ROUTING) {
4920 case R_CTL_DEVICE_DATA:
4921 data_cb = 1;
4922 break;
4923
4924 case R_CTL_EXTENDED_SVC:
4925 check_type = 0;
4926 /* FALLTHROUGH */
4927
4928 case R_CTL_FC4_SVC:
4929 data_cb = 0;
4930 break;
4931
4932 default:
4933 mutex_enter(&port->fp_mutex);
4934 ASSERT(port->fp_active_ubs > 0);
4935 if (--(port->fp_active_ubs) == 0) {
4936 port->fp_soft_state &= ~FP_SOFT_IN_UNSOL_CB;
4937 }
4938 mutex_exit(&port->fp_mutex);
4939 port->fp_fca_tran->fca_ub_release(port->fp_fca_handle,
4940 1, &buf->ub_token);
4941 return;
4942 }
4943
4944 rw_enter(&fctl_ulp_lock, RW_READER);
4945 for (mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
4946 if (check_type && mod->mod_info->ulp_type != type) {
4947 continue;
4948 }
4949
4950 rw_enter(&fctl_mod_ports_lock, RW_READER);
4951 ulp_port = fctl_get_ulp_port(mod, port);
4952 rw_exit(&fctl_mod_ports_lock);
4953
4954 if (ulp_port == NULL) {
4955 continue;
4956 }
4957
4958 mutex_enter(&ulp_port->port_mutex);
4959 if (FCTL_DISALLOW_CALLBACKS(ulp_port->port_dstate)) {
4960 mutex_exit(&ulp_port->port_mutex);
4961 continue;
4962 }
4963 mutex_exit(&ulp_port->port_mutex);
4964
4965 if (data_cb == 1) {
4966 rval = mod->mod_info->ulp_data_callback(
4967 mod->mod_info->ulp_handle,
4968 (opaque_t)port, buf, claimed);
4969 } else {
4970 rval = mod->mod_info->ulp_els_callback(
4971 mod->mod_info->ulp_handle,
4972 (opaque_t)port, buf, claimed);
4973 }
4974
4975 if (rval == FC_SUCCESS && claimed == 0) {
4976 claimed = 1;
4977 }
4978 }
4979 rw_exit(&fctl_ulp_lock);
4980
4981 if (claimed == 0) {
4982 /*
4983 * We should actually RJT since nobody claimed it.
4984 */
4985 mutex_enter(&port->fp_mutex);
4986 ASSERT(port->fp_active_ubs > 0);
4987 if (--(port->fp_active_ubs) == 0) {
4988 port->fp_soft_state &= ~FP_SOFT_IN_UNSOL_CB;
4989 }
4990 mutex_exit(&port->fp_mutex);
4991 port->fp_fca_tran->fca_ub_release(port->fp_fca_handle,
4992 1, &buf->ub_token);
4993
4994 } else {
4995 mutex_enter(&port->fp_mutex);
4996 if (--port->fp_active_ubs == 0) {
4997 port->fp_soft_state &= ~FP_SOFT_IN_UNSOL_CB;
4998 }
4999 mutex_exit(&port->fp_mutex);
5000 }
5001 }
5002
5003
5004 /*
5005 * Both fd_mutex and pd_mutex are held (in that order) coming in to this func
5006 *
5007 * With all these mutexes held, we should make sure this function does not eat
5008 * up much time.
5009 */
5010 void
5011 fctl_copy_portmap_held(fc_portmap_t *map, fc_remote_port_t *pd)
5012 {
5013 fc_remote_node_t *node;
5014
5015 ASSERT(MUTEX_HELD(&pd->pd_mutex));
5016
5017 map->map_pwwn = pd->pd_port_name;
5018 map->map_did = pd->pd_port_id;
5019 map->map_hard_addr = pd->pd_hard_addr;
5020 map->map_state = pd->pd_state;
5021 map->map_type = pd->pd_type;
5022 map->map_flags = 0;
5023
5024 ASSERT(map->map_type <= PORT_DEVICE_DELETE);
5025
5026 bcopy(pd->pd_fc4types, map->map_fc4_types, sizeof (pd->pd_fc4types));
5027
5028 node = pd->pd_remote_nodep;
5029
5030 ASSERT(MUTEX_HELD(&node->fd_mutex));
5031
5032 if (node) {
5033 map->map_nwwn = node->fd_node_name;
5034 }
5035 map->map_pd = pd;
5036 }
5037
5038 void
5039 fctl_copy_portmap(fc_portmap_t *map, fc_remote_port_t *pd)
5040 {
5041 fc_remote_node_t *node;
5042
5043 ASSERT(!MUTEX_HELD(&pd->pd_mutex));
5044
5045 mutex_enter(&pd->pd_mutex);
5046 map->map_pwwn = pd->pd_port_name;
5047 map->map_did = pd->pd_port_id;
5048 map->map_hard_addr = pd->pd_hard_addr;
5049 map->map_state = pd->pd_state;
5050 map->map_type = pd->pd_type;
5051 map->map_flags = 0;
5052
5053 ASSERT(map->map_type <= PORT_DEVICE_DELETE);
5054
5055 bcopy(pd->pd_fc4types, map->map_fc4_types, sizeof (pd->pd_fc4types));
5056
5057 node = pd->pd_remote_nodep;
5058 mutex_exit(&pd->pd_mutex);
5059
5060 if (node) {
5061 mutex_enter(&node->fd_mutex);
5062 map->map_nwwn = node->fd_node_name;
5063 mutex_exit(&node->fd_mutex);
5064 }
5065 map->map_pd = pd;
5066 }
5067
5068
5069 static int
5070 fctl_update_host_ns_values(fc_local_port_t *port, fc_ns_cmd_t *ns_req)
5071 {
5072 int rval = FC_SUCCESS;
5073
5074 switch (ns_req->ns_cmd) {
5075 case NS_RFT_ID: {
5076 int count;
5077 uint32_t *src;
5078 uint32_t *dst;
5079 ns_rfc_type_t *rfc;
5080
5081 rfc = (ns_rfc_type_t *)ns_req->ns_req_payload;
5082
5083 mutex_enter(&port->fp_mutex);
5084 src = (uint32_t *)port->fp_fc4_types;
5085 dst = (uint32_t *)rfc->rfc_types;
5086
5087 for (count = 0; count < 8; count++) {
5088 *src++ |= *dst++;
5089 }
5090 mutex_exit(&port->fp_mutex);
5091
5092 break;
5093 }
5094
5095 case NS_RSPN_ID: {
5096 ns_spn_t *spn;
5097
5098 spn = (ns_spn_t *)ns_req->ns_req_payload;
5099
5100 mutex_enter(&port->fp_mutex);
5101 port->fp_sym_port_namelen = spn->spn_len;
5102 if (spn->spn_len) {
5103 bcopy((caddr_t)spn + sizeof (ns_spn_t),
5104 port->fp_sym_port_name, spn->spn_len);
5105 }
5106 mutex_exit(&port->fp_mutex);
5107
5108 break;
5109 }
5110
5111 case NS_RSNN_NN: {
5112 ns_snn_t *snn;
5113
5114 snn = (ns_snn_t *)ns_req->ns_req_payload;
5115
5116 mutex_enter(&port->fp_mutex);
5117 port->fp_sym_node_namelen = snn->snn_len;
5118 if (snn->snn_len) {
5119 bcopy((caddr_t)snn + sizeof (ns_snn_t),
5120 port->fp_sym_node_name, snn->snn_len);
5121 }
5122 mutex_exit(&port->fp_mutex);
5123
5124 break;
5125 }
5126
5127 case NS_RIP_NN: {
5128 ns_rip_t *rip;
5129
5130 rip = (ns_rip_t *)ns_req->ns_req_payload;
5131
5132 mutex_enter(&port->fp_mutex);
5133 bcopy(rip->rip_ip_addr, port->fp_ip_addr,
5134 sizeof (rip->rip_ip_addr));
5135 mutex_exit(&port->fp_mutex);
5136
5137 break;
5138 }
5139
5140 case NS_RIPA_NN: {
5141 ns_ipa_t *ipa;
5142
5143 ipa = (ns_ipa_t *)ns_req->ns_req_payload;
5144
5145 mutex_enter(&port->fp_mutex);
5146 bcopy(ipa->ipa_value, port->fp_ipa, sizeof (ipa->ipa_value));
5147 mutex_exit(&port->fp_mutex);
5148
5149 break;
5150 }
5151
5152 default:
5153 rval = FC_BADOBJECT;
5154 break;
5155 }
5156
5157 return (rval);
5158 }
5159
5160
5161 static int
5162 fctl_retrieve_host_ns_values(fc_local_port_t *port, fc_ns_cmd_t *ns_req)
5163 {
5164 int rval = FC_SUCCESS;
5165
5166 switch (ns_req->ns_cmd) {
5167 case NS_GFT_ID: {
5168 ns_rfc_type_t *rfc;
5169
5170 rfc = (ns_rfc_type_t *)ns_req->ns_resp_payload;
5171
5172 mutex_enter(&port->fp_mutex);
5173 bcopy(port->fp_fc4_types, rfc->rfc_types,
5174 sizeof (rfc->rfc_types));
5175 mutex_exit(&port->fp_mutex);
5176 break;
5177 }
5178
5179 case NS_GSPN_ID: {
5180 ns_spn_t *spn;
5181
5182 spn = (ns_spn_t *)ns_req->ns_resp_payload;
5183
5184 mutex_enter(&port->fp_mutex);
5185 spn->spn_len = port->fp_sym_port_namelen;
5186 if (spn->spn_len) {
5187 bcopy(port->fp_sym_port_name, (caddr_t)spn +
5188 sizeof (ns_spn_t), spn->spn_len);
5189 }
5190 mutex_exit(&port->fp_mutex);
5191
5192 break;
5193 }
5194
5195 case NS_GSNN_NN: {
5196 ns_snn_t *snn;
5197
5198 snn = (ns_snn_t *)ns_req->ns_resp_payload;
5199
5200 mutex_enter(&port->fp_mutex);
5201 snn->snn_len = port->fp_sym_node_namelen;
5202 if (snn->snn_len) {
5203 bcopy(port->fp_sym_node_name, (caddr_t)snn +
5204 sizeof (ns_snn_t), snn->snn_len);
5205 }
5206 mutex_exit(&port->fp_mutex);
5207
5208 break;
5209 }
5210
5211 case NS_GIP_NN: {
5212 ns_rip_t *rip;
5213
5214 rip = (ns_rip_t *)ns_req->ns_resp_payload;
5215
5216 mutex_enter(&port->fp_mutex);
5217 bcopy(port->fp_ip_addr, rip->rip_ip_addr,
5218 sizeof (rip->rip_ip_addr));
5219 mutex_exit(&port->fp_mutex);
5220
5221 break;
5222 }
5223
5224 case NS_GIPA_NN: {
5225 ns_ipa_t *ipa;
5226
5227 ipa = (ns_ipa_t *)ns_req->ns_resp_payload;
5228
5229 mutex_enter(&port->fp_mutex);
5230 bcopy(port->fp_ipa, ipa->ipa_value, sizeof (ipa->ipa_value));
5231 mutex_exit(&port->fp_mutex);
5232
5233 break;
5234 }
5235
5236 default:
5237 rval = FC_BADOBJECT;
5238 break;
5239 }
5240
5241 return (rval);
5242 }
5243
5244
5245 fctl_ns_req_t *
5246 fctl_alloc_ns_cmd(uint32_t cmd_len, uint32_t resp_len, uint32_t data_len,
5247 uint32_t ns_flags, int sleep)
5248 {
5249 fctl_ns_req_t *ns_cmd;
5250
5251 ns_cmd = kmem_zalloc(sizeof (*ns_cmd), sleep);
5252 if (ns_cmd == NULL) {
5253 return (NULL);
5254 }
5255
5256 if (cmd_len) {
5257 ns_cmd->ns_cmd_buf = kmem_zalloc(cmd_len, sleep);
5258 if (ns_cmd->ns_cmd_buf == NULL) {
5259 kmem_free(ns_cmd, sizeof (*ns_cmd));
5260 return (NULL);
5261 }
5262 ns_cmd->ns_cmd_size = cmd_len;
5263 }
5264
5265 ns_cmd->ns_resp_size = resp_len;
5266
5267 if (data_len) {
5268 ns_cmd->ns_data_buf = kmem_zalloc(data_len, sleep);
5269 if (ns_cmd->ns_data_buf == NULL) {
5270 if (ns_cmd->ns_cmd_buf && cmd_len) {
5271 kmem_free(ns_cmd->ns_cmd_buf, cmd_len);
5272 }
5273 kmem_free(ns_cmd, sizeof (*ns_cmd));
5274 return (NULL);
5275 }
5276 ns_cmd->ns_data_len = data_len;
5277 }
5278 ns_cmd->ns_flags = ns_flags;
5279
5280 return (ns_cmd);
5281 }
5282
5283
5284 void
5285 fctl_free_ns_cmd(fctl_ns_req_t *ns_cmd)
5286 {
5287 if (ns_cmd->ns_cmd_size && ns_cmd->ns_cmd_buf) {
5288 kmem_free(ns_cmd->ns_cmd_buf, ns_cmd->ns_cmd_size);
5289 }
5290 if (ns_cmd->ns_data_len && ns_cmd->ns_data_buf) {
5291 kmem_free(ns_cmd->ns_data_buf, ns_cmd->ns_data_len);
5292 }
5293 kmem_free(ns_cmd, sizeof (*ns_cmd));
5294 }
5295
5296
5297 int
5298 fctl_ulp_port_ioctl(fc_local_port_t *port, dev_t dev, int cmd,
5299 intptr_t data, int mode, cred_t *credp, int *rval)
5300 {
5301 int ret;
5302 int save;
5303 uint32_t claimed;
5304 fc_ulp_module_t *mod;
5305 fc_ulp_ports_t *ulp_port;
5306
5307 save = *rval;
5308 *rval = ENOTTY;
5309
5310 rw_enter(&fctl_ulp_lock, RW_READER);
5311 for (claimed = 0, mod = fctl_ulp_modules; mod; mod = mod->mod_next) {
5312 rw_enter(&fctl_mod_ports_lock, RW_READER);
5313 ulp_port = fctl_get_ulp_port(mod, port);
5314 rw_exit(&fctl_mod_ports_lock);
5315
5316 if (ulp_port == NULL) {
5317 continue;
5318 }
5319
5320 mutex_enter(&ulp_port->port_mutex);
5321 if (FCTL_DISALLOW_CALLBACKS(ulp_port->port_dstate) ||
5322 mod->mod_info->ulp_port_ioctl == NULL) {
5323 mutex_exit(&ulp_port->port_mutex);
5324 continue;
5325 }
5326 mutex_exit(&ulp_port->port_mutex);
5327
5328 ret = mod->mod_info->ulp_port_ioctl(
5329 mod->mod_info->ulp_handle, (opaque_t)port,
5330 dev, cmd, data, mode, credp, rval, claimed);
5331
5332 if (ret == FC_SUCCESS && claimed == 0) {
5333 claimed = 1;
5334 }
5335 }
5336 rw_exit(&fctl_ulp_lock);
5337
5338 ret = *rval;
5339 *rval = save;
5340
5341 return (ret);
5342 }
5343
5344 /*
5345 * raise power if necessary, and set the port busy
5346 *
5347 * this may cause power to be raised, so no power related locks should
5348 * be held
5349 */
5350 int
5351 fc_ulp_busy_port(opaque_t port_handle)
5352 {
5353 fc_local_port_t *port = port_handle;
5354
5355 return (fctl_busy_port(port));
5356 }
5357
5358 void
5359 fc_ulp_idle_port(opaque_t port_handle)
5360 {
5361 fc_local_port_t *port = port_handle;
5362 fctl_idle_port(port);
5363 }
5364
5365 void
5366 fc_ulp_copy_portmap(fc_portmap_t *map, opaque_t pd)
5367 {
5368 fctl_copy_portmap(map, (fc_remote_port_t *)pd);
5369 }
5370
5371
5372 int
5373 fc_ulp_get_npiv_port_num(opaque_t port_handle)
5374 {
5375 int portsnum = 0;
5376 fc_local_port_t *port = port_handle;
5377 fc_local_port_t *tmpport;
5378
5379 mutex_enter(&port->fp_mutex);
5380 tmpport = port->fp_port_next;
5381 if (!tmpport) {
5382 mutex_exit(&port->fp_mutex);
5383 return (portsnum);
5384 }
5385 while (tmpport != port) {
5386 portsnum ++;
5387 tmpport = tmpport->fp_port_next;
5388 }
5389 mutex_exit(&port->fp_mutex);
5390 return (portsnum);
5391 }
5392
5393 fc_local_port_t *
5394 fc_get_npiv_port(fc_local_port_t *phyport, la_wwn_t *pwwn)
5395 {
5396 fc_fca_port_t *fca_port;
5397 fc_local_port_t *tmpPort = phyport;
5398
5399 mutex_enter(&fctl_port_lock);
5400
5401 for (fca_port = fctl_fca_portlist; fca_port != NULL;
5402 fca_port = fca_port->port_next) {
5403 tmpPort = fca_port->port_handle;
5404 if (tmpPort == NULL) {
5405 continue;
5406 }
5407 mutex_enter(&tmpPort->fp_mutex);
5408 if (bcmp(tmpPort->fp_service_params.nport_ww_name.raw_wwn,
5409 pwwn->raw_wwn, sizeof (la_wwn_t)) == 0) {
5410 mutex_exit(&tmpPort->fp_mutex);
5411 mutex_exit(&fctl_port_lock);
5412 return (tmpPort);
5413 }
5414 mutex_exit(&tmpPort->fp_mutex);
5415 }
5416
5417 mutex_exit(&fctl_port_lock);
5418
5419 return (NULL);
5420 }
5421
5422 int
5423 fc_ulp_get_npiv_port_list(opaque_t port_handle, char *pathList)
5424 {
5425 int portsnum = 0;
5426 fc_local_port_t *port = port_handle;
5427 fc_local_port_t *tmpport;
5428
5429 mutex_enter(&port->fp_mutex);
5430 tmpport = port->fp_port_next;
5431 if (!tmpport || (port->fp_npiv_type == FC_NPIV_PORT)) {
5432 mutex_exit(&port->fp_mutex);
5433 return (portsnum);
5434 }
5435
5436 while (tmpport != port) {
5437 (void) ddi_pathname(tmpport->fp_port_dip,
5438 &pathList[MAXPATHLEN * portsnum]);
5439 portsnum ++;
5440 tmpport = tmpport->fp_port_next;
5441 }
5442 mutex_exit(&port->fp_mutex);
5443
5444 return (portsnum);
5445 }
5446
5447
5448 fc_local_port_t *
5449 fc_delete_npiv_port(fc_local_port_t *port, la_wwn_t *pwwn)
5450 {
5451 fc_local_port_t *tmpport;
5452
5453 mutex_enter(&port->fp_mutex);
5454 tmpport = port->fp_port_next;
5455 if (!tmpport || (port->fp_npiv_type == FC_NPIV_PORT)) {
5456 mutex_exit(&port->fp_mutex);
5457 return (NULL);
5458 }
5459
5460 while (tmpport != port) {
5461 if ((bcmp(tmpport->fp_service_params.nport_ww_name.raw_wwn,
5462 pwwn->raw_wwn, sizeof (la_wwn_t)) == 0) &&
5463 (tmpport->fp_npiv_state == 0)) {
5464 tmpport->fp_npiv_state = FC_NPIV_DELETING;
5465 mutex_exit(&port->fp_mutex);
5466 return (tmpport);
5467 }
5468 tmpport = tmpport->fp_port_next;
5469 }
5470
5471 mutex_exit(&port->fp_mutex);
5472 return (NULL);
5473 }
5474
5475 /*
5476 * Get the list of Adapters. On multi-ported adapters,
5477 * only ONE port on the adapter will be returned.
5478 * pathList should be (count * MAXPATHLEN) long.
5479 * The return value will be set to the number of
5480 * HBAs that were found on the system. If the value
5481 * is greater than count, the routine should be retried
5482 * with a larger buffer.
5483 */
5484 int
5485 fc_ulp_get_adapter_paths(char *pathList, int count)
5486 {
5487 fc_fca_port_t *fca_port;
5488 int in = 0, out = 0, check, skip, maxPorts = 0;
5489 fc_local_port_t **portList;
5490 fc_local_port_t *new_port, *stored_port;
5491 fca_hba_fru_details_t *new_fru, *stored_fru;
5492
5493 ASSERT(pathList != NULL);
5494
5495 /* First figure out how many ports we have */
5496 mutex_enter(&fctl_port_lock);
5497
5498 for (fca_port = fctl_fca_portlist; fca_port != NULL;
5499 fca_port = fca_port->port_next) {
5500 maxPorts ++;
5501 }
5502
5503 /* Now allocate a buffer to store all the pointers for comparisons */
5504 portList = kmem_zalloc(sizeof (fc_local_port_t *) * maxPorts, KM_SLEEP);
5505
5506 for (fca_port = fctl_fca_portlist; fca_port != NULL;
5507 fca_port = fca_port->port_next) {
5508 skip = 0;
5509
5510 /* Lock the new port for subsequent comparisons */
5511 new_port = fca_port->port_handle;
5512 mutex_enter(&new_port->fp_mutex);
5513 new_fru = &new_port->fp_hba_port_attrs.hba_fru_details;
5514
5515 /* Filter out secondary ports from the list */
5516 for (check = 0; check < out; check++) {
5517 if (portList[check] == NULL) {
5518 continue;
5519 }
5520 /* Guard against duplicates (should never happen) */
5521 if (portList[check] == fca_port->port_handle) {
5522 /* Same port */
5523 skip = 1;
5524 break;
5525 }
5526
5527 /* Lock the already stored port for comparison */
5528 stored_port = portList[check];
5529 mutex_enter(&stored_port->fp_mutex);
5530 stored_fru =
5531 &stored_port->fp_hba_port_attrs.hba_fru_details;
5532
5533 /* Are these ports on the same HBA? */
5534 if (new_fru->high == stored_fru->high &&
5535 new_fru->low == stored_fru->low) {
5536 /* Now double check driver */
5537 if (strncmp(
5538 new_port->fp_hba_port_attrs.driver_name,
5539 stored_port->fp_hba_port_attrs.driver_name,
5540 FCHBA_DRIVER_NAME_LEN) == 0) {
5541 /* we don't need to grow the list */
5542 skip = 1;
5543 /* looking at a lower port index? */
5544 if (new_fru->port_index <
5545 stored_fru->port_index) {
5546 /* Replace the port in list */
5547 mutex_exit(
5548 &stored_port->fp_mutex);
5549 if (new_port->fp_npiv_type ==
5550 FC_NPIV_PORT) {
5551 break;
5552 }
5553 portList[check] = new_port;
5554 break;
5555 } /* Else, just skip this port */
5556 }
5557 }
5558
5559 mutex_exit(&stored_port->fp_mutex);
5560 }
5561 mutex_exit(&new_port->fp_mutex);
5562
5563 if (!skip) {
5564 /*
5565 * Either this is the first port for this HBA, or
5566 * it's a secondary port and we haven't stored the
5567 * primary/first port for that HBA. In the latter case,
5568 * will just filter it out as we proceed to loop.
5569 */
5570 if (fca_port->port_handle->fp_npiv_type ==
5571 FC_NPIV_PORT) {
5572 continue;
5573 } else {
5574 portList[out++] = fca_port->port_handle;
5575 }
5576 }
5577 }
5578
5579 if (out <= count) {
5580 for (in = 0; in < out; in++) {
5581 (void) ddi_pathname(portList[in]->fp_port_dip,
5582 &pathList[MAXPATHLEN * in]);
5583 }
5584 }
5585 mutex_exit(&fctl_port_lock);
5586 kmem_free(portList, sizeof (*portList) * maxPorts);
5587 return (out);
5588 }
5589
5590 uint32_t
5591 fc_ulp_get_rscn_count(opaque_t port_handle)
5592 {
5593 uint32_t count;
5594 fc_local_port_t *port;
5595
5596 port = (fc_local_port_t *)port_handle;
5597 mutex_enter(&port->fp_mutex);
5598 count = port->fp_rscn_count;
5599 mutex_exit(&port->fp_mutex);
5600
5601 return (count);
5602 }
5603
5604
5605 /*
5606 * This function is a very similar to fctl_add_orphan except that it expects
5607 * that the fp_mutex and pd_mutex of the pd passed in are held coming in.
5608 *
5609 * Note that there is a lock hierarchy here (fp_mutex should be held first) but
5610 * since this function could be called with a different pd's pd_mutex held, we
5611 * should take care not to release fp_mutex in this function.
5612 */
5613 int
5614 fctl_add_orphan_held(fc_local_port_t *port, fc_remote_port_t *pd)
5615 {
5616 int rval = FC_FAILURE;
5617 la_wwn_t pwwn;
5618 fc_orphan_t *orp;
5619 fc_orphan_t *orphan;
5620
5621 ASSERT(MUTEX_HELD(&port->fp_mutex));
5622 ASSERT(MUTEX_HELD(&pd->pd_mutex));
5623
5624 pwwn = pd->pd_port_name;
5625
5626 for (orp = port->fp_orphan_list; orp != NULL; orp = orp->orp_next) {
5627 if (fctl_wwn_cmp(&orp->orp_pwwn, &pwwn) == 0) {
5628 return (FC_SUCCESS);
5629 }
5630 }
5631
5632 orphan = kmem_zalloc(sizeof (*orphan), KM_NOSLEEP);
5633 if (orphan) {
5634 orphan->orp_pwwn = pwwn;
5635 orphan->orp_tstamp = ddi_get_lbolt();
5636
5637 if (port->fp_orphan_list) {
5638 ASSERT(port->fp_orphan_count > 0);
5639 orphan->orp_next = port->fp_orphan_list;
5640 }
5641 port->fp_orphan_list = orphan;
5642 port->fp_orphan_count++;
5643
5644 rval = FC_SUCCESS;
5645 }
5646
5647 return (rval);
5648 }
5649
5650 int
5651 fctl_add_orphan(fc_local_port_t *port, fc_remote_port_t *pd, int sleep)
5652 {
5653 int rval = FC_FAILURE;
5654 la_wwn_t pwwn;
5655 fc_orphan_t *orp;
5656 fc_orphan_t *orphan;
5657
5658 mutex_enter(&port->fp_mutex);
5659
5660 mutex_enter(&pd->pd_mutex);
5661 pwwn = pd->pd_port_name;
5662 mutex_exit(&pd->pd_mutex);
5663
5664 for (orp = port->fp_orphan_list; orp != NULL; orp = orp->orp_next) {
5665 if (fctl_wwn_cmp(&orp->orp_pwwn, &pwwn) == 0) {
5666 mutex_exit(&port->fp_mutex);
5667 return (FC_SUCCESS);
5668 }
5669 }
5670 mutex_exit(&port->fp_mutex);
5671
5672 orphan = kmem_zalloc(sizeof (*orphan), sleep);
5673 if (orphan != NULL) {
5674 mutex_enter(&port->fp_mutex);
5675
5676 orphan->orp_pwwn = pwwn;
5677 orphan->orp_tstamp = ddi_get_lbolt();
5678
5679 if (port->fp_orphan_list) {
5680 ASSERT(port->fp_orphan_count > 0);
5681 orphan->orp_next = port->fp_orphan_list;
5682 }
5683 port->fp_orphan_list = orphan;
5684 port->fp_orphan_count++;
5685 mutex_exit(&port->fp_mutex);
5686
5687 rval = FC_SUCCESS;
5688 }
5689
5690 return (rval);
5691 }
5692
5693
5694 int
5695 fctl_remove_if_orphan(fc_local_port_t *port, la_wwn_t *pwwn)
5696 {
5697 int rval = FC_FAILURE;
5698 fc_orphan_t *prev = NULL;
5699 fc_orphan_t *orp;
5700
5701 mutex_enter(&port->fp_mutex);
5702 for (orp = port->fp_orphan_list; orp != NULL; orp = orp->orp_next) {
5703 if (fctl_wwn_cmp(&orp->orp_pwwn, pwwn) == 0) {
5704 if (prev) {
5705 prev->orp_next = orp->orp_next;
5706 } else {
5707 ASSERT(port->fp_orphan_list == orp);
5708 port->fp_orphan_list = orp->orp_next;
5709 }
5710 port->fp_orphan_count--;
5711 rval = FC_SUCCESS;
5712 break;
5713 }
5714 prev = orp;
5715 }
5716 mutex_exit(&port->fp_mutex);
5717
5718 if (rval == FC_SUCCESS) {
5719 kmem_free(orp, sizeof (*orp));
5720 }
5721
5722 return (rval);
5723 }
5724
5725
5726 static void
5727 fctl_print_if_not_orphan(fc_local_port_t *port, fc_remote_port_t *pd)
5728 {
5729 char ww_name[17];
5730 la_wwn_t pwwn;
5731 fc_orphan_t *orp;
5732
5733 mutex_enter(&port->fp_mutex);
5734
5735 mutex_enter(&pd->pd_mutex);
5736 pwwn = pd->pd_port_name;
5737 mutex_exit(&pd->pd_mutex);
5738
5739 for (orp = port->fp_orphan_list; orp != NULL; orp = orp->orp_next) {
5740 if (fctl_wwn_cmp(&orp->orp_pwwn, &pwwn) == 0) {
5741 mutex_exit(&port->fp_mutex);
5742 return;
5743 }
5744 }
5745 mutex_exit(&port->fp_mutex);
5746
5747 fc_wwn_to_str(&pwwn, ww_name);
5748
5749 cmn_err(CE_WARN, "!fctl(%d): N_x Port with D_ID=%x, PWWN=%s"
5750 " disappeared from fabric", port->fp_instance,
5751 pd->pd_port_id.port_id, ww_name);
5752 }
5753
5754
5755 /* ARGSUSED */
5756 static void
5757 fctl_link_reset_done(opaque_t port_handle, uchar_t result)
5758 {
5759 fc_local_port_t *port = port_handle;
5760
5761 mutex_enter(&port->fp_mutex);
5762 port->fp_soft_state &= ~FP_SOFT_IN_LINK_RESET;
5763 mutex_exit(&port->fp_mutex);
5764
5765 fctl_idle_port(port);
5766 }
5767
5768
5769 static int
5770 fctl_error(int fc_errno, char **errmsg)
5771 {
5772 int count;
5773
5774 for (count = 0; count < sizeof (fc_errlist) /
5775 sizeof (fc_errlist[0]); count++) {
5776 if (fc_errlist[count].fc_errno == fc_errno) {
5777 *errmsg = fc_errlist[count].fc_errname;
5778 return (FC_SUCCESS);
5779 }
5780 }
5781 *errmsg = fctl_undefined;
5782
5783 return (FC_FAILURE);
5784 }
5785
5786
5787 /*
5788 * Return number of successful translations.
5789 * Anybody with some userland programming experience would have
5790 * figured it by now that the return value exactly resembles that
5791 * of scanf(3c). This function returns a count of successful
5792 * translations. It could range from 0 (no match for state, reason,
5793 * action, expln) to 4 (successful matches for all state, reason,
5794 * action, expln) and where translation isn't successful into a
5795 * friendlier message the relevent field is set to "Undefined"
5796 */
5797 static int
5798 fctl_pkt_error(fc_packet_t *pkt, char **state, char **reason,
5799 char **action, char **expln)
5800 {
5801 int ret;
5802 int len;
5803 int index;
5804 fc_pkt_error_t *error;
5805 fc_pkt_reason_t *reason_b; /* Base pointer */
5806 fc_pkt_action_t *action_b; /* Base pointer */
5807 fc_pkt_expln_t *expln_b; /* Base pointer */
5808
5809 ret = 0;
5810 *state = *reason = *action = *expln = fctl_undefined;
5811
5812 len = sizeof (fc_pkt_errlist) / sizeof fc_pkt_errlist[0];
5813 for (index = 0; index < len; index++) {
5814 error = fc_pkt_errlist + index;
5815 if (pkt->pkt_state == error->pkt_state) {
5816 *state = error->pkt_msg;
5817 ret++;
5818
5819 reason_b = error->pkt_reason;
5820 action_b = error->pkt_action;
5821 expln_b = error->pkt_expln;
5822
5823 while (reason_b != NULL &&
5824 reason_b->reason_val != FC_REASON_INVALID) {
5825 if (reason_b->reason_val == pkt->pkt_reason) {
5826 *reason = reason_b->reason_msg;
5827 ret++;
5828 break;
5829 }
5830 reason_b++;
5831 }
5832
5833 while (action_b != NULL &&
5834 action_b->action_val != FC_ACTION_INVALID) {
5835 if (action_b->action_val == pkt->pkt_action) {
5836 *action = action_b->action_msg;
5837 ret++;
5838 break;
5839 }
5840 action_b++;
5841 }
5842
5843 while (expln_b != NULL &&
5844 expln_b->expln_val != FC_EXPLN_INVALID) {
5845 if (expln_b->expln_val == pkt->pkt_expln) {
5846 *expln = expln_b->expln_msg;
5847 ret++;
5848 break;
5849 }
5850 expln_b++;
5851 }
5852 break;
5853 }
5854 }
5855
5856 return (ret);
5857 }
5858
5859
5860 /*
5861 * Remove all port devices that are marked OLD, remove
5862 * corresponding node devices (fc_remote_node_t)
5863 */
5864 void
5865 fctl_remove_oldies(fc_local_port_t *port)
5866 {
5867 int index;
5868 int initiator;
5869 fc_remote_node_t *node;
5870 struct pwwn_hash *head;
5871 fc_remote_port_t *pd;
5872 fc_remote_port_t *old_pd;
5873 fc_remote_port_t *last_pd;
5874
5875 /*
5876 * Nuke all OLD devices
5877 */
5878 mutex_enter(&port->fp_mutex);
5879
5880 for (index = 0; index < pwwn_table_size; index++) {
5881 head = &port->fp_pwwn_table[index];
5882 last_pd = NULL;
5883 pd = head->pwwn_head;
5884
5885 while (pd != NULL) {
5886 mutex_enter(&pd->pd_mutex);
5887 if (pd->pd_type != PORT_DEVICE_OLD) {
5888 mutex_exit(&pd->pd_mutex);
5889 last_pd = pd;
5890 pd = pd->pd_wwn_hnext;
5891 continue;
5892 }
5893
5894 /*
5895 * Remove this from the PWWN hash table
5896 */
5897 old_pd = pd;
5898 pd = old_pd->pd_wwn_hnext;
5899
5900 if (last_pd == NULL) {
5901 ASSERT(old_pd == head->pwwn_head);
5902 head->pwwn_head = pd;
5903 } else {
5904 last_pd->pd_wwn_hnext = pd;
5905 }
5906 head->pwwn_count--;
5907 /*
5908 * Make sure we tie fp_dev_count to the size of the
5909 * pwwn_table
5910 */
5911 port->fp_dev_count--;
5912 old_pd->pd_wwn_hnext = NULL;
5913
5914 fctl_delist_did_table(port, old_pd);
5915 node = old_pd->pd_remote_nodep;
5916 ASSERT(node != NULL);
5917
5918 initiator = (old_pd->pd_recepient ==
5919 PD_PLOGI_INITIATOR) ? 1 : 0;
5920
5921 mutex_exit(&old_pd->pd_mutex);
5922
5923 if (FC_IS_TOP_SWITCH(port->fp_topology) && initiator) {
5924 mutex_exit(&port->fp_mutex);
5925
5926 (void) fctl_add_orphan(port, old_pd,
5927 KM_NOSLEEP);
5928 } else {
5929 mutex_exit(&port->fp_mutex);
5930 }
5931
5932 if (fctl_destroy_remote_port(port, old_pd) == 0) {
5933 if (node) {
5934 fctl_destroy_remote_node(node);
5935 }
5936 }
5937
5938 mutex_enter(&port->fp_mutex);
5939 }
5940 }
5941
5942 mutex_exit(&port->fp_mutex);
5943 }
5944
5945
5946 static void
5947 fctl_check_alpa_list(fc_local_port_t *port, fc_remote_port_t *pd)
5948 {
5949 ASSERT(MUTEX_HELD(&port->fp_mutex));
5950 ASSERT(port->fp_topology == FC_TOP_PRIVATE_LOOP);
5951
5952 if (fctl_is_alpa_present(port, pd->pd_port_id.port_id) == FC_SUCCESS) {
5953 return;
5954 }
5955
5956 cmn_err(CE_WARN, "!fctl(%d): AL_PA=0x%x doesn't exist in LILP map",
5957 port->fp_instance, pd->pd_port_id.port_id);
5958 }
5959
5960
5961 static int
5962 fctl_is_alpa_present(fc_local_port_t *port, uchar_t alpa)
5963 {
5964 int index;
5965
5966 ASSERT(MUTEX_HELD(&port->fp_mutex));
5967 ASSERT(port->fp_topology == FC_TOP_PRIVATE_LOOP);
5968
5969 for (index = 0; index < port->fp_lilp_map.lilp_length; index++) {
5970 if (port->fp_lilp_map.lilp_alpalist[index] == alpa) {
5971 return (FC_SUCCESS);
5972 }
5973 }
5974
5975 return (FC_FAILURE);
5976 }
5977
5978
5979 fc_remote_port_t *
5980 fctl_lookup_pd_by_did(fc_local_port_t *port, uint32_t d_id)
5981 {
5982 int index;
5983 struct pwwn_hash *head;
5984 fc_remote_port_t *pd;
5985
5986 ASSERT(MUTEX_HELD(&port->fp_mutex));
5987
5988 for (index = 0; index < pwwn_table_size; index++) {
5989 head = &port->fp_pwwn_table[index];
5990 pd = head->pwwn_head;
5991
5992 while (pd != NULL) {
5993 mutex_enter(&pd->pd_mutex);
5994 if (pd->pd_port_id.port_id == d_id) {
5995 mutex_exit(&pd->pd_mutex);
5996 return (pd);
5997 }
5998 mutex_exit(&pd->pd_mutex);
5999 pd = pd->pd_wwn_hnext;
6000 }
6001 }
6002
6003 return (pd);
6004 }
6005
6006
6007 /*
6008 * trace debugging
6009 */
6010 void
6011 fc_trace_debug(fc_trace_logq_t *logq, caddr_t name, int dflag, int dlevel,
6012 int errno, const char *fmt, ...)
6013 {
6014 char buf[FC_MAX_TRACE_BUF_LEN + 3]; /* 3 is for "\n" */
6015 char *bufptr = buf;
6016 va_list ap;
6017 int cnt = 0;
6018
6019 if ((dlevel & dflag) == 0) {
6020 return;
6021 }
6022
6023 if (name) {
6024 cnt = snprintf(buf, FC_MAX_TRACE_BUF_LEN + 1, "%d=>%s::",
6025 logq->il_id++, name);
6026 } else {
6027 cnt = snprintf(buf, FC_MAX_TRACE_BUF_LEN + 1, "%d=>trace::",
6028 logq->il_id++);
6029 }
6030
6031 if (cnt < FC_MAX_TRACE_BUF_LEN) {
6032 va_start(ap, fmt);
6033 cnt += vsnprintf(buf + cnt, FC_MAX_TRACE_BUF_LEN + 1 - cnt,
6034 fmt, ap);
6035 va_end(ap);
6036 }
6037
6038 if (cnt > FC_MAX_TRACE_BUF_LEN) {
6039 cnt = FC_MAX_TRACE_BUF_LEN;
6040 }
6041 if (errno && (cnt < FC_MAX_TRACE_BUF_LEN)) {
6042 cnt += snprintf(buf + cnt, FC_MAX_TRACE_BUF_LEN + 1 - cnt,
6043 "error=0x%x\n", errno);
6044 }
6045 (void) snprintf(buf + cnt, FC_MAX_TRACE_BUF_LEN + 3 - cnt, "\n");
6046
6047 if (logq && (dlevel & FC_TRACE_LOG_BUF) != 0) {
6048 fc_trace_logmsg(logq, buf, dlevel);
6049 }
6050
6051 /*
6052 * We do not want to print the log numbers that appear as
6053 * random numbers at the console and messages files, to
6054 * the user.
6055 */
6056 if ((bufptr = strchr(buf, '>')) == NULL) {
6057 /*
6058 * We would have added the a string with "=>" above and so,
6059 * ideally, we should not get here at all. But, if we do,
6060 * we'll just use the full buf.
6061 */
6062 bufptr = buf;
6063 } else {
6064 bufptr++;
6065 }
6066
6067 switch (dlevel & FC_TRACE_LOG_MASK) {
6068 case FC_TRACE_LOG_CONSOLE:
6069 cmn_err(CE_WARN, "%s", bufptr);
6070 break;
6071
6072 case FC_TRACE_LOG_CONSOLE_MSG:
6073 cmn_err(CE_WARN, "%s", bufptr);
6074 break;
6075
6076 case FC_TRACE_LOG_MSG:
6077 cmn_err(CE_WARN, "!%s", bufptr);
6078 break;
6079
6080 default:
6081 break;
6082 }
6083 }
6084
6085
6086 /*
6087 * This function can block
6088 */
6089 fc_trace_logq_t *
6090 fc_trace_alloc_logq(int maxsize)
6091 {
6092 fc_trace_logq_t *logq;
6093
6094 logq = kmem_zalloc(sizeof (*logq), KM_SLEEP);
6095
6096 mutex_init(&logq->il_lock, NULL, MUTEX_DRIVER, NULL);
6097 logq->il_hiwat = maxsize;
6098 logq->il_flags |= FC_TRACE_LOGQ_V2;
6099
6100 return (logq);
6101 }
6102
6103
6104 void
6105 fc_trace_free_logq(fc_trace_logq_t *logq)
6106 {
6107 mutex_enter(&logq->il_lock);
6108 while (logq->il_msgh) {
6109 fc_trace_freemsg(logq);
6110 }
6111 mutex_exit(&logq->il_lock);
6112
6113 mutex_destroy(&logq->il_lock);
6114 kmem_free(logq, sizeof (*logq));
6115 }
6116
6117
6118 /* ARGSUSED */
6119 void
6120 fc_trace_logmsg(fc_trace_logq_t *logq, caddr_t buf, int level)
6121 {
6122 int qfull = 0;
6123 fc_trace_dmsg_t *dmsg;
6124
6125 dmsg = kmem_alloc(sizeof (*dmsg), KM_NOSLEEP);
6126 if (dmsg == NULL) {
6127 mutex_enter(&logq->il_lock);
6128 logq->il_afail++;
6129 mutex_exit(&logq->il_lock);
6130
6131 return;
6132 }
6133
6134 gethrestime(&dmsg->id_time);
6135
6136 dmsg->id_size = strlen(buf) + 1;
6137 dmsg->id_buf = kmem_alloc(dmsg->id_size, KM_NOSLEEP);
6138 if (dmsg->id_buf == NULL) {
6139 kmem_free(dmsg, sizeof (*dmsg));
6140
6141 mutex_enter(&logq->il_lock);
6142 logq->il_afail++;
6143 mutex_exit(&logq->il_lock);
6144
6145 return;
6146 }
6147 bcopy(buf, dmsg->id_buf, strlen(buf));
6148 dmsg->id_buf[strlen(buf)] = '\0';
6149
6150 mutex_enter(&logq->il_lock);
6151
6152 logq->il_size += dmsg->id_size;
6153 if (logq->il_size >= logq->il_hiwat) {
6154 qfull = 1;
6155 }
6156
6157 if (qfull) {
6158 fc_trace_freemsg(logq);
6159 }
6160
6161 dmsg->id_next = NULL;
6162 if (logq->il_msgt) {
6163 logq->il_msgt->id_next = dmsg;
6164 } else {
6165 ASSERT(logq->il_msgh == NULL);
6166 logq->il_msgh = dmsg;
6167 }
6168 logq->il_msgt = dmsg;
6169
6170 mutex_exit(&logq->il_lock);
6171 }
6172
6173
6174 static void
6175 fc_trace_freemsg(fc_trace_logq_t *logq)
6176 {
6177 fc_trace_dmsg_t *dmsg;
6178
6179 ASSERT(MUTEX_HELD(&logq->il_lock));
6180
6181 if ((dmsg = logq->il_msgh) != NULL) {
6182 logq->il_msgh = dmsg->id_next;
6183 if (logq->il_msgh == NULL) {
6184 logq->il_msgt = NULL;
6185 }
6186
6187 logq->il_size -= dmsg->id_size;
6188 kmem_free(dmsg->id_buf, dmsg->id_size);
6189 kmem_free(dmsg, sizeof (*dmsg));
6190 } else {
6191 ASSERT(logq->il_msgt == NULL);
6192 }
6193 }
6194
6195 /*
6196 * Used by T11 FC-HBA to fetch discovered ports by index.
6197 * Returns NULL if the index isn't valid.
6198 */
6199 fc_remote_port_t *
6200 fctl_lookup_pd_by_index(fc_local_port_t *port, uint32_t index)
6201 {
6202 int outer;
6203 int match = 0;
6204 struct pwwn_hash *head;
6205 fc_remote_port_t *pd;
6206
6207 ASSERT(MUTEX_HELD(&port->fp_mutex));
6208
6209 for (outer = 0;
6210 outer < pwwn_table_size && match <= index;
6211 outer++) {
6212 head = &port->fp_pwwn_table[outer];
6213 pd = head->pwwn_head;
6214 if (pd != NULL) match ++;
6215
6216 while (pd != NULL && match <= index) {
6217 pd = pd->pd_wwn_hnext;
6218 if (pd != NULL) match ++;
6219 }
6220 }
6221
6222 return (pd);
6223 }
6224
6225 /*
6226 * Search for a matching Node or Port WWN in the discovered port list
6227 */
6228 fc_remote_port_t *
6229 fctl_lookup_pd_by_wwn(fc_local_port_t *port, la_wwn_t wwn)
6230 {
6231 int index;
6232 struct pwwn_hash *head;
6233 fc_remote_port_t *pd;
6234
6235 ASSERT(MUTEX_HELD(&port->fp_mutex));
6236
6237 for (index = 0; index < pwwn_table_size; index++) {
6238 head = &port->fp_pwwn_table[index];
6239 pd = head->pwwn_head;
6240
6241 while (pd != NULL) {
6242 mutex_enter(&pd->pd_mutex);
6243 if (bcmp(pd->pd_port_name.raw_wwn, wwn.raw_wwn,
6244 sizeof (la_wwn_t)) == 0) {
6245 mutex_exit(&pd->pd_mutex);
6246 return (pd);
6247 }
6248 if (bcmp(pd->pd_remote_nodep->fd_node_name.raw_wwn,
6249 wwn.raw_wwn, sizeof (la_wwn_t)) == 0) {
6250 mutex_exit(&pd->pd_mutex);
6251 return (pd);
6252 }
6253 mutex_exit(&pd->pd_mutex);
6254 pd = pd->pd_wwn_hnext;
6255 }
6256 }
6257 /* No match */
6258 return (NULL);
6259 }
6260
6261
6262 /*
6263 * Count the number of ports on this adapter.
6264 * This routine will walk the port list and count up the number of adapters
6265 * with matching fp_hba_port_attrs.hba_fru_details.high and
6266 * fp_hba_port_attrs.hba_fru_details.low.
6267 *
6268 * port->fp_mutex must not be held.
6269 */
6270 int
6271 fctl_count_fru_ports(fc_local_port_t *port, int npivflag)
6272 {
6273 fca_hba_fru_details_t *fru;
6274 fc_fca_port_t *fca_port;
6275 fc_local_port_t *tmpPort = NULL;
6276 uint32_t count = 1;
6277
6278 mutex_enter(&fctl_port_lock);
6279
6280 mutex_enter(&port->fp_mutex);
6281 fru = &port->fp_hba_port_attrs.hba_fru_details;
6282
6283 /* Detect FCA drivers that don't support linking HBA ports */
6284 if (fru->high == 0 && fru->low == 0 && fru->port_index == 0) {
6285 mutex_exit(&port->fp_mutex);
6286 mutex_exit(&fctl_port_lock);
6287 return (1);
6288 }
6289
6290 for (fca_port = fctl_fca_portlist; fca_port != NULL;
6291 fca_port = fca_port->port_next) {
6292 tmpPort = fca_port->port_handle;
6293 if (tmpPort == port) {
6294 continue;
6295 }
6296 mutex_enter(&tmpPort->fp_mutex);
6297
6298 /*
6299 * If an FCA driver returns unique fru->high and fru->low for
6300 * ports on the same card, there is no way for the transport
6301 * layer to determine that the two ports on the same FRU. So,
6302 * the discovery of the ports on a same FRU is limited to what
6303 * the FCA driver can report back.
6304 */
6305 if (tmpPort->fp_hba_port_attrs.hba_fru_details.high ==
6306 fru->high &&
6307 tmpPort->fp_hba_port_attrs.hba_fru_details.low ==
6308 fru->low) {
6309 /* Now double check driver */
6310 if (strncmp(port->fp_hba_port_attrs.driver_name,
6311 tmpPort->fp_hba_port_attrs.driver_name,
6312 FCHBA_DRIVER_NAME_LEN) == 0) {
6313 if (!npivflag ||
6314 (tmpPort->fp_npiv_type != FC_NPIV_PORT)) {
6315 count++;
6316 }
6317 } /* Else, different FCA driver */
6318 } /* Else not the same HBA FRU */
6319 mutex_exit(&tmpPort->fp_mutex);
6320 }
6321
6322 mutex_exit(&port->fp_mutex);
6323 mutex_exit(&fctl_port_lock);
6324
6325 return (count);
6326 }
6327
6328 fc_fca_port_t *
6329 fctl_local_port_list_add(fc_fca_port_t *list, fc_local_port_t *port)
6330 {
6331 fc_fca_port_t *tmp = list, *newentry = NULL;
6332
6333 newentry = kmem_zalloc(sizeof (fc_fca_port_t), KM_NOSLEEP);
6334 if (newentry == NULL) {
6335 return (list);
6336 }
6337 newentry->port_handle = port;
6338
6339 if (tmp == NULL) {
6340 return (newentry);
6341 }
6342 while (tmp->port_next != NULL) tmp = tmp->port_next;
6343 tmp->port_next = newentry;
6344
6345 return (list);
6346 }
6347
6348 void
6349 fctl_local_port_list_free(fc_fca_port_t *list)
6350 {
6351 fc_fca_port_t *tmp = list, *nextentry;
6352
6353 if (tmp == NULL) {
6354 return;
6355 }
6356
6357 while (tmp != NULL) {
6358 nextentry = tmp->port_next;
6359 kmem_free(tmp, sizeof (*tmp));
6360 tmp = nextentry;
6361 }
6362 }
6363
6364 /*
6365 * Fetch another port on the HBA FRU based on index.
6366 * Returns NULL if index not found.
6367 *
6368 * port->fp_mutex must not be held.
6369 */
6370 fc_local_port_t *
6371 fctl_get_adapter_port_by_index(fc_local_port_t *port, uint32_t port_index)
6372 {
6373 fca_hba_fru_details_t *fru;
6374 fc_fca_port_t *fca_port;
6375 fc_local_port_t *tmpPort = NULL;
6376 fc_fca_port_t *list = NULL, *tmpEntry;
6377 fc_local_port_t *phyPort, *virPort = NULL;
6378 int index, phyPortNum = 0;
6379
6380 mutex_enter(&fctl_port_lock);
6381
6382 mutex_enter(&port->fp_mutex);
6383 fru = &port->fp_hba_port_attrs.hba_fru_details;
6384
6385 /* Are we looking for this port? */
6386 if (fru->port_index == port_index) {
6387 mutex_exit(&port->fp_mutex);
6388 mutex_exit(&fctl_port_lock);
6389 return (port);
6390 }
6391
6392 /* Detect FCA drivers that don't support linking HBA ports */
6393 if (fru->high == 0 && fru->low == 0 && fru->port_index == 0) {
6394 mutex_exit(&port->fp_mutex);
6395 mutex_exit(&fctl_port_lock);
6396 return (NULL);
6397 }
6398
6399 list = fctl_local_port_list_add(list, port);
6400 phyPortNum++;
6401 /* Loop through all known ports */
6402 for (fca_port = fctl_fca_portlist; fca_port != NULL;
6403 fca_port = fca_port->port_next) {
6404 tmpPort = fca_port->port_handle;
6405 if (tmpPort == port) {
6406 /* Skip the port that was passed in as the argument */
6407 continue;
6408 }
6409 mutex_enter(&tmpPort->fp_mutex);
6410
6411 /* See if this port is on the same HBA FRU (fast check) */
6412 if (tmpPort->fp_hba_port_attrs.hba_fru_details.high ==
6413 fru->high &&
6414 tmpPort->fp_hba_port_attrs.hba_fru_details.low ==
6415 fru->low) {
6416 /* Now double check driver (slower check) */
6417 if (strncmp(port->fp_hba_port_attrs.driver_name,
6418 tmpPort->fp_hba_port_attrs.driver_name,
6419 FCHBA_DRIVER_NAME_LEN) == 0) {
6420
6421 fru =
6422 &tmpPort->fp_hba_port_attrs.hba_fru_details;
6423 /* Check for the matching port_index */
6424 if ((tmpPort->fp_npiv_type != FC_NPIV_PORT) &&
6425 (fru->port_index == port_index)) {
6426 /* Found it! */
6427 mutex_exit(&tmpPort->fp_mutex);
6428 mutex_exit(&port->fp_mutex);
6429 mutex_exit(&fctl_port_lock);
6430 fctl_local_port_list_free(list);
6431 return (tmpPort);
6432 }
6433 if (tmpPort->fp_npiv_type != FC_NPIV_PORT) {
6434 (void) fctl_local_port_list_add(list,
6435 tmpPort);
6436 phyPortNum++;
6437 }
6438 } /* Else, different FCA driver */
6439 } /* Else not the same HBA FRU */
6440 mutex_exit(&tmpPort->fp_mutex);
6441
6442 }
6443
6444 /* scan all physical port on same chip to find virtual port */
6445 tmpEntry = list;
6446 index = phyPortNum - 1;
6447 virPort = NULL;
6448 while (index < port_index) {
6449 if (tmpEntry == NULL) {
6450 break;
6451 }
6452 if (virPort == NULL) {
6453 phyPort = tmpEntry->port_handle;
6454 virPort = phyPort->fp_port_next;
6455 if (virPort == NULL) {
6456 tmpEntry = tmpEntry->port_next;
6457 continue;
6458 }
6459 } else {
6460 virPort = virPort->fp_port_next;
6461 }
6462 if (virPort == phyPort) {
6463 tmpEntry = tmpEntry->port_next;
6464 virPort = NULL;
6465 } else {
6466 index++;
6467 }
6468 }
6469 mutex_exit(&port->fp_mutex);
6470 mutex_exit(&fctl_port_lock);
6471
6472 fctl_local_port_list_free(list);
6473 if (virPort) {
6474 return (virPort);
6475 }
6476 return (NULL);
6477 }
6478
6479 int
6480 fctl_busy_port(fc_local_port_t *port)
6481 {
6482 ASSERT(!MUTEX_HELD(&port->fp_mutex));
6483
6484 mutex_enter(&port->fp_mutex);
6485 if (port->fp_soft_state & FP_SOFT_NO_PMCOMP) {
6486 /*
6487 * If fctl_busy_port() is called before we've registered our
6488 * PM components, we return success. We need to be aware of
6489 * this because the caller will eventually call fctl_idle_port.
6490 * This wouldn't be a problem except that if we have
6491 * registered our PM components in the meantime, we will
6492 * then be idling a component that was never busied. PM
6493 * will be very unhappy if we do this. Thus, we keep
6494 * track of this with port->fp_pm_busy_nocomp.
6495 */
6496 port->fp_pm_busy_nocomp++;
6497 mutex_exit(&port->fp_mutex);
6498 return (0);
6499 }
6500 port->fp_pm_busy++;
6501 mutex_exit(&port->fp_mutex);
6502
6503 if (pm_busy_component(port->fp_port_dip,
6504 FP_PM_COMPONENT) != DDI_SUCCESS) {
6505 mutex_enter(&port->fp_mutex);
6506 port->fp_pm_busy--;
6507 mutex_exit(&port->fp_mutex);
6508 return (ENXIO);
6509 }
6510
6511 mutex_enter(&port->fp_mutex);
6512 if (port->fp_pm_level == FP_PM_PORT_DOWN) {
6513 mutex_exit(&port->fp_mutex);
6514 if (pm_raise_power(port->fp_port_dip, FP_PM_COMPONENT,
6515 FP_PM_PORT_UP) != DDI_SUCCESS) {
6516
6517 mutex_enter(&port->fp_mutex);
6518 port->fp_pm_busy--;
6519 mutex_exit(&port->fp_mutex);
6520
6521 (void) pm_idle_component(port->fp_port_dip,
6522 FP_PM_COMPONENT);
6523 return (EIO);
6524 }
6525 return (0);
6526 }
6527 mutex_exit(&port->fp_mutex);
6528 return (0);
6529 }
6530
6531 void
6532 fctl_idle_port(fc_local_port_t *port)
6533 {
6534 ASSERT(!MUTEX_HELD(&port->fp_mutex));
6535
6536 mutex_enter(&port->fp_mutex);
6537
6538 /*
6539 * If port->fp_pm_busy_nocomp is > 0, that means somebody had
6540 * called fctl_busy_port prior to us registering our PM components.
6541 * In that case, we just decrement fp_pm_busy_nocomp and return.
6542 */
6543
6544 if (port->fp_pm_busy_nocomp > 0) {
6545 port->fp_pm_busy_nocomp--;
6546 mutex_exit(&port->fp_mutex);
6547 return;
6548 }
6549
6550 port->fp_pm_busy--;
6551 mutex_exit(&port->fp_mutex);
6552
6553 (void) pm_idle_component(port->fp_port_dip, FP_PM_COMPONENT);
6554 }
6555
6556 /*
6557 * Function: fctl_tc_timer
6558 *
6559 * Description: Resets the value of the timed counter.
6560 *
6561 * Arguments: *tc Timed counter
6562 *
6563 * Return Value: Nothing
6564 *
6565 * Context: Kernel context.
6566 */
6567 static void
6568 fctl_tc_timer(void *arg)
6569 {
6570 timed_counter_t *tc = (timed_counter_t *)arg;
6571
6572 ASSERT(tc != NULL);
6573 ASSERT(tc->sig == tc);
6574
6575 mutex_enter(&tc->mutex);
6576 if (tc->active) {
6577 tc->active = B_FALSE;
6578 tc->counter = 0;
6579 }
6580 mutex_exit(&tc->mutex);
6581 }
6582
6583 /*
6584 * Function: fctl_tc_constructor
6585 *
6586 * Description: Constructs a timed counter.
6587 *
6588 * Arguments: *tc Address where the timed counter will reside.
6589 * max_value Maximum value the counter is allowed to take.
6590 * timer Number of microseconds after which the counter
6591 * will be reset. The timer is started when the
6592 * value of the counter goes from 0 to 1.
6593 *
6594 * Return Value: Nothing
6595 *
6596 * Context: Kernel context.
6597 */
6598 void
6599 fctl_tc_constructor(timed_counter_t *tc, uint32_t max_value, clock_t timer)
6600 {
6601 ASSERT(tc != NULL);
6602 ASSERT(tc->sig != tc);
6603
6604 bzero(tc, sizeof (*tc));
6605 mutex_init(&tc->mutex, NULL, MUTEX_DRIVER, NULL);
6606 tc->timer = drv_usectohz(timer);
6607 tc->active = B_FALSE;
6608 tc->maxed_out = B_FALSE;
6609 tc->max_value = max_value;
6610 tc->sig = tc;
6611 }
6612
6613 /*
6614 * Function: fctl_tc_destructor
6615 *
6616 * Description: Destroyes a timed counter.
6617 *
6618 * Arguments: *tc Timed counter to destroy.
6619 *
6620 * Return Value: Nothing
6621 *
6622 * Context: Kernel context.
6623 */
6624 void
6625 fctl_tc_destructor(timed_counter_t *tc)
6626 {
6627 ASSERT(tc != NULL);
6628 ASSERT(tc->sig == tc);
6629 ASSERT(!mutex_owned(&tc->mutex));
6630
6631 mutex_enter(&tc->mutex);
6632 if (tc->active) {
6633 tc->active = B_FALSE;
6634 mutex_exit(&tc->mutex);
6635 (void) untimeout(tc->tid);
6636 mutex_enter(&tc->mutex);
6637 tc->sig = NULL;
6638 }
6639 mutex_exit(&tc->mutex);
6640 mutex_destroy(&tc->mutex);
6641 }
6642
6643 /*
6644 * Function: fctl_tc_increment
6645 *
6646 * Description: Increments a timed counter
6647 *
6648 * Arguments: *tc Timed counter to increment.
6649 *
6650 * Return Value: B_TRUE Counter reached the max value.
6651 * B_FALSE Counter hasn't reached the max value.
6652 *
6653 * Context: Kernel or interrupt context.
6654 */
6655 boolean_t
6656 fctl_tc_increment(timed_counter_t *tc)
6657 {
6658 ASSERT(tc != NULL);
6659 ASSERT(tc->sig == tc);
6660
6661 mutex_enter(&tc->mutex);
6662 if (!tc->maxed_out) {
6663 /* Hasn't maxed out yet. */
6664 ++tc->counter;
6665 if (tc->counter >= tc->max_value) {
6666 /* Just maxed out. */
6667 tc->maxed_out = B_TRUE;
6668 }
6669 if (!tc->active) {
6670 tc->tid = timeout(fctl_tc_timer, tc, tc->timer);
6671 tc->active = B_TRUE;
6672 }
6673 }
6674 mutex_exit(&tc->mutex);
6675
6676 return (tc->maxed_out);
6677 }
6678
6679 /*
6680 * Function: fctl_tc_reset
6681 *
6682 * Description: Resets a timed counter. The caller of this function has to
6683 * to make sure that while in fctl_tc_reset() fctl_tc_increment()
6684 * is not called.
6685 *
6686 * Arguments: *tc Timed counter to reset.
6687 *
6688 * Return Value: 0 Counter reached the max value.
6689 * Not 0 Counter hasn't reached the max value.
6690 *
6691 * Context: Kernel or interrupt context.
6692 */
6693 void
6694 fctl_tc_reset(timed_counter_t *tc)
6695 {
6696 ASSERT(tc != NULL);
6697 ASSERT(tc->sig == tc);
6698
6699 mutex_enter(&tc->mutex);
6700 tc->counter = 0;
6701 tc->maxed_out = B_FALSE;
6702 if (tc->active) {
6703 tc->active = B_FALSE;
6704 (void) untimeout(tc->tid);
6705 }
6706 mutex_exit(&tc->mutex);
6707 }
6708
6709 void
6710 fc_ulp_log_device_event(opaque_t port_handle, int type)
6711 {
6712 fc_local_port_t *port = port_handle;
6713 nvlist_t *attr_list;
6714
6715 if (nvlist_alloc(&attr_list, NV_UNIQUE_NAME_TYPE,
6716 KM_SLEEP) != DDI_SUCCESS) {
6717 return;
6718 }
6719
6720 if (nvlist_add_uint32(attr_list, "instance",
6721 port->fp_instance) != DDI_SUCCESS) {
6722 goto error;
6723 }
6724
6725 if (nvlist_add_byte_array(attr_list, "port-wwn",
6726 port->fp_service_params.nport_ww_name.raw_wwn,
6727 sizeof (la_wwn_t)) != DDI_SUCCESS) {
6728 goto error;
6729 }
6730
6731 (void) ddi_log_sysevent(port->fp_port_dip, DDI_VENDOR_SUNW, EC_SUNFC,
6732 (type == FC_ULP_DEVICE_ONLINE) ?
6733 ESC_SUNFC_DEVICE_ONLINE : ESC_SUNFC_DEVICE_OFFLINE,
6734 attr_list, NULL, DDI_SLEEP);
6735 nvlist_free(attr_list);
6736 return;
6737
6738 error:
6739 nvlist_free(attr_list);
6740 }