dos -> unix

1 files changed, 428 insertions, 428 deletions

diff --git a/libX11/src/os2Stubs.c b/libX11/src/os2Stubs.c
index f1408095c..ee09cb5fe 100644
--- a/libX11/src/os2Stubs.c
+++ b/libX11/src/os2Stubs.c
@@ -1,428 +1,428 @@
-/*

- * (c) Copyright 1996 by Sebastien Marineau and Holger Veit

- *			<marineau@genie.uottawa.ca>

- *                      <Holger.Veit@gmd.de>

- *

- * Permission is hereby granted, free of charge, to any person obtaining a

- * copy of this software and associated documentation files (the "Software"),

- * to deal in the Software without restriction, including without limitation

- * the rights to use, copy, modify, merge, publish, distribute, sublicense,

- * and/or sell copies of the Software, and to permit persons to whom the

- * Software is furnished to do so, subject to the following conditions:

- *

- * The above copyright notice and this permission notice shall be included in

- * all copies or substantial portions of the Software.

- *

- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

- * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

- * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL

- * HOLGER VEIT  BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,

- * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF

- * OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

- * SOFTWARE.

- *

- * Except as contained in this notice, the name of Sebastien Marineau or Holger Veit

- * shall not be used in advertising or otherwise to promote the sale, use or other

- * dealings in this Software without prior written authorization from Holger Veit or

- * Sebastien Marineau.

- *

- */

-

-

-/* A few OS/2 functions needed in the X11 lib. Mainly, the file path redirection

- * functions and the "optimized" select() for the clients */

-

-#define I_NEED_OS2_H

-#ifdef HAVE_CONFIG_H

-#include <config.h>

-#endif

-#include <X11/Xpoll.h>

-#include <stdio.h>

-#include <sys/errno.h>

-#define INCL_DOSSEMAPHORES

-#define INCL_DOSNPIPES

-#define INCL_DOSMISC

-#define INCL_DOSMODULEMGR

-#undef BOOL

-#undef BYTE

-#include <os2.h>

-#include <sys/select.h>

-#include <sys/time.h>

-

-char *__XOS2RedirRoot(char *fname)

-{

-    /* This adds a further redirection by allowing the ProjectRoot

-     * to be prepended by the content of the envvar X11ROOT.

-     * This is for the purpose to move the whole X11 stuff to a different

-     * disk drive.

-     * The feature was added despite various environment variables

-     * because not all file opens respect them.

-     */

-    static char redirname[300]; /* enough for long filenames */

-    char *root;

-

-    /* if name does not start with /, assume it is not root-based */

-    if (fname==0 || !(fname[0]=='/' || fname[0]=='\\'))

-	return fname;

-

-    root = (char*)getenv("X11ROOT");

-    if (root==0 ||

-	(fname[1]==':' && isalpha(fname[0])) ||

-        (strlen(fname)+strlen(root)+2) > 300)

-	return fname;

-    sprintf(redirname,"%s%s",root,fname);

-    return redirname;

-}

-

-char *__XOS2RedirRoot1(char *format, char *arg1, char *arg2, char *arg3)

-{

-    /* this first constructs a name from a format and up to three

-     * components, then adds a path

-     */

-    char buf[300];

-    sprintf(buf,format,arg1,arg2,arg3);

-    return __XOS2RedirRoot(buf);

-}

-

-/* This below implements select() for the calls in this file. It has been */

-/* somewhat optimized for improved performance, but assumes a few */

-/* things so it cannot be used as a general select. If both pipes and     */

-/* sockets are present, this may call the emx select                          */

-

-

-HEV hPipeSem;

-HMODULE hmod_so32dll;

-static int (*os2_tcp_select)(int*,int,int,int,long);

-ULONG os2_get_sys_millis();

-extern int _files[];

-

-#define MAX_TCP 256

-/* These lifted from sys/emx.h. Change if that changes there! */

-#define F_SOCKET 0x10000000

-#define F_PIPE 0x20000000

-

-struct select_data

