Blame view
drivers/target/target_core_pscsi.c
32.1 KB
c66ac9db8 [SCSI] target: Ad... |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
/******************************************************************************* * Filename: target_core_pscsi.c * * This file contains the generic target mode <-> Linux SCSI subsystem plugin. * * Copyright (c) 2003, 2004, 2005 PyX Technologies, Inc. * Copyright (c) 2005, 2006, 2007 SBE, Inc. * Copyright (c) 2007-2010 Rising Tide Systems * Copyright (c) 2008-2010 Linux-iSCSI.org * * Nicholas A. Bellinger <nab@kernel.org> * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ******************************************************************************/ |
c66ac9db8 [SCSI] target: Ad... |
28 29 30 31 32 33 34 |
#include <linux/string.h> #include <linux/parser.h> #include <linux/timer.h> #include <linux/blkdev.h> #include <linux/blk_types.h> #include <linux/slab.h> #include <linux/spinlock.h> |
c66ac9db8 [SCSI] target: Ad... |
35 36 37 |
#include <linux/genhd.h> #include <linux/cdrom.h> #include <linux/file.h> |
827509e38 drivers/target: A... |
38 |
#include <linux/module.h> |
c66ac9db8 [SCSI] target: Ad... |
39 40 41 42 |
#include <scsi/scsi.h> #include <scsi/scsi_device.h> #include <scsi/scsi_cmnd.h> #include <scsi/scsi_host.h> |
e66ecd505 [SCSI] target: Co... |
43 |
#include <scsi/scsi_tcq.h> |
c66ac9db8 [SCSI] target: Ad... |
44 45 46 47 48 49 50 51 52 53 54 55 |
#include <target/target_core_base.h> #include <target/target_core_device.h> #include <target/target_core_transport.h> #include "target_core_pscsi.h" #define ISPRINT(a) ((a >= ' ') && (a <= '~')) static struct se_subsystem_api pscsi_template; static void pscsi_req_done(struct request *, int); |
c66ac9db8 [SCSI] target: Ad... |
56 57 58 59 60 61 62 |
/* pscsi_attach_hba(): * * pscsi_get_sh() used scsi_host_lookup() to locate struct Scsi_Host. * from the passed SCSI Host ID. */ static int pscsi_attach_hba(struct se_hba *hba, u32 host_id) { |
c66ac9db8 [SCSI] target: Ad... |
63 64 65 |
struct pscsi_hba_virt *phv; phv = kzalloc(sizeof(struct pscsi_hba_virt), GFP_KERNEL); |
6708bb27b target: Follow up... |
66 67 68 |
if (!phv) { pr_err("Unable to allocate struct pscsi_hba_virt "); |
e3d6f909e target: Core clea... |
69 |
return -ENOMEM; |
c66ac9db8 [SCSI] target: Ad... |
70 71 72 |
} phv->phv_host_id = host_id; phv->phv_mode = PHV_VIRUTAL_HOST_ID; |
c66ac9db8 [SCSI] target: Ad... |
73 |
|
5951146de target: More core... |
74 |
hba->hba_ptr = phv; |
c66ac9db8 [SCSI] target: Ad... |
75 |
|
6708bb27b target: Follow up... |
76 |
pr_debug("CORE_HBA[%d] - TCM SCSI HBA Driver %s on" |
c66ac9db8 [SCSI] target: Ad... |
77 78 79 |
" Generic Target Core Stack %s ", hba->hba_id, PSCSI_VERSION, TARGET_CORE_MOD_VERSION); |
6708bb27b target: Follow up... |
80 81 |
pr_debug("CORE_HBA[%d] - Attached SCSI HBA to Generic ", |
e3d6f909e target: Core clea... |
82 |
hba->hba_id); |
c66ac9db8 [SCSI] target: Ad... |
83 84 85 86 87 88 89 90 91 92 93 |
return 0; } static void pscsi_detach_hba(struct se_hba *hba) { struct pscsi_hba_virt *phv = hba->hba_ptr; struct Scsi_Host *scsi_host = phv->phv_lld_host; if (scsi_host) { scsi_host_put(scsi_host); |
6708bb27b target: Follow up... |
94 |
pr_debug("CORE_HBA[%d] - Detached SCSI HBA: %s from" |
c66ac9db8 [SCSI] target: Ad... |
95 96 97 98 99 |
" Generic Target Core ", hba->hba_id, (scsi_host->hostt->name) ? (scsi_host->hostt->name) : "Unknown"); } else |
6708bb27b target: Follow up... |
100 |
pr_debug("CORE_HBA[%d] - Detached Virtual SCSI HBA" |
c66ac9db8 [SCSI] target: Ad... |
101 102 103 104 105 106 107 108 109 110 111 |
" from Generic Target Core ", hba->hba_id); kfree(phv); hba->hba_ptr = NULL; } static int pscsi_pmode_enable_hba(struct se_hba *hba, unsigned long mode_flag) { struct pscsi_hba_virt *phv = (struct pscsi_hba_virt *)hba->hba_ptr; struct Scsi_Host *sh = phv->phv_lld_host; |
c66ac9db8 [SCSI] target: Ad... |
112 113 114 |
/* * Release the struct Scsi_Host */ |
6708bb27b target: Follow up... |
115 116 |
if (!mode_flag) { if (!sh) |
c66ac9db8 [SCSI] target: Ad... |
117 118 119 120 |
return 0; phv->phv_lld_host = NULL; phv->phv_mode = PHV_VIRUTAL_HOST_ID; |
c66ac9db8 [SCSI] target: Ad... |
121 |
|
6708bb27b target: Follow up... |
122 |
pr_debug("CORE_HBA[%d] - Disabled pSCSI HBA Passthrough" |
c66ac9db8 [SCSI] target: Ad... |
123 124 125 126 127 128 129 130 131 132 133 |
" %s ", hba->hba_id, (sh->hostt->name) ? (sh->hostt->name) : "Unknown"); scsi_host_put(sh); return 0; } /* * Otherwise, locate struct Scsi_Host from the original passed * pSCSI Host ID and enable for phba mode */ |
e3d6f909e target: Core clea... |
134 135 |
sh = scsi_host_lookup(phv->phv_host_id); if (IS_ERR(sh)) { |
6708bb27b target: Follow up... |
136 |
pr_err("pSCSI: Unable to locate SCSI Host for" |
c66ac9db8 [SCSI] target: Ad... |
137 138 |
" phv_host_id: %d ", phv->phv_host_id); |
e3d6f909e target: Core clea... |
139 |
return PTR_ERR(sh); |
c66ac9db8 [SCSI] target: Ad... |
140 |
} |
c66ac9db8 [SCSI] target: Ad... |
141 142 143 |
phv->phv_lld_host = sh; phv->phv_mode = PHV_LLD_SCSI_HOST_NO; |
6708bb27b target: Follow up... |
144 145 |
pr_debug("CORE_HBA[%d] - Enabled pSCSI HBA Passthrough %s ", |
c66ac9db8 [SCSI] target: Ad... |
146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 |
hba->hba_id, (sh->hostt->name) ? (sh->hostt->name) : "Unknown"); return 1; } static void pscsi_tape_read_blocksize(struct se_device *dev, struct scsi_device *sdev) { unsigned char cdb[MAX_COMMAND_SIZE], *buf; int ret; buf = kzalloc(12, GFP_KERNEL); if (!buf) return; memset(cdb, 0, MAX_COMMAND_SIZE); cdb[0] = MODE_SENSE; cdb[4] = 0x0c; /* 12 bytes */ ret = scsi_execute_req(sdev, cdb, DMA_FROM_DEVICE, buf, 12, NULL, HZ, 1, NULL); if (ret) goto out_free; /* * If MODE_SENSE still returns zero, set the default value to 1024. */ sdev->sector_size = (buf[9] << 16) | (buf[10] << 8) | (buf[11]); if (!sdev->sector_size) sdev->sector_size = 1024; out_free: kfree(buf); } static void pscsi_set_inquiry_info(struct scsi_device *sdev, struct t10_wwn *wwn) { unsigned char *buf; if (sdev->inquiry_len < INQUIRY_LEN) return; buf = sdev->inquiry; if (!buf) return; /* * Use sdev->inquiry from drivers/scsi/scsi_scan.c:scsi_alloc_sdev() */ memcpy(&wwn->vendor[0], &buf[8], sizeof(wwn->vendor)); memcpy(&wwn->model[0], &buf[16], sizeof(wwn->model)); memcpy(&wwn->revision[0], &buf[32], sizeof(wwn->revision)); } static int pscsi_get_inquiry_vpd_serial(struct scsi_device *sdev, struct t10_wwn *wwn) { unsigned char cdb[MAX_COMMAND_SIZE], *buf; int ret; buf = kzalloc(INQUIRY_VPD_SERIAL_LEN, GFP_KERNEL); if (!buf) |
e3d6f909e target: Core clea... |
207 |
return -ENOMEM; |
c66ac9db8 [SCSI] target: Ad... |
208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 |
memset(cdb, 0, MAX_COMMAND_SIZE); cdb[0] = INQUIRY; cdb[1] = 0x01; /* Query VPD */ cdb[2] = 0x80; /* Unit Serial Number */ cdb[3] = (INQUIRY_VPD_SERIAL_LEN >> 8) & 0xff; cdb[4] = (INQUIRY_VPD_SERIAL_LEN & 0xff); ret = scsi_execute_req(sdev, cdb, DMA_FROM_DEVICE, buf, INQUIRY_VPD_SERIAL_LEN, NULL, HZ, 1, NULL); if (ret) goto out_free; snprintf(&wwn->unit_serial[0], INQUIRY_VPD_SERIAL_LEN, "%s", &buf[4]); wwn->t10_sub_dev->su_dev_flags |= SDF_FIRMWARE_VPD_UNIT_SERIAL; kfree(buf); return 0; out_free: kfree(buf); |
e3d6f909e target: Core clea... |
230 |
return -EPERM; |
c66ac9db8 [SCSI] target: Ad... |
231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 |
} static void pscsi_get_inquiry_vpd_device_ident(struct scsi_device *sdev, struct t10_wwn *wwn) { unsigned char cdb[MAX_COMMAND_SIZE], *buf, *page_83; int ident_len, page_len, off = 4, ret; struct t10_vpd *vpd; buf = kzalloc(INQUIRY_VPD_SERIAL_LEN, GFP_KERNEL); if (!buf) return; memset(cdb, 0, MAX_COMMAND_SIZE); cdb[0] = INQUIRY; cdb[1] = 0x01; /* Query VPD */ cdb[2] = 0x83; /* Device Identifier */ cdb[3] = (INQUIRY_VPD_DEVICE_IDENTIFIER_LEN >> 8) & 0xff; cdb[4] = (INQUIRY_VPD_DEVICE_IDENTIFIER_LEN & 0xff); ret = scsi_execute_req(sdev, cdb, DMA_FROM_DEVICE, buf, INQUIRY_VPD_DEVICE_IDENTIFIER_LEN, NULL, HZ, 1, NULL); if (ret) goto out; page_len = (buf[2] << 8) | buf[3]; while (page_len > 0) { /* Grab a pointer to the Identification descriptor */ page_83 = &buf[off]; ident_len = page_83[3]; if (!ident_len) { |
6708bb27b target: Follow up... |
264 |
pr_err("page_83[3]: identifier" |
c66ac9db8 [SCSI] target: Ad... |
265 266 267 268 |
" length zero! "); break; } |
6708bb27b target: Follow up... |
269 270 |
pr_debug("T10 VPD Identifer Length: %d ", ident_len); |
c66ac9db8 [SCSI] target: Ad... |
271 272 273 |
vpd = kzalloc(sizeof(struct t10_vpd), GFP_KERNEL); if (!vpd) { |
6708bb27b target: Follow up... |
274 |
pr_err("Unable to allocate memory for" |
c66ac9db8 [SCSI] target: Ad... |
275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 |
" struct t10_vpd "); goto out; } INIT_LIST_HEAD(&vpd->vpd_list); transport_set_vpd_proto_id(vpd, page_83); transport_set_vpd_assoc(vpd, page_83); if (transport_set_vpd_ident_type(vpd, page_83) < 0) { off += (ident_len + 4); page_len -= (ident_len + 4); kfree(vpd); continue; } if (transport_set_vpd_ident(vpd, page_83) < 0) { off += (ident_len + 4); page_len -= (ident_len + 4); kfree(vpd); continue; } list_add_tail(&vpd->vpd_list, &wwn->t10_vpd_list); off += (ident_len + 4); page_len -= (ident_len + 4); } out: kfree(buf); } /* pscsi_add_device_to_list(): * * */ static struct se_device *pscsi_add_device_to_list( struct se_hba *hba, struct se_subsystem_dev *se_dev, struct pscsi_dev_virt *pdv, struct scsi_device *sd, int dev_flags) { struct se_device *dev; struct se_dev_limits dev_limits; struct request_queue *q; struct queue_limits *limits; memset(&dev_limits, 0, sizeof(struct se_dev_limits)); if (!sd->queue_depth) { sd->queue_depth = PSCSI_DEFAULT_QUEUEDEPTH; |
6708bb27b target: Follow up... |
326 |
pr_err("Set broken SCSI Device %d:%d:%d" |
c66ac9db8 [SCSI] target: Ad... |
327 328 329 330 331 332 333 334 335 336 337 |
" queue_depth to %d ", sd->channel, sd->id, sd->lun, sd->queue_depth); } /* * Setup the local scope queue_limits from struct request_queue->limits * to pass into transport_add_device_to_core_hba() as struct se_dev_limits. */ q = sd->request_queue; limits = &dev_limits.limits; limits->logical_block_size = sd->sector_size; |
a1d8b49ab target: Updates f... |
338 339 |
limits->max_hw_sectors = min_t(int, sd->host->max_sectors, queue_max_hw_sectors(q)); limits->max_sectors = min_t(int, sd->host->max_sectors, queue_max_sectors(q)); |
c66ac9db8 [SCSI] target: Ad... |
340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 |
dev_limits.hw_queue_depth = sd->queue_depth; dev_limits.queue_depth = sd->queue_depth; /* * Setup our standard INQUIRY info into se_dev->t10_wwn */ pscsi_set_inquiry_info(sd, &se_dev->t10_wwn); /* * Set the pointer pdv->pdv_sd to from passed struct scsi_device, * which has already been referenced with Linux SCSI code with * scsi_device_get() in this file's pscsi_create_virtdevice(). * * The passthrough operations called by the transport_add_device_* * function below will require this pointer to be set for passthroug * ops. * * For the shutdown case in pscsi_free_device(), this struct * scsi_device reference is released with Linux SCSI code * scsi_device_put() and the pdv->pdv_sd cleared. */ pdv->pdv_sd = sd; dev = transport_add_device_to_core_hba(hba, &pscsi_template, |
5951146de target: More core... |
363 |
se_dev, dev_flags, pdv, |
c66ac9db8 [SCSI] target: Ad... |
364 |
&dev_limits, NULL, NULL); |
6708bb27b target: Follow up... |
365 |
if (!dev) { |
c66ac9db8 [SCSI] target: Ad... |
366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 |
pdv->pdv_sd = NULL; return NULL; } /* * Locate VPD WWN Information used for various purposes within * the Storage Engine. */ if (!pscsi_get_inquiry_vpd_serial(sd, &se_dev->t10_wwn)) { /* * If VPD Unit Serial returned GOOD status, try * VPD Device Identification page (0x83). */ pscsi_get_inquiry_vpd_device_ident(sd, &se_dev->t10_wwn); } /* * For TYPE_TAPE, attempt to determine blocksize with MODE_SENSE. */ if (sd->type == TYPE_TAPE) pscsi_tape_read_blocksize(dev, sd); return dev; } static void *pscsi_allocate_virtdevice(struct se_hba *hba, const char *name) { struct pscsi_dev_virt *pdv; pdv = kzalloc(sizeof(struct pscsi_dev_virt), GFP_KERNEL); |
6708bb27b target: Follow up... |
395 396 397 |
if (!pdv) { pr_err("Unable to allocate memory for struct pscsi_dev_virt "); |
c66ac9db8 [SCSI] target: Ad... |
398 399 400 |
return NULL; } pdv->pdv_se_hba = hba; |
6708bb27b target: Follow up... |
401 402 |
pr_debug("PSCSI: Allocated pdv: %p for %s ", pdv, name); |
5951146de target: More core... |
403 |
return pdv; |
c66ac9db8 [SCSI] target: Ad... |
404 405 406 407 408 409 410 411 412 413 |
} /* * Called with struct Scsi_Host->host_lock called. */ static struct se_device *pscsi_create_type_disk( struct scsi_device *sd, struct pscsi_dev_virt *pdv, struct se_subsystem_dev *se_dev, struct se_hba *hba) |
5dd7ed2e8 [SCSI] target: Mi... |
414 |
__releases(sh->host_lock) |
c66ac9db8 [SCSI] target: Ad... |
415 416 417 418 419 420 421 422 |
{ struct se_device *dev; struct pscsi_hba_virt *phv = (struct pscsi_hba_virt *)pdv->pdv_se_hba->hba_ptr; struct Scsi_Host *sh = sd->host; struct block_device *bd; u32 dev_flags = 0; if (scsi_device_get(sd)) { |
6708bb27b target: Follow up... |
423 424 |
pr_err("scsi_device_get() failed for %d:%d:%d:%d ", |
c66ac9db8 [SCSI] target: Ad... |
425 426 427 428 429 430 431 432 433 434 435 |
sh->host_no, sd->channel, sd->id, sd->lun); spin_unlock_irq(sh->host_lock); return NULL; } spin_unlock_irq(sh->host_lock); /* * Claim exclusive struct block_device access to struct scsi_device * for TYPE_DISK using supplied udev_path */ bd = blkdev_get_by_path(se_dev->se_dev_udev_path, FMODE_WRITE|FMODE_READ|FMODE_EXCL, pdv); |
3ae279d25 [SCSI] target: ib... |
436 |
if (IS_ERR(bd)) { |
6708bb27b target: Follow up... |
437 438 |
pr_err("pSCSI: blkdev_get_by_path() failed "); |
c66ac9db8 [SCSI] target: Ad... |
439 440 441 442 443 444 |
scsi_device_put(sd); return NULL; } pdv->pdv_bd = bd; dev = pscsi_add_device_to_list(hba, se_dev, pdv, sd, dev_flags); |
6708bb27b target: Follow up... |
445 |
if (!dev) { |
c66ac9db8 [SCSI] target: Ad... |
446 447 448 449 |
blkdev_put(pdv->pdv_bd, FMODE_WRITE|FMODE_READ|FMODE_EXCL); scsi_device_put(sd); return NULL; } |
6708bb27b target: Follow up... |
450 451 |
pr_debug("CORE_PSCSI[%d] - Added TYPE_DISK for %d:%d:%d:%d ", |
c66ac9db8 [SCSI] target: Ad... |
452 453 454 455 456 457 458 459 460 461 462 463 464 |
phv->phv_host_id, sh->host_no, sd->channel, sd->id, sd->lun); return dev; } /* * Called with struct Scsi_Host->host_lock called. */ static struct se_device *pscsi_create_type_rom( struct scsi_device *sd, struct pscsi_dev_virt *pdv, struct se_subsystem_dev *se_dev, struct se_hba *hba) |
5dd7ed2e8 [SCSI] target: Mi... |
465 |
__releases(sh->host_lock) |
c66ac9db8 [SCSI] target: Ad... |
466 467 468 469 470 471 472 |
{ struct se_device *dev; struct pscsi_hba_virt *phv = (struct pscsi_hba_virt *)pdv->pdv_se_hba->hba_ptr; struct Scsi_Host *sh = sd->host; u32 dev_flags = 0; if (scsi_device_get(sd)) { |
6708bb27b target: Follow up... |
473 474 |
pr_err("scsi_device_get() failed for %d:%d:%d:%d ", |
c66ac9db8 [SCSI] target: Ad... |
475 476 477 478 479 480 481 |
sh->host_no, sd->channel, sd->id, sd->lun); spin_unlock_irq(sh->host_lock); return NULL; } spin_unlock_irq(sh->host_lock); dev = pscsi_add_device_to_list(hba, se_dev, pdv, sd, dev_flags); |
6708bb27b target: Follow up... |
482 |
if (!dev) { |
c66ac9db8 [SCSI] target: Ad... |
483 484 485 |
scsi_device_put(sd); return NULL; } |
6708bb27b target: Follow up... |
486 487 |
pr_debug("CORE_PSCSI[%d] - Added Type: %s for %d:%d:%d:%d ", |
c66ac9db8 [SCSI] target: Ad... |
488 489 490 491 492 493 494 495 496 497 498 499 500 501 |
phv->phv_host_id, scsi_device_type(sd->type), sh->host_no, sd->channel, sd->id, sd->lun); return dev; } /* *Called with struct Scsi_Host->host_lock called. */ static struct se_device *pscsi_create_type_other( struct scsi_device *sd, struct pscsi_dev_virt *pdv, struct se_subsystem_dev *se_dev, struct se_hba *hba) |
5dd7ed2e8 [SCSI] target: Mi... |
502 |
__releases(sh->host_lock) |
c66ac9db8 [SCSI] target: Ad... |
503 504 505 506 507 508 509 510 |
{ struct se_device *dev; struct pscsi_hba_virt *phv = (struct pscsi_hba_virt *)pdv->pdv_se_hba->hba_ptr; struct Scsi_Host *sh = sd->host; u32 dev_flags = 0; spin_unlock_irq(sh->host_lock); dev = pscsi_add_device_to_list(hba, se_dev, pdv, sd, dev_flags); |
6708bb27b target: Follow up... |
511 |
if (!dev) |
c66ac9db8 [SCSI] target: Ad... |
512 |
return NULL; |
6708bb27b target: Follow up... |
513 514 |
pr_debug("CORE_PSCSI[%d] - Added Type: %s for %d:%d:%d:%d ", |
c66ac9db8 [SCSI] target: Ad... |
515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 |
phv->phv_host_id, scsi_device_type(sd->type), sh->host_no, sd->channel, sd->id, sd->lun); return dev; } static struct se_device *pscsi_create_virtdevice( struct se_hba *hba, struct se_subsystem_dev *se_dev, void *p) { struct pscsi_dev_virt *pdv = (struct pscsi_dev_virt *)p; struct se_device *dev; struct scsi_device *sd; struct pscsi_hba_virt *phv = (struct pscsi_hba_virt *)hba->hba_ptr; struct Scsi_Host *sh = phv->phv_lld_host; int legacy_mode_enable = 0; |
6708bb27b target: Follow up... |
532 533 |
if (!pdv) { pr_err("Unable to locate struct pscsi_dev_virt" |
c66ac9db8 [SCSI] target: Ad... |
534 535 |
" parameter "); |
613640e4e [SCSI] target: Co... |
536 |
return ERR_PTR(-EINVAL); |
c66ac9db8 [SCSI] target: Ad... |
537 538 539 540 541 |
} /* * If not running in PHV_LLD_SCSI_HOST_NO mode, locate the * struct Scsi_Host we will need to bring the TCM/pSCSI object online */ |
6708bb27b target: Follow up... |
542 |
if (!sh) { |
c66ac9db8 [SCSI] target: Ad... |
543 |
if (phv->phv_mode == PHV_LLD_SCSI_HOST_NO) { |
6708bb27b target: Follow up... |
544 |
pr_err("pSCSI: Unable to locate struct" |
c66ac9db8 [SCSI] target: Ad... |
545 546 |
" Scsi_Host for PHV_LLD_SCSI_HOST_NO "); |
613640e4e [SCSI] target: Co... |
547 |
return ERR_PTR(-ENODEV); |
c66ac9db8 [SCSI] target: Ad... |
548 549 550 551 552 553 |
} /* * For the newer PHV_VIRUTAL_HOST_ID struct scsi_device * reference, we enforce that udev_path has been set */ if (!(se_dev->su_dev_flags & SDF_USING_UDEV_PATH)) { |
6708bb27b target: Follow up... |
554 |
pr_err("pSCSI: udev_path attribute has not" |
c66ac9db8 [SCSI] target: Ad... |
555 556 |
" been set before ENABLE=1 "); |
613640e4e [SCSI] target: Co... |
557 |
return ERR_PTR(-EINVAL); |
c66ac9db8 [SCSI] target: Ad... |
558 559 560 561 562 563 564 565 |
} /* * If no scsi_host_id= was passed for PHV_VIRUTAL_HOST_ID, * use the original TCM hba ID to reference Linux/SCSI Host No * and enable for PHV_LLD_SCSI_HOST_NO mode. */ if (!(pdv->pdv_flags & PDF_HAS_VIRT_HOST_ID)) { spin_lock(&hba->device_lock); |
6708bb27b target: Follow up... |
566 567 |
if (!list_empty(&hba->hba_dev_list)) { pr_err("pSCSI: Unable to set hba_mode" |
c66ac9db8 [SCSI] target: Ad... |
568 569 570 |
" with active devices "); spin_unlock(&hba->device_lock); |
613640e4e [SCSI] target: Co... |
571 |
return ERR_PTR(-EEXIST); |
c66ac9db8 [SCSI] target: Ad... |
572 573 574 575 |
} spin_unlock(&hba->device_lock); if (pscsi_pmode_enable_hba(hba, 1) != 1) |
613640e4e [SCSI] target: Co... |
576 |
return ERR_PTR(-ENODEV); |
c66ac9db8 [SCSI] target: Ad... |
577 578 579 580 581 |
legacy_mode_enable = 1; hba->hba_flags |= HBA_FLAGS_PSCSI_MODE; sh = phv->phv_lld_host; } else { |
e3d6f909e target: Core clea... |
582 583 |
sh = scsi_host_lookup(pdv->pdv_host_id); if (IS_ERR(sh)) { |
6708bb27b target: Follow up... |
584 |
pr_err("pSCSI: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
585 586 |
" pdv_host_id: %d ", pdv->pdv_host_id); |
942d82646 target: Make pscs... |
587 |
return ERR_CAST(sh); |
c66ac9db8 [SCSI] target: Ad... |
588 589 590 591 |
} } } else { if (phv->phv_mode == PHV_VIRUTAL_HOST_ID) { |
6708bb27b target: Follow up... |
592 |
pr_err("pSCSI: PHV_VIRUTAL_HOST_ID set while" |
c66ac9db8 [SCSI] target: Ad... |
593 594 |
" struct Scsi_Host exists "); |
613640e4e [SCSI] target: Co... |
595 |
return ERR_PTR(-EEXIST); |
c66ac9db8 [SCSI] target: Ad... |
596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 |
} } spin_lock_irq(sh->host_lock); list_for_each_entry(sd, &sh->__devices, siblings) { if ((pdv->pdv_channel_id != sd->channel) || (pdv->pdv_target_id != sd->id) || (pdv->pdv_lun_id != sd->lun)) continue; /* * Functions will release the held struct scsi_host->host_lock * before calling calling pscsi_add_device_to_list() to register * struct scsi_device with target_core_mod. */ switch (sd->type) { case TYPE_DISK: dev = pscsi_create_type_disk(sd, pdv, se_dev, hba); break; case TYPE_ROM: dev = pscsi_create_type_rom(sd, pdv, se_dev, hba); break; default: dev = pscsi_create_type_other(sd, pdv, se_dev, hba); break; } |
6708bb27b target: Follow up... |
621 |
if (!dev) { |
c66ac9db8 [SCSI] target: Ad... |
622 623 624 625 626 627 628 |
if (phv->phv_mode == PHV_VIRUTAL_HOST_ID) scsi_host_put(sh); else if (legacy_mode_enable) { pscsi_pmode_enable_hba(hba, 0); hba->hba_flags &= ~HBA_FLAGS_PSCSI_MODE; } pdv->pdv_sd = NULL; |
613640e4e [SCSI] target: Co... |
629 |
return ERR_PTR(-ENODEV); |
c66ac9db8 [SCSI] target: Ad... |
630 631 632 633 |
} return dev; } spin_unlock_irq(sh->host_lock); |
6708bb27b target: Follow up... |
634 635 |
pr_err("pSCSI: Unable to locate %d:%d:%d:%d ", sh->host_no, |
c66ac9db8 [SCSI] target: Ad... |
636 637 638 639 640 641 642 643 |
pdv->pdv_channel_id, pdv->pdv_target_id, pdv->pdv_lun_id); if (phv->phv_mode == PHV_VIRUTAL_HOST_ID) scsi_host_put(sh); else if (legacy_mode_enable) { pscsi_pmode_enable_hba(hba, 0); hba->hba_flags &= ~HBA_FLAGS_PSCSI_MODE; } |
613640e4e [SCSI] target: Co... |
644 |
return ERR_PTR(-ENODEV); |
c66ac9db8 [SCSI] target: Ad... |
645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 |
} /* pscsi_free_device(): (Part of se_subsystem_api_t template) * * */ static void pscsi_free_device(void *p) { struct pscsi_dev_virt *pdv = p; struct pscsi_hba_virt *phv = pdv->pdv_se_hba->hba_ptr; struct scsi_device *sd = pdv->pdv_sd; if (sd) { /* * Release exclusive pSCSI internal struct block_device claim for * struct scsi_device with TYPE_DISK from pscsi_create_type_disk() */ if ((sd->type == TYPE_DISK) && pdv->pdv_bd) { blkdev_put(pdv->pdv_bd, FMODE_WRITE|FMODE_READ|FMODE_EXCL); pdv->pdv_bd = NULL; } /* * For HBA mode PHV_LLD_SCSI_HOST_NO, release the reference * to struct Scsi_Host now. */ if ((phv->phv_mode == PHV_LLD_SCSI_HOST_NO) && (phv->phv_lld_host != NULL)) scsi_host_put(phv->phv_lld_host); if ((sd->type == TYPE_DISK) || (sd->type == TYPE_ROM)) scsi_device_put(sd); pdv->pdv_sd = NULL; } kfree(pdv); } static inline struct pscsi_plugin_task *PSCSI_TASK(struct se_task *task) { return container_of(task, struct pscsi_plugin_task, pscsi_task); } /* pscsi_transport_complete(): * * */ static int pscsi_transport_complete(struct se_task *task) { |
42bf829ee target: Cleanup u... |
696 |
struct pscsi_dev_virt *pdv = task->task_se_cmd->se_dev->dev_ptr; |
c66ac9db8 [SCSI] target: Ad... |
697 698 699 700 701 702 703 704 705 706 707 708 |
struct scsi_device *sd = pdv->pdv_sd; int result; struct pscsi_plugin_task *pt = PSCSI_TASK(task); unsigned char *cdb = &pt->pscsi_cdb[0]; result = pt->pscsi_result; /* * Hack to make sure that Write-Protect modepage is set if R/O mode is * forced. */ if (((cdb[0] == MODE_SENSE) || (cdb[0] == MODE_SENSE_10)) && (status_byte(result) << 1) == SAM_STAT_GOOD) { |
e3d6f909e target: Core clea... |
709 |
if (!task->task_se_cmd->se_deve) |
c66ac9db8 [SCSI] target: Ad... |
710 |
goto after_mode_sense; |
e3d6f909e target: Core clea... |
711 |
if (task->task_se_cmd->se_deve->lun_flags & |
c66ac9db8 [SCSI] target: Ad... |
712 |
TRANSPORT_LUNFLAGS_READ_ONLY) { |
05d1c7c0d target: Make all ... |
713 |
unsigned char *buf = transport_kmap_first_data_page(task->task_se_cmd); |
c66ac9db8 [SCSI] target: Ad... |
714 715 716 717 718 719 720 721 |
if (cdb[0] == MODE_SENSE_10) { if (!(buf[3] & 0x80)) buf[3] |= 0x80; } else { if (!(buf[2] & 0x80)) buf[2] |= 0x80; } |
05d1c7c0d target: Make all ... |
722 723 |
transport_kunmap_first_data_page(task->task_se_cmd); |
c66ac9db8 [SCSI] target: Ad... |
724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 |
} } after_mode_sense: if (sd->type != TYPE_TAPE) goto after_mode_select; /* * Hack to correctly obtain the initiator requested blocksize for * TYPE_TAPE. Since this value is dependent upon each tape media, * struct scsi_device->sector_size will not contain the correct value * by default, so we go ahead and set it so * TRANSPORT(dev)->get_blockdev() returns the correct value to the * storage engine. */ if (((cdb[0] == MODE_SELECT) || (cdb[0] == MODE_SELECT_10)) && (status_byte(result) << 1) == SAM_STAT_GOOD) { unsigned char *buf; struct scatterlist *sg = task->task_sg; u16 bdl; u32 blocksize; buf = sg_virt(&sg[0]); |
6708bb27b target: Follow up... |
747 748 749 |
if (!buf) { pr_err("Unable to get buf for scatterlist "); |
c66ac9db8 [SCSI] target: Ad... |
750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 |
goto after_mode_select; } if (cdb[0] == MODE_SELECT) bdl = (buf[3]); else bdl = (buf[6] << 8) | (buf[7]); if (!bdl) goto after_mode_select; if (cdb[0] == MODE_SELECT) blocksize = (buf[9] << 16) | (buf[10] << 8) | (buf[11]); else blocksize = (buf[13] << 16) | (buf[14] << 8) | (buf[15]); sd->sector_size = blocksize; } after_mode_select: if (status_byte(result) & CHECK_CONDITION) return 1; return 0; } static struct se_task * |
6708bb27b target: Follow up... |
779 |
pscsi_alloc_task(unsigned char *cdb) |
c66ac9db8 [SCSI] target: Ad... |
780 781 |
{ struct pscsi_plugin_task *pt; |
c66ac9db8 [SCSI] target: Ad... |
782 |
|
6708bb27b target: Follow up... |
783 784 785 786 787 |
/* * Dynamically alloc cdb space, since it may be larger than * TCM_MAX_COMMAND_SIZE */ pt = kzalloc(sizeof(*pt) + scsi_command_size(cdb), GFP_KERNEL); |
c66ac9db8 [SCSI] target: Ad... |
788 |
if (!pt) { |
6708bb27b target: Follow up... |
789 790 |
pr_err("Unable to allocate struct pscsi_plugin_task "); |
c66ac9db8 [SCSI] target: Ad... |
791 792 |
return NULL; } |
c66ac9db8 [SCSI] target: Ad... |
793 794 |
return &pt->pscsi_task; } |
c66ac9db8 [SCSI] target: Ad... |
795 796 797 |
static void pscsi_free_task(struct se_task *task) { struct pscsi_plugin_task *pt = PSCSI_TASK(task); |
c66ac9db8 [SCSI] target: Ad... |
798 799 |
/* |
c66ac9db8 [SCSI] target: Ad... |
800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 |
* We do not release the bio(s) here associated with this task, as * this is handled by bio_put() and pscsi_bi_endio(). */ kfree(pt); } enum { Opt_scsi_host_id, Opt_scsi_channel_id, Opt_scsi_target_id, Opt_scsi_lun_id, Opt_err }; static match_table_t tokens = { {Opt_scsi_host_id, "scsi_host_id=%d"}, {Opt_scsi_channel_id, "scsi_channel_id=%d"}, {Opt_scsi_target_id, "scsi_target_id=%d"}, {Opt_scsi_lun_id, "scsi_lun_id=%d"}, {Opt_err, NULL} }; static ssize_t pscsi_set_configfs_dev_params(struct se_hba *hba, struct se_subsystem_dev *se_dev, const char *page, ssize_t count) { struct pscsi_dev_virt *pdv = se_dev->se_dev_su_ptr; struct pscsi_hba_virt *phv = hba->hba_ptr; char *orig, *ptr, *opts; substring_t args[MAX_OPT_ARGS]; int ret = 0, arg, token; opts = kstrdup(page, GFP_KERNEL); if (!opts) return -ENOMEM; orig = opts; while ((ptr = strsep(&opts, ",")) != NULL) { if (!*ptr) continue; token = match_token(ptr, tokens, args); switch (token) { case Opt_scsi_host_id: if (phv->phv_mode == PHV_LLD_SCSI_HOST_NO) { |
6708bb27b target: Follow up... |
844 |
pr_err("PSCSI[%d]: Unable to accept" |
c66ac9db8 [SCSI] target: Ad... |
845 846 847 848 849 850 851 852 853 |
" scsi_host_id while phv_mode ==" " PHV_LLD_SCSI_HOST_NO ", phv->phv_host_id); ret = -EINVAL; goto out; } match_int(args, &arg); pdv->pdv_host_id = arg; |
6708bb27b target: Follow up... |
854 |
pr_debug("PSCSI[%d]: Referencing SCSI Host ID:" |
c66ac9db8 [SCSI] target: Ad... |
855 856 857 858 859 860 861 |
" %d ", phv->phv_host_id, pdv->pdv_host_id); pdv->pdv_flags |= PDF_HAS_VIRT_HOST_ID; break; case Opt_scsi_channel_id: match_int(args, &arg); pdv->pdv_channel_id = arg; |
6708bb27b target: Follow up... |
862 |
pr_debug("PSCSI[%d]: Referencing SCSI Channel" |
c66ac9db8 [SCSI] target: Ad... |
863 864 865 866 867 868 869 870 |
" ID: %d ", phv->phv_host_id, pdv->pdv_channel_id); pdv->pdv_flags |= PDF_HAS_CHANNEL_ID; break; case Opt_scsi_target_id: match_int(args, &arg); pdv->pdv_target_id = arg; |
6708bb27b target: Follow up... |
871 |
pr_debug("PSCSI[%d]: Referencing SCSI Target" |
c66ac9db8 [SCSI] target: Ad... |
872 873 874 875 876 877 878 879 |
" ID: %d ", phv->phv_host_id, pdv->pdv_target_id); pdv->pdv_flags |= PDF_HAS_TARGET_ID; break; case Opt_scsi_lun_id: match_int(args, &arg); pdv->pdv_lun_id = arg; |
6708bb27b target: Follow up... |
880 |
pr_debug("PSCSI[%d]: Referencing SCSI LUN ID:" |
c66ac9db8 [SCSI] target: Ad... |
881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 |
" %d ", phv->phv_host_id, pdv->pdv_lun_id); pdv->pdv_flags |= PDF_HAS_LUN_ID; break; default: break; } } out: kfree(orig); return (!ret) ? count : ret; } static ssize_t pscsi_check_configfs_dev_params( struct se_hba *hba, struct se_subsystem_dev *se_dev) { struct pscsi_dev_virt *pdv = se_dev->se_dev_su_ptr; if (!(pdv->pdv_flags & PDF_HAS_CHANNEL_ID) || !(pdv->pdv_flags & PDF_HAS_TARGET_ID) || !(pdv->pdv_flags & PDF_HAS_LUN_ID)) { |
6708bb27b target: Follow up... |
904 |
pr_err("Missing scsi_channel_id=, scsi_target_id= and" |
c66ac9db8 [SCSI] target: Ad... |
905 906 |
" scsi_lun_id= parameters "); |
e3d6f909e target: Core clea... |
907 |
return -EINVAL; |
c66ac9db8 [SCSI] target: Ad... |
908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 |
} return 0; } static ssize_t pscsi_show_configfs_dev_params(struct se_hba *hba, struct se_subsystem_dev *se_dev, char *b) { struct pscsi_hba_virt *phv = hba->hba_ptr; struct pscsi_dev_virt *pdv = se_dev->se_dev_su_ptr; struct scsi_device *sd = pdv->pdv_sd; unsigned char host_id[16]; ssize_t bl; int i; if (phv->phv_mode == PHV_VIRUTAL_HOST_ID) snprintf(host_id, 16, "%d", pdv->pdv_host_id); else snprintf(host_id, 16, "PHBA Mode"); bl = sprintf(b, "SCSI Device Bus Location:" " Channel ID: %d Target ID: %d LUN: %d Host ID: %s ", pdv->pdv_channel_id, pdv->pdv_target_id, pdv->pdv_lun_id, host_id); if (sd) { bl += sprintf(b + bl, " "); bl += sprintf(b + bl, "Vendor: "); for (i = 0; i < 8; i++) { if (ISPRINT(sd->vendor[i])) /* printable character? */ bl += sprintf(b + bl, "%c", sd->vendor[i]); else bl += sprintf(b + bl, " "); } bl += sprintf(b + bl, " Model: "); for (i = 0; i < 16; i++) { if (ISPRINT(sd->model[i])) /* printable character ? */ bl += sprintf(b + bl, "%c", sd->model[i]); else bl += sprintf(b + bl, " "); } bl += sprintf(b + bl, " Rev: "); for (i = 0; i < 4; i++) { if (ISPRINT(sd->rev[i])) /* printable character ? */ bl += sprintf(b + bl, "%c", sd->rev[i]); else bl += sprintf(b + bl, " "); } bl += sprintf(b + bl, " "); } return bl; } static void pscsi_bi_endio(struct bio *bio, int error) { bio_put(bio); } |
a1d8b49ab target: Updates f... |
968 |
static inline struct bio *pscsi_get_bio(int sg_num) |
c66ac9db8 [SCSI] target: Ad... |
969 970 971 972 973 974 975 |
{ struct bio *bio; /* * Use bio_malloc() following the comment in for bio -> struct request * in block/blk-core.c:blk_make_request() */ bio = bio_kmalloc(GFP_KERNEL, sg_num); |
6708bb27b target: Follow up... |
976 977 978 |
if (!bio) { pr_err("PSCSI: bio_kmalloc() failed "); |
c66ac9db8 [SCSI] target: Ad... |
979 980 981 982 983 984 |
return NULL; } bio->bi_end_io = pscsi_bi_endio; return bio; } |
02b1a7463 target: cleanup p... |
985 986 |
static int pscsi_map_sg(struct se_task *task, struct scatterlist *task_sg, struct bio **hbio) |
c66ac9db8 [SCSI] target: Ad... |
987 |
{ |
03e98c9eb target: Address l... |
988 |
struct se_cmd *cmd = task->task_se_cmd; |
42bf829ee target: Cleanup u... |
989 |
struct pscsi_dev_virt *pdv = task->task_se_cmd->se_dev->dev_ptr; |
02b1a7463 target: cleanup p... |
990 991 |
u32 task_sg_num = task->task_sg_nents; struct bio *bio = NULL, *tbio = NULL; |
c66ac9db8 [SCSI] target: Ad... |
992 993 994 995 996 |
struct page *page; struct scatterlist *sg; u32 data_len = task->task_size, i, len, bytes, off; int nr_pages = (task->task_size + task_sg[0].offset + PAGE_SIZE - 1) >> PAGE_SHIFT; |
03e98c9eb target: Address l... |
997 |
int nr_vecs = 0, rc; |
c66ac9db8 [SCSI] target: Ad... |
998 |
int rw = (task->task_data_direction == DMA_TO_DEVICE); |
02b1a7463 target: cleanup p... |
999 |
*hbio = NULL; |
6708bb27b target: Follow up... |
1000 1001 |
pr_debug("PSCSI: nr_pages: %d ", nr_pages); |
c66ac9db8 [SCSI] target: Ad... |
1002 1003 1004 1005 1006 |
for_each_sg(task_sg, sg, task_sg_num, i) { page = sg_page(sg); off = sg->offset; len = sg->length; |
6708bb27b target: Follow up... |
1007 1008 |
pr_debug("PSCSI: i: %d page: %p len: %d off: %d ", i, |
c66ac9db8 [SCSI] target: Ad... |
1009 1010 1011 1012 1013 |
page, len, off); while (len > 0 && data_len > 0) { bytes = min_t(unsigned int, len, PAGE_SIZE - off); bytes = min(bytes, data_len); |
6708bb27b target: Follow up... |
1014 |
if (!bio) { |
c66ac9db8 [SCSI] target: Ad... |
1015 1016 1017 1018 1019 |
nr_vecs = min_t(int, BIO_MAX_PAGES, nr_pages); nr_pages -= nr_vecs; /* * Calls bio_kmalloc() and sets bio->bi_end_io() */ |
a1d8b49ab target: Updates f... |
1020 |
bio = pscsi_get_bio(nr_vecs); |
6708bb27b target: Follow up... |
1021 |
if (!bio) |
c66ac9db8 [SCSI] target: Ad... |
1022 1023 1024 1025 |
goto fail; if (rw) bio->bi_rw |= REQ_WRITE; |
6708bb27b target: Follow up... |
1026 |
pr_debug("PSCSI: Allocated bio: %p," |
c66ac9db8 [SCSI] target: Ad... |
1027 1028 1029 1030 1031 1032 1033 1034 1035 |
" dir: %s nr_vecs: %d ", bio, (rw) ? "rw" : "r", nr_vecs); /* * Set *hbio pointer to handle the case: * nr_pages > BIO_MAX_PAGES, where additional * bios need to be added to complete a given * struct se_task */ |
02b1a7463 target: cleanup p... |
1036 1037 |
if (!*hbio) *hbio = tbio = bio; |
c66ac9db8 [SCSI] target: Ad... |
1038 1039 1040 |
else tbio = tbio->bi_next = bio; } |
6708bb27b target: Follow up... |
1041 |
pr_debug("PSCSI: Calling bio_add_pc_page() i: %d" |
c66ac9db8 [SCSI] target: Ad... |
1042 1043 1044 1045 1046 1047 1048 1049 |
" bio: %p page: %p len: %d off: %d ", i, bio, page, len, off); rc = bio_add_pc_page(pdv->pdv_sd->request_queue, bio, page, bytes, off); if (rc != bytes) goto fail; |
6708bb27b target: Follow up... |
1050 1051 |
pr_debug("PSCSI: bio->bi_vcnt: %d nr_vecs: %d ", |
c66ac9db8 [SCSI] target: Ad... |
1052 1053 1054 |
bio->bi_vcnt, nr_vecs); if (bio->bi_vcnt > nr_vecs) { |
6708bb27b target: Follow up... |
1055 |
pr_debug("PSCSI: Reached bio->bi_vcnt max:" |
c66ac9db8 [SCSI] target: Ad... |
1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 |
" %d i: %d bio: %p, allocating another" " bio ", bio->bi_vcnt, i, bio); /* * Clear the pointer so that another bio will * be allocated with pscsi_get_bio() above, the * current bio has already been set *tbio and * bio->bi_next. */ bio = NULL; } page++; len -= bytes; data_len -= bytes; off = 0; } } |
c66ac9db8 [SCSI] target: Ad... |
1074 |
|
6708bb27b target: Follow up... |
1075 |
return task->task_sg_nents; |
c66ac9db8 [SCSI] target: Ad... |
1076 |
fail: |
02b1a7463 target: cleanup p... |
1077 1078 1079 |
while (*hbio) { bio = *hbio; *hbio = (*hbio)->bi_next; |
c66ac9db8 [SCSI] target: Ad... |
1080 |
bio->bi_next = NULL; |
02b1a7463 target: cleanup p... |
1081 |
bio_endio(bio, 0); /* XXX: should be error */ |
c66ac9db8 [SCSI] target: Ad... |
1082 |
} |
03e98c9eb target: Address l... |
1083 1084 |
cmd->scsi_sense_reason = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; return -ENOMEM; |
c66ac9db8 [SCSI] target: Ad... |
1085 |
} |
02b1a7463 target: cleanup p... |
1086 |
static int pscsi_do_task(struct se_task *task) |
c66ac9db8 [SCSI] target: Ad... |
1087 |
{ |
03e98c9eb target: Address l... |
1088 |
struct se_cmd *cmd = task->task_se_cmd; |
42bf829ee target: Cleanup u... |
1089 |
struct pscsi_dev_virt *pdv = task->task_se_cmd->se_dev->dev_ptr; |
02b1a7463 target: cleanup p... |
1090 1091 1092 |
struct pscsi_plugin_task *pt = PSCSI_TASK(task); struct request *req; struct bio *hbio; |
c66ac9db8 [SCSI] target: Ad... |
1093 |
int ret; |
485fd0d1e target: replace -... |
1094 |
target_get_task_cdb(task, pt->pscsi_cdb); |
02b1a7463 target: cleanup p... |
1095 1096 1097 1098 1099 1100 1101 1102 |
if (task->task_se_cmd->se_cmd_flags & SCF_SCSI_NON_DATA_CDB) { req = blk_get_request(pdv->pdv_sd->request_queue, (task->task_data_direction == DMA_TO_DEVICE), GFP_KERNEL); if (!req || IS_ERR(req)) { pr_err("PSCSI: blk_get_request() failed: %ld ", req ? IS_ERR(req) : -ENOMEM); |
03e98c9eb target: Address l... |
1103 1104 1105 |
cmd->scsi_sense_reason = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; return -ENODEV; |
02b1a7463 target: cleanup p... |
1106 1107 1108 |
} } else { BUG_ON(!task->task_size); |
c66ac9db8 [SCSI] target: Ad... |
1109 |
|
c66ac9db8 [SCSI] target: Ad... |
1110 |
/* |
02b1a7463 target: cleanup p... |
1111 |
* Setup the main struct request for the task->task_sg[] payload |
c66ac9db8 [SCSI] target: Ad... |
1112 |
*/ |
02b1a7463 target: cleanup p... |
1113 |
ret = pscsi_map_sg(task, task->task_sg, &hbio); |
03e98c9eb target: Address l... |
1114 1115 1116 1117 1118 |
if (ret < 0) { cmd->scsi_sense_reason = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; return ret; } |
02b1a7463 target: cleanup p... |
1119 1120 1121 |
req = blk_make_request(pdv->pdv_sd->request_queue, hbio, GFP_KERNEL); |
ed327ed33 target/pscsi: blk... |
1122 |
if (IS_ERR(req)) { |
02b1a7463 target: cleanup p... |
1123 1124 1125 1126 |
pr_err("pSCSI: blk_make_request() failed "); goto fail; } |
c66ac9db8 [SCSI] target: Ad... |
1127 |
} |
02b1a7463 target: cleanup p... |
1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 |
req->cmd_type = REQ_TYPE_BLOCK_PC; req->end_io = pscsi_req_done; req->end_io_data = task; req->cmd_len = scsi_command_size(pt->pscsi_cdb); req->cmd = &pt->pscsi_cdb[0]; req->sense = &pt->pscsi_sense[0]; req->sense_len = 0; if (pdv->pdv_sd->type == TYPE_DISK) req->timeout = PS_TIMEOUT_DISK; else req->timeout = PS_TIMEOUT_OTHER; req->retries = PS_RETRY; |
c66ac9db8 [SCSI] target: Ad... |
1140 |
|
02b1a7463 target: cleanup p... |
1141 1142 1143 |
blk_execute_rq_nowait(pdv->pdv_sd->request_queue, NULL, req, (task->task_se_cmd->sam_task_attr == MSG_HEAD_TAG), pscsi_req_done); |
03e98c9eb target: Address l... |
1144 |
return 0; |
02b1a7463 target: cleanup p... |
1145 1146 1147 1148 1149 1150 1151 1152 |
fail: while (hbio) { struct bio *bio = hbio; hbio = hbio->bi_next; bio->bi_next = NULL; bio_endio(bio, 0); /* XXX: should be error */ } |
03e98c9eb target: Address l... |
1153 1154 |
cmd->scsi_sense_reason = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; return -ENOMEM; |
c66ac9db8 [SCSI] target: Ad... |
1155 |
} |
c66ac9db8 [SCSI] target: Ad... |
1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 |
/* pscsi_get_sense_buffer(): * * */ static unsigned char *pscsi_get_sense_buffer(struct se_task *task) { struct pscsi_plugin_task *pt = PSCSI_TASK(task); return (unsigned char *)&pt->pscsi_sense[0]; } /* pscsi_get_device_rev(): * * */ static u32 pscsi_get_device_rev(struct se_device *dev) { struct pscsi_dev_virt *pdv = dev->dev_ptr; struct scsi_device *sd = pdv->pdv_sd; return (sd->scsi_level - 1) ? sd->scsi_level - 1 : 1; } /* pscsi_get_device_type(): * * */ static u32 pscsi_get_device_type(struct se_device *dev) { struct pscsi_dev_virt *pdv = dev->dev_ptr; struct scsi_device *sd = pdv->pdv_sd; return sd->type; } static sector_t pscsi_get_blocks(struct se_device *dev) { struct pscsi_dev_virt *pdv = dev->dev_ptr; if (pdv->pdv_bd && pdv->pdv_bd->bd_part) return pdv->pdv_bd->bd_part->nr_sects; dump_stack(); return 0; } /* pscsi_handle_SAM_STATUS_failures(): * * */ static inline void pscsi_process_SAM_status( struct se_task *task, struct pscsi_plugin_task *pt) { task->task_scsi_status = status_byte(pt->pscsi_result); |
6708bb27b target: Follow up... |
1211 |
if (task->task_scsi_status) { |
c66ac9db8 [SCSI] target: Ad... |
1212 |
task->task_scsi_status <<= 1; |
6708bb27b target: Follow up... |
1213 |
pr_debug("PSCSI Status Byte exception at task: %p CDB:" |
c66ac9db8 [SCSI] target: Ad... |
1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 |
" 0x%02x Result: 0x%08x ", task, pt->pscsi_cdb[0], pt->pscsi_result); } switch (host_byte(pt->pscsi_result)) { case DID_OK: transport_complete_task(task, (!task->task_scsi_status)); break; default: |
6708bb27b target: Follow up... |
1224 |
pr_debug("PSCSI Host Byte exception at task: %p CDB:" |
c66ac9db8 [SCSI] target: Ad... |
1225 1226 1227 1228 |
" 0x%02x Result: 0x%08x ", task, pt->pscsi_cdb[0], pt->pscsi_result); task->task_scsi_status = SAM_STAT_CHECK_CONDITION; |
03e98c9eb target: Address l... |
1229 1230 |
task->task_se_cmd->scsi_sense_reason = TCM_UNSUPPORTED_SCSI_OPCODE; |
c66ac9db8 [SCSI] target: Ad... |
1231 1232 1233 |
transport_complete_task(task, 0); break; } |
c66ac9db8 [SCSI] target: Ad... |
1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 |
} static void pscsi_req_done(struct request *req, int uptodate) { struct se_task *task = req->end_io_data; struct pscsi_plugin_task *pt = PSCSI_TASK(task); pt->pscsi_result = req->errors; pt->pscsi_resid = req->resid_len; pscsi_process_SAM_status(task, pt); |
c66ac9db8 [SCSI] target: Ad... |
1245 |
__blk_put_request(req->q, req); |
c66ac9db8 [SCSI] target: Ad... |
1246 1247 1248 1249 1250 1251 |
} static struct se_subsystem_api pscsi_template = { .name = "pscsi", .owner = THIS_MODULE, .transport_type = TRANSPORT_PLUGIN_PHBA_PDEV, |
c66ac9db8 [SCSI] target: Ad... |
1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 |
.attach_hba = pscsi_attach_hba, .detach_hba = pscsi_detach_hba, .pmode_enable_hba = pscsi_pmode_enable_hba, .allocate_virtdevice = pscsi_allocate_virtdevice, .create_virtdevice = pscsi_create_virtdevice, .free_device = pscsi_free_device, .transport_complete = pscsi_transport_complete, .alloc_task = pscsi_alloc_task, .do_task = pscsi_do_task, .free_task = pscsi_free_task, .check_configfs_dev_params = pscsi_check_configfs_dev_params, .set_configfs_dev_params = pscsi_set_configfs_dev_params, .show_configfs_dev_params = pscsi_show_configfs_dev_params, |
c66ac9db8 [SCSI] target: Ad... |
1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 |
.get_sense_buffer = pscsi_get_sense_buffer, .get_device_rev = pscsi_get_device_rev, .get_device_type = pscsi_get_device_type, .get_blocks = pscsi_get_blocks, }; static int __init pscsi_module_init(void) { return transport_subsystem_register(&pscsi_template); } static void pscsi_module_exit(void) { transport_subsystem_release(&pscsi_template); } MODULE_DESCRIPTION("TCM PSCSI subsystem plugin"); MODULE_AUTHOR("nab@Linux-iSCSI.org"); MODULE_LICENSE("GPL"); module_init(pscsi_module_init); module_exit(pscsi_module_exit); |