zfcp_scsi.c 19.1 KB
Newer Older
S
Swen Schillig 已提交
1
/*
C
Christof Schmitt 已提交
2
 * zfcp device driver
L
Linus Torvalds 已提交
3
 *
C
Christof Schmitt 已提交
4
 * Interface to Linux SCSI midlayer.
S
Swen Schillig 已提交
5
 *
6
 * Copyright IBM Corporation 2002, 2009
L
Linus Torvalds 已提交
7 8
 */

9 10 11
#define KMSG_COMPONENT "zfcp"
#define pr_fmt(fmt) KMSG_COMPONENT ": " fmt

L
Linus Torvalds 已提交
12
#include "zfcp_ext.h"
13
#include <asm/atomic.h>
L
Linus Torvalds 已提交
14

15 16 17 18
static unsigned int default_depth = 32;
module_param_named(queue_depth, default_depth, uint, 0600);
MODULE_PARM_DESC(queue_depth, "Default queue depth for new SCSI devices");

L
Linus Torvalds 已提交
19
/* Find start of Sense Information in FCP response unit*/
20
char *zfcp_get_fcp_sns_info_ptr(struct fcp_rsp_iu *fcp_rsp_iu)
L
Linus Torvalds 已提交
21 22 23
{
	char *fcp_sns_info_ptr;

24
	fcp_sns_info_ptr = (unsigned char *) &fcp_rsp_iu[1];
L
Linus Torvalds 已提交
25
	if (fcp_rsp_iu->validity.bits.fcp_rsp_len_valid)
26
		fcp_sns_info_ptr += fcp_rsp_iu->fcp_rsp_len;
L
Linus Torvalds 已提交
27 28 29 30

	return fcp_sns_info_ptr;
}

31 32 33 34 35 36
static int zfcp_scsi_change_queue_depth(struct scsi_device *sdev, int depth)
{
	scsi_adjust_queue_depth(sdev, scsi_get_tag_type(sdev), depth);
	return sdev->queue_depth;
}

37
static void zfcp_scsi_slave_destroy(struct scsi_device *sdpnt)
L
Linus Torvalds 已提交
38 39
{
	struct zfcp_unit *unit = (struct zfcp_unit *) sdpnt->hostdata;
40 41
	unit->device = NULL;
	zfcp_unit_put(unit);
L
Linus Torvalds 已提交
42 43
}

44
static int zfcp_scsi_slave_configure(struct scsi_device *sdp)
L
Linus Torvalds 已提交
45 46
{
	if (sdp->tagged_supported)
47
		scsi_adjust_queue_depth(sdp, MSG_SIMPLE_TAG, default_depth);
L
Linus Torvalds 已提交
48 49 50 51 52
	else
		scsi_adjust_queue_depth(sdp, 0, 1);
	return 0;
}

53
static void zfcp_scsi_command_fail(struct scsi_cmnd *scpnt, int result)
L
Linus Torvalds 已提交
54
{
55
	set_host_byte(scpnt, result);
56 57 58
	if ((scpnt->device != NULL) && (scpnt->device->host != NULL))
		zfcp_scsi_dbf_event_result("fail", 4,
			(struct zfcp_adapter*) scpnt->device->host->hostdata[0],
59
			scpnt, NULL);
L
Linus Torvalds 已提交
60 61 62 63
	/* return directly */
	scpnt->scsi_done(scpnt);
}

64 65
static int zfcp_scsi_queuecommand(struct scsi_cmnd *scpnt,
				  void (*done) (struct scsi_cmnd *))
