1 /* fc.c: Generic Fibre Channel and FC4 SCSI driver.
3 * Copyright (C) 1997,1998,1999 Jakub Jelinek (jj@ultra.linux.cz)
4 * Copyright (C) 1997,1998 Jirka Hanika (geo@ff.cuni.cz)
6 * There are two kinds of Fibre Channel adapters used in Linux. Either
7 * the adapter is "smart" and does all FC bookkeeping by itself and
8 * just presents a standard SCSI interface to the operating system
9 * (that's e.g. the case with Qlogic FC cards), or leaves most of the FC
10 * bookkeeping to the OS (e.g. soc, socal). Drivers for the former adapters
11 * will look like normal SCSI drivers (with the exception of max_id will be
12 * usually 127), the latter on the other side allows SCSI, IP over FC and other
13 * protocols. This driver tree is for the latter adapters.
15 * This file should support both Point-to-Point and Arbitrated Loop topologies.
18 * Fibre Channel Physical & Signaling Interface (FC-PH), dpANS, 1994
19 * dpANS Fibre Channel Protocol for SCSI (X3.269-199X), Rev. 012, 1995
20 * Fibre Channel Arbitrated Loop (FC-AL), Rev. 4.5, 1995
21 * Fibre Channel Private Loop SCSI Direct Attach (FC-PLDA), Rev. 2.1, 1997
24 #include <linux/module.h>
25 #include <linux/kernel.h>
26 #include <linux/jiffies.h>
27 #include <linux/types.h>
28 #include <linux/fcntl.h>
29 #include <linux/interrupt.h>
30 #include <linux/ptrace.h>
31 #include <linux/ioport.h>
33 #include <linux/slab.h>
34 #include <linux/string.h>
35 #include <linux/init.h>
37 #include <asm/pgtable.h>
39 #include <asm/semaphore.h>
41 #include <scsi/scsi_host.h>
45 #define fc_printk printk ("%s: ", fc->name); printk
48 #define FCD(x) fc_printk x;
49 #define FCND(x) printk ("FC: "); printk x;
56 #define dma_alloc_consistent(d,s,p) sbus_alloc_consistent(d,s,p)
57 #define dma_free_consistent(d,s,v,h) sbus_free_consistent(d,s,v,h)
58 #define dma_map_single(d,v,s,dir) sbus_map_single(d,v,s,dir)
59 #define dma_unmap_single(d,h,s,dir) sbus_unmap_single(d,h,s,dir)
60 #define dma_map_sg(d,s,n,dir) sbus_map_sg(d,s,n,dir)
61 #define dma_unmap_sg(d,s,n,dir) sbus_unmap_sg(d,s,n,dir)
63 #define dma_alloc_consistent(d,s,p) pci_alloc_consistent(d,s,p)
64 #define dma_free_consistent(d,s,v,h) pci_free_consistent(d,s,v,h)
65 #define dma_map_single(d,v,s,dir) pci_map_single(d,v,s,dir)
66 #define dma_unmap_single(d,h,s,dir) pci_unmap_single(d,h,s,dir)
67 #define dma_map_sg(d,s,n,dir) pci_map_sg(d,s,n,dir)
68 #define dma_unmap_sg(d,s,n,dir) pci_unmap_sg(d,s,n,dir)
71 #define FCP_CMND(SCpnt) ((fcp_cmnd *)&(SCpnt->SCp))
72 #define FC_SCMND(SCpnt) ((fc_channel *)(SCpnt->device->host->hostdata[0]))
73 #define SC_FCMND(fcmnd) ((Scsi_Cmnd *)((long)fcmnd - (long)&(((Scsi_Cmnd *)0)->SCp)))
75 static int fcp_scsi_queue_it(fc_channel
*, Scsi_Cmnd
*, fcp_cmnd
*, int);
76 void fcp_queue_empty(fc_channel
*);
78 static void fcp_scsi_insert_queue (fc_channel
*fc
, fcp_cmnd
*fcmd
)
85 fc
->scsi_que
->prev
->next
= fcmd
;
86 fcmd
->prev
= fc
->scsi_que
->prev
;
87 fc
->scsi_que
->prev
= fcmd
;
88 fcmd
->next
= fc
->scsi_que
;
92 static void fcp_scsi_remove_queue (fc_channel
*fc
, fcp_cmnd
*fcmd
)
94 if (fcmd
== fcmd
->next
) {
98 if (fcmd
== fc
->scsi_que
)
99 fc
->scsi_que
= fcmd
->next
;
100 fcmd
->prev
->next
= fcmd
->next
;
101 fcmd
->next
->prev
= fcmd
->prev
;
104 fc_channel
*fc_channels
= NULL
;
106 #define LSMAGIC 620829043
109 struct semaphore sem
;
115 struct timer_list timer
;
116 unsigned char grace
[0];
119 #define LSOMAGIC 654907799
122 struct semaphore sem
;
127 struct timer_list timer
;
130 #define LSEMAGIC 84482456
133 struct semaphore sem
;
136 struct timer_list timer
;
139 static void fcp_login_timeout(unsigned long data
)
142 FCND(("Login timeout\n"))
146 static void fcp_login_done(fc_channel
*fc
, int i
, int status
)
151 ls
*l
= (ls
*)fc
->ls
;
153 FCD(("Login done %d %d\n", i
, status
))
155 if (fc
->state
== FC_STATE_FPORT_OK
) {
156 FCD(("Additional FPORT_OK received with status %d\n", status
))
160 case FC_STATUS_OK
: /* Oh, we found a fabric */
161 case FC_STATUS_P_RJT
: /* Oh, we haven't found any */
162 fc
->state
= FC_STATE_FPORT_OK
;
164 plogi
= l
->logi
+ 3 * i
;
165 dma_unmap_single (fc
->dev
, fcmd
->cmd
, 3 * sizeof(logi
),
167 plogi
->code
= LS_PLOGI
;
168 memcpy (&plogi
->nport_wwn
, &fc
->wwn_nport
, sizeof(fc_wwn
));
169 memcpy (&plogi
->node_wwn
, &fc
->wwn_node
, sizeof(fc_wwn
));
170 memcpy (&plogi
->common
, fc
->common_svc
, sizeof(common_svc_parm
));
171 memcpy (&plogi
->class1
, fc
->class_svcs
, 3*sizeof(svc_parm
));
173 fcmd
->token
+= l
->count
;
174 FILL_FCHDR_RCTL_DID(fch
, R_CTL_ELS_REQ
, fc
->did
);
175 FILL_FCHDR_SID(fch
, fc
->sid
);
179 unsigned *x
= (unsigned *)plogi
;
181 for (i
= 0; i
< 21; i
++)
182 printk ("%08x ", x
[i
]);
186 fcmd
->cmd
= dma_map_single (fc
->dev
, plogi
, 3 * sizeof(logi
),
188 fcmd
->rsp
= fcmd
->cmd
+ 2 * sizeof(logi
);
189 if (fc
->hw_enque (fc
, fcmd
))
190 printk ("FC: Cannot enque PLOGI packet on %s\n", fc
->name
);
192 case FC_STATUS_ERR_OFFLINE
:
193 fc
->state
= FC_STATE_MAYBEOFFLINE
;
194 FCD (("FC is offline %d\n", l
->grace
[i
]))
197 printk ("FLOGI failed for %s with status %d\n", fc
->name
, status
);
198 /* Do some sort of error recovery here */
203 if (fc
->state
!= FC_STATE_FPORT_OK
) {
204 FCD(("Unexpected N-PORT rsp received"))
209 plogi
= l
->logi
+ 3 * i
;
210 dma_unmap_single (fc
->dev
, l
->fcmds
[i
].cmd
, 3 * sizeof(logi
),
212 if (!fc
->wwn_dest
.lo
&& !fc
->wwn_dest
.hi
) {
213 memcpy (&fc
->wwn_dest
, &plogi
[1].node_wwn
, sizeof(fc_wwn
));
214 FCD(("Dest WWN %08x%08x\n", *(u32
*)&fc
->wwn_dest
, fc
->wwn_dest
.lo
))
215 } else if (fc
->wwn_dest
.lo
!= plogi
[1].node_wwn
.lo
||
216 fc
->wwn_dest
.hi
!= plogi
[1].node_wwn
.hi
) {
217 printk ("%s: mismatch in wwns. Got %08x%08x, expected %08x%08x\n",
219 *(u32
*)&plogi
[1].node_wwn
, plogi
[1].node_wwn
.lo
,
220 *(u32
*)&fc
->wwn_dest
, fc
->wwn_dest
.lo
);
222 fc
->state
= FC_STATE_ONLINE
;
223 printk ("%s: ONLINE\n", fc
->name
);
224 if (atomic_dec_and_test (&l
->todo
))
227 case FC_STATUS_ERR_OFFLINE
:
228 fc
->state
= FC_STATE_OFFLINE
;
229 dma_unmap_single (fc
->dev
, l
->fcmds
[i
].cmd
, 3 * sizeof(logi
),
231 printk ("%s: FC is offline\n", fc
->name
);
232 if (atomic_dec_and_test (&l
->todo
))
236 printk ("PLOGI failed for %s with status %d\n", fc
->name
, status
);
237 /* Do some sort of error recovery here */
243 static void fcp_report_map_done(fc_channel
*fc
, int i
, int status
)
248 ls
*l
= (ls
*)fc
->ls
;
251 FCD(("Report map done %d %d\n", i
, status
))
253 case FC_STATUS_OK
: /* Ok, let's have a fun on a loop */
254 dma_unmap_single (fc
->dev
, l
->fcmds
[i
].cmd
, 3 * sizeof(logi
),
256 p
= (fc_al_posmap
*)(l
->logi
+ 3 * i
);
260 FCD(("%08x\n", u
[0]))
262 FCD(("%08x.%08x.%08x.%08x.%08x.%08x.%08x.%08x\n", u
[0],u
[1],u
[2],u
[3],u
[4],u
[5],u
[6],u
[7]))
265 if ((p
->magic
& 0xffff0000) != FC_AL_LILP
|| !p
->len
) {
266 printk ("FC: Bad magic from REPORT_AL_MAP on %s - %08x\n", fc
->name
, p
->magic
);
267 fc
->state
= FC_STATE_OFFLINE
;
269 fc
->posmap
= (fcp_posmap
*)kmalloc(sizeof(fcp_posmap
)+p
->len
, GFP_KERNEL
);
271 printk("FC: Not enough memory, offlining channel\n");
272 fc
->state
= FC_STATE_OFFLINE
;
275 memset(fc
->posmap
, 0, sizeof(fcp_posmap
)+p
->len
);
276 /* FIXME: This is where SOCAL transfers our AL-PA.
277 Keep it here till we found out what other cards do... */
278 fc
->sid
= (p
->magic
& 0xff);
279 for (i
= 0; i
< p
->len
; i
++)
280 if (p
->alpa
[i
] == fc
->sid
)
289 fc
->posmap
->len
= p
->len
;
290 for (j
= 0; j
< p
->len
; j
++) {
292 fc
->posmap
->list
[j
] = p
->alpa
[i
++];
294 fc
->state
= FC_STATE_ONLINE
;
297 printk ("%s: ONLINE\n", fc
->name
);
298 if (atomic_dec_and_test (&l
->todo
))
301 case FC_STATUS_POINTTOPOINT
: /* We're Point-to-Point, no AL... */
302 FCD(("SID %d DID %d\n", fc
->sid
, fc
->did
))
304 dma_unmap_single(fc
->dev
, fcmd
->cmd
, 3 * sizeof(logi
),
307 memset(l
->logi
+ 3 * i
, 0, 3 * sizeof(logi
));
308 FILL_FCHDR_RCTL_DID(fch
, R_CTL_ELS_REQ
, FS_FABRIC_F_PORT
);
309 FILL_FCHDR_SID(fch
, 0);
310 FILL_FCHDR_TYPE_FCTL(fch
, TYPE_EXTENDED_LS
, F_CTL_FIRST_SEQ
| F_CTL_SEQ_INITIATIVE
);
311 FILL_FCHDR_SEQ_DF_SEQ(fch
, 0, 0, 0);
312 FILL_FCHDR_OXRX(fch
, 0xffff, 0xffff);
314 l
->logi
[3 * i
].code
= LS_FLOGI
;
315 fcmd
->cmd
= dma_map_single (fc
->dev
, l
->logi
+ 3 * i
, 3 * sizeof(logi
),
317 fcmd
->rsp
= fcmd
->cmd
+ sizeof(logi
);
318 fcmd
->cmdlen
= sizeof(logi
);
319 fcmd
->rsplen
= sizeof(logi
);
320 fcmd
->data
= (dma_addr_t
)NULL
;
321 fcmd
->class = FC_CLASS_SIMPLE
;
322 fcmd
->proto
= TYPE_EXTENDED_LS
;
323 if (fc
->hw_enque (fc
, fcmd
))
324 printk ("FC: Cannot enque FLOGI packet on %s\n", fc
->name
);
326 case FC_STATUS_ERR_OFFLINE
:
327 fc
->state
= FC_STATE_MAYBEOFFLINE
;
328 FCD (("FC is offline %d\n", l
->grace
[i
]))
331 printk ("FLOGI failed for %s with status %d\n", fc
->name
, status
);
332 /* Do some sort of error recovery here */
337 void fcp_register(fc_channel
*fc
, u8 type
, int unregister
)
340 int slots
= (fc
->can_queue
* 3) >> 1;
342 FCND(("Going to %sregister\n", unregister
? "un" : ""))
344 if (type
== TYPE_SCSI_FCP
) {
346 fc
->scsi_cmd_pool
= (fcp_cmd
*)
347 dma_alloc_consistent (fc
->dev
,
348 slots
* (sizeof (fcp_cmd
) + fc
->rsp_size
),
350 fc
->scsi_rsp_pool
= (char *)(fc
->scsi_cmd_pool
+ slots
);
351 fc
->dma_scsi_rsp
= fc
->dma_scsi_cmd
+ slots
* sizeof (fcp_cmd
);
352 fc
->scsi_bitmap_end
= (slots
+ 63) & ~63;
353 size
= fc
->scsi_bitmap_end
/ 8;
354 fc
->scsi_bitmap
= kmalloc (size
, GFP_KERNEL
);
355 memset (fc
->scsi_bitmap
, 0, size
);
356 set_bit (0, fc
->scsi_bitmap
);
357 for (i
= fc
->can_queue
; i
< fc
->scsi_bitmap_end
; i
++)
358 set_bit (i
, fc
->scsi_bitmap
);
359 fc
->scsi_free
= fc
->can_queue
;
360 fc
->cmd_slots
= (fcp_cmnd
**)kmalloc(slots
* sizeof(fcp_cmnd
*), GFP_KERNEL
);
361 memset(fc
->cmd_slots
, 0, slots
* sizeof(fcp_cmnd
*));
364 fc
->scsi_name
[0] = 0;
365 kfree (fc
->scsi_bitmap
);
366 kfree (fc
->cmd_slots
);
367 FCND(("Unregistering\n"));
370 if (fc
->rst_pkt
->eh_state
== SCSI_STATE_UNUSED
)
373 /* Can't happen. Some memory would be lost. */
374 printk("FC: Reset in progress. Now?!");
378 FCND(("Unregistered\n"));
381 printk ("FC: %segistering unknown type %02x\n", unregister
? "Unr" : "R", type
);
384 static void fcp_scsi_done(Scsi_Cmnd
*SCpnt
);
386 static inline void fcp_scsi_receive(fc_channel
*fc
, int token
, int status
, fc_hdr
*fch
)
395 fcmd
= fc
->cmd_slots
[token
];
397 rsp
= (fcp_rsp
*) (fc
->scsi_rsp_pool
+ fc
->rsp_size
* token
);
398 SCpnt
= SC_FCMND(fcmd
);
400 if (SCpnt
->done
!= fcp_scsi_done
)
403 rsp_status
= rsp
->fcp_status
;
404 FCD(("rsp_status %08x status %08x\n", rsp_status
, status
))
409 if (rsp_status
& FCP_STATUS_RESID
) {
411 FCD(("Resid %d\n", rsp
->fcp_resid
))
413 fcp_cmd
*cmd
= fc
->scsi_cmd_pool
+ token
;
417 for (i
= 0; i
< sizeof(fcp_cmd
); i
+=4)
418 printk ("%08x ", *(u32
*)(((char *)cmd
)+i
));
419 printk ("\nResponse ");
420 for (i
= 0; i
< fc
->rsp_size
; i
+=4)
421 printk ("%08x ", *(u32
*)(((char *)rsp
)+i
));
427 if (rsp_status
& FCP_STATUS_SENSE_LEN
) {
428 sense_len
= rsp
->fcp_sense_len
;
429 if (sense_len
> sizeof(SCpnt
->sense_buffer
)) sense_len
= sizeof(SCpnt
->sense_buffer
);
430 memcpy(SCpnt
->sense_buffer
, ((char *)(rsp
+1)), sense_len
);
435 dma_unmap_sg(fc
->dev
, (struct scatterlist
*)SCpnt
->buffer
,
437 SCpnt
->sc_data_direction
);
439 dma_unmap_single(fc
->dev
, fcmd
->data
, SCpnt
->request_bufflen
,
440 SCpnt
->sc_data_direction
);
444 host_status
=DID_ERROR
; /* FIXME */
445 FCD(("Wrong FC status %d for token %d\n", status
, token
))
449 if (status_byte(rsp_status
) == QUEUE_FULL
) {
450 printk ("%s: (%d,%d) Received rsp_status 0x%x\n", fc
->name
, SCpnt
->device
->channel
, SCpnt
->device
->id
, rsp_status
);
453 SCpnt
->result
= (host_status
<< 16) | (rsp_status
& 0xff);
455 if (host_status
|| SCpnt
->result
|| rsp_status
) printk("FC: host_status %d, packet status %d\n",
456 host_status
, SCpnt
->result
);
458 SCpnt
->done
= fcmd
->done
;
460 clear_bit(token
, fc
->scsi_bitmap
);
462 FCD(("Calling scsi_done with %08x\n", SCpnt
->result
))
463 SCpnt
->scsi_done(SCpnt
);
466 void fcp_receive_solicited(fc_channel
*fc
, int proto
, int token
, int status
, fc_hdr
*fch
)
469 FCD(("receive_solicited %d %d %d\n", proto
, token
, status
))
472 fcp_scsi_receive(fc
, token
, status
, fch
); break;
473 case TYPE_EXTENDED_LS
:
474 case PROTO_REPORT_AL_MAP
:
477 magic
= ((ls
*)(fc
->ls
))->magic
;
478 if (magic
== LSMAGIC
) {
479 ls
*l
= (ls
*)fc
->ls
;
480 int i
= (token
>= l
->count
) ? token
- l
->count
: token
;
483 if ((unsigned)i
< l
->count
&& l
->fcmds
[i
].fc
== fc
) {
484 if (proto
== TYPE_EXTENDED_LS
)
485 fcp_login_done(fc
, token
, status
);
487 fcp_report_map_done(fc
, token
, status
);
491 FCD(("fc %p fc->ls %p fc->cmd_slots %p\n", fc
, fc
->ls
, fc
->cmd_slots
))
492 if (proto
== TYPE_EXTENDED_LS
&& !fc
->ls
&& fc
->cmd_slots
) {
495 fcmd
= fc
->cmd_slots
[token
];
496 if (fcmd
&& fcmd
->ls
&& ((ls
*)(fcmd
->ls
))->magic
== LSEMAGIC
) {
497 lse
*l
= (lse
*)fcmd
->ls
;
505 if (fc
->ls
&& ((lso
*)(fc
->ls
))->magic
== LSOMAGIC
) {
506 lso
*l
= (lso
*)fc
->ls
;
508 if ((unsigned)token
< l
->count
&& l
->fcmds
[token
].fc
== fc
) {
509 /* Wow, OFFLINE response arrived :) */
510 FCD(("OFFLINE Response arrived\n"))
511 fc
->state
= FC_STATE_OFFLINE
;
512 if (atomic_dec_and_test (&l
->todo
))
523 void fcp_state_change(fc_channel
*fc
, int state
)
525 FCD(("state_change %d %d\n", state
, fc
->state
))
526 if (state
== FC_STATE_ONLINE
&& fc
->state
== FC_STATE_MAYBEOFFLINE
)
527 fc
->state
= FC_STATE_UNINITED
;
528 else if (state
== FC_STATE_ONLINE
)
529 printk (KERN_WARNING
"%s: state change to ONLINE\n", fc
->name
);
531 printk (KERN_ERR
"%s: state change to OFFLINE\n", fc
->name
);
534 int fcp_initialize(fc_channel
*fcchain
, int count
)
541 FCND(("fcp_inititialize %08lx\n", (long)fcp_init
))
542 FCND(("fc_channels %08lx\n", (long)fc_channels
))
543 FCND((" SID %d DID %d\n", fcchain
->sid
, fcchain
->did
))
544 l
= kmalloc(sizeof (ls
) + count
, GFP_KERNEL
);
546 printk ("FC: Cannot allocate memory for initialization\n");
549 memset (l
, 0, sizeof(ls
) + count
);
552 FCND(("FCP Init for %d channels\n", count
))
553 init_MUTEX_LOCKED(&l
->sem
);
554 init_timer(&l
->timer
);
555 l
->timer
.function
= fcp_login_timeout
;
556 l
->timer
.data
= (unsigned long)l
;
557 atomic_set (&l
->todo
, count
);
558 l
->logi
= kmalloc (count
* 3 * sizeof(logi
), GFP_KERNEL
);
559 l
->fcmds
= kmalloc (count
* sizeof(fcp_cmnd
), GFP_KERNEL
);
560 if (!l
->logi
|| !l
->fcmds
) {
561 if (l
->logi
) kfree (l
->logi
);
562 if (l
->fcmds
) kfree (l
->fcmds
);
564 printk ("FC: Cannot allocate DMA memory for initialization\n");
567 memset (l
->logi
, 0, count
* 3 * sizeof(logi
));
568 memset (l
->fcmds
, 0, count
* sizeof(fcp_cmnd
));
569 for (fc
= fcchain
, i
= 0; fc
&& i
< count
; fc
= fc
->next
, i
++) {
570 fc
->state
= FC_STATE_UNINITED
;
571 fc
->rst_pkt
= NULL
; /* kmalloc when first used */
573 /* First try if we are in a AL topology */
574 FCND(("Initializing REPORT_MAP packets\n"))
575 for (fc
= fcchain
, i
= 0; fc
&& i
< count
; fc
= fc
->next
, i
++) {
579 /* Assumes sizeof(fc_al_posmap) < 3 * sizeof(logi), which is true */
580 fcmd
->cmd
= dma_map_single (fc
->dev
, l
->logi
+ 3 * i
, 3 * sizeof(logi
),
582 fcmd
->proto
= PROTO_REPORT_AL_MAP
;
586 for (retry
= 0; retry
< 8; retry
++) {
588 FCND(("Sending REPORT_MAP/FLOGI/PLOGI packets\n"))
589 for (fc
= fcchain
, i
= 0; fc
&& i
< count
; fc
= fc
->next
, i
++) {
590 if (fc
->state
== FC_STATE_ONLINE
|| fc
->state
== FC_STATE_OFFLINE
)
592 disable_irq(fc
->irq
);
593 if (fc
->state
== FC_STATE_MAYBEOFFLINE
) {
598 fc
->state
= FC_STATE_OFFLINE
;
600 dma_unmap_single (fc
->dev
, l
->fcmds
[i
].cmd
, 3 * sizeof(logi
), DMA_BIDIRECTIONAL
);
601 if (atomic_dec_and_test (&l
->todo
))
605 ret
= fc
->hw_enque (fc
, fc
->login
);
611 if (ret
== -ENOSYS
&& fc
->login
->proto
== PROTO_REPORT_AL_MAP
) {
612 /* Oh yes, this card handles Point-to-Point only, so let's try that. */
615 FCD(("SID %d DID %d\n", fc
->sid
, fc
->did
))
617 dma_unmap_single(fc
->dev
, fcmd
->cmd
, 3 * sizeof(logi
), DMA_BIDIRECTIONAL
);
619 FILL_FCHDR_RCTL_DID(fch
, R_CTL_ELS_REQ
, FS_FABRIC_F_PORT
);
620 FILL_FCHDR_SID(fch
, 0);
621 FILL_FCHDR_TYPE_FCTL(fch
, TYPE_EXTENDED_LS
, F_CTL_FIRST_SEQ
| F_CTL_SEQ_INITIATIVE
);
622 FILL_FCHDR_SEQ_DF_SEQ(fch
, 0, 0, 0);
623 FILL_FCHDR_OXRX(fch
, 0xffff, 0xffff);
625 l
->logi
[3 * i
].code
= LS_FLOGI
;
626 fcmd
->cmd
= dma_map_single (fc
->dev
, l
->logi
+ 3 * i
, 3 * sizeof(logi
), DMA_BIDIRECTIONAL
);
627 fcmd
->rsp
= fcmd
->cmd
+ sizeof(logi
);
628 fcmd
->cmdlen
= sizeof(logi
);
629 fcmd
->rsplen
= sizeof(logi
);
630 fcmd
->data
= (dma_addr_t
)NULL
;
631 fcmd
->class = FC_CLASS_SIMPLE
;
632 fcmd
->proto
= TYPE_EXTENDED_LS
;
634 printk ("FC: Cannot enque FLOGI/REPORT_MAP packet on %s\n", fc
->name
);
638 l
->timer
.expires
= jiffies
+ 5 * HZ
;
639 add_timer(&l
->timer
);
642 if (!atomic_read(&l
->todo
)) {
643 FCND(("All channels answered in time\n"))
644 break; /* All fc channels have answered us */
649 for (fc
= fcchain
, i
= 0; fc
&& i
< count
; fc
= fc
->next
, i
++) {
652 case FC_STATE_ONLINE
: break;
653 case FC_STATE_OFFLINE
: break;
654 default: dma_unmap_single (fc
->dev
, l
->fcmds
[i
].cmd
, 3 * sizeof(logi
), DMA_BIDIRECTIONAL
);
658 del_timer(&l
->timer
);
665 int fcp_forceoffline(fc_channel
*fcchain
, int count
)
672 memset (&l
, 0, sizeof(lso
));
675 FCND(("FCP Force Offline for %d channels\n", count
))
676 init_MUTEX_LOCKED(&l
.sem
);
677 init_timer(&l
.timer
);
678 l
.timer
.function
= fcp_login_timeout
;
679 l
.timer
.data
= (unsigned long)&l
;
680 atomic_set (&l
.todo
, count
);
681 l
.fcmds
= kmalloc (count
* sizeof(fcp_cmnd
), GFP_KERNEL
);
684 printk ("FC: Cannot allocate memory for forcing offline\n");
687 memset (l
.fcmds
, 0, count
* sizeof(fcp_cmnd
));
688 FCND(("Initializing OFFLINE packets\n"))
689 for (fc
= fcchain
, i
= 0; fc
&& i
< count
; fc
= fc
->next
, i
++) {
690 fc
->state
= FC_STATE_UNINITED
;
695 fcmd
->class = FC_CLASS_OFFLINE
;
696 fcmd
->proto
= PROTO_OFFLINE
;
699 disable_irq(fc
->irq
);
700 ret
= fc
->hw_enque (fc
, fc
->login
);
702 if (ret
) printk ("FC: Cannot enque OFFLINE packet on %s\n", fc
->name
);
705 l
.timer
.expires
= jiffies
+ 5 * HZ
;
710 for (fc
= fcchain
, i
= 0; fc
&& i
< count
; fc
= fc
->next
, i
++)
716 int fcp_init(fc_channel
*fcchain
)
722 for (fc
= fcchain
; fc
; fc
= fc
->next
) {
723 fc
->fcp_register
= fcp_register
;
727 ret
= fcp_initialize (fcchain
, count
);
732 fc_channels
= fcchain
;
734 for (fc
= fc_channels
; fc
->next
; fc
= fc
->next
);
740 void fcp_release(fc_channel
*fcchain
, int count
) /* count must > 0 */
745 for (fc
= fcchain
; --count
&& fc
->next
; fc
= fc
->next
);
747 printk("FC: nothing to release\n");
751 if (fc_channels
== fcchain
)
752 fc_channels
= fc
->next
;
754 for (fcx
= fc_channels
; fcx
->next
!= fcchain
; fcx
= fcx
->next
);
755 fcx
->next
= fc
->next
;
760 * We've just grabbed fcchain out of the fc_channel list
761 * and zero-terminated it, while destroying the count.
763 * Freeing the fc's is the low level driver's responsibility.
768 static void fcp_scsi_done (Scsi_Cmnd
*SCpnt
)
770 if (FCP_CMND(SCpnt
)->done
)
771 FCP_CMND(SCpnt
)->done(SCpnt
);
774 static int fcp_scsi_queue_it(fc_channel
*fc
, Scsi_Cmnd
*SCpnt
, fcp_cmnd
*fcmd
, int prepare
)
780 i
= find_first_zero_bit (fc
->scsi_bitmap
, fc
->scsi_bitmap_end
);
781 set_bit (i
, fc
->scsi_bitmap
);
783 cmd
= fc
->scsi_cmd_pool
+ i
;
785 if (fc
->encode_addr (SCpnt
, cmd
->fcp_addr
, fc
, fcmd
)) {
786 /* Invalid channel/id/lun and couldn't map it into fcp_addr */
787 clear_bit (i
, fc
->scsi_bitmap
);
788 SCpnt
->result
= (DID_BAD_TARGET
<< 16);
789 SCpnt
->scsi_done(SCpnt
);
793 fc
->cmd_slots
[fcmd
->token
] = fcmd
;
795 if (SCpnt
->device
->tagged_supported
) {
796 if (jiffies
- fc
->ages
[SCpnt
->device
->channel
* fc
->targets
+ SCpnt
->device
->id
] > (5 * 60 * HZ
)) {
797 fc
->ages
[SCpnt
->device
->channel
* fc
->targets
+ SCpnt
->device
->id
] = jiffies
;
798 fcp_cntl
= FCP_CNTL_QTYPE_ORDERED
;
800 fcp_cntl
= FCP_CNTL_QTYPE_SIMPLE
;
802 fcp_cntl
= FCP_CNTL_QTYPE_UNTAGGED
;
803 if (!SCpnt
->request_bufflen
&& !SCpnt
->use_sg
) {
804 cmd
->fcp_cntl
= fcp_cntl
;
805 fcmd
->data
= (dma_addr_t
)NULL
;
807 switch (SCpnt
->cmnd
[0]) {
811 cmd
->fcp_cntl
= (FCP_CNTL_WRITE
| fcp_cntl
); break;
813 cmd
->fcp_cntl
= (FCP_CNTL_READ
| fcp_cntl
); break;
815 if (!SCpnt
->use_sg
) {
816 cmd
->fcp_data_len
= SCpnt
->request_bufflen
;
817 fcmd
->data
= dma_map_single (fc
->dev
, (char *)SCpnt
->request_buffer
,
818 SCpnt
->request_bufflen
,
819 SCpnt
->sc_data_direction
);
821 struct scatterlist
*sg
= (struct scatterlist
*)SCpnt
->buffer
;
824 FCD(("XXX: Use_sg %d %d\n", SCpnt
->use_sg
, sg
->length
))
825 nents
= dma_map_sg (fc
->dev
, sg
, SCpnt
->use_sg
,
826 SCpnt
->sc_data_direction
);
827 if (nents
> 1) printk ("%s: SG for nents %d (use_sg %d) not handled yet\n", fc
->name
, nents
, SCpnt
->use_sg
);
828 fcmd
->data
= sg_dma_address(sg
);
829 cmd
->fcp_data_len
= sg_dma_len(sg
);
832 memcpy (cmd
->fcp_cdb
, SCpnt
->cmnd
, SCpnt
->cmd_len
);
833 memset (cmd
->fcp_cdb
+SCpnt
->cmd_len
, 0, sizeof(cmd
->fcp_cdb
)-SCpnt
->cmd_len
);
834 FCD(("XXX: %04x.%04x.%04x.%04x - %08x%08x%08x\n", cmd
->fcp_addr
[0], cmd
->fcp_addr
[1], cmd
->fcp_addr
[2], cmd
->fcp_addr
[3], *(u32
*)SCpnt
->cmnd
, *(u32
*)(SCpnt
->cmnd
+4), *(u32
*)(SCpnt
->cmnd
+8)))
836 FCD(("Trying to enque %p\n", fcmd
))
838 if (!fc
->hw_enque (fc
, fcmd
)) {
839 FCD(("hw_enque succeeded for %p\n", fcmd
))
843 FCD(("Putting into que1 %p\n", fcmd
))
844 fcp_scsi_insert_queue (fc
, fcmd
);
848 int fcp_scsi_queuecommand(Scsi_Cmnd
*SCpnt
, void (* done
)(Scsi_Cmnd
*))
850 fcp_cmnd
*fcmd
= FCP_CMND(SCpnt
);
851 fc_channel
*fc
= FC_SCMND(SCpnt
);
853 FCD(("Entering SCSI queuecommand %p\n", fcmd
))
854 if (SCpnt
->done
!= fcp_scsi_done
) {
855 fcmd
->done
= SCpnt
->done
;
856 SCpnt
->done
= fcp_scsi_done
;
857 SCpnt
->scsi_done
= done
;
858 fcmd
->proto
= TYPE_SCSI_FCP
;
859 if (!fc
->scsi_free
) {
860 FCD(("FC: !scsi_free, putting cmd on ML queue\n"))
861 #if (FCP_SCSI_USE_NEW_EH_CODE == 0)
862 printk("fcp_scsi_queue_command: queue full, losing cmd, bad\n");
866 return fcp_scsi_queue_it(fc
, SCpnt
, fcmd
, 1);
868 return fcp_scsi_queue_it(fc
, SCpnt
, fcmd
, 0);
871 void fcp_queue_empty(fc_channel
*fc
)
875 FCD(("Queue empty\n"))
876 while ((fcmd
= fc
->scsi_que
)) {
877 /* The hw told us we can try again queue some packet */
878 if (fc
->hw_enque (fc
, fcmd
))
880 fcp_scsi_remove_queue (fc
, fcmd
);
884 int fcp_scsi_abort(Scsi_Cmnd
*SCpnt
)
886 /* Internal bookkeeping only. Lose 1 cmd_slots slot. */
887 fcp_cmnd
*fcmd
= FCP_CMND(SCpnt
);
888 fc_channel
*fc
= FC_SCMND(SCpnt
);
891 * We react to abort requests by simply forgetting
892 * about the command and pretending everything's sweet.
893 * This may or may not be silly. We can't, however,
894 * immediately reuse the command's cmd_slots slot,
895 * as its result may arrive later and we cannot
896 * check whether it is the aborted one, can't we?
898 * Therefore, after the first few aborts are done,
899 * we tell the scsi error handler to do something clever.
900 * It will eventually call host reset, refreshing
903 * There is a theoretical chance that we sometimes allow
904 * more than can_queue packets to the jungle this way,
905 * but the worst outcome possible is a series of
906 * more aborts and eventually the dev_reset catharsis.
909 if (++fc
->abort_count
< (fc
->can_queue
>> 1)) {
910 SCpnt
->result
= DID_ABORT
;
912 printk("FC: soft abort\n");
915 printk("FC: hard abort refused\n");
921 void fcp_scsi_reset_done(Scsi_Cmnd
*SCpnt
)
923 fc_channel
*fc
= FC_SCMND(SCpnt
);
925 fc
->rst_pkt
->eh_state
= SCSI_STATE_FINISHED
;
926 up(fc
->rst_pkt
->device
->host
->eh_action
);
930 #define FCP_RESET_TIMEOUT (2*HZ)
932 int fcp_scsi_dev_reset(Scsi_Cmnd
*SCpnt
)
934 #if 0 /* broken junk, but if davem wants to compile this driver, let him.. */
938 fc_channel
*fc
= FC_SCMND(SCpnt
);
939 DECLARE_MUTEX_LOCKED(sem
);
942 fc
->rst_pkt
= (Scsi_Cmnd
*) kmalloc(sizeof(SCpnt
), GFP_KERNEL
);
943 if (!fc
->rst_pkt
) return FAILED
;
945 fcmd
= FCP_CMND(fc
->rst_pkt
);
949 cmd
= fc
->scsi_cmd_pool
+ 0;
950 FCD(("Preparing rst packet\n"))
951 fc
->encode_addr (SCpnt
, cmd
->fcp_addr
, fc
, fcmd
);
952 fc
->rst_pkt
->device
= SCpnt
->device
;
953 fc
->rst_pkt
->cmd_len
= 0;
955 fc
->cmd_slots
[0] = fcmd
;
957 cmd
->fcp_cntl
= FCP_CNTL_QTYPE_ORDERED
| FCP_CNTL_RESET
;
958 fcmd
->data
= (dma_addr_t
)NULL
;
959 fcmd
->proto
= TYPE_SCSI_FCP
;
961 memcpy (cmd
->fcp_cdb
, SCpnt
->cmnd
, SCpnt
->cmd_len
);
962 memset (cmd
->fcp_cdb
+SCpnt
->cmd_len
, 0, sizeof(cmd
->fcp_cdb
)-SCpnt
->cmd_len
);
963 FCD(("XXX: %04x.%04x.%04x.%04x - %08x%08x%08x\n", cmd
->fcp_addr
[0], cmd
->fcp_addr
[1], cmd
->fcp_addr
[2], cmd
->fcp_addr
[3], *(u32
*)SCpnt
->cmnd
, *(u32
*)(SCpnt
->cmnd
+4), *(u32
*)(SCpnt
->cmnd
+8)))
965 fcmd
= FCP_CMND(fc
->rst_pkt
);
966 if (fc
->rst_pkt
->eh_state
== SCSI_STATE_QUEUED
)
967 return FAILED
; /* or SUCCESS. Only these */
969 fc
->rst_pkt
->done
= NULL
;
972 fc
->rst_pkt
->eh_state
= SCSI_STATE_QUEUED
;
973 init_timer(&fc
->rst_pkt
->eh_timeout
);
974 fc
->rst_pkt
->eh_timeout
.data
= (unsigned long) fc
->rst_pkt
;
975 fc
->rst_pkt
->eh_timeout
.expires
= jiffies
+ FCP_RESET_TIMEOUT
;
976 fc
->rst_pkt
->eh_timeout
.function
= (void (*)(unsigned long))fcp_scsi_reset_done
;
978 add_timer(&fc
->rst_pkt
->eh_timeout
);
981 * Set up the semaphore so we wait for the command to complete.
984 fc
->rst_pkt
->device
->host
->eh_action
= &sem
;
985 fc
->rst_pkt
->request
->rq_status
= RQ_SCSI_BUSY
;
987 fc
->rst_pkt
->done
= fcp_scsi_reset_done
;
989 spin_lock_irqsave(SCpnt
->device
->host
->host_lock
, flags
);
990 fcp_scsi_queue_it(fc
, fc
->rst_pkt
, fcmd
, 0);
991 spin_unlock_irqrestore(SCpnt
->device
->host
->host_lock
, flags
);
995 fc
->rst_pkt
->device
->host
->eh_action
= NULL
;
996 del_timer(&fc
->rst_pkt
->eh_timeout
);
999 * See if timeout. If so, tell the host to forget about it.
1000 * In other words, we don't want a callback any more.
1002 if (fc
->rst_pkt
->eh_state
== SCSI_STATE_TIMEOUT
) {
1003 fc
->rst_pkt
->eh_state
= SCSI_STATE_UNUSED
;
1006 fc
->rst_pkt
->eh_state
= SCSI_STATE_UNUSED
;
1011 static int __fcp_scsi_host_reset(Scsi_Cmnd
*SCpnt
)
1013 fc_channel
*fc
= FC_SCMND(SCpnt
);
1014 fcp_cmnd
*fcmd
= FCP_CMND(SCpnt
);
1017 printk ("FC: host reset\n");
1019 for (i
=0; i
< fc
->can_queue
; i
++) {
1020 if (fc
->cmd_slots
[i
] && SCpnt
->result
!= DID_ABORT
) {
1021 SCpnt
->result
= DID_RESET
;
1023 fc
->cmd_slots
[i
] = NULL
;
1027 fc
->abort_count
= 0;
1028 if (fcp_initialize(fc
, 1)) return SUCCESS
;
1032 int fcp_scsi_host_reset(Scsi_Cmnd
*SCpnt
)
1034 unsigned long flags
;
1037 spin_lock_irqsave(SCpnt
->device
->host
->host_lock
, flags
);
1038 rc
= __fcp_scsi_host_reset(SCpnt
);
1039 spin_unlock_irqrestore(SCpnt
->device
->host
->host_lock
, flags
);
1044 static int fcp_els_queue_it(fc_channel
*fc
, fcp_cmnd
*fcmd
)
1048 i
= find_first_zero_bit (fc
->scsi_bitmap
, fc
->scsi_bitmap_end
);
1049 set_bit (i
, fc
->scsi_bitmap
);
1052 fc
->cmd_slots
[fcmd
->token
] = fcmd
;
1053 return fcp_scsi_queue_it(fc
, NULL
, fcmd
, 0);
1056 static int fc_do_els(fc_channel
*fc
, unsigned int alpa
, void *data
, int len
)
1058 fcp_cmnd _fcmd
, *fcmd
;
1064 memset(fcmd
, 0, sizeof(fcmd
));
1065 FCD(("PLOGI SID %d DID %d\n", fc
->sid
, alpa
))
1067 FILL_FCHDR_RCTL_DID(fch
, R_CTL_ELS_REQ
, alpa
);
1068 FILL_FCHDR_SID(fch
, fc
->sid
);
1069 FILL_FCHDR_TYPE_FCTL(fch
, TYPE_EXTENDED_LS
, F_CTL_FIRST_SEQ
| F_CTL_SEQ_INITIATIVE
);
1070 FILL_FCHDR_SEQ_DF_SEQ(fch
, 0, 0, 0);
1071 FILL_FCHDR_OXRX(fch
, 0xffff, 0xffff);
1073 fcmd
->cmd
= dma_map_single (fc
->dev
, data
, 2 * len
, DMA_BIDIRECTIONAL
);
1074 fcmd
->rsp
= fcmd
->cmd
+ len
;
1077 fcmd
->data
= (dma_addr_t
)NULL
;
1079 fcmd
->class = FC_CLASS_SIMPLE
;
1080 fcmd
->proto
= TYPE_EXTENDED_LS
;
1082 memset (&l
, 0, sizeof(lse
));
1084 init_MUTEX_LOCKED(&l
.sem
);
1085 l
.timer
.function
= fcp_login_timeout
;
1086 l
.timer
.data
= (unsigned long)&l
;
1087 l
.status
= FC_STATUS_TIMED_OUT
;
1088 fcmd
->ls
= (void *)&l
;
1090 disable_irq(fc
->irq
);
1091 fcp_els_queue_it(fc
, fcmd
);
1092 enable_irq(fc
->irq
);
1095 l
.timer
.expires
= jiffies
+ 5 * HZ
;
1096 add_timer(&l
.timer
);
1098 del_timer(&l
.timer
);
1099 if (l
.status
!= FC_STATUS_TIMED_OUT
) break;
1100 if (++i
== 3) break;
1101 disable_irq(fc
->irq
);
1102 fcp_scsi_queue_it(fc
, NULL
, fcmd
, 0);
1103 enable_irq(fc
->irq
);
1106 clear_bit(fcmd
->token
, fc
->scsi_bitmap
);
1108 dma_unmap_single (fc
->dev
, fcmd
->cmd
, 2 * len
, DMA_BIDIRECTIONAL
);
1112 int fc_do_plogi(fc_channel
*fc
, unsigned char alpa
, fc_wwn
*node
, fc_wwn
*nport
)
1117 l
= (logi
*)kmalloc(2 * sizeof(logi
), GFP_KERNEL
);
1118 if (!l
) return -ENOMEM
;
1119 memset(l
, 0, 2 * sizeof(logi
));
1121 memcpy (&l
->nport_wwn
, &fc
->wwn_nport
, sizeof(fc_wwn
));
1122 memcpy (&l
->node_wwn
, &fc
->wwn_node
, sizeof(fc_wwn
));
1123 memcpy (&l
->common
, fc
->common_svc
, sizeof(common_svc_parm
));
1124 memcpy (&l
->class1
, fc
->class_svcs
, 3*sizeof(svc_parm
));
1125 status
= fc_do_els(fc
, alpa
, l
, sizeof(logi
));
1126 if (status
== FC_STATUS_OK
) {
1127 if (l
[1].code
== LS_ACC
) {
1129 u32
*u
= (u32
*)&l
[1].nport_wwn
;
1130 FCD(("AL-PA %02x: Port WWN %08x%08x Node WWN %08x%08x\n", alpa
,
1131 u
[0], u
[1], u
[2], u
[3]))
1133 memcpy(nport
, &l
[1].nport_wwn
, sizeof(fc_wwn
));
1134 memcpy(node
, &l
[1].node_wwn
, sizeof(fc_wwn
));
1136 status
= FC_STATUS_BAD_RSP
;
1147 int fc_do_prli(fc_channel
*fc
, unsigned char alpa
)
1152 p
= (prli
*)kmalloc(2 * sizeof(prli
), GFP_KERNEL
);
1153 if (!p
) return -ENOMEM
;
1154 memset(p
, 0, 2 * sizeof(prli
));
1156 p
->params
[0] = 0x08002000;
1157 p
->params
[3] = 0x00000022;
1158 status
= fc_do_els(fc
, alpa
, p
, sizeof(prli
));
1159 if (status
== FC_STATUS_OK
&& p
[1].code
!= LS_PRLI_ACC
&& p
[1].code
!= LS_ACC
)
1160 status
= FC_STATUS_BAD_RSP
;
1165 MODULE_LICENSE("GPL");