xref: /netbsd-src/sys/dev/dm/dm_pdev.c (revision b1c86f5f087524e68db12794ee9c3e3da1ab17a0)
1 /*        $NetBSD: dm_pdev.c,v 1.6 2010/01/04 00:19:08 haad Exp $      */
2 
3 /*
4  * Copyright (c) 2008 The NetBSD Foundation, Inc.
5  * All rights reserved.
6  *
7  * This code is derived from software contributed to The NetBSD Foundation
8  * by Adam Hamsik.
9  *
10  * Redistribution and use in source and binary forms, with or without
11  * modification, are permitted provided that the following conditions
12  * are met:
13  * 1. Redistributions of source code must retain the above copyright
14  *    notice, this list of conditions and the following disclaimer.
15  * 2. Redistributions in binary form must reproduce the above copyright
16  *    notice, this list of conditions and the following disclaimer in the
17  *    documentation and/or other materials provided with the distribution.
18  *
19  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29  * POSSIBILITY OF SUCH DAMAGE.
30  */
31 
32 #include <sys/types.h>
33 #include <sys/param.h>
34 
35 #include <sys/disk.h>
36 #include <sys/fcntl.h>
37 #include <sys/kmem.h>
38 #include <sys/namei.h>
39 #include <sys/vnode.h>
40 
41 #include <dev/dkvar.h>
42 
43 #include "dm.h"
44 
45 SLIST_HEAD(dm_pdevs, dm_pdev) dm_pdev_list;
46 
47 	kmutex_t dm_pdev_mutex;
48 
49 	static dm_pdev_t *dm_pdev_alloc(const char *);
50 	static int dm_pdev_rem(dm_pdev_t *);
51 	static dm_pdev_t *dm_pdev_lookup_name(const char *);
52 
53 /*
54  * Find used pdev with name == dm_pdev_name.
55  */
56 	dm_pdev_t *
57 	          dm_pdev_lookup_name(const char *dm_pdev_name)
58 {
59 	dm_pdev_t *dm_pdev;
60 	int dlen;
61 	int slen;
62 
63 	KASSERT(dm_pdev_name != NULL);
64 
65 	slen = strlen(dm_pdev_name);
66 
67 	SLIST_FOREACH(dm_pdev, &dm_pdev_list, next_pdev) {
68 		dlen = strlen(dm_pdev->name);
69 
70 		if (slen != dlen)
71 			continue;
72 
73 		if (strncmp(dm_pdev_name, dm_pdev->name, slen) == 0)
74 			return dm_pdev;
75 	}
76 
77 	return NULL;
78 }
79 /*
80  * Create entry for device with name dev_name and open vnode for it.
81  * If entry already exists in global SLIST I will only increment
82  * reference counter.
83  */
84 dm_pdev_t *
85 dm_pdev_insert(const char *dev_name)
86 {
87 	dm_pdev_t *dmp;
88 	int error;
89 
90 	KASSERT(dev_name != NULL);
91 
92 	mutex_enter(&dm_pdev_mutex);
93 	dmp = dm_pdev_lookup_name(dev_name);
94 
95 	if (dmp != NULL) {
96 		dmp->ref_cnt++;
97 		aprint_debug("dmp_pdev_insert pdev %s already in tree\n", dev_name);
98 		mutex_exit(&dm_pdev_mutex);
99 		return dmp;
100 	}
101 	mutex_exit(&dm_pdev_mutex);
102 
103 	if ((dmp = dm_pdev_alloc(dev_name)) == NULL)
104 		return NULL;
105 
106 	error = dk_lookup(dev_name, curlwp, &dmp->pdev_vnode, UIO_SYSSPACE);
107 	if (error) {
108 		aprint_debug("dk_lookup on device: %s failed with error %d!\n",
109 		    dev_name, error);
110 		kmem_free(dmp, sizeof(dm_pdev_t));
111 		return NULL;
112 	}
113 	dmp->ref_cnt = 1;
114 
115 	mutex_enter(&dm_pdev_mutex);
116 	SLIST_INSERT_HEAD(&dm_pdev_list, dmp, next_pdev);
117 	mutex_exit(&dm_pdev_mutex);
118 
119 	return dmp;
120 }
121 /*
122  * Initialize pdev subsystem.
123  */
124 int
125 dm_pdev_init(void)
126 {
127 	SLIST_INIT(&dm_pdev_list);	/* initialize global pdev list */
128 	mutex_init(&dm_pdev_mutex, MUTEX_DEFAULT, IPL_NONE);
129 
130 	return 0;
131 }
132 /*
133  * Allocat new pdev structure if is not already present and
134  * set name.
135  */
136 static dm_pdev_t *
137 dm_pdev_alloc(const char *name)
138 {
139 	dm_pdev_t *dmp;
140 
141 	if ((dmp = kmem_zalloc(sizeof(dm_pdev_t), KM_SLEEP)) == NULL)
142 		return NULL;
143 
144 	strlcpy(dmp->name, name, MAX_DEV_NAME);
145 
146 	dmp->ref_cnt = 0;
147 	dmp->pdev_vnode = NULL;
148 
149 	return dmp;
150 }
151 /*
152  * Destroy allocated dm_pdev.
153  */
154 static int
155 dm_pdev_rem(dm_pdev_t * dmp)
156 {
157 	int err;
158 
159 	KASSERT(dmp != NULL);
160 
161 	if (dmp->pdev_vnode != NULL) {
162 		err = vn_close(dmp->pdev_vnode, FREAD | FWRITE, FSCRED);
163 		if (err != 0)
164 			return err;
165 	}
166 	kmem_free(dmp, sizeof(*dmp));
167 	dmp = NULL;
168 
169 	return 0;
170 }
171 /*
172  * Destroy all existing pdev's in device-mapper.
173  */
174 int
175 dm_pdev_destroy(void)
176 {
177 	dm_pdev_t *dm_pdev;
178 
179 	mutex_enter(&dm_pdev_mutex);
180 	while (!SLIST_EMPTY(&dm_pdev_list)) {	/* List Deletion. */
181 
182 		dm_pdev = SLIST_FIRST(&dm_pdev_list);
183 
184 		SLIST_REMOVE_HEAD(&dm_pdev_list, next_pdev);
185 
186 		dm_pdev_rem(dm_pdev);
187 	}
188 	mutex_exit(&dm_pdev_mutex);
189 
190 	mutex_destroy(&dm_pdev_mutex);
191 	return 0;
192 }
193 /*
194  * This funcion is called from dm_dev_remove_ioctl.
195  * When I'm removing device from list, I have to decrement
196  * reference counter. If reference counter is 0 I will remove
197  * dmp from global list and from device list to. And I will CLOSE
198  * dmp vnode too.
199  */
200 
201 /*
202  * Decrement pdev reference counter if 0 remove it.
203  */
204 int
205 dm_pdev_decr(dm_pdev_t * dmp)
206 {
207 	KASSERT(dmp != NULL);
208 	/*
209 	 * If this was last reference remove dmp from
210 	 * global list also.
211 	 */
212 	mutex_enter(&dm_pdev_mutex);
213 
214 	if (--dmp->ref_cnt == 0) {
215 		SLIST_REMOVE(&dm_pdev_list, dmp, dm_pdev, next_pdev);
216 		mutex_exit(&dm_pdev_mutex);
217 		dm_pdev_rem(dmp);
218 		return 0;
219 	}
220 	mutex_exit(&dm_pdev_mutex);
221 	return 0;
222 }
223 /*static int
224   dm_pdev_dump_list(void)
225   {
226   dm_pdev_t *dmp;
227 
228   aprint_verbose("Dumping dm_pdev_list \n");
229 
230   SLIST_FOREACH(dmp, &dm_pdev_list, next_pdev) {
231   aprint_verbose("dm_pdev_name %s ref_cnt %d list_rf_cnt %d\n",
232   dmp->name, dmp->ref_cnt, dmp->list_ref_cnt);
233   }
234 
235   return 0;
236 
237   }*/
238