Linux Audio

Check our new training course

Loading...
v3.1
   1/*
   2 * Copyright (c) 2005-2010 Brocade Communications Systems, Inc.
 
   3 * All rights reserved
   4 * www.brocade.com
   5 *
   6 * Linux driver for Brocade Fibre Channel Host Bus Adapter.
   7 *
   8 * This program is free software; you can redistribute it and/or modify it
   9 * under the terms of the GNU General Public License (GPL) Version 2 as
  10 * published by the Free Software Foundation
  11 *
  12 * This program is distributed in the hope that it will be useful, but
  13 * WITHOUT ANY WARRANTY; without even the implied warranty of
  14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15 * General Public License for more details.
  16 */
  17
  18/*
  19 *  bfad_im.c Linux driver IM module.
  20 */
  21
 
 
  22#include "bfad_drv.h"
  23#include "bfad_im.h"
  24#include "bfa_fcs.h"
  25
  26BFA_TRC_FILE(LDRV, IM);
  27
  28DEFINE_IDR(bfad_im_port_index);
  29struct scsi_transport_template *bfad_im_scsi_transport_template;
  30struct scsi_transport_template *bfad_im_scsi_vport_transport_template;
  31static void bfad_im_itnim_work_handler(struct work_struct *work);
  32static int bfad_im_queuecommand(struct Scsi_Host *h, struct scsi_cmnd *cmnd);
  33static int bfad_im_slave_alloc(struct scsi_device *sdev);
  34static void bfad_im_fc_rport_add(struct bfad_im_port_s  *im_port,
  35				struct bfad_itnim_s *itnim);
  36
  37void
  38bfa_cb_ioim_done(void *drv, struct bfad_ioim_s *dio,
  39			enum bfi_ioim_status io_status, u8 scsi_status,
  40			int sns_len, u8 *sns_info, s32 residue)
  41{
  42	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dio;
  43	struct bfad_s         *bfad = drv;
  44	struct bfad_itnim_data_s *itnim_data;
  45	struct bfad_itnim_s *itnim;
  46	u8         host_status = DID_OK;
  47
  48	switch (io_status) {
  49	case BFI_IOIM_STS_OK:
  50		bfa_trc(bfad, scsi_status);
  51		scsi_set_resid(cmnd, 0);
  52
  53		if (sns_len > 0) {
  54			bfa_trc(bfad, sns_len);
  55			if (sns_len > SCSI_SENSE_BUFFERSIZE)
  56				sns_len = SCSI_SENSE_BUFFERSIZE;
  57			memcpy(cmnd->sense_buffer, sns_info, sns_len);
  58		}
  59
  60		if (residue > 0) {
  61			bfa_trc(bfad, residue);
  62			scsi_set_resid(cmnd, residue);
  63			if (!sns_len && (scsi_status == SAM_STAT_GOOD) &&
  64				(scsi_bufflen(cmnd) - residue) <
  65					cmnd->underflow) {
  66				bfa_trc(bfad, 0);
  67				host_status = DID_ERROR;
  68			}
  69		}
  70		cmnd->result = ScsiResult(host_status, scsi_status);
  71
  72		break;
  73
  74	case BFI_IOIM_STS_ABORTED:
  75	case BFI_IOIM_STS_TIMEDOUT:
 
 
 
  76	case BFI_IOIM_STS_PATHTOV:
 
 
 
  77	default:
  78		host_status = DID_ERROR;
  79		cmnd->result = ScsiResult(host_status, 0);
  80	}
  81
  82	/* Unmap DMA, if host is NULL, it means a scsi passthru cmd */
  83	if (cmnd->device->host != NULL)
  84		scsi_dma_unmap(cmnd);
  85
  86	cmnd->host_scribble = NULL;
  87	bfa_trc(bfad, cmnd->result);
  88
  89	itnim_data = cmnd->device->hostdata;
  90	if (itnim_data) {
  91		itnim = itnim_data->itnim;
  92		if (!cmnd->result && itnim &&
  93			 (bfa_lun_queue_depth > cmnd->device->queue_depth)) {
  94			/* Queue depth adjustment for good status completion */
  95			bfad_ramp_up_qdepth(itnim, cmnd->device);
  96		} else if (cmnd->result == SAM_STAT_TASK_SET_FULL && itnim) {
  97			/* qfull handling */
  98			bfad_handle_qfull(itnim, cmnd->device);
  99		}
 100	}
 101
 102	cmnd->scsi_done(cmnd);
 103}
 104
 105void
 106bfa_cb_ioim_good_comp(void *drv, struct bfad_ioim_s *dio)
 107{
 108	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dio;
 109	struct bfad_itnim_data_s *itnim_data;
 110	struct bfad_itnim_s *itnim;
 111
 112	cmnd->result = ScsiResult(DID_OK, SCSI_STATUS_GOOD);
 113
 114	/* Unmap DMA, if host is NULL, it means a scsi passthru cmd */
 115	if (cmnd->device->host != NULL)
 116		scsi_dma_unmap(cmnd);
 117
 118	cmnd->host_scribble = NULL;
 119
 120	/* Queue depth adjustment */
 121	if (bfa_lun_queue_depth > cmnd->device->queue_depth) {
 122		itnim_data = cmnd->device->hostdata;
 123		if (itnim_data) {
 124			itnim = itnim_data->itnim;
 125			if (itnim)
 126				bfad_ramp_up_qdepth(itnim, cmnd->device);
 127		}
 128	}
 129
 130	cmnd->scsi_done(cmnd);
 131}
 132
 133void
 134bfa_cb_ioim_abort(void *drv, struct bfad_ioim_s *dio)
 135{
 136	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dio;
 137	struct bfad_s         *bfad = drv;
 138
 139	cmnd->result = ScsiResult(DID_ERROR, 0);
 140
 141	/* Unmap DMA, if host is NULL, it means a scsi passthru cmd */
 142	if (cmnd->device->host != NULL)
 143		scsi_dma_unmap(cmnd);
 144
 145	bfa_trc(bfad, cmnd->result);
 146	cmnd->host_scribble = NULL;
 147}
 148
 149void
 150bfa_cb_tskim_done(void *bfad, struct bfad_tskim_s *dtsk,
 151		   enum bfi_tskim_status tsk_status)
 152{
 153	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dtsk;
 154	wait_queue_head_t *wq;
 155
 156	cmnd->SCp.Status |= tsk_status << 1;
 157	set_bit(IO_DONE_BIT, (unsigned long *)&cmnd->SCp.Status);
 158	wq = (wait_queue_head_t *) cmnd->SCp.ptr;
 159	cmnd->SCp.ptr = NULL;
 160
 161	if (wq)
 162		wake_up(wq);
 163}
 164
 165/*
 166 *  Scsi_Host_template SCSI host template
 167 */
 168/*
 169 * Scsi_Host template entry, returns BFAD PCI info.
 170 */
 171static const char *
 172bfad_im_info(struct Scsi_Host *shost)
 173{
 174	static char     bfa_buf[256];
 175	struct bfad_im_port_s *im_port =
 176			(struct bfad_im_port_s *) shost->hostdata[0];
 177	struct bfad_s *bfad = im_port->bfad;
 178
 179	memset(bfa_buf, 0, sizeof(bfa_buf));
 180	snprintf(bfa_buf, sizeof(bfa_buf),
 181		"Brocade FC/FCOE Adapter, " "hwpath: %s driver: %s",
 182		bfad->pci_name, BFAD_DRIVER_VERSION);
 183
 184	return bfa_buf;
 185}
 186
 187/*
 188 * Scsi_Host template entry, aborts the specified SCSI command.
 189 *
 190 * Returns: SUCCESS or FAILED.
 191 */
 192static int
 193bfad_im_abort_handler(struct scsi_cmnd *cmnd)
 194{
 195	struct Scsi_Host *shost = cmnd->device->host;
 196	struct bfad_im_port_s *im_port =
 197			(struct bfad_im_port_s *) shost->hostdata[0];
 198	struct bfad_s         *bfad = im_port->bfad;
 199	struct bfa_ioim_s *hal_io;
 200	unsigned long   flags;
 201	u32        timeout;
 202	int             rc = FAILED;
 203
 204	spin_lock_irqsave(&bfad->bfad_lock, flags);
 205	hal_io = (struct bfa_ioim_s *) cmnd->host_scribble;
 206	if (!hal_io) {
 207		/* IO has been completed, retrun success */
 208		rc = SUCCESS;
 209		goto out;
 210	}
 211	if (hal_io->dio != (struct bfad_ioim_s *) cmnd) {
 212		rc = FAILED;
 213		goto out;
 214	}
 215
 216	bfa_trc(bfad, hal_io->iotag);
 217	BFA_LOG(KERN_INFO, bfad, bfa_log_level,
 218		"scsi%d: abort cmnd %p iotag %x\n",
 219		im_port->shost->host_no, cmnd, hal_io->iotag);
 220	(void) bfa_ioim_abort(hal_io);
 221	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 222
 223	/* Need to wait until the command get aborted */
 224	timeout = 10;
 225	while ((struct bfa_ioim_s *) cmnd->host_scribble == hal_io) {
 226		set_current_state(TASK_UNINTERRUPTIBLE);
 227		schedule_timeout(timeout);
 228		if (timeout < 4 * HZ)
 229			timeout *= 2;
 230	}
 231
 232	cmnd->scsi_done(cmnd);
 233	bfa_trc(bfad, hal_io->iotag);
 234	BFA_LOG(KERN_INFO, bfad, bfa_log_level,
 235		"scsi%d: complete abort 0x%p iotag 0x%x\n",
 236		im_port->shost->host_no, cmnd, hal_io->iotag);
 237	return SUCCESS;
 238out:
 239	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 240	return rc;
 241}
 242
 243static bfa_status_t
 244bfad_im_target_reset_send(struct bfad_s *bfad, struct scsi_cmnd *cmnd,
 245		     struct bfad_itnim_s *itnim)
 246{
 247	struct bfa_tskim_s *tskim;
 248	struct bfa_itnim_s *bfa_itnim;
 249	bfa_status_t    rc = BFA_STATUS_OK;
 250	struct scsi_lun scsilun;
 251
 252	tskim = bfa_tskim_alloc(&bfad->bfa, (struct bfad_tskim_s *) cmnd);
 253	if (!tskim) {
 254		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 255			"target reset, fail to allocate tskim\n");
 256		rc = BFA_STATUS_FAILED;
 257		goto out;
 258	}
 259
 260	/*
 261	 * Set host_scribble to NULL to avoid aborting a task command if
 262	 * happens.
 263	 */
 264	cmnd->host_scribble = NULL;
 265	cmnd->SCp.Status = 0;
 266	bfa_itnim = bfa_fcs_itnim_get_halitn(&itnim->fcs_itnim);
 
 
 
 
 
 
 
 
 
 
 
 
 
 267	memset(&scsilun, 0, sizeof(scsilun));
 268	bfa_tskim_start(tskim, bfa_itnim, scsilun,
 269			    FCP_TM_TARGET_RESET, BFAD_TARGET_RESET_TMO);
 270out:
 271	return rc;
 272}
 273
 274/*
 275 * Scsi_Host template entry, resets a LUN and abort its all commands.
 276 *
 277 * Returns: SUCCESS or FAILED.
 278 *
 279 */
 280static int
 281bfad_im_reset_lun_handler(struct scsi_cmnd *cmnd)
 282{
 283	struct Scsi_Host *shost = cmnd->device->host;
 284	struct bfad_im_port_s *im_port =
 285			(struct bfad_im_port_s *) shost->hostdata[0];
 286	struct bfad_itnim_data_s *itnim_data = cmnd->device->hostdata;
 287	struct bfad_s         *bfad = im_port->bfad;
 288	struct bfa_tskim_s *tskim;
 289	struct bfad_itnim_s   *itnim;
 290	struct bfa_itnim_s *bfa_itnim;
 291	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(wq);
 292	int             rc = SUCCESS;
 293	unsigned long   flags;
 294	enum bfi_tskim_status task_status;
 295	struct scsi_lun scsilun;
 296
 297	spin_lock_irqsave(&bfad->bfad_lock, flags);
 298	itnim = itnim_data->itnim;
 299	if (!itnim) {
 300		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 301		rc = FAILED;
 302		goto out;
 303	}
 304
 305	tskim = bfa_tskim_alloc(&bfad->bfa, (struct bfad_tskim_s *) cmnd);
 306	if (!tskim) {
 307		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 308				"LUN reset, fail to allocate tskim");
 309		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 310		rc = FAILED;
 311		goto out;
 312	}
 313
 314	/*
 315	 * Set host_scribble to NULL to avoid aborting a task command
 316	 * if happens.
 317	 */
 318	cmnd->host_scribble = NULL;
 319	cmnd->SCp.ptr = (char *)&wq;
 320	cmnd->SCp.Status = 0;
 321	bfa_itnim = bfa_fcs_itnim_get_halitn(&itnim->fcs_itnim);
 
 
 
 
 
 
 
 
 
 
 
 
 
 322	int_to_scsilun(cmnd->device->lun, &scsilun);
 323	bfa_tskim_start(tskim, bfa_itnim, scsilun,
 324			    FCP_TM_LUN_RESET, BFAD_LUN_RESET_TMO);
 325	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 326
 327	wait_event(wq, test_bit(IO_DONE_BIT,
 328			(unsigned long *)&cmnd->SCp.Status));
 329
 330	task_status = cmnd->SCp.Status >> 1;
 331	if (task_status != BFI_TSKIM_STS_OK) {
 332		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 333			"LUN reset failure, status: %d\n", task_status);
 334		rc = FAILED;
 335	}
 336
 337out:
 338	return rc;
 339}
 340
 341/*
 342 * Scsi_Host template entry, resets the bus and abort all commands.
 343 */
 344static int
 345bfad_im_reset_bus_handler(struct scsi_cmnd *cmnd)
 346{
 347	struct Scsi_Host *shost = cmnd->device->host;
 348	struct bfad_im_port_s *im_port =
 349				(struct bfad_im_port_s *) shost->hostdata[0];
 350	struct bfad_s         *bfad = im_port->bfad;
 351	struct bfad_itnim_s   *itnim;
 352	unsigned long   flags;
 353	u32        i, rc, err_cnt = 0;
 354	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(wq);
 355	enum bfi_tskim_status task_status;
 356
 357	spin_lock_irqsave(&bfad->bfad_lock, flags);
 358	for (i = 0; i < MAX_FCP_TARGET; i++) {
 359		itnim = bfad_get_itnim(im_port, i);
 360		if (itnim) {
 361			cmnd->SCp.ptr = (char *)&wq;
 362			rc = bfad_im_target_reset_send(bfad, cmnd, itnim);
 363			if (rc != BFA_STATUS_OK) {
 364				err_cnt++;
 365				continue;
 366			}
 367
 368			/* wait target reset to complete */
 369			spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 370			wait_event(wq, test_bit(IO_DONE_BIT,
 371					(unsigned long *)&cmnd->SCp.Status));
 372			spin_lock_irqsave(&bfad->bfad_lock, flags);
 373
 374			task_status = cmnd->SCp.Status >> 1;
 375			if (task_status != BFI_TSKIM_STS_OK) {
 376				BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 377					"target reset failure,"
 378					" status: %d\n", task_status);
 379				err_cnt++;
 380			}
 381		}
 382	}
 383	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 384
 385	if (err_cnt)
 386		return FAILED;
 387
 388	return SUCCESS;
 389}
 390
 391/*
 392 * Scsi_Host template entry slave_destroy.
 393 */
 394static void
 395bfad_im_slave_destroy(struct scsi_device *sdev)
 396{
 397	sdev->hostdata = NULL;
 398	return;
 399}
 400
 401/*
 402 *  BFA FCS itnim callbacks
 403 */
 404
 405/*
 406 * BFA FCS itnim alloc callback, after successful PRLI
 407 * Context: Interrupt
 408 */
 409void
 410bfa_fcb_itnim_alloc(struct bfad_s *bfad, struct bfa_fcs_itnim_s **itnim,
 411		    struct bfad_itnim_s **itnim_drv)
 412{
 413	*itnim_drv = kzalloc(sizeof(struct bfad_itnim_s), GFP_ATOMIC);
 414	if (*itnim_drv == NULL)
 415		return;
 416
 417	(*itnim_drv)->im = bfad->im;
 418	*itnim = &(*itnim_drv)->fcs_itnim;
 419	(*itnim_drv)->state = ITNIM_STATE_NONE;
 420
 421	/*
 422	 * Initiaze the itnim_work
 423	 */
 424	INIT_WORK(&(*itnim_drv)->itnim_work, bfad_im_itnim_work_handler);
 425	bfad->bfad_flags |= BFAD_RPORT_ONLINE;
 426}
 427
 428/*
 429 * BFA FCS itnim free callback.
 430 * Context: Interrupt. bfad_lock is held
 431 */
 432void
 433bfa_fcb_itnim_free(struct bfad_s *bfad, struct bfad_itnim_s *itnim_drv)
 434{
 435	struct bfad_port_s    *port;
 436	wwn_t wwpn;
 437	u32 fcid;
 438	char wwpn_str[32], fcid_str[16];
 439	struct bfad_im_s	*im = itnim_drv->im;
 440
 441	/* online to free state transtion should not happen */
 442	WARN_ON(itnim_drv->state == ITNIM_STATE_ONLINE);
 443
 444	itnim_drv->queue_work = 1;
 445	/* offline request is not yet done, use the same request to free */
 446	if (itnim_drv->state == ITNIM_STATE_OFFLINE_PENDING)
 447		itnim_drv->queue_work = 0;
 448
 449	itnim_drv->state = ITNIM_STATE_FREE;
 450	port = bfa_fcs_itnim_get_drvport(&itnim_drv->fcs_itnim);
 451	itnim_drv->im_port = port->im_port;
 452	wwpn = bfa_fcs_itnim_get_pwwn(&itnim_drv->fcs_itnim);
 453	fcid = bfa_fcs_itnim_get_fcid(&itnim_drv->fcs_itnim);
 454	wwn2str(wwpn_str, wwpn);
 455	fcid2str(fcid_str, fcid);
 456	BFA_LOG(KERN_INFO, bfad, bfa_log_level,
 457		"ITNIM FREE scsi%d: FCID: %s WWPN: %s\n",
 458		port->im_port->shost->host_no,
 459		fcid_str, wwpn_str);
 460
 461	/* ITNIM processing */
 462	if (itnim_drv->queue_work)
 463		queue_work(im->drv_workq, &itnim_drv->itnim_work);
 464}
 465
 466/*
 467 * BFA FCS itnim online callback.
 468 * Context: Interrupt. bfad_lock is held
 469 */
 470void
 471bfa_fcb_itnim_online(struct bfad_itnim_s *itnim_drv)
 472{
 473	struct bfad_port_s    *port;
 474	struct bfad_im_s	*im = itnim_drv->im;
 475
 476	itnim_drv->bfa_itnim = bfa_fcs_itnim_get_halitn(&itnim_drv->fcs_itnim);
 477	port = bfa_fcs_itnim_get_drvport(&itnim_drv->fcs_itnim);
 478	itnim_drv->state = ITNIM_STATE_ONLINE;
 479	itnim_drv->queue_work = 1;
 480	itnim_drv->im_port = port->im_port;
 481
 482	/* ITNIM processing */
 483	if (itnim_drv->queue_work)
 484		queue_work(im->drv_workq, &itnim_drv->itnim_work);
 485}
 486
 487/*
 488 * BFA FCS itnim offline callback.
 489 * Context: Interrupt. bfad_lock is held
 490 */
 491void
 492bfa_fcb_itnim_offline(struct bfad_itnim_s *itnim_drv)
 493{
 494	struct bfad_port_s    *port;
 495	struct bfad_s *bfad;
 496	struct bfad_im_s	*im = itnim_drv->im;
 497
 498	port = bfa_fcs_itnim_get_drvport(&itnim_drv->fcs_itnim);
 499	bfad = port->bfad;
 500	if ((bfad->pport.flags & BFAD_PORT_DELETE) ||
 501		 (port->flags & BFAD_PORT_DELETE)) {
 502		itnim_drv->state = ITNIM_STATE_OFFLINE;
 503		return;
 504	}
 505	itnim_drv->im_port = port->im_port;
 506	itnim_drv->state = ITNIM_STATE_OFFLINE_PENDING;
 507	itnim_drv->queue_work = 1;
 508
 509	/* ITNIM processing */
 510	if (itnim_drv->queue_work)
 511		queue_work(im->drv_workq, &itnim_drv->itnim_work);
 512}
 513
 514/*
 515 * Allocate a Scsi_Host for a port.
 516 */
 517int
 518bfad_im_scsi_host_alloc(struct bfad_s *bfad, struct bfad_im_port_s *im_port,
 519			struct device *dev)
 520{
 521	int error = 1;
 522
 523	mutex_lock(&bfad_mutex);
 524	if (!idr_pre_get(&bfad_im_port_index, GFP_KERNEL)) {
 525		mutex_unlock(&bfad_mutex);
 526		printk(KERN_WARNING "idr_pre_get failure\n");
 527		goto out;
 528	}
 529
 530	error = idr_get_new(&bfad_im_port_index, im_port,
 531					 &im_port->idr_id);
 532	if (error) {
 533		mutex_unlock(&bfad_mutex);
 534		printk(KERN_WARNING "idr_get_new failure\n");
 535		goto out;
 536	}
 537
 538	mutex_unlock(&bfad_mutex);
 539
 540	im_port->shost = bfad_scsi_host_alloc(im_port, bfad);
 541	if (!im_port->shost) {
 542		error = 1;
 543		goto out_free_idr;
 544	}
 545
 546	im_port->shost->hostdata[0] = (unsigned long)im_port;
 547	im_port->shost->unique_id = im_port->idr_id;
 548	im_port->shost->this_id = -1;
 549	im_port->shost->max_id = MAX_FCP_TARGET;
 550	im_port->shost->max_lun = MAX_FCP_LUN;
 551	im_port->shost->max_cmd_len = 16;
 552	im_port->shost->can_queue = bfad->cfg_data.ioc_queue_depth;
 553	if (im_port->port->pvb_type == BFAD_PORT_PHYS_BASE)
 554		im_port->shost->transportt = bfad_im_scsi_transport_template;
 555	else
 556		im_port->shost->transportt =
 557				bfad_im_scsi_vport_transport_template;
 558
 559	error = scsi_add_host_with_dma(im_port->shost, dev, &bfad->pcidev->dev);
 560	if (error) {
 561		printk(KERN_WARNING "scsi_add_host failure %d\n", error);
 562		goto out_fc_rel;
 563	}
 564
 565	return 0;
 566
 567out_fc_rel:
 568	scsi_host_put(im_port->shost);
 569	im_port->shost = NULL;
 570out_free_idr:
 571	mutex_lock(&bfad_mutex);
 572	idr_remove(&bfad_im_port_index, im_port->idr_id);
 573	mutex_unlock(&bfad_mutex);
 574out:
 575	return error;
 576}
 577
 578void
 579bfad_im_scsi_host_free(struct bfad_s *bfad, struct bfad_im_port_s *im_port)
 580{
 581	bfa_trc(bfad, bfad->inst_no);
 582	BFA_LOG(KERN_INFO, bfad, bfa_log_level, "Free scsi%d\n",
 583			im_port->shost->host_no);
 584
 585	fc_remove_host(im_port->shost);
 586
 587	scsi_remove_host(im_port->shost);
 588	scsi_host_put(im_port->shost);
 589
 590	mutex_lock(&bfad_mutex);
 591	idr_remove(&bfad_im_port_index, im_port->idr_id);
 592	mutex_unlock(&bfad_mutex);
 593}
 594
 595static void
 596bfad_im_port_delete_handler(struct work_struct *work)
 597{
 598	struct bfad_im_port_s *im_port =
 599		container_of(work, struct bfad_im_port_s, port_delete_work);
 600
 601	if (im_port->port->pvb_type != BFAD_PORT_PHYS_BASE) {
 602		im_port->flags |= BFAD_PORT_DELETE;
 603		fc_vport_terminate(im_port->fc_vport);
 604	}
 605}
 606
 607bfa_status_t
 608bfad_im_port_new(struct bfad_s *bfad, struct bfad_port_s *port)
 609{
 610	int             rc = BFA_STATUS_OK;
 611	struct bfad_im_port_s *im_port;
 612
 613	im_port = kzalloc(sizeof(struct bfad_im_port_s), GFP_ATOMIC);
 614	if (im_port == NULL) {
 615		rc = BFA_STATUS_ENOMEM;
 616		goto ext;
 617	}
 618	port->im_port = im_port;
 619	im_port->port = port;
 620	im_port->bfad = bfad;
 621
 622	INIT_WORK(&im_port->port_delete_work, bfad_im_port_delete_handler);
 623	INIT_LIST_HEAD(&im_port->itnim_mapped_list);
 624	INIT_LIST_HEAD(&im_port->binding_list);
 625
 626ext:
 627	return rc;
 628}
 629
 630void
 631bfad_im_port_delete(struct bfad_s *bfad, struct bfad_port_s *port)
 632{
 633	struct bfad_im_port_s *im_port = port->im_port;
 634
 635	queue_work(bfad->im->drv_workq,
 636				&im_port->port_delete_work);
 637}
 638
 639void
 640bfad_im_port_clean(struct bfad_im_port_s *im_port)
 641{
 642	struct bfad_fcp_binding *bp, *bp_new;
 643	unsigned long flags;
 644	struct bfad_s *bfad =  im_port->bfad;
 645
 646	spin_lock_irqsave(&bfad->bfad_lock, flags);
 647	list_for_each_entry_safe(bp, bp_new, &im_port->binding_list,
 648					list_entry) {
 649		list_del(&bp->list_entry);
 650		kfree(bp);
 651	}
 652
 653	/* the itnim_mapped_list must be empty at this time */
 654	WARN_ON(!list_empty(&im_port->itnim_mapped_list));
 655
 656	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 657}
 658
 659static void bfad_aen_im_notify_handler(struct work_struct *work)
 660{
 661	struct bfad_im_s *im =
 662		container_of(work, struct bfad_im_s, aen_im_notify_work);
 663	struct bfa_aen_entry_s *aen_entry;
 664	struct bfad_s *bfad = im->bfad;
 665	struct Scsi_Host *shost = bfad->pport.im_port->shost;
 666	void *event_data;
 667	unsigned long flags;
 668
 669	while (!list_empty(&bfad->active_aen_q)) {
 670		spin_lock_irqsave(&bfad->bfad_aen_spinlock, flags);
 671		bfa_q_deq(&bfad->active_aen_q, &aen_entry);
 672		spin_unlock_irqrestore(&bfad->bfad_aen_spinlock, flags);
 673		event_data = (char *)aen_entry + sizeof(struct list_head);
 674		fc_host_post_vendor_event(shost, fc_get_event_number(),
 675				sizeof(struct bfa_aen_entry_s) -
 676				sizeof(struct list_head),
 677				(char *)event_data, BFAD_NL_VENDOR_ID);
 678		spin_lock_irqsave(&bfad->bfad_aen_spinlock, flags);
 679		list_add_tail(&aen_entry->qe, &bfad->free_aen_q);
 680		spin_unlock_irqrestore(&bfad->bfad_aen_spinlock, flags);
 681	}
 682}
 683
 684bfa_status_t
 685bfad_im_probe(struct bfad_s *bfad)
 686{
 687	struct bfad_im_s      *im;
 688	bfa_status_t    rc = BFA_STATUS_OK;
 689
 690	im = kzalloc(sizeof(struct bfad_im_s), GFP_KERNEL);
 691	if (im == NULL) {
 692		rc = BFA_STATUS_ENOMEM;
 693		goto ext;
 694	}
 695
 696	bfad->im = im;
 697	im->bfad = bfad;
 698
 699	if (bfad_thread_workq(bfad) != BFA_STATUS_OK) {
 700		kfree(im);
 701		rc = BFA_STATUS_FAILED;
 702	}
 703
 704	INIT_WORK(&im->aen_im_notify_work, bfad_aen_im_notify_handler);
 705ext:
 706	return rc;
 707}
 708
 709void
 710bfad_im_probe_undo(struct bfad_s *bfad)
 711{
 712	if (bfad->im) {
 713		bfad_destroy_workq(bfad->im);
 714		kfree(bfad->im);
 715		bfad->im = NULL;
 716	}
 717}
 718
 719struct Scsi_Host *
 720bfad_scsi_host_alloc(struct bfad_im_port_s *im_port, struct bfad_s *bfad)
 721{
 722	struct scsi_host_template *sht;
 723
 724	if (im_port->port->pvb_type == BFAD_PORT_PHYS_BASE)
 725		sht = &bfad_im_scsi_host_template;
 726	else
 727		sht = &bfad_im_vport_template;
 728
 729	if (max_xfer_size != BFAD_MAX_SECTORS >> 1)
 730		sht->max_sectors = max_xfer_size << 1;
 731
 732	sht->sg_tablesize = bfad->cfg_data.io_max_sge;
 733
 734	return scsi_host_alloc(sht, sizeof(unsigned long));
 735}
 736
 737void
 738bfad_scsi_host_free(struct bfad_s *bfad, struct bfad_im_port_s *im_port)
 739{
 740	if (!(im_port->flags & BFAD_PORT_DELETE))
 741		flush_workqueue(bfad->im->drv_workq);
 742	bfad_im_scsi_host_free(im_port->bfad, im_port);
 743	bfad_im_port_clean(im_port);
 744	kfree(im_port);
 745}
 746
 747void
 748bfad_destroy_workq(struct bfad_im_s *im)
 749{
 750	if (im && im->drv_workq) {
 751		flush_workqueue(im->drv_workq);
 752		destroy_workqueue(im->drv_workq);
 753		im->drv_workq = NULL;
 754	}
 755}
 756
 757bfa_status_t
 758bfad_thread_workq(struct bfad_s *bfad)
 759{
 760	struct bfad_im_s      *im = bfad->im;
 761
 762	bfa_trc(bfad, 0);
 763	snprintf(im->drv_workq_name, KOBJ_NAME_LEN, "bfad_wq_%d",
 764		 bfad->inst_no);
 765	im->drv_workq = create_singlethread_workqueue(im->drv_workq_name);
 766	if (!im->drv_workq)
 767		return BFA_STATUS_FAILED;
 768
 769	return BFA_STATUS_OK;
 770}
 771
 772/*
 773 * Scsi_Host template entry.
 774 *
 775 * Description:
 776 * OS entry point to adjust the queue_depths on a per-device basis.
 777 * Called once per device during the bus scan.
 778 * Return non-zero if fails.
 779 */
 780static int
 781bfad_im_slave_configure(struct scsi_device *sdev)
 782{
 783	if (sdev->tagged_supported)
 784		scsi_activate_tcq(sdev, bfa_lun_queue_depth);
 785	else
 786		scsi_deactivate_tcq(sdev, bfa_lun_queue_depth);
 787
 788	return 0;
 789}
 790
 791struct scsi_host_template bfad_im_scsi_host_template = {
 792	.module = THIS_MODULE,
 793	.name = BFAD_DRIVER_NAME,
 794	.info = bfad_im_info,
 795	.queuecommand = bfad_im_queuecommand,
 796	.eh_abort_handler = bfad_im_abort_handler,
 797	.eh_device_reset_handler = bfad_im_reset_lun_handler,
 798	.eh_bus_reset_handler = bfad_im_reset_bus_handler,
 799
 800	.slave_alloc = bfad_im_slave_alloc,
 801	.slave_configure = bfad_im_slave_configure,
 802	.slave_destroy = bfad_im_slave_destroy,
 803
 804	.this_id = -1,
 805	.sg_tablesize = BFAD_IO_MAX_SGE,
 806	.cmd_per_lun = 3,
 807	.use_clustering = ENABLE_CLUSTERING,
 808	.shost_attrs = bfad_im_host_attrs,
 809	.max_sectors = BFAD_MAX_SECTORS,
 810	.vendor_id = BFA_PCI_VENDOR_ID_BROCADE,
 811};
 812
 813struct scsi_host_template bfad_im_vport_template = {
 814	.module = THIS_MODULE,
 815	.name = BFAD_DRIVER_NAME,
 816	.info = bfad_im_info,
 817	.queuecommand = bfad_im_queuecommand,
 818	.eh_abort_handler = bfad_im_abort_handler,
 819	.eh_device_reset_handler = bfad_im_reset_lun_handler,
 820	.eh_bus_reset_handler = bfad_im_reset_bus_handler,
 821
 822	.slave_alloc = bfad_im_slave_alloc,
 823	.slave_configure = bfad_im_slave_configure,
 824	.slave_destroy = bfad_im_slave_destroy,
 825
 826	.this_id = -1,
 827	.sg_tablesize = BFAD_IO_MAX_SGE,
 828	.cmd_per_lun = 3,
 829	.use_clustering = ENABLE_CLUSTERING,
 830	.shost_attrs = bfad_im_vport_attrs,
 831	.max_sectors = BFAD_MAX_SECTORS,
 832};
 833
 834bfa_status_t
 835bfad_im_module_init(void)
 836{
 837	bfad_im_scsi_transport_template =
 838		fc_attach_transport(&bfad_im_fc_function_template);
 839	if (!bfad_im_scsi_transport_template)
 840		return BFA_STATUS_ENOMEM;
 841
 842	bfad_im_scsi_vport_transport_template =
 843		fc_attach_transport(&bfad_im_vport_fc_function_template);
 844	if (!bfad_im_scsi_vport_transport_template) {
 845		fc_release_transport(bfad_im_scsi_transport_template);
 846		return BFA_STATUS_ENOMEM;
 847	}
 848
 849	return BFA_STATUS_OK;
 850}
 851
 852void
 853bfad_im_module_exit(void)
 854{
 855	if (bfad_im_scsi_transport_template)
 856		fc_release_transport(bfad_im_scsi_transport_template);
 857
 858	if (bfad_im_scsi_vport_transport_template)
 859		fc_release_transport(bfad_im_scsi_vport_transport_template);
 
 
 860}
 861
 862void
 863bfad_ramp_up_qdepth(struct bfad_itnim_s *itnim, struct scsi_device *sdev)
 864{
 865	struct scsi_device *tmp_sdev;
 866
 867	if (((jiffies - itnim->last_ramp_up_time) >
 868		BFA_QUEUE_FULL_RAMP_UP_TIME * HZ) &&
 869		((jiffies - itnim->last_queue_full_time) >
 870		BFA_QUEUE_FULL_RAMP_UP_TIME * HZ)) {
 871		shost_for_each_device(tmp_sdev, sdev->host) {
 872			if (bfa_lun_queue_depth > tmp_sdev->queue_depth) {
 873				if (tmp_sdev->id != sdev->id)
 874					continue;
 875				if (tmp_sdev->ordered_tags)
 876					scsi_adjust_queue_depth(tmp_sdev,
 877						MSG_ORDERED_TAG,
 878						tmp_sdev->queue_depth + 1);
 879				else
 880					scsi_adjust_queue_depth(tmp_sdev,
 881						MSG_SIMPLE_TAG,
 882						tmp_sdev->queue_depth + 1);
 883
 884				itnim->last_ramp_up_time = jiffies;
 885			}
 886		}
 887	}
 888}
 889
 890void
 891bfad_handle_qfull(struct bfad_itnim_s *itnim, struct scsi_device *sdev)
 892{
 893	struct scsi_device *tmp_sdev;
 894
 895	itnim->last_queue_full_time = jiffies;
 896
 897	shost_for_each_device(tmp_sdev, sdev->host) {
 898		if (tmp_sdev->id != sdev->id)
 899			continue;
 900		scsi_track_queue_full(tmp_sdev, tmp_sdev->queue_depth - 1);
 901	}
 902}
 903
 904struct bfad_itnim_s *
 905bfad_get_itnim(struct bfad_im_port_s *im_port, int id)
 906{
 907	struct bfad_itnim_s   *itnim = NULL;
 908
 909	/* Search the mapped list for this target ID */
 910	list_for_each_entry(itnim, &im_port->itnim_mapped_list, list_entry) {
 911		if (id == itnim->scsi_tgt_id)
 912			return itnim;
 913	}
 914
 915	return NULL;
 916}
 917
 918/*
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 919 * Scsi_Host template entry slave_alloc
 920 */
 921static int
 922bfad_im_slave_alloc(struct scsi_device *sdev)
 923{
 924	struct fc_rport *rport = starget_to_rport(scsi_target(sdev));
 
 
 925
 926	if (!rport || fc_remote_port_chkready(rport))
 927		return -ENXIO;
 928
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 929	sdev->hostdata = rport->dd_data;
 930
 931	return 0;
 932}
 933
 934static u32
 935bfad_im_supported_speeds(struct bfa_s *bfa)
 936{
 937	struct bfa_ioc_attr_s *ioc_attr;
 938	u32 supported_speed = 0;
 939
 940	ioc_attr = kzalloc(sizeof(struct bfa_ioc_attr_s), GFP_KERNEL);
 941	if (!ioc_attr)
 942		return 0;
 943
 944	bfa_ioc_get_attr(&bfa->ioc, ioc_attr);
 945	if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_16GBPS)
 946		supported_speed |=  FC_PORTSPEED_16GBIT | FC_PORTSPEED_8GBIT |
 947				FC_PORTSPEED_4GBIT | FC_PORTSPEED_2GBIT;
 948	else if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_8GBPS) {
 949		if (ioc_attr->adapter_attr.is_mezz) {
 950			supported_speed |= FC_PORTSPEED_8GBIT |
 951				FC_PORTSPEED_4GBIT |
 952				FC_PORTSPEED_2GBIT | FC_PORTSPEED_1GBIT;
 953		} else {
 954			supported_speed |= FC_PORTSPEED_8GBIT |
 955				FC_PORTSPEED_4GBIT |
 956				FC_PORTSPEED_2GBIT;
 957		}
 958	} else if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_4GBPS) {
 959		supported_speed |=  FC_PORTSPEED_4GBIT | FC_PORTSPEED_2GBIT |
 960				FC_PORTSPEED_1GBIT;
 961	} else if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_10GBPS) {
 962		supported_speed |= FC_PORTSPEED_10GBIT;
 963	}
 964	kfree(ioc_attr);
 965	return supported_speed;
 966}
 967
 968void
 969bfad_fc_host_init(struct bfad_im_port_s *im_port)
 970{
 971	struct Scsi_Host *host = im_port->shost;
 972	struct bfad_s         *bfad = im_port->bfad;
 973	struct bfad_port_s    *port = im_port->port;
 974	char symname[BFA_SYMNAME_MAXLEN];
 975	struct bfa_fcport_s *fcport = BFA_FCPORT_MOD(&bfad->bfa);
 976
 977	fc_host_node_name(host) =
 978		cpu_to_be64((bfa_fcs_lport_get_nwwn(port->fcs_port)));
 979	fc_host_port_name(host) =
 980		cpu_to_be64((bfa_fcs_lport_get_pwwn(port->fcs_port)));
 981	fc_host_max_npiv_vports(host) = bfa_lps_get_max_vport(&bfad->bfa);
 982
 983	fc_host_supported_classes(host) = FC_COS_CLASS3;
 984
 985	memset(fc_host_supported_fc4s(host), 0,
 986	       sizeof(fc_host_supported_fc4s(host)));
 987	if (supported_fc4s & BFA_LPORT_ROLE_FCP_IM)
 988		/* For FCP type 0x08 */
 989		fc_host_supported_fc4s(host)[2] = 1;
 990	/* For fibre channel services type 0x20 */
 991	fc_host_supported_fc4s(host)[7] = 1;
 992
 993	strncpy(symname, bfad->bfa_fcs.fabric.bport.port_cfg.sym_name.symname,
 994		BFA_SYMNAME_MAXLEN);
 995	sprintf(fc_host_symbolic_name(host), "%s", symname);
 996
 997	fc_host_supported_speeds(host) = bfad_im_supported_speeds(&bfad->bfa);
 998	fc_host_maxframe_size(host) = fcport->cfg.maxfrsize;
 999}
1000
1001static void
1002bfad_im_fc_rport_add(struct bfad_im_port_s *im_port, struct bfad_itnim_s *itnim)
1003{
1004	struct fc_rport_identifiers rport_ids;
1005	struct fc_rport *fc_rport;
1006	struct bfad_itnim_data_s *itnim_data;
1007
1008	rport_ids.node_name =
1009		cpu_to_be64(bfa_fcs_itnim_get_nwwn(&itnim->fcs_itnim));
1010	rport_ids.port_name =
1011		cpu_to_be64(bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim));
1012	rport_ids.port_id =
1013		bfa_hton3b(bfa_fcs_itnim_get_fcid(&itnim->fcs_itnim));
1014	rport_ids.roles = FC_RPORT_ROLE_UNKNOWN;
1015
1016	itnim->fc_rport = fc_rport =
1017		fc_remote_port_add(im_port->shost, 0, &rport_ids);
1018
1019	if (!fc_rport)
1020		return;
1021
1022	fc_rport->maxframe_size =
1023		bfa_fcs_itnim_get_maxfrsize(&itnim->fcs_itnim);
1024	fc_rport->supported_classes = bfa_fcs_itnim_get_cos(&itnim->fcs_itnim);
1025
1026	itnim_data = fc_rport->dd_data;
1027	itnim_data->itnim = itnim;
1028
1029	rport_ids.roles |= FC_RPORT_ROLE_FCP_TARGET;
1030
1031	if (rport_ids.roles != FC_RPORT_ROLE_UNKNOWN)
1032		fc_remote_port_rolechg(fc_rport, rport_ids.roles);
1033
1034	if ((fc_rport->scsi_target_id != -1)
1035	    && (fc_rport->scsi_target_id < MAX_FCP_TARGET))
1036		itnim->scsi_tgt_id = fc_rport->scsi_target_id;
1037
 
 
1038	return;
1039}
1040
1041/*
1042 * Work queue handler using FC transport service
1043* Context: kernel
1044 */
1045static void
1046bfad_im_itnim_work_handler(struct work_struct *work)
1047{
1048	struct bfad_itnim_s   *itnim = container_of(work, struct bfad_itnim_s,
1049							itnim_work);
1050	struct bfad_im_s      *im = itnim->im;
1051	struct bfad_s         *bfad = im->bfad;
1052	struct bfad_im_port_s *im_port;
1053	unsigned long   flags;
1054	struct fc_rport *fc_rport;
1055	wwn_t wwpn;
1056	u32 fcid;
1057	char wwpn_str[32], fcid_str[16];
1058
1059	spin_lock_irqsave(&bfad->bfad_lock, flags);
1060	im_port = itnim->im_port;
1061	bfa_trc(bfad, itnim->state);
1062	switch (itnim->state) {
1063	case ITNIM_STATE_ONLINE:
1064		if (!itnim->fc_rport) {
1065			spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1066			bfad_im_fc_rport_add(im_port, itnim);
1067			spin_lock_irqsave(&bfad->bfad_lock, flags);
1068			wwpn = bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim);
1069			fcid = bfa_fcs_itnim_get_fcid(&itnim->fcs_itnim);
1070			wwn2str(wwpn_str, wwpn);
1071			fcid2str(fcid_str, fcid);
1072			list_add_tail(&itnim->list_entry,
1073				&im_port->itnim_mapped_list);
1074			BFA_LOG(KERN_INFO, bfad, bfa_log_level,
1075				"ITNIM ONLINE Target: %d:0:%d "
1076				"FCID: %s WWPN: %s\n",
1077				im_port->shost->host_no,
1078				itnim->scsi_tgt_id,
1079				fcid_str, wwpn_str);
1080		} else {
1081			printk(KERN_WARNING
1082				"%s: itnim %llx is already in online state\n",
1083				__func__,
1084				bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim));
1085		}
1086
1087		break;
1088	case ITNIM_STATE_OFFLINE_PENDING:
1089		itnim->state = ITNIM_STATE_OFFLINE;
1090		if (itnim->fc_rport) {
1091			fc_rport = itnim->fc_rport;
1092			((struct bfad_itnim_data_s *)
1093				fc_rport->dd_data)->itnim = NULL;
1094			itnim->fc_rport = NULL;
1095			if (!(im_port->port->flags & BFAD_PORT_DELETE)) {
1096				spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1097				fc_rport->dev_loss_tmo =
1098					bfa_fcpim_path_tov_get(&bfad->bfa) + 1;
1099				fc_remote_port_delete(fc_rport);
1100				spin_lock_irqsave(&bfad->bfad_lock, flags);
1101			}
1102			wwpn = bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim);
1103			fcid = bfa_fcs_itnim_get_fcid(&itnim->fcs_itnim);
1104			wwn2str(wwpn_str, wwpn);
1105			fcid2str(fcid_str, fcid);
1106			list_del(&itnim->list_entry);
1107			BFA_LOG(KERN_INFO, bfad, bfa_log_level,
1108				"ITNIM OFFLINE Target: %d:0:%d "
1109				"FCID: %s WWPN: %s\n",
1110				im_port->shost->host_no,
1111				itnim->scsi_tgt_id,
1112				fcid_str, wwpn_str);
1113		}
1114		break;
1115	case ITNIM_STATE_FREE:
1116		if (itnim->fc_rport) {
1117			fc_rport = itnim->fc_rport;
1118			((struct bfad_itnim_data_s *)
1119				fc_rport->dd_data)->itnim = NULL;
1120			itnim->fc_rport = NULL;
1121			if (!(im_port->port->flags & BFAD_PORT_DELETE)) {
1122				spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1123				fc_rport->dev_loss_tmo =
1124					bfa_fcpim_path_tov_get(&bfad->bfa) + 1;
1125				fc_remote_port_delete(fc_rport);
1126				spin_lock_irqsave(&bfad->bfad_lock, flags);
1127			}
1128			list_del(&itnim->list_entry);
1129		}
1130
1131		kfree(itnim);
1132		break;
1133	default:
1134		WARN_ON(1);
1135		break;
1136	}
1137
1138	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1139}
1140
1141/*
1142 * Scsi_Host template entry, queue a SCSI command to the BFAD.
1143 */
1144static int
1145bfad_im_queuecommand_lck(struct scsi_cmnd *cmnd, void (*done) (struct scsi_cmnd *))
1146{
1147	struct bfad_im_port_s *im_port =
1148		(struct bfad_im_port_s *) cmnd->device->host->hostdata[0];
1149	struct bfad_s         *bfad = im_port->bfad;
1150	struct bfad_itnim_data_s *itnim_data = cmnd->device->hostdata;
1151	struct bfad_itnim_s   *itnim;
1152	struct bfa_ioim_s *hal_io;
1153	unsigned long   flags;
1154	int             rc;
1155	int       sg_cnt = 0;
1156	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd->device));
1157
1158	rc = fc_remote_port_chkready(rport);
1159	if (rc) {
1160		cmnd->result = rc;
 
 
 
 
 
 
 
 
 
1161		done(cmnd);
1162		return 0;
1163	}
1164
1165	sg_cnt = scsi_dma_map(cmnd);
1166	if (sg_cnt < 0)
1167		return SCSI_MLQUEUE_HOST_BUSY;
1168
1169	cmnd->scsi_done = done;
1170
1171	spin_lock_irqsave(&bfad->bfad_lock, flags);
1172	if (!(bfad->bfad_flags & BFAD_HAL_START_DONE)) {
1173		printk(KERN_WARNING
1174			"bfad%d, queuecommand %p %x failed, BFA stopped\n",
1175		       bfad->inst_no, cmnd, cmnd->cmnd[0]);
1176		cmnd->result = ScsiResult(DID_NO_CONNECT, 0);
1177		goto out_fail_cmd;
1178	}
1179
1180
1181	itnim = itnim_data->itnim;
1182	if (!itnim) {
1183		cmnd->result = ScsiResult(DID_IMM_RETRY, 0);
1184		goto out_fail_cmd;
1185	}
1186
1187	hal_io = bfa_ioim_alloc(&bfad->bfa, (struct bfad_ioim_s *) cmnd,
1188				    itnim->bfa_itnim, sg_cnt);
1189	if (!hal_io) {
1190		printk(KERN_WARNING "hal_io failure\n");
1191		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1192		scsi_dma_unmap(cmnd);
1193		return SCSI_MLQUEUE_HOST_BUSY;
1194	}
1195
1196	cmnd->host_scribble = (char *)hal_io;
1197	bfa_ioim_start(hal_io);
1198	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1199
1200	return 0;
1201
1202out_fail_cmd:
1203	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1204	scsi_dma_unmap(cmnd);
1205	if (done)
1206		done(cmnd);
1207
1208	return 0;
1209}
1210
1211static DEF_SCSI_QCMD(bfad_im_queuecommand)
1212
1213void
1214bfad_rport_online_wait(struct bfad_s *bfad)
1215{
1216	int i;
1217	int rport_delay = 10;
1218
1219	for (i = 0; !(bfad->bfad_flags & BFAD_PORT_ONLINE)
1220		&& i < bfa_linkup_delay; i++) {
1221		set_current_state(TASK_UNINTERRUPTIBLE);
1222		schedule_timeout(HZ);
1223	}
1224
1225	if (bfad->bfad_flags & BFAD_PORT_ONLINE) {
1226		rport_delay = rport_delay < bfa_linkup_delay ?
1227			rport_delay : bfa_linkup_delay;
1228		for (i = 0; !(bfad->bfad_flags & BFAD_RPORT_ONLINE)
1229			&& i < rport_delay; i++) {
1230			set_current_state(TASK_UNINTERRUPTIBLE);
1231			schedule_timeout(HZ);
1232		}
1233
1234		if (rport_delay > 0 && (bfad->bfad_flags & BFAD_RPORT_ONLINE)) {
1235			set_current_state(TASK_UNINTERRUPTIBLE);
1236			schedule_timeout(rport_delay * HZ);
1237		}
1238	}
1239}
1240
1241int
1242bfad_get_linkup_delay(struct bfad_s *bfad)
1243{
1244	u8		nwwns = 0;
1245	wwn_t		wwns[BFA_PREBOOT_BOOTLUN_MAX];
1246	int		linkup_delay;
1247
1248	/*
1249	 * Querying for the boot target port wwns
1250	 * -- read from boot information in flash.
1251	 * If nwwns > 0 => boot over SAN and set linkup_delay = 30
1252	 * else => local boot machine set linkup_delay = 0
1253	 */
1254
1255	bfa_iocfc_get_bootwwns(&bfad->bfa, &nwwns, wwns);
1256
1257	if (nwwns > 0)
1258		/* If Boot over SAN set linkup_delay = 30sec */
1259		linkup_delay = 30;
1260	else
1261		/* If local boot; no linkup_delay */
1262		linkup_delay = 0;
1263
1264	return linkup_delay;
1265}
v4.6
   1/*
   2 * Copyright (c) 2005-2014 Brocade Communications Systems, Inc.
   3 * Copyright (c) 2014- QLogic Corporation.
   4 * All rights reserved
   5 * www.qlogic.com
   6 *
   7 * Linux driver for QLogic BR-series Fibre Channel Host Bus Adapter.
   8 *
   9 * This program is free software; you can redistribute it and/or modify it
  10 * under the terms of the GNU General Public License (GPL) Version 2 as
  11 * published by the Free Software Foundation
  12 *
  13 * This program is distributed in the hope that it will be useful, but
  14 * WITHOUT ANY WARRANTY; without even the implied warranty of
  15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16 * General Public License for more details.
  17 */
  18
  19/*
  20 *  bfad_im.c Linux driver IM module.
  21 */
  22
  23#include <linux/export.h>
  24
  25#include "bfad_drv.h"
  26#include "bfad_im.h"
  27#include "bfa_fcs.h"
  28
  29BFA_TRC_FILE(LDRV, IM);
  30
  31DEFINE_IDR(bfad_im_port_index);
  32struct scsi_transport_template *bfad_im_scsi_transport_template;
  33struct scsi_transport_template *bfad_im_scsi_vport_transport_template;
  34static void bfad_im_itnim_work_handler(struct work_struct *work);
  35static int bfad_im_queuecommand(struct Scsi_Host *h, struct scsi_cmnd *cmnd);
  36static int bfad_im_slave_alloc(struct scsi_device *sdev);
  37static void bfad_im_fc_rport_add(struct bfad_im_port_s  *im_port,
  38				struct bfad_itnim_s *itnim);
  39
  40void
  41bfa_cb_ioim_done(void *drv, struct bfad_ioim_s *dio,
  42			enum bfi_ioim_status io_status, u8 scsi_status,
  43			int sns_len, u8 *sns_info, s32 residue)
  44{
  45	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dio;
  46	struct bfad_s         *bfad = drv;
  47	struct bfad_itnim_data_s *itnim_data;
  48	struct bfad_itnim_s *itnim;
  49	u8         host_status = DID_OK;
  50
  51	switch (io_status) {
  52	case BFI_IOIM_STS_OK:
  53		bfa_trc(bfad, scsi_status);
  54		scsi_set_resid(cmnd, 0);
  55
  56		if (sns_len > 0) {
  57			bfa_trc(bfad, sns_len);
  58			if (sns_len > SCSI_SENSE_BUFFERSIZE)
  59				sns_len = SCSI_SENSE_BUFFERSIZE;
  60			memcpy(cmnd->sense_buffer, sns_info, sns_len);
  61		}
  62
  63		if (residue > 0) {
  64			bfa_trc(bfad, residue);
  65			scsi_set_resid(cmnd, residue);
  66			if (!sns_len && (scsi_status == SAM_STAT_GOOD) &&
  67				(scsi_bufflen(cmnd) - residue) <
  68					cmnd->underflow) {
  69				bfa_trc(bfad, 0);
  70				host_status = DID_ERROR;
  71			}
  72		}
  73		cmnd->result = ScsiResult(host_status, scsi_status);
  74
  75		break;
  76
 
  77	case BFI_IOIM_STS_TIMEDOUT:
  78		host_status = DID_TIME_OUT;
  79		cmnd->result = ScsiResult(host_status, 0);
  80		break;
  81	case BFI_IOIM_STS_PATHTOV:
  82		host_status = DID_TRANSPORT_DISRUPTED;
  83		cmnd->result = ScsiResult(host_status, 0);
  84		break;
  85	default:
  86		host_status = DID_ERROR;
  87		cmnd->result = ScsiResult(host_status, 0);
  88	}
  89
  90	/* Unmap DMA, if host is NULL, it means a scsi passthru cmd */
  91	if (cmnd->device->host != NULL)
  92		scsi_dma_unmap(cmnd);
  93
  94	cmnd->host_scribble = NULL;
  95	bfa_trc(bfad, cmnd->result);
  96
  97	itnim_data = cmnd->device->hostdata;
  98	if (itnim_data) {
  99		itnim = itnim_data->itnim;
 100		if (!cmnd->result && itnim &&
 101			 (bfa_lun_queue_depth > cmnd->device->queue_depth)) {
 102			/* Queue depth adjustment for good status completion */
 103			bfad_ramp_up_qdepth(itnim, cmnd->device);
 104		} else if (cmnd->result == SAM_STAT_TASK_SET_FULL && itnim) {
 105			/* qfull handling */
 106			bfad_handle_qfull(itnim, cmnd->device);
 107		}
 108	}
 109
 110	cmnd->scsi_done(cmnd);
 111}
 112
 113void
 114bfa_cb_ioim_good_comp(void *drv, struct bfad_ioim_s *dio)
 115{
 116	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dio;
 117	struct bfad_itnim_data_s *itnim_data;
 118	struct bfad_itnim_s *itnim;
 119
 120	cmnd->result = ScsiResult(DID_OK, SCSI_STATUS_GOOD);
 121
 122	/* Unmap DMA, if host is NULL, it means a scsi passthru cmd */
 123	if (cmnd->device->host != NULL)
 124		scsi_dma_unmap(cmnd);
 125
 126	cmnd->host_scribble = NULL;
 127
 128	/* Queue depth adjustment */
 129	if (bfa_lun_queue_depth > cmnd->device->queue_depth) {
 130		itnim_data = cmnd->device->hostdata;
 131		if (itnim_data) {
 132			itnim = itnim_data->itnim;
 133			if (itnim)
 134				bfad_ramp_up_qdepth(itnim, cmnd->device);
 135		}
 136	}
 137
 138	cmnd->scsi_done(cmnd);
 139}
 140
 141void
 142bfa_cb_ioim_abort(void *drv, struct bfad_ioim_s *dio)
 143{
 144	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dio;
 145	struct bfad_s         *bfad = drv;
 146
 147	cmnd->result = ScsiResult(DID_ERROR, 0);
 148
 149	/* Unmap DMA, if host is NULL, it means a scsi passthru cmd */
 150	if (cmnd->device->host != NULL)
 151		scsi_dma_unmap(cmnd);
 152
 153	bfa_trc(bfad, cmnd->result);
 154	cmnd->host_scribble = NULL;
 155}
 156
 157void
 158bfa_cb_tskim_done(void *bfad, struct bfad_tskim_s *dtsk,
 159		   enum bfi_tskim_status tsk_status)
 160{
 161	struct scsi_cmnd *cmnd = (struct scsi_cmnd *)dtsk;
 162	wait_queue_head_t *wq;
 163
 164	cmnd->SCp.Status |= tsk_status << 1;
 165	set_bit(IO_DONE_BIT, (unsigned long *)&cmnd->SCp.Status);
 166	wq = (wait_queue_head_t *) cmnd->SCp.ptr;
 167	cmnd->SCp.ptr = NULL;
 168
 169	if (wq)
 170		wake_up(wq);
 171}
 172
 173/*
 174 *  Scsi_Host_template SCSI host template
 175 */
 176/*
 177 * Scsi_Host template entry, returns BFAD PCI info.
 178 */
 179static const char *
 180bfad_im_info(struct Scsi_Host *shost)
 181{
 182	static char     bfa_buf[256];
 183	struct bfad_im_port_s *im_port =
 184			(struct bfad_im_port_s *) shost->hostdata[0];
 185	struct bfad_s *bfad = im_port->bfad;
 186
 187	memset(bfa_buf, 0, sizeof(bfa_buf));
 188	snprintf(bfa_buf, sizeof(bfa_buf),
 189		"QLogic BR-series FC/FCOE Adapter, hwpath: %s driver: %s",
 190		bfad->pci_name, BFAD_DRIVER_VERSION);
 191
 192	return bfa_buf;
 193}
 194
 195/*
 196 * Scsi_Host template entry, aborts the specified SCSI command.
 197 *
 198 * Returns: SUCCESS or FAILED.
 199 */
 200static int
 201bfad_im_abort_handler(struct scsi_cmnd *cmnd)
 202{
 203	struct Scsi_Host *shost = cmnd->device->host;
 204	struct bfad_im_port_s *im_port =
 205			(struct bfad_im_port_s *) shost->hostdata[0];
 206	struct bfad_s         *bfad = im_port->bfad;
 207	struct bfa_ioim_s *hal_io;
 208	unsigned long   flags;
 209	u32        timeout;
 210	int             rc = FAILED;
 211
 212	spin_lock_irqsave(&bfad->bfad_lock, flags);
 213	hal_io = (struct bfa_ioim_s *) cmnd->host_scribble;
 214	if (!hal_io) {
 215		/* IO has been completed, return success */
 216		rc = SUCCESS;
 217		goto out;
 218	}
 219	if (hal_io->dio != (struct bfad_ioim_s *) cmnd) {
 220		rc = FAILED;
 221		goto out;
 222	}
 223
 224	bfa_trc(bfad, hal_io->iotag);
 225	BFA_LOG(KERN_INFO, bfad, bfa_log_level,
 226		"scsi%d: abort cmnd %p iotag %x\n",
 227		im_port->shost->host_no, cmnd, hal_io->iotag);
 228	(void) bfa_ioim_abort(hal_io);
 229	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 230
 231	/* Need to wait until the command get aborted */
 232	timeout = 10;
 233	while ((struct bfa_ioim_s *) cmnd->host_scribble == hal_io) {
 234		set_current_state(TASK_UNINTERRUPTIBLE);
 235		schedule_timeout(timeout);
 236		if (timeout < 4 * HZ)
 237			timeout *= 2;
 238	}
 239
 240	cmnd->scsi_done(cmnd);
 241	bfa_trc(bfad, hal_io->iotag);
 242	BFA_LOG(KERN_INFO, bfad, bfa_log_level,
 243		"scsi%d: complete abort 0x%p iotag 0x%x\n",
 244		im_port->shost->host_no, cmnd, hal_io->iotag);
 245	return SUCCESS;
 246out:
 247	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 248	return rc;
 249}
 250
 251static bfa_status_t
 252bfad_im_target_reset_send(struct bfad_s *bfad, struct scsi_cmnd *cmnd,
 253		     struct bfad_itnim_s *itnim)
 254{
 255	struct bfa_tskim_s *tskim;
 256	struct bfa_itnim_s *bfa_itnim;
 257	bfa_status_t    rc = BFA_STATUS_OK;
 258	struct scsi_lun scsilun;
 259
 260	tskim = bfa_tskim_alloc(&bfad->bfa, (struct bfad_tskim_s *) cmnd);
 261	if (!tskim) {
 262		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 263			"target reset, fail to allocate tskim\n");
 264		rc = BFA_STATUS_FAILED;
 265		goto out;
 266	}
 267
 268	/*
 269	 * Set host_scribble to NULL to avoid aborting a task command if
 270	 * happens.
 271	 */
 272	cmnd->host_scribble = NULL;
 273	cmnd->SCp.Status = 0;
 274	bfa_itnim = bfa_fcs_itnim_get_halitn(&itnim->fcs_itnim);
 275	/*
 276	 * bfa_itnim can be NULL if the port gets disconnected and the bfa
 277	 * and fcs layers have cleaned up their nexus with the targets and
 278	 * the same has not been cleaned up by the shim
 279	 */
 280	if (bfa_itnim == NULL) {
 281		bfa_tskim_free(tskim);
 282		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 283			"target reset, bfa_itnim is NULL\n");
 284		rc = BFA_STATUS_FAILED;
 285		goto out;
 286	}
 287
 288	memset(&scsilun, 0, sizeof(scsilun));
 289	bfa_tskim_start(tskim, bfa_itnim, scsilun,
 290			    FCP_TM_TARGET_RESET, BFAD_TARGET_RESET_TMO);
 291out:
 292	return rc;
 293}
 294
 295/*
 296 * Scsi_Host template entry, resets a LUN and abort its all commands.
 297 *
 298 * Returns: SUCCESS or FAILED.
 299 *
 300 */
 301static int
 302bfad_im_reset_lun_handler(struct scsi_cmnd *cmnd)
 303{
 304	struct Scsi_Host *shost = cmnd->device->host;
 305	struct bfad_im_port_s *im_port =
 306			(struct bfad_im_port_s *) shost->hostdata[0];
 307	struct bfad_itnim_data_s *itnim_data = cmnd->device->hostdata;
 308	struct bfad_s         *bfad = im_port->bfad;
 309	struct bfa_tskim_s *tskim;
 310	struct bfad_itnim_s   *itnim;
 311	struct bfa_itnim_s *bfa_itnim;
 312	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(wq);
 313	int             rc = SUCCESS;
 314	unsigned long   flags;
 315	enum bfi_tskim_status task_status;
 316	struct scsi_lun scsilun;
 317
 318	spin_lock_irqsave(&bfad->bfad_lock, flags);
 319	itnim = itnim_data->itnim;
 320	if (!itnim) {
 321		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 322		rc = FAILED;
 323		goto out;
 324	}
 325
 326	tskim = bfa_tskim_alloc(&bfad->bfa, (struct bfad_tskim_s *) cmnd);
 327	if (!tskim) {
 328		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 329				"LUN reset, fail to allocate tskim");
 330		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 331		rc = FAILED;
 332		goto out;
 333	}
 334
 335	/*
 336	 * Set host_scribble to NULL to avoid aborting a task command
 337	 * if happens.
 338	 */
 339	cmnd->host_scribble = NULL;
 340	cmnd->SCp.ptr = (char *)&wq;
 341	cmnd->SCp.Status = 0;
 342	bfa_itnim = bfa_fcs_itnim_get_halitn(&itnim->fcs_itnim);
 343	/*
 344	 * bfa_itnim can be NULL if the port gets disconnected and the bfa
 345	 * and fcs layers have cleaned up their nexus with the targets and
 346	 * the same has not been cleaned up by the shim
 347	 */
 348	if (bfa_itnim == NULL) {
 349		bfa_tskim_free(tskim);
 350		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 351			"lun reset, bfa_itnim is NULL\n");
 352		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 353		rc = FAILED;
 354		goto out;
 355	}
 356	int_to_scsilun(cmnd->device->lun, &scsilun);
 357	bfa_tskim_start(tskim, bfa_itnim, scsilun,
 358			    FCP_TM_LUN_RESET, BFAD_LUN_RESET_TMO);
 359	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 360
 361	wait_event(wq, test_bit(IO_DONE_BIT,
 362			(unsigned long *)&cmnd->SCp.Status));
 363
 364	task_status = cmnd->SCp.Status >> 1;
 365	if (task_status != BFI_TSKIM_STS_OK) {
 366		BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 367			"LUN reset failure, status: %d\n", task_status);
 368		rc = FAILED;
 369	}
 370
 371out:
 372	return rc;
 373}
 374
 375/*
 376 * Scsi_Host template entry, resets the bus and abort all commands.
 377 */
 378static int
 379bfad_im_reset_bus_handler(struct scsi_cmnd *cmnd)
 380{
 381	struct Scsi_Host *shost = cmnd->device->host;
 382	struct bfad_im_port_s *im_port =
 383				(struct bfad_im_port_s *) shost->hostdata[0];
 384	struct bfad_s         *bfad = im_port->bfad;
 385	struct bfad_itnim_s   *itnim;
 386	unsigned long   flags;
 387	u32        i, rc, err_cnt = 0;
 388	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(wq);
 389	enum bfi_tskim_status task_status;
 390
 391	spin_lock_irqsave(&bfad->bfad_lock, flags);
 392	for (i = 0; i < MAX_FCP_TARGET; i++) {
 393		itnim = bfad_get_itnim(im_port, i);
 394		if (itnim) {
 395			cmnd->SCp.ptr = (char *)&wq;
 396			rc = bfad_im_target_reset_send(bfad, cmnd, itnim);
 397			if (rc != BFA_STATUS_OK) {
 398				err_cnt++;
 399				continue;
 400			}
 401
 402			/* wait target reset to complete */
 403			spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 404			wait_event(wq, test_bit(IO_DONE_BIT,
 405					(unsigned long *)&cmnd->SCp.Status));
 406			spin_lock_irqsave(&bfad->bfad_lock, flags);
 407
 408			task_status = cmnd->SCp.Status >> 1;
 409			if (task_status != BFI_TSKIM_STS_OK) {
 410				BFA_LOG(KERN_ERR, bfad, bfa_log_level,
 411					"target reset failure,"
 412					" status: %d\n", task_status);
 413				err_cnt++;
 414			}
 415		}
 416	}
 417	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 418
 419	if (err_cnt)
 420		return FAILED;
 421
 422	return SUCCESS;
 423}
 424
 425/*
 426 * Scsi_Host template entry slave_destroy.
 427 */
 428static void
 429bfad_im_slave_destroy(struct scsi_device *sdev)
 430{
 431	sdev->hostdata = NULL;
 432	return;
 433}
 434
 435/*
 436 *  BFA FCS itnim callbacks
 437 */
 438
 439/*
 440 * BFA FCS itnim alloc callback, after successful PRLI
 441 * Context: Interrupt
 442 */
 443void
 444bfa_fcb_itnim_alloc(struct bfad_s *bfad, struct bfa_fcs_itnim_s **itnim,
 445		    struct bfad_itnim_s **itnim_drv)
 446{
 447	*itnim_drv = kzalloc(sizeof(struct bfad_itnim_s), GFP_ATOMIC);
 448	if (*itnim_drv == NULL)
 449		return;
 450
 451	(*itnim_drv)->im = bfad->im;
 452	*itnim = &(*itnim_drv)->fcs_itnim;
 453	(*itnim_drv)->state = ITNIM_STATE_NONE;
 454
 455	/*
 456	 * Initiaze the itnim_work
 457	 */
 458	INIT_WORK(&(*itnim_drv)->itnim_work, bfad_im_itnim_work_handler);
 459	bfad->bfad_flags |= BFAD_RPORT_ONLINE;
 460}
 461
 462/*
 463 * BFA FCS itnim free callback.
 464 * Context: Interrupt. bfad_lock is held
 465 */
 466void
 467bfa_fcb_itnim_free(struct bfad_s *bfad, struct bfad_itnim_s *itnim_drv)
 468{
 469	struct bfad_port_s    *port;
 470	wwn_t wwpn;
 471	u32 fcid;
 472	char wwpn_str[32], fcid_str[16];
 473	struct bfad_im_s	*im = itnim_drv->im;
 474
 475	/* online to free state transtion should not happen */
 476	WARN_ON(itnim_drv->state == ITNIM_STATE_ONLINE);
 477
 478	itnim_drv->queue_work = 1;
 479	/* offline request is not yet done, use the same request to free */
 480	if (itnim_drv->state == ITNIM_STATE_OFFLINE_PENDING)
 481		itnim_drv->queue_work = 0;
 482
 483	itnim_drv->state = ITNIM_STATE_FREE;
 484	port = bfa_fcs_itnim_get_drvport(&itnim_drv->fcs_itnim);
 485	itnim_drv->im_port = port->im_port;
 486	wwpn = bfa_fcs_itnim_get_pwwn(&itnim_drv->fcs_itnim);
 487	fcid = bfa_fcs_itnim_get_fcid(&itnim_drv->fcs_itnim);
 488	wwn2str(wwpn_str, wwpn);
 489	fcid2str(fcid_str, fcid);
 490	BFA_LOG(KERN_INFO, bfad, bfa_log_level,
 491		"ITNIM FREE scsi%d: FCID: %s WWPN: %s\n",
 492		port->im_port->shost->host_no,
 493		fcid_str, wwpn_str);
 494
 495	/* ITNIM processing */
 496	if (itnim_drv->queue_work)
 497		queue_work(im->drv_workq, &itnim_drv->itnim_work);
 498}
 499
 500/*
 501 * BFA FCS itnim online callback.
 502 * Context: Interrupt. bfad_lock is held
 503 */
 504void
 505bfa_fcb_itnim_online(struct bfad_itnim_s *itnim_drv)
 506{
 507	struct bfad_port_s    *port;
 508	struct bfad_im_s	*im = itnim_drv->im;
 509
 510	itnim_drv->bfa_itnim = bfa_fcs_itnim_get_halitn(&itnim_drv->fcs_itnim);
 511	port = bfa_fcs_itnim_get_drvport(&itnim_drv->fcs_itnim);
 512	itnim_drv->state = ITNIM_STATE_ONLINE;
 513	itnim_drv->queue_work = 1;
 514	itnim_drv->im_port = port->im_port;
 515
 516	/* ITNIM processing */
 517	if (itnim_drv->queue_work)
 518		queue_work(im->drv_workq, &itnim_drv->itnim_work);
 519}
 520
 521/*
 522 * BFA FCS itnim offline callback.
 523 * Context: Interrupt. bfad_lock is held
 524 */
 525void
 526bfa_fcb_itnim_offline(struct bfad_itnim_s *itnim_drv)
 527{
 528	struct bfad_port_s    *port;
 529	struct bfad_s *bfad;
 530	struct bfad_im_s	*im = itnim_drv->im;
 531
 532	port = bfa_fcs_itnim_get_drvport(&itnim_drv->fcs_itnim);
 533	bfad = port->bfad;
 534	if ((bfad->pport.flags & BFAD_PORT_DELETE) ||
 535		 (port->flags & BFAD_PORT_DELETE)) {
 536		itnim_drv->state = ITNIM_STATE_OFFLINE;
 537		return;
 538	}
 539	itnim_drv->im_port = port->im_port;
 540	itnim_drv->state = ITNIM_STATE_OFFLINE_PENDING;
 541	itnim_drv->queue_work = 1;
 542
 543	/* ITNIM processing */
 544	if (itnim_drv->queue_work)
 545		queue_work(im->drv_workq, &itnim_drv->itnim_work);
 546}
 547
 548/*
 549 * Allocate a Scsi_Host for a port.
 550 */
 551int
 552bfad_im_scsi_host_alloc(struct bfad_s *bfad, struct bfad_im_port_s *im_port,
 553			struct device *dev)
 554{
 555	int error = 1;
 556
 557	mutex_lock(&bfad_mutex);
 558	error = idr_alloc(&bfad_im_port_index, im_port, 0, 0, GFP_KERNEL);
 559	if (error < 0) {
 
 
 
 
 
 
 
 560		mutex_unlock(&bfad_mutex);
 561		printk(KERN_WARNING "idr_alloc failure\n");
 562		goto out;
 563	}
 564	im_port->idr_id = error;
 565	mutex_unlock(&bfad_mutex);
 566
 567	im_port->shost = bfad_scsi_host_alloc(im_port, bfad);
 568	if (!im_port->shost) {
 569		error = 1;
 570		goto out_free_idr;
 571	}
 572
 573	im_port->shost->hostdata[0] = (unsigned long)im_port;
 574	im_port->shost->unique_id = im_port->idr_id;
 575	im_port->shost->this_id = -1;
 576	im_port->shost->max_id = MAX_FCP_TARGET;
 577	im_port->shost->max_lun = MAX_FCP_LUN;
 578	im_port->shost->max_cmd_len = 16;
 579	im_port->shost->can_queue = bfad->cfg_data.ioc_queue_depth;
 580	if (im_port->port->pvb_type == BFAD_PORT_PHYS_BASE)
 581		im_port->shost->transportt = bfad_im_scsi_transport_template;
 582	else
 583		im_port->shost->transportt =
 584				bfad_im_scsi_vport_transport_template;
 585
 586	error = scsi_add_host_with_dma(im_port->shost, dev, &bfad->pcidev->dev);
 587	if (error) {
 588		printk(KERN_WARNING "scsi_add_host failure %d\n", error);
 589		goto out_fc_rel;
 590	}
 591
 592	return 0;
 593
 594out_fc_rel:
 595	scsi_host_put(im_port->shost);
 596	im_port->shost = NULL;
 597out_free_idr:
 598	mutex_lock(&bfad_mutex);
 599	idr_remove(&bfad_im_port_index, im_port->idr_id);
 600	mutex_unlock(&bfad_mutex);
 601out:
 602	return error;
 603}
 604
 605void
 606bfad_im_scsi_host_free(struct bfad_s *bfad, struct bfad_im_port_s *im_port)
 607{
 608	bfa_trc(bfad, bfad->inst_no);
 609	BFA_LOG(KERN_INFO, bfad, bfa_log_level, "Free scsi%d\n",
 610			im_port->shost->host_no);
 611
 612	fc_remove_host(im_port->shost);
 613
 614	scsi_remove_host(im_port->shost);
 615	scsi_host_put(im_port->shost);
 616
 617	mutex_lock(&bfad_mutex);
 618	idr_remove(&bfad_im_port_index, im_port->idr_id);
 619	mutex_unlock(&bfad_mutex);
 620}
 621
 622static void
 623bfad_im_port_delete_handler(struct work_struct *work)
 624{
 625	struct bfad_im_port_s *im_port =
 626		container_of(work, struct bfad_im_port_s, port_delete_work);
 627
 628	if (im_port->port->pvb_type != BFAD_PORT_PHYS_BASE) {
 629		im_port->flags |= BFAD_PORT_DELETE;
 630		fc_vport_terminate(im_port->fc_vport);
 631	}
 632}
 633
 634bfa_status_t
 635bfad_im_port_new(struct bfad_s *bfad, struct bfad_port_s *port)
 636{
 637	int             rc = BFA_STATUS_OK;
 638	struct bfad_im_port_s *im_port;
 639
 640	im_port = kzalloc(sizeof(struct bfad_im_port_s), GFP_ATOMIC);
 641	if (im_port == NULL) {
 642		rc = BFA_STATUS_ENOMEM;
 643		goto ext;
 644	}
 645	port->im_port = im_port;
 646	im_port->port = port;
 647	im_port->bfad = bfad;
 648
 649	INIT_WORK(&im_port->port_delete_work, bfad_im_port_delete_handler);
 650	INIT_LIST_HEAD(&im_port->itnim_mapped_list);
 651	INIT_LIST_HEAD(&im_port->binding_list);
 652
 653ext:
 654	return rc;
 655}
 656
 657void
 658bfad_im_port_delete(struct bfad_s *bfad, struct bfad_port_s *port)
 659{
 660	struct bfad_im_port_s *im_port = port->im_port;
 661
 662	queue_work(bfad->im->drv_workq,
 663				&im_port->port_delete_work);
 664}
 665
 666void
 667bfad_im_port_clean(struct bfad_im_port_s *im_port)
 668{
 669	struct bfad_fcp_binding *bp, *bp_new;
 670	unsigned long flags;
 671	struct bfad_s *bfad =  im_port->bfad;
 672
 673	spin_lock_irqsave(&bfad->bfad_lock, flags);
 674	list_for_each_entry_safe(bp, bp_new, &im_port->binding_list,
 675					list_entry) {
 676		list_del(&bp->list_entry);
 677		kfree(bp);
 678	}
 679
 680	/* the itnim_mapped_list must be empty at this time */
 681	WARN_ON(!list_empty(&im_port->itnim_mapped_list));
 682
 683	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
 684}
 685
 686static void bfad_aen_im_notify_handler(struct work_struct *work)
 687{
 688	struct bfad_im_s *im =
 689		container_of(work, struct bfad_im_s, aen_im_notify_work);
 690	struct bfa_aen_entry_s *aen_entry;
 691	struct bfad_s *bfad = im->bfad;
 692	struct Scsi_Host *shost = bfad->pport.im_port->shost;
 693	void *event_data;
 694	unsigned long flags;
 695
 696	while (!list_empty(&bfad->active_aen_q)) {
 697		spin_lock_irqsave(&bfad->bfad_aen_spinlock, flags);
 698		bfa_q_deq(&bfad->active_aen_q, &aen_entry);
 699		spin_unlock_irqrestore(&bfad->bfad_aen_spinlock, flags);
 700		event_data = (char *)aen_entry + sizeof(struct list_head);
 701		fc_host_post_vendor_event(shost, fc_get_event_number(),
 702				sizeof(struct bfa_aen_entry_s) -
 703				sizeof(struct list_head),
 704				(char *)event_data, BFAD_NL_VENDOR_ID);
 705		spin_lock_irqsave(&bfad->bfad_aen_spinlock, flags);
 706		list_add_tail(&aen_entry->qe, &bfad->free_aen_q);
 707		spin_unlock_irqrestore(&bfad->bfad_aen_spinlock, flags);
 708	}
 709}
 710
 711bfa_status_t
 712bfad_im_probe(struct bfad_s *bfad)
 713{
 714	struct bfad_im_s      *im;
 
 715
 716	im = kzalloc(sizeof(struct bfad_im_s), GFP_KERNEL);
 717	if (im == NULL)
 718		return BFA_STATUS_ENOMEM;
 
 
 719
 720	bfad->im = im;
 721	im->bfad = bfad;
 722
 723	if (bfad_thread_workq(bfad) != BFA_STATUS_OK) {
 724		kfree(im);
 725		return BFA_STATUS_FAILED;
 726	}
 727
 728	INIT_WORK(&im->aen_im_notify_work, bfad_aen_im_notify_handler);
 729	return BFA_STATUS_OK;
 
 730}
 731
 732void
 733bfad_im_probe_undo(struct bfad_s *bfad)
 734{
 735	if (bfad->im) {
 736		bfad_destroy_workq(bfad->im);
 737		kfree(bfad->im);
 738		bfad->im = NULL;
 739	}
 740}
 741
 742struct Scsi_Host *
 743bfad_scsi_host_alloc(struct bfad_im_port_s *im_port, struct bfad_s *bfad)
 744{
 745	struct scsi_host_template *sht;
 746
 747	if (im_port->port->pvb_type == BFAD_PORT_PHYS_BASE)
 748		sht = &bfad_im_scsi_host_template;
 749	else
 750		sht = &bfad_im_vport_template;
 751
 752	if (max_xfer_size != BFAD_MAX_SECTORS >> 1)
 753		sht->max_sectors = max_xfer_size << 1;
 754
 755	sht->sg_tablesize = bfad->cfg_data.io_max_sge;
 756
 757	return scsi_host_alloc(sht, sizeof(unsigned long));
 758}
 759
 760void
 761bfad_scsi_host_free(struct bfad_s *bfad, struct bfad_im_port_s *im_port)
 762{
 763	if (!(im_port->flags & BFAD_PORT_DELETE))
 764		flush_workqueue(bfad->im->drv_workq);
 765	bfad_im_scsi_host_free(im_port->bfad, im_port);
 766	bfad_im_port_clean(im_port);
 767	kfree(im_port);
 768}
 769
 770void
 771bfad_destroy_workq(struct bfad_im_s *im)
 772{
 773	if (im && im->drv_workq) {
 774		flush_workqueue(im->drv_workq);
 775		destroy_workqueue(im->drv_workq);
 776		im->drv_workq = NULL;
 777	}
 778}
 779
 780bfa_status_t
 781bfad_thread_workq(struct bfad_s *bfad)
 782{
 783	struct bfad_im_s      *im = bfad->im;
 784
 785	bfa_trc(bfad, 0);
 786	snprintf(im->drv_workq_name, KOBJ_NAME_LEN, "bfad_wq_%d",
 787		 bfad->inst_no);
 788	im->drv_workq = create_singlethread_workqueue(im->drv_workq_name);
 789	if (!im->drv_workq)
 790		return BFA_STATUS_FAILED;
 791
 792	return BFA_STATUS_OK;
 793}
 794
 795/*
 796 * Scsi_Host template entry.
 797 *
 798 * Description:
 799 * OS entry point to adjust the queue_depths on a per-device basis.
 800 * Called once per device during the bus scan.
 801 * Return non-zero if fails.
 802 */
 803static int
 804bfad_im_slave_configure(struct scsi_device *sdev)
 805{
 806	scsi_change_queue_depth(sdev, bfa_lun_queue_depth);
 
 
 
 
 807	return 0;
 808}
 809
 810struct scsi_host_template bfad_im_scsi_host_template = {
 811	.module = THIS_MODULE,
 812	.name = BFAD_DRIVER_NAME,
 813	.info = bfad_im_info,
 814	.queuecommand = bfad_im_queuecommand,
 815	.eh_abort_handler = bfad_im_abort_handler,
 816	.eh_device_reset_handler = bfad_im_reset_lun_handler,
 817	.eh_bus_reset_handler = bfad_im_reset_bus_handler,
 818
 819	.slave_alloc = bfad_im_slave_alloc,
 820	.slave_configure = bfad_im_slave_configure,
 821	.slave_destroy = bfad_im_slave_destroy,
 822
 823	.this_id = -1,
 824	.sg_tablesize = BFAD_IO_MAX_SGE,
 825	.cmd_per_lun = 3,
 826	.use_clustering = ENABLE_CLUSTERING,
 827	.shost_attrs = bfad_im_host_attrs,
 828	.max_sectors = BFAD_MAX_SECTORS,
 829	.vendor_id = BFA_PCI_VENDOR_ID_BROCADE,
 830};
 831
 832struct scsi_host_template bfad_im_vport_template = {
 833	.module = THIS_MODULE,
 834	.name = BFAD_DRIVER_NAME,
 835	.info = bfad_im_info,
 836	.queuecommand = bfad_im_queuecommand,
 837	.eh_abort_handler = bfad_im_abort_handler,
 838	.eh_device_reset_handler = bfad_im_reset_lun_handler,
 839	.eh_bus_reset_handler = bfad_im_reset_bus_handler,
 840
 841	.slave_alloc = bfad_im_slave_alloc,
 842	.slave_configure = bfad_im_slave_configure,
 843	.slave_destroy = bfad_im_slave_destroy,
 844
 845	.this_id = -1,
 846	.sg_tablesize = BFAD_IO_MAX_SGE,
 847	.cmd_per_lun = 3,
 848	.use_clustering = ENABLE_CLUSTERING,
 849	.shost_attrs = bfad_im_vport_attrs,
 850	.max_sectors = BFAD_MAX_SECTORS,
 851};
 852
 853bfa_status_t
 854bfad_im_module_init(void)
 855{
 856	bfad_im_scsi_transport_template =
 857		fc_attach_transport(&bfad_im_fc_function_template);
 858	if (!bfad_im_scsi_transport_template)
 859		return BFA_STATUS_ENOMEM;
 860
 861	bfad_im_scsi_vport_transport_template =
 862		fc_attach_transport(&bfad_im_vport_fc_function_template);
 863	if (!bfad_im_scsi_vport_transport_template) {
 864		fc_release_transport(bfad_im_scsi_transport_template);
 865		return BFA_STATUS_ENOMEM;
 866	}
 867
 868	return BFA_STATUS_OK;
 869}
 870
 871void
 872bfad_im_module_exit(void)
 873{
 874	if (bfad_im_scsi_transport_template)
 875		fc_release_transport(bfad_im_scsi_transport_template);
 876
 877	if (bfad_im_scsi_vport_transport_template)
 878		fc_release_transport(bfad_im_scsi_vport_transport_template);
 879
 880	idr_destroy(&bfad_im_port_index);
 881}
 882
 883void
 884bfad_ramp_up_qdepth(struct bfad_itnim_s *itnim, struct scsi_device *sdev)
 885{
 886	struct scsi_device *tmp_sdev;
 887
 888	if (((jiffies - itnim->last_ramp_up_time) >
 889		BFA_QUEUE_FULL_RAMP_UP_TIME * HZ) &&
 890		((jiffies - itnim->last_queue_full_time) >
 891		BFA_QUEUE_FULL_RAMP_UP_TIME * HZ)) {
 892		shost_for_each_device(tmp_sdev, sdev->host) {
 893			if (bfa_lun_queue_depth > tmp_sdev->queue_depth) {
 894				if (tmp_sdev->id != sdev->id)
 895					continue;
 896				scsi_change_queue_depth(tmp_sdev,
 897					tmp_sdev->queue_depth + 1);
 
 
 
 
 
 
 898
 899				itnim->last_ramp_up_time = jiffies;
 900			}
 901		}
 902	}
 903}
 904
 905void
 906bfad_handle_qfull(struct bfad_itnim_s *itnim, struct scsi_device *sdev)
 907{
 908	struct scsi_device *tmp_sdev;
 909
 910	itnim->last_queue_full_time = jiffies;
 911
 912	shost_for_each_device(tmp_sdev, sdev->host) {
 913		if (tmp_sdev->id != sdev->id)
 914			continue;
 915		scsi_track_queue_full(tmp_sdev, tmp_sdev->queue_depth - 1);
 916	}
 917}
 918
 919struct bfad_itnim_s *
 920bfad_get_itnim(struct bfad_im_port_s *im_port, int id)
 921{
 922	struct bfad_itnim_s   *itnim = NULL;
 923
 924	/* Search the mapped list for this target ID */
 925	list_for_each_entry(itnim, &im_port->itnim_mapped_list, list_entry) {
 926		if (id == itnim->scsi_tgt_id)
 927			return itnim;
 928	}
 929
 930	return NULL;
 931}
 932
 933/*
 934 * Function is invoked from the SCSI Host Template slave_alloc() entry point.
 935 * Has the logic to query the LUN Mask database to check if this LUN needs to
 936 * be made visible to the SCSI mid-layer or not.
 937 *
 938 * Returns BFA_STATUS_OK if this LUN needs to be added to the OS stack.
 939 * Returns -ENXIO to notify SCSI mid-layer to not add this LUN to the OS stack.
 940 */
 941static int
 942bfad_im_check_if_make_lun_visible(struct scsi_device *sdev,
 943				  struct fc_rport *rport)
 944{
 945	struct bfad_itnim_data_s *itnim_data =
 946				(struct bfad_itnim_data_s *) rport->dd_data;
 947	struct bfa_s *bfa = itnim_data->itnim->bfa_itnim->bfa;
 948	struct bfa_rport_s *bfa_rport = itnim_data->itnim->bfa_itnim->rport;
 949	struct bfa_lun_mask_s *lun_list = bfa_get_lun_mask_list(bfa);
 950	int i = 0, ret = -ENXIO;
 951
 952	for (i = 0; i < MAX_LUN_MASK_CFG; i++) {
 953		if (lun_list[i].state == BFA_IOIM_LUN_MASK_ACTIVE &&
 954		    scsilun_to_int(&lun_list[i].lun) == sdev->lun &&
 955		    lun_list[i].rp_tag == bfa_rport->rport_tag &&
 956		    lun_list[i].lp_tag == (u8)bfa_rport->rport_info.lp_tag) {
 957			ret = BFA_STATUS_OK;
 958			break;
 959		}
 960	}
 961	return ret;
 962}
 963
 964/*
 965 * Scsi_Host template entry slave_alloc
 966 */
 967static int
 968bfad_im_slave_alloc(struct scsi_device *sdev)
 969{
 970	struct fc_rport *rport = starget_to_rport(scsi_target(sdev));
 971	struct bfad_itnim_data_s *itnim_data;
 972	struct bfa_s *bfa;
 973
 974	if (!rport || fc_remote_port_chkready(rport))
 975		return -ENXIO;
 976
 977	itnim_data = (struct bfad_itnim_data_s *) rport->dd_data;
 978	bfa = itnim_data->itnim->bfa_itnim->bfa;
 979
 980	if (bfa_get_lun_mask_status(bfa) == BFA_LUNMASK_ENABLED) {
 981		/*
 982		 * We should not mask LUN 0 - since this will translate
 983		 * to no LUN / TARGET for SCSI ml resulting no scan.
 984		 */
 985		if (sdev->lun == 0) {
 986			sdev->sdev_bflags |= BLIST_NOREPORTLUN |
 987					     BLIST_SPARSELUN;
 988			goto done;
 989		}
 990
 991		/*
 992		 * Query LUN Mask configuration - to expose this LUN
 993		 * to the SCSI mid-layer or to mask it.
 994		 */
 995		if (bfad_im_check_if_make_lun_visible(sdev, rport) !=
 996							BFA_STATUS_OK)
 997			return -ENXIO;
 998	}
 999done:
1000	sdev->hostdata = rport->dd_data;
1001
1002	return 0;
1003}
1004
1005u32
1006bfad_im_supported_speeds(struct bfa_s *bfa)
1007{
1008	struct bfa_ioc_attr_s *ioc_attr;
1009	u32 supported_speed = 0;
1010
1011	ioc_attr = kzalloc(sizeof(struct bfa_ioc_attr_s), GFP_KERNEL);
1012	if (!ioc_attr)
1013		return 0;
1014
1015	bfa_ioc_get_attr(&bfa->ioc, ioc_attr);
1016	if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_16GBPS)
1017		supported_speed |=  FC_PORTSPEED_16GBIT | FC_PORTSPEED_8GBIT |
1018				FC_PORTSPEED_4GBIT | FC_PORTSPEED_2GBIT;
1019	else if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_8GBPS) {
1020		if (ioc_attr->adapter_attr.is_mezz) {
1021			supported_speed |= FC_PORTSPEED_8GBIT |
1022				FC_PORTSPEED_4GBIT |
1023				FC_PORTSPEED_2GBIT | FC_PORTSPEED_1GBIT;
1024		} else {
1025			supported_speed |= FC_PORTSPEED_8GBIT |
1026				FC_PORTSPEED_4GBIT |
1027				FC_PORTSPEED_2GBIT;
1028		}
1029	} else if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_4GBPS) {
1030		supported_speed |=  FC_PORTSPEED_4GBIT | FC_PORTSPEED_2GBIT |
1031				FC_PORTSPEED_1GBIT;
1032	} else if (ioc_attr->adapter_attr.max_speed == BFA_PORT_SPEED_10GBPS) {
1033		supported_speed |= FC_PORTSPEED_10GBIT;
1034	}
1035	kfree(ioc_attr);
1036	return supported_speed;
1037}
1038
1039void
1040bfad_fc_host_init(struct bfad_im_port_s *im_port)
1041{
1042	struct Scsi_Host *host = im_port->shost;
1043	struct bfad_s         *bfad = im_port->bfad;
1044	struct bfad_port_s    *port = im_port->port;
1045	char symname[BFA_SYMNAME_MAXLEN];
1046	struct bfa_fcport_s *fcport = BFA_FCPORT_MOD(&bfad->bfa);
1047
1048	fc_host_node_name(host) =
1049		cpu_to_be64((bfa_fcs_lport_get_nwwn(port->fcs_port)));
1050	fc_host_port_name(host) =
1051		cpu_to_be64((bfa_fcs_lport_get_pwwn(port->fcs_port)));
1052	fc_host_max_npiv_vports(host) = bfa_lps_get_max_vport(&bfad->bfa);
1053
1054	fc_host_supported_classes(host) = FC_COS_CLASS3;
1055
1056	memset(fc_host_supported_fc4s(host), 0,
1057	       sizeof(fc_host_supported_fc4s(host)));
1058	if (supported_fc4s & BFA_LPORT_ROLE_FCP_IM)
1059		/* For FCP type 0x08 */
1060		fc_host_supported_fc4s(host)[2] = 1;
1061	/* For fibre channel services type 0x20 */
1062	fc_host_supported_fc4s(host)[7] = 1;
1063
1064	strlcpy(symname, bfad->bfa_fcs.fabric.bport.port_cfg.sym_name.symname,
1065		BFA_SYMNAME_MAXLEN);
1066	sprintf(fc_host_symbolic_name(host), "%s", symname);
1067
1068	fc_host_supported_speeds(host) = bfad_im_supported_speeds(&bfad->bfa);
1069	fc_host_maxframe_size(host) = fcport->cfg.maxfrsize;
1070}
1071
1072static void
1073bfad_im_fc_rport_add(struct bfad_im_port_s *im_port, struct bfad_itnim_s *itnim)
1074{
1075	struct fc_rport_identifiers rport_ids;
1076	struct fc_rport *fc_rport;
1077	struct bfad_itnim_data_s *itnim_data;
1078
1079	rport_ids.node_name =
1080		cpu_to_be64(bfa_fcs_itnim_get_nwwn(&itnim->fcs_itnim));
1081	rport_ids.port_name =
1082		cpu_to_be64(bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim));
1083	rport_ids.port_id =
1084		bfa_hton3b(bfa_fcs_itnim_get_fcid(&itnim->fcs_itnim));
1085	rport_ids.roles = FC_RPORT_ROLE_UNKNOWN;
1086
1087	itnim->fc_rport = fc_rport =
1088		fc_remote_port_add(im_port->shost, 0, &rport_ids);
1089
1090	if (!fc_rport)
1091		return;
1092
1093	fc_rport->maxframe_size =
1094		bfa_fcs_itnim_get_maxfrsize(&itnim->fcs_itnim);
1095	fc_rport->supported_classes = bfa_fcs_itnim_get_cos(&itnim->fcs_itnim);
1096
1097	itnim_data = fc_rport->dd_data;
1098	itnim_data->itnim = itnim;
1099
1100	rport_ids.roles |= FC_RPORT_ROLE_FCP_TARGET;
1101
1102	if (rport_ids.roles != FC_RPORT_ROLE_UNKNOWN)
1103		fc_remote_port_rolechg(fc_rport, rport_ids.roles);
1104
1105	if ((fc_rport->scsi_target_id != -1)
1106	    && (fc_rport->scsi_target_id < MAX_FCP_TARGET))
1107		itnim->scsi_tgt_id = fc_rport->scsi_target_id;
1108
1109	itnim->channel = fc_rport->channel;
1110
1111	return;
1112}
1113
1114/*
1115 * Work queue handler using FC transport service
1116* Context: kernel
1117 */
1118static void
1119bfad_im_itnim_work_handler(struct work_struct *work)
1120{
1121	struct bfad_itnim_s   *itnim = container_of(work, struct bfad_itnim_s,
1122							itnim_work);
1123	struct bfad_im_s      *im = itnim->im;
1124	struct bfad_s         *bfad = im->bfad;
1125	struct bfad_im_port_s *im_port;
1126	unsigned long   flags;
1127	struct fc_rport *fc_rport;
1128	wwn_t wwpn;
1129	u32 fcid;
1130	char wwpn_str[32], fcid_str[16];
1131
1132	spin_lock_irqsave(&bfad->bfad_lock, flags);
1133	im_port = itnim->im_port;
1134	bfa_trc(bfad, itnim->state);
1135	switch (itnim->state) {
1136	case ITNIM_STATE_ONLINE:
1137		if (!itnim->fc_rport) {
1138			spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1139			bfad_im_fc_rport_add(im_port, itnim);
1140			spin_lock_irqsave(&bfad->bfad_lock, flags);
1141			wwpn = bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim);
1142			fcid = bfa_fcs_itnim_get_fcid(&itnim->fcs_itnim);
1143			wwn2str(wwpn_str, wwpn);
1144			fcid2str(fcid_str, fcid);
1145			list_add_tail(&itnim->list_entry,
1146				&im_port->itnim_mapped_list);
1147			BFA_LOG(KERN_INFO, bfad, bfa_log_level,
1148				"ITNIM ONLINE Target: %d:0:%d "
1149				"FCID: %s WWPN: %s\n",
1150				im_port->shost->host_no,
1151				itnim->scsi_tgt_id,
1152				fcid_str, wwpn_str);
1153		} else {
1154			printk(KERN_WARNING
1155				"%s: itnim %llx is already in online state\n",
1156				__func__,
1157				bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim));
1158		}
1159
1160		break;
1161	case ITNIM_STATE_OFFLINE_PENDING:
1162		itnim->state = ITNIM_STATE_OFFLINE;
1163		if (itnim->fc_rport) {
1164			fc_rport = itnim->fc_rport;
1165			((struct bfad_itnim_data_s *)
1166				fc_rport->dd_data)->itnim = NULL;
1167			itnim->fc_rport = NULL;
1168			if (!(im_port->port->flags & BFAD_PORT_DELETE)) {
1169				spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1170				fc_rport->dev_loss_tmo =
1171					bfa_fcpim_path_tov_get(&bfad->bfa) + 1;
1172				fc_remote_port_delete(fc_rport);
1173				spin_lock_irqsave(&bfad->bfad_lock, flags);
1174			}
1175			wwpn = bfa_fcs_itnim_get_pwwn(&itnim->fcs_itnim);
1176			fcid = bfa_fcs_itnim_get_fcid(&itnim->fcs_itnim);
1177			wwn2str(wwpn_str, wwpn);
1178			fcid2str(fcid_str, fcid);
1179			list_del(&itnim->list_entry);
1180			BFA_LOG(KERN_INFO, bfad, bfa_log_level,
1181				"ITNIM OFFLINE Target: %d:0:%d "
1182				"FCID: %s WWPN: %s\n",
1183				im_port->shost->host_no,
1184				itnim->scsi_tgt_id,
1185				fcid_str, wwpn_str);
1186		}
1187		break;
1188	case ITNIM_STATE_FREE:
1189		if (itnim->fc_rport) {
1190			fc_rport = itnim->fc_rport;
1191			((struct bfad_itnim_data_s *)
1192				fc_rport->dd_data)->itnim = NULL;
1193			itnim->fc_rport = NULL;
1194			if (!(im_port->port->flags & BFAD_PORT_DELETE)) {
1195				spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1196				fc_rport->dev_loss_tmo =
1197					bfa_fcpim_path_tov_get(&bfad->bfa) + 1;
1198				fc_remote_port_delete(fc_rport);
1199				spin_lock_irqsave(&bfad->bfad_lock, flags);
1200			}
1201			list_del(&itnim->list_entry);
1202		}
1203
1204		kfree(itnim);
1205		break;
1206	default:
1207		WARN_ON(1);
1208		break;
1209	}
1210
1211	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1212}
1213
1214/*
1215 * Scsi_Host template entry, queue a SCSI command to the BFAD.
1216 */
1217static int
1218bfad_im_queuecommand_lck(struct scsi_cmnd *cmnd, void (*done) (struct scsi_cmnd *))
1219{
1220	struct bfad_im_port_s *im_port =
1221		(struct bfad_im_port_s *) cmnd->device->host->hostdata[0];
1222	struct bfad_s         *bfad = im_port->bfad;
1223	struct bfad_itnim_data_s *itnim_data = cmnd->device->hostdata;
1224	struct bfad_itnim_s   *itnim;
1225	struct bfa_ioim_s *hal_io;
1226	unsigned long   flags;
1227	int             rc;
1228	int       sg_cnt = 0;
1229	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd->device));
1230
1231	rc = fc_remote_port_chkready(rport);
1232	if (rc) {
1233		cmnd->result = rc;
1234		done(cmnd);
1235		return 0;
1236	}
1237
1238	if (bfad->bfad_flags & BFAD_EEH_BUSY) {
1239		if (bfad->bfad_flags & BFAD_EEH_PCI_CHANNEL_IO_PERM_FAILURE)
1240			cmnd->result = DID_NO_CONNECT << 16;
1241		else
1242			cmnd->result = DID_REQUEUE << 16;
1243		done(cmnd);
1244		return 0;
1245	}
1246
1247	sg_cnt = scsi_dma_map(cmnd);
1248	if (sg_cnt < 0)
1249		return SCSI_MLQUEUE_HOST_BUSY;
1250
1251	cmnd->scsi_done = done;
1252
1253	spin_lock_irqsave(&bfad->bfad_lock, flags);
1254	if (!(bfad->bfad_flags & BFAD_HAL_START_DONE)) {
1255		printk(KERN_WARNING
1256			"bfad%d, queuecommand %p %x failed, BFA stopped\n",
1257		       bfad->inst_no, cmnd, cmnd->cmnd[0]);
1258		cmnd->result = ScsiResult(DID_NO_CONNECT, 0);
1259		goto out_fail_cmd;
1260	}
1261
1262
1263	itnim = itnim_data->itnim;
1264	if (!itnim) {
1265		cmnd->result = ScsiResult(DID_IMM_RETRY, 0);
1266		goto out_fail_cmd;
1267	}
1268
1269	hal_io = bfa_ioim_alloc(&bfad->bfa, (struct bfad_ioim_s *) cmnd,
1270				    itnim->bfa_itnim, sg_cnt);
1271	if (!hal_io) {
1272		printk(KERN_WARNING "hal_io failure\n");
1273		spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1274		scsi_dma_unmap(cmnd);
1275		return SCSI_MLQUEUE_HOST_BUSY;
1276	}
1277
1278	cmnd->host_scribble = (char *)hal_io;
1279	bfa_ioim_start(hal_io);
1280	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1281
1282	return 0;
1283
1284out_fail_cmd:
1285	spin_unlock_irqrestore(&bfad->bfad_lock, flags);
1286	scsi_dma_unmap(cmnd);
1287	if (done)
1288		done(cmnd);
1289
1290	return 0;
1291}
1292
1293static DEF_SCSI_QCMD(bfad_im_queuecommand)
1294
1295void
1296bfad_rport_online_wait(struct bfad_s *bfad)
1297{
1298	int i;
1299	int rport_delay = 10;
1300
1301	for (i = 0; !(bfad->bfad_flags & BFAD_PORT_ONLINE)
1302		&& i < bfa_linkup_delay; i++) {
1303		set_current_state(TASK_UNINTERRUPTIBLE);
1304		schedule_timeout(HZ);
1305	}
1306
1307	if (bfad->bfad_flags & BFAD_PORT_ONLINE) {
1308		rport_delay = rport_delay < bfa_linkup_delay ?
1309			rport_delay : bfa_linkup_delay;
1310		for (i = 0; !(bfad->bfad_flags & BFAD_RPORT_ONLINE)
1311			&& i < rport_delay; i++) {
1312			set_current_state(TASK_UNINTERRUPTIBLE);
1313			schedule_timeout(HZ);
1314		}
1315
1316		if (rport_delay > 0 && (bfad->bfad_flags & BFAD_RPORT_ONLINE)) {
1317			set_current_state(TASK_UNINTERRUPTIBLE);
1318			schedule_timeout(rport_delay * HZ);
1319		}
1320	}
1321}
1322
1323int
1324bfad_get_linkup_delay(struct bfad_s *bfad)
1325{
1326	u8		nwwns = 0;
1327	wwn_t		wwns[BFA_PREBOOT_BOOTLUN_MAX];
1328	int		linkup_delay;
1329
1330	/*
1331	 * Querying for the boot target port wwns
1332	 * -- read from boot information in flash.
1333	 * If nwwns > 0 => boot over SAN and set linkup_delay = 30
1334	 * else => local boot machine set linkup_delay = 0
1335	 */
1336
1337	bfa_iocfc_get_bootwwns(&bfad->bfa, &nwwns, wwns);
1338
1339	if (nwwns > 0)
1340		/* If Boot over SAN set linkup_delay = 30sec */
1341		linkup_delay = 30;
1342	else
1343		/* If local boot; no linkup_delay */
1344		linkup_delay = 0;
1345
1346	return linkup_delay;
1347}