d/freebsd-skq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Introduce an SX lock which allows us to stall event processing

Browse Source 
during OAM operations.
This commit is contained in:
Poul-Henning Kamp 2003-03-23 21:58:09 +00:00
parent e2f9a08bb0
commit d943f1b0b9
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
sys/geom/geom_event.c
View File

@ -66,6 +66,7 @@ static u_int g_pending_events;
static void g_do_event(struct g_event *ep);
static TAILQ_HEAD(,g_provider) g_doorstep = TAILQ_HEAD_INITIALIZER(g_doorstep);
static struct mtx g_eventlock;
static struct sx g_eventstall;
static int g_shutdown;
void
@ -76,6 +77,20 @@ g_waitidle(void)
tsleep(&g_pending_events, PPAUSE, "g_waitidle", hz/5);
}
void
g_stall_events(void)
{
sx_slock(&g_eventstall);
}
void
g_release_events(void)
{
sx_sunlock(&g_eventstall);
}
void
g_orphan_provider(struct g_provider *pp, int error)
{
@ -220,6 +235,7 @@ one_event(void)
struct g_event *ep;
struct g_provider *pp;
sx_xlock(&g_eventstall);
g_topology_lock();
for (;;) {
mtx_lock(&g_eventlock);
@ -236,6 +252,7 @@ one_event(void)
if (ep == NULL) {
mtx_unlock(&g_eventlock);
g_topology_unlock();
sx_xunlock(&g_eventstall);
return (0);
}
TAILQ_REMOVE(&g_events, ep, events);
@ -254,6 +271,7 @@ one_event(void)
if (g_pending_events == 0)
wakeup(&g_pending_events);
g_topology_unlock();
sx_xunlock(&g_eventstall);
return (1);
}
@ -345,4 +363,5 @@ g_event_init()
SHUTDOWN_PRI_FIRST);
#endif
mtx_init(&g_eventlock, "GEOM orphanage", NULL, MTX_DEF);
sx_init(&g_eventstall, "GEOM event stalling");
}

2
sys/geom/geom_int.h
View File

@ -94,6 +94,8 @@ void g_conftxt(void *);
void g_event_init(void);
void g_post_event(enum g_events ev, struct g_class *mp, struct g_geom *gp, struct g_provider *pp, struct g_consumer *cp);
void g_run_events(void);
void g_stall_events(void);
void g_release_events(void);
/* geom_subr.c */
extern struct class_list_head g_classes;