aboutsummaryrefslogtreecommitdiff
path: root/sys/cam
diff options
context:
space:
mode:
authorAlexander Motin <mav@FreeBSD.org>2020-05-02 16:54:59 +0000
committerAlexander Motin <mav@FreeBSD.org>2020-05-02 16:54:59 +0000
commit34144c2c7153ceb7deb6732434aaf3de5522e7d0 (patch)
tree9fa9c4d93dc1488c494dd9304e3b2e4072bc22fd /sys/cam
parent41b23744320e2f661fb4fc5677038ddf337ca453 (diff)
downloadsrc-34144c2c7153ceb7deb6732434aaf3de5522e7d0.tar.gz
src-34144c2c7153ceb7deb6732434aaf3de5522e7d0.zip
Cleanup LUN addition/removal.
- Make ctl_add_lun() synchronous. Asynchronous addition was used by Copan's proprietary code long ago and never for upstream FreeBSD. - Move LUN enable/disable calls from backends to CTL core. - Serialize LUN modification and partially removal to avoid double frees. - Slightly unify backends code. MFC after: 2 weeks Sponsored by: iXsystems, Inc.
Notes
Notes: svn path=/head/; revision=360564
Diffstat (limited to 'sys/cam')
-rw-r--r--sys/cam/ctl/ctl.c190
-rw-r--r--sys/cam/ctl/ctl_backend.c1
-rw-r--r--sys/cam/ctl/ctl_backend.h30
-rw-r--r--sys/cam/ctl/ctl_backend_block.c230
-rw-r--r--sys/cam/ctl/ctl_backend_ramdisk.c216
-rw-r--r--sys/cam/ctl/ctl_private.h3
6 files changed, 185 insertions, 485 deletions
diff --git a/sys/cam/ctl/ctl.c b/sys/cam/ctl/ctl.c
index a3b662afc3f2..6649d6be176e 100644
--- a/sys/cam/ctl/ctl.c
+++ b/sys/cam/ctl/ctl.c
@@ -469,10 +469,9 @@ static void ctl_ioctl_fill_ooa(struct ctl_lun *lun, uint32_t *cur_fill_num,
struct ctl_ooa_entry *kern_entries);
static int ctl_ioctl(struct cdev *dev, u_long cmd, caddr_t addr, int flag,
struct thread *td);
-static int ctl_alloc_lun(struct ctl_softc *ctl_softc, struct ctl_lun *lun,
- struct ctl_be_lun *be_lun);
+static int ctl_enable_lun(struct ctl_lun *lun);
+static int ctl_disable_lun(struct ctl_lun *lun);
static int ctl_free_lun(struct ctl_lun *lun);
-static void ctl_create_lun(struct ctl_be_lun *be_lun);
static int ctl_do_mode_select(union ctl_io *io);
static int ctl_pro_preempt(struct ctl_softc *softc, struct ctl_lun *lun,
@@ -547,7 +546,6 @@ static int ctl_datamove_remote_xfer(union ctl_io *io, unsigned command,
static void ctl_datamove_remote_read(union ctl_io *io);
static void ctl_datamove_remote(union ctl_io *io);
static void ctl_process_done(union ctl_io *io);
-static void ctl_lun_thread(void *arg);
static void ctl_thresh_thread(void *arg);
static void ctl_work_thread(void *arg);
static void ctl_enqueue_incoming(union ctl_io *io);
@@ -1945,7 +1943,6 @@ ctl_init(void)
"HA link state (0 - offline, 1 - unknown, 2 - online)");
STAILQ_INIT(&softc->lun_list);
- STAILQ_INIT(&softc->pending_lun_queue);
STAILQ_INIT(&softc->fe_list);
STAILQ_INIT(&softc->port_list);
STAILQ_INIT(&softc->be_list);
@@ -1973,12 +1970,6 @@ ctl_init(void)
return (error);
}
}
- error = kproc_kthread_add(ctl_lun_thread, softc,
- &softc->ctl_proc, &softc->lun_thread, 0, 0, "ctl", "lun");
- if (error != 0) {
- printf("error creating CTL lun thread!\n");
- return (error);
- }
error = kproc_kthread_add(ctl_thresh_thread, softc,
&softc->ctl_proc, &softc->thresh_thread, 0, 0, "ctl", "thresh");
if (error != 0) {
@@ -2020,11 +2011,6 @@ ctl_shutdown(void)
}
mtx_destroy(&thr->queue_lock);
}
- while (softc->lun_thread != NULL) {
- wakeup(&softc->pending_lun_queue);
- if (softc->lun_thread != NULL)
- pause("CTL thr shutdown", 1);
- }
while (softc->thresh_thread != NULL) {
wakeup(softc->thresh_thread);
if (softc->thresh_thread != NULL)
@@ -4497,32 +4483,23 @@ hex2bin(const char *str, uint8_t *buf, int buf_size)
}
/*
- * LUN allocation.
- *
- * Requirements:
- * - caller allocates and zeros LUN storage, or passes in a NULL LUN if he
- * wants us to allocate the LUN and he can block.
- * - ctl_softc is always set
- * - be_lun is set if the LUN has a backend (needed for disk LUNs)
+ * Add LUN.
*
* Returns 0 for success, non-zero (errno) for failure.
*/
-static int
-ctl_alloc_lun(struct ctl_softc *ctl_softc, struct ctl_lun *ctl_lun,
- struct ctl_be_lun *const be_lun)
+int
+ctl_add_lun(struct ctl_be_lun *be_lun)
{
+ struct ctl_softc *ctl_softc = control_softc;
struct ctl_lun *nlun, *lun;
struct scsi_vpd_id_descriptor *desc;
struct scsi_vpd_id_t10 *t10id;
const char *eui, *naa, *scsiname, *uuid, *vendor, *value;
- int lun_number, lun_malloced;
+ int lun_number;
int devidlen, idlen1, idlen2 = 0, len;
- if (be_lun == NULL)
- return (EINVAL);
-
/*
- * We currently only support Direct Access or Processor LUN types.
+ * We support only Direct Access, CD-ROM or Processor LUN types.
*/
switch (be_lun->lun_type) {
case T_DIRECT:
@@ -4532,21 +4509,9 @@ ctl_alloc_lun(struct ctl_softc *ctl_softc, struct ctl_lun *ctl_lun,
case T_SEQUENTIAL:
case T_CHANGER:
default:
- be_lun->lun_config_status(be_lun->be_lun,
- CTL_LUN_CONFIG_FAILURE);
- break;
- }
- if (ctl_lun == NULL) {
- lun = malloc(sizeof(*lun), M_CTL, M_WAITOK);
- lun_malloced = 1;
- } else {
- lun_malloced = 0;
- lun = ctl_lun;
+ return (EINVAL);
}
-
- memset(lun, 0, sizeof(*lun));
- if (lun_malloced)
- lun->flags = CTL_LUN_MALLOCED;
+ lun = malloc(sizeof(*lun), M_CTL, M_WAITOK | M_ZERO);
lun->pending_sense = malloc(sizeof(struct scsi_sense_data *) *
ctl_max_ports, M_DEVBUF, M_WAITOK | M_ZERO);
@@ -4658,10 +4623,7 @@ ctl_alloc_lun(struct ctl_softc *ctl_softc, struct ctl_lun *ctl_lun,
}
fail:
free(lun->lun_devid, M_CTL);
- if (lun->flags & CTL_LUN_MALLOCED)
- free(lun, M_CTL);
- be_lun->lun_config_status(be_lun->be_lun,
- CTL_LUN_CONFIG_FAILURE);
+ free(lun, M_CTL);
return (ENOSPC);
}
lun_number = be_lun->req_lun_id;
@@ -4687,7 +4649,6 @@ fail:
lun->backend = be_lun->be;
be_lun->ctl_lun = lun;
be_lun->lun_id = lun_number;
- atomic_add_int(&be_lun->be->num_luns, 1);
if (be_lun->flags & CTL_LUN_FLAG_EJECTED)
lun->flags |= CTL_LUN_EJECTED;
if (be_lun->flags & CTL_LUN_FLAG_NO_MEDIA)
@@ -4743,15 +4704,27 @@ fail:
ctl_softc->num_luns++;
mtx_unlock(&ctl_softc->ctl_lock);
- lun->be_lun->lun_config_status(lun->be_lun->be_lun, CTL_LUN_CONFIG_OK);
+ /*
+ * We successfully added the LUN, attempt to enable it.
+ */
+ if (ctl_enable_lun(lun) != 0) {
+ printf("%s: ctl_enable_lun() failed!\n", __func__);
+ mtx_lock(&ctl_softc->ctl_lock);
+ STAILQ_REMOVE(&ctl_softc->lun_list, lun, ctl_lun, links);
+ ctl_clear_mask(ctl_softc->ctl_lun_mask, lun_number);
+ ctl_softc->ctl_luns[lun_number] = NULL;
+ ctl_softc->num_luns--;
+ mtx_unlock(&ctl_softc->ctl_lock);
+ free(lun->lun_devid, M_CTL);
+ free(lun, M_CTL);
+ return (EIO);
+ }
+
return (0);
}
/*
- * Delete a LUN.
- * Assumptions:
- * - LUN has already been marked invalid and any pending I/O has been taken
- * care of.
+ * Free LUN that has no active requests.
*/
static int
ctl_free_lun(struct ctl_lun *lun)
@@ -4778,7 +4751,6 @@ ctl_free_lun(struct ctl_lun *lun)
/*
* Tell the backend to free resources, if this LUN has a backend.
*/
- atomic_subtract_int(&lun->be_lun->be->num_luns, 1);
lun->be_lun->lun_shutdown(lun->be_lun->be_lun);
lun->ie_reportcnt = UINT32_MAX;
@@ -4794,57 +4766,24 @@ ctl_free_lun(struct ctl_lun *lun)
free(lun->pr_keys, M_DEVBUF);
free(lun->write_buffer, M_CTL);
free(lun->prevent, M_CTL);
- if (lun->flags & CTL_LUN_MALLOCED)
- free(lun, M_CTL);
+ free(lun, M_CTL);
return (0);
}
-static void
-ctl_create_lun(struct ctl_be_lun *be_lun)
-{
-
- /*
- * ctl_alloc_lun() should handle all potential failure cases.
- */
- ctl_alloc_lun(control_softc, NULL, be_lun);
-}
-
-int
-ctl_add_lun(struct ctl_be_lun *be_lun)
-{
- struct ctl_softc *softc = control_softc;
-
- mtx_lock(&softc->ctl_lock);
- STAILQ_INSERT_TAIL(&softc->pending_lun_queue, be_lun, links);
- mtx_unlock(&softc->ctl_lock);
- wakeup(&softc->pending_lun_queue);
-
- return (0);
-}
-
-int
-ctl_enable_lun(struct ctl_be_lun *be_lun)
+static int
+ctl_enable_lun(struct ctl_lun *lun)
{
struct ctl_softc *softc;
struct ctl_port *port, *nport;
- struct ctl_lun *lun;
int retval;
- lun = (struct ctl_lun *)be_lun->ctl_lun;
softc = lun->ctl_softc;
mtx_lock(&softc->ctl_lock);
mtx_lock(&lun->lun_lock);
- if ((lun->flags & CTL_LUN_DISABLED) == 0) {
- /*
- * eh? Why did we get called if the LUN is already
- * enabled?
- */
- mtx_unlock(&lun->lun_lock);
- mtx_unlock(&softc->ctl_lock);
- return (0);
- }
+ KASSERT((lun->flags & CTL_LUN_DISABLED) != 0,
+ ("%s: LUN not disabled", __func__));
lun->flags &= ~CTL_LUN_DISABLED;
mtx_unlock(&lun->lun_lock);
@@ -4875,24 +4814,19 @@ ctl_enable_lun(struct ctl_be_lun *be_lun)
return (0);
}
-int
-ctl_disable_lun(struct ctl_be_lun *be_lun)
+static int
+ctl_disable_lun(struct ctl_lun *lun)
{
struct ctl_softc *softc;
struct ctl_port *port;
- struct ctl_lun *lun;
int retval;
- lun = (struct ctl_lun *)be_lun->ctl_lun;
softc = lun->ctl_softc;
mtx_lock(&softc->ctl_lock);
mtx_lock(&lun->lun_lock);
- if (lun->flags & CTL_LUN_DISABLED) {
- mtx_unlock(&lun->lun_lock);
- mtx_unlock(&softc->ctl_lock);
- return (0);
- }
+ KASSERT((lun->flags & CTL_LUN_DISABLED) == 0,
+ ("%s: LUN not enabled", __func__));
lun->flags |= CTL_LUN_DISABLED;
mtx_unlock(&lun->lun_lock);
@@ -5023,25 +4957,22 @@ ctl_lun_secondary(struct ctl_be_lun *be_lun)
return (0);
}
+/*
+ * Remove LUN. If there are active requests, wait for completion.
+ *
+ * Returns 0 for success, non-zero (errno) for failure.
+ * Completion is reported to backed via the lun_shutdown() method.
+ */
int
-ctl_invalidate_lun(struct ctl_be_lun *be_lun)
+ctl_remove_lun(struct ctl_be_lun *be_lun)
{
struct ctl_lun *lun;
lun = (struct ctl_lun *)be_lun->ctl_lun;
- mtx_lock(&lun->lun_lock);
+ ctl_disable_lun(lun);
- /*
- * The LUN needs to be disabled before it can be marked invalid.
- */
- if ((lun->flags & CTL_LUN_DISABLED) == 0) {
- mtx_unlock(&lun->lun_lock);
- return (-1);
- }
- /*
- * Mark the LUN invalid.
- */
+ mtx_lock(&lun->lun_lock);
lun->flags |= CTL_LUN_INVALID;
/*
@@ -13404,35 +13335,6 @@ ctl_work_thread(void *arg)
}
static void
-ctl_lun_thread(void *arg)
-{
- struct ctl_softc *softc = (struct ctl_softc *)arg;
- struct ctl_be_lun *be_lun;
-
- CTL_DEBUG_PRINT(("ctl_lun_thread starting\n"));
- thread_lock(curthread);
- sched_prio(curthread, PUSER - 1);
- thread_unlock(curthread);
-
- while (!softc->shutdown) {
- mtx_lock(&softc->ctl_lock);
- be_lun = STAILQ_FIRST(&softc->pending_lun_queue);
- if (be_lun != NULL) {
- STAILQ_REMOVE_HEAD(&softc->pending_lun_queue, links);
- mtx_unlock(&softc->ctl_lock);
- ctl_create_lun(be_lun);
- continue;
- }
-
- /* Sleep until we have something to do. */
- mtx_sleep(&softc->pending_lun_queue, &softc->ctl_lock,
- PDROP, "-", 0);
- }
- softc->lun_thread = NULL;
- kthread_exit();
-}
-
-static void
ctl_thresh_thread(void *arg)
{
struct ctl_softc *softc = (struct ctl_softc *)arg;
diff --git a/sys/cam/ctl/ctl_backend.c b/sys/cam/ctl/ctl_backend.c
index 0a0645556636..71d4b001e6e6 100644
--- a/sys/cam/ctl/ctl_backend.c
+++ b/sys/cam/ctl/ctl_backend.c
@@ -83,7 +83,6 @@ ctl_backend_register(struct ctl_backend_driver *be)
#ifdef CS_BE_CONFIG_MOVE_DONE_IS_NOT_USED
be->config_move_done = ctl_config_move_done;
#endif
- be->num_luns = 0;
/* Call the backend's initialization routine. */
if (be->init != NULL) {
diff --git a/sys/cam/ctl/ctl_backend.h b/sys/cam/ctl/ctl_backend.h
index 587bb70a8b81..3abe2c8cf6cb 100644
--- a/sys/cam/ctl/ctl_backend.h
+++ b/sys/cam/ctl/ctl_backend.h
@@ -80,14 +80,7 @@ typedef enum {
MODULE_DEPEND(name, cam, 1, 1, 1)
-typedef enum {
- CTL_LUN_CONFIG_OK,
- CTL_LUN_CONFIG_FAILURE
-} ctl_lun_config_status;
-
typedef void (*be_callback_t)(void *be_lun);
-typedef void (*be_lun_config_t)(void *be_lun,
- ctl_lun_config_status status);
/*
* The lun_type field is the SCSI device type of this particular LUN. In
@@ -136,16 +129,11 @@ typedef void (*be_lun_config_t)(void *be_lun,
* should be padded with ASCII spaces. This field should NOT be NULL
* terminated.
*
- * The lun_shutdown() method is the callback for the ctl_invalidate_lun()
+ * The lun_shutdown() method is the callback for the ctl_remove_lun()
* call. It is called when all outstanding I/O for that LUN has been
* completed and CTL has deleted the resources for that LUN. When the CTL
* backend gets this call, it can safely free its per-LUN resources.
*
- * The lun_config_status() method is the callback for the ctl_add_lun()
- * call. It is called when the LUN is successfully added, or when LUN
- * addition fails. If the LUN is successfully added, the backend may call
- * the ctl_enable_lun() method to enable the LUN.
- *
* The be field is a pointer to the ctl_backend_driver structure, which
* contains the backend methods to be called by CTL.
*
@@ -173,7 +161,6 @@ struct ctl_be_lun {
uint8_t serial_num[CTL_SN_LEN]; /* passed to CTL */
uint8_t device_id[CTL_DEVID_LEN];/* passed to CTL */
be_callback_t lun_shutdown; /* passed to CTL */
- be_lun_config_t lun_config_status; /* passed to CTL */
struct ctl_backend_driver *be; /* passed to CTL */
void *ctl_lun; /* used by CTL */
nvlist_t *options; /* passed to CTL */
@@ -212,7 +199,6 @@ struct ctl_backend_driver {
#if 0
be_vfunc_t config_write_done; /* passed to backend */
#endif
- u_int num_luns; /* used by CTL */
STAILQ_ENTRY(ctl_backend_driver) links; /* used by CTL */
};
@@ -221,22 +207,16 @@ int ctl_backend_deregister(struct ctl_backend_driver *be);
struct ctl_backend_driver *ctl_backend_find(char *backend_name);
/*
- * To add a LUN, first call ctl_add_lun(). You will get the lun_config_status()
- * callback when the LUN addition has either succeeded or failed.
- *
- * Once you get that callback, you can then call ctl_enable_lun() to enable
- * the LUN.
+ * To add a LUN, call ctl_add_lun().
*/
int ctl_add_lun(struct ctl_be_lun *be_lun);
-int ctl_enable_lun(struct ctl_be_lun *be_lun);
/*
- * To delete a LUN, first call ctl_disable_lun(), then
- * ctl_invalidate_lun(). You will get the lun_shutdown() callback when all
+ * To remove a LUN, first call ctl_remove_lun().
+ * You will get the lun_shutdown() callback when all
* I/O to the LUN has completed and the LUN has been deleted.
*/
-int ctl_disable_lun(struct ctl_be_lun *be_lun);
-int ctl_invalidate_lun(struct ctl_be_lun *be_lun);
+int ctl_remove_lun(struct ctl_be_lun *be_lun);
/*
* To start a LUN (transition from powered off to powered on state) call
diff --git a/sys/cam/ctl/ctl_backend_block.c b/sys/cam/ctl/ctl_backend_block.c
index 6323c47271f5..4a2feb712443 100644
--- a/sys/cam/ctl/ctl_backend_block.c
+++ b/sys/cam/ctl/ctl_backend_block.c
@@ -80,6 +80,7 @@ __FBSDID("$FreeBSD$");
#include <sys/sysctl.h>
#include <sys/nv.h>
#include <sys/dnv.h>
+#include <sys/sx.h>
#include <geom/geom.h>
@@ -121,7 +122,6 @@ SDT_PROVIDER_DEFINE(cbb);
typedef enum {
CTL_BE_BLOCK_LUN_UNCONFIGURED = 0x01,
- CTL_BE_BLOCK_LUN_CONFIG_ERR = 0x02,
CTL_BE_BLOCK_LUN_WAITING = 0x04,
} ctl_be_block_lun_flags;
@@ -153,7 +153,6 @@ typedef uint64_t (*cbb_getattr_t)(struct ctl_be_block_lun *be_lun,
*/
struct ctl_be_block_lun {
struct ctl_lun_create_params params;
- char lunname[32];
char *dev_path;
ctl_be_block_type dev_type;
struct vnode *vn;
@@ -169,7 +168,7 @@ struct ctl_be_block_lun {
struct ctl_be_block_softc *softc;
struct devstat *disk_stats;
ctl_be_block_lun_flags flags;
- STAILQ_ENTRY(ctl_be_block_lun) links;
+ SLIST_ENTRY(ctl_be_block_lun) links;
struct ctl_be_lun cbe_lun;
struct taskqueue *io_taskqueue;
struct task io_task;
@@ -186,10 +185,11 @@ struct ctl_be_block_lun {
* Overall softc structure for the block backend module.
*/
struct ctl_be_block_softc {
+ struct sx modify_lock;
struct mtx lock;
uma_zone_t beio_zone;
int num_luns;
- STAILQ_HEAD(, ctl_be_block_lun) lun_list;
+ SLIST_HEAD(, ctl_be_block_lun) lun_list;
};
static struct ctl_be_block_softc backend_block_softc;
@@ -272,8 +272,6 @@ static int ctl_be_block_rm(struct ctl_be_block_softc *softc,
static int ctl_be_block_modify(struct ctl_be_block_softc *softc,
struct ctl_lun_req *req);
static void ctl_be_block_lun_shutdown(void *be_lun);
-static void ctl_be_block_lun_config_status(void *be_lun,
- ctl_lun_config_status status);
static int ctl_be_block_config_write(union ctl_io *io);
static int ctl_be_block_config_read(union ctl_io *io);
static int ctl_be_block_lun_info(void *be_lun, struct sbuf *sb);
@@ -296,7 +294,7 @@ static struct ctl_backend_driver ctl_be_block_driver =
.lun_attr = ctl_be_block_lun_attr
};
-MALLOC_DEFINE(M_CTLBLK, "ctlblk", "Memory used for CTL block backend");
+MALLOC_DEFINE(M_CTLBLK, "ctlblock", "Memory used for CTL block backend");
CTL_BACKEND_DECLARE(cbb, ctl_be_block_driver);
static struct ctl_be_block_io *
@@ -1761,13 +1759,10 @@ static int
ctl_be_block_ioctl(struct cdev *dev, u_long cmd, caddr_t addr,
int flag, struct thread *td)
{
- struct ctl_be_block_softc *softc;
+ struct ctl_be_block_softc *softc = &backend_block_softc;
int error;
- softc = &backend_block_softc;
-
error = 0;
-
switch (cmd) {
case CTL_LUN_REQ: {
struct ctl_lun_req *lun_req;
@@ -2230,11 +2225,10 @@ ctl_be_block_create(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
STAILQ_INIT(&be_lun->config_read_queue);
STAILQ_INIT(&be_lun->config_write_queue);
STAILQ_INIT(&be_lun->datamove_queue);
- sprintf(be_lun->lunname, "cblk%d", softc->num_luns);
- mtx_init(&be_lun->io_lock, "cblk io lock", NULL, MTX_DEF);
- mtx_init(&be_lun->queue_lock, "cblk queue lock", NULL, MTX_DEF);
+ mtx_init(&be_lun->io_lock, "ctlblock io", NULL, MTX_DEF);
+ mtx_init(&be_lun->queue_lock, "ctlblock queue", NULL, MTX_DEF);
cbe_lun->options = nvlist_clone(req->args_nvl);
- be_lun->lun_zone = uma_zcreate(be_lun->lunname, CTLBLK_MAX_SEG,
+ be_lun->lun_zone = uma_zcreate("ctlblock", CTLBLK_MAX_SEG,
NULL, NULL, NULL, NULL, /*align*/ 0, /*flags*/0);
if (be_lun->lun_zone == NULL) {
snprintf(req->error_str, sizeof(req->error_str),
@@ -2246,7 +2240,7 @@ ctl_be_block_create(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
cbe_lun->lun_type = params->device_type;
else
cbe_lun->lun_type = T_DIRECT;
- be_lun->flags = CTL_BE_BLOCK_LUN_UNCONFIGURED;
+ be_lun->flags = 0;
cbe_lun->flags = 0;
value = dnvlist_get_string(cbe_lun->options, "ha_role", NULL);
if (value != NULL) {
@@ -2311,7 +2305,6 @@ ctl_be_block_create(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
cbe_lun->req_lun_id = 0;
cbe_lun->lun_shutdown = ctl_be_block_lun_shutdown;
- cbe_lun->lun_config_status = ctl_be_block_lun_config_status;
cbe_lun->be = &ctl_be_block_driver;
if ((params->flags & CTL_LUN_FLAG_SERIAL_NUM) == 0) {
@@ -2344,7 +2337,7 @@ ctl_be_block_create(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
TASK_INIT(&be_lun->io_task, /*priority*/0, ctl_be_block_worker, be_lun);
- be_lun->io_taskqueue = taskqueue_create(be_lun->lunname, M_WAITOK,
+ be_lun->io_taskqueue = taskqueue_create("ctlblocktq", M_WAITOK,
taskqueue_thread_enqueue, /*context*/&be_lun->io_taskqueue);
if (be_lun->io_taskqueue == NULL) {
@@ -2371,27 +2364,15 @@ ctl_be_block_create(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
/*num threads*/num_threads,
/*priority*/PUSER,
/*proc*/control_softc->ctl_proc,
- /*thread name*/
- "%s taskq", be_lun->lunname);
+ /*thread name*/"block");
if (retval != 0)
goto bailout_error;
be_lun->num_threads = num_threads;
- mtx_lock(&softc->lock);
- softc->num_luns++;
- STAILQ_INSERT_TAIL(&softc->lun_list, be_lun, links);
-
- mtx_unlock(&softc->lock);
-
retval = ctl_add_lun(&be_lun->cbe_lun);
if (retval != 0) {
- mtx_lock(&softc->lock);
- STAILQ_REMOVE(&softc->lun_list, be_lun, ctl_be_block_lun,
- links);
- softc->num_luns--;
- mtx_unlock(&softc->lock);
snprintf(req->error_str, sizeof(req->error_str),
"ctl_add_lun() returned error %d, see dmesg for "
"details", retval);
@@ -2399,42 +2380,20 @@ ctl_be_block_create(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
goto bailout_error;
}
- mtx_lock(&softc->lock);
-
- /*
- * Tell the config_status routine that we're waiting so it won't
- * clean up the LUN in the event of an error.
- */
- be_lun->flags |= CTL_BE_BLOCK_LUN_WAITING;
-
- while (be_lun->flags & CTL_BE_BLOCK_LUN_UNCONFIGURED) {
- retval = msleep(be_lun, &softc->lock, PCATCH, "ctlblk", 0);
- if (retval == EINTR)
- break;
- }
- be_lun->flags &= ~CTL_BE_BLOCK_LUN_WAITING;
-
- if (be_lun->flags & CTL_BE_BLOCK_LUN_CONFIG_ERR) {
- snprintf(req->error_str, sizeof(req->error_str),
- "LUN configuration error, see dmesg for details");
- STAILQ_REMOVE(&softc->lun_list, be_lun, ctl_be_block_lun,
- links);
- softc->num_luns--;
- mtx_unlock(&softc->lock);
- goto bailout_error;
- } else {
- params->req_lun_id = cbe_lun->lun_id;
- }
-
- mtx_unlock(&softc->lock);
-
- be_lun->disk_stats = devstat_new_entry("cbb", params->req_lun_id,
+ be_lun->disk_stats = devstat_new_entry("cbb", cbe_lun->lun_id,
cbe_lun->blocksize,
DEVSTAT_ALL_SUPPORTED,
cbe_lun->lun_type
| DEVSTAT_TYPE_IF_OTHER,
DEVSTAT_PRIORITY_OTHER);
+ mtx_lock(&softc->lock);
+ softc->num_luns++;
+ SLIST_INSERT_HEAD(&softc->lun_list, be_lun, links);
+ mtx_unlock(&softc->lock);
+
+ params->req_lun_id = cbe_lun->lun_id;
+
return (retval);
bailout_error:
@@ -2465,12 +2424,18 @@ ctl_be_block_rm(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
params = &req->reqdata.rm;
+ sx_xlock(&softc->modify_lock);
mtx_lock(&softc->lock);
- STAILQ_FOREACH(be_lun, &softc->lun_list, links) {
- if (be_lun->cbe_lun.lun_id == params->lun_id)
+ SLIST_FOREACH(be_lun, &softc->lun_list, links) {
+ if (be_lun->cbe_lun.lun_id == params->lun_id) {
+ SLIST_REMOVE(&softc->lun_list, be_lun,
+ ctl_be_block_lun, links);
+ softc->num_luns--;
break;
+ }
}
mtx_unlock(&softc->lock);
+ sx_xunlock(&softc->modify_lock);
if (be_lun == NULL) {
snprintf(req->error_str, sizeof(req->error_str),
"LUN %u is not managed by the block backend",
@@ -2479,14 +2444,6 @@ ctl_be_block_rm(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
}
cbe_lun = &be_lun->cbe_lun;
- retval = ctl_disable_lun(cbe_lun);
- if (retval != 0) {
- snprintf(req->error_str, sizeof(req->error_str),
- "error %d returned from ctl_disable_lun() for "
- "LUN %d", retval, params->lun_id);
- goto bailout_error;
- }
-
if (be_lun->vn != NULL) {
cbe_lun->flags |= CTL_LUN_FLAG_NO_MEDIA;
ctl_lun_no_media(cbe_lun);
@@ -2494,49 +2451,36 @@ ctl_be_block_rm(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
ctl_be_block_close(be_lun);
}
- retval = ctl_invalidate_lun(cbe_lun);
+ mtx_lock(&softc->lock);
+ be_lun->flags |= CTL_BE_BLOCK_LUN_WAITING;
+ mtx_unlock(&softc->lock);
+
+ retval = ctl_remove_lun(cbe_lun);
if (retval != 0) {
snprintf(req->error_str, sizeof(req->error_str),
- "error %d returned from ctl_invalidate_lun() for "
+ "error %d returned from ctl_remove_lun() for "
"LUN %d", retval, params->lun_id);
+ mtx_lock(&softc->lock);
+ be_lun->flags &= ~CTL_BE_BLOCK_LUN_WAITING;
+ mtx_unlock(&softc->lock);
goto bailout_error;
}
mtx_lock(&softc->lock);
- be_lun->flags |= CTL_BE_BLOCK_LUN_WAITING;
while ((be_lun->flags & CTL_BE_BLOCK_LUN_UNCONFIGURED) == 0) {
- retval = msleep(be_lun, &softc->lock, PCATCH, "ctlblk", 0);
- if (retval == EINTR)
- break;
- }
+ retval = msleep(be_lun, &softc->lock, PCATCH, "ctlblockrm", 0);
+ if (retval == EINTR)
+ break;
+ }
be_lun->flags &= ~CTL_BE_BLOCK_LUN_WAITING;
-
- if ((be_lun->flags & CTL_BE_BLOCK_LUN_UNCONFIGURED) == 0) {
- snprintf(req->error_str, sizeof(req->error_str),
- "interrupted waiting for LUN to be freed");
+ if (be_lun->flags & CTL_BE_BLOCK_LUN_UNCONFIGURED) {
mtx_unlock(&softc->lock);
- goto bailout_error;
+ free(be_lun, M_CTLBLK);
+ } else {
+ mtx_unlock(&softc->lock);
+ return (EINTR);
}
- STAILQ_REMOVE(&softc->lun_list, be_lun, ctl_be_block_lun, links);
-
- softc->num_luns--;
- mtx_unlock(&softc->lock);
-
- taskqueue_drain_all(be_lun->io_taskqueue);
- taskqueue_free(be_lun->io_taskqueue);
-
- if (be_lun->disk_stats != NULL)
- devstat_remove_entry(be_lun->disk_stats);
-
- uma_zdestroy(be_lun->lun_zone);
-
- nvlist_destroy(cbe_lun->options);
- free(be_lun->dev_path, M_CTLBLK);
- mtx_destroy(&be_lun->queue_lock);
- mtx_destroy(&be_lun->io_lock);
- free(be_lun, M_CTLBLK);
-
req->status = CTL_LUN_OK;
return (0);
@@ -2557,8 +2501,9 @@ ctl_be_block_modify(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
params = &req->reqdata.modify;
+ sx_xlock(&softc->modify_lock);
mtx_lock(&softc->lock);
- STAILQ_FOREACH(be_lun, &softc->lun_list, links) {
+ SLIST_FOREACH(be_lun, &softc->lun_list, links) {
if (be_lun->cbe_lun.lun_id == params->lun_id)
break;
}
@@ -2635,66 +2580,41 @@ ctl_be_block_modify(struct ctl_be_block_softc *softc, struct ctl_lun_req *req)
/* Tell the user the exact size we ended up using */
params->lun_size_bytes = be_lun->size_bytes;
+ sx_xunlock(&softc->modify_lock);
req->status = error ? CTL_LUN_WARNING : CTL_LUN_OK;
return (0);
bailout_error:
+ sx_xunlock(&softc->modify_lock);
req->status = CTL_LUN_ERROR;
return (0);
}
static void
-ctl_be_block_lun_shutdown(void *be_lun)
-{
- struct ctl_be_block_lun *lun = be_lun;
- struct ctl_be_block_softc *softc = lun->softc;
-
- mtx_lock(&softc->lock);
- lun->flags |= CTL_BE_BLOCK_LUN_UNCONFIGURED;
- if (lun->flags & CTL_BE_BLOCK_LUN_WAITING)
- wakeup(lun);
- mtx_unlock(&softc->lock);
-}
-
-static void
-ctl_be_block_lun_config_status(void *be_lun, ctl_lun_config_status status)
+ctl_be_block_lun_shutdown(void *lun)
{
- struct ctl_be_block_lun *lun;
- struct ctl_be_block_softc *softc;
-
- lun = (struct ctl_be_block_lun *)be_lun;
- softc = lun->softc;
-
- if (status == CTL_LUN_CONFIG_OK) {
- mtx_lock(&softc->lock);
- lun->flags &= ~CTL_BE_BLOCK_LUN_UNCONFIGURED;
- if (lun->flags & CTL_BE_BLOCK_LUN_WAITING)
- wakeup(lun);
- mtx_unlock(&softc->lock);
-
- /*
- * We successfully added the LUN, attempt to enable it.
- */
- if (ctl_enable_lun(&lun->cbe_lun) != 0) {
- printf("%s: ctl_enable_lun() failed!\n", __func__);
- if (ctl_invalidate_lun(&lun->cbe_lun) != 0) {
- printf("%s: ctl_invalidate_lun() failed!\n",
- __func__);
- }
- }
-
- return;
- }
+ struct ctl_be_block_lun *be_lun = lun;
+ struct ctl_be_block_softc *softc = be_lun->softc;
+ taskqueue_drain_all(be_lun->io_taskqueue);
+ taskqueue_free(be_lun->io_taskqueue);
+ if (be_lun->disk_stats != NULL)
+ devstat_remove_entry(be_lun->disk_stats);
+ uma_zdestroy(be_lun->lun_zone);
+ nvlist_destroy(be_lun->cbe_lun.options);
+ free(be_lun->dev_path, M_CTLBLK);
+ mtx_destroy(&be_lun->queue_lock);
+ mtx_destroy(&be_lun->io_lock);
mtx_lock(&softc->lock);
- lun->flags &= ~CTL_BE_BLOCK_LUN_UNCONFIGURED;
- lun->flags |= CTL_BE_BLOCK_LUN_CONFIG_ERR;
- wakeup(lun);
+ be_lun->flags |= CTL_BE_BLOCK_LUN_UNCONFIGURED;
+ if (be_lun->flags & CTL_BE_BLOCK_LUN_WAITING)
+ wakeup(be_lun);
+ else
+ free(be_lun, M_CTLBLK);
mtx_unlock(&softc->lock);
}
-
static int
ctl_be_block_config_write(union ctl_io *io)
{
@@ -2858,10 +2778,11 @@ ctl_be_block_init(void)
{
struct ctl_be_block_softc *softc = &backend_block_softc;
+ sx_init(&softc->modify_lock, "ctlblock modify");
mtx_init(&softc->lock, "ctlblock", NULL, MTX_DEF);
softc->beio_zone = uma_zcreate("beio", sizeof(struct ctl_be_block_io),
NULL, NULL, NULL, NULL, UMA_ALIGN_PTR, 0);
- STAILQ_INIT(&softc->lun_list);
+ SLIST_INIT(&softc->lun_list);
return (0);
}
@@ -2870,23 +2791,24 @@ static int
ctl_be_block_shutdown(void)
{
struct ctl_be_block_softc *softc = &backend_block_softc;
- struct ctl_be_block_lun *lun, *next_lun;
+ struct ctl_be_block_lun *lun;
mtx_lock(&softc->lock);
- STAILQ_FOREACH_SAFE(lun, &softc->lun_list, links, next_lun) {
+ while ((lun = SLIST_FIRST(&softc->lun_list)) != NULL) {
+ SLIST_REMOVE_HEAD(&softc->lun_list, links);
+ softc->num_luns--;
/*
- * Drop our lock here. Since ctl_invalidate_lun() can call
+ * Drop our lock here. Since ctl_remove_lun() can call
* back into us, this could potentially lead to a recursive
* lock of the same mutex, which would cause a hang.
*/
mtx_unlock(&softc->lock);
- ctl_disable_lun(&lun->cbe_lun);
- ctl_invalidate_lun(&lun->cbe_lun);
+ ctl_remove_lun(&lun->cbe_lun);
mtx_lock(&softc->lock);
}
mtx_unlock(&softc->lock);
-
uma_zdestroy(softc->beio_zone);
mtx_destroy(&softc->lock);
+ sx_destroy(&softc->modify_lock);
return (0);
}
diff --git a/sys/cam/ctl/ctl_backend_ramdisk.c b/sys/cam/ctl/ctl_backend_ramdisk.c
index 52c983080a7e..96ab28d6381e 100644
--- a/sys/cam/ctl/ctl_backend_ramdisk.c
+++ b/sys/cam/ctl/ctl_backend_ramdisk.c
@@ -102,13 +102,11 @@ typedef enum {
typedef enum {
CTL_BE_RAMDISK_LUN_UNCONFIGURED = 0x01,
- CTL_BE_RAMDISK_LUN_CONFIG_ERR = 0x02,
CTL_BE_RAMDISK_LUN_WAITING = 0x04
} ctl_be_ramdisk_lun_flags;
struct ctl_be_ramdisk_lun {
struct ctl_lun_create_params params;
- char lunname[32];
int indir;
uint8_t **pages;
uint8_t *zero_page;
@@ -121,7 +119,7 @@ struct ctl_be_ramdisk_lun {
uint64_t cap_used;
struct ctl_be_ramdisk_softc *softc;
ctl_be_ramdisk_lun_flags flags;
- STAILQ_ENTRY(ctl_be_ramdisk_lun) links;
+ SLIST_ENTRY(ctl_be_ramdisk_lun) links;
struct ctl_be_lun cbe_lun;
struct taskqueue *io_taskqueue;
struct task io_task;
@@ -130,9 +128,10 @@ struct ctl_be_ramdisk_lun {
};
struct ctl_be_ramdisk_softc {
+ struct sx modify_lock;
struct mtx lock;
int num_luns;
- STAILQ_HEAD(, ctl_be_ramdisk_lun) lun_list;
+ SLIST_HEAD(, ctl_be_ramdisk_lun) lun_list;
};
static struct ctl_be_ramdisk_softc rd_softc;
@@ -157,8 +156,6 @@ static int ctl_backend_ramdisk_create(struct ctl_be_ramdisk_softc *softc,
static int ctl_backend_ramdisk_modify(struct ctl_be_ramdisk_softc *softc,
struct ctl_lun_req *req);
static void ctl_backend_ramdisk_lun_shutdown(void *be_lun);
-static void ctl_backend_ramdisk_lun_config_status(void *be_lun,
- ctl_lun_config_status status);
static struct ctl_backend_driver ctl_be_ramdisk_driver =
{
@@ -174,7 +171,7 @@ static struct ctl_backend_driver ctl_be_ramdisk_driver =
.lun_attr = ctl_backend_ramdisk_lun_attr,
};
-MALLOC_DEFINE(M_RAMDISK, "ramdisk", "Memory used for CTL RAMdisk");
+MALLOC_DEFINE(M_RAMDISK, "ctlramdisk", "Memory used for CTL RAMdisk");
CTL_BACKEND_DECLARE(cbr, ctl_be_ramdisk_driver);
static int
@@ -183,8 +180,9 @@ ctl_backend_ramdisk_init(void)
struct ctl_be_ramdisk_softc *softc = &rd_softc;
memset(softc, 0, sizeof(*softc));
- mtx_init(&softc->lock, "ctlramdisk", NULL, MTX_DEF);
- STAILQ_INIT(&softc->lun_list);
+ sx_init(&softc->modify_lock, "ctlrammod");
+ mtx_init(&softc->lock, "ctlram", NULL, MTX_DEF);
+ SLIST_INIT(&softc->lun_list);
return (0);
}
@@ -192,22 +190,24 @@ static int
ctl_backend_ramdisk_shutdown(void)
{
struct ctl_be_ramdisk_softc *softc = &rd_softc;
- struct ctl_be_ramdisk_lun *lun, *next_lun;
+ struct ctl_be_ramdisk_lun *lun;
mtx_lock(&softc->lock);
- STAILQ_FOREACH_SAFE(lun, &softc->lun_list, links, next_lun) {
+ while ((lun = SLIST_FIRST(&softc->lun_list)) != NULL) {
+ SLIST_REMOVE_HEAD(&softc->lun_list, links);
+ softc->num_luns--;
/*
- * Drop our lock here. Since ctl_invalidate_lun() can call
+ * Drop our lock here. Since ctl_remove_lun() can call
* back into us, this could potentially lead to a recursive
* lock of the same mutex, which would cause a hang.
*/
mtx_unlock(&softc->lock);
- ctl_disable_lun(&lun->cbe_lun);
- ctl_invalidate_lun(&lun->cbe_lun);
+ ctl_remove_lun(&lun->cbe_lun);
mtx_lock(&softc->lock);
}
mtx_unlock(&softc->lock);
mtx_destroy(&softc->lock);
+ sx_destroy(&softc->modify_lock);
return (0);
}
@@ -889,12 +889,18 @@ ctl_backend_ramdisk_rm(struct ctl_be_ramdisk_softc *softc,
int retval;
params = &req->reqdata.rm;
+ sx_xlock(&softc->modify_lock);
mtx_lock(&softc->lock);
- STAILQ_FOREACH(be_lun, &softc->lun_list, links) {
- if (be_lun->cbe_lun.lun_id == params->lun_id)
+ SLIST_FOREACH(be_lun, &softc->lun_list, links) {
+ if (be_lun->cbe_lun.lun_id == params->lun_id) {
+ SLIST_REMOVE(&softc->lun_list, be_lun,
+ ctl_be_ramdisk_lun, links);
+ softc->num_luns--;
break;
+ }
}
mtx_unlock(&softc->lock);
+ sx_xunlock(&softc->modify_lock);
if (be_lun == NULL) {
snprintf(req->error_str, sizeof(req->error_str),
"%s: LUN %u is not managed by the ramdisk backend",
@@ -902,14 +908,6 @@ ctl_backend_ramdisk_rm(struct ctl_be_ramdisk_softc *softc,
goto bailout_error;
}
- retval = ctl_disable_lun(&be_lun->cbe_lun);
- if (retval != 0) {
- snprintf(req->error_str, sizeof(req->error_str),
- "%s: error %d returned from ctl_disable_lun() for "
- "LUN %d", __func__, retval, params->lun_id);
- goto bailout_error;
- }
-
/*
* Set the waiting flag before we invalidate the LUN. Our shutdown
* routine can be called any time after we invalidate the LUN,
@@ -922,10 +920,10 @@ ctl_backend_ramdisk_rm(struct ctl_be_ramdisk_softc *softc,
be_lun->flags |= CTL_BE_RAMDISK_LUN_WAITING;
mtx_unlock(&softc->lock);
- retval = ctl_invalidate_lun(&be_lun->cbe_lun);
+ retval = ctl_remove_lun(&be_lun->cbe_lun);
if (retval != 0) {
snprintf(req->error_str, sizeof(req->error_str),
- "%s: error %d returned from ctl_invalidate_lun() for "
+ "%s: error %d returned from ctl_remove_lun() for "
"LUN %d", __func__, retval, params->lun_id);
mtx_lock(&softc->lock);
be_lun->flags &= ~CTL_BE_RAMDISK_LUN_WAITING;
@@ -935,35 +933,17 @@ ctl_backend_ramdisk_rm(struct ctl_be_ramdisk_softc *softc,
mtx_lock(&softc->lock);
while ((be_lun->flags & CTL_BE_RAMDISK_LUN_UNCONFIGURED) == 0) {
- retval = msleep(be_lun, &softc->lock, PCATCH, "ctlram", 0);
+ retval = msleep(be_lun, &softc->lock, PCATCH, "ctlramrm", 0);
if (retval == EINTR)
break;
}
be_lun->flags &= ~CTL_BE_RAMDISK_LUN_WAITING;
-
- /*
- * We only remove this LUN from the list and free it (below) if
- * retval == 0. If the user interrupted the wait, we just bail out
- * without actually freeing the LUN. We let the shutdown routine
- * free the LUN if that happens.
- */
- if (retval == 0) {
- STAILQ_REMOVE(&softc->lun_list, be_lun, ctl_be_ramdisk_lun,
- links);
- softc->num_luns--;
- }
-
- mtx_unlock(&softc->lock);
-
- if (retval == 0) {
- taskqueue_drain_all(be_lun->io_taskqueue);
- taskqueue_free(be_lun->io_taskqueue);
- nvlist_destroy(be_lun->cbe_lun.options);
- free(be_lun->zero_page, M_RAMDISK);
- ctl_backend_ramdisk_freeallpages(be_lun->pages, be_lun->indir);
- sx_destroy(&be_lun->page_lock);
- mtx_destroy(&be_lun->queue_lock);
+ if (be_lun->flags & CTL_BE_RAMDISK_LUN_UNCONFIGURED) {
+ mtx_unlock(&softc->lock);
free(be_lun, M_RAMDISK);
+ } else {
+ mtx_unlock(&softc->lock);
+ return (EINTR);
}
req->status = CTL_LUN_OK;
@@ -995,13 +975,12 @@ ctl_backend_ramdisk_create(struct ctl_be_ramdisk_softc *softc,
cbe_lun->options = nvlist_clone(req->args_nvl);
be_lun->params = req->reqdata.create;
be_lun->softc = softc;
- sprintf(be_lun->lunname, "cram%d", softc->num_luns);
if (params->flags & CTL_LUN_FLAG_DEV_TYPE)
cbe_lun->lun_type = params->device_type;
else
cbe_lun->lun_type = T_DIRECT;
- be_lun->flags = CTL_BE_RAMDISK_LUN_UNCONFIGURED;
+ be_lun->flags = 0;
cbe_lun->flags = 0;
value = dnvlist_get_string(cbe_lun->options, "ha_role", NULL);
if (value != NULL) {
@@ -1097,7 +1076,6 @@ ctl_backend_ramdisk_create(struct ctl_be_ramdisk_softc *softc,
cbe_lun->req_lun_id = 0;
cbe_lun->lun_shutdown = ctl_backend_ramdisk_lun_shutdown;
- cbe_lun->lun_config_status = ctl_backend_ramdisk_lun_config_status;
cbe_lun->be = &ctl_be_ramdisk_driver;
if ((params->flags & CTL_LUN_FLAG_SERIAL_NUM) == 0) {
snprintf(tmpstr, sizeof(tmpstr), "MYSERIAL%04d",
@@ -1128,18 +1106,18 @@ ctl_backend_ramdisk_create(struct ctl_be_ramdisk_softc *softc,
}
STAILQ_INIT(&be_lun->cont_queue);
- sx_init(&be_lun->page_lock, "cram page lock");
+ sx_init(&be_lun->page_lock, "ctlram page");
if (be_lun->cap_bytes == 0) {
be_lun->indir = 0;
be_lun->pages = malloc(be_lun->pblocksize, M_RAMDISK, M_WAITOK);
}
be_lun->zero_page = malloc(be_lun->pblocksize, M_RAMDISK,
M_WAITOK|M_ZERO);
- mtx_init(&be_lun->queue_lock, "cram queue lock", NULL, MTX_DEF);
+ mtx_init(&be_lun->queue_lock, "ctlram queue", NULL, MTX_DEF);
TASK_INIT(&be_lun->io_task, /*priority*/0, ctl_backend_ramdisk_worker,
be_lun);
- be_lun->io_taskqueue = taskqueue_create(be_lun->lunname, M_WAITOK,
+ be_lun->io_taskqueue = taskqueue_create("ctlramtq", M_WAITOK,
taskqueue_thread_enqueue, /*context*/&be_lun->io_taskqueue);
if (be_lun->io_taskqueue == NULL) {
snprintf(req->error_str, sizeof(req->error_str),
@@ -1151,23 +1129,12 @@ ctl_backend_ramdisk_create(struct ctl_be_ramdisk_softc *softc,
/*num threads*/1,
/*priority*/PUSER,
/*proc*/control_softc->ctl_proc,
- /*thread name*/
- "%s taskq", be_lun->lunname);
+ /*thread name*/"ramdisk");
if (retval != 0)
goto bailout_error;
- mtx_lock(&softc->lock);
- softc->num_luns++;
- STAILQ_INSERT_TAIL(&softc->lun_list, be_lun, links);
- mtx_unlock(&softc->lock);
-
retval = ctl_add_lun(&be_lun->cbe_lun);
if (retval != 0) {
- mtx_lock(&softc->lock);
- STAILQ_REMOVE(&softc->lun_list, be_lun, ctl_be_ramdisk_lun,
- links);
- softc->num_luns--;
- mtx_unlock(&softc->lock);
snprintf(req->error_str, sizeof(req->error_str),
"%s: ctl_add_lun() returned error %d, see dmesg for "
"details", __func__, retval);
@@ -1176,34 +1143,12 @@ ctl_backend_ramdisk_create(struct ctl_be_ramdisk_softc *softc,
}
mtx_lock(&softc->lock);
-
- /*
- * Tell the config_status routine that we're waiting so it won't
- * clean up the LUN in the event of an error.
- */
- be_lun->flags |= CTL_BE_RAMDISK_LUN_WAITING;
-
- while (be_lun->flags & CTL_BE_RAMDISK_LUN_UNCONFIGURED) {
- retval = msleep(be_lun, &softc->lock, PCATCH, "ctlram", 0);
- if (retval == EINTR)
- break;
- }
- be_lun->flags &= ~CTL_BE_RAMDISK_LUN_WAITING;
-
- if (be_lun->flags & CTL_BE_RAMDISK_LUN_CONFIG_ERR) {
- snprintf(req->error_str, sizeof(req->error_str),
- "%s: LUN configuration error, see dmesg for details",
- __func__);
- STAILQ_REMOVE(&softc->lun_list, be_lun, ctl_be_ramdisk_lun,
- links);
- softc->num_luns--;
- mtx_unlock(&softc->lock);
- goto bailout_error;
- } else {
- params->req_lun_id = cbe_lun->lun_id;
- }
+ softc->num_luns++;
+ SLIST_INSERT_HEAD(&softc->lun_list, be_lun, links);
mtx_unlock(&softc->lock);
+ params->req_lun_id = cbe_lun->lun_id;
+
req->status = CTL_LUN_OK;
return (retval);
@@ -1234,9 +1179,9 @@ ctl_backend_ramdisk_modify(struct ctl_be_ramdisk_softc *softc,
int wasprim;
params = &req->reqdata.modify;
-
+ sx_xlock(&softc->modify_lock);
mtx_lock(&softc->lock);
- STAILQ_FOREACH(be_lun, &softc->lun_list, links) {
+ SLIST_FOREACH(be_lun, &softc->lun_list, links) {
if (be_lun->cbe_lun.lun_id == params->lun_id)
break;
}
@@ -1290,80 +1235,35 @@ ctl_backend_ramdisk_modify(struct ctl_be_ramdisk_softc *softc,
/* Tell the user the exact size we ended up using */
params->lun_size_bytes = be_lun->size_bytes;
+ sx_xunlock(&softc->modify_lock);
req->status = CTL_LUN_OK;
return (0);
bailout_error:
+ sx_xunlock(&softc->modify_lock);
req->status = CTL_LUN_ERROR;
return (0);
}
static void
-ctl_backend_ramdisk_lun_shutdown(void *be_lun)
+ctl_backend_ramdisk_lun_shutdown(void *lun)
{
- struct ctl_be_ramdisk_lun *lun = be_lun;
- struct ctl_be_ramdisk_softc *softc = lun->softc;
-
- mtx_lock(&softc->lock);
- lun->flags |= CTL_BE_RAMDISK_LUN_UNCONFIGURED;
- if (lun->flags & CTL_BE_RAMDISK_LUN_WAITING) {
- wakeup(lun);
- } else {
- STAILQ_REMOVE(&softc->lun_list, lun, ctl_be_ramdisk_lun,
- links);
- softc->num_luns--;
- free(be_lun, M_RAMDISK);
- }
- mtx_unlock(&softc->lock);
-}
-
-static void
-ctl_backend_ramdisk_lun_config_status(void *be_lun,
- ctl_lun_config_status status)
-{
- struct ctl_be_ramdisk_lun *lun;
- struct ctl_be_ramdisk_softc *softc;
-
- lun = (struct ctl_be_ramdisk_lun *)be_lun;
- softc = lun->softc;
-
- if (status == CTL_LUN_CONFIG_OK) {
- mtx_lock(&softc->lock);
- lun->flags &= ~CTL_BE_RAMDISK_LUN_UNCONFIGURED;
- if (lun->flags & CTL_BE_RAMDISK_LUN_WAITING)
- wakeup(lun);
- mtx_unlock(&softc->lock);
-
- /*
- * We successfully added the LUN, attempt to enable it.
- */
- if (ctl_enable_lun(&lun->cbe_lun) != 0) {
- printf("%s: ctl_enable_lun() failed!\n", __func__);
- if (ctl_invalidate_lun(&lun->cbe_lun) != 0) {
- printf("%s: ctl_invalidate_lun() failed!\n",
- __func__);
- }
- }
-
- return;
- }
+ struct ctl_be_ramdisk_lun *be_lun = lun;
+ struct ctl_be_ramdisk_softc *softc = be_lun->softc;
+ taskqueue_drain_all(be_lun->io_taskqueue);
+ taskqueue_free(be_lun->io_taskqueue);
+ nvlist_destroy(be_lun->cbe_lun.options);
+ free(be_lun->zero_page, M_RAMDISK);
+ ctl_backend_ramdisk_freeallpages(be_lun->pages, be_lun->indir);
+ sx_destroy(&be_lun->page_lock);
+ mtx_destroy(&be_lun->queue_lock);
mtx_lock(&softc->lock);
- lun->flags &= ~CTL_BE_RAMDISK_LUN_UNCONFIGURED;
-
- /*
- * If we have a user waiting, let him handle the cleanup. If not,
- * clean things up here.
- */
- if (lun->flags & CTL_BE_RAMDISK_LUN_WAITING) {
- lun->flags |= CTL_BE_RAMDISK_LUN_CONFIG_ERR;
- wakeup(lun);
- } else {
- STAILQ_REMOVE(&softc->lun_list, lun, ctl_be_ramdisk_lun,
- links);
- softc->num_luns--;
- free(lun, M_RAMDISK);
- }
+ be_lun->flags |= CTL_BE_RAMDISK_LUN_UNCONFIGURED;
+ if (be_lun->flags & CTL_BE_RAMDISK_LUN_WAITING)
+ wakeup(be_lun);
+ else
+ free(be_lun, M_RAMDISK);
mtx_unlock(&softc->lock);
}
diff --git a/sys/cam/ctl/ctl_private.h b/sys/cam/ctl/ctl_private.h
index 6f3848dc0faa..5dd82d3032ac 100644
--- a/sys/cam/ctl/ctl_private.h
+++ b/sys/cam/ctl/ctl_private.h
@@ -147,7 +147,6 @@ typedef enum {
CTL_LUN_RESERVED = 0x002,
CTL_LUN_INVALID = 0x004,
CTL_LUN_DISABLED = 0x008,
- CTL_LUN_MALLOCED = 0x010,
CTL_LUN_STOPPED = 0x020,
CTL_LUN_NO_MEDIA = 0x040,
CTL_LUN_EJECTED = 0x080,
@@ -458,7 +457,6 @@ struct ctl_softc {
struct ctl_lun **ctl_luns;
uint32_t *ctl_port_mask;
STAILQ_HEAD(, ctl_lun) lun_list;
- STAILQ_HEAD(, ctl_be_lun) pending_lun_queue;
uint32_t num_frontends;
STAILQ_HEAD(, ctl_frontend) fe_list;
uint32_t num_ports;
@@ -470,7 +468,6 @@ struct ctl_softc {
uint32_t cur_pool_id;
int shutdown;
struct ctl_thread threads[CTL_MAX_THREADS];
- struct thread *lun_thread;
struct thread *thresh_thread;
TAILQ_HEAD(tpc_tokens, tpc_token) tpc_tokens;
struct callout tpc_timeout;