L
Linus Torvalds 已提交
66 67 68
{
	struct zfcp_unit *unit;
	struct zfcp_adapter *adapter;
69 70
	int    status, scsi_result, ret;
	struct fc_rport *rport = starget_to_rport(scsi_target(scpnt->device));
L
Linus Torvalds 已提交
71 72 73 74 75 76 77 78 79 80 81

	/* reset the status for this request */
	scpnt->result = 0;
	scpnt->host_scribble = NULL;
	scpnt->scsi_done = done;

	/*
	 * figure out adapter and target device
	 * (stored there by zfcp_scsi_slave_alloc)
	 */
	adapter = (struct zfcp_adapter *) scpnt->device->host->hostdata[0];
82 83 84 85 86 87 88 89 90 91
	unit = scpnt->device->hostdata;

	BUG_ON(!adapter || (adapter != unit->port->adapter));
	BUG_ON(!scpnt->scsi_done);

	if (unlikely(!unit)) {
		zfcp_scsi_command_fail(scpnt, DID_NO_CONNECT);
		return 0;
	}

92 93 94 95 96 97 98 99
	scsi_result = fc_remote_port_chkready(rport);
	if (unlikely(scsi_result)) {
		scpnt->result = scsi_result;
		zfcp_scsi_dbf_event_result("fail", 4, adapter, scpnt, NULL);
		scpnt->scsi_done(scpnt);
		return 0;
	}

100 101 102 103 104 105 106
	status = atomic_read(&unit->status);
	if (unlikely((status & ZFCP_STATUS_COMMON_ERP_FAILED) ||
		     !(status & ZFCP_STATUS_COMMON_RUNNING))) {
		zfcp_scsi_command_fail(scpnt, DID_ERROR);
		return 0;;
	}

107
	ret = zfcp_fsf_send_fcp_command_task(unit, scpnt);
108
	if (unlikely(ret == -EBUSY))
109
		return SCSI_MLQUEUE_DEVICE_BUSY;
110 111
	else if (unlikely(ret < 0))
		return SCSI_MLQUEUE_HOST_BUSY;
L
Linus Torvalds 已提交
112

113
	return ret;
L
Linus Torvalds 已提交
114 115
}

116 117 118
static struct zfcp_unit *zfcp_unit_lookup(struct zfcp_adapter *adapter,
					  int channel, unsigned int id,
					  unsigned int lun)
L
Linus Torvalds 已提交
119 120
{
	struct zfcp_port *port;
121
	struct zfcp_unit *unit;
122
	int scsi_lun;
L
Linus Torvalds 已提交
123 124

	list_for_each_entry(port, &adapter->port_list_head, list) {
125
		if (!port->rport || (id != port->rport->scsi_target_id))
L
Linus Torvalds 已提交
126
			continue;
127 128 129 130
		list_for_each_entry(unit, &port->unit_list_head, list) {
			scsi_lun = scsilun_to_int(
				(struct scsi_lun *)&unit->fcp_lun);
			if (lun == scsi_lun)
131
				return unit;
132
		}
L
Linus Torvalds 已提交
133
	}
134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150

	return NULL;
}

static int zfcp_scsi_slave_alloc(struct scsi_device *sdp)
{
	struct zfcp_adapter *adapter;
	struct zfcp_unit *unit;
	unsigned long flags;
	int retval = -ENXIO;

	adapter = (struct zfcp_adapter *) sdp->host->hostdata[0];
	if (!adapter)
		goto out;

	read_lock_irqsave(&zfcp_data.config_lock, flags);
	unit = zfcp_unit_lookup(adapter, sdp->channel, sdp->id, sdp->lun);
151
	if (unit) {
152 153 154 155 156 157 158
		sdp->hostdata = unit;
		unit->device = sdp;
		zfcp_unit_get(unit);
		retval = 0;
	}
	read_unlock_irqrestore(&zfcp_data.config_lock, flags);
out:
L
Linus Torvalds 已提交
159 160 161
	return retval;
}