-{

-   fd_set read_copy;

-   fd_set write_copy;

-   BOOL have_read;

-   BOOL have_write;

-   int tcp_select_mask[MAX_TCP];

-   int tcp_emx_handles[MAX_TCP];

-   int tcp_select_copy[MAX_TCP];

-   int socket_nread;

-   int socket_nwrite;

-   int socket_ntotal;

-   int pipe_ntotal;

-   int pipe_have_write;

-   int max_fds;

-};

-

-int os2ClientSelect(int nfds, fd_set *readfds, fd_set *writefds,

-        fd_set *exceptfds, struct timeval *timeout)

-{

-static BOOL FirstTime=TRUE;

-static haveTCPIP=TRUE;

-ULONG timeout_ms;

-ULONG postCount, start_millis,now_millis;

-char faildata[16];

-struct select_data sd;

-BOOL any_ready;

-int np,ns, i,ready_handles,n;

-APIRET rc;

-

-sd.have_read=FALSE; sd.have_write=FALSE;

-sd.socket_nread=0; sd.socket_nwrite=0; sd.socket_ntotal=0;

-sd.max_fds=31; ready_handles=0; any_ready=FALSE;

-sd.pipe_ntotal=0; sd.pipe_have_write=FALSE;

-

-if(FirstTime){

-   /* First load the so32dll.dll module and get a pointer to the SELECT fn */

-

-   if((rc=DosLoadModule(faildata,sizeof(faildata),"SO32DLL",&hmod_so32dll))!=0){

-        fprintf(stderr, "Could not load module so32dll.dll, rc = %d. Error note %s\n",rc,faildata);

-        haveTCPIP=FALSE;

-        }

-   if((rc = DosQueryProcAddr(hmod_so32dll, 0, "SELECT", (PPFN)&os2_tcp_select))!=0){

-        fprintf(stderr, "Could not query address of SELECT, rc = %d.\n",rc);

-        haveTCPIP=FALSE;

-        }

-   /* Call these a first time to set the semaphore */

-    rc = DosCreateEventSem(NULL, &hPipeSem, DC_SEM_SHARED, FALSE);

-    if(rc) {

-             fprintf(stderr, "Could not create event semaphore, rc=%d\n",rc);

-             return(-1);

-             }

-    rc = DosResetEventSem(hPipeSem, &postCount);

-    FirstTime = FALSE;

-}

-

-/* Set up the time delay structs */

-

-    if(timeout!=NULL) {

-	timeout_ms=timeout->tv_sec*1000+timeout->tv_usec/1000;

-	}

-    else { timeout_ms=1000000; }  /* This should be large enough... */

-    if(timeout_ms>0) start_millis=os2_get_sys_millis();

-

-/* Copy the masks */

-    {FD_ZERO(&sd.read_copy);}

-    {FD_ZERO(&sd.write_copy);}

-    if(readfds!=NULL){ XFD_COPYSET(readfds,&sd.read_copy); sd.have_read=TRUE;}

-    if(writefds!=NULL) {XFD_COPYSET(writefds,&sd.write_copy);sd.have_write=TRUE;}

-

-/* And zero the original masks */

-    if(sd.have_read){ FD_ZERO(readfds);}

-    if(sd.have_write) {FD_ZERO(writefds);}

-    if(exceptfds != NULL) {FD_ZERO(exceptfds);}

-

-/* Now we parse the fd_sets passed to select and separate pipe/sockets */

-        n = os2_parse_select(&sd,nfds);

-        if(n == -1) {

-           errno = EBADF;

-           return (-1);

-           }

-

-/* Now we have three cases: either we have sockets, pipes, or both */

-/* We handle all three cases differently to optimize things */

-

-/* Case 1: only pipes! */

-        if((sd.pipe_ntotal >0) && (!sd.socket_ntotal)){

-            np = os2_check_pipes(&sd,readfds,writefds);

-            if(np > 0){

-               return (np);

-               }

-            else if (np == -1) { return(-1); }

-            while(!any_ready){

-                 rc = DosWaitEventSem(hPipeSem, timeout_ms);

-                 if(rc == 640)  {

-                     return(0);

-                     }

-                 if((rc != 0) && (rc != 95)) {errno= EBADF; return(-1);}

-                 np = os2_check_pipes(&sd,readfds,writefds);

-                 if (np > 0){

-                    return(np);

-                    }

-                 else if (np < 0){ return(-1); }

-                 }

-          }

-

-/* Case 2: only sockets. Just let the os/2 tcp select do the work */

-        if((sd.socket_ntotal > 0) && (!sd.pipe_ntotal)){

-                ns = os2_check_sockets(&sd, readfds, writefds, timeout_ms);

-                return (ns);

-                }

-

-/* Case 3: combination of both */

-        if((sd.socket_ntotal > 0) && (sd.pipe_ntotal)){

-           np = os2_check_pipes(&sd,readfds,writefds);

-              if(np > 0){

-                 any_ready=TRUE;

-                 ready_handles += np;

-                 }

-              else if (np == -1) { return(-1); }

-

-           ns = os2_check_sockets(&sd,readfds,writefds, 0);

-           if(ns>0){

-               ready_handles+=ns;

-               any_ready = TRUE;

-               }

-           else if (ns == -1) {return(-1);}

-

-           while (!any_ready && timeout_ms){

-

-                rc = DosWaitEventSem(hPipeSem, 10L);

-                if(rc == 0){

-                        np = os2_check_pipes(&sd,readfds,writefds);

-                        if(np > 0){

-                        ready_handles+=np;

-                        any_ready = TRUE;

-                        }

-                        else if (np == -1) {

-                                return(-1); }

-                      }

-

-                 ns = os2_check_sockets(&sd,readfds,writefds,exceptfds, 0);

-                 if(ns>0){

-                      ready_handles+=ns;

-                      any_ready = TRUE;

-                     }

-                 else if (ns == -1) {return(-1);}

-

-                  if (i%8 == 0) {

-                    now_millis = os2_get_sys_millis();

-                    if((now_millis-start_millis) > timeout_ms) timeout_ms = 0;

-                    }

-                   i++;

-                  }

-        }

-

-return(ready_handles);

-}

