summaryrefslogtreecommitdiff
path: root/sys/dev/raidframe/rf_engine.c
diff options
context:
space:
mode:
authorThierry Deval <tdeval@cvs.openbsd.org>2003-01-19 14:32:01 +0000
committerThierry Deval <tdeval@cvs.openbsd.org>2003-01-19 14:32:01 +0000
commit4313458ad98a8314c696b5100ea7cccd2b0923b3 (patch)
treee29062b45d1f0009c776864dd3bec06fbfcdb406 /sys/dev/raidframe/rf_engine.c
parent1f528c791537ae1f66aa5dac58dc2742c01d6c7f (diff)
Temporary fix for PR#3069 (thanks for the report, Alex Cichowski), until
I find time to really follow all cases. At least it works here, and doesn't add new problems, it seems.
Diffstat (limited to 'sys/dev/raidframe/rf_engine.c')
-rw-r--r--sys/dev/raidframe/rf_engine.c21
1 files changed, 11 insertions, 10 deletions
diff --git a/sys/dev/raidframe/rf_engine.c b/sys/dev/raidframe/rf_engine.c
index 458ab8c00b3..e30e9f9f56f 100644
--- a/sys/dev/raidframe/rf_engine.c
+++ b/sys/dev/raidframe/rf_engine.c
@@ -1,4 +1,4 @@
-/* $OpenBSD: rf_engine.c,v 1.13 2002/12/16 07:01:03 tdeval Exp $ */
+/* $OpenBSD: rf_engine.c,v 1.14 2003/01/19 14:32:00 tdeval Exp $ */
/* $NetBSD: rf_engine.c,v 1.10 2000/08/20 16:51:03 thorpej Exp $ */
/*
@@ -159,7 +159,8 @@ rf_ConfigureEngine(RF_ShutdownList_t **listp, RF_Raid_t *raidPtr,
* thread.
*/
if (rf_engineDebug) {
- printf("raid%d: Creating engine thread\n", raidPtr->raidid);
+ printf("raid%d: %s engine thread\n", raidPtr->raidid,
+ (initproc)?"Starting":"Creating");
}
if (rf_hook_cookies == NULL) {
rf_hook_cookies =
@@ -179,12 +180,12 @@ rf_ConfigureEngine(RF_ShutdownList_t **listp, RF_Raid_t *raidPtr,
snprintf(&raidname[0], 16, "raid%d", raidPtr->raidid);
if (RF_CREATE_THREAD(raidPtr->engine_thread,
rf_DAGExecutionThread, raidPtr, &raidname[0])) {
- RF_ERRORMSG("RAIDFRAME: Unable to create engine"
+ RF_ERRORMSG("RAIDFRAME: Unable to start engine"
" thread\n");
return (ENOMEM);
}
if (rf_engineDebug) {
- printf("raid%d: Created engine thread\n",
+ printf("raid%d: Engine thread started\n",
raidPtr->raidid);
}
RF_THREADGROUP_STARTED(&raidPtr->engine_tg);
@@ -306,7 +307,7 @@ rf_FireNode(RF_DagNode_t *node)
switch (node->status) {
case rf_fired:
/* Fire the do function of a node. */
- if (rf_engineDebug) {
+ if (rf_engineDebug>1) {
printf("raid%d: Firing node 0x%lx (%s)\n",
node->dagHdr->raidPtr->raidid,
(unsigned long) node, node->name);
@@ -327,7 +328,7 @@ rf_FireNode(RF_DagNode_t *node)
break;
case rf_recover:
/* Fire the undo function of a node. */
- if (rf_engineDebug) {
+ if (rf_engineDebug>1) {
printf("raid%d: Firing (undo) node 0x%lx (%s)\n",
node->dagHdr->raidPtr->raidid,
(unsigned long) node, node->name);
@@ -798,7 +799,7 @@ rf_DispatchDAG(RF_DagHeader_t *dag, void (*cbFunc) (void *), void *cbArg)
if (rf_ValidateDAG(dag))
RF_PANIC();
}
- if (rf_engineDebug) {
+ if (rf_engineDebug>1) {
printf("raid%d: Entering DispatchDAG\n", raidPtr->raidid);
}
raidPtr->dags_in_flight++; /*
@@ -839,7 +840,7 @@ rf_DAGExecutionThread_pre(RF_ThreadArg_t arg)
raidPtr = (RF_Raid_t *) arg;
if (rf_engineDebug) {
- printf("raid%d: Creating engine thread\n", raidPtr->raidid);
+ printf("raid%d: Starting engine thread\n", raidPtr->raidid);
}
lastpid = RF_ENGINE_PID + raidPtr->raidid - 1;
@@ -851,13 +852,13 @@ rf_DAGExecutionThread_pre(RF_ThreadArg_t arg)
if (RF_CREATE_THREAD(raidPtr->engine_thread, rf_DAGExecutionThread,
raidPtr, &raidname[0])) {
- RF_ERRORMSG("RAIDFRAME: Unable to create engine thread\n");
+ RF_ERRORMSG("RAIDFRAME: Unable to start engine thread\n");
return;
}
lastpid = oldpid;
if (rf_engineDebug) {
- printf("raid%d: Created engine thread\n", raidPtr->raidid);
+ printf("raid%d: Engine thread started\n", raidPtr->raidid);
}
RF_THREADGROUP_STARTED(&raidPtr->engine_tg);
}