162
static int zfcp_scsi_eh_abort_handler(struct scsi_cmnd *scpnt)
L
Linus Torvalds 已提交
163
{
164 165 166 167 168
	struct Scsi_Host *scsi_host = scpnt->device->host;
	struct zfcp_adapter *adapter =
		(struct zfcp_adapter *) scsi_host->hostdata[0];
	struct zfcp_unit *unit = scpnt->device->hostdata;
	struct zfcp_fsf_req *old_req, *abrt_req;
L
Linus Torvalds 已提交
169
	unsigned long flags;
170
	unsigned long old_req_id = (unsigned long) scpnt->host_scribble;
171
	int retval = SUCCESS;
172
	int retry = 3;
L
Linus Torvalds 已提交
173

174
	/* avoid race condition between late normal completion and abort */
L
Linus Torvalds 已提交
175 176
	write_lock_irqsave(&adapter->abort_lock, flags);

177
	spin_lock(&adapter->req_list_lock);
178
	old_req = zfcp_reqlist_find(adapter, old_req_id);
179
	spin_unlock(&adapter->req_list_lock);
180
	if (!old_req) {
L
Linus Torvalds 已提交
181
		write_unlock_irqrestore(&adapter->abort_lock, flags);
182 183
		zfcp_scsi_dbf_event_abort("lte1", adapter, scpnt, NULL,
					  old_req_id);
184
		return FAILED; /* completion could be in progress */
L
Linus Torvalds 已提交
185
	}
186
	old_req->data = NULL;
L
Linus Torvalds 已提交
187

188
	/* don't access old fsf_req after releasing the abort_lock */
L
Linus Torvalds 已提交
189
	write_unlock_irqrestore(&adapter->abort_lock, flags);
190

191 192 193 194 195 196 197 198 199 200 201 202
	while (retry--) {
		abrt_req = zfcp_fsf_abort_fcp_command(old_req_id, unit);
		if (abrt_req)
			break;

		zfcp_erp_wait(adapter);
		if (!(atomic_read(&adapter->status) &
		      ZFCP_STATUS_COMMON_RUNNING)) {
			zfcp_scsi_dbf_event_abort("nres", adapter, scpnt, NULL,
						  old_req_id);
			return SUCCESS;
		}
L
Linus Torvalds 已提交
203
	}
204 205
	if (!abrt_req)
		return FAILED;
L
Linus Torvalds 已提交
206

207 208
	wait_event(abrt_req->completion_wq,
		   abrt_req->status & ZFCP_STATUS_FSFREQ_COMPLETED);
209

210 211 212 213 214 215
	if (abrt_req->status & ZFCP_STATUS_FSFREQ_ABORTSUCCEEDED)
		zfcp_scsi_dbf_event_abort("okay", adapter, scpnt, abrt_req, 0);
	else if (abrt_req->status & ZFCP_STATUS_FSFREQ_ABORTNOTNEEDED)
		zfcp_scsi_dbf_event_abort("lte2", adapter, scpnt, abrt_req, 0);
	else {
		zfcp_scsi_dbf_event_abort("fail", adapter, scpnt, abrt_req, 0);
L
Linus Torvalds 已提交
216 217
		retval = FAILED;
	}
218
	zfcp_fsf_req_free(abrt_req);
219
	return retval;
L
Linus Torvalds 已提交
220 221
}

222
static int zfcp_task_mgmt_function(struct scsi_cmnd *scpnt, u8 tm_flags)
L
Linus Torvalds 已提交
223
{
224
	struct zfcp_unit *unit = scpnt->device->hostdata;
L
Linus Torvalds 已提交
225 226
	struct zfcp_adapter *adapter = unit->port->adapter;
	struct zfcp_fsf_req *fsf_req;
227
	int retval = SUCCESS;
228 229 230 231 232 233 234 235 236 237 238 239 240 241
	int retry = 3;

	while (retry--) {
		fsf_req = zfcp_fsf_send_fcp_ctm(unit, tm_flags);
		if (fsf_req)
			break;

		zfcp_erp_wait(adapter);
		if (!(atomic_read(&adapter->status) &
		      ZFCP_STATUS_COMMON_RUNNING)) {
			zfcp_scsi_dbf_event_devreset("nres", tm_flags, unit,
						     scpnt);
			return SUCCESS;
		}
L
Linus Torvalds 已提交
242
	}
243 244
	if (!fsf_req)
		return FAILED;
L
Linus Torvalds 已提交
245

246 247
	wait_event(fsf_req->completion_wq,
		   fsf_req->status & ZFCP_STATUS_FSFREQ_COMPLETED);
248

249 250
	if (fsf_req->status & ZFCP_STATUS_FSFREQ_TMFUNCFAILED) {
		zfcp_scsi_dbf_event_devreset("fail", tm_flags, unit, scpnt);
251
		retval = FAILED;
252 253
	} else if (fsf_req->status & ZFCP_STATUS_FSFREQ_TMFUNCNOTSUPP) {
		zfcp_scsi_dbf_event_devreset("nsup", tm_flags, unit, scpnt);
254
		retval = FAILED;
255 256
	} else
		zfcp_scsi_dbf_event_devreset("okay", tm_flags, unit, scpnt);
257 258

	zfcp_fsf_req_free(fsf_req);
L
Linus Torvalds 已提交
259 260 261
	return retval;
}