-

-

-ULONG os2_get_sys_millis()

-{

-   APIRET rc;

-   ULONG milli;

-

-   rc = DosQuerySysInfo(14, 14, &milli, sizeof(milli));

-   if(rc) {

-        fprintf(stderr,"Bad return code querying the millisecond counter! rc=%d\n",rc);

-        return(0);

-        }

-   return(milli);

-}

-

-int os2_parse_select(sd,nfds)

-struct select_data *sd;

-int nfds;

-{

-   int i;

-   APIRET rc;

-/* First we determine up to which descriptor we need to check.              */

-/* No need to check up to 256 if we don't have to (and usually we dont...)*/

-/* Note: stuff here is hardcoded for fd_sets which are int[8] as in EMX!!!    */

-

-  if(nfds > sd->max_fds){

-     for(i=0;i<((FD_SETSIZE+31)/32);i++){

-        if(sd->read_copy.fds_bits[i] ||

-            sd->write_copy.fds_bits[i])

-                        sd->max_fds=(i*32) +32;

-        }

-     }

-   else { sd->max_fds = nfds; }

-/* Check if result is greater than specified in select() call */

-  if(sd->max_fds > nfds) sd->max_fds = nfds;

-

-  if (sd->have_read)

-    {

-      for (i = 0; i < sd->max_fds; ++i) {

-        if (FD_ISSET (i, &sd->read_copy)){

-         if(_files[i] & F_SOCKET)

-           {

-            sd->tcp_select_mask[sd->socket_ntotal]=_getsockhandle(i);

-            sd->tcp_emx_handles[sd->socket_ntotal]=i;

-            sd->socket_ntotal++; sd->socket_nread++;

-           }

-         else if (_files[i] & F_PIPE)

-          {

-            sd -> pipe_ntotal++;

-            rc = DosSetNPipeSem((HPIPE)i, (HSEM) hPipeSem, i);

-            if(rc) { fprintf(stderr,"Error SETNPIPE rc = %d\n",rc); return -1;}

-          }

-        }

-      }

-    }

-

-  if (sd->have_write)

-    {

-      for (i = 0; i < sd->max_fds; ++i) {

-        if (FD_ISSET (i, &sd->write_copy)){

-         if(_files[i] & F_SOCKET)

-         {

-            sd->tcp_select_mask[sd->socket_ntotal]=_getsockhandle(i);

-            sd->tcp_emx_handles[sd->socket_ntotal]=i;

-            sd->socket_ntotal++; sd->socket_nwrite++;

-         }

-         else if (_files[i] & F_PIPE)

-          {

-            sd -> pipe_ntotal++;

-            rc = DosSetNPipeSem((HPIPE)i, (HSEM) hPipeSem, i);

-            if(rc) { fprintf(stderr,"Error SETNPIPE rc = %d\n",rc); return -1;}

-            sd -> pipe_have_write=TRUE;

-          }

-        }

-      }

-    }

-

-

-return(sd->socket_ntotal);

-}

