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