262 263
static int zfcp_scsi_eh_device_reset_handler(struct scsi_cmnd *scpnt)
{
264
	return zfcp_task_mgmt_function(scpnt, FCP_LOGICAL_UNIT_RESET);
265 266 267 268
}

static int zfcp_scsi_eh_target_reset_handler(struct scsi_cmnd *scpnt)
{
269
	return zfcp_task_mgmt_function(scpnt, FCP_TARGET_RESET);
270 271
}

272
static int zfcp_scsi_eh_host_reset_handler(struct scsi_cmnd *scpnt)
L
Linus Torvalds 已提交
273
{
274 275
	struct zfcp_unit *unit = scpnt->device->hostdata;
	struct zfcp_adapter *adapter = unit->port->adapter;
L
Linus Torvalds 已提交
276

277
	zfcp_erp_adapter_reopen(adapter, 0, "schrh_1", scpnt);
278
	zfcp_erp_wait(adapter);
L
Linus Torvalds 已提交
279

280
	return SUCCESS;
L
Linus Torvalds 已提交
281 282
}

283
int zfcp_adapter_scsi_register(struct zfcp_adapter *adapter)
L
Linus Torvalds 已提交
284
{
285
	struct ccw_dev_id dev_id;
L
Linus Torvalds 已提交
286

287
	if (adapter->scsi_host)
288
		return 0;
289

290
	ccw_device_get_id(adapter->ccw_device, &dev_id);
L
Linus Torvalds 已提交
291 292 293 294
	/* register adapter as SCSI host with mid layer of SCSI stack */
	adapter->scsi_host = scsi_host_alloc(&zfcp_data.scsi_host_template,
					     sizeof (struct zfcp_adapter *));
	if (!adapter->scsi_host) {
C
Christof Schmitt 已提交
295
		dev_err(&adapter->ccw_device->dev,
296 297
			"Registering the FCP device with the "
			"SCSI stack failed\n");
298
		return -EIO;
L
Linus Torvalds 已提交
299 300 301 302 303 304
	}

	/* tell the SCSI stack some characteristics of this adapter */
	adapter->scsi_host->max_id = 1;
	adapter->scsi_host->max_lun = 1;
	adapter->scsi_host->max_channel = 0;
305 306
	adapter->scsi_host->unique_id = dev_id.devno;
	adapter->scsi_host->max_cmd_len = 255;
307
	adapter->scsi_host->transportt = zfcp_data.scsi_transport_template;
L
Linus Torvalds 已提交
308 309 310 311 312

	adapter->scsi_host->hostdata[0] = (unsigned long) adapter;

	if (scsi_add_host(adapter->scsi_host, &adapter->ccw_device->dev)) {
		scsi_host_put(adapter->scsi_host);
313
		return -EIO;
L
Linus Torvalds 已提交
314
	}
315 316

	return 0;
L
Linus Torvalds 已提交
317 318
}

