=================================================================== RCS file: /home/cvs/OpenXM/src/kan96xx/plugin/oxmisc.c,v retrieving revision 1.12 retrieving revision 1.18 diff -u -p -r1.12 -r1.18 --- OpenXM/src/kan96xx/plugin/oxmisc.c 2002/02/24 10:27:20 1.12 +++ 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.11 2001/12/28 08:18:22 takayama Exp $ */ +/* $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc.c,v 1.17 2003/11/18 11:08:27 takayama Exp $ */ #include #include #include @@ -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; @@ -900,7 +900,6 @@ static void cancelConnection() { 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; @@ -941,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); } @@ -986,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; @@ -1008,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