[SCSI] zfcp: Move workqueue to adapter struct
[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
058b8647 209 wait_for_completion(&abrt_req->completion);
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
058b8647 248 wait_for_completion(&fsf_req->completion);
77eb1699 249
8a36e453
MS
250 if (fsf_req->status & ZFCP_STATUS_FSFREQ_TMFUNCFAILED) {
251 zfcp_scsi_dbf_event_devreset("fail", tm_flags, unit, scpnt);
f76af7d7 252 retval = FAILED;
8a36e453
MS
253 } else if (fsf_req->status & ZFCP_STATUS_FSFREQ_TMFUNCNOTSUPP) {
254 zfcp_scsi_dbf_event_devreset("nsup", tm_flags, unit, scpnt);
f76af7d7 255 retval = FAILED;
8a36e453
MS
256 } else
257 zfcp_scsi_dbf_event_devreset("okay", tm_flags, unit, scpnt);
77eb1699
AH
258
259 zfcp_fsf_req_free(fsf_req);
1da177e4
LT
260 return retval;
261}
262
f76af7d7
MP
263static int zfcp_scsi_eh_device_reset_handler(struct scsi_cmnd *scpnt)
264{
63caf367 265 return zfcp_task_mgmt_function(scpnt, FCP_LOGICAL_UNIT_RESET);
f76af7d7
MP
266}
267
268static int zfcp_scsi_eh_target_reset_handler(struct scsi_cmnd *scpnt)
269{
63caf367 270 return zfcp_task_mgmt_function(scpnt, FCP_TARGET_RESET);
f76af7d7
MP
271}
272
2b67fc46 273static int zfcp_scsi_eh_host_reset_handler(struct scsi_cmnd *scpnt)
1da177e4 274{
63caf367
CS
275 struct zfcp_unit *unit = scpnt->device->hostdata;
276 struct zfcp_adapter *adapter = unit->port->adapter;
1da177e4 277
5ffd51a5 278 zfcp_erp_adapter_reopen(adapter, 0, "schrh_1", scpnt);
81654286 279 zfcp_erp_wait(adapter);
1da177e4 280
810f1e3e 281 return SUCCESS;
1da177e4
LT
282}
283
f76af7d7 284int zfcp_adapter_scsi_register(struct zfcp_adapter *adapter)
1da177e4 285{
f76af7d7 286 struct ccw_dev_id dev_id;
1da177e4 287
9f28745a 288 if (adapter->scsi_host)
f76af7d7 289 return 0;
9f28745a 290
f76af7d7 291 ccw_device_get_id(adapter->ccw_device, &dev_id);
1da177e4
LT
292 /* register adapter as SCSI host with mid layer of SCSI stack */
293 adapter->scsi_host = scsi_host_alloc(&zfcp_data.scsi_host_template,
294 sizeof (struct zfcp_adapter *));
295 if (!adapter->scsi_host) {
553448f6 296 dev_err(&adapter->ccw_device->dev,
ff3b24fa
CS
297 "Registering the FCP device with the "
298 "SCSI stack failed\n");
f76af7d7 299 return -EIO;
1da177e4 300 }
1da177e4
LT
301
302 /* tell the SCSI stack some characteristics of this adapter */
303 adapter->scsi_host->max_id = 1;
304 adapter->scsi_host->max_lun = 1;
305 adapter->scsi_host->max_channel = 0;
f76af7d7
MP
306 adapter->scsi_host->unique_id = dev_id.devno;
307 adapter->scsi_host->max_cmd_len = 255;
dd52e0ea 308 adapter->scsi_host->transportt = zfcp_data.scsi_transport_template;
1da177e4 309
1da177e4
LT
310 adapter->scsi_host->hostdata[0] = (unsigned long) adapter;
311
312 if (scsi_add_host(adapter->scsi_host, &adapter->ccw_device->dev)) {
313 scsi_host_put(adapter->scsi_host);
f76af7d7 314 return -EIO;
1da177e4 315 }
f76af7d7
MP
316
317 return 0;
1da177e4
LT
318}
319
f76af7d7 320void zfcp_adapter_scsi_unregister(struct zfcp_adapter *adapter)
1da177e4
LT
321{
322 struct Scsi_Host *shost;
13e1e1f0 323 struct zfcp_port *port;
1da177e4
LT
324
325 shost = adapter->scsi_host;
326 if (!shost)
327 return;
f76af7d7 328
13e1e1f0
AH
329 read_lock_irq(&zfcp_data.config_lock);
330 list_for_each_entry(port, &adapter->port_list_head, list)
331 if (port->rport)
332 port->rport = NULL;
f76af7d7 333
13e1e1f0 334 read_unlock_irq(&zfcp_data.config_lock);
3859f6a2 335 fc_remove_host(shost);
1da177e4
LT
336 scsi_remove_host(shost);
337 scsi_host_put(shost);
338 adapter->scsi_host = NULL;
1da177e4
LT
339
340 return;
341}
342
f6cd94b1
AH
343static struct fc_host_statistics*
344zfcp_init_fc_host_stats(struct zfcp_adapter *adapter)
1da177e4 345{
f6cd94b1 346 struct fc_host_statistics *fc_stats;
1da177e4 347
f6cd94b1
AH
348 if (!adapter->fc_stats) {
349 fc_stats = kmalloc(sizeof(*fc_stats), GFP_KERNEL);
350 if (!fc_stats)
351 return NULL;
352 adapter->fc_stats = fc_stats; /* freed in adater_dequeue */
353 }
354 memset(adapter->fc_stats, 0, sizeof(*adapter->fc_stats));
355 return adapter->fc_stats;
1da177e4
LT
356}
357
f76af7d7
MP
358static void zfcp_adjust_fc_host_stats(struct fc_host_statistics *fc_stats,
359 struct fsf_qtcb_bottom_port *data,
360 struct fsf_qtcb_bottom_port *old)
1da177e4 361{
f76af7d7
MP
362 fc_stats->seconds_since_last_reset =
363 data->seconds_since_last_reset - old->seconds_since_last_reset;
f6cd94b1
AH
364 fc_stats->tx_frames = data->tx_frames - old->tx_frames;
365 fc_stats->tx_words = data->tx_words - old->tx_words;
366 fc_stats->rx_frames = data->rx_frames - old->rx_frames;
367 fc_stats->rx_words = data->rx_words - old->rx_words;
368 fc_stats->lip_count = data->lip - old->lip;
369 fc_stats->nos_count = data->nos - old->nos;
370 fc_stats->error_frames = data->error_frames - old->error_frames;
371 fc_stats->dumped_frames = data->dumped_frames - old->dumped_frames;
372 fc_stats->link_failure_count = data->link_failure - old->link_failure;
373 fc_stats->loss_of_sync_count = data->loss_of_sync - old->loss_of_sync;
f76af7d7
MP
374 fc_stats->loss_of_signal_count =
375 data->loss_of_signal - old->loss_of_signal;
376 fc_stats->prim_seq_protocol_err_count =
377 data->psp_error_counts - old->psp_error_counts;
378 fc_stats->invalid_tx_word_count =
379 data->invalid_tx_words - old->invalid_tx_words;
f6cd94b1 380 fc_stats->invalid_crc_count = data->invalid_crcs - old->invalid_crcs;
f76af7d7
MP
381 fc_stats->fcp_input_requests =
382 data->input_requests - old->input_requests;
383 fc_stats->fcp_output_requests =
384 data->output_requests - old->output_requests;
385 fc_stats->fcp_control_requests =
386 data->control_requests - old->control_requests;
f6cd94b1
AH
387 fc_stats->fcp_input_megabytes = data->input_mb - old->input_mb;
388 fc_stats->fcp_output_megabytes = data->output_mb - old->output_mb;
389}
1da177e4 390
f76af7d7
MP
391static void zfcp_set_fc_host_stats(struct fc_host_statistics *fc_stats,
392 struct fsf_qtcb_bottom_port *data)
f6cd94b1
AH
393{
394 fc_stats->seconds_since_last_reset = data->seconds_since_last_reset;
395 fc_stats->tx_frames = data->tx_frames;
396 fc_stats->tx_words = data->tx_words;
397 fc_stats->rx_frames = data->rx_frames;
398 fc_stats->rx_words = data->rx_words;
399 fc_stats->lip_count = data->lip;
400 fc_stats->nos_count = data->nos;
401 fc_stats->error_frames = data->error_frames;
402 fc_stats->dumped_frames = data->dumped_frames;
403 fc_stats->link_failure_count = data->link_failure;
404 fc_stats->loss_of_sync_count = data->loss_of_sync;
405 fc_stats->loss_of_signal_count = data->loss_of_signal;
406 fc_stats->prim_seq_protocol_err_count = data->psp_error_counts;
407 fc_stats->invalid_tx_word_count = data->invalid_tx_words;
408 fc_stats->invalid_crc_count = data->invalid_crcs;
409 fc_stats->fcp_input_requests = data->input_requests;
410 fc_stats->fcp_output_requests = data->output_requests;
411 fc_stats->fcp_control_requests = data->control_requests;
412 fc_stats->fcp_input_megabytes = data->input_mb;
413 fc_stats->fcp_output_megabytes = data->output_mb;
414}
415
f76af7d7 416static struct fc_host_statistics *zfcp_get_fc_host_stats(struct Scsi_Host *host)
f6cd94b1
AH
417{
418 struct zfcp_adapter *adapter;
419 struct fc_host_statistics *fc_stats;
420 struct fsf_qtcb_bottom_port *data;
421 int ret;
422
f76af7d7 423 adapter = (struct zfcp_adapter *)host->hostdata[0];
f6cd94b1
AH
424 fc_stats = zfcp_init_fc_host_stats(adapter);
425 if (!fc_stats)
426 return NULL;
427
ec4081c6 428 data = kzalloc(sizeof(*data), GFP_KERNEL);
f6cd94b1
AH
429 if (!data)
430 return NULL;
f6cd94b1 431
52ef11a7 432 ret = zfcp_fsf_exchange_port_data_sync(adapter, data);
f6cd94b1
AH
433 if (ret) {
434 kfree(data);
f76af7d7 435 return NULL;
f6cd94b1
AH
436 }
437
438 if (adapter->stats_reset &&
439 ((jiffies/HZ - adapter->stats_reset) <
f76af7d7 440 data->seconds_since_last_reset))
f6cd94b1
AH
441 zfcp_adjust_fc_host_stats(fc_stats, data,
442 adapter->stats_reset_data);
f76af7d7 443 else
f6cd94b1
AH
444 zfcp_set_fc_host_stats(fc_stats, data);
445
446 kfree(data);
447 return fc_stats;
1da177e4
LT
448}
449
f76af7d7 450static void zfcp_reset_fc_host_stats(struct Scsi_Host *shost)
1da177e4 451{
f6cd94b1 452 struct zfcp_adapter *adapter;
f76af7d7 453 struct fsf_qtcb_bottom_port *data;
f6cd94b1 454 int ret;
1da177e4 455
f6cd94b1 456 adapter = (struct zfcp_adapter *)shost->hostdata[0];
ec4081c6 457 data = kzalloc(sizeof(*data), GFP_KERNEL);
f6cd94b1
AH
458 if (!data)
459 return;
f6cd94b1 460
52ef11a7 461 ret = zfcp_fsf_exchange_port_data_sync(adapter, data);
f76af7d7 462 if (ret)
83f6d6d7 463 kfree(data);
f76af7d7 464 else {
f6cd94b1 465 adapter->stats_reset = jiffies/HZ;
f76af7d7 466 kfree(adapter->stats_reset_data);
f6cd94b1 467 adapter->stats_reset_data = data; /* finally freed in
f76af7d7 468 adapter_dequeue */
f6cd94b1 469 }
1da177e4
LT
470}
471
85a82392
SS
472static void zfcp_get_host_port_state(struct Scsi_Host *shost)
473{
474 struct zfcp_adapter *adapter =
475 (struct zfcp_adapter *)shost->hostdata[0];
476 int status = atomic_read(&adapter->status);
477
478 if ((status & ZFCP_STATUS_COMMON_RUNNING) &&
479 !(status & ZFCP_STATUS_ADAPTER_LINK_UNPLUGGED))
480 fc_host_port_state(shost) = FC_PORTSTATE_ONLINE;
481 else if (status & ZFCP_STATUS_ADAPTER_LINK_UNPLUGGED)
482 fc_host_port_state(shost) = FC_PORTSTATE_LINKDOWN;
483 else if (status & ZFCP_STATUS_COMMON_ERP_FAILED)
484 fc_host_port_state(shost) = FC_PORTSTATE_ERROR;
485 else
486 fc_host_port_state(shost) = FC_PORTSTATE_UNKNOWN;
487}
488
338151e0
AH
489static void zfcp_set_rport_dev_loss_tmo(struct fc_rport *rport, u32 timeout)
490{
491 rport->dev_loss_tmo = timeout;
492}
493
a2fa0aed
CS
494/**
495 * zfcp_scsi_dev_loss_tmo_callbk - Free any reference to rport
496 * @rport: The rport that is about to be deleted.
497 */
498static void zfcp_scsi_dev_loss_tmo_callbk(struct fc_rport *rport)
499{
70932935 500 struct zfcp_port *port;
a2fa0aed
CS
501
502 write_lock_irq(&zfcp_data.config_lock);
70932935
CS
503 port = rport->dd_data;
504 if (port)
505 port->rport = NULL;
a2fa0aed
CS
506 write_unlock_irq(&zfcp_data.config_lock);
507}
508
509/**
510 * zfcp_scsi_terminate_rport_io - Terminate all I/O on a rport
511 * @rport: The FC rport where to teminate I/O
512 *
513 * Abort all pending SCSI commands for a port by closing the
514 * port. Using a reopen for avoids a conflict with a shutdown
515 * overwriting a reopen.
516 */
517static void zfcp_scsi_terminate_rport_io(struct fc_rport *rport)
518{
70932935
CS
519 struct zfcp_port *port;
520
521 write_lock_irq(&zfcp_data.config_lock);
522 port = rport->dd_data;
523 if (port)
524 zfcp_port_get(port);
525 write_unlock_irq(&zfcp_data.config_lock);
a2fa0aed 526
70932935
CS
527 if (port) {
528 zfcp_erp_port_reopen(port, 0, "sctrpi1", NULL);
529 zfcp_port_put(port);
530 }
a2fa0aed
CS
531}
532
533static void zfcp_scsi_rport_register(struct zfcp_port *port)
534{
535 struct fc_rport_identifiers ids;
536 struct fc_rport *rport;
537
379d6bf6
CS
538 if (port->rport)
539 return;
540
a2fa0aed
CS
541 ids.node_name = port->wwnn;
542 ids.port_name = port->wwpn;
543 ids.port_id = port->d_id;
544 ids.roles = FC_RPORT_ROLE_FCP_TARGET;
545
546 rport = fc_remote_port_add(port->adapter->scsi_host, 0, &ids);
547 if (!rport) {
548 dev_err(&port->adapter->ccw_device->dev,
549 "Registering port 0x%016Lx failed\n",
550 (unsigned long long)port->wwpn);
551 return;
552 }
553
554 rport->dd_data = port;
555 rport->maxframe_size = port->maxframe_size;
556 rport->supported_classes = port->supported_classes;
557 port->rport = rport;
558}
559
560static void zfcp_scsi_rport_block(struct zfcp_port *port)
561{
70932935
CS
562 struct fc_rport *rport = port->rport;
563
379d6bf6 564 if (rport) {
70932935 565 fc_remote_port_delete(rport);
379d6bf6
CS
566 port->rport = NULL;
567 }
a2fa0aed
CS
568}
569
570void zfcp_scsi_schedule_rport_register(struct zfcp_port *port)
571{
572 zfcp_port_get(port);
573 port->rport_task = RPORT_ADD;
574
4544683a 575 if (!queue_work(port->adapter->work_queue, &port->rport_work))
a2fa0aed
CS
576 zfcp_port_put(port);
577}
578
579void zfcp_scsi_schedule_rport_block(struct zfcp_port *port)
580{
581 zfcp_port_get(port);
582 port->rport_task = RPORT_DEL;
583
4544683a
SS
584 if (port->rport && queue_work(port->adapter->work_queue,
585 &port->rport_work))
a67417ab
SS
586 return;
587
588 zfcp_port_put(port);
a2fa0aed
CS
589}
590
591void zfcp_scsi_schedule_rports_block(struct zfcp_adapter *adapter)
592{
593 struct zfcp_port *port;
594
595 list_for_each_entry(port, &adapter->port_list_head, list)
596 zfcp_scsi_schedule_rport_block(port);
597}
598
599void zfcp_scsi_rport_work(struct work_struct *work)
600{
601 struct zfcp_port *port = container_of(work, struct zfcp_port,
602 rport_work);
603
604 while (port->rport_task) {
605 if (port->rport_task == RPORT_ADD) {
606 port->rport_task = RPORT_NONE;
607 zfcp_scsi_rport_register(port);
608 } else {
609 port->rport_task = RPORT_NONE;
610 zfcp_scsi_rport_block(port);
611 }
612 }
613
614 zfcp_port_put(port);
615}
616
617
92d5193b
SS
618void zfcp_scsi_scan(struct work_struct *work)
619{
620 struct zfcp_unit *unit = container_of(work, struct zfcp_unit,
621 scsi_work);
622 struct fc_rport *rport;
623
624 flush_work(&unit->port->rport_work);
625 rport = unit->port->rport;
626
627 if (rport && rport->port_state == FC_PORTSTATE_ONLINE)
628 scsi_scan_target(&rport->dev, 0, rport->scsi_target_id,
629 scsilun_to_int((struct scsi_lun *)
630 &unit->fcp_lun), 0);
631
632 zfcp_unit_put(unit);
633}
634
9d544f2b
SS
635static int zfcp_execute_fc_job(struct fc_bsg_job *job)
636{
637 switch (job->request->msgcode) {
638 case FC_BSG_RPT_ELS:
639 case FC_BSG_HST_ELS_NOLOGIN:
640 return zfcp_fc_execute_els_fc_job(job);
641 case FC_BSG_RPT_CT:
642 case FC_BSG_HST_CT:
643 return zfcp_fc_execute_ct_fc_job(job);
644 default:
645 return -EINVAL;
646 }
647}
648
1da177e4 649struct fc_function_template zfcp_transport_functions = {
1da177e4
LT
650 .show_starget_port_id = 1,
651 .show_starget_port_name = 1,
652 .show_starget_node_name = 1,
3859f6a2 653 .show_rport_supported_classes = 1,
75bfc283 654 .show_rport_maxframe_size = 1,
338151e0 655 .show_rport_dev_loss_tmo = 1,
3859f6a2
AH
656 .show_host_node_name = 1,
657 .show_host_port_name = 1,
ad757cdf 658 .show_host_permanent_port_name = 1,
3859f6a2 659 .show_host_supported_classes = 1,
ad757cdf 660 .show_host_supported_speeds = 1,
13e1e1f0 661 .show_host_maxframe_size = 1,
3859f6a2 662 .show_host_serial_number = 1,
f6cd94b1
AH
663 .get_fc_host_stats = zfcp_get_fc_host_stats,
664 .reset_fc_host_stats = zfcp_reset_fc_host_stats,
338151e0 665 .set_rport_dev_loss_tmo = zfcp_set_rport_dev_loss_tmo,
85a82392 666 .get_host_port_state = zfcp_get_host_port_state,
a2fa0aed
CS
667 .dev_loss_tmo_callbk = zfcp_scsi_dev_loss_tmo_callbk,
668 .terminate_rport_io = zfcp_scsi_terminate_rport_io,
85a82392 669 .show_host_port_state = 1,
9d544f2b 670 .bsg_request = zfcp_execute_fc_job,
f6cd94b1
AH
671 /* no functions registered for following dynamic attributes but
672 directly set by LLDD */
ad757cdf 673 .show_host_port_type = 1,
13e1e1f0
AH
674 .show_host_speed = 1,
675 .show_host_port_id = 1,
52ef11a7 676 .disable_target_scan = 1,
1da177e4
LT
677};
678
f76af7d7
MP
679struct zfcp_data zfcp_data = {
680 .scsi_host_template = {
681 .name = "zfcp",
682 .module = THIS_MODULE,
683 .proc_name = "zfcp",
a40a1baf 684 .change_queue_depth = zfcp_scsi_change_queue_depth,
f76af7d7
MP
685 .slave_alloc = zfcp_scsi_slave_alloc,
686 .slave_configure = zfcp_scsi_slave_configure,
687 .slave_destroy = zfcp_scsi_slave_destroy,
688 .queuecommand = zfcp_scsi_queuecommand,
689 .eh_abort_handler = zfcp_scsi_eh_abort_handler,
690 .eh_device_reset_handler = zfcp_scsi_eh_device_reset_handler,
691 .eh_target_reset_handler = zfcp_scsi_eh_target_reset_handler,
692 .eh_host_reset_handler = zfcp_scsi_eh_host_reset_handler,
693 .can_queue = 4096,
694 .this_id = -1,
695 .sg_tablesize = ZFCP_MAX_SBALES_PER_REQ,
696 .cmd_per_lun = 1,
697 .use_clustering = 1,
698 .sdev_attrs = zfcp_sysfs_sdev_attrs,
699 .max_sectors = (ZFCP_MAX_SBALES_PER_REQ * 8),
60221920 700 .shost_attrs = zfcp_sysfs_shost_attrs,
f76af7d7
MP
701 },
702};
This page took 0.484372 seconds and 5 git commands to generate.