319
void zfcp_adapter_scsi_unregister(struct zfcp_adapter *adapter)
L
Linus Torvalds 已提交
320 321
{
	struct Scsi_Host *shost;
322
	struct zfcp_port *port;
L
Linus Torvalds 已提交
323 324 325 326

	shost = adapter->scsi_host;
	if (!shost)
		return;
327

328 329 330 331
	read_lock_irq(&zfcp_data.config_lock);
	list_for_each_entry(port, &adapter->port_list_head, list)
		if (port->rport)
			port->rport = NULL;
332

333
	read_unlock_irq(&zfcp_data.config_lock);
334
	fc_remove_host(shost);
L
Linus Torvalds 已提交
335 336 337 338 339 340 341
	scsi_remove_host(shost);
	scsi_host_put(shost);
	adapter->scsi_host = NULL;

	return;
}

342 343
static struct fc_host_statistics*
zfcp_init_fc_host_stats(struct zfcp_adapter *adapter)
L
Linus Torvalds 已提交
344
{
345
	struct fc_host_statistics *fc_stats;
L
Linus Torvalds 已提交
346

347 348 349 350 351 352 353 354
	if (!adapter->fc_stats) {
		fc_stats = kmalloc(sizeof(*fc_stats), GFP_KERNEL);
		if (!fc_stats)
			return NULL;
		adapter->fc_stats = fc_stats; /* freed in adater_dequeue */
	}
	memset(adapter->fc_stats, 0, sizeof(*adapter->fc_stats));
	return adapter->fc_stats;
L
Linus Torvalds 已提交
355 356
}

357 358 359
static void zfcp_adjust_fc_host_stats(struct fc_host_statistics *fc_stats,
				      struct fsf_qtcb_bottom_port *data,
				      struct fsf_qtcb_bottom_port *old)
L
Linus Torvalds 已提交
360
{
361 362
	fc_stats->seconds_since_last_reset =
		data->seconds_since_last_reset - old->seconds_since_last_reset;
363 364 365 366 367 368 369 370 371 372
	fc_stats->tx_frames = data->tx_frames - old->tx_frames;
	fc_stats->tx_words = data->tx_words - old->tx_words;
	fc_stats->rx_frames = data->rx_frames - old->rx_frames;
	fc_stats->rx_words = data->rx_words - old->rx_words;
	fc_stats->lip_count = data->lip - old->lip;
	fc_stats->nos_count = data->nos - old->nos;
	fc_stats->error_frames = data->error_frames - old->error_frames;
	fc_stats->dumped_frames = data->dumped_frames - old->dumped_frames;
	fc_stats->link_failure_count = data->link_failure - old->link_failure;
	fc_stats->loss_of_sync_count = data->loss_of_sync - old->loss_of_sync;
373 374 375 376 377 378
	fc_stats->loss_of_signal_count =
		data->loss_of_signal - old->loss_of_signal;
	fc_stats->prim_seq_protocol_err_count =
		data->psp_error_counts - old->psp_error_counts;
	fc_stats->invalid_tx_word_count =
		data->invalid_tx_words - old->invalid_tx_words;
379
	fc_stats->invalid_crc_count = data->invalid_crcs - old->invalid_crcs;
380 381 382 383 384 385
	fc_stats->fcp_input_requests =
		data->input_requests - old->input_requests;
	fc_stats->fcp_output_requests =
		data->output_requests - old->output_requests;
	fc_stats->fcp_control_requests =
		data->control_requests - old->control_requests;
386 387 388
	fc_stats->fcp_input_megabytes = data->input_mb - old->input_mb;
	fc_stats->fcp_output_megabytes = data->output_mb - old->output_mb;
}
L
Linus Torvalds 已提交
389

390 391
static void zfcp_set_fc_host_stats(struct fc_host_statistics *fc_stats,
				   struct fsf_qtcb_bottom_port *data)