-

-

-int os2_check_sockets(sd,readfds,writefds)

-struct select_data *sd;

-fd_set *readfds,*writefds;

-{

-   int e,i;

-   int j,n;

-        memcpy(sd->tcp_select_copy,sd->tcp_select_mask,

-                sd->socket_ntotal*sizeof(int));

-

-        e = os2_tcp_select(sd->tcp_select_copy,sd->socket_nread,

-                sd->socket_nwrite, 0, 0);

-

-        if(e == 0) return(e);

-/* We have something ready? */

-        if(e>0){

-            j = 0; n = 0;

-            for (i = 0; i < sd->socket_nread; ++i, ++j)

-                 if (sd->tcp_select_copy[j] != -1)

-                    {

-                    FD_SET (sd->tcp_emx_handles[j], readfds);

-                    n ++;

-                    }

-             for (i = 0; i < sd->socket_nwrite; ++i, ++j)

-                  if (sd->tcp_select_copy[j] != -1)

-                     {

-                     FD_SET (sd->tcp_emx_handles[j], writefds);

-                     n ++;

-                     }

-               errno = 0;

-

-               return n;

-              }

-        if(e<0){

-           /*Error -- TODO */

-           fprintf(stderr,"Error in server select! e=%d\n",e);

-           errno = EBADF;

-           return (-1);

-           }

- }

-

-/* Check to see if anything is ready on pipes */

-

-int os2_check_pipes(sd,readfds,writefds)

-struct select_data *sd;

-fd_set *readfds,*writefds;

-{

-int i,e;

-ULONG ulPostCount;

-PIPESEMSTATE pipeSemState[128];

-APIRET rc;

-        e = 0;

-        rc = DosResetEventSem(hPipeSem,&ulPostCount);

-        rc = DosQueryNPipeSemState((HSEM) hPipeSem, (PPIPESEMSTATE)&pipeSemState,

-                sizeof(pipeSemState));

-        if(rc) fprintf(stderr,"SELECT: rc from QueryNPipeSem: %d\n",rc);

-        i=0;

-        while (pipeSemState[i].fStatus != 0) {

-           /*fprintf(stderr,"SELECT: sem entry, stat=%d, flag=%d, key=%d,avail=%d\n",

-                pipeSemState[i].fStatus,pipeSemState[i].fFlag,pipeSemState[i].usKey,

-                pipeSemState[i].usAvail); */

-           if((pipeSemState[i].fStatus == 1) &&

-                    (FD_ISSET(pipeSemState[i].usKey,&sd->read_copy))){

-                FD_SET(pipeSemState[i].usKey,readfds);

-                e++;

-                }

-           else if((pipeSemState[i].fStatus == 2)  &&

-                    (FD_ISSET(pipeSemState[i].usKey,&sd->write_copy))){

-                FD_SET(pipeSemState[i].usKey,writefds);

-                e++;

-                }

-            else if( (pipeSemState[i].fStatus == 3) &&

-                ( (FD_ISSET(pipeSemState[i].usKey,&sd->read_copy)) ||

-                  (FD_ISSET(pipeSemState[i].usKey,&sd->write_copy)) )){

-                errno = EBADF;

-                return (-1);

-                }

-            i++;

-            } /* endwhile */

-        /*fprintf(stderr,"Done listing pipe sem entries, total %d entries, total ready entries %d\n",i,e);*/

-errno = 0;

-return(e);

-}

-

-

-

+/*
+ * (c) Copyright 1996 by Sebastien Marineau and Holger Veit
+ *			<marineau@genie.uottawa.ca>
+ *                      <Holger.Veit@gmd.de>
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * HOLGER VEIT  BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
+ * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF
+ * OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ *
+ * Except as contained in this notice, the name of Sebastien Marineau or Holger Veit
+ * shall not be used in advertising or otherwise to promote the sale, use or other
+ * dealings in this Software without prior written authorization from Holger Veit or
+ * Sebastien Marineau.
+ *
+ */
+
+
+/* A few OS/2 functions needed in the X11 lib. Mainly, the file path redirection
+ * functions and the "optimized" select() for the clients */
+
+#define I_NEED_OS2_H
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+#include <X11/Xpoll.h>
+#include <stdio.h>
+#include <sys/errno.h>
+#define INCL_DOSSEMAPHORES
+#define INCL_DOSNPIPES
+#define INCL_DOSMISC
+#define INCL_DOSMODULEMGR
+#undef BOOL
+#undef BYTE
+#include <os2.h>
+#include <sys/select.h>
+#include <sys/time.h>
+
+char *__XOS2RedirRoot(char *fname)
+{
+    /* This adds a further redirection by allowing the ProjectRoot
+     * to be prepended by the content of the envvar X11ROOT.
+     * This is for the purpose to move the whole X11 stuff to a different
+     * disk drive.
+     * The feature was added despite various environment variables
+     * because not all file opens respect them.
+     */
+    static char redirname[300]; /* enough for long filenames */
+    char *root;
+
+    /* if name does not start with /, assume it is not root-based */
+    if (fname==0 || !(fname[0]=='/' || fname[0]=='\\'))
+	return fname;
+
+    root = (char*)getenv("X11ROOT");
+    if (root==0 ||
+	(fname[1]==':' && isalpha(fname[0])) ||
+        (strlen(fname)+strlen(root)+2) > 300)
+	return fname;
+    sprintf(redirname,"%s%s",root,fname);
+    return redirname;
+}
+
+char *__XOS2RedirRoot1(char *format, char *arg1, char *arg2, char *arg3)
+{
+    /* this first constructs a name from a format and up to three
+     * components, then adds a path
+     */
+    char buf[300];
+    sprintf(buf,format,arg1,arg2,arg3);
+    return __XOS2RedirRoot(buf);
+}
+
+/* This below implements select() for the calls in this file. It has been */
+/* somewhat optimized for improved performance, but assumes a few */
+/* things so it cannot be used as a general select. If both pipes and     */
+/* sockets are present, this may call the emx select                          */
+
+
+HEV hPipeSem;
+HMODULE hmod_so32dll;
+static int (*os2_tcp_select)(int*,int,int,int,long);
+ULONG os2_get_sys_millis();
+extern int _files[];
+
+#define MAX_TCP 256
+/* These lifted from sys/emx.h. Change if that changes there! */
+#define F_SOCKET 0x10000000
+#define F_PIPE 0x20000000
+
+struct select_data
+{
+   fd_set read_copy;
+   fd_set write_copy;
+   BOOL have_read;
+   BOOL have_write;
+   int tcp_select_mask[MAX_TCP];
+   int tcp_emx_handles[MAX_TCP];
+   int tcp_select_copy[MAX_TCP];
+   int socket_nread;
+   int socket_nwrite;
+   int socket_ntotal;
+   int pipe_ntotal;
+   int pipe_have_write;
+   int max_fds;
+};
+
+int os2ClientSelect(int nfds, fd_set *readfds, fd_set *writefds,
+        fd_set *exceptfds, struct timeval *timeout)
+{
+static BOOL FirstTime=TRUE;
+static haveTCPIP=TRUE;
+ULONG timeout_ms;
+ULONG postCount, start_millis,now_millis;
+char faildata[16];
+struct select_data sd;
+BOOL any_ready;
+int np,ns, i,ready_handles,n;
+APIRET rc;
+
+sd.have_read=FALSE; sd.have_write=FALSE;
+sd.socket_nread=0; sd.socket_nwrite=0; sd.socket_ntotal=0;
+sd.max_fds=31; ready_handles=0; any_ready=FALSE;
+sd.pipe_ntotal=0; sd.pipe_have_write=FALSE;
+
+if(FirstTime){
+   /* First load the so32dll.dll module and get a pointer to the SELECT fn */
+
+   if((rc=DosLoadModule(faildata,sizeof(faildata),"SO32DLL",&hmod_so32dll))!=0){
+        fprintf(stderr, "Could not load module so32dll.dll, rc = %d. Error note %s\n",rc,faildata);
+        haveTCPIP=FALSE;
+        }
+   if((rc = DosQueryProcAddr(hmod_so32dll, 0, "SELECT", (PPFN)&os2_tcp_select))!=0){
+        fprintf(stderr, "Could not query address of SELECT, rc = %d.\n",rc);
+        haveTCPIP=FALSE;
+        }
+   /* Call these a first time to set the semaphore */
+    rc = DosCreateEventSem(NULL, &hPipeSem, DC_SEM_SHARED, FALSE);
+    if(rc) {
+             fprintf(stderr, "Could not create event semaphore, rc=%d\n",rc);
+             return(-1);
+             }
+    rc = DosResetEventSem(hPipeSem, &postCount);
+    FirstTime = FALSE;
+}
+
+/* Set up the time delay structs */
+
+    if(timeout!=NULL) {
+	timeout_ms=timeout->tv_sec*1000+timeout->tv_usec/1000;
+	}
+    else { timeout_ms=1000000; }  /* This should be large enough... */
+    if(timeout_ms>0) start_millis=os2_get_sys_millis();
+
+/* Copy the masks */
+    {FD_ZERO(&sd.read_copy);}
+    {FD_ZERO(&sd.write_copy);}
+    if(readfds!=NULL){ XFD_COPYSET(readfds,&sd.read_copy); sd.have_read=TRUE;}
+    if(writefds!=NULL) {XFD_COPYSET(writefds,&sd.write_copy);sd.have_write=TRUE;}
+
+/* And zero the original masks */
+    if(sd.have_read){ FD_ZERO(readfds);}
+    if(sd.have_write) {FD_ZERO(writefds);}
+    if(exceptfds != NULL) {FD_ZERO(exceptfds);}
+
+/* Now we parse the fd_sets passed to select and separate pipe/sockets */
+        n = os2_parse_select(&sd,nfds);
+        if(n == -1) {
+           errno = EBADF;
+           return (-1);
+           }
+
+/* Now we have three cases: either we have sockets, pipes, or both */
+/* We handle all three cases differently to optimize things */
+
+/* Case 1: only pipes! */
+        if((sd.pipe_ntotal >0) && (!sd.socket_ntotal)){
+            np = os2_check_pipes(&sd,readfds,writefds);
+            if(np > 0){
+               return (np);
+               }
+            else if (np == -1) { return(-1); }
+            while(!any_ready){
+                 rc = DosWaitEventSem(hPipeSem, timeout_ms);
+                 if(rc == 640)  {
+                     return(0);
+                     }
+                 if((rc != 0) && (rc != 95)) {errno= EBADF; return(-1);}
+                 np = os2_check_pipes(&sd,readfds,writefds);
+                 if (np > 0){
+                    return(np);
+                    }
+                 else if (np < 0){ return(-1); }
+                 }
+          }
+
+/* Case 2: only sockets. Just let the os/2 tcp select do the work */
+        if((sd.socket_ntotal > 0) && (!sd.pipe_ntotal)){
+                ns = os2_check_sockets(&sd, readfds, writefds, timeout_ms);
+                return (ns);
+                }
+
+/* Case 3: combination of both */
+        if((sd.socket_ntotal > 0) && (sd.pipe_ntotal)){
+           np = os2_check_pipes(&sd,readfds,writefds);
+              if(np > 0){
+                 any_ready=TRUE;
+                 ready_handles += np;
+                 }
+              else if (np == -1) { return(-1); }
+
+           ns = os2_check_sockets(&sd,readfds,writefds, 0);
+           if(ns>0){
+               ready_handles+=ns;
+               any_ready = TRUE;
+               }
+           else if (ns == -1) {return(-1);}
+
+           while (!any_ready && timeout_ms){
+
+                rc = DosWaitEventSem(hPipeSem, 10L);
+                if(rc == 0){
+                        np = os2_check_pipes(&sd,readfds,writefds);
+                        if(np > 0){
+                        ready_handles+=np;
+                        any_ready = TRUE;
+                        }
+                        else if (np == -1) {
+                                return(-1); }
+                      }
+
+                 ns = os2_check_sockets(&sd,readfds,writefds,exceptfds, 0);
+                 if(ns>0){
+                      ready_handles+=ns;
+                      any_ready = TRUE;
+                     }
+                 else if (ns == -1) {return(-1);}
+
+                  if (i%8 == 0) {
+                    now_millis = os2_get_sys_millis();
+                    if((now_millis-start_millis) > timeout_ms) timeout_ms = 0;
+                    }
+                   i++;
+                  }
+        }
+
+return(ready_handles);
+}
+
+
+ULONG os2_get_sys_millis()
+{
+   APIRET rc;
+   ULONG milli;
+
+   rc = DosQuerySysInfo(14, 14, &milli, sizeof(milli));
+   if(rc) {
+        fprintf(stderr,"Bad return code querying the millisecond counter! rc=%d\n",rc);
+        return(0);
+        }
+   return(milli);
+}
+
+int os2_parse_select(sd,nfds)
+struct select_data *sd;
+int nfds;
+{
+   int i;
+   APIRET rc;
+/* First we determine up to which descriptor we need to check.              */
+/* No need to check up to 256 if we don't have to (and usually we dont...)*/
+/* Note: stuff here is hardcoded for fd_sets which are int[8] as in EMX!!!    */
+
+  if(nfds > sd->max_fds){
+     for(i=0;i<((FD_SETSIZE+31)/32);i++){
+        if(sd->read_copy.fds_bits[i] ||
+            sd->write_copy.fds_bits[i])
+                        sd->max_fds=(i*32) +32;
+        }
+     }
+   else { sd->max_fds = nfds; }
+/* Check if result is greater than specified in select() call */
+  if(sd->max_fds > nfds) sd->max_fds = nfds;
+
+  if (sd->have_read)
+    {
+      for (i = 0; i < sd->max_fds; ++i) {
+        if (FD_ISSET (i, &sd->read_copy)){
+         if(_files[i] & F_SOCKET)
+           {
+            sd->tcp_select_mask[sd->socket_ntotal]=_getsockhandle(i);
+            sd->tcp_emx_handles[sd->socket_ntotal]=i;
+            sd->socket_ntotal++; sd->socket_nread++;
+           }
+         else if (_files[i] & F_PIPE)
+          {
+            sd -> pipe_ntotal++;
+            rc = DosSetNPipeSem((HPIPE)i, (HSEM) hPipeSem, i);
+            if(rc) { fprintf(stderr,"Error SETNPIPE rc = %d\n",rc); return -1;}
+          }
+        }
+      }
+    }
+
+  if (sd->have_write)
+    {
+      for (i = 0; i < sd->max_fds; ++i) {
+        if (FD_ISSET (i, &sd->write_copy)){
+         if(_files[i] & F_SOCKET)
+         {
+            sd->tcp_select_mask[sd->socket_ntotal]=_getsockhandle(i);
+            sd->tcp_emx_handles[sd->socket_ntotal]=i;
+            sd->socket_ntotal++; sd->socket_nwrite++;
+         }
+         else if (_files[i] & F_PIPE)
+          {
+            sd -> pipe_ntotal++;
+            rc = DosSetNPipeSem((HPIPE)i, (HSEM) hPipeSem, i);
+            if(rc) { fprintf(stderr,"Error SETNPIPE rc = %d\n",rc); return -1;}
+            sd -> pipe_have_write=TRUE;
+          }
+        }
+      }
+    }
+
+
+return(sd->socket_ntotal);
+}
+
+
+int os2_check_sockets(sd,readfds,writefds)
+struct select_data *sd;
+fd_set *readfds,*writefds;
+{
+   int e,i;
+   int j,n;
+        memcpy(sd->tcp_select_copy,sd->tcp_select_mask,
+                sd->socket_ntotal*sizeof(int));
+
+        e = os2_tcp_select(sd->tcp_select_copy,sd->socket_nread,
+                sd->socket_nwrite, 0, 0);
+
+        if(e == 0) return(e);
+/* We have something ready? */
+        if(e>0){
+            j = 0; n = 0;
+            for (i = 0; i < sd->socket_nread; ++i, ++j)
+                 if (sd->tcp_select_copy[j] != -1)
+                    {
+                    FD_SET (sd->tcp_emx_handles[j], readfds);
+                    n ++;
+                    }
+             for (i = 0; i < sd->socket_nwrite; ++i, ++j)
+                  if (sd->tcp_select_copy[j] != -1)
+                     {
+                     FD_SET (sd->tcp_emx_handles[j], writefds);
+                     n ++;
+                     }
+               errno = 0;
+
+               return n;
+              }
+        if(e<0){
+           /*Error -- TODO */
+           fprintf(stderr,"Error in server select! e=%d\n",e);
+           errno = EBADF;
+           return (-1);
+           }
+ }
+
+/* Check to see if anything is ready on pipes */
+
+int os2_check_pipes(sd,readfds,writefds)
+struct select_data *sd;
+fd_set *readfds,*writefds;
+{
+int i,e;
+ULONG ulPostCount;
+PIPESEMSTATE pipeSemState[128];
+APIRET rc;
+        e = 0;
+        rc = DosResetEventSem(hPipeSem,&ulPostCount);
+        rc = DosQueryNPipeSemState((HSEM) hPipeSem, (PPIPESEMSTATE)&pipeSemState,
+                sizeof(pipeSemState));
+        if(rc) fprintf(stderr,"SELECT: rc from QueryNPipeSem: %d\n",rc);
+        i=0;
+        while (pipeSemState[i].fStatus != 0) {
+           /*fprintf(stderr,"SELECT: sem entry, stat=%d, flag=%d, key=%d,avail=%d\n",
+                pipeSemState[i].fStatus,pipeSemState[i].fFlag,pipeSemState[i].usKey,
+                pipeSemState[i].usAvail); */
+           if((pipeSemState[i].fStatus == 1) &&
+                    (FD_ISSET(pipeSemState[i].usKey,&sd->read_copy))){
+                FD_SET(pipeSemState[i].usKey,readfds);
+                e++;
+                }
+           else if((pipeSemState[i].fStatus == 2)  &&
+                    (FD_ISSET(pipeSemState[i].usKey,&sd->write_copy))){
+                FD_SET(pipeSemState[i].usKey,writefds);
+                e++;
+                }
+            else if( (pipeSemState[i].fStatus == 3) &&
+                ( (FD_ISSET(pipeSemState[i].usKey,&sd->read_copy)) ||
+                  (FD_ISSET(pipeSemState[i].usKey,&sd->write_copy)) )){
+                errno = EBADF;
+                return (-1);
+                }
+            i++;
+            } /* endwhile */
+        /*fprintf(stderr,"Done listing pipe sem entries, total %d entries, total ready entries %d\n",i,e);*/
+errno = 0;
+return(e);
+}
+
+
+