1080361d6SPawel Jakub Dawidek /*-
24d846d26SWarner Losh * SPDX-License-Identifier: BSD-2-Clause
33728855aSPedro F. Giffuni *
499394c59SPawel Jakub Dawidek * Copyright (c) 2005 Pawel Jakub Dawidek <pjd@FreeBSD.org>
5080361d6SPawel Jakub Dawidek * All rights reserved.
6080361d6SPawel Jakub Dawidek *
7080361d6SPawel Jakub Dawidek * Redistribution and use in source and binary forms, with or without
8080361d6SPawel Jakub Dawidek * modification, are permitted provided that the following conditions
9080361d6SPawel Jakub Dawidek * are met:
10080361d6SPawel Jakub Dawidek * 1. Redistributions of source code must retain the above copyright
11080361d6SPawel Jakub Dawidek * notice, this list of conditions and the following disclaimer.
12080361d6SPawel Jakub Dawidek * 2. Redistributions in binary form must reproduce the above copyright
13080361d6SPawel Jakub Dawidek * notice, this list of conditions and the following disclaimer in the
14080361d6SPawel Jakub Dawidek * documentation and/or other materials provided with the distribution.
15080361d6SPawel Jakub Dawidek *
16080361d6SPawel Jakub Dawidek * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND
17080361d6SPawel Jakub Dawidek * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18080361d6SPawel Jakub Dawidek * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19080361d6SPawel Jakub Dawidek * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
20080361d6SPawel Jakub Dawidek * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21080361d6SPawel Jakub Dawidek * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22080361d6SPawel Jakub Dawidek * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23080361d6SPawel Jakub Dawidek * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24080361d6SPawel Jakub Dawidek * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25080361d6SPawel Jakub Dawidek * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26080361d6SPawel Jakub Dawidek * SUCH DAMAGE.
27080361d6SPawel Jakub Dawidek */
28080361d6SPawel Jakub Dawidek
29080361d6SPawel Jakub Dawidek #include <sys/param.h>
30080361d6SPawel Jakub Dawidek #include <sys/systm.h>
31080361d6SPawel Jakub Dawidek #include <sys/kernel.h>
32080361d6SPawel Jakub Dawidek #include <sys/module.h>
33080361d6SPawel Jakub Dawidek #include <sys/lock.h>
34080361d6SPawel Jakub Dawidek #include <sys/mutex.h>
35080361d6SPawel Jakub Dawidek #include <sys/bio.h>
365d807a0eSAndrey V. Elsukov #include <sys/sbuf.h>
37080361d6SPawel Jakub Dawidek #include <sys/sysctl.h>
38080361d6SPawel Jakub Dawidek #include <sys/malloc.h>
39080361d6SPawel Jakub Dawidek #include <vm/uma.h>
40080361d6SPawel Jakub Dawidek #include <geom/geom.h>
41ac03832eSConrad Meyer #include <geom/geom_dbg.h>
42080361d6SPawel Jakub Dawidek #include <geom/shsec/g_shsec.h>
43080361d6SPawel Jakub Dawidek
44cb08c2ccSAlexander Leidinger FEATURE(geom_shsec, "GEOM shared secret device support");
45080361d6SPawel Jakub Dawidek
465bb84bc8SRobert Watson static MALLOC_DEFINE(M_SHSEC, "shsec_data", "GEOM_SHSEC Data");
47080361d6SPawel Jakub Dawidek
48080361d6SPawel Jakub Dawidek static uma_zone_t g_shsec_zone;
49080361d6SPawel Jakub Dawidek
50080361d6SPawel Jakub Dawidek static int g_shsec_destroy(struct g_shsec_softc *sc, boolean_t force);
51080361d6SPawel Jakub Dawidek static int g_shsec_destroy_geom(struct gctl_req *req, struct g_class *mp,
52080361d6SPawel Jakub Dawidek struct g_geom *gp);
53080361d6SPawel Jakub Dawidek
54080361d6SPawel Jakub Dawidek static g_taste_t g_shsec_taste;
55080361d6SPawel Jakub Dawidek static g_ctl_req_t g_shsec_config;
56080361d6SPawel Jakub Dawidek static g_dumpconf_t g_shsec_dumpconf;
57080361d6SPawel Jakub Dawidek static g_init_t g_shsec_init;
58080361d6SPawel Jakub Dawidek static g_fini_t g_shsec_fini;
59080361d6SPawel Jakub Dawidek
60080361d6SPawel Jakub Dawidek struct g_class g_shsec_class = {
61080361d6SPawel Jakub Dawidek .name = G_SHSEC_CLASS_NAME,
62080361d6SPawel Jakub Dawidek .version = G_VERSION,
63080361d6SPawel Jakub Dawidek .ctlreq = g_shsec_config,
64080361d6SPawel Jakub Dawidek .taste = g_shsec_taste,
65080361d6SPawel Jakub Dawidek .destroy_geom = g_shsec_destroy_geom,
66080361d6SPawel Jakub Dawidek .init = g_shsec_init,
67080361d6SPawel Jakub Dawidek .fini = g_shsec_fini
68080361d6SPawel Jakub Dawidek };
69080361d6SPawel Jakub Dawidek
70080361d6SPawel Jakub Dawidek SYSCTL_DECL(_kern_geom);
717029da5cSPawel Biernacki static SYSCTL_NODE(_kern_geom, OID_AUTO, shsec, CTLFLAG_RW | CTLFLAG_MPSAFE, 0,
726472ac3dSEd Schouten "GEOM_SHSEC stuff");
73cd853791SKonstantin Belousov static u_int g_shsec_debug;
74af3b2549SHans Petter Selasky SYSCTL_UINT(_kern_geom_shsec, OID_AUTO, debug, CTLFLAG_RWTUN, &g_shsec_debug, 0,
75080361d6SPawel Jakub Dawidek "Debug level");
76cd853791SKonstantin Belousov static u_long g_shsec_maxmem;
77cd853791SKonstantin Belousov SYSCTL_ULONG(_kern_geom_shsec, OID_AUTO, maxmem,
78cd853791SKonstantin Belousov CTLFLAG_RDTUN | CTLFLAG_NOFETCH, &g_shsec_maxmem,
79080361d6SPawel Jakub Dawidek 0, "Maximum memory that can be allocated for I/O (in bytes)");
80080361d6SPawel Jakub Dawidek static u_int g_shsec_alloc_failed = 0;
81080361d6SPawel Jakub Dawidek SYSCTL_UINT(_kern_geom_shsec, OID_AUTO, alloc_failed, CTLFLAG_RD,
82080361d6SPawel Jakub Dawidek &g_shsec_alloc_failed, 0, "How many times I/O allocation failed");
83080361d6SPawel Jakub Dawidek
84080361d6SPawel Jakub Dawidek /*
85080361d6SPawel Jakub Dawidek * Greatest Common Divisor.
86080361d6SPawel Jakub Dawidek */
87080361d6SPawel Jakub Dawidek static u_int
gcd(u_int a,u_int b)88080361d6SPawel Jakub Dawidek gcd(u_int a, u_int b)
89080361d6SPawel Jakub Dawidek {
90080361d6SPawel Jakub Dawidek u_int c;
91080361d6SPawel Jakub Dawidek
92080361d6SPawel Jakub Dawidek while (b != 0) {
93080361d6SPawel Jakub Dawidek c = a;
94080361d6SPawel Jakub Dawidek a = b;
95080361d6SPawel Jakub Dawidek b = (c % b);
96080361d6SPawel Jakub Dawidek }
97080361d6SPawel Jakub Dawidek return (a);
98080361d6SPawel Jakub Dawidek }
99080361d6SPawel Jakub Dawidek
100080361d6SPawel Jakub Dawidek /*
101080361d6SPawel Jakub Dawidek * Least Common Multiple.
102080361d6SPawel Jakub Dawidek */
103080361d6SPawel Jakub Dawidek static u_int
lcm(u_int a,u_int b)104080361d6SPawel Jakub Dawidek lcm(u_int a, u_int b)
105080361d6SPawel Jakub Dawidek {
106080361d6SPawel Jakub Dawidek
107080361d6SPawel Jakub Dawidek return ((a * b) / gcd(a, b));
108080361d6SPawel Jakub Dawidek }
109080361d6SPawel Jakub Dawidek
110080361d6SPawel Jakub Dawidek static void
g_shsec_init(struct g_class * mp __unused)111080361d6SPawel Jakub Dawidek g_shsec_init(struct g_class *mp __unused)
112080361d6SPawel Jakub Dawidek {
113080361d6SPawel Jakub Dawidek
114cd853791SKonstantin Belousov g_shsec_maxmem = maxphys * 100;
115cd853791SKonstantin Belousov TUNABLE_ULONG_FETCH("kern.geom.shsec.maxmem,", &g_shsec_maxmem);
116cd853791SKonstantin Belousov g_shsec_zone = uma_zcreate("g_shsec_zone", maxphys, NULL, NULL, NULL,
117080361d6SPawel Jakub Dawidek NULL, 0, 0);
118cd853791SKonstantin Belousov g_shsec_maxmem -= g_shsec_maxmem % maxphys;
119cd853791SKonstantin Belousov uma_zone_set_max(g_shsec_zone, g_shsec_maxmem / maxphys);
120080361d6SPawel Jakub Dawidek }
121080361d6SPawel Jakub Dawidek
122080361d6SPawel Jakub Dawidek static void
g_shsec_fini(struct g_class * mp __unused)123080361d6SPawel Jakub Dawidek g_shsec_fini(struct g_class *mp __unused)
124080361d6SPawel Jakub Dawidek {
125080361d6SPawel Jakub Dawidek
126080361d6SPawel Jakub Dawidek uma_zdestroy(g_shsec_zone);
127080361d6SPawel Jakub Dawidek }
128080361d6SPawel Jakub Dawidek
129080361d6SPawel Jakub Dawidek /*
130080361d6SPawel Jakub Dawidek * Return the number of valid disks.
131080361d6SPawel Jakub Dawidek */
132080361d6SPawel Jakub Dawidek static u_int
g_shsec_nvalid(struct g_shsec_softc * sc)133080361d6SPawel Jakub Dawidek g_shsec_nvalid(struct g_shsec_softc *sc)
134080361d6SPawel Jakub Dawidek {
135080361d6SPawel Jakub Dawidek u_int i, no;
136080361d6SPawel Jakub Dawidek
137080361d6SPawel Jakub Dawidek no = 0;
138080361d6SPawel Jakub Dawidek for (i = 0; i < sc->sc_ndisks; i++) {
139080361d6SPawel Jakub Dawidek if (sc->sc_disks[i] != NULL)
140080361d6SPawel Jakub Dawidek no++;
141080361d6SPawel Jakub Dawidek }
142080361d6SPawel Jakub Dawidek
143080361d6SPawel Jakub Dawidek return (no);
144080361d6SPawel Jakub Dawidek }
145080361d6SPawel Jakub Dawidek
146080361d6SPawel Jakub Dawidek static void
g_shsec_remove_disk(struct g_consumer * cp)147080361d6SPawel Jakub Dawidek g_shsec_remove_disk(struct g_consumer *cp)
148080361d6SPawel Jakub Dawidek {
149080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
150080361d6SPawel Jakub Dawidek u_int no;
151080361d6SPawel Jakub Dawidek
152080361d6SPawel Jakub Dawidek KASSERT(cp != NULL, ("Non-valid disk in %s.", __func__));
153080361d6SPawel Jakub Dawidek sc = (struct g_shsec_softc *)cp->private;
154080361d6SPawel Jakub Dawidek KASSERT(sc != NULL, ("NULL sc in %s.", __func__));
155080361d6SPawel Jakub Dawidek no = cp->index;
156080361d6SPawel Jakub Dawidek
157080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Disk %s removed from %s.", cp->provider->name,
158080361d6SPawel Jakub Dawidek sc->sc_name);
159080361d6SPawel Jakub Dawidek
160080361d6SPawel Jakub Dawidek sc->sc_disks[no] = NULL;
161080361d6SPawel Jakub Dawidek if (sc->sc_provider != NULL) {
1628b64f3caSAlexander Motin g_wither_provider(sc->sc_provider, ENXIO);
163080361d6SPawel Jakub Dawidek sc->sc_provider = NULL;
164080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s removed.", sc->sc_name);
165080361d6SPawel Jakub Dawidek }
166080361d6SPawel Jakub Dawidek
167080361d6SPawel Jakub Dawidek if (cp->acr > 0 || cp->acw > 0 || cp->ace > 0)
1686a8eef35SAlexander Motin return;
169080361d6SPawel Jakub Dawidek g_detach(cp);
170080361d6SPawel Jakub Dawidek g_destroy_consumer(cp);
171080361d6SPawel Jakub Dawidek }
172080361d6SPawel Jakub Dawidek
173080361d6SPawel Jakub Dawidek static void
g_shsec_orphan(struct g_consumer * cp)174080361d6SPawel Jakub Dawidek g_shsec_orphan(struct g_consumer *cp)
175080361d6SPawel Jakub Dawidek {
176080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
177080361d6SPawel Jakub Dawidek struct g_geom *gp;
178080361d6SPawel Jakub Dawidek
179080361d6SPawel Jakub Dawidek g_topology_assert();
180080361d6SPawel Jakub Dawidek gp = cp->geom;
181080361d6SPawel Jakub Dawidek sc = gp->softc;
182080361d6SPawel Jakub Dawidek if (sc == NULL)
183080361d6SPawel Jakub Dawidek return;
184080361d6SPawel Jakub Dawidek
185080361d6SPawel Jakub Dawidek g_shsec_remove_disk(cp);
186080361d6SPawel Jakub Dawidek /* If there are no valid disks anymore, remove device. */
187cfdb9185SAlexander Motin if (LIST_EMPTY(&gp->consumer))
188080361d6SPawel Jakub Dawidek g_shsec_destroy(sc, 1);
189080361d6SPawel Jakub Dawidek }
190080361d6SPawel Jakub Dawidek
191080361d6SPawel Jakub Dawidek static int
g_shsec_access(struct g_provider * pp,int dr,int dw,int de)192080361d6SPawel Jakub Dawidek g_shsec_access(struct g_provider *pp, int dr, int dw, int de)
193080361d6SPawel Jakub Dawidek {
1946a8eef35SAlexander Motin struct g_consumer *cp1, *cp2, *tmp;
195080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
196080361d6SPawel Jakub Dawidek struct g_geom *gp;
197080361d6SPawel Jakub Dawidek int error;
198080361d6SPawel Jakub Dawidek
199080361d6SPawel Jakub Dawidek gp = pp->geom;
200080361d6SPawel Jakub Dawidek sc = gp->softc;
201080361d6SPawel Jakub Dawidek
202080361d6SPawel Jakub Dawidek /* On first open, grab an extra "exclusive" bit */
203080361d6SPawel Jakub Dawidek if (pp->acr == 0 && pp->acw == 0 && pp->ace == 0)
204080361d6SPawel Jakub Dawidek de++;
205080361d6SPawel Jakub Dawidek /* ... and let go of it on last close */
206080361d6SPawel Jakub Dawidek if ((pp->acr + dr) == 0 && (pp->acw + dw) == 0 && (pp->ace + de) == 0)
207080361d6SPawel Jakub Dawidek de--;
208080361d6SPawel Jakub Dawidek
209080361d6SPawel Jakub Dawidek error = ENXIO;
2106a8eef35SAlexander Motin LIST_FOREACH_SAFE(cp1, &gp->consumer, consumer, tmp) {
211080361d6SPawel Jakub Dawidek error = g_access(cp1, dr, dw, de);
2126a8eef35SAlexander Motin if (error != 0)
2136a8eef35SAlexander Motin goto fail;
2146a8eef35SAlexander Motin if (cp1->acr == 0 && cp1->acw == 0 && cp1->ace == 0 &&
2156a8eef35SAlexander Motin cp1->flags & G_CF_ORPHAN) {
2166a8eef35SAlexander Motin g_detach(cp1);
2176a8eef35SAlexander Motin g_destroy_consumer(cp1);
2186a8eef35SAlexander Motin }
2196a8eef35SAlexander Motin }
220cfdb9185SAlexander Motin
221cfdb9185SAlexander Motin /* If there are no valid disks anymore, remove device. */
222cfdb9185SAlexander Motin if (LIST_EMPTY(&gp->consumer))
223cfdb9185SAlexander Motin g_shsec_destroy(sc, 1);
224cfdb9185SAlexander Motin
2256a8eef35SAlexander Motin return (error);
2266a8eef35SAlexander Motin
2276a8eef35SAlexander Motin fail:
2286a8eef35SAlexander Motin /* If we fail here, backout all previous changes. */
229080361d6SPawel Jakub Dawidek LIST_FOREACH(cp2, &gp->consumer, consumer) {
230080361d6SPawel Jakub Dawidek if (cp1 == cp2)
2316a8eef35SAlexander Motin break;
232080361d6SPawel Jakub Dawidek g_access(cp2, -dr, -dw, -de);
233080361d6SPawel Jakub Dawidek }
234080361d6SPawel Jakub Dawidek return (error);
235080361d6SPawel Jakub Dawidek }
236080361d6SPawel Jakub Dawidek
237080361d6SPawel Jakub Dawidek static void
g_shsec_xor1(uint32_t * src,uint32_t * dst,ssize_t len)238080361d6SPawel Jakub Dawidek g_shsec_xor1(uint32_t *src, uint32_t *dst, ssize_t len)
239080361d6SPawel Jakub Dawidek {
240080361d6SPawel Jakub Dawidek
241080361d6SPawel Jakub Dawidek for (; len > 0; len -= sizeof(uint32_t), dst++)
242080361d6SPawel Jakub Dawidek *dst = *dst ^ *src++;
243080361d6SPawel Jakub Dawidek KASSERT(len == 0, ("len != 0 (len=%zd)", len));
244080361d6SPawel Jakub Dawidek }
245080361d6SPawel Jakub Dawidek
246080361d6SPawel Jakub Dawidek static void
g_shsec_done(struct bio * bp)247080361d6SPawel Jakub Dawidek g_shsec_done(struct bio *bp)
248080361d6SPawel Jakub Dawidek {
249080361d6SPawel Jakub Dawidek struct bio *pbp;
250080361d6SPawel Jakub Dawidek
251080361d6SPawel Jakub Dawidek pbp = bp->bio_parent;
252080361d6SPawel Jakub Dawidek if (bp->bio_error == 0)
253080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(2, bp, "Request done.");
254080361d6SPawel Jakub Dawidek else {
255080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(0, bp, "Request failed (error=%d).",
256080361d6SPawel Jakub Dawidek bp->bio_error);
257080361d6SPawel Jakub Dawidek if (pbp->bio_error == 0)
258080361d6SPawel Jakub Dawidek pbp->bio_error = bp->bio_error;
259080361d6SPawel Jakub Dawidek }
260080361d6SPawel Jakub Dawidek if (pbp->bio_cmd == BIO_READ) {
261080361d6SPawel Jakub Dawidek if ((pbp->bio_pflags & G_SHSEC_BFLAG_FIRST) != 0) {
262080361d6SPawel Jakub Dawidek bcopy(bp->bio_data, pbp->bio_data, pbp->bio_length);
263080361d6SPawel Jakub Dawidek pbp->bio_pflags = 0;
264080361d6SPawel Jakub Dawidek } else {
265080361d6SPawel Jakub Dawidek g_shsec_xor1((uint32_t *)bp->bio_data,
266080361d6SPawel Jakub Dawidek (uint32_t *)pbp->bio_data,
267080361d6SPawel Jakub Dawidek (ssize_t)pbp->bio_length);
268080361d6SPawel Jakub Dawidek }
269080361d6SPawel Jakub Dawidek }
270a2dfffb9SMark Johnston if (bp->bio_data != NULL) {
2716572e5ffSJohn Baldwin explicit_bzero(bp->bio_data, bp->bio_length);
272080361d6SPawel Jakub Dawidek uma_zfree(g_shsec_zone, bp->bio_data);
273a2dfffb9SMark Johnston }
274080361d6SPawel Jakub Dawidek g_destroy_bio(bp);
275080361d6SPawel Jakub Dawidek pbp->bio_inbed++;
276080361d6SPawel Jakub Dawidek if (pbp->bio_children == pbp->bio_inbed) {
277080361d6SPawel Jakub Dawidek pbp->bio_completed = pbp->bio_length;
278080361d6SPawel Jakub Dawidek g_io_deliver(pbp, pbp->bio_error);
279080361d6SPawel Jakub Dawidek }
280080361d6SPawel Jakub Dawidek }
281080361d6SPawel Jakub Dawidek
282080361d6SPawel Jakub Dawidek static void
g_shsec_xor2(uint32_t * rand,uint32_t * dst,ssize_t len)283080361d6SPawel Jakub Dawidek g_shsec_xor2(uint32_t *rand, uint32_t *dst, ssize_t len)
284080361d6SPawel Jakub Dawidek {
285080361d6SPawel Jakub Dawidek
286080361d6SPawel Jakub Dawidek for (; len > 0; len -= sizeof(uint32_t), dst++) {
287080361d6SPawel Jakub Dawidek *rand = arc4random();
288080361d6SPawel Jakub Dawidek *dst = *dst ^ *rand++;
289080361d6SPawel Jakub Dawidek }
290080361d6SPawel Jakub Dawidek KASSERT(len == 0, ("len != 0 (len=%zd)", len));
291080361d6SPawel Jakub Dawidek }
292080361d6SPawel Jakub Dawidek
293080361d6SPawel Jakub Dawidek static void
g_shsec_start(struct bio * bp)294080361d6SPawel Jakub Dawidek g_shsec_start(struct bio *bp)
295080361d6SPawel Jakub Dawidek {
296080361d6SPawel Jakub Dawidek TAILQ_HEAD(, bio) queue = TAILQ_HEAD_INITIALIZER(queue);
297080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
298080361d6SPawel Jakub Dawidek struct bio *cbp;
299080361d6SPawel Jakub Dawidek uint32_t *dst;
300080361d6SPawel Jakub Dawidek ssize_t len;
301080361d6SPawel Jakub Dawidek u_int no;
302080361d6SPawel Jakub Dawidek int error;
303080361d6SPawel Jakub Dawidek
304080361d6SPawel Jakub Dawidek sc = bp->bio_to->geom->softc;
305080361d6SPawel Jakub Dawidek /*
306080361d6SPawel Jakub Dawidek * If sc == NULL, provider's error should be set and g_shsec_start()
307080361d6SPawel Jakub Dawidek * should not be called at all.
308080361d6SPawel Jakub Dawidek */
309080361d6SPawel Jakub Dawidek KASSERT(sc != NULL,
310080361d6SPawel Jakub Dawidek ("Provider's error should be set (error=%d)(device=%s).",
311080361d6SPawel Jakub Dawidek bp->bio_to->error, bp->bio_to->name));
312080361d6SPawel Jakub Dawidek
313080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(2, bp, "Request received.");
314080361d6SPawel Jakub Dawidek
315080361d6SPawel Jakub Dawidek switch (bp->bio_cmd) {
316080361d6SPawel Jakub Dawidek case BIO_READ:
317080361d6SPawel Jakub Dawidek case BIO_WRITE:
318118c814eSPawel Jakub Dawidek case BIO_FLUSH:
3198b522bdaSWarner Losh case BIO_SPEEDUP:
320080361d6SPawel Jakub Dawidek /*
321080361d6SPawel Jakub Dawidek * Only those requests are supported.
322080361d6SPawel Jakub Dawidek */
323080361d6SPawel Jakub Dawidek break;
324080361d6SPawel Jakub Dawidek case BIO_DELETE:
325080361d6SPawel Jakub Dawidek case BIO_GETATTR:
326080361d6SPawel Jakub Dawidek /* To which provider it should be delivered? */
327080361d6SPawel Jakub Dawidek default:
328080361d6SPawel Jakub Dawidek g_io_deliver(bp, EOPNOTSUPP);
329080361d6SPawel Jakub Dawidek return;
330080361d6SPawel Jakub Dawidek }
331080361d6SPawel Jakub Dawidek
332080361d6SPawel Jakub Dawidek /*
333080361d6SPawel Jakub Dawidek * Allocate all bios first and calculate XOR.
334080361d6SPawel Jakub Dawidek */
335080361d6SPawel Jakub Dawidek dst = NULL;
336080361d6SPawel Jakub Dawidek len = bp->bio_length;
337080361d6SPawel Jakub Dawidek if (bp->bio_cmd == BIO_READ)
338080361d6SPawel Jakub Dawidek bp->bio_pflags = G_SHSEC_BFLAG_FIRST;
339080361d6SPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) {
340080361d6SPawel Jakub Dawidek cbp = g_clone_bio(bp);
341080361d6SPawel Jakub Dawidek if (cbp == NULL) {
342080361d6SPawel Jakub Dawidek error = ENOMEM;
343080361d6SPawel Jakub Dawidek goto failure;
344080361d6SPawel Jakub Dawidek }
345080361d6SPawel Jakub Dawidek TAILQ_INSERT_TAIL(&queue, cbp, bio_queue);
346080361d6SPawel Jakub Dawidek
347080361d6SPawel Jakub Dawidek /*
348080361d6SPawel Jakub Dawidek * Fill in the component buf structure.
349080361d6SPawel Jakub Dawidek */
350080361d6SPawel Jakub Dawidek cbp->bio_done = g_shsec_done;
351a2dfffb9SMark Johnston cbp->bio_caller2 = sc->sc_disks[no];
352a2dfffb9SMark Johnston if (bp->bio_cmd == BIO_READ || bp->bio_cmd == BIO_WRITE) {
353080361d6SPawel Jakub Dawidek cbp->bio_data = uma_zalloc(g_shsec_zone, M_NOWAIT);
354080361d6SPawel Jakub Dawidek if (cbp->bio_data == NULL) {
355080361d6SPawel Jakub Dawidek g_shsec_alloc_failed++;
356080361d6SPawel Jakub Dawidek error = ENOMEM;
357080361d6SPawel Jakub Dawidek goto failure;
358080361d6SPawel Jakub Dawidek }
359080361d6SPawel Jakub Dawidek if (bp->bio_cmd == BIO_WRITE) {
360080361d6SPawel Jakub Dawidek if (no == 0) {
361080361d6SPawel Jakub Dawidek dst = (uint32_t *)cbp->bio_data;
362080361d6SPawel Jakub Dawidek bcopy(bp->bio_data, dst, len);
363080361d6SPawel Jakub Dawidek } else {
364a2dfffb9SMark Johnston g_shsec_xor2((uint32_t *)cbp->bio_data,
365a2dfffb9SMark Johnston dst, len);
366a2dfffb9SMark Johnston }
367080361d6SPawel Jakub Dawidek }
368080361d6SPawel Jakub Dawidek }
369080361d6SPawel Jakub Dawidek }
370080361d6SPawel Jakub Dawidek /*
371080361d6SPawel Jakub Dawidek * Fire off all allocated requests!
372080361d6SPawel Jakub Dawidek */
373080361d6SPawel Jakub Dawidek while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
374080361d6SPawel Jakub Dawidek struct g_consumer *cp;
375080361d6SPawel Jakub Dawidek
376080361d6SPawel Jakub Dawidek TAILQ_REMOVE(&queue, cbp, bio_queue);
377080361d6SPawel Jakub Dawidek cp = cbp->bio_caller2;
378080361d6SPawel Jakub Dawidek cbp->bio_caller2 = NULL;
379080361d6SPawel Jakub Dawidek cbp->bio_to = cp->provider;
380080361d6SPawel Jakub Dawidek G_SHSEC_LOGREQ(2, cbp, "Sending request.");
381080361d6SPawel Jakub Dawidek g_io_request(cbp, cp);
382080361d6SPawel Jakub Dawidek }
383080361d6SPawel Jakub Dawidek return;
384080361d6SPawel Jakub Dawidek failure:
385080361d6SPawel Jakub Dawidek while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
386080361d6SPawel Jakub Dawidek TAILQ_REMOVE(&queue, cbp, bio_queue);
387080361d6SPawel Jakub Dawidek bp->bio_children--;
388080361d6SPawel Jakub Dawidek if (cbp->bio_data != NULL) {
3896572e5ffSJohn Baldwin explicit_bzero(cbp->bio_data, cbp->bio_length);
390080361d6SPawel Jakub Dawidek uma_zfree(g_shsec_zone, cbp->bio_data);
391080361d6SPawel Jakub Dawidek }
392080361d6SPawel Jakub Dawidek g_destroy_bio(cbp);
393080361d6SPawel Jakub Dawidek }
394080361d6SPawel Jakub Dawidek if (bp->bio_error == 0)
395080361d6SPawel Jakub Dawidek bp->bio_error = error;
396080361d6SPawel Jakub Dawidek g_io_deliver(bp, bp->bio_error);
397080361d6SPawel Jakub Dawidek }
398080361d6SPawel Jakub Dawidek
399080361d6SPawel Jakub Dawidek static void
g_shsec_check_and_run(struct g_shsec_softc * sc)400080361d6SPawel Jakub Dawidek g_shsec_check_and_run(struct g_shsec_softc *sc)
401080361d6SPawel Jakub Dawidek {
402080361d6SPawel Jakub Dawidek off_t mediasize, ms;
403080361d6SPawel Jakub Dawidek u_int no, sectorsize = 0;
404080361d6SPawel Jakub Dawidek
405080361d6SPawel Jakub Dawidek if (g_shsec_nvalid(sc) != sc->sc_ndisks)
406080361d6SPawel Jakub Dawidek return;
407080361d6SPawel Jakub Dawidek
408080361d6SPawel Jakub Dawidek sc->sc_provider = g_new_providerf(sc->sc_geom, "shsec/%s", sc->sc_name);
409080361d6SPawel Jakub Dawidek /*
410080361d6SPawel Jakub Dawidek * Find the smallest disk.
411080361d6SPawel Jakub Dawidek */
412080361d6SPawel Jakub Dawidek mediasize = sc->sc_disks[0]->provider->mediasize;
413080361d6SPawel Jakub Dawidek mediasize -= sc->sc_disks[0]->provider->sectorsize;
414080361d6SPawel Jakub Dawidek sectorsize = sc->sc_disks[0]->provider->sectorsize;
415080361d6SPawel Jakub Dawidek for (no = 1; no < sc->sc_ndisks; no++) {
416080361d6SPawel Jakub Dawidek ms = sc->sc_disks[no]->provider->mediasize;
417080361d6SPawel Jakub Dawidek ms -= sc->sc_disks[no]->provider->sectorsize;
418080361d6SPawel Jakub Dawidek if (ms < mediasize)
419080361d6SPawel Jakub Dawidek mediasize = ms;
420080361d6SPawel Jakub Dawidek sectorsize = lcm(sectorsize,
421080361d6SPawel Jakub Dawidek sc->sc_disks[no]->provider->sectorsize);
422080361d6SPawel Jakub Dawidek }
423080361d6SPawel Jakub Dawidek sc->sc_provider->sectorsize = sectorsize;
424080361d6SPawel Jakub Dawidek sc->sc_provider->mediasize = mediasize;
425080361d6SPawel Jakub Dawidek g_error_provider(sc->sc_provider, 0);
426080361d6SPawel Jakub Dawidek
427080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s activated.", sc->sc_name);
428080361d6SPawel Jakub Dawidek }
429080361d6SPawel Jakub Dawidek
430080361d6SPawel Jakub Dawidek static int
g_shsec_read_metadata(struct g_consumer * cp,struct g_shsec_metadata * md)431080361d6SPawel Jakub Dawidek g_shsec_read_metadata(struct g_consumer *cp, struct g_shsec_metadata *md)
432080361d6SPawel Jakub Dawidek {
433080361d6SPawel Jakub Dawidek struct g_provider *pp;
434080361d6SPawel Jakub Dawidek u_char *buf;
435080361d6SPawel Jakub Dawidek int error;
436080361d6SPawel Jakub Dawidek
437080361d6SPawel Jakub Dawidek g_topology_assert();
438080361d6SPawel Jakub Dawidek
439080361d6SPawel Jakub Dawidek error = g_access(cp, 1, 0, 0);
440080361d6SPawel Jakub Dawidek if (error != 0)
441080361d6SPawel Jakub Dawidek return (error);
442080361d6SPawel Jakub Dawidek pp = cp->provider;
443080361d6SPawel Jakub Dawidek g_topology_unlock();
444080361d6SPawel Jakub Dawidek buf = g_read_data(cp, pp->mediasize - pp->sectorsize, pp->sectorsize,
445080361d6SPawel Jakub Dawidek &error);
446080361d6SPawel Jakub Dawidek g_topology_lock();
447080361d6SPawel Jakub Dawidek g_access(cp, -1, 0, 0);
448080361d6SPawel Jakub Dawidek if (buf == NULL)
449080361d6SPawel Jakub Dawidek return (error);
450080361d6SPawel Jakub Dawidek
451080361d6SPawel Jakub Dawidek /* Decode metadata. */
452080361d6SPawel Jakub Dawidek shsec_metadata_decode(buf, md);
453080361d6SPawel Jakub Dawidek g_free(buf);
454080361d6SPawel Jakub Dawidek
455080361d6SPawel Jakub Dawidek return (0);
456080361d6SPawel Jakub Dawidek }
457080361d6SPawel Jakub Dawidek
458080361d6SPawel Jakub Dawidek /*
459080361d6SPawel Jakub Dawidek * Add disk to given device.
460080361d6SPawel Jakub Dawidek */
461080361d6SPawel Jakub Dawidek static int
g_shsec_add_disk(struct g_shsec_softc * sc,struct g_provider * pp,u_int no)462080361d6SPawel Jakub Dawidek g_shsec_add_disk(struct g_shsec_softc *sc, struct g_provider *pp, u_int no)
463080361d6SPawel Jakub Dawidek {
464080361d6SPawel Jakub Dawidek struct g_consumer *cp, *fcp;
465080361d6SPawel Jakub Dawidek struct g_geom *gp;
466080361d6SPawel Jakub Dawidek struct g_shsec_metadata md;
467080361d6SPawel Jakub Dawidek int error;
468080361d6SPawel Jakub Dawidek
469080361d6SPawel Jakub Dawidek /* Metadata corrupted? */
470080361d6SPawel Jakub Dawidek if (no >= sc->sc_ndisks)
471080361d6SPawel Jakub Dawidek return (EINVAL);
472080361d6SPawel Jakub Dawidek
473080361d6SPawel Jakub Dawidek /* Check if disk is not already attached. */
474080361d6SPawel Jakub Dawidek if (sc->sc_disks[no] != NULL)
475080361d6SPawel Jakub Dawidek return (EEXIST);
476080361d6SPawel Jakub Dawidek
477080361d6SPawel Jakub Dawidek gp = sc->sc_geom;
478080361d6SPawel Jakub Dawidek fcp = LIST_FIRST(&gp->consumer);
479080361d6SPawel Jakub Dawidek
480080361d6SPawel Jakub Dawidek cp = g_new_consumer(gp);
481080361d6SPawel Jakub Dawidek error = g_attach(cp, pp);
482080361d6SPawel Jakub Dawidek if (error != 0) {
483080361d6SPawel Jakub Dawidek g_destroy_consumer(cp);
484080361d6SPawel Jakub Dawidek return (error);
485080361d6SPawel Jakub Dawidek }
486080361d6SPawel Jakub Dawidek
487080361d6SPawel Jakub Dawidek if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0)) {
488080361d6SPawel Jakub Dawidek error = g_access(cp, fcp->acr, fcp->acw, fcp->ace);
489080361d6SPawel Jakub Dawidek if (error != 0) {
490080361d6SPawel Jakub Dawidek g_detach(cp);
491080361d6SPawel Jakub Dawidek g_destroy_consumer(cp);
492080361d6SPawel Jakub Dawidek return (error);
493080361d6SPawel Jakub Dawidek }
494080361d6SPawel Jakub Dawidek }
495080361d6SPawel Jakub Dawidek
496080361d6SPawel Jakub Dawidek /* Reread metadata. */
497080361d6SPawel Jakub Dawidek error = g_shsec_read_metadata(cp, &md);
498080361d6SPawel Jakub Dawidek if (error != 0)
499080361d6SPawel Jakub Dawidek goto fail;
500080361d6SPawel Jakub Dawidek
501080361d6SPawel Jakub Dawidek if (strcmp(md.md_magic, G_SHSEC_MAGIC) != 0 ||
502080361d6SPawel Jakub Dawidek strcmp(md.md_name, sc->sc_name) != 0 || md.md_id != sc->sc_id) {
503080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Metadata on %s changed.", pp->name);
504080361d6SPawel Jakub Dawidek goto fail;
505080361d6SPawel Jakub Dawidek }
506080361d6SPawel Jakub Dawidek
507080361d6SPawel Jakub Dawidek cp->private = sc;
508080361d6SPawel Jakub Dawidek cp->index = no;
509080361d6SPawel Jakub Dawidek sc->sc_disks[no] = cp;
510080361d6SPawel Jakub Dawidek
511080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Disk %s attached to %s.", pp->name, sc->sc_name);
512080361d6SPawel Jakub Dawidek
513080361d6SPawel Jakub Dawidek g_shsec_check_and_run(sc);
514080361d6SPawel Jakub Dawidek
515080361d6SPawel Jakub Dawidek return (0);
516080361d6SPawel Jakub Dawidek fail:
517080361d6SPawel Jakub Dawidek if (fcp != NULL && (fcp->acr > 0 || fcp->acw > 0 || fcp->ace > 0))
518080361d6SPawel Jakub Dawidek g_access(cp, -fcp->acr, -fcp->acw, -fcp->ace);
519080361d6SPawel Jakub Dawidek g_detach(cp);
520080361d6SPawel Jakub Dawidek g_destroy_consumer(cp);
521080361d6SPawel Jakub Dawidek return (error);
522080361d6SPawel Jakub Dawidek }
523080361d6SPawel Jakub Dawidek
524080361d6SPawel Jakub Dawidek static struct g_geom *
g_shsec_create(struct g_class * mp,const struct g_shsec_metadata * md)525080361d6SPawel Jakub Dawidek g_shsec_create(struct g_class *mp, const struct g_shsec_metadata *md)
526080361d6SPawel Jakub Dawidek {
527080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
528080361d6SPawel Jakub Dawidek struct g_geom *gp;
529080361d6SPawel Jakub Dawidek u_int no;
530080361d6SPawel Jakub Dawidek
531080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, "Creating device %s (id=%u).", md->md_name, md->md_id);
532080361d6SPawel Jakub Dawidek
533080361d6SPawel Jakub Dawidek /* Two disks is minimum. */
534080361d6SPawel Jakub Dawidek if (md->md_all < 2) {
535080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Too few disks defined for %s.", md->md_name);
536080361d6SPawel Jakub Dawidek return (NULL);
537080361d6SPawel Jakub Dawidek }
538080361d6SPawel Jakub Dawidek
539080361d6SPawel Jakub Dawidek /* Check for duplicate unit */
540080361d6SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) {
541080361d6SPawel Jakub Dawidek sc = gp->softc;
542080361d6SPawel Jakub Dawidek if (sc != NULL && strcmp(sc->sc_name, md->md_name) == 0) {
543080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s already configured.",
544080361d6SPawel Jakub Dawidek sc->sc_name);
545080361d6SPawel Jakub Dawidek return (NULL);
546080361d6SPawel Jakub Dawidek }
547080361d6SPawel Jakub Dawidek }
548080361d6SPawel Jakub Dawidek gp = g_new_geomf(mp, "%s", md->md_name);
549080361d6SPawel Jakub Dawidek sc = malloc(sizeof(*sc), M_SHSEC, M_WAITOK | M_ZERO);
550080361d6SPawel Jakub Dawidek gp->start = g_shsec_start;
551080361d6SPawel Jakub Dawidek gp->spoiled = g_shsec_orphan;
552080361d6SPawel Jakub Dawidek gp->orphan = g_shsec_orphan;
553080361d6SPawel Jakub Dawidek gp->access = g_shsec_access;
554080361d6SPawel Jakub Dawidek gp->dumpconf = g_shsec_dumpconf;
555080361d6SPawel Jakub Dawidek
556080361d6SPawel Jakub Dawidek sc->sc_id = md->md_id;
557080361d6SPawel Jakub Dawidek sc->sc_ndisks = md->md_all;
558080361d6SPawel Jakub Dawidek sc->sc_disks = malloc(sizeof(struct g_consumer *) * sc->sc_ndisks,
559080361d6SPawel Jakub Dawidek M_SHSEC, M_WAITOK | M_ZERO);
560080361d6SPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++)
561080361d6SPawel Jakub Dawidek sc->sc_disks[no] = NULL;
562080361d6SPawel Jakub Dawidek
563080361d6SPawel Jakub Dawidek gp->softc = sc;
564080361d6SPawel Jakub Dawidek sc->sc_geom = gp;
565080361d6SPawel Jakub Dawidek sc->sc_provider = NULL;
566080361d6SPawel Jakub Dawidek
567080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s created (id=%u).", sc->sc_name, sc->sc_id);
568080361d6SPawel Jakub Dawidek
569080361d6SPawel Jakub Dawidek return (gp);
570080361d6SPawel Jakub Dawidek }
571080361d6SPawel Jakub Dawidek
572080361d6SPawel Jakub Dawidek static int
g_shsec_destroy(struct g_shsec_softc * sc,boolean_t force)573080361d6SPawel Jakub Dawidek g_shsec_destroy(struct g_shsec_softc *sc, boolean_t force)
574080361d6SPawel Jakub Dawidek {
575080361d6SPawel Jakub Dawidek struct g_provider *pp;
576080361d6SPawel Jakub Dawidek struct g_geom *gp;
577080361d6SPawel Jakub Dawidek u_int no;
578080361d6SPawel Jakub Dawidek
579080361d6SPawel Jakub Dawidek g_topology_assert();
580080361d6SPawel Jakub Dawidek
581080361d6SPawel Jakub Dawidek if (sc == NULL)
582080361d6SPawel Jakub Dawidek return (ENXIO);
583080361d6SPawel Jakub Dawidek
584080361d6SPawel Jakub Dawidek pp = sc->sc_provider;
585080361d6SPawel Jakub Dawidek if (pp != NULL && (pp->acr != 0 || pp->acw != 0 || pp->ace != 0)) {
586080361d6SPawel Jakub Dawidek if (force) {
587080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s is still open, so it "
588080361d6SPawel Jakub Dawidek "can't be definitely removed.", pp->name);
589080361d6SPawel Jakub Dawidek } else {
590080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1,
591080361d6SPawel Jakub Dawidek "Device %s is still open (r%dw%de%d).", pp->name,
592080361d6SPawel Jakub Dawidek pp->acr, pp->acw, pp->ace);
593080361d6SPawel Jakub Dawidek return (EBUSY);
594080361d6SPawel Jakub Dawidek }
595080361d6SPawel Jakub Dawidek }
596080361d6SPawel Jakub Dawidek
597080361d6SPawel Jakub Dawidek for (no = 0; no < sc->sc_ndisks; no++) {
598080361d6SPawel Jakub Dawidek if (sc->sc_disks[no] != NULL)
599080361d6SPawel Jakub Dawidek g_shsec_remove_disk(sc->sc_disks[no]);
600080361d6SPawel Jakub Dawidek }
601080361d6SPawel Jakub Dawidek
602080361d6SPawel Jakub Dawidek gp = sc->sc_geom;
603080361d6SPawel Jakub Dawidek gp->softc = NULL;
604080361d6SPawel Jakub Dawidek KASSERT(sc->sc_provider == NULL, ("Provider still exists? (device=%s)",
605080361d6SPawel Jakub Dawidek gp->name));
606080361d6SPawel Jakub Dawidek free(sc->sc_disks, M_SHSEC);
607080361d6SPawel Jakub Dawidek free(sc, M_SHSEC);
608080361d6SPawel Jakub Dawidek
609080361d6SPawel Jakub Dawidek pp = LIST_FIRST(&gp->provider);
610080361d6SPawel Jakub Dawidek if (pp == NULL || (pp->acr == 0 && pp->acw == 0 && pp->ace == 0))
611080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Device %s destroyed.", gp->name);
612080361d6SPawel Jakub Dawidek
613080361d6SPawel Jakub Dawidek g_wither_geom(gp, ENXIO);
614080361d6SPawel Jakub Dawidek
615080361d6SPawel Jakub Dawidek return (0);
616080361d6SPawel Jakub Dawidek }
617080361d6SPawel Jakub Dawidek
618080361d6SPawel Jakub Dawidek static int
g_shsec_destroy_geom(struct gctl_req * req __unused,struct g_class * mp __unused,struct g_geom * gp)619080361d6SPawel Jakub Dawidek g_shsec_destroy_geom(struct gctl_req *req __unused, struct g_class *mp __unused,
620080361d6SPawel Jakub Dawidek struct g_geom *gp)
621080361d6SPawel Jakub Dawidek {
622080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
623080361d6SPawel Jakub Dawidek
624080361d6SPawel Jakub Dawidek sc = gp->softc;
625080361d6SPawel Jakub Dawidek return (g_shsec_destroy(sc, 0));
626080361d6SPawel Jakub Dawidek }
627080361d6SPawel Jakub Dawidek
628080361d6SPawel Jakub Dawidek static struct g_geom *
g_shsec_taste(struct g_class * mp,struct g_provider * pp,int flags __unused)629080361d6SPawel Jakub Dawidek g_shsec_taste(struct g_class *mp, struct g_provider *pp, int flags __unused)
630080361d6SPawel Jakub Dawidek {
631080361d6SPawel Jakub Dawidek struct g_shsec_metadata md;
632080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
633080361d6SPawel Jakub Dawidek struct g_consumer *cp;
634080361d6SPawel Jakub Dawidek struct g_geom *gp;
635080361d6SPawel Jakub Dawidek int error;
636080361d6SPawel Jakub Dawidek
637080361d6SPawel Jakub Dawidek g_trace(G_T_TOPOLOGY, "%s(%s, %s)", __func__, mp->name, pp->name);
638080361d6SPawel Jakub Dawidek g_topology_assert();
639080361d6SPawel Jakub Dawidek
640f8727e71SPawel Jakub Dawidek /* Skip providers that are already open for writing. */
641f8727e71SPawel Jakub Dawidek if (pp->acw > 0)
642f8727e71SPawel Jakub Dawidek return (NULL);
643f8727e71SPawel Jakub Dawidek
644080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(3, "Tasting %s.", pp->name);
645080361d6SPawel Jakub Dawidek
646080361d6SPawel Jakub Dawidek gp = g_new_geomf(mp, "shsec:taste");
647080361d6SPawel Jakub Dawidek gp->start = g_shsec_start;
648080361d6SPawel Jakub Dawidek gp->access = g_shsec_access;
649080361d6SPawel Jakub Dawidek gp->orphan = g_shsec_orphan;
650080361d6SPawel Jakub Dawidek cp = g_new_consumer(gp);
65110ae42ccSAlexander Motin cp->flags |= G_CF_DIRECT_SEND | G_CF_DIRECT_RECEIVE;
652d22ff249SEdward Tomasz Napierala error = g_attach(cp, pp);
653d22ff249SEdward Tomasz Napierala if (error == 0) {
654080361d6SPawel Jakub Dawidek error = g_shsec_read_metadata(cp, &md);
655080361d6SPawel Jakub Dawidek g_detach(cp);
656d22ff249SEdward Tomasz Napierala }
657080361d6SPawel Jakub Dawidek g_destroy_consumer(cp);
658080361d6SPawel Jakub Dawidek g_destroy_geom(gp);
659080361d6SPawel Jakub Dawidek if (error != 0)
660080361d6SPawel Jakub Dawidek return (NULL);
661080361d6SPawel Jakub Dawidek gp = NULL;
662080361d6SPawel Jakub Dawidek
663080361d6SPawel Jakub Dawidek if (strcmp(md.md_magic, G_SHSEC_MAGIC) != 0)
664080361d6SPawel Jakub Dawidek return (NULL);
665080361d6SPawel Jakub Dawidek if (md.md_version > G_SHSEC_VERSION) {
666080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Kernel module is too old to handle %s.\n",
667080361d6SPawel Jakub Dawidek pp->name);
668080361d6SPawel Jakub Dawidek return (NULL);
669080361d6SPawel Jakub Dawidek }
670e6890985SPawel Jakub Dawidek /*
671e6890985SPawel Jakub Dawidek * Backward compatibility:
672e6890985SPawel Jakub Dawidek */
673e6890985SPawel Jakub Dawidek /* There was no md_provsize field in earlier versions of metadata. */
674e6890985SPawel Jakub Dawidek if (md.md_version < 1)
675e6890985SPawel Jakub Dawidek md.md_provsize = pp->mediasize;
676e6890985SPawel Jakub Dawidek
67790f2be24SAlexander Motin if (md.md_provider[0] != '\0' &&
67890f2be24SAlexander Motin !g_compare_names(md.md_provider, pp->name))
679080361d6SPawel Jakub Dawidek return (NULL);
680e6890985SPawel Jakub Dawidek if (md.md_provsize != pp->mediasize)
681e6890985SPawel Jakub Dawidek return (NULL);
682080361d6SPawel Jakub Dawidek
683080361d6SPawel Jakub Dawidek /*
684080361d6SPawel Jakub Dawidek * Let's check if device already exists.
685080361d6SPawel Jakub Dawidek */
686080361d6SPawel Jakub Dawidek sc = NULL;
687080361d6SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) {
688080361d6SPawel Jakub Dawidek sc = gp->softc;
689080361d6SPawel Jakub Dawidek if (sc == NULL)
690080361d6SPawel Jakub Dawidek continue;
691080361d6SPawel Jakub Dawidek if (strcmp(md.md_name, sc->sc_name) != 0)
692080361d6SPawel Jakub Dawidek continue;
693080361d6SPawel Jakub Dawidek if (md.md_id != sc->sc_id)
694080361d6SPawel Jakub Dawidek continue;
695080361d6SPawel Jakub Dawidek break;
696080361d6SPawel Jakub Dawidek }
697080361d6SPawel Jakub Dawidek if (gp != NULL) {
698080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name);
699080361d6SPawel Jakub Dawidek error = g_shsec_add_disk(sc, pp, md.md_no);
700080361d6SPawel Jakub Dawidek if (error != 0) {
701080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Cannot add disk %s to %s (error=%d).",
702080361d6SPawel Jakub Dawidek pp->name, gp->name, error);
703080361d6SPawel Jakub Dawidek return (NULL);
704080361d6SPawel Jakub Dawidek }
705080361d6SPawel Jakub Dawidek } else {
706080361d6SPawel Jakub Dawidek gp = g_shsec_create(mp, &md);
707080361d6SPawel Jakub Dawidek if (gp == NULL) {
708080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Cannot create device %s.", md.md_name);
709080361d6SPawel Jakub Dawidek return (NULL);
710080361d6SPawel Jakub Dawidek }
711080361d6SPawel Jakub Dawidek sc = gp->softc;
712080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(1, "Adding disk %s to %s.", pp->name, gp->name);
713080361d6SPawel Jakub Dawidek error = g_shsec_add_disk(sc, pp, md.md_no);
714080361d6SPawel Jakub Dawidek if (error != 0) {
715080361d6SPawel Jakub Dawidek G_SHSEC_DEBUG(0, "Cannot add disk %s to %s (error=%d).",
716080361d6SPawel Jakub Dawidek pp->name, gp->name, error);
717080361d6SPawel Jakub Dawidek g_shsec_destroy(sc, 1);
718080361d6SPawel Jakub Dawidek return (NULL);
719080361d6SPawel Jakub Dawidek }
720080361d6SPawel Jakub Dawidek }
721080361d6SPawel Jakub Dawidek return (gp);
722080361d6SPawel Jakub Dawidek }
723080361d6SPawel Jakub Dawidek
724080361d6SPawel Jakub Dawidek static struct g_shsec_softc *
g_shsec_find_device(struct g_class * mp,const char * name)725080361d6SPawel Jakub Dawidek g_shsec_find_device(struct g_class *mp, const char *name)
726080361d6SPawel Jakub Dawidek {
727080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
728080361d6SPawel Jakub Dawidek struct g_geom *gp;
729080361d6SPawel Jakub Dawidek
730080361d6SPawel Jakub Dawidek LIST_FOREACH(gp, &mp->geom, geom) {
731080361d6SPawel Jakub Dawidek sc = gp->softc;
732080361d6SPawel Jakub Dawidek if (sc == NULL)
733080361d6SPawel Jakub Dawidek continue;
734080361d6SPawel Jakub Dawidek if (strcmp(sc->sc_name, name) == 0)
735080361d6SPawel Jakub Dawidek return (sc);
736080361d6SPawel Jakub Dawidek }
737080361d6SPawel Jakub Dawidek return (NULL);
738080361d6SPawel Jakub Dawidek }
739080361d6SPawel Jakub Dawidek
740080361d6SPawel Jakub Dawidek static void
g_shsec_ctl_destroy(struct gctl_req * req,struct g_class * mp)741080361d6SPawel Jakub Dawidek g_shsec_ctl_destroy(struct gctl_req *req, struct g_class *mp)
742080361d6SPawel Jakub Dawidek {
743080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
744080361d6SPawel Jakub Dawidek int *force, *nargs, error;
745080361d6SPawel Jakub Dawidek const char *name;
746080361d6SPawel Jakub Dawidek char param[16];
747080361d6SPawel Jakub Dawidek u_int i;
748080361d6SPawel Jakub Dawidek
749080361d6SPawel Jakub Dawidek g_topology_assert();
750080361d6SPawel Jakub Dawidek
751080361d6SPawel Jakub Dawidek nargs = gctl_get_paraml(req, "nargs", sizeof(*nargs));
752080361d6SPawel Jakub Dawidek if (nargs == NULL) {
753080361d6SPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "nargs");
754080361d6SPawel Jakub Dawidek return;
755080361d6SPawel Jakub Dawidek }
756080361d6SPawel Jakub Dawidek if (*nargs <= 0) {
757080361d6SPawel Jakub Dawidek gctl_error(req, "Missing device(s).");
758080361d6SPawel Jakub Dawidek return;
759080361d6SPawel Jakub Dawidek }
760080361d6SPawel Jakub Dawidek force = gctl_get_paraml(req, "force", sizeof(*force));
761080361d6SPawel Jakub Dawidek if (force == NULL) {
762080361d6SPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "force");
763080361d6SPawel Jakub Dawidek return;
764080361d6SPawel Jakub Dawidek }
765080361d6SPawel Jakub Dawidek
766080361d6SPawel Jakub Dawidek for (i = 0; i < (u_int)*nargs; i++) {
767080361d6SPawel Jakub Dawidek snprintf(param, sizeof(param), "arg%u", i);
768080361d6SPawel Jakub Dawidek name = gctl_get_asciiparam(req, param);
769080361d6SPawel Jakub Dawidek if (name == NULL) {
770080361d6SPawel Jakub Dawidek gctl_error(req, "No 'arg%u' argument.", i);
771080361d6SPawel Jakub Dawidek return;
772080361d6SPawel Jakub Dawidek }
773080361d6SPawel Jakub Dawidek sc = g_shsec_find_device(mp, name);
774080361d6SPawel Jakub Dawidek if (sc == NULL) {
775080361d6SPawel Jakub Dawidek gctl_error(req, "No such device: %s.", name);
776080361d6SPawel Jakub Dawidek return;
777080361d6SPawel Jakub Dawidek }
778080361d6SPawel Jakub Dawidek error = g_shsec_destroy(sc, *force);
779080361d6SPawel Jakub Dawidek if (error != 0) {
780080361d6SPawel Jakub Dawidek gctl_error(req, "Cannot destroy device %s (error=%d).",
781080361d6SPawel Jakub Dawidek sc->sc_name, error);
782080361d6SPawel Jakub Dawidek return;
783080361d6SPawel Jakub Dawidek }
784080361d6SPawel Jakub Dawidek }
785080361d6SPawel Jakub Dawidek }
786080361d6SPawel Jakub Dawidek
787080361d6SPawel Jakub Dawidek static void
g_shsec_config(struct gctl_req * req,struct g_class * mp,const char * verb)788080361d6SPawel Jakub Dawidek g_shsec_config(struct gctl_req *req, struct g_class *mp, const char *verb)
789080361d6SPawel Jakub Dawidek {
790080361d6SPawel Jakub Dawidek uint32_t *version;
791080361d6SPawel Jakub Dawidek
792080361d6SPawel Jakub Dawidek g_topology_assert();
793080361d6SPawel Jakub Dawidek
794080361d6SPawel Jakub Dawidek version = gctl_get_paraml(req, "version", sizeof(*version));
795080361d6SPawel Jakub Dawidek if (version == NULL) {
796080361d6SPawel Jakub Dawidek gctl_error(req, "No '%s' argument.", "version");
797080361d6SPawel Jakub Dawidek return;
798080361d6SPawel Jakub Dawidek }
799080361d6SPawel Jakub Dawidek if (*version != G_SHSEC_VERSION) {
800080361d6SPawel Jakub Dawidek gctl_error(req, "Userland and kernel parts are out of sync.");
801080361d6SPawel Jakub Dawidek return;
802080361d6SPawel Jakub Dawidek }
803080361d6SPawel Jakub Dawidek
804080361d6SPawel Jakub Dawidek if (strcmp(verb, "stop") == 0) {
805080361d6SPawel Jakub Dawidek g_shsec_ctl_destroy(req, mp);
806080361d6SPawel Jakub Dawidek return;
807080361d6SPawel Jakub Dawidek }
808080361d6SPawel Jakub Dawidek
809080361d6SPawel Jakub Dawidek gctl_error(req, "Unknown verb.");
810080361d6SPawel Jakub Dawidek }
811080361d6SPawel Jakub Dawidek
812080361d6SPawel Jakub Dawidek static void
g_shsec_dumpconf(struct sbuf * sb,const char * indent,struct g_geom * gp,struct g_consumer * cp,struct g_provider * pp)813080361d6SPawel Jakub Dawidek g_shsec_dumpconf(struct sbuf *sb, const char *indent, struct g_geom *gp,
814080361d6SPawel Jakub Dawidek struct g_consumer *cp, struct g_provider *pp)
815080361d6SPawel Jakub Dawidek {
816080361d6SPawel Jakub Dawidek struct g_shsec_softc *sc;
817080361d6SPawel Jakub Dawidek
818080361d6SPawel Jakub Dawidek sc = gp->softc;
819080361d6SPawel Jakub Dawidek if (sc == NULL)
820080361d6SPawel Jakub Dawidek return;
821080361d6SPawel Jakub Dawidek if (pp != NULL) {
822080361d6SPawel Jakub Dawidek /* Nothing here. */
823080361d6SPawel Jakub Dawidek } else if (cp != NULL) {
824080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<Number>%u</Number>\n", indent,
825080361d6SPawel Jakub Dawidek (u_int)cp->index);
826080361d6SPawel Jakub Dawidek } else {
827080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<ID>%u</ID>\n", indent, (u_int)sc->sc_id);
828080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<Status>Total=%u, Online=%u</Status>\n",
829080361d6SPawel Jakub Dawidek indent, sc->sc_ndisks, g_shsec_nvalid(sc));
830080361d6SPawel Jakub Dawidek sbuf_printf(sb, "%s<State>", indent);
831080361d6SPawel Jakub Dawidek if (sc->sc_provider != NULL && sc->sc_provider->error == 0)
832080361d6SPawel Jakub Dawidek sbuf_printf(sb, "UP");
833080361d6SPawel Jakub Dawidek else
834080361d6SPawel Jakub Dawidek sbuf_printf(sb, "DOWN");
835080361d6SPawel Jakub Dawidek sbuf_printf(sb, "</State>\n");
836080361d6SPawel Jakub Dawidek }
837080361d6SPawel Jakub Dawidek }
838080361d6SPawel Jakub Dawidek
839080361d6SPawel Jakub Dawidek DECLARE_GEOM_CLASS(g_shsec_class, g_shsec);
84074d6c131SKyle Evans MODULE_VERSION(geom_shsec, 0);
841