2 * Copyright (c) 2008 Yahoo!, Inc.
4 * Written by: John Baldwin <jhb@FreeBSD.org>
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
9 * 1. Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * 2. Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * 3. Neither the name of the author nor the names of any co-contributors
15 * may be used to endorse or promote products derived from this software
16 * without specific prior written permission.
18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
19 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
22 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 #include <sys/cdefs.h>
34 #include <sys/param.h>
43 #include <cam/scsi/scsi_message.h>
44 #include <cam/scsi/scsi_pass.h>
55 xptfd = open(XPT_DEVICE, O_RDWR);
60 mpt_query_disk(U8 VolumeBus, U8 VolumeID, struct mpt_query_disk *qd)
62 struct bus_match_pattern *b;
63 struct periph_match_pattern *p;
64 struct periph_match_result *r;
69 /* mpt(4) only handles devices on bus 0. */
76 bzero(&ccb, sizeof(ccb));
78 ccb.ccb_h.func_code = XPT_DEV_MATCH;
79 ccb.ccb_h.path_id = CAM_XPT_PATH_ID;
80 ccb.ccb_h.target_id = CAM_TARGET_WILDCARD;
81 ccb.ccb_h.target_lun = CAM_LUN_WILDCARD;
83 bufsize = sizeof(struct dev_match_result) * 5;
84 ccb.cdm.num_matches = 0;
85 ccb.cdm.match_buf_len = bufsize;
86 ccb.cdm.matches = calloc(1, bufsize);
88 bufsize = sizeof(struct dev_match_pattern) * 2;
89 ccb.cdm.num_patterns = 2;
90 ccb.cdm.pattern_buf_len = bufsize;
91 ccb.cdm.patterns = calloc(1, bufsize);
93 /* Match mptX bus 0. */
94 ccb.cdm.patterns[0].type = DEV_MATCH_BUS;
95 b = &ccb.cdm.patterns[0].pattern.bus_pattern;
96 snprintf(b->dev_name, sizeof(b->dev_name), "mpt");
97 b->unit_number = mpt_unit;
99 b->flags = BUS_MATCH_NAME | BUS_MATCH_UNIT | BUS_MATCH_BUS_ID;
101 /* Look for a "da" device at the specified target and lun. */
102 ccb.cdm.patterns[1].type = DEV_MATCH_PERIPH;
103 p = &ccb.cdm.patterns[1].pattern.periph_pattern;
104 snprintf(p->periph_name, sizeof(p->periph_name), "da");
105 p->target_id = VolumeID;
106 p->flags = PERIPH_MATCH_NAME | PERIPH_MATCH_TARGET;
108 if (ioctl(xptfd, CAMIOCOMMAND, &ccb) < 0) {
110 free(ccb.cdm.matches);
111 free(ccb.cdm.patterns);
114 free(ccb.cdm.patterns);
116 if (((ccb.ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) ||
117 (ccb.cdm.status != CAM_DEV_MATCH_LAST)) {
118 warnx("mpt_query_disk got CAM error %#x, CDM error %d\n",
119 ccb.ccb_h.status, ccb.cdm.status);
120 free(ccb.cdm.matches);
125 * We should have exactly 2 matches, 1 for the bus and 1 for
126 * the peripheral. However, if we only have 1 match and it is
127 * for the bus, don't print an error message and return
130 if (ccb.cdm.num_matches == 1 &&
131 ccb.cdm.matches[0].type == DEV_MATCH_BUS) {
132 free(ccb.cdm.matches);
135 if (ccb.cdm.num_matches != 2) {
136 warnx("mpt_query_disk got %d matches, expected 2",
137 ccb.cdm.num_matches);
138 free(ccb.cdm.matches);
141 if (ccb.cdm.matches[0].type != DEV_MATCH_BUS ||
142 ccb.cdm.matches[1].type != DEV_MATCH_PERIPH) {
143 warnx("mpt_query_disk got wrong CAM matches");
144 free(ccb.cdm.matches);
148 /* Copy out the data. */
149 r = &ccb.cdm.matches[1].result.periph_result;
150 snprintf(qd->devname, sizeof(qd->devname), "%s%d", r->periph_name,
152 free(ccb.cdm.matches);
158 periph_is_volume(CONFIG_PAGE_IOC_2 *ioc2, struct periph_match_result *r)
160 CONFIG_PAGE_IOC_2_RAID_VOL *vol;
165 vol = ioc2->RaidVolume;
166 for (i = 0; i < ioc2->NumActiveVolumes; vol++, i++) {
167 if (vol->VolumeBus == 0 && vol->VolumeID == r->target_id)
173 /* Much borrowed from scsireadcapacity() in src/sbin/camcontrol/camcontrol.c. */
175 fetch_scsi_capacity(struct cam_device *dev, struct mpt_standalone_disk *disk)
177 struct scsi_read_capacity_data rcap;
178 struct scsi_read_capacity_data_long rcaplong;
182 ccb = cam_getccb(dev);
186 /* Zero the rest of the ccb. */
187 bzero(&(&ccb->ccb_h)[1], sizeof(struct ccb_scsiio) -
188 sizeof(struct ccb_hdr));
190 scsi_read_capacity(&ccb->csio, 1, NULL, MSG_SIMPLE_Q_TAG, &rcap,
191 SSD_FULL_SIZE, 5000);
193 /* Disable freezing the device queue */
194 ccb->ccb_h.flags |= CAM_DEV_QFRZDIS;
196 if (cam_send_ccb(dev, ccb) < 0) {
202 if ((ccb->ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
209 * A last block of 2^32-1 means that the true capacity is over 2TB,
210 * and we need to issue the long READ CAPACITY to get the real
211 * capacity. Otherwise, we're all set.
213 if (scsi_4btoul(rcap.addr) != 0xffffffff) {
214 disk->maxlba = scsi_4btoul(rcap.addr);
218 /* Zero the rest of the ccb. */
219 bzero(&(&ccb->ccb_h)[1], sizeof(struct ccb_scsiio) -
220 sizeof(struct ccb_hdr));
222 scsi_read_capacity_16(&ccb->csio, 1, NULL, MSG_SIMPLE_Q_TAG, 0, 0, 0,
223 &rcaplong, SSD_FULL_SIZE, 5000);
225 /* Disable freezing the device queue */
226 ccb->ccb_h.flags |= CAM_DEV_QFRZDIS;
228 if (cam_send_ccb(dev, ccb) < 0) {
234 if ((ccb->ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
240 disk->maxlba = scsi_8btou64(rcaplong.addr);
244 /* Borrowed heavily from scsi_all.c:scsi_print_inquiry(). */
246 format_scsi_inquiry(struct mpt_standalone_disk *disk,
247 struct scsi_inquiry_data *inq_data)
249 char vendor[16], product[48], revision[16], rstr[12];
251 if (SID_QUAL_IS_VENDOR_UNIQUE(inq_data))
253 if (SID_TYPE(inq_data) != T_DIRECT)
255 if (SID_QUAL(inq_data) != SID_QUAL_LU_CONNECTED)
258 cam_strvis(vendor, inq_data->vendor, sizeof(inq_data->vendor),
260 cam_strvis(product, inq_data->product, sizeof(inq_data->product),
262 cam_strvis(revision, inq_data->revision, sizeof(inq_data->revision),
265 /* Hack for SATA disks, no idea how to tell speed. */
266 if (strcmp(vendor, "ATA") == 0) {
267 snprintf(disk->inqstring, sizeof(disk->inqstring),
268 "<%s %s> SATA", product, revision);
272 switch (SID_ANSI_REV(inq_data)) {
274 strcpy(rstr, "SCSI-CCS");
280 snprintf(rstr, sizeof (rstr), "SCSI-%d",
281 SID_ANSI_REV(inq_data));
284 snprintf(disk->inqstring, sizeof(disk->inqstring), "<%s %s %s> %s",
285 vendor, product, revision, rstr);
288 /* Much borrowed from scsiinquiry() in src/sbin/camcontrol/camcontrol.c. */
290 fetch_scsi_inquiry(struct cam_device *dev, struct mpt_standalone_disk *disk)
292 struct scsi_inquiry_data *inq_buf;
296 ccb = cam_getccb(dev);
300 /* Zero the rest of the ccb. */
301 bzero(&(&ccb->ccb_h)[1], sizeof(struct ccb_scsiio) -
302 sizeof(struct ccb_hdr));
304 inq_buf = calloc(1, sizeof(*inq_buf));
305 if (inq_buf == NULL) {
309 scsi_inquiry(&ccb->csio, 1, NULL, MSG_SIMPLE_Q_TAG, (void *)inq_buf,
310 SHORT_INQUIRY_LENGTH, 0, 0, SSD_FULL_SIZE, 5000);
312 /* Disable freezing the device queue */
313 ccb->ccb_h.flags |= CAM_DEV_QFRZDIS;
315 if (cam_send_ccb(dev, ccb) < 0) {
322 if ((ccb->ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
329 format_scsi_inquiry(disk, inq_buf);
335 mpt_fetch_disks(int fd, int *ndisks, struct mpt_standalone_disk **disksp)
337 CONFIG_PAGE_IOC_2 *ioc2;
338 struct mpt_standalone_disk *disks;
339 struct bus_match_pattern *b;
340 struct periph_match_pattern *p;
341 struct periph_match_result *r;
342 struct cam_device *dev;
351 for (count = 100;; count+= 100) {
352 /* Try to fetch 'count' disks in one go. */
353 bzero(&ccb, sizeof(ccb));
355 ccb.ccb_h.func_code = XPT_DEV_MATCH;
357 bufsize = sizeof(struct dev_match_result) * (count + 2);
358 ccb.cdm.num_matches = 0;
359 ccb.cdm.match_buf_len = bufsize;
360 ccb.cdm.matches = calloc(1, bufsize);
362 bufsize = sizeof(struct dev_match_pattern) * 2;
363 ccb.cdm.num_patterns = 2;
364 ccb.cdm.pattern_buf_len = bufsize;
365 ccb.cdm.patterns = calloc(1, bufsize);
367 /* Match mptX bus 0. */
368 ccb.cdm.patterns[0].type = DEV_MATCH_BUS;
369 b = &ccb.cdm.patterns[0].pattern.bus_pattern;
370 snprintf(b->dev_name, sizeof(b->dev_name), "mpt");
371 b->unit_number = mpt_unit;
373 b->flags = BUS_MATCH_NAME | BUS_MATCH_UNIT | BUS_MATCH_BUS_ID;
375 /* Match any "da" peripherals. */
376 ccb.cdm.patterns[1].type = DEV_MATCH_PERIPH;
377 p = &ccb.cdm.patterns[1].pattern.periph_pattern;
378 snprintf(p->periph_name, sizeof(p->periph_name), "da");
379 p->flags = PERIPH_MATCH_NAME;
381 if (ioctl(xptfd, CAMIOCOMMAND, &ccb) < 0) {
383 free(ccb.cdm.matches);
384 free(ccb.cdm.patterns);
387 free(ccb.cdm.patterns);
389 /* Check for CCB errors. */
390 if ((ccb.ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
391 free(ccb.cdm.matches);
395 /* If we need a longer list, try again. */
396 if (ccb.cdm.status == CAM_DEV_MATCH_MORE) {
397 free(ccb.cdm.matches);
401 /* If we got an error, abort. */
402 if (ccb.cdm.status != CAM_DEV_MATCH_LAST) {
403 free(ccb.cdm.matches);
410 * We should have N + 1 matches, 1 for the bus and 1 for each
413 if (ccb.cdm.num_matches < 1) {
414 warnx("mpt_fetch_disks didn't get any matches");
415 free(ccb.cdm.matches);
418 if (ccb.cdm.matches[0].type != DEV_MATCH_BUS) {
419 warnx("mpt_fetch_disks got wrong CAM matches");
420 free(ccb.cdm.matches);
423 for (i = 1; i < ccb.cdm.num_matches; i++) {
424 if (ccb.cdm.matches[i].type != DEV_MATCH_PERIPH) {
425 warnx("mpt_fetch_disks got wrong CAM matches");
426 free(ccb.cdm.matches);
431 /* Shortcut if we don't have any "da" devices. */
432 if (ccb.cdm.num_matches == 1) {
433 free(ccb.cdm.matches);
440 * Some of the "da" peripherals may be for RAID volumes, so
441 * fetch the IOC 2 page (list of RAID volumes) so we can
442 * exclude them from the list.
444 ioc2 = mpt_read_ioc_page(fd, 2, NULL);
445 disks = calloc(ccb.cdm.num_matches, sizeof(*disks));
447 for (i = 1; i < ccb.cdm.num_matches; i++) {
448 r = &ccb.cdm.matches[i].result.periph_result;
449 if (periph_is_volume(ioc2, r))
451 disks[count].bus = 0;
452 disks[count].target = r->target_id;
453 snprintf(disks[count].devname, sizeof(disks[count].devname),
454 "%s%d", r->periph_name, r->unit_number);
456 dev = cam_open_device(disks[count].devname, O_RDWR);
458 fetch_scsi_capacity(dev, &disks[count]);
459 fetch_scsi_inquiry(dev, &disks[count]);
460 cam_close_device(dev);
464 free(ccb.cdm.matches);
473 * Instruct the mpt(4) device to rescan its busses to find new devices
474 * such as disks whose RAID physdisk page was removed or volumes that
475 * were created. If id is -1, the entire bus is rescanned.
476 * Otherwise, only devices at the specified ID are rescanned. If bus
477 * is -1, then all busses are scanned instead of the specified bus.
478 * Note that currently, only bus 0 is supported.
481 mpt_rescan_bus(int bus, int id)
483 struct bus_match_pattern *b;
488 /* mpt(4) only handles devices on bus 0. */
489 if (bus != -1 && bus != 0)
495 /* First, find the path id of bus 0 for this mpt controller. */
496 bzero(&ccb, sizeof(ccb));
498 ccb.ccb_h.func_code = XPT_DEV_MATCH;
500 bufsize = sizeof(struct dev_match_result) * 1;
501 ccb.cdm.num_matches = 0;
502 ccb.cdm.match_buf_len = bufsize;
503 ccb.cdm.matches = calloc(1, bufsize);
505 bufsize = sizeof(struct dev_match_pattern) * 1;
506 ccb.cdm.num_patterns = 1;
507 ccb.cdm.pattern_buf_len = bufsize;
508 ccb.cdm.patterns = calloc(1, bufsize);
510 /* Match mptX bus 0. */
511 ccb.cdm.patterns[0].type = DEV_MATCH_BUS;
512 b = &ccb.cdm.patterns[0].pattern.bus_pattern;
513 snprintf(b->dev_name, sizeof(b->dev_name), "mpt");
514 b->unit_number = mpt_unit;
516 b->flags = BUS_MATCH_NAME | BUS_MATCH_UNIT | BUS_MATCH_BUS_ID;
518 if (ioctl(xptfd, CAMIOCOMMAND, &ccb) < 0) {
519 free(ccb.cdm.matches);
520 free(ccb.cdm.patterns);
523 free(ccb.cdm.patterns);
525 if (((ccb.ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) ||
526 (ccb.cdm.status != CAM_DEV_MATCH_LAST)) {
527 warnx("mpt_rescan_bus got CAM error %#x, CDM error %d\n",
528 ccb.ccb_h.status, ccb.cdm.status);
529 free(ccb.cdm.matches);
533 /* We should have exactly 1 match for the bus. */
534 if (ccb.cdm.num_matches != 1 ||
535 ccb.cdm.matches[0].type != DEV_MATCH_BUS) {
536 free(ccb.cdm.matches);
539 path_id = ccb.cdm.matches[0].result.bus_result.path_id;
540 free(ccb.cdm.matches);
542 /* Now perform the actual rescan. */
543 ccb.ccb_h.path_id = path_id;
545 ccb.ccb_h.func_code = XPT_SCAN_BUS;
546 ccb.ccb_h.target_id = CAM_TARGET_WILDCARD;
547 ccb.ccb_h.target_lun = CAM_LUN_WILDCARD;
548 ccb.ccb_h.timeout = 5000;
550 ccb.ccb_h.func_code = XPT_SCAN_LUN;
551 ccb.ccb_h.target_id = id;
552 ccb.ccb_h.target_lun = 0;
554 ccb.crcn.flags = CAM_FLAG_NONE;
556 /* Run this at a low priority. */
557 ccb.ccb_h.pinfo.priority = 5;
559 if (ioctl(xptfd, CAMIOCOMMAND, &ccb) == -1)
562 if ((ccb.ccb_h.status & CAM_STATUS_MASK) != CAM_REQ_CMP) {
563 warnx("mpt_rescan_bus rescan got CAM error %#x\n",
564 ccb.ccb_h.status & CAM_STATUS_MASK);