projects
/
ghc-hetmet.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
[project @ 2004-09-29 09:49:21 by ross]
[ghc-hetmet.git]
/
ghc
/
rts
/
Select.c
diff --git
a/ghc/rts/Select.c
b/ghc/rts/Select.c
index
d7e6ffc
..
2687064
100644
(file)
--- a/
ghc/rts/Select.c
+++ b/
ghc/rts/Select.c
@@
-1,5
+1,4
@@
/* -----------------------------------------------------------------------------
/* -----------------------------------------------------------------------------
- * $Id: Select.c,v 1.30 2003/10/01 10:49:09 wolfgang Exp $
*
* (c) The GHC Team 1995-2002
*
*
* (c) The GHC Team 1995-2002
*
@@
-68,7
+67,7
@@
wakeUpSleepingThreads(nat ticks)
sleeping_queue = tso->link;
tso->why_blocked = NotBlocked;
tso->link = END_TSO_QUEUE;
sleeping_queue = tso->link;
tso->why_blocked = NotBlocked;
tso->link = END_TSO_QUEUE;
- IF_DEBUG(scheduler,belch("Waking up sleeping thread %d\n", tso->id));
+ IF_DEBUG(scheduler,debugBelch("Waking up sleeping thread %d\n", tso->id));
PUSH_ON_RUN_QUEUE(tso);
flag = rtsTrue;
}
PUSH_ON_RUN_QUEUE(tso);
flag = rtsTrue;
}
@@
-105,11
+104,11
@@
awaitEvent(rtsBool wait)
tv.tv_usec = 0;
IF_DEBUG(scheduler,
tv.tv_usec = 0;
IF_DEBUG(scheduler,
- belch("scheduler: checking for threads blocked on I/O");
+ debugBelch("scheduler: checking for threads blocked on I/O");
if (wait) {
if (wait) {
- belch(" (waiting)");
+ debugBelch(" (waiting)");
}
}
- belch("\n");
+ debugBelch("\n");
);
/* loop until we've woken up some threads. This loop is needed
);
/* loop until we've woken up some threads. This loop is needed
@@
-220,8
+219,6
@@
awaitEvent(rtsBool wait)
unblock_all = rtsTrue;
break;
} else {
unblock_all = rtsTrue;
break;
} else {
- fprintf(stderr,"%d\n", errno);
- fflush(stderr);
perror("select");
barf("select failed");
}
perror("select");
barf("select failed");
}
@@
-299,7
+296,7
@@
awaitEvent(rtsBool wait)
}
if (ready) {
}
if (ready) {
- IF_DEBUG(scheduler,belch("Waking up blocked thread %d\n", tso->id));
+ IF_DEBUG(scheduler,debugBelch("Waking up blocked thread %d\n", tso->id));
tso->why_blocked = NotBlocked;
tso->link = END_TSO_QUEUE;
PUSH_ON_RUN_QUEUE(tso);
tso->why_blocked = NotBlocked;
tso->link = END_TSO_QUEUE;
PUSH_ON_RUN_QUEUE(tso);