392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414
{
	fc_stats->seconds_since_last_reset = data->seconds_since_last_reset;
	fc_stats->tx_frames = data->tx_frames;
	fc_stats->tx_words = data->tx_words;
	fc_stats->rx_frames = data->rx_frames;
	fc_stats->rx_words = data->rx_words;
	fc_stats->lip_count = data->lip;
	fc_stats->nos_count = data->nos;
	fc_stats->error_frames = data->error_frames;
	fc_stats->dumped_frames = data->dumped_frames;
	fc_stats->link_failure_count = data->link_failure;
	fc_stats->loss_of_sync_count = data->loss_of_sync;
	fc_stats->loss_of_signal_count = data->loss_of_signal;
	fc_stats->prim_seq_protocol_err_count = data->psp_error_counts;
	fc_stats->invalid_tx_word_count = data->invalid_tx_words;
	fc_stats->invalid_crc_count = data->invalid_crcs;
	fc_stats->fcp_input_requests = data->input_requests;
	fc_stats->fcp_output_requests = data->output_requests;
	fc_stats->fcp_control_requests = data->control_requests;
	fc_stats->fcp_input_megabytes = data->input_mb;
	fc_stats->fcp_output_megabytes = data->output_mb;
}

415
static struct fc_host_statistics *zfcp_get_fc_host_stats(struct Scsi_Host *host)
416 417 418 419 420 421
{
	struct zfcp_adapter *adapter;
	struct fc_host_statistics *fc_stats;
	struct fsf_qtcb_bottom_port *data;
	int ret;

422
	adapter = (struct zfcp_adapter *)host->hostdata[0];
423 424 425 426
	fc_stats = zfcp_init_fc_host_stats(adapter);
	if (!fc_stats)
		return NULL;

427
	data = kzalloc(sizeof(*data), GFP_KERNEL);
428 429 430
	if (!data)
		return NULL;

431
	ret = zfcp_fsf_exchange_port_data_sync(adapter, data);
432 433
	if (ret) {
		kfree(data);
434
		return NULL;
435 436 437 438
	}

	if (adapter->stats_reset &&
	    ((jiffies/HZ - adapter->stats_reset) <
439
	     data->seconds_since_last_reset))
440 441
		zfcp_adjust_fc_host_stats(fc_stats, data,
					  adapter->stats_reset_data);
442
	else
443 444 445 446
		zfcp_set_fc_host_stats(fc_stats, data);

	kfree(data);
	return fc_stats;
L
Linus Torvalds 已提交
447 448
}

449
static void zfcp_reset_fc_host_stats(struct Scsi_Host *shost)
L
Linus Torvalds 已提交
450
{
451
	struct zfcp_adapter *adapter;
452
	struct fsf_qtcb_bottom_port *data;
453
	int ret;
L
Linus Torvalds 已提交
454

455
	adapter = (struct zfcp_adapter *)shost->hostdata[0];
456
	data = kzalloc(sizeof(*data), GFP_KERNEL);
457 458 459
	if (!data)
		return;

460
	ret = zfcp_fsf_exchange_port_data_sync(adapter, data);
461
	if (ret)
H
Heiko Carstens 已提交
462
		kfree(data);
463
	else {
464
		adapter->stats_reset = jiffies/HZ;
465
		kfree(adapter->stats_reset_data);
466
		adapter->stats_reset_data = data; /* finally freed in
467
						     adapter_dequeue */
468
	}
L
Linus Torvalds 已提交
469 470
}

471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487
static void zfcp_get_host_port_state(struct Scsi_Host *shost)
{
	struct zfcp_adapter *adapter =
		(struct zfcp_adapter *)shost->hostdata[0];
	int status = atomic_read(&adapter->status);

	if ((status & ZFCP_STATUS_COMMON_RUNNING) &&
	    !(status & ZFCP_STATUS_ADAPTER_LINK_UNPLUGGED))
		fc_host_port_state(shost) = FC_PORTSTATE_ONLINE;
	else if (status & ZFCP_STATUS_ADAPTER_LINK_UNPLUGGED)
		fc_host_port_state(shost) = FC_PORTSTATE_LINKDOWN;
	else if (status & ZFCP_STATUS_COMMON_ERP_FAILED)
		fc_host_port_state(shost) = FC_PORTSTATE_ERROR;
	else
		fc_host_port_state(shost) = FC_PORTSTATE_UNKNOWN;
}

488 489 490 491 492
static void zfcp_set_rport_dev_loss_tmo(struct fc_rport *rport, u32 timeout)
{
	rport->dev_loss_tmo = timeout;
}

