summaryrefslogtreecommitdiff
path: root/sys/dev
diff options
context:
space:
mode:
authormrg <mrg@NetBSD.org>2011-05-01 10:01:01 +0000
committermrg <mrg@NetBSD.org>2011-05-01 10:01:01 +0000
commitf78020a2f433a44bef760cf9083cbc42ed37c360 (patch)
tree3bd2446ea252b48fb258526ac0ea67ef2fcc64a5 /sys/dev
parentaf1ef5cc31e6ff645ce013f4856cebc6602aed04 (diff)
convert eq_mutex to a kmutex.
convert ltsleep() used for plain timeout into kpause().
Diffstat (limited to 'sys/dev')
-rw-r--r--sys/dev/raidframe/rf_reconstruct.h4
-rw-r--r--sys/dev/raidframe/rf_reconutil.c8
-rw-r--r--sys/dev/raidframe/rf_revent.c24
-rw-r--r--sys/dev/raidframe/rf_threadstuff.h4
4 files changed, 21 insertions, 19 deletions
diff --git a/sys/dev/raidframe/rf_reconstruct.h b/sys/dev/raidframe/rf_reconstruct.h
index f67669eb5ba..ac616b2046b 100644
--- a/sys/dev/raidframe/rf_reconstruct.h
+++ b/sys/dev/raidframe/rf_reconstruct.h
@@ -1,4 +1,4 @@
-/* $NetBSD: rf_reconstruct.h,v 1.24 2008/05/19 19:49:55 oster Exp $ */
+/* $NetBSD: rf_reconstruct.h,v 1.25 2011/05/01 10:01:01 mrg Exp $ */
/*
* Copyright (c) 1995 Carnegie-Mellon University.
* All rights reserved.
@@ -137,7 +137,7 @@ struct RF_ReconCtrl_s {
/* reconstruction event queue */
RF_ReconEvent_t *eventQueue; /* queue of pending reconstruction
* events */
- RF_DECLARE_MUTEX(eq_mutex) /* mutex for locking event
+ rf_declare_mutex2(eq_mutex); /* mutex for locking event
* queue */
int eq_count; /* debug only */
diff --git a/sys/dev/raidframe/rf_reconutil.c b/sys/dev/raidframe/rf_reconutil.c
index 9e488b97b5b..515fdc4f2b2 100644
--- a/sys/dev/raidframe/rf_reconutil.c
+++ b/sys/dev/raidframe/rf_reconutil.c
@@ -1,4 +1,4 @@
-/* $NetBSD: rf_reconutil.c,v 1.29 2011/04/30 01:44:36 mrg Exp $ */
+/* $NetBSD: rf_reconutil.c,v 1.30 2011/05/01 10:01:01 mrg Exp $ */
/*
* Copyright (c) 1995 Carnegie-Mellon University.
* All rights reserved.
@@ -31,7 +31,7 @@
********************************************/
#include <sys/cdefs.h>
-__KERNEL_RCSID(0, "$NetBSD: rf_reconutil.c,v 1.29 2011/04/30 01:44:36 mrg Exp $");
+__KERNEL_RCSID(0, "$NetBSD: rf_reconutil.c,v 1.30 2011/05/01 10:01:01 mrg Exp $");
#include <dev/raidframe/raidframevar.h>
@@ -125,7 +125,7 @@ rf_MakeReconControl(RF_RaidReconDesc_t *reconDesc,
}
/* initialize the event queue */
- rf_mutex_init(&reconCtrlPtr->eq_mutex);
+ rf_init_mutex2(reconCtrlPtr->eq_mutex, IPL_VM);
reconCtrlPtr->eventQueue = NULL;
reconCtrlPtr->eq_count = 0;
@@ -171,6 +171,8 @@ rf_FreeReconControl(RF_Raid_t *raidPtr)
t = reconCtrlPtr->floatingRbufs;
}
+ rf_destroy_mutex2(reconCtrlPtr->eq_mutex);
+
rf_FreeReconMap(reconCtrlPtr->reconMap);
rf_FreeParityStripeStatusTable(raidPtr, reconCtrlPtr->pssTable);
RF_Free(reconCtrlPtr->perDiskInfo,
diff --git a/sys/dev/raidframe/rf_revent.c b/sys/dev/raidframe/rf_revent.c
index 94da52f7181..911c2abbde4 100644
--- a/sys/dev/raidframe/rf_revent.c
+++ b/sys/dev/raidframe/rf_revent.c
@@ -1,4 +1,4 @@
-/* $NetBSD: rf_revent.c,v 1.25 2008/05/19 19:49:55 oster Exp $ */
+/* $NetBSD: rf_revent.c,v 1.26 2011/05/01 10:01:01 mrg Exp $ */
/*
* Copyright (c) 1995 Carnegie-Mellon University.
* All rights reserved.
@@ -30,7 +30,7 @@
*/
#include <sys/cdefs.h>
-__KERNEL_RCSID(0, "$NetBSD: rf_revent.c,v 1.25 2008/05/19 19:49:55 oster Exp $");
+__KERNEL_RCSID(0, "$NetBSD: rf_revent.c,v 1.26 2011/05/01 10:01:01 mrg Exp $");
#include <sys/errno.h>
@@ -81,7 +81,7 @@ rf_GetNextReconEvent(RF_RaidReconDesc_t *reconDesc)
RF_ReconEvent_t *event;
int stall_count;
- RF_LOCK_MUTEX(rctrl->eq_mutex);
+ rf_lock_mutex2(rctrl->eq_mutex);
/* q null and count==0 must be equivalent conditions */
RF_ASSERT((rctrl->eventQueue == NULL) == (rctrl->eq_count == 0));
@@ -114,9 +114,8 @@ rf_GetNextReconEvent(RF_RaidReconDesc_t *reconDesc)
reconDesc->numReconExecDelays++;
#endif /* RF_RECON_STATS > 0 */
- status = ltsleep(&reconDesc->reconExecTicks, PRIBIO,
- "recon delay", RECON_TIMO,
- &rctrl->eq_mutex);
+ status = rf_sleep("rfrecond", RECON_TIMO,
+ rctrl->eq_mutex);
RF_ASSERT(status == EWOULDBLOCK);
reconDesc->reconExecTicks = 0;
}
@@ -128,8 +127,7 @@ rf_GetNextReconEvent(RF_RaidReconDesc_t *reconDesc)
reconDesc->numReconEventWaits++;
#endif /* RF_RECON_STATS > 0 */
- ltsleep(&(rctrl)->eventQueue, PRIBIO, "raidframe eventq",
- RF_EVENTQ_WAIT, &((rctrl)->eq_mutex));
+ rf_sleep("rfevq", RF_EVENTQ_WAIT, rctrl->eq_mutex);
stall_count++;
@@ -155,7 +153,7 @@ rf_GetNextReconEvent(RF_RaidReconDesc_t *reconDesc)
/* q null and count==0 must be equivalent conditions */
RF_ASSERT((rctrl->eventQueue == NULL) == (rctrl->eq_count == 0));
- RF_UNLOCK_MUTEX(rctrl->eq_mutex);
+ rf_unlock_mutex2(rctrl->eq_mutex);
return (event);
}
/* enqueues a reconstruction event on the indicated queue */
@@ -170,13 +168,13 @@ rf_CauseReconEvent(RF_Raid_t *raidPtr, RF_RowCol_t col, void *arg,
RF_ASSERT(col != rctrl->fcol);
}
RF_ASSERT(col >= 0 && col <= raidPtr->numCol);
- RF_LOCK_MUTEX(rctrl->eq_mutex);
+ rf_lock_mutex2(rctrl->eq_mutex);
/* q null and count==0 must be equivalent conditions */
RF_ASSERT((rctrl->eventQueue == NULL) == (rctrl->eq_count == 0));
event->next = rctrl->eventQueue;
rctrl->eventQueue = event;
rctrl->eq_count++;
- RF_UNLOCK_MUTEX(rctrl->eq_mutex);
+ rf_unlock_mutex2(rctrl->eq_mutex);
wakeup(&(rctrl)->eventQueue);
}
@@ -206,7 +204,7 @@ rf_DrainReconEventQueue(RF_RaidReconDesc_t *reconDesc)
RF_ReconCtrl_t *rctrl = reconDesc->raidPtr->reconControl;
RF_ReconEvent_t *event;
- RF_LOCK_MUTEX(rctrl->eq_mutex);
+ rf_lock_mutex2(rctrl->eq_mutex);
while (rctrl->eventQueue!=NULL) {
event = rctrl->eventQueue;
@@ -216,7 +214,7 @@ rf_DrainReconEventQueue(RF_RaidReconDesc_t *reconDesc)
/* dump it */
rf_FreeReconEventDesc(event);
}
- RF_UNLOCK_MUTEX(rctrl->eq_mutex);
+ rf_unlock_mutex2(rctrl->eq_mutex);
}
void
diff --git a/sys/dev/raidframe/rf_threadstuff.h b/sys/dev/raidframe/rf_threadstuff.h
index c27de0accd3..6a646c3f9aa 100644
--- a/sys/dev/raidframe/rf_threadstuff.h
+++ b/sys/dev/raidframe/rf_threadstuff.h
@@ -1,4 +1,4 @@
-/* $NetBSD: rf_threadstuff.h,v 1.26 2011/04/30 01:44:36 mrg Exp $ */
+/* $NetBSD: rf_threadstuff.h,v 1.27 2011/05/01 10:01:01 mrg Exp $ */
/*
* Copyright (c) 1995 Carnegie-Mellon University.
* All rights reserved.
@@ -91,6 +91,8 @@ typedef void *RF_ThreadArg_t;
#define rf_signal_cond2(_c_) cv_signal(&(_c_))
#define rf_broadcast_cond2(_c_) cv_broadcast(&(_c_))
+#define rf_sleep(_w_,_t_,_m_) kpause((_w_), false, (_t_), &(_m_))
+
/*
* In NetBSD, kernel threads are simply processes which share several
* substructures and never run in userspace.