===================================================================
RCS file: /home/cvs/OpenXM/src/kan96xx/plugin/oxmisc.c,v
retrieving revision 1.11
retrieving revision 1.18
diff -u -p -r1.11 -r1.18
--- OpenXM/src/kan96xx/plugin/oxmisc.c	2001/12/28 08:18:22	1.11
+++ OpenXM/src/kan96xx/plugin/oxmisc.c	2003/11/19 01:02:39	1.18
@@ -1,4 +1,4 @@
-/*  $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc.c,v 1.10 2001/08/10 13:48:39 takayama Exp $ */
+/*  $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc.c,v 1.17 2003/11/18 11:08:27 takayama Exp $ */
 #include <stdio.h>
 #include <sys/types.h>
 #include <sys/stat.h>
@@ -598,6 +598,7 @@ int oxInitClient(oxclientp client)
   client->mathcapObjp = NULL;
   client->controlByteOrder = OX_BYTE_NETWORK_BYTE_ORDER;
   client->engineByteOrder = OX_BYTE_NETWORK_BYTE_ORDER;
+  client->engineID = -1;
   return(0);
 }
 
@@ -611,7 +612,6 @@ int oxIsThereErrorClient(oxclientp client) {
 oxclientp oxCreateClient(char *sname,int portStream,int portControl)
      /* you also need to change oxCreateClient2. */
 {
-  static int clnum = 0;
   int v = 0;
   int fdControl = -1;
   int fdStream = -1;
@@ -654,7 +654,7 @@ oxclientp oxCreateClient(char *sname,int portStream,in
   client->dataport = portStream;
   client->controlport = portControl;
   client->controlfd = fdControl;
-  client->id = clnum; clnum++;
+  client->id = oxGetClientID();
   client->type = CLIENT_SOCKET; /* socket */
   client->engineByteOrder = engineByteOrder;
   client->controlByteOrder = controlByteOrder;
@@ -883,16 +883,23 @@ char *oxGenPass(void) {
 
 
 static void cancelConnection() {
+#if defined(__CYGWIN__)
+  extern sigjmp_buf MyEnv_oxmisc;
+#else
   extern jmp_buf MyEnv_oxmisc;
+#endif
   signal(SIGALRM,SIG_IGN);
   fprintf(stderr,"Time out in TCP/IP connection.\n");
+#if defined(__CYGWIN__)
+  siglongjmp(MyEnv_oxmisc,1);
+#else
   longjmp(MyEnv_oxmisc,1);
+#endif
 }
 
 oxclientp oxCreateClient2(int fdstream,int portStream,
                           int fdcontrol,int portControl,int ipmask,char *pass)
 {
-  static int clnum = 0;
   int v = 0;
   int fdControl = -1;
   int fdStream = -1;
@@ -900,11 +907,19 @@ oxclientp oxCreateClient2(int fdstream,int portStream,
 
   char *s;
   oxclientp client;
-  extern jmp_buf MyEnv_oxmisc ;
+#if defined(__CYGWIN__)
+  extern sigjmp_buf MyEnv_oxmisc;
+#else
+  extern jmp_buf MyEnv_oxmisc;
+#endif
   int controlByteOrder, engineByteOrder;
 
   v = !Quiet;
+#if defined(__CYGWIN__)
+  if (sigsetjmp(MyEnv_oxmisc,1)) {
+#else
   if (setjmp(MyEnv_oxmisc)) {
+#endif
     return(NULL);
   }else{
   }
@@ -925,7 +940,8 @@ oxclientp oxCreateClient2(int fdstream,int portStream,
   if (v) fprintf(stderr,"\nStream port %d : Connected.\n",portStream);
 
   if (fdStream == -1 || fdControl == -1) {
-    fprintf(stderr,"\nOpen error in oxCreateClient.\n");
+    fprintf(stderr,"\nOpen error in oxCreateClient2.\n");
+    fprintf(stderr,"fdStream=%d, fdControl=%d\n",fdStream,fdControl);
     return(NULL);
   }
 
@@ -970,7 +986,7 @@ oxclientp oxCreateClient2(int fdstream,int portStream,
   client->dataport = portStream;
   client->controlport = portControl;
   client->controlfd = fdControl;
-  client->id = clnum; clnum++;
+  client->id = oxGetClientID();
   client->type = CLIENT_SOCKET; /* socket */
   client->engineByteOrder = engineByteOrder;
   client->controlByteOrder = controlByteOrder;
@@ -992,20 +1008,79 @@ int oxSetByteOrder(int fd) {
   return(OX_BYTE_NETWORK_BYTE_ORDER);
 }
 
-int oxTellMyByteOrder(int fd) {  
+int oxTellMyByteOrder(int fdOut, int fdIn) {  
   char data[1];
   int peertype;
   /* It is for server. read and next write. */
 
   /* We support only Network byte order */
   data[0] = OX_BYTE_NETWORK_BYTE_ORDER;
-  write(fd,data,1);
-  fsync(fd);  /* returns 0 if normal. Does it work for socket? */
+  write(fdOut,data,1);
+  fsync(fdOut);  /* returns 0 if normal. Does it work for socket? */
 
-  read(fd,data,1);
+  read(fdIn,data,1); /* Read pear's byte order */
 
   return(OX_BYTE_NETWORK_BYTE_ORDER);
 }
 
 
+struct object OxClientList[MAX_N_OF_CLIENT];
+int OxClientListn = 0;
 
+int oxGetClientID() {
+  extern struct object OxClientList[];
+  extern int OxClientListn;
+  extern struct object Nobj;
+  int i;
+  for (i=0; i<OxClientListn; i++) {
+	if ((OxClientList[i]).tag == Snull) {
+	  return i;
+	}
+  }
+  i = OxClientListn;
+  (OxClientList[i]).tag = Snull;
+  if (OxClientListn < MAX_N_OF_CLIENT-1) {
+	OxClientListn++;
+	return i;
+  }else{
+	fprintf(MyErrorOut,"oxGetClientID(): the client table is full. Returns ID = 0.\n");
+	return 0;
+  }
+}
+
+char *oxFIDtoStr(int id) {
+  switch( id ) {
+  case SM_mathcap:
+    return "SM_mathcap"; break;
+  case SM_setMathCap:
+    return "SM_setMathCap"; break;
+  case SM_pops:
+    return "SM_pops"; break;
+  case SM_getsp:
+    return "SM_getsp"; break;
+  case SM_dupErrors:
+    return "SM_dupErrors"; break;
+  case SM_pushCMOtag:
+    return "SM_pushCMOtag"; break;
+  case SM_setName:
+    return "SM_setName"; break;
+  case SM_evalName:
+    return "SM_evalName"; break;
+  case SM_executeStringByLocalParser:
+    return "SM_executeStringByLocalParser"; break;
+  case SM_executeFunction:
+    return "SM_executeFunction"; break;
+  case SM_popCMO:
+    return "SM_popCMO"; break;
+  case SM_popString:
+    return "SM_popString"; break;
+  case SM_shutdown:
+    return "SM_shutdown"; break;
+  case SM_beginBlock:
+    return "SM_beginBlock"; break;
+  case SM_endBlock:
+    return "SM_endBlock"; break;
+  default:
+    return "Unknown to oxFIDtoStr"; break;
+  }
+}