[SCSI] zfcp: fix layering oddities between zfcp_fsf and zfcp_qdio
[deliverable/linux.git] / drivers / s390 / scsi / zfcp_scsi.c
CommitLineData
41fa2ada 1/*
553448f6 2 * zfcp device driver
1da177e4 3 *
553448f6 4 * Interface to Linux SCSI midlayer.
41fa2ada 5 *
a2fa0aed 6 * Copyright IBM Corporation 2002, 2009
1da177e4
LT
7 */
8
ecf39d42
CS
9#define KMSG_COMPONENT "zfcp"
10#define pr_fmt(fmt) KMSG_COMPONENT ": " fmt
11
5f852be9 12#include <asm/atomic.h>
dcd20e23
CS
13#include "zfcp_ext.h"
14#include "zfcp_dbf.h"
1da177e4 15
a40a1baf
CS
16static unsigned int default_depth = 32;
17module_param_named(queue_depth, default_depth, uint, 0600);
18MODULE_PARM_DESC(queue_depth, "Default queue depth for new SCSI devices");
19
1da177e4 20/* Find start of Sense Information in FCP response unit*/
f76af7d7 21char *zfcp_get_fcp_sns_info_ptr(struct fcp_rsp_iu *fcp_rsp_iu)
1da177e4
LT
22{
23 char *fcp_sns_info_ptr;
24
f76af7d7 25 fcp_sns_info_ptr = (unsigned char *) &fcp_rsp_iu[1];
1da177e4 26 if (fcp_rsp_iu->validity.bits.fcp_rsp_len_valid)
f76af7d7 27 fcp_sns_info_ptr += fcp_rsp_iu->fcp_rsp_len;
1da177e4
LT
28
29 return fcp_sns_info_ptr;
30}
31
a40a1baf
CS
32static int zfcp_scsi_change_queue_depth(struct scsi_device *sdev, int depth)
33{
34 scsi_adjust_queue_depth(sdev, scsi_get_tag_type(sdev), depth);
35 return sdev->queue_depth;
36}
37
f6c0e7a7 38static void zfcp_scsi_slave_destroy(struct scsi_device *sdpnt)
1da177e4
LT
39{
40 struct zfcp_unit *unit = (struct zfcp_unit *) sdpnt->hostdata;
26816f1c 41 unit->device = NULL;
26816f1c 42 zfcp_unit_put(unit);
1da177e4
LT
43}
44
f76af7d7 45static int zfcp_scsi_slave_configure(struct scsi_device *sdp)
1da177e4
LT
46{
47 if (sdp->tagged_supported)
a40a1baf 48 scsi_adjust_queue_depth(sdp, MSG_SIMPLE_TAG, default_depth);
1da177e4
LT
49 else
50 scsi_adjust_queue_depth(sdp, 0, 1);
51 return 0;
52}
53
f76af7d7 54static void zfcp_scsi_command_fail(struct scsi_cmnd *scpnt, int result)
1da177e4 55{
feac6a07 56 set_host_byte(scpnt, result);
8a36e453
MS
57 if ((scpnt->device != NULL) && (scpnt->device->host != NULL))
58 zfcp_scsi_dbf_event_result("fail", 4,
59 (struct zfcp_adapter*) scpnt->device->host->hostdata[0],
ed829ad6 60 scpnt, NULL);
1da177e4
LT
61 /* return directly */
62 scpnt->scsi_done(scpnt);
63}
64
f76af7d7
MP
65static int zfcp_scsi_queuecommand(struct scsi_cmnd *scpnt,
66 void (*done) (struct scsi_cmnd *))
1da177e4
LT
67{
68 struct zfcp_unit *unit;
69 struct zfcp_adapter *adapter;
a2fa0aed
CS
70 int status, scsi_result, ret;
71 struct fc_rport *rport = starget_to_rport(scsi_target(scpnt->device));
1da177e4
LT
72
73 /* reset the status for this request */
74 scpnt->result = 0;
75 scpnt->host_scribble = NULL;
76 scpnt->scsi_done = done;
77
78 /*
79 * figure out adapter and target device
80 * (stored there by zfcp_scsi_slave_alloc)
81 */
82 adapter = (struct zfcp_adapter *) scpnt->device->host->hostdata[0];
f76af7d7
MP
83 unit = scpnt->device->hostdata;
84
85 BUG_ON(!adapter || (adapter != unit->port->adapter));
86 BUG_ON(!scpnt->scsi_done);
87
88 if (unlikely(!unit)) {
89 zfcp_scsi_command_fail(scpnt, DID_NO_CONNECT);
90 return 0;
91 }
92
a2fa0aed
CS
93 scsi_result = fc_remote_port_chkready(rport);
94 if (unlikely(scsi_result)) {
95 scpnt->result = scsi_result;
96 zfcp_scsi_dbf_event_result("fail", 4, adapter, scpnt, NULL);
97 scpnt->scsi_done(scpnt);
98 return 0;
99 }
100
f76af7d7
MP
101 status = atomic_read(&unit->status);
102 if (unlikely((status & ZFCP_STATUS_COMMON_ERP_FAILED) ||
103 !(status & ZFCP_STATUS_COMMON_RUNNING))) {
104 zfcp_scsi_command_fail(scpnt, DID_ERROR);
105 return 0;;
106 }
107
63caf367 108 ret = zfcp_fsf_send_fcp_command_task(unit, scpnt);
f76af7d7 109 if (unlikely(ret == -EBUSY))
f7a65e92 110 return SCSI_MLQUEUE_DEVICE_BUSY;
f76af7d7
MP
111 else if (unlikely(ret < 0))
112 return SCSI_MLQUEUE_HOST_BUSY;
1da177e4 113
f76af7d7 114 return ret;
1da177e4
LT
115}
116
f76af7d7
MP
117static struct zfcp_unit *zfcp_unit_lookup(struct zfcp_adapter *adapter,
118 int channel, unsigned int id,
119 unsigned int lun)
1da177e4
LT
120{
121 struct zfcp_port *port;
f76af7d7 122 struct zfcp_unit *unit;
0406289e 123 int scsi_lun;
1da177e4
LT
124
125 list_for_each_entry(port, &adapter->port_list_head, list) {
3859f6a2 126 if (!port->rport || (id != port->rport->scsi_target_id))
1da177e4 127 continue;
0406289e
CS
128 list_for_each_entry(unit, &port->unit_list_head, list) {
129 scsi_lun = scsilun_to_int(
130 (struct scsi_lun *)&unit->fcp_lun);
131 if (lun == scsi_lun)
f76af7d7 132 return unit;
0406289e 133 }
1da177e4 134 }
f76af7d7
MP
135
136 return NULL;
137}
138
139static int zfcp_scsi_slave_alloc(struct scsi_device *sdp)
140{
141 struct zfcp_adapter *adapter;
142 struct zfcp_unit *unit;
143 unsigned long flags;
144 int retval = -ENXIO;
145
146 adapter = (struct zfcp_adapter *) sdp->host->hostdata[0];
147 if (!adapter)
148 goto out;
149
150 read_lock_irqsave(&zfcp_data.config_lock, flags);
151 unit = zfcp_unit_lookup(adapter, sdp->channel, sdp->id, sdp->lun);
86f8a1b4 152 if (unit) {
f76af7d7
MP
153 sdp->hostdata = unit;
154 unit->device = sdp;
155 zfcp_unit_get(unit);
156 retval = 0;
157 }
158 read_unlock_irqrestore(&zfcp_data.config_lock, flags);
159out:
1da177e4
LT
160 return retval;
161}
162
2b67fc46 163static int zfcp_scsi_eh_abort_handler(struct scsi_cmnd *scpnt)
1da177e4 164{
63caf367
CS
165 struct Scsi_Host *scsi_host = scpnt->device->host;
166 struct zfcp_adapter *adapter =
167 (struct zfcp_adapter *) scsi_host->hostdata[0];
168 struct zfcp_unit *unit = scpnt->device->hostdata;
169 struct zfcp_fsf_req *old_req, *abrt_req;
1da177e4 170 unsigned long flags;
a11a52be 171 unsigned long old_reqid = (unsigned long) scpnt->host_scribble;
4eff4a36 172 int retval = SUCCESS;
63caf367 173 int retry = 3;
a11a52be 174 char *dbf_tag;
1da177e4 175
059c97d0 176 /* avoid race condition between late normal completion and abort */
1da177e4
LT
177 write_lock_irqsave(&adapter->abort_lock, flags);
178
4eff4a36 179 spin_lock(&adapter->req_list_lock);
a11a52be 180 old_req = zfcp_reqlist_find(adapter, old_reqid);
4eff4a36 181 spin_unlock(&adapter->req_list_lock);
63caf367 182 if (!old_req) {
1da177e4 183 write_unlock_irqrestore(&adapter->abort_lock, flags);
63caf367 184 zfcp_scsi_dbf_event_abort("lte1", adapter, scpnt, NULL,
a11a52be 185 old_reqid);
c6936e7f 186 return FAILED; /* completion could be in progress */
1da177e4 187 }
63caf367 188 old_req->data = NULL;
1da177e4 189
4eff4a36 190 /* don't access old fsf_req after releasing the abort_lock */
1da177e4 191 write_unlock_irqrestore(&adapter->abort_lock, flags);
4eff4a36 192
63caf367 193 while (retry--) {
a11a52be 194 abrt_req = zfcp_fsf_abort_fcp_command(old_reqid, unit);
63caf367
CS
195 if (abrt_req)
196 break;
197
198 zfcp_erp_wait(adapter);
199 if (!(atomic_read(&adapter->status) &
200 ZFCP_STATUS_COMMON_RUNNING)) {
201 zfcp_scsi_dbf_event_abort("nres", adapter, scpnt, NULL,
a11a52be 202 old_reqid);
63caf367
CS
203 return SUCCESS;
204 }
1da177e4 205 }
63caf367
CS
206 if (!abrt_req)
207 return FAILED;
1da177e4 208
63caf367
CS
209 wait_event(abrt_req->completion_wq,
210 abrt_req->status & ZFCP_STATUS_FSFREQ_COMPLETED);
059c97d0 211
63caf367 212 if (abrt_req->status & ZFCP_STATUS_FSFREQ_ABORTSUCCEEDED)
a11a52be 213 dbf_tag = "okay";
63caf367 214 else if (abrt_req->status & ZFCP_STATUS_FSFREQ_ABORTNOTNEEDED)
a11a52be 215 dbf_tag = "lte2";
63caf367 216 else {
a11a52be 217 dbf_tag = "fail";
1da177e4 218 retval = FAILED;
1da177e4 219 }
a11a52be 220 zfcp_scsi_dbf_event_abort(dbf_tag, adapter, scpnt, abrt_req, old_reqid);
63caf367 221 zfcp_fsf_req_free(abrt_req);
f76af7d7 222 return retval;
1da177e4
LT
223}
224
63caf367 225static int zfcp_task_mgmt_function(struct scsi_cmnd *scpnt, u8 tm_flags)
1da177e4 226{
63caf367 227 struct zfcp_unit *unit = scpnt->device->hostdata;
1da177e4 228 struct zfcp_adapter *adapter = unit->port->adapter;
1da177e4 229 struct zfcp_fsf_req *fsf_req;
f76af7d7 230 int retval = SUCCESS;
63caf367
CS
231 int retry = 3;
232
233 while (retry--) {
234 fsf_req = zfcp_fsf_send_fcp_ctm(unit, tm_flags);
235 if (fsf_req)
236 break;
237
238 zfcp_erp_wait(adapter);
239 if (!(atomic_read(&adapter->status) &
240 ZFCP_STATUS_COMMON_RUNNING)) {
241 zfcp_scsi_dbf_event_devreset("nres", tm_flags, unit,
242 scpnt);
243 return SUCCESS;
244 }
1da177e4 245 }
63caf367
CS
246 if (!fsf_req)
247 return FAILED;
1da177e4 248
63caf367
CS
249 wait_event(fsf_req->completion_wq,
250 fsf_req->status & ZFCP_STATUS_FSFREQ_COMPLETED);
77eb1699 251
8a36e453
MS
252 if (fsf_req->status & ZFCP_STATUS_FSFREQ_TMFUNCFAILED) {
253 zfcp_scsi_dbf_event_devreset("fail", tm_flags, unit, scpnt);
f76af7d7 254 retval = FAILED;
8a36e453
MS
255 } else if (fsf_req->status & ZFCP_STATUS_FSFREQ_TMFUNCNOTSUPP) {
256 zfcp_scsi_dbf_event_devreset("nsup", tm_flags, unit, scpnt);
f76af7d7 257 retval = FAILED;
8a36e453
MS
258 } else
259 zfcp_scsi_dbf_event_devreset("okay", tm_flags, unit, scpnt);
77eb1699
AH
260
261 zfcp_fsf_req_free(fsf_req);
1da177e4
LT
262 return retval;
263}
264
f76af7d7
MP
265static int zfcp_scsi_eh_device_reset_handler(struct scsi_cmnd *scpnt)
266{
63caf367 267 return zfcp_task_mgmt_function(scpnt, FCP_LOGICAL_UNIT_RESET);
f76af7d7
MP
268}
269
270static int zfcp_scsi_eh_target_reset_handler(struct scsi_cmnd *scpnt)
271{
63caf367 272 return zfcp_task_mgmt_function(scpnt, FCP_TARGET_RESET);
f76af7d7
MP
273}
274
2b67fc46 275static int zfcp_scsi_eh_host_reset_handler(struct scsi_cmnd *scpnt)
1da177e4 276{
63caf367
CS
277 struct zfcp_unit *unit = scpnt->device->hostdata;
278 struct zfcp_adapter *adapter = unit->port->adapter;
1da177e4 279
5ffd51a5 280 zfcp_erp_adapter_reopen(adapter, 0, "schrh_1", scpnt);
81654286 281 zfcp_erp_wait(adapter);
1da177e4 282
810f1e3e 283 return SUCCESS;
1da177e4
LT
284}
285
f76af7d7 286int zfcp_adapter_scsi_register(struct zfcp_adapter *adapter)
1da177e4 287{
f76af7d7 288 struct ccw_dev_id dev_id;
1da177e4 289
9f28745a 290 if (adapter->scsi_host)
f76af7d7 291 return 0;
9f28745a 292
f76af7d7 293 ccw_device_get_id(adapter->ccw_device, &dev_id);
1da177e4
LT
294 /* register adapter as SCSI host with mid layer of SCSI stack */
295 adapter->scsi_host = scsi_host_alloc(&zfcp_data.scsi_host_template,
296 sizeof (struct zfcp_adapter *));
297 if (!adapter->scsi_host) {
553448f6 298 dev_err(&adapter->ccw_device->dev,
ff3b24fa
CS
299 "Registering the FCP device with the "
300 "SCSI stack failed\n");
f76af7d7 301 return -EIO;
1da177e4 302 }
1da177e4
LT
303
304 /* tell the SCSI stack some characteristics of this adapter */
305 adapter->scsi_host->max_id = 1;
306 adapter->scsi_host->max_lun = 1;
307 adapter->scsi_host->max_channel = 0;
f76af7d7
MP
308 adapter->scsi_host->unique_id = dev_id.devno;
309 adapter->scsi_host->max_cmd_len = 255;
dd52e0ea 310 adapter->scsi_host->transportt = zfcp_data.scsi_transport_template;
1da177e4 311
1da177e4
LT
312 adapter->scsi_host->hostdata[0] = (unsigned long) adapter;
313
314 if (scsi_add_host(adapter->scsi_host, &adapter->ccw_device->dev)) {
315 scsi_host_put(adapter->scsi_host);
f76af7d7 316 return -EIO;
1da177e4 317 }
f76af7d7
MP
318
319 return 0;
1da177e4
LT
320}
321
f76af7d7 322void zfcp_adapter_scsi_unregister(struct zfcp_adapter *adapter)
1da177e4
LT
323{
324 struct Scsi_Host *shost;
13e1e1f0 325 struct zfcp_port *port;
1da177e4
LT
326
327 shost = adapter->scsi_host;
328 if (!shost)
329 return;
f76af7d7 330
13e1e1f0
AH
331 read_lock_irq(&zfcp_data.config_lock);
332 list_for_each_entry(port, &adapter->port_list_head, list)
333 if (port->rport)
334 port->rport = NULL;
f76af7d7 335
13e1e1f0 336 read_unlock_irq(&zfcp_data.config_lock);
3859f6a2 337 fc_remove_host(shost);
1da177e4
LT
338 scsi_remove_host(shost);
339 scsi_host_put(shost);
340 adapter->scsi_host = NULL;
1da177e4
LT
341
342 return;
343}
344
f6cd94b1
AH
345static struct fc_host_statistics*
346zfcp_init_fc_host_stats(struct zfcp_adapter *adapter)
1da177e4 347{
f6cd94b1 348 struct fc_host_statistics *fc_stats;
1da177e4 349
f6cd94b1
AH
350 if (!adapter->fc_stats) {
351 fc_stats = kmalloc(sizeof(*fc_stats), GFP_KERNEL);
352 if (!fc_stats)
353 return NULL;
354 adapter->fc_stats = fc_stats; /* freed in adater_dequeue */
355 }
356 memset(adapter->fc_stats, 0, sizeof(*adapter->fc_stats));
357 return adapter->fc_stats;
1da177e4
LT
358}
359
f76af7d7
MP
360static void zfcp_adjust_fc_host_stats(struct fc_host_statistics *fc_stats,
361 struct fsf_qtcb_bottom_port *data,
362 struct fsf_qtcb_bottom_port *old)
1da177e4 363{
f76af7d7
MP
364 fc_stats->seconds_since_last_reset =
365 data->seconds_since_last_reset - old->seconds_since_last_reset;
f6cd94b1
AH
366 fc_stats->tx_frames = data->tx_frames - old->tx_frames;
367 fc_stats->tx_words = data->tx_words - old->tx_words;
368 fc_stats->rx_frames = data->rx_frames - old->rx_frames;
369 fc_stats->rx_words = data->rx_words - old->rx_words;
370 fc_stats->lip_count = data->lip - old->lip;
371 fc_stats->nos_count = data->nos - old->nos;
372 fc_stats->error_frames = data->error_frames - old->error_frames;
373 fc_stats->dumped_frames = data->dumped_frames - old->dumped_frames;
374 fc_stats->link_failure_count = data->link_failure - old->link_failure;
375 fc_stats->loss_of_sync_count = data->loss_of_sync - old->loss_of_sync;
f76af7d7
MP
376 fc_stats->loss_of_signal_count =
377 data->loss_of_signal - old->loss_of_signal;
378 fc_stats->prim_seq_protocol_err_count =
379 data->psp_error_counts - old->psp_error_counts;
380 fc_stats->invalid_tx_word_count =
381 data->invalid_tx_words - old->invalid_tx_words;
f6cd94b1 382 fc_stats->invalid_crc_count = data->invalid_crcs - old->invalid_crcs;
f76af7d7
MP
383 fc_stats->fcp_input_requests =
384 data->input_requests - old->input_requests;
385 fc_stats->fcp_output_requests =
386 data->output_requests - old->output_requests;
387 fc_stats->fcp_control_requests =
388 data->control_requests - old->control_requests;
f6cd94b1
AH
389 fc_stats->fcp_input_megabytes = data->input_mb - old->input_mb;
390 fc_stats->fcp_output_megabytes = data->output_mb - old->output_mb;
391}
1da177e4 392
f76af7d7
MP
393static void zfcp_set_fc_host_stats(struct fc_host_statistics *fc_stats,
394 struct fsf_qtcb_bottom_port *data)
f6cd94b1
AH
395{
396 fc_stats->seconds_since_last_reset = data->seconds_since_last_reset;
397 fc_stats->tx_frames = data->tx_frames;
398 fc_stats->tx_words = data->tx_words;
399 fc_stats->rx_frames = data->rx_frames;
400 fc_stats->rx_words = data->rx_words;
401 fc_stats->lip_count = data->lip;
402 fc_stats->nos_count = data->nos;
403 fc_stats->error_frames = data->error_frames;
404 fc_stats->dumped_frames = data->dumped_frames;
405 fc_stats->link_failure_count = data->link_failure;
406 fc_stats->loss_of_sync_count = data->loss_of_sync;
407 fc_stats->loss_of_signal_count = data->loss_of_signal;
408 fc_stats->prim_seq_protocol_err_count = data->psp_error_counts;
409 fc_stats->invalid_tx_word_count = data->invalid_tx_words;
410 fc_stats->invalid_crc_count = data->invalid_crcs;
411 fc_stats->fcp_input_requests = data->input_requests;
412 fc_stats->fcp_output_requests = data->output_requests;
413 fc_stats->fcp_control_requests = data->control_requests;
414 fc_stats->fcp_input_megabytes = data->input_mb;
415 fc_stats->fcp_output_megabytes = data->output_mb;
416}
417
f76af7d7 418static struct fc_host_statistics *zfcp_get_fc_host_stats(struct Scsi_Host *host)
f6cd94b1
AH
419{
420 struct zfcp_adapter *adapter;
421 struct fc_host_statistics *fc_stats;
422 struct fsf_qtcb_bottom_port *data;
423 int ret;
424
f76af7d7 425 adapter = (struct zfcp_adapter *)host->hostdata[0];
f6cd94b1
AH
426 fc_stats = zfcp_init_fc_host_stats(adapter);
427 if (!fc_stats)
428 return NULL;
429
ec4081c6 430 data = kzalloc(sizeof(*data), GFP_KERNEL);
f6cd94b1
AH
431 if (!data)
432 return NULL;
f6cd94b1 433
52ef11a7 434 ret = zfcp_fsf_exchange_port_data_sync(adapter, data);
f6cd94b1
AH
435 if (ret) {
436 kfree(data);
f76af7d7 437 return NULL;
f6cd94b1
AH
438 }
439
440 if (adapter->stats_reset &&
441 ((jiffies/HZ - adapter->stats_reset) <
f76af7d7 442 data->seconds_since_last_reset))
f6cd94b1
AH
443 zfcp_adjust_fc_host_stats(fc_stats, data,
444 adapter->stats_reset_data);
f76af7d7 445 else
f6cd94b1
AH
446 zfcp_set_fc_host_stats(fc_stats, data);
447
448 kfree(data);
449 return fc_stats;
1da177e4
LT
450}
451
f76af7d7 452static void zfcp_reset_fc_host_stats(struct Scsi_Host *shost)
1da177e4 453{
f6cd94b1 454 struct zfcp_adapter *adapter;
f76af7d7 455 struct fsf_qtcb_bottom_port *data;
f6cd94b1 456 int ret;
1da177e4 457
f6cd94b1 458 adapter = (struct zfcp_adapter *)shost->hostdata[0];
ec4081c6 459 data = kzalloc(sizeof(*data), GFP_KERNEL);
f6cd94b1
AH
460 if (!data)
461 return;
f6cd94b1 462
52ef11a7 463 ret = zfcp_fsf_exchange_port_data_sync(adapter, data);
f76af7d7 464 if (ret)
83f6d6d7 465 kfree(data);
f76af7d7 466 else {
f6cd94b1 467 adapter->stats_reset = jiffies/HZ;
f76af7d7 468 kfree(adapter->stats_reset_data);
f6cd94b1 469 adapter->stats_reset_data = data; /* finally freed in
f76af7d7 470 adapter_dequeue */
f6cd94b1 471 }
1da177e4
LT
472}
473
85a82392
SS
474static void zfcp_get_host_port_state(struct Scsi_Host *shost)
475{
476 struct zfcp_adapter *adapter =
477 (struct zfcp_adapter *)shost->hostdata[0];
478 int status = atomic_read(&adapter->status);
479
480 if ((status & ZFCP_STATUS_COMMON_RUNNING) &&
481 !(status & ZFCP_STATUS_ADAPTER_LINK_UNPLUGGED))
482 fc_host_port_state(shost) = FC_PORTSTATE_ONLINE;
483 else if (status & ZFCP_STATUS_ADAPTER_LINK_UNPLUGGED)
484 fc_host_port_state(shost) = FC_PORTSTATE_LINKDOWN;
485 else if (status & ZFCP_STATUS_COMMON_ERP_FAILED)
486 fc_host_port_state(shost) = FC_PORTSTATE_ERROR;
487 else
488 fc_host_port_state(shost) = FC_PORTSTATE_UNKNOWN;
489}
490
338151e0
AH
491static void zfcp_set_rport_dev_loss_tmo(struct fc_rport *rport, u32 timeout)
492{
493 rport->dev_loss_tmo = timeout;
494}
495
a2fa0aed
CS
496/**
497 * zfcp_scsi_dev_loss_tmo_callbk - Free any reference to rport
498 * @rport: The rport that is about to be deleted.
499 */
500static void zfcp_scsi_dev_loss_tmo_callbk(struct fc_rport *rport)
501{
70932935 502 struct zfcp_port *port;
a2fa0aed
CS
503
504 write_lock_irq(&zfcp_data.config_lock);
70932935
CS
505 port = rport->dd_data;
506 if (port)
507 port->rport = NULL;
a2fa0aed
CS
508 write_unlock_irq(&zfcp_data.config_lock);
509}
510
511/**
512 * zfcp_scsi_terminate_rport_io - Terminate all I/O on a rport
513 * @rport: The FC rport where to teminate I/O
514 *
515 * Abort all pending SCSI commands for a port by closing the
516 * port. Using a reopen for avoids a conflict with a shutdown
517 * overwriting a reopen.
518 */
519static void zfcp_scsi_terminate_rport_io(struct fc_rport *rport)
520{
70932935
CS
521 struct zfcp_port *port;
522
523 write_lock_irq(&zfcp_data.config_lock);
524 port = rport->dd_data;
525 if (port)
526 zfcp_port_get(port);
527 write_unlock_irq(&zfcp_data.config_lock);
a2fa0aed 528
70932935
CS
529 if (port) {
530 zfcp_erp_port_reopen(port, 0, "sctrpi1", NULL);
531 zfcp_port_put(port);
532 }
a2fa0aed
CS
533}
534
535static void zfcp_scsi_rport_register(struct zfcp_port *port)
536{
537 struct fc_rport_identifiers ids;
538 struct fc_rport *rport;
539
379d6bf6
CS
540 if (port->rport)
541 return;
542
a2fa0aed
CS
543 ids.node_name = port->wwnn;
544 ids.port_name = port->wwpn;
545 ids.port_id = port->d_id;
546 ids.roles = FC_RPORT_ROLE_FCP_TARGET;
547
548 rport = fc_remote_port_add(port->adapter->scsi_host, 0, &ids);
549 if (!rport) {
550 dev_err(&port->adapter->ccw_device->dev,
551 "Registering port 0x%016Lx failed\n",
552 (unsigned long long)port->wwpn);
553 return;
554 }
555
556 rport->dd_data = port;
557 rport->maxframe_size = port->maxframe_size;
558 rport->supported_classes = port->supported_classes;
559 port->rport = rport;
560}
561
562static void zfcp_scsi_rport_block(struct zfcp_port *port)
563{
70932935
CS
564 struct fc_rport *rport = port->rport;
565
379d6bf6 566 if (rport) {
70932935 567 fc_remote_port_delete(rport);
379d6bf6
CS
568 port->rport = NULL;
569 }
a2fa0aed
CS
570}
571
572void zfcp_scsi_schedule_rport_register(struct zfcp_port *port)
573{
574 zfcp_port_get(port);
575 port->rport_task = RPORT_ADD;
576
577 if (!queue_work(zfcp_data.work_queue, &port->rport_work))
578 zfcp_port_put(port);
579}
580
581void zfcp_scsi_schedule_rport_block(struct zfcp_port *port)
582{
583 zfcp_port_get(port);
584 port->rport_task = RPORT_DEL;
585
a67417ab
SS
586 if (port->rport && queue_work(zfcp_data.work_queue, &port->rport_work))
587 return;
588
589 zfcp_port_put(port);
a2fa0aed
CS
590}
591
592void zfcp_scsi_schedule_rports_block(struct zfcp_adapter *adapter)
593{
594 struct zfcp_port *port;
595
596 list_for_each_entry(port, &adapter->port_list_head, list)
597 zfcp_scsi_schedule_rport_block(port);
598}
599
600void zfcp_scsi_rport_work(struct work_struct *work)
601{
602 struct zfcp_port *port = container_of(work, struct zfcp_port,
603 rport_work);
604
605 while (port->rport_task) {
606 if (port->rport_task == RPORT_ADD) {
607 port->rport_task = RPORT_NONE;
608 zfcp_scsi_rport_register(port);
609 } else {
610 port->rport_task = RPORT_NONE;
611 zfcp_scsi_rport_block(port);
612 }
613 }
614
615 zfcp_port_put(port);
616}
617
618
92d5193b
SS
619void zfcp_scsi_scan(struct work_struct *work)
620{
621 struct zfcp_unit *unit = container_of(work, struct zfcp_unit,
622 scsi_work);
623 struct fc_rport *rport;
624
625 flush_work(&unit->port->rport_work);
626 rport = unit->port->rport;
627
628 if (rport && rport->port_state == FC_PORTSTATE_ONLINE)
629 scsi_scan_target(&rport->dev, 0, rport->scsi_target_id,
630 scsilun_to_int((struct scsi_lun *)
631 &unit->fcp_lun), 0);
632
633 zfcp_unit_put(unit);
634}
635
9d544f2b
SS
636static int zfcp_execute_fc_job(struct fc_bsg_job *job)
637{
638 switch (job->request->msgcode) {
639 case FC_BSG_RPT_ELS:
640 case FC_BSG_HST_ELS_NOLOGIN:
641 return zfcp_fc_execute_els_fc_job(job);
642 case FC_BSG_RPT_CT:
643 case FC_BSG_HST_CT:
644 return zfcp_fc_execute_ct_fc_job(job);
645 default:
646 return -EINVAL;
647 }
648}
649
1da177e4 650struct fc_function_template zfcp_transport_functions = {
1da177e4
LT
651 .show_starget_port_id = 1,
652 .show_starget_port_name = 1,
653 .show_starget_node_name = 1,
3859f6a2 654 .show_rport_supported_classes = 1,
75bfc283 655 .show_rport_maxframe_size = 1,
338151e0 656 .show_rport_dev_loss_tmo = 1,
3859f6a2
AH
657 .show_host_node_name = 1,
658 .show_host_port_name = 1,
ad757cdf 659 .show_host_permanent_port_name = 1,
3859f6a2 660 .show_host_supported_classes = 1,
ad757cdf 661 .show_host_supported_speeds = 1,
13e1e1f0 662 .show_host_maxframe_size = 1,
3859f6a2 663 .show_host_serial_number = 1,
f6cd94b1
AH
664 .get_fc_host_stats = zfcp_get_fc_host_stats,
665 .reset_fc_host_stats = zfcp_reset_fc_host_stats,
338151e0 666 .set_rport_dev_loss_tmo = zfcp_set_rport_dev_loss_tmo,
85a82392 667 .get_host_port_state = zfcp_get_host_port_state,
a2fa0aed
CS
668 .dev_loss_tmo_callbk = zfcp_scsi_dev_loss_tmo_callbk,
669 .terminate_rport_io = zfcp_scsi_terminate_rport_io,
85a82392 670 .show_host_port_state = 1,
9d544f2b 671 .bsg_request = zfcp_execute_fc_job,
f6cd94b1
AH
672 /* no functions registered for following dynamic attributes but
673 directly set by LLDD */
ad757cdf 674 .show_host_port_type = 1,
13e1e1f0
AH
675 .show_host_speed = 1,
676 .show_host_port_id = 1,
52ef11a7 677 .disable_target_scan = 1,
1da177e4
LT
678};
679
f76af7d7
MP
680struct zfcp_data zfcp_data = {
681 .scsi_host_template = {
682 .name = "zfcp",
683 .module = THIS_MODULE,
684 .proc_name = "zfcp",
a40a1baf 685 .change_queue_depth = zfcp_scsi_change_queue_depth,
f76af7d7
MP
686 .slave_alloc = zfcp_scsi_slave_alloc,
687 .slave_configure = zfcp_scsi_slave_configure,
688 .slave_destroy = zfcp_scsi_slave_destroy,
689 .queuecommand = zfcp_scsi_queuecommand,
690 .eh_abort_handler = zfcp_scsi_eh_abort_handler,
691 .eh_device_reset_handler = zfcp_scsi_eh_device_reset_handler,
692 .eh_target_reset_handler = zfcp_scsi_eh_target_reset_handler,
693 .eh_host_reset_handler = zfcp_scsi_eh_host_reset_handler,
694 .can_queue = 4096,
695 .this_id = -1,
696 .sg_tablesize = ZFCP_MAX_SBALES_PER_REQ,
697 .cmd_per_lun = 1,
698 .use_clustering = 1,
699 .sdev_attrs = zfcp_sysfs_sdev_attrs,
700 .max_sectors = (ZFCP_MAX_SBALES_PER_REQ * 8),
60221920 701 .shost_attrs = zfcp_sysfs_shost_attrs,
f76af7d7
MP
702 },
703};
This page took 0.509585 seconds and 5 git commands to generate.