vds.c revision 1ae0874509b6811fdde1dfd46f0d93fd09867a3f
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * CDDL HEADER START
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * The contents of this file are subject to the terms of the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Common Development and Distribution License (the "License").
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * You may not use this file except in compliance with the License.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * See the License for the specific language governing permissions
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * and limitations under the License.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * When distributing Covered Code, include this CDDL HEADER in each
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * If applicable, add the following below this CDDL HEADER, with the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * fields enclosed by brackets "[]" replaced with your own identifying
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * information: Portions Copyright [yyyy] [name of copyright owner]
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * CDDL HEADER END
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Copyright 2006 Sun Microsystems, Inc. All rights reserved.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Use is subject to license terms.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#pragma ident "%Z%%M% %I% %E% SMI"
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Virtual disk server
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Virtual disk server initialization flags */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Virtual disk server tunable parameters */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Identification parameters for MD, synthetic dkio(7i) structures, etc. */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Virtual disk initialization flags */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Flags for opening/closing backing devices via LDI */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * By Solaris convention, slice/partition 2 represents the entire disk;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * unfortunately, this convention does not appear to be codified.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Return a cpp token as a string */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Print a message prefixed with the current function name to the message log
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * (and optionally to the console for verbose boots); these macros use cpp's
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * concatenation of string literals and C99 variable-length-argument-list
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Return a pointer to the "i"th vdisk dring element */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#define VD_DRING_ELEM(i) ((vd_dring_entry_t *)(void *) \
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Return the virtual disk client's type as a string (for use in messages) */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (((vd)->xfer_mode == VIO_DESC_MODE) ? "in-band client" : \
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (((vd)->xfer_mode == VIO_DRING_MODE) ? "dring client" : \
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo "unsupported client")))
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* Debugging macros */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("dst:%x op:%x st:%u nb:%lx addr:%lx ncook:%u\n", \
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#else /* !DEBUG */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#define PR0(...)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#define PR1(...)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#define PR2(...)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#endif /* DEBUG */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppotypedef struct vds {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo uint_t initialized; /* driver inst initialization flags */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ldi_ident_t ldi_ident; /* driver's identifier for LDI */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo mod_hash_t *vd_table; /* table of virtual disks served */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppotypedef struct vd {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ldi_handle_t ldi_handle[V_NUMPAR]; /* LDI slice handles */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo struct dk_geom dk_geom; /* synthetic for slice type */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ldc_dring_handle_t dring_handle; /* handle for dring ops */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppotypedef struct vds_operation {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo int (*function)(vd_t *vd, vd_dring_payload_t *request);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppotypedef struct ioctl {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo const char *cmd_name;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppostatic void *vds_state;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppostatic uint64_t vds_operations; /* see vds_operation[] definition below */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#endif /* DEBUG */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PR1("Read %lu bytes at block %lu", request->nbytes, request->addr);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (EINVAL); /* no service for trivial requests */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_strategy(vd->ldi_handle[request->slice], &buf)) == 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status == 0) &&
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ((status = ldc_mem_copy(vd->ldc_handle, buf.b_un.b_addr, 0,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_copy() returned errno %d copying to client",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo kmem_free(buf.b_un.b_addr, buf.b_bcount); /* nbytes can change */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_do_bwrite(vd_t *vd, uint_t slice, diskaddr_t block, size_t nbytes,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ldc_mem_cookie_t *cookie, uint64_t ncookies, caddr_t data)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get data from client */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldc_mem_copy(vd->ldc_handle, data, 0, &nbytes,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_copy() returned errno %d copying from client",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_strategy(vd->ldi_handle[slice], &buf)) == 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PR1("Write %ld bytes at block %lu", request->nbytes, request->addr);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (EINVAL); /* no service for trivial requests */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo status = vd_do_bwrite(vd, request->slice, request->addr,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo request->nbytes, request->cookie, request->ncookies, data);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo switch (cmd) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_do_ioctl(vd_t *vd, vd_dring_payload_t *request, void* buf, ioctl_t *ioctl)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo size_t nbytes = request->nbytes; /* modifiable copy */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get data from client, if necessary */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldc_mem_copy(vd->ldc_handle, buf, 0, &nbytes,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Handle single-slice block devices internally; otherwise, have the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * real driver perform the ioctl()
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (vd->vdisk_type == VD_DISK_TYPE_SLICE && !vd->pseudo) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = vd_do_slice_ioctl(vd, ioctl->cmd, buf)) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo } else if ((status = ldi_ioctl(vd->ldi_handle[request->slice],
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ioctl->cmd, (intptr_t)buf, FKIOCTL, kcred, &rval)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PR0("ldi_ioctl(%s) = errno %d", ioctl->cmd_name, status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (rval != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("%s set rval = %d, which is not being returned to client",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#endif /* DEBUG */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Send data to client, if necessary */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldc_mem_copy(vd->ldc_handle, buf, 0, &nbytes,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#define RNDSIZE(expr) P2ROUNDUP(sizeof (expr), sizeof (uint64_t))
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Command (no-copy) operations */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_FLUSH, STRINGIZE(VD_OP_FLUSH), DKIOCFLUSHWRITECACHE,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* "Get" (copy-out) operations */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_GET_WCE, STRINGIZE(VD_OP_GET_WCE), DKIOCGETWCE,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_GET_DISKGEOM, STRINGIZE(VD_OP_GET_DISKGEOM), DKIOCGGEOM,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo STRINGIZE(DKIOCGGEOM), VD_COPYOUT, RNDSIZE(struct dk_geom)},
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_GET_VTOC, STRINGIZE(VD_OP_GET_VTOC), DKIOCGVTOC,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo STRINGIZE(DKIOCGVTOC), VD_COPYOUT, RNDSIZE(struct vtoc)},
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* "Set" (copy-in) operations */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_SET_WCE, STRINGIZE(VD_OP_SET_WCE), DKIOCSETWCE,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_SET_DISKGEOM, STRINGIZE(VD_OP_SET_DISKGEOM), DKIOCSGEOM,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo STRINGIZE(DKIOCSGEOM), VD_COPYIN, RNDSIZE(struct dk_geom)},
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo {VD_OP_SET_VTOC, STRINGIZE(VD_OP_SET_VTOC), DKIOCSVTOC,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo STRINGIZE(DKIOCSVTOC), VD_COPYIN, RNDSIZE(struct vtoc)},
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo size_t nioctls = (sizeof (ioctl))/(sizeof (ioctl[0]));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Determine ioctl corresponding to caller's "operation" and
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * validate caller's "nbytes"
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (i = 0; i < nioctls; i++) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo } else if ((request->nbytes % sizeof (uint64_t)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ASSERT(i < nioctls); /* because "operation" already validated */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Define the supported operations once the functions for performing them have
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * been defined
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Process a request using a defined operation
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_request(vd_t *vd, vd_dring_payload_t *request)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Range-check slice */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Perform the requested operation */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (i = 0; i < vds_noperations; i++)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* No matching operation found */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fhepposend_msg(ldc_handle_t ldc_handle, void *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (status != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Return 1 if the "type", "subtype", and "env" fields of the "tag" first
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * argument match the corresponding remaining arguments; otherwise, return 0
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_msgtype(vio_msg_tag_t *tag, int type, int subtype, int env)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_CTRL, VIO_SUBTYPE_INFO,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Unsupported version; send back supported version */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Valid message, version accepted */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_attr_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_CTRL, VIO_SUBTYPE_INFO,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Received maximum transfer size of 0 from client");
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Success: valid message and transfer mode */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * The vd_dring_inband_msg_t contains one cookie; need room
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * for up to n-1 more cookies, where "n" is the number of full
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * pages plus possibly one partial page required to cover
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * "max_xfer_sz". Add room for one more cookie if
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * "max_xfer_sz" isn't an integral multiple of the page size.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Must first get the maximum transfer size in bytes.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#else /* NEWOBP */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#endif /* NEWOBP */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Set the maximum expected message length to
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * accommodate in-band-descriptor messages with all
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * their cookies
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd->max_msglen = MAX(vd->max_msglen, max_inband_msglen);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_dring_reg_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vio_dring_reg_msg_t *reg_msg = (vio_dring_reg_msg_t *)msg;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_CTRL, VIO_SUBTYPE_INFO,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Expected at least %lu-byte register-dring message; "
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (reg_msg->ncookies - 1)*(sizeof (reg_msg->cookie[0]));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("A dring was previously registered; only support one");
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * In addition to fixing the assertion in the success case
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * below, supporting drings which require more than one
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * "cookie" requires increasing the value of vd->max_msglen
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * somewhere in the code path prior to receiving the message
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * which results in calling this function. Note that without
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * making this change, the larger message size required to
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * accommodate multiple cookies cannot be successfully
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * received, so this function will not even get called.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Gracefully accommodating more dring cookies might
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * reasonably demand exchanging an additional attribute or
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * making a minor protocol adjustment
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("reg_msg->ncookies = %u != 1", reg_msg->ncookies);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo status = ldc_mem_dring_map(vd->ldc_handle, reg_msg->cookie,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo reg_msg->descriptor_size, LDC_SHADOW_MAP, &vd->dring_handle);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (status != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * To remove the need for this assertion, must call
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * ldc_mem_dring_nextcookie() successfully ncookies-1 times after a
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * successful call to ldc_mem_dring_map()
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ldc_mem_dring_info(vd->dring_handle, &dring_minfo)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_dring_info() returned errno %d", status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldc_mem_dring_unmap(vd->dring_handle)) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_dring_unmap() returned errno %d", status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Valid message and dring mapped */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_dring_unreg_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vio_dring_unreg_msg_t *unreg_msg = (vio_dring_unreg_msg_t *)msg;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_CTRL, VIO_SUBTYPE_INFO,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (ENOMSG); /* not an unregister-dring message */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* FIXME set ack in unreg_msg? */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_CTRL, VIO_SUBTYPE_INFO, VIO_RDX))
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Expected %lu-byte RDX message; received %lu bytes",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ((status = ldc_mem_dring_unmap(vd->dring_handle)) != 0))
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_dring_unmap() returned errno %d", status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd->max_msglen = sizeof (vio_msg_t); /* baseline vio message size */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((vd->initialized & VD_SEQ_NUM) && (seq_num != vd->seq_num + 1)) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (1);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd->initialized |= VD_SEQ_NUM; /* superfluous after first time... */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Return the expected size of an inband-descriptor message with all the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * cookies it claims to include
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return ((sizeof (*msg)) +
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (msg->payload.ncookies - 1)*(sizeof (msg->payload.cookie[0])));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Process an in-band descriptor message: used with clients like OBP, with
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * which vds exchanges descriptors within VIO message payloads, rather than
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * operating on them within a descriptor ring
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_desc_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd_dring_inband_msg_t *desc_msg = (vd_dring_inband_msg_t *)msg;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_DATA, VIO_SUBTYPE_INFO,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (ENOMSG); /* not an in-band-descriptor message */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (msglen != (expected = expected_inband_size(desc_msg))) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (vd_check_seq_num(vd, desc_msg->hdr.seq_num) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Valid message; process the request */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo desc_msg->payload.status = vd_process_request(vd, &desc_msg->payload);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_accept_dring_elems(vd_t *vd, uint32_t start, uint32_t ndesc)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Check descriptor states */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (n = ndesc, i = start; n > 0; n--, i = (i + 1) % vd->dring_len) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Descriptors are valid; accept them */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (n = ndesc, i = start; n > 0; n--, i = (i + 1) % vd->dring_len)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_dring(vd_t *vd, uint32_t start, uint32_t end)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Validate descriptor range */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((start >= vd->dring_len) || (end >= vd->dring_len)) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("\"start\" = %u, \"end\" = %u; both must be less than %u",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Acquire updated dring elements */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_dring_acquire() returned errno %d", status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Accept updated dring elements */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ndesc = ((end < start) ? end + vd->dring_len : end) - start + 1;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Release dring elements */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldc_mem_dring_release() returned errno %d", status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* If a descriptor was in the wrong state, return an error */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Process accepted dring elements */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (n = ndesc, i = start; n > 0; n--, i = (i + 1) % vd->dring_len) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Process descriptor outside acquire/release bracket */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Re-acquire client's dring element */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo i, i)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Update processed element */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Perhaps client timed out waiting for I/O... */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Release updated processed element */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo i, i)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* If the descriptor was in the wrong state, return an error */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_dring_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!vd_msgtype(&msg->tag, VIO_TYPE_DATA, VIO_SUBTYPE_INFO,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Expected %lu-byte dring message; received %lu bytes",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Valid message; process dring */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (vd_process_dring(vd, dring_msg->start_idx, dring_msg->end_idx));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fhepporecv_msg(ldc_handle_t ldc_handle, void *msg, size_t *nbytes)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* FIXME work around interrupt problem */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (status != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo } else if (*nbytes == 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_do_process_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PR1("Processing (%x/%x/%x) message", msg->tag.vio_msgtype,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Validate session ID up front, since it applies to all messages
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((msg->tag.vio_sid != vd->sid) && (vd->initialized & VD_SID)) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Process the received message based on connection state
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* The first version message sets the SID */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Version negotiated, move to that state */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = vd_process_attr_msg(vd, msg, msglen)) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Attributes exchanged, move to that state */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Ready to receive in-band descriptors */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VIO_DRING_MODE: /* expect register-dring message */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* One dring negotiated, move to that state */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VD_STATE_DRING: /* expect RDX, register-dring, or unreg-dring */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Ready to receive data */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * If another register-dring message is received, stay in
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * dring state in case the client sends RDX; although the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * protocol allows multiple drings, this server does not
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * support using more than one
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Acknowledge an unregister-dring message, but reset the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * connection anyway: Although the protocol allows
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * unregistering drings, this server cannot serve a vdisk
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * without its only dring
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VIO_DESC_MODE: /* expect in-band-descriptor message */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VIO_DRING_MODE: /* expect dring-data or unreg-dring */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Typically expect dring-data messages, so handle
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * them first
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Acknowledge an unregister-dring message, but reset
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * the connection anyway: Although the protocol
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * allows unregistering drings, this server cannot
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * serve a vdisk without its only dring
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_process_msg(vd_t *vd, vio_msg_t *msg, size_t msglen)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Check that the message is at least big enough for a "tag", so that
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * message processing can proceed based on tag-specified message type
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Can't "nack" short message, so drop the big hammer */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Process the message
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo switch (status = vd_do_process_msg(vd, msg, msglen)) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* "ack" valid, successfully-processed messages */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* "nack" invalid messages */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* "nack" failed messages */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* An LDC error probably occurred, so try resetting it */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* "ack" or "nack" the message */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (msg->tag.vio_subtype == VIO_SUBTYPE_ACK) ? "ACK" : "NACK");
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Reset the connection for nack'ed or failed messages */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo max_msglen = vd->max_msglen; /* vd->maxmsglen can change */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd->enabled && recv_msg(vd->ldc_handle, vio_msg, &nbytes) == 0;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Queue a task to process the new data */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (ddi_taskq_dispatch(vd->taskq, vd_process_queue, vd, 0) !=
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Reset the connection state when channel comes (back) up */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_check_for_vd(mod_hash_key_t key, mod_hash_val_t *val, void *arg)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo switch (cmd) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* the real work happens below */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* nothing to do for this non-device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((vds = ddi_get_soft_state(vds_state, instance)) == NULL) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Do no detach when serving any vdisks */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo mod_hash_walk(vds->vd_table, vds_check_for_vd, &vd_present);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (parent = ddi_get_parent(dip); (parent != NULL) && (parent != root);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (strcmp(ddi_get_name(parent), DEVI_PSEUDO_NEXNAME) == 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovd_get_params(ldi_handle_t lh, char *block_device, vd_t *vd)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get block device's device number, otyp, and size */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Cannot serve non-block device %s", block_device);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (ldi_get_size(lh, &vd->vdisk_size) != DDI_SUCCESS) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Determine if backing block device is a pseudo device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((dip = ddi_hold_devi_by_instance(getmajor(vd->dev[0]),
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0); /* ...and we're done */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get dk_cinfo to determine slice of backing block device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_ioctl(lh, DKIOCINFO, (intptr_t)&dk_cinfo,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* If block device slice is entire disk, fill in all slice devices */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo minor_t minor = getminor(vd->dev[0]) - VD_ENTIRE_DISK_SLICE;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0); /* ...and we're done */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Otherwise, we have a (partial) slice of a block device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Initialize dk_geom structure for single-slice block device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_ioctl(lh, DKIOCGGEOM, (intptr_t)&vd->dk_geom,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("%s geometry claims 0 sectors per track", block_device);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo lbtodb(vd->vdisk_size)/vd->dk_geom.dkg_nsect/vd->dk_geom.dkg_nhead;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd->dk_geom.dkg_pcyl = vd->dk_geom.dkg_ncyl + vd->dk_geom.dkg_acyl;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Initialize vtoc structure for single-slice block device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_ioctl(lh, DKIOCGVTOC, (intptr_t)&vd->vtoc,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo MIN(sizeof (VD_VOLUME_NAME), sizeof (vd->vtoc.v_volume)));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo MIN(sizeof (VD_ASCIILABEL), sizeof (vd->vtoc.v_asciilabel)));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_do_init_vd(vds_t *vds, uint64_t id, char *block_device, uint64_t ldc_id,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((vd = kmem_zalloc(sizeof (*vd), KM_NOSLEEP)) == NULL) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo *vdp = vd; /* assign here so vds_destroy_vd() can cleanup later */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get device parameters */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_open_by_name(block_device, FREAD, kcred, &lh,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldi_open_by_name(%s) = errno %d", block_device, status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldi_close(%s) = errno %d", block_device, status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ((vd->vdisk_type == VD_DISK_TYPE_DISK) ? "disk" : "slice"),
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Initialize locking */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (ddi_get_soft_iblock_cookie(vds->dip, DDI_SOFTINT_MED,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Open the backing-device slices */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo getmajor(vd->dev[slice]), getminor(vd->dev[slice]), slice);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_open_by_dev(&vd->dev[slice], OTYP_BLK,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldi_open_by_dev() returned errno %d for slice %u",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* vds_destroy_vd() will close any open slices */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#if 0 /* FIXME */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Create the task queue for the vdisk */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) snprintf(tq_name, sizeof (tq_name), "vd%lu", id);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((vd->taskq = ddi_taskq_create(vds->dip, tq_name, 1,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vd->enabled = 1; /* before callback can dispatch to taskq */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Bring up LDC */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldc_init(ldc_id, &ldc_attr, &vd->ldc_handle)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldc_reg_callback(vd->ldc_handle, vd_handle_ldc_events,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Add the successfully-initialized vdisk to the server's table */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (mod_hash_insert(vds->vd_table, (mod_hash_key_t)id, vd) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Destroy the state associated with a virtual disk
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Disable queuing requests for the vdisk */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Drain and destroy the task queue (*before* shutting down LDC) */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo ddi_taskq_destroy(vd->taskq); /* waits for queued tasks */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Shut down LDC */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Close any open backing-device slices */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (uint_t slice = 0; slice < vd->nslices; slice++) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Free lock */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Finally, free the vdisk structure itself */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_init_vd(vds_t *vds, uint64_t id, char *block_device, uint64_t ldc_id)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#endif /* lint */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = vds_do_init_vd(vds, id, block_device, ldc_id, &vd)) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_do_get_ldc_id(md_t *md, mde_cookie_t vd_node, mde_cookie_t *channel,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Look for channel endpoint child(ren) of the vdisk MD node */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("No \"%s\" found for virtual disk", VD_CHANNEL_ENDPOINT);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (-1);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get the "id" value for the first channel endpoint node */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_val(md, channel[0], VD_ID_PROP, ldc_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (-1);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Using ID of first of multiple channels for this vdisk");
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_get_ldc_id(md_t *md, mde_cookie_t vd_node, uint64_t *ldc_id)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Invalid node count in Machine Description subtree");
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (-1);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo status = vds_do_get_ldc_id(md, vd_node, channel, ldc_id);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_val(md, vd_node, VD_ID_PROP, &id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_str(md, vd_node, VD_BLOCK_DEVICE_PROP,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Error getting vdisk \"%s\"", VD_BLOCK_DEVICE_PROP);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (vds_init_vd(vds, id, block_device, ldc_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_remove_vd(vds_t *vds, md_t *md, mde_cookie_t vd_node)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_val(md, vd_node, VD_ID_PROP, &id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Unable to get \"%s\" property from vdisk's MD node",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (mod_hash_destroy(vds->vd_table, (mod_hash_key_t)id) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovds_change_vd(vds_t *vds, md_t *prev_md, mde_cookie_t prev_vd_node,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Validate that vdisk ID has not changed */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_val(prev_md, prev_vd_node, VD_ID_PROP, &prev_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_val(curr_md, curr_vd_node, VD_ID_PROP, &curr_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Error getting current vdisk \"%s\" property", VD_ID_PROP);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Validate that LDC ID has not changed */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (vds_get_ldc_id(prev_md, prev_vd_node, &prev_ldc_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (vds_get_ldc_id(curr_md, curr_vd_node, &curr_ldc_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo "LDC ID changed from %lu to %lu", prev_ldc_id, curr_ldc_id);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Determine whether device path has changed */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_str(prev_md, prev_vd_node, VD_BLOCK_DEVICE_PROP,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (md_get_prop_str(curr_md, curr_vd_node, VD_BLOCK_DEVICE_PROP,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Error getting current vdisk \"%s\"", VD_BLOCK_DEVICE_PROP);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return; /* no relevant (supported) change */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Remove old state, which will close vdisk and reset */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (mod_hash_destroy(vds->vd_table, (mod_hash_key_t)prev_id) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Re-initialize vdisk with new state */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (vds_init_vd(vds, curr_id, curr_dev, curr_ldc_id) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vds_remove_vd(vds, md->removed.mdp, md->removed.mdep[i]);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vds_change_vd(vds, md->match_prev.mdp, md->match_prev.mdep[i],
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* MDEG specification for a (particular) vds node */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo static mdeg_node_spec_t vds_spec = {"virtual-device", vds_prop_spec};
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* MDEG specification for matching a vd node */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo static mdeg_node_match_t vd_spec = {"virtual-device-port",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * The "cfg-handle" property of a vds node in an MD contains the MD's
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * notion of "instance", or unique identifier, for that node; OBP
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * stores the value of the "cfg-handle" MD property as the value of
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * the "reg" property on the node in the device tree it builds from
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * the MD and passes to Solaris. Thus, we look up the devinfo node's
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * "reg" property value to uniquely identify this device instance when
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * registering with the MD event-generation framework. If the "reg"
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * property cannot be found, the device tree state is presumably so
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * broken that there is no point in continuing.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (!ddi_prop_exists(DDI_DEV_T_ANY, dip, DDI_PROP_DONTPASS, reg_prop)) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Get the MD instance for later MDEG registration */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo cfg_handle = ddi_prop_get_int(DDI_DEV_T_ANY, dip, DDI_PROP_DONTPASS,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (ddi_soft_state_zalloc(vds_state, instance) != DDI_SUCCESS) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("Could not allocate state for instance %u", instance);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((vds = ddi_get_soft_state(vds_state, instance)) == NULL) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vds->vd_table = mod_hash_create_ptrhash("vds_vd_table", VDS_NCHAINS,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo sizeof (void *));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ldi_ident_from_dip(dip, &vds->ldi_ident)) != 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo PRN("ldi_ident_from_dip() returned errno %d", status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Register for MD updates */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (mdeg_register(&vds_spec, &vd_spec, vds_process_md, vds,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo switch (cmd) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* nothing to do for this non-device */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo 0, /* devo_refcnt */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo "virtual disk server v%I%",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((status = ddi_soft_state_init(&vds_state, sizeof (vds_t), 1)) != 0)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* Fill in the bit-mask of server-supported operations */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (i = 0; i < vds_noperations; i++)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vds_operations |= 1 << (vds_operation[i].operation - 1);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (0);