1dd84a43cSPoul-Henning Kamp /*-
23728855aSPedro F. Giffuni * SPDX-License-Identifier: BSD-3-Clause
33728855aSPedro F. Giffuni *
4dd84a43cSPoul-Henning Kamp * Copyright (c) 2002 Poul-Henning Kamp
5dd84a43cSPoul-Henning Kamp * Copyright (c) 2002 Networks Associates Technology, Inc.
6dd84a43cSPoul-Henning Kamp * All rights reserved.
7dd84a43cSPoul-Henning Kamp *
8dd84a43cSPoul-Henning Kamp * This software was developed for the FreeBSD Project by Poul-Henning Kamp
9dd84a43cSPoul-Henning Kamp * and NAI Labs, the Security Research Division of Network Associates, Inc.
10dd84a43cSPoul-Henning Kamp * under DARPA/SPAWAR contract N66001-01-C-8035 ("CBOSS"), as part of the
11dd84a43cSPoul-Henning Kamp * DARPA CHATS research program.
12dd84a43cSPoul-Henning Kamp *
13dd84a43cSPoul-Henning Kamp * Redistribution and use in source and binary forms, with or without
14dd84a43cSPoul-Henning Kamp * modification, are permitted provided that the following conditions
15dd84a43cSPoul-Henning Kamp * are met:
16dd84a43cSPoul-Henning Kamp * 1. Redistributions of source code must retain the above copyright
17dd84a43cSPoul-Henning Kamp * notice, this list of conditions and the following disclaimer.
18dd84a43cSPoul-Henning Kamp * 2. Redistributions in binary form must reproduce the above copyright
19dd84a43cSPoul-Henning Kamp * notice, this list of conditions and the following disclaimer in the
20dd84a43cSPoul-Henning Kamp * documentation and/or other materials provided with the distribution.
21dd84a43cSPoul-Henning Kamp * 3. The names of the authors may not be used to endorse or promote
22dd84a43cSPoul-Henning Kamp * products derived from this software without specific prior written
23dd84a43cSPoul-Henning Kamp * permission.
24dd84a43cSPoul-Henning Kamp *
25dd84a43cSPoul-Henning Kamp * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
26dd84a43cSPoul-Henning Kamp * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
27dd84a43cSPoul-Henning Kamp * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
28dd84a43cSPoul-Henning Kamp * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
29dd84a43cSPoul-Henning Kamp * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
30dd84a43cSPoul-Henning Kamp * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
31dd84a43cSPoul-Henning Kamp * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
32dd84a43cSPoul-Henning Kamp * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
33dd84a43cSPoul-Henning Kamp * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
34dd84a43cSPoul-Henning Kamp * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
35dd84a43cSPoul-Henning Kamp * SUCH DAMAGE.
36dd84a43cSPoul-Henning Kamp */
37dd84a43cSPoul-Henning Kamp
38dd84a43cSPoul-Henning Kamp /*
39dd84a43cSPoul-Henning Kamp * XXX: How do we in general know that objects referenced in events
40dd84a43cSPoul-Henning Kamp * have not been destroyed before we get around to handle the event ?
41dd84a43cSPoul-Henning Kamp */
42dd84a43cSPoul-Henning Kamp
43dd84a43cSPoul-Henning Kamp #include <sys/param.h>
44dd84a43cSPoul-Henning Kamp #include <sys/malloc.h>
45dd84a43cSPoul-Henning Kamp #include <sys/systm.h>
46dd84a43cSPoul-Henning Kamp #include <sys/kernel.h>
47dd84a43cSPoul-Henning Kamp #include <sys/lock.h>
48dd84a43cSPoul-Henning Kamp #include <sys/mutex.h>
499197ce2eSPoul-Henning Kamp #include <sys/proc.h>
50dd84a43cSPoul-Henning Kamp #include <sys/errno.h>
51dd84a43cSPoul-Henning Kamp #include <sys/time.h>
52dd84a43cSPoul-Henning Kamp #include <geom/geom.h>
53b1876192SPoul-Henning Kamp #include <geom/geom_int.h>
54dd84a43cSPoul-Henning Kamp
559197ce2eSPoul-Henning Kamp #include <machine/stdarg.h>
569197ce2eSPoul-Henning Kamp
57a974614bSPoul-Henning Kamp TAILQ_HEAD(event_tailq_head, g_event);
58a974614bSPoul-Henning Kamp
59dd84a43cSPoul-Henning Kamp static struct event_tailq_head g_events = TAILQ_HEAD_INITIALIZER(g_events);
60abb50a48SPoul-Henning Kamp static u_int g_pending_events;
61dd84a43cSPoul-Henning Kamp static TAILQ_HEAD(,g_provider) g_doorstep = TAILQ_HEAD_INITIALIZER(g_doorstep);
62903e43feSPoul-Henning Kamp static struct mtx g_eventlock;
631b464bd8SPoul-Henning Kamp static int g_wither_work;
64dd84a43cSPoul-Henning Kamp
65a974614bSPoul-Henning Kamp #define G_N_EVENTREFS 20
66a974614bSPoul-Henning Kamp
67a974614bSPoul-Henning Kamp struct g_event {
68a974614bSPoul-Henning Kamp TAILQ_ENTRY(g_event) events;
69a974614bSPoul-Henning Kamp g_event_t *func;
700a9c130cSPoul-Henning Kamp void *arg;
710a9c130cSPoul-Henning Kamp int flag;
72a974614bSPoul-Henning Kamp void *ref[G_N_EVENTREFS];
73a974614bSPoul-Henning Kamp };
74a974614bSPoul-Henning Kamp
750a9c130cSPoul-Henning Kamp #define EV_DONE 0x80000
760a9c130cSPoul-Henning Kamp #define EV_WAKEUP 0x40000
77c8589ad1SPoul-Henning Kamp #define EV_CANCELED 0x20000
7859ccfe81SMatt Jacob #define EV_INPROGRESS 0x10000
790a9c130cSPoul-Henning Kamp
80dd84a43cSPoul-Henning Kamp void
g_waitidle(struct thread * td)81cc1ec772SKonstantin Belousov g_waitidle(struct thread *td)
82dd84a43cSPoul-Henning Kamp {
83dd84a43cSPoul-Henning Kamp
849197ce2eSPoul-Henning Kamp g_topology_assert_not();
859197ce2eSPoul-Henning Kamp
86e4da09c0SPoul-Henning Kamp mtx_lock(&g_eventlock);
878b8a7c43SColin Percival TSWAIT("GEOM events");
88e4da09c0SPoul-Henning Kamp while (!TAILQ_EMPTY(&g_events))
89e4da09c0SPoul-Henning Kamp msleep(&g_pending_events, &g_eventlock, PPAUSE,
90f4bf48c2SAlexander Motin "g_waitidle", 0);
918b8a7c43SColin Percival TSUNWAIT("GEOM events");
92e4da09c0SPoul-Henning Kamp mtx_unlock(&g_eventlock);
93cc1ec772SKonstantin Belousov td->td_pflags &= ~TDP_GEOM;
94dd84a43cSPoul-Henning Kamp }
95dd84a43cSPoul-Henning Kamp
96c6d31b83SKonstantin Belousov static void
ast_geom(struct thread * td,int tda __unused)97cc1ec772SKonstantin Belousov ast_geom(struct thread *td, int tda __unused)
98c6d31b83SKonstantin Belousov {
99c6d31b83SKonstantin Belousov /*
100c6d31b83SKonstantin Belousov * If this thread tickled GEOM, we need to wait for the giggling to
101c6d31b83SKonstantin Belousov * stop before we return to userland.
102c6d31b83SKonstantin Belousov */
103cc1ec772SKonstantin Belousov g_waitidle(td);
104c6d31b83SKonstantin Belousov }
105c6d31b83SKonstantin Belousov
106c6d31b83SKonstantin Belousov static void
geom_event_init(void * arg __unused)107c6d31b83SKonstantin Belousov geom_event_init(void *arg __unused)
108c6d31b83SKonstantin Belousov {
109c6d31b83SKonstantin Belousov ast_register(TDA_GEOM, ASTR_ASTF_REQUIRED | ASTR_TDP | ASTR_KCLEAR,
110c6d31b83SKonstantin Belousov TDP_GEOM, ast_geom);
111c6d31b83SKonstantin Belousov }
112c6d31b83SKonstantin Belousov SYSINIT(geom_event, SI_SUB_INTRINSIC, SI_ORDER_ANY, geom_event_init, NULL);
113c6d31b83SKonstantin Belousov
114416494d7SJustin T. Gibbs struct g_attrchanged_args {
115416494d7SJustin T. Gibbs struct g_provider *pp;
116416494d7SJustin T. Gibbs const char *attr;
117416494d7SJustin T. Gibbs };
118416494d7SJustin T. Gibbs
119416494d7SJustin T. Gibbs static void
g_attr_changed_event(void * arg,int flag)120416494d7SJustin T. Gibbs g_attr_changed_event(void *arg, int flag)
121416494d7SJustin T. Gibbs {
122416494d7SJustin T. Gibbs struct g_attrchanged_args *args;
123416494d7SJustin T. Gibbs struct g_provider *pp;
124416494d7SJustin T. Gibbs struct g_consumer *cp;
125416494d7SJustin T. Gibbs struct g_consumer *next_cp;
126416494d7SJustin T. Gibbs
127416494d7SJustin T. Gibbs args = arg;
128416494d7SJustin T. Gibbs pp = args->pp;
129416494d7SJustin T. Gibbs
130416494d7SJustin T. Gibbs g_topology_assert();
131416494d7SJustin T. Gibbs if (flag != EV_CANCEL && g_shutdown == 0) {
132416494d7SJustin T. Gibbs /*
133416494d7SJustin T. Gibbs * Tell all consumers of the change.
134416494d7SJustin T. Gibbs */
135416494d7SJustin T. Gibbs LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, next_cp) {
136416494d7SJustin T. Gibbs if (cp->geom->attrchanged != NULL)
137416494d7SJustin T. Gibbs cp->geom->attrchanged(cp, args->attr);
138416494d7SJustin T. Gibbs }
139416494d7SJustin T. Gibbs }
140416494d7SJustin T. Gibbs g_free(args);
141416494d7SJustin T. Gibbs }
142416494d7SJustin T. Gibbs
143416494d7SJustin T. Gibbs int
g_attr_changed(struct g_provider * pp,const char * attr,int flag)144416494d7SJustin T. Gibbs g_attr_changed(struct g_provider *pp, const char *attr, int flag)
145416494d7SJustin T. Gibbs {
146416494d7SJustin T. Gibbs struct g_attrchanged_args *args;
147416494d7SJustin T. Gibbs int error;
148416494d7SJustin T. Gibbs
149416494d7SJustin T. Gibbs args = g_malloc(sizeof *args, flag);
150416494d7SJustin T. Gibbs if (args == NULL)
151416494d7SJustin T. Gibbs return (ENOMEM);
152416494d7SJustin T. Gibbs args->pp = pp;
153416494d7SJustin T. Gibbs args->attr = attr;
154416494d7SJustin T. Gibbs error = g_post_event(g_attr_changed_event, args, flag, pp, NULL);
155416494d7SJustin T. Gibbs if (error != 0)
156416494d7SJustin T. Gibbs g_free(args);
157416494d7SJustin T. Gibbs return (error);
158416494d7SJustin T. Gibbs }
159416494d7SJustin T. Gibbs
160b8005b9bSPawel Jakub Dawidek void
g_orphan_provider(struct g_provider * pp,int error)161dd84a43cSPoul-Henning Kamp g_orphan_provider(struct g_provider *pp, int error)
162dd84a43cSPoul-Henning Kamp {
163dd84a43cSPoul-Henning Kamp
1643d1d5bc3SPoul-Henning Kamp /* G_VALID_PROVIDER(pp) We likely lack topology lock */
165dd84a43cSPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_orphan_provider(%p(%s), %d)",
166dd84a43cSPoul-Henning Kamp pp, pp->name, error);
167dd84a43cSPoul-Henning Kamp KASSERT(error != 0,
168dd84a43cSPoul-Henning Kamp ("g_orphan_provider(%p(%s), 0) error must be non-zero\n",
169dd84a43cSPoul-Henning Kamp pp, pp->name));
170d0265773SPoul-Henning Kamp
171dd84a43cSPoul-Henning Kamp pp->error = error;
172903e43feSPoul-Henning Kamp mtx_lock(&g_eventlock);
173d0265773SPoul-Henning Kamp KASSERT(!(pp->flags & G_PF_ORPHAN),
174d0265773SPoul-Henning Kamp ("g_orphan_provider(%p(%s)), already an orphan", pp, pp->name));
175d0265773SPoul-Henning Kamp pp->flags |= G_PF_ORPHAN;
176dd84a43cSPoul-Henning Kamp TAILQ_INSERT_TAIL(&g_doorstep, pp, orphan);
177903e43feSPoul-Henning Kamp mtx_unlock(&g_eventlock);
178dd84a43cSPoul-Henning Kamp wakeup(&g_wait_event);
179dd84a43cSPoul-Henning Kamp }
180dd84a43cSPoul-Henning Kamp
181dd84a43cSPoul-Henning Kamp /*
182dd84a43cSPoul-Henning Kamp * This function is called once on each provider which the event handler
183dd84a43cSPoul-Henning Kamp * finds on its g_doorstep.
184dd84a43cSPoul-Henning Kamp */
185dd84a43cSPoul-Henning Kamp
186dd84a43cSPoul-Henning Kamp static void
g_orphan_register(struct g_provider * pp)187b1876192SPoul-Henning Kamp g_orphan_register(struct g_provider *pp)
188dd84a43cSPoul-Henning Kamp {
189dd84a43cSPoul-Henning Kamp struct g_consumer *cp, *cp2;
1908592d7a7SPoul-Henning Kamp int wf;
191dd84a43cSPoul-Henning Kamp
192dd84a43cSPoul-Henning Kamp g_topology_assert();
1933d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp);
1943d1d5bc3SPoul-Henning Kamp g_trace(G_T_TOPOLOGY, "g_orphan_register(%s)", pp->name);
195dd84a43cSPoul-Henning Kamp
1963ea5d7ecSPawel Jakub Dawidek g_cancel_event(pp);
1973ea5d7ecSPawel Jakub Dawidek
1988592d7a7SPoul-Henning Kamp wf = pp->flags & G_PF_WITHER;
1998592d7a7SPoul-Henning Kamp pp->flags &= ~G_PF_WITHER;
2008592d7a7SPoul-Henning Kamp
201dd84a43cSPoul-Henning Kamp /*
202dd84a43cSPoul-Henning Kamp * Tell all consumers the bad news.
203f48b8819SPoul-Henning Kamp * Don't be surprised if they self-destruct.
204dd84a43cSPoul-Henning Kamp */
2053631c638SAlexander Motin LIST_FOREACH_SAFE(cp, &pp->consumers, consumers, cp2) {
20607d77fc6SPoul-Henning Kamp KASSERT(cp->geom->orphan != NULL,
20707d77fc6SPoul-Henning Kamp ("geom %s has no orphan, class %s",
20807d77fc6SPoul-Henning Kamp cp->geom->name, cp->geom->class->name));
209362073c0SAndrey V. Elsukov /*
210362073c0SAndrey V. Elsukov * XXX: g_dev_orphan method does deferred destroying
211362073c0SAndrey V. Elsukov * and it is possible, that other event could already
212362073c0SAndrey V. Elsukov * call the orphan method. Check consumer's flags to
213362073c0SAndrey V. Elsukov * do not schedule it twice.
214362073c0SAndrey V. Elsukov */
215362073c0SAndrey V. Elsukov if (cp->flags & G_CF_ORPHAN)
216362073c0SAndrey V. Elsukov continue;
2173631c638SAlexander Motin cp->flags |= G_CF_ORPHAN;
21807d77fc6SPoul-Henning Kamp cp->geom->orphan(cp);
219dd84a43cSPoul-Henning Kamp }
2208592d7a7SPoul-Henning Kamp if (LIST_EMPTY(&pp->consumers) && wf)
221b144e6ffSPoul-Henning Kamp g_destroy_provider(pp);
2228592d7a7SPoul-Henning Kamp else
2238592d7a7SPoul-Henning Kamp pp->flags |= wf;
22420d2026bSPoul-Henning Kamp #ifdef notyet
225e5829909SPoul-Henning Kamp cp = LIST_FIRST(&pp->consumers);
226e5829909SPoul-Henning Kamp if (cp != NULL)
227e5829909SPoul-Henning Kamp return;
228e5829909SPoul-Henning Kamp if (pp->geom->flags & G_GEOM_WITHER)
229e5829909SPoul-Henning Kamp g_destroy_provider(pp);
23020d2026bSPoul-Henning Kamp #endif
231dd84a43cSPoul-Henning Kamp }
232dd84a43cSPoul-Henning Kamp
233dd84a43cSPoul-Henning Kamp static int
one_event(void)234b1876192SPoul-Henning Kamp one_event(void)
235dd84a43cSPoul-Henning Kamp {
236dd84a43cSPoul-Henning Kamp struct g_event *ep;
237dd84a43cSPoul-Henning Kamp struct g_provider *pp;
238dd84a43cSPoul-Henning Kamp
239f7842e00SJaakko Heinonen g_topology_assert();
240903e43feSPoul-Henning Kamp mtx_lock(&g_eventlock);
2419794a803SAlexander Motin pp = TAILQ_FIRST(&g_doorstep);
2423d1d5bc3SPoul-Henning Kamp if (pp != NULL) {
2433d1d5bc3SPoul-Henning Kamp G_VALID_PROVIDER(pp);
244dd84a43cSPoul-Henning Kamp TAILQ_REMOVE(&g_doorstep, pp, orphan);
245903e43feSPoul-Henning Kamp mtx_unlock(&g_eventlock);
246b1876192SPoul-Henning Kamp g_orphan_register(pp);
247f7842e00SJaakko Heinonen return (1);
248dd84a43cSPoul-Henning Kamp }
249f7842e00SJaakko Heinonen
250dd84a43cSPoul-Henning Kamp ep = TAILQ_FIRST(&g_events);
251dd84a43cSPoul-Henning Kamp if (ep == NULL) {
252e4da09c0SPoul-Henning Kamp wakeup(&g_pending_events);
253dd84a43cSPoul-Henning Kamp return (0);
254dd84a43cSPoul-Henning Kamp }
25559ccfe81SMatt Jacob ep->flag |= EV_INPROGRESS;
256346cd5feSPoul-Henning Kamp mtx_unlock(&g_eventlock);
257d98777f8SPoul-Henning Kamp g_topology_assert();
258d98777f8SPoul-Henning Kamp ep->func(ep->arg, 0);
259d98777f8SPoul-Henning Kamp g_topology_assert();
260e4da09c0SPoul-Henning Kamp mtx_lock(&g_eventlock);
2618b8a7c43SColin Percival TSRELEASE("GEOM events");
262e4da09c0SPoul-Henning Kamp TAILQ_REMOVE(&g_events, ep, events);
26359ccfe81SMatt Jacob ep->flag &= ~EV_INPROGRESS;
2640a9c130cSPoul-Henning Kamp if (ep->flag & EV_WAKEUP) {
2650a9c130cSPoul-Henning Kamp ep->flag |= EV_DONE;
2660a9c130cSPoul-Henning Kamp wakeup(ep);
267f4bf48c2SAlexander Motin mtx_unlock(&g_eventlock);
2680a9c130cSPoul-Henning Kamp } else {
2699d142a6eSJaakko Heinonen mtx_unlock(&g_eventlock);
2709dfffbc9SPoul-Henning Kamp g_free(ep);
2710a9c130cSPoul-Henning Kamp }
272dd84a43cSPoul-Henning Kamp return (1);
273dd84a43cSPoul-Henning Kamp }
274dd84a43cSPoul-Henning Kamp
275dd84a43cSPoul-Henning Kamp void
g_run_events(void)276ac315343SDimitry Andric g_run_events(void)
277dd84a43cSPoul-Henning Kamp {
278dd84a43cSPoul-Henning Kamp
279f7842e00SJaakko Heinonen for (;;) {
280f7842e00SJaakko Heinonen g_topology_lock();
281b1876192SPoul-Henning Kamp while (one_event())
282dd84a43cSPoul-Henning Kamp ;
283f7842e00SJaakko Heinonen mtx_assert(&g_eventlock, MA_OWNED);
28450199fa0SAlexander Motin if (g_wither_work) {
28550199fa0SAlexander Motin g_wither_work = 0;
286f7842e00SJaakko Heinonen mtx_unlock(&g_eventlock);
28750199fa0SAlexander Motin g_wither_washer();
2881b464bd8SPoul-Henning Kamp g_topology_unlock();
289f7842e00SJaakko Heinonen } else {
290f7842e00SJaakko Heinonen g_topology_unlock();
291f7842e00SJaakko Heinonen msleep(&g_wait_event, &g_eventlock, PRIBIO | PDROP,
2929794a803SAlexander Motin "-", 0);
293f7842e00SJaakko Heinonen }
294f7842e00SJaakko Heinonen }
295f7842e00SJaakko Heinonen /* NOTREACHED */
296dd84a43cSPoul-Henning Kamp }
297dd84a43cSPoul-Henning Kamp
298dd84a43cSPoul-Henning Kamp void
g_cancel_event(void * ref)299afcbcfaeSPoul-Henning Kamp g_cancel_event(void *ref)
300dddc28bfSPoul-Henning Kamp {
301dddc28bfSPoul-Henning Kamp struct g_event *ep, *epn;
3022ab31b05SPoul-Henning Kamp struct g_provider *pp;
303afcbcfaeSPoul-Henning Kamp u_int n;
304dddc28bfSPoul-Henning Kamp
305dddc28bfSPoul-Henning Kamp mtx_lock(&g_eventlock);
3062ab31b05SPoul-Henning Kamp TAILQ_FOREACH(pp, &g_doorstep, orphan) {
3072ab31b05SPoul-Henning Kamp if (pp != ref)
3082ab31b05SPoul-Henning Kamp continue;
3092ab31b05SPoul-Henning Kamp TAILQ_REMOVE(&g_doorstep, pp, orphan);
3102ab31b05SPoul-Henning Kamp break;
3112ab31b05SPoul-Henning Kamp }
312e4da09c0SPoul-Henning Kamp TAILQ_FOREACH_SAFE(ep, &g_events, events, epn) {
31359ccfe81SMatt Jacob if (ep->flag & EV_INPROGRESS)
31459ccfe81SMatt Jacob continue;
315afcbcfaeSPoul-Henning Kamp for (n = 0; n < G_N_EVENTREFS; n++) {
316afcbcfaeSPoul-Henning Kamp if (ep->ref[n] == NULL)
317afcbcfaeSPoul-Henning Kamp break;
318e4da09c0SPoul-Henning Kamp if (ep->ref[n] != ref)
319e4da09c0SPoul-Henning Kamp continue;
3208b8a7c43SColin Percival TSRELEASE("GEOM events");
321dddc28bfSPoul-Henning Kamp TAILQ_REMOVE(&g_events, ep, events);
322316aed03SPoul-Henning Kamp ep->func(ep->arg, EV_CANCEL);
323e4da09c0SPoul-Henning Kamp mtx_assert(&g_eventlock, MA_OWNED);
3240a9c130cSPoul-Henning Kamp if (ep->flag & EV_WAKEUP) {
325e4da09c0SPoul-Henning Kamp ep->flag |= (EV_DONE|EV_CANCELED);
3260a9c130cSPoul-Henning Kamp wakeup(ep);
3270a9c130cSPoul-Henning Kamp } else {
3289dfffbc9SPoul-Henning Kamp g_free(ep);
3290a9c130cSPoul-Henning Kamp }
330afcbcfaeSPoul-Henning Kamp break;
331dddc28bfSPoul-Henning Kamp }
332afcbcfaeSPoul-Henning Kamp }
333e4da09c0SPoul-Henning Kamp if (TAILQ_EMPTY(&g_events))
334e4da09c0SPoul-Henning Kamp wakeup(&g_pending_events);
335dddc28bfSPoul-Henning Kamp mtx_unlock(&g_eventlock);
336dddc28bfSPoul-Henning Kamp }
337dddc28bfSPoul-Henning Kamp
338380710a5SWarner Losh struct g_event *
g_alloc_event(int flag)339380710a5SWarner Losh g_alloc_event(int flag)
340346cd5feSPoul-Henning Kamp {
341380710a5SWarner Losh KASSERT(flag == M_WAITOK || flag == M_NOWAIT,
342380710a5SWarner Losh ("Wrong flag to g_alloc_event"));
343380710a5SWarner Losh
344380710a5SWarner Losh return (g_malloc(sizeof(struct g_event), flag | M_ZERO));
345380710a5SWarner Losh }
346380710a5SWarner Losh
347380710a5SWarner Losh static void
g_post_event_ep_va(g_event_t * func,void * arg,int wuflag,struct g_event * ep,va_list ap)348380710a5SWarner Losh g_post_event_ep_va(g_event_t *func, void *arg, int wuflag,
349380710a5SWarner Losh struct g_event *ep, va_list ap)
350380710a5SWarner Losh {
351afcbcfaeSPoul-Henning Kamp void *p;
352afcbcfaeSPoul-Henning Kamp u_int n;
353346cd5feSPoul-Henning Kamp
354793ffa8eSPoul-Henning Kamp ep->flag = wuflag;
355afcbcfaeSPoul-Henning Kamp for (n = 0; n < G_N_EVENTREFS; n++) {
356afcbcfaeSPoul-Henning Kamp p = va_arg(ap, void *);
357afcbcfaeSPoul-Henning Kamp if (p == NULL)
358afcbcfaeSPoul-Henning Kamp break;
359afcbcfaeSPoul-Henning Kamp g_trace(G_T_TOPOLOGY, " ref %p", p);
360e0d617c1SPoul-Henning Kamp ep->ref[n] = p;
361afcbcfaeSPoul-Henning Kamp }
362afcbcfaeSPoul-Henning Kamp KASSERT(p == NULL, ("Too many references to event"));
363346cd5feSPoul-Henning Kamp ep->func = func;
364346cd5feSPoul-Henning Kamp ep->arg = arg;
365346cd5feSPoul-Henning Kamp mtx_lock(&g_eventlock);
3668b8a7c43SColin Percival TSHOLD("GEOM events");
367346cd5feSPoul-Henning Kamp TAILQ_INSERT_TAIL(&g_events, ep, events);
368346cd5feSPoul-Henning Kamp mtx_unlock(&g_eventlock);
369346cd5feSPoul-Henning Kamp wakeup(&g_wait_event);
3709197ce2eSPoul-Henning Kamp curthread->td_pflags |= TDP_GEOM;
371c6d31b83SKonstantin Belousov ast_sched(curthread, TDA_GEOM);
372380710a5SWarner Losh }
373380710a5SWarner Losh
374380710a5SWarner Losh void
g_post_event_ep(g_event_t * func,void * arg,struct g_event * ep,...)375380710a5SWarner Losh g_post_event_ep(g_event_t *func, void *arg, struct g_event *ep, ...)
376380710a5SWarner Losh {
377380710a5SWarner Losh va_list ap;
378380710a5SWarner Losh
379380710a5SWarner Losh va_start(ap, ep);
380380710a5SWarner Losh g_post_event_ep_va(func, arg, 0, ep, ap);
381380710a5SWarner Losh va_end(ap);
382380710a5SWarner Losh }
383380710a5SWarner Losh
384380710a5SWarner Losh
385380710a5SWarner Losh static int
g_post_event_x(g_event_t * func,void * arg,int flag,int wuflag,struct g_event ** epp,va_list ap)386380710a5SWarner Losh g_post_event_x(g_event_t *func, void *arg, int flag, int wuflag, struct g_event **epp, va_list ap)
387380710a5SWarner Losh {
388380710a5SWarner Losh struct g_event *ep;
389380710a5SWarner Losh
390380710a5SWarner Losh g_trace(G_T_TOPOLOGY, "g_post_event_x(%p, %p, %d, %d)",
391380710a5SWarner Losh func, arg, flag, wuflag);
392380710a5SWarner Losh KASSERT(wuflag == 0 || wuflag == EV_WAKEUP,
393380710a5SWarner Losh ("Wrong wuflag in g_post_event_x(0x%x)", wuflag));
394380710a5SWarner Losh ep = g_alloc_event(flag);
395380710a5SWarner Losh if (ep == NULL)
396380710a5SWarner Losh return (ENOMEM);
397380710a5SWarner Losh if (epp != NULL)
398380710a5SWarner Losh *epp = ep;
399380710a5SWarner Losh g_post_event_ep_va(func, arg, wuflag, ep, ap);
4000a9c130cSPoul-Henning Kamp return (0);
4010a9c130cSPoul-Henning Kamp }
4020a9c130cSPoul-Henning Kamp
4030a9c130cSPoul-Henning Kamp int
g_post_event(g_event_t * func,void * arg,int flag,...)4040a9c130cSPoul-Henning Kamp g_post_event(g_event_t *func, void *arg, int flag, ...)
4050a9c130cSPoul-Henning Kamp {
4060a9c130cSPoul-Henning Kamp va_list ap;
407a1a9b445SPoul-Henning Kamp int i;
4080a9c130cSPoul-Henning Kamp
4090a9c130cSPoul-Henning Kamp KASSERT(flag == M_WAITOK || flag == M_NOWAIT,
4100a9c130cSPoul-Henning Kamp ("Wrong flag to g_post_event"));
411a1a9b445SPoul-Henning Kamp va_start(ap, flag);
412793ffa8eSPoul-Henning Kamp i = g_post_event_x(func, arg, flag, 0, NULL, ap);
413a1a9b445SPoul-Henning Kamp va_end(ap);
414a1a9b445SPoul-Henning Kamp return (i);
4150a9c130cSPoul-Henning Kamp }
4160a9c130cSPoul-Henning Kamp
4171b464bd8SPoul-Henning Kamp void
g_do_wither(void)418ac315343SDimitry Andric g_do_wither(void)
419f7842e00SJaakko Heinonen {
4201b464bd8SPoul-Henning Kamp
421f7842e00SJaakko Heinonen mtx_lock(&g_eventlock);
4221b464bd8SPoul-Henning Kamp g_wither_work = 1;
423f7842e00SJaakko Heinonen mtx_unlock(&g_eventlock);
4241b464bd8SPoul-Henning Kamp wakeup(&g_wait_event);
4251b464bd8SPoul-Henning Kamp }
4260a9c130cSPoul-Henning Kamp
4270a9c130cSPoul-Henning Kamp /*
4280a9c130cSPoul-Henning Kamp * XXX: It might actually be useful to call this function with topology held.
4290a9c130cSPoul-Henning Kamp * XXX: This would ensure that the event gets created before anything else
4300a9c130cSPoul-Henning Kamp * XXX: changes. At present all users have a handle on things in some other
4310a9c130cSPoul-Henning Kamp * XXX: way, so this remains an XXX for now.
4320a9c130cSPoul-Henning Kamp */
4330a9c130cSPoul-Henning Kamp
4340a9c130cSPoul-Henning Kamp int
g_waitfor_event(g_event_t * func,void * arg,int flag,...)4350a9c130cSPoul-Henning Kamp g_waitfor_event(g_event_t *func, void *arg, int flag, ...)
4360a9c130cSPoul-Henning Kamp {
4370a9c130cSPoul-Henning Kamp va_list ap;
4380a9c130cSPoul-Henning Kamp struct g_event *ep;
4390a9c130cSPoul-Henning Kamp int error;
4400a9c130cSPoul-Henning Kamp
44118e88d82SPawel Jakub Dawidek g_topology_assert_not();
4420a9c130cSPoul-Henning Kamp KASSERT(flag == M_WAITOK || flag == M_NOWAIT,
4430a9c130cSPoul-Henning Kamp ("Wrong flag to g_post_event"));
444a1a9b445SPoul-Henning Kamp va_start(ap, flag);
445793ffa8eSPoul-Henning Kamp error = g_post_event_x(func, arg, flag, EV_WAKEUP, &ep, ap);
446a1a9b445SPoul-Henning Kamp va_end(ap);
4470a9c130cSPoul-Henning Kamp if (error)
4480a9c130cSPoul-Henning Kamp return (error);
4499d142a6eSJaakko Heinonen
4509d142a6eSJaakko Heinonen mtx_lock(&g_eventlock);
4519d142a6eSJaakko Heinonen while (!(ep->flag & EV_DONE))
452f4bf48c2SAlexander Motin msleep(ep, &g_eventlock, PRIBIO, "g_waitfor_event", 0);
453c8589ad1SPoul-Henning Kamp if (ep->flag & EV_CANCELED)
454c8589ad1SPoul-Henning Kamp error = EAGAIN;
4559d142a6eSJaakko Heinonen mtx_unlock(&g_eventlock);
4569d142a6eSJaakko Heinonen
4579dfffbc9SPoul-Henning Kamp g_free(ep);
458c8589ad1SPoul-Henning Kamp return (error);
459346cd5feSPoul-Henning Kamp }
460346cd5feSPoul-Henning Kamp
461dd84a43cSPoul-Henning Kamp void
g_event_init(void)462ac315343SDimitry Andric g_event_init(void)
463dd84a43cSPoul-Henning Kamp {
464dd84a43cSPoul-Henning Kamp
465903e43feSPoul-Henning Kamp mtx_init(&g_eventlock, "GEOM orphanage", NULL, MTX_DEF);
466dd84a43cSPoul-Henning Kamp }
467