493 494 495 496 497 498
/**
 * zfcp_scsi_dev_loss_tmo_callbk - Free any reference to rport
 * @rport: The rport that is about to be deleted.
 */
static void zfcp_scsi_dev_loss_tmo_callbk(struct fc_rport *rport)
{
499
	struct zfcp_port *port;
500 501

	write_lock_irq(&zfcp_data.config_lock);
502 503 504
	port = rport->dd_data;
	if (port)
		port->rport = NULL;
505 506 507 508 509 510 511 512 513 514 515 516 517
	write_unlock_irq(&zfcp_data.config_lock);
}

/**
 * zfcp_scsi_terminate_rport_io - Terminate all I/O on a rport
 * @rport: The FC rport where to teminate I/O
 *
 * Abort all pending SCSI commands for a port by closing the
 * port. Using a reopen for avoids a conflict with a shutdown
 * overwriting a reopen.
 */
static void zfcp_scsi_terminate_rport_io(struct fc_rport *rport)
{
518 519 520 521 522 523 524
	struct zfcp_port *port;

	write_lock_irq(&zfcp_data.config_lock);
	port = rport->dd_data;
	if (port)
		zfcp_port_get(port);
	write_unlock_irq(&zfcp_data.config_lock);
525

526 527 528 529
	if (port) {
		zfcp_erp_port_reopen(port, 0, "sctrpi1", NULL);
		zfcp_port_put(port);
	}
530 531 532 533 534 535 536
}

static void zfcp_scsi_rport_register(struct zfcp_port *port)
{
	struct fc_rport_identifiers ids;
	struct fc_rport *rport;

537 538 539
	if (port->rport)
		return;

540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560
	ids.node_name = port->wwnn;
	ids.port_name = port->wwpn;
	ids.port_id = port->d_id;
	ids.roles = FC_RPORT_ROLE_FCP_TARGET;

	rport = fc_remote_port_add(port->adapter->scsi_host, 0, &ids);
	if (!rport) {
		dev_err(&port->adapter->ccw_device->dev,
			"Registering port 0x%016Lx failed\n",
			(unsigned long long)port->wwpn);
		return;
	}

	rport->dd_data = port;
	rport->maxframe_size = port->maxframe_size;
	rport->supported_classes = port->supported_classes;
	port->rport = rport;
}

static void zfcp_scsi_rport_block(struct zfcp_port *port)
{
561 562
	struct fc_rport *rport = port->rport;

563
	if (rport) {
564
		fc_remote_port_delete(rport);
565 566
		port->rport = NULL;
	}
567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613
}

void zfcp_scsi_schedule_rport_register(struct zfcp_port *port)
{
	zfcp_port_get(port);
	port->rport_task = RPORT_ADD;

	if (!queue_work(zfcp_data.work_queue, &port->rport_work))
		zfcp_port_put(port);
}

void zfcp_scsi_schedule_rport_block(struct zfcp_port *port)
{
	zfcp_port_get(port);
	port->rport_task = RPORT_DEL;

	if (!queue_work(zfcp_data.work_queue, &port->rport_work))
		zfcp_port_put(port);
}

void zfcp_scsi_schedule_rports_block(struct zfcp_adapter *adapter)
{
	struct zfcp_port *port;

	list_for_each_entry(port, &adapter->port_list_head, list)
		zfcp_scsi_schedule_rport_block(port);
}

void zfcp_scsi_rport_work(struct work_struct *work)
{
	struct zfcp_port *port = container_of(work, struct zfcp_port,
					      rport_work);

	while (port->rport_task) {
		if (port->rport_task == RPORT_ADD) {
			port->rport_task = RPORT_NONE;
			zfcp_scsi_rport_register(port);
		} else {
			port->rport_task = RPORT_NONE;
			zfcp_scsi_rport_block(port);
		}
	}

	zfcp_port_put(port);
}


614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630
void zfcp_scsi_scan(struct work_struct *work)
{
	struct zfcp_unit *unit = container_of(work, struct zfcp_unit,
					      scsi_work);
	struct fc_rport *rport;

	flush_work(&unit->port->rport_work);
	rport = unit->port->rport;

	if (rport && rport->port_state == FC_PORTSTATE_ONLINE)
		scsi_scan_target(&rport->dev, 0, rport->scsi_target_id,
				 scsilun_to_int((struct scsi_lun *)
						&unit->fcp_lun), 0);

	zfcp_unit_put(unit);
}

631 632 633 634 635 636 637 638 639 640 641 642 643 644
static int zfcp_execute_fc_job(struct fc_bsg_job *job)
{
	switch (job->request->msgcode) {
	case FC_BSG_RPT_ELS:
	case FC_BSG_HST_ELS_NOLOGIN:
		return zfcp_fc_execute_els_fc_job(job);
	case FC_BSG_RPT_CT:
	case FC_BSG_HST_CT:
		return zfcp_fc_execute_ct_fc_job(job);
	default:
		return -EINVAL;
	}
}

L
Linus Torvalds 已提交
645 646 647 648
struct fc_function_template zfcp_transport_functions = {
	.show_starget_port_id = 1,
	.show_starget_port_name = 1,
	.show_starget_node_name = 1,
649
	.show_rport_supported_classes = 1,
650
	.show_rport_maxframe_size = 1,
651
	.show_rport_dev_loss_tmo = 1,
652 653
	.show_host_node_name = 1,
	.show_host_port_name = 1,
654
	.show_host_permanent_port_name = 1,
655
	.show_host_supported_classes = 1,
656
	.show_host_supported_speeds = 1,
657
	.show_host_maxframe_size = 1,
658
	.show_host_serial_number = 1,
659 660
	.get_fc_host_stats = zfcp_get_fc_host_stats,
	.reset_fc_host_stats = zfcp_reset_fc_host_stats,
661
	.set_rport_dev_loss_tmo = zfcp_set_rport_dev_loss_tmo,
662
	.get_host_port_state = zfcp_get_host_port_state,
663 664
	.dev_loss_tmo_callbk = zfcp_scsi_dev_loss_tmo_callbk,
	.terminate_rport_io = zfcp_scsi_terminate_rport_io,
665
	.show_host_port_state = 1,
666
	.bsg_request = zfcp_execute_fc_job,
667 668
	/* no functions registered for following dynamic attributes but
	   directly set by LLDD */
669
	.show_host_port_type = 1,
670 671
	.show_host_speed = 1,
	.show_host_port_id = 1,
672
	.disable_target_scan = 1,
L
Linus Torvalds 已提交
673 674
};

675 676 677 678 679
struct zfcp_data zfcp_data = {
	.scsi_host_template = {
		.name			 = "zfcp",
		.module			 = THIS_MODULE,
		.proc_name		 = "zfcp",
680
		.change_queue_depth	 = zfcp_scsi_change_queue_depth,
681 682 683 684 685 686 687 688 689 690 691 692 693 694 695
		.slave_alloc		 = zfcp_scsi_slave_alloc,
		.slave_configure	 = zfcp_scsi_slave_configure,
		.slave_destroy		 = zfcp_scsi_slave_destroy,
		.queuecommand		 = zfcp_scsi_queuecommand,
		.eh_abort_handler	 = zfcp_scsi_eh_abort_handler,
		.eh_device_reset_handler = zfcp_scsi_eh_device_reset_handler,
		.eh_target_reset_handler = zfcp_scsi_eh_target_reset_handler,
		.eh_host_reset_handler	 = zfcp_scsi_eh_host_reset_handler,
		.can_queue		 = 4096,
		.this_id		 = -1,
		.sg_tablesize		 = ZFCP_MAX_SBALES_PER_REQ,
		.cmd_per_lun		 = 1,
		.use_clustering		 = 1,
		.sdev_attrs		 = zfcp_sysfs_sdev_attrs,
		.max_sectors		 = (ZFCP_MAX_SBALES_PER_REQ * 8),
696
		.shost_attrs		 = zfcp_sysfs_shost_attrs,
697 698
	},
};