2 * SPDX-License-Identifier: BSD-2-Clause-FreeBSD
4 * Copyright (c) 2007 Lukas Ertl
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
16 * THIS SOFTWARE IS PROVIDED BY AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
20 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30 #include <sys/cdefs.h>
31 __FBSDID("$FreeBSD$");
33 #include <sys/param.h>
34 #include <sys/kernel.h>
36 #include <sys/malloc.h>
37 #include <sys/mutex.h>
38 #include <sys/systm.h>
40 #include <geom/geom.h>
41 #include <geom/geom_dbg.h>
42 #include <geom/vinum/geom_vinum_var.h>
43 #include <geom/vinum/geom_vinum.h>
46 gv_post_event(struct gv_softc *sc, int event, void *arg1, void *arg2,
47 intmax_t arg3, intmax_t arg4)
51 ev = g_malloc(sizeof(*ev), M_WAITOK | M_ZERO);
58 mtx_lock(&sc->equeue_mtx);
59 TAILQ_INSERT_TAIL(&sc->equeue, ev, events);
61 mtx_unlock(&sc->equeue_mtx);
65 gv_worker_exit(struct gv_softc *sc)
69 ev = g_malloc(sizeof(*ev), M_WAITOK | M_ZERO);
70 ev->type = GV_EVENT_THREAD_EXIT;
72 mtx_lock(&sc->equeue_mtx);
73 TAILQ_INSERT_TAIL(&sc->equeue, ev, events);
75 msleep(sc->worker, &sc->equeue_mtx, PDROP, "gv_wor", 0);
79 gv_get_event(struct gv_softc *sc)
83 KASSERT(sc != NULL, ("NULL sc"));
84 mtx_lock(&sc->equeue_mtx);
85 ev = TAILQ_FIRST(&sc->equeue);
86 mtx_unlock(&sc->equeue_mtx);
91 gv_remove_event(struct gv_softc *sc, struct gv_event *ev)
94 KASSERT(sc != NULL, ("NULL sc"));
95 KASSERT(ev != NULL, ("NULL ev"));
96 mtx_lock(&sc->equeue_mtx);
97 TAILQ_REMOVE(&sc->equeue, ev, events);
98 mtx_unlock(&sc->equeue_mtx);
102 gv_drive_tasted(struct gv_softc *sc, struct g_provider *pp)
105 struct g_consumer *cp;
114 G_VINUM_DEBUG(2, "tasted drive on '%s'", pp->name);
115 if ((GV_CFG_OFFSET % pp->sectorsize) != 0 ||
116 (GV_CFG_LEN % pp->sectorsize) != 0) {
117 G_VINUM_DEBUG(0, "provider %s has unsupported sectorsize.",
124 cp = g_new_consumer(gp);
125 if (g_attach(cp, pp) != 0) {
126 g_destroy_consumer(cp);
128 G_VINUM_DEBUG(0, "failed to attach to provider on taste event");
131 if (g_access(cp, 1, 0, 0) != 0) {
133 g_destroy_consumer(cp);
135 G_VINUM_DEBUG(0, "failed to access consumer on taste event");
140 hdr = g_malloc(GV_HDR_LEN, M_WAITOK | M_ZERO);
141 /* Read header and on-disk configuration. */
142 error = gv_read_header(cp, hdr);
144 G_VINUM_DEBUG(0, "failed to read header during taste");
149 * Setup the drive before we parse the on-disk configuration, so that
150 * we already know about the drive then.
152 d = gv_find_drive(sc, hdr->label.name);
154 d = g_malloc(sizeof(*d), M_WAITOK | M_ZERO);
155 strlcpy(d->name, hdr->label.name, sizeof(d->name));
156 strlcpy(d->device, pp->name, sizeof(d->device));
157 } else if (d->flags & GV_DRIVE_REFERENCED) {
158 strlcpy(d->device, pp->name, sizeof(d->device));
159 d->flags &= ~GV_DRIVE_REFERENCED;
161 G_VINUM_DEBUG(2, "drive '%s' is already known", d->name);
165 /* Add the consumer and header to the new drive. */
168 gv_create_drive(sc, d);
170 buf = g_read_data(cp, GV_CFG_OFFSET, GV_CFG_LEN, NULL);
172 G_VINUM_DEBUG(0, "failed to read config during taste");
175 gv_parse_config(sc, buf, d);
179 g_access(cp, -1, 0, 0);
182 gv_setup_objects(sc);
183 gv_set_drive_state(d, GV_DRIVE_UP, 0);
191 g_access(cp, -1, 0, 0);
193 g_destroy_consumer(cp);
198 * Count completed BIOs and handle orphanization when all are done.
201 gv_drive_done(struct gv_drive *d)
204 KASSERT(d->active >= 0, ("Negative number of BIOs (%d)", d->active));
205 if (--d->active == 0 && (d->flags & GV_DRIVE_ORPHANED)) {
206 d->flags &= ~GV_DRIVE_ORPHANED;
207 gv_post_event(d->vinumconf, GV_EVENT_DRIVE_LOST, d, NULL, 0, 0);
212 * When losing a drive (e.g. hardware failure), we cut down the consumer
213 * attached to the underlying device and bring the drive itself to a
214 * "referenced" state so that normal tasting could bring it up cleanly if it
215 * possibly arrives again.
218 gv_drive_lost(struct gv_softc *sc, struct gv_drive *d)
220 struct g_consumer *cp;
222 struct gv_sd *s, *s2;
223 struct gv_freelist *fl, *fl2;
225 gv_set_drive_state(d, GV_DRIVE_DOWN,
226 GV_SETSTATE_FORCE | GV_SETSTATE_CONFIG);
232 G_VINUM_DEBUG(2, "dead drive '%s' has still active "
233 "requests, unable to detach consumer", d->name);
234 d->flags |= GV_DRIVE_ORPHANED;
238 if (cp->acr != 0 || cp->acw != 0 || cp->ace != 0)
239 g_access(cp, -cp->acr, -cp->acw, -cp->ace);
241 g_destroy_consumer(cp);
245 LIST_FOREACH_SAFE(fl, &d->freelist, freelist, fl2) {
246 LIST_REMOVE(fl, freelist);
253 d->flags |= GV_DRIVE_REFERENCED;
254 snprintf(d->device, sizeof(d->device), "???");
257 d->freelist_entries = 0;
260 /* Put the subdisk in tasted mode, and remove from drive list. */
261 LIST_FOREACH_SAFE(s, &d->subdisks, from_drive, s2) {
262 LIST_REMOVE(s, from_drive);
263 s->flags |= GV_SD_TASTED;
267 * Don't forget that gv_is_newer wants a "real" drive at the beginning
268 * of the list, so, just to be safe, we shuffle around.
270 LIST_REMOVE(d, drive);
271 d2 = LIST_FIRST(&sc->drives);
273 LIST_INSERT_HEAD(&sc->drives, d, drive);
275 LIST_INSERT_AFTER(d2, d, drive);