1 /* $NetBSD: dm_target.c,v 1.12 2010/01/04 00:14:41 haad Exp $ */
4 * Copyright (c) 2010-2011 Alex Hornung <alex@alexhornung.com>
5 * Copyright (c) 2008 The NetBSD Foundation, Inc.
8 * This code is derived from software contributed to The NetBSD Foundation
11 * Redistribution and use in source and binary forms, with or without
12 * modification, are permitted provided that the following conditions
14 * 1. Redistributions of source code Must retain the above copyright
15 * notice, this list of conditions and the following disclaimer.
16 * 2. Redistributions in binary form must reproduce the above copyright
17 * notice, this list of conditions and the following disclaimer in the
18 * documentation and/or other materials provided with the distribution.
20 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
21 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
22 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
23 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
24 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
25 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
26 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
27 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
28 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
29 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
30 * POSSIBILITY OF SUCH DAMAGE.
33 #include <sys/types.h>
34 #include <sys/malloc.h>
35 #include <sys/module.h>
36 #include <sys/linker.h>
37 #include <dev/disk/dm/dm.h>
39 #include "netbsd-dm.h"
41 static dm_target_t *dm_target_lookup_name(const char *);
43 static TAILQ_HEAD(, dm_target) dm_target_list;
45 static struct lock dm_target_mutex;
48 dm_target_busy(dm_target_t *target)
50 atomic_add_int(&target->ref_cnt, 1);
54 * Release reference counter on target.
57 dm_target_unbusy(dm_target_t *target)
59 KKASSERT(target->ref_cnt > 0);
60 atomic_subtract_int(&target->ref_cnt, 1);
64 * Try to autoload the module for the requested target.
67 dm_target_autoload(const char *dm_target_name)
71 linker_file_t linker_file;
74 ksnprintf(mod_name, sizeof(mod_name), "dm_target_%s", dm_target_name);
75 error = linker_reference_module(mod_name, NULL, &linker_file);
77 kprintf("dm: could not autoload module for target %s\n",
82 dmt = dm_target_lookup(dm_target_name);
84 linker_release_module(NULL, NULL, linker_file);
88 /* XXX: extra-big hack to allow users to kldunload the module */
89 linker_file->userrefs = 1;
95 * Lookup for target in global target list.
98 dm_target_lookup(const char *dm_target_name)
104 if (dm_target_name == NULL)
107 lockmgr(&dm_target_mutex, LK_EXCLUSIVE);
109 dmt = dm_target_lookup_name(dm_target_name);
113 lockmgr(&dm_target_mutex, LK_RELEASE);
119 * Search for name in TAILQ and return apropriate pointer.
122 dm_target_lookup_name(const char *dm_target_name)
124 dm_target_t *dm_target;
126 TAILQ_FOREACH(dm_target, &dm_target_list, dm_target_next) {
127 if (strcmp(dm_target_name, dm_target->name) == 0)
135 * Insert new target struct into the TAILQ.
136 * dm_target contains name, version, function pointer to specific target
140 dm_target_insert(dm_target_t *dm_target)
144 if (dm_target->init == NULL) {
145 kprintf("dm: %s missing init\n", dm_target->name);
148 if (dm_target->destroy == NULL) {
149 kprintf("dm: %s missing destroy\n", dm_target->name);
152 if (dm_target->strategy == NULL) {
153 kprintf("dm: %s missing strategy\n", dm_target->name);
157 lockmgr(&dm_target_mutex, LK_EXCLUSIVE);
159 dmt = dm_target_lookup_name(dm_target->name);
161 kprintf("uhoh, target_insert EEXIST\n");
162 lockmgr(&dm_target_mutex, LK_RELEASE);
165 TAILQ_INSERT_TAIL(&dm_target_list, dm_target, dm_target_next);
167 lockmgr(&dm_target_mutex, LK_RELEASE);
173 * Remove target from TAILQ, target is selected with it's name.
176 dm_target_remove(char *dm_target_name)
180 KKASSERT(dm_target_name != NULL);
182 lockmgr(&dm_target_mutex, LK_EXCLUSIVE);
184 dmt = dm_target_lookup_name(dm_target_name);
186 lockmgr(&dm_target_mutex, LK_RELEASE);
189 if (dmt->ref_cnt > 0) {
190 lockmgr(&dm_target_mutex, LK_RELEASE);
193 TAILQ_REMOVE(&dm_target_list, dmt, dm_target_next);
195 lockmgr(&dm_target_mutex, LK_RELEASE);
203 * Allocate new target entry.
206 dm_target_alloc(const char *name)
210 dmt = kmalloc(sizeof(*dmt), M_DM, M_WAITOK | M_ZERO);
215 strlcpy(dmt->name, name, sizeof(dmt->name));
221 dm_target_free(dm_target_t *dmt)
223 KKASSERT(dmt != NULL);
231 * Return prop_array of dm_target dictionaries.
234 dm_target_prop_list(void)
236 prop_array_t target_array, ver;
237 prop_dictionary_t target_dict;
238 dm_target_t *dm_target;
242 target_array = prop_array_create();
244 lockmgr(&dm_target_mutex, LK_EXCLUSIVE);
246 TAILQ_FOREACH(dm_target, &dm_target_list, dm_target_next) {
248 target_dict = prop_dictionary_create();
249 ver = prop_array_create();
250 prop_dictionary_set_cstring(target_dict, DM_TARGETS_NAME,
253 for (i = 0; i < 3; i++)
254 prop_array_add_uint32(ver, dm_target->version[i]);
256 prop_dictionary_set(target_dict, DM_TARGETS_VERSION, ver);
257 prop_array_add(target_array, target_dict);
259 prop_object_release(ver);
260 prop_object_release(target_dict);
263 lockmgr(&dm_target_mutex, LK_RELEASE);
269 * Initialize dm_target subsystem.
274 TAILQ_INIT(&dm_target_list); /* initialize global target list */
275 lockinit(&dm_target_mutex, "dmtrgt", 0, LK_CANRECURSE);
281 * Destroy all targets and remove them from queue.
282 * This routine is called from dmdestroy, before module
286 dm_target_uninit(void)
288 dm_target_t *dm_target;
290 lockmgr(&dm_target_mutex, LK_EXCLUSIVE);
292 while ((dm_target = TAILQ_FIRST(&dm_target_list)) != NULL) {
293 TAILQ_REMOVE(&dm_target_list, dm_target, dm_target_next);
294 dm_target_free(dm_target);
296 KKASSERT(TAILQ_EMPTY(&dm_target_list));
298 lockmgr(&dm_target_mutex, LK_RELEASE);
300 lockuninit(&dm_target_mutex);