From 224f25a6ab4e15e8b4743996e065dc7f1ebc5410 Mon Sep 17 00:00:00 2001
From: sof <unknown>
Date: Thu, 15 Jul 2004 20:50:40 +0000
Subject: [PATCH] [project @ 2004-07-15 20:50:40 by sof] oops, back out rev.
 1.31

---
 ghc/rts/Select.c |   23 ++++-------------------
 1 file changed, 4 insertions(+), 19 deletions(-)

diff --git a/ghc/rts/Select.c b/ghc/rts/Select.c
index 30e715e..223bdd6 100644
--- a/ghc/rts/Select.c
+++ b/ghc/rts/Select.c
@@ -1,5 +1,5 @@
 /* -----------------------------------------------------------------------------
- * $Id: Select.c,v 1.31 2004/07/15 20:42:45 sof Exp $
+ * $Id: Select.c,v 1.32 2004/07/15 20:50:40 sof Exp $
  *
  * (c) The GHC Team 1995-2002
  *
@@ -35,10 +35,6 @@
 #include <unistd.h>
 #endif
 
-#ifdef INTEGRITY
-#include <sys/socket.h>
-#endif
-
 /* last timestamp */
 nat timestamp = 0;
 
@@ -170,19 +166,7 @@ awaitEvent(rtsBool wait)
 
 #ifdef RTS_SUPPORTS_THREADS
       if(!workerWakeupInited) {
-#if defined(INTEGRITY)
-	int arg;
-	int rc = socketpair(AF_LOCAL, SOCK_STREAM, 0, workerWakeupPipe);
-	if (rc == -1) {
-	  printf("failed to create socketpair: %d\n", errno);
-	}
-	arg = fcntl(workerWakeupPipe[0], F_GETFL,0);
-	fcntl(workerWakeupPipe[0], F_SETFL, arg | O_NONBLOCK);
-	arg = fcntl(workerWakeupPipe[1], F_GETFL,0);
-	fcntl(workerWakeupPipe[1], F_SETFL, arg | O_NONBLOCK);
-#else
           pipe(workerWakeupPipe);
-#endif
           workerWakeupInited = rtsTrue;
       }
       FD_SET(workerWakeupPipe[0], &rfd);
@@ -361,9 +345,10 @@ wakeBlockedWorkerThread()
 {
     if(isWorkerBlockedInAwaitEvent && !workerWakeupPending) {
     	unsigned char dummy = 42;	// Any value will do here
-	// write something so that select() wakes up
-    	workerWakeupPending = rtsTrue;
+    	
+			// write something so that select() wakes up
     	write(workerWakeupPipe[1],&dummy,1);
+    	workerWakeupPending = rtsTrue;
     }
 }
 
-- 
1.7.10.4