=================================================================== RCS file: /home/cvs/OpenXM/src/kxx/oxserver00.c,v retrieving revision 1.4 retrieving revision 1.12 diff -u -p -r1.4 -r1.12 --- OpenXM/src/kxx/oxserver00.c 2000/07/30 09:55:40 1.4 +++ OpenXM/src/kxx/oxserver00.c 2003/11/19 01:02:40 1.12 @@ -1,4 +1,4 @@ -/* $OpenXM: OpenXM/src/kxx/oxserver00.c,v 1.3 2000/02/02 03:30:49 takayama Exp $ */ +/* $OpenXM: OpenXM/src/kxx/oxserver00.c,v 1.11 2003/11/18 11:08:27 takayama Exp $ */ /* nullserver01 */ #include #include @@ -20,9 +20,14 @@ extern int SerialOX; /* Serial number of the packets extern int SerialCurrent; /* Current Serial number of the recieved packet. */ extern int OXprintMessage; /* print oxmessages? */ +#if defined(__CYGWIN__) +sigjmp_buf EnvOfChildServer; +#else jmp_buf EnvOfChildServer; +#endif int JmpMessage = 0; +extern int Lisplike; static char *getSuffix(char *s); main(int argc, char *argv[]) { @@ -33,12 +38,15 @@ main(int argc, char *argv[]) { char *tigers[] = {"callsm1.sm1","tigers.sm1"}; char *basicCD[] = {"basicCD.sm1"}; /* If you change the above, you need to change the argc of Sm1_start below. - */ + */ if (argc > 1) { if (strcmp(argv[1],"-monitor")==0) { fprintf(stderr,"Taking the packet monitor.\n"); PacketMonitor = 1; + }else if (strcmp(argv[1],"-lispLike")==0) { + fprintf(stderr,"Output lispLike expression.\n"); + Lisplike = 1; }else{ fprintf(stderr,"Unknown option. Possible options are -monitor\n"); } @@ -59,14 +67,18 @@ main(int argc, char *argv[]) { Sm1_start(0, NULL, "ox_sm1"); } - nullserver(3); + nullserver(3,4); } static char *getSuffix(char *s) { /* getSuffix("ox_sm1_forAsir") returns "forAsir" */ + /* getSuffix("ox_sm1_forAsir.exe") returns "forAsir" */ /* getSuffix("ox_sm1_gnuplot") returns "gnuplot" */ int n,i,k; n = strlen(s); + if (n > 5 && (strcmp(".exe",&(s[n-4]))==0 || strcmp(".EXE",&(s[n-4]))==0)) { + s[n-4] = '\0'; + } for (i=n-1; i>=0; i--) { if (s[i] == '_') { return( s+i+1 ); @@ -74,55 +86,82 @@ static char *getSuffix(char *s) { } return(s); } -nullserver(int fdStream) { +nullserver(int fdStreamIn,int fdStreamOut) { int mtag; int message = 1; - ox_stream ostream; + ox_stream ostreamIn; + ox_stream ostreamOut; char sreason[1024]; extern void controlResetHandler(); +#if defined(__CYGWIN__) + extern sigjmp_buf EnvOfStackMachine; +#else extern jmp_buf EnvOfStackMachine; +#endif int engineByteOrder; + /* for debug, use -monitor + PacketMonitor = 1; */ + fflush(NULL); - engineByteOrder = oxTellMyByteOrder(fdStream); + engineByteOrder = oxTellMyByteOrder(fdStreamOut,fdStreamIn); /* Set the network byte order. */ fprintf(stderr,"engineByteOrder=%x\n",engineByteOrder); - if (fdStream != -1) { - ostream = fp2open(fdStream); - if (ostream == NULL) { - fprintf(stderr,"fp2open(fdStream) failed.\n"); - fdStream = -1; + if (fdStreamIn != -1) { + ostreamIn = fp2open(fdStreamIn); + if (ostreamIn == NULL) { + fprintf(stderr,"fp2open(fdStreamIn) failed.\n"); + fdStreamIn = -1; } - if (PacketMonitor) fp2watch(ostream,stdout); + if (PacketMonitor) fp2watch(ostreamIn,stdout); } + if (fdStreamOut != -1) { + ostreamOut = fp2open(fdStreamOut); + if (ostreamOut == NULL) { + fprintf(stderr,"fp2open(fdStreamOut) failed.\n"); + fdStreamOut = -1; + } + if (PacketMonitor) fp2watch(ostreamOut,stdout); + } + aaa : ; +#if defined(__CYGWIN__) + if (sigsetjmp(EnvOfChildServer,1)) { +#else if (setjmp(EnvOfChildServer)) { +#endif fprintf(stderr,"childServerMain: jump here.\n"); if (OxInterruptFlag == 0) { fprintf(stderr," ?! \n"); fflush(NULL); } + KSexecuteString(" ctrlC-hook "); /* Execute User Defined functions. */ + KSexecuteString(" (Computation is interrupted.) "); signal(SIGUSR1,controlResetHandler); goto aaa; } else { if (JmpMessage) fprintf(stderr,"Set EnvOfChildServer.\n"); signal(SIGUSR1,controlResetHandler); } - +#if defined(__CYGWIN__) + if (sigsetjmp(EnvOfStackMachine,1)) { +#else if (setjmp(EnvOfStackMachine)) { - fprintf(stderr,"childServerMain: jump here by EnvOfStackMachine.\n"); +#endif + fprintf(stderr,"childServerMain: jump here by EnvOfStackMachine or timeout.\n"); if (OxInterruptFlag == 0) { fprintf(stderr," ?! \n"); fflush(NULL); } /* In case of error in the stack machine, pop the error info and send the error packet. */ /* oxSendOXheader(ostream,OX_DATA,SerialOX++); - oxSendCmoError(ostream); - oxSendOXheader(ostream,OX_DATA,SerialOX++); - sprintf(sreason,"Jump here by sm1 error."); - oxSendCmoError2(ostream,sreason); + oxSendCmoError(ostream); + oxSendOXheader(ostream,OX_DATA,SerialOX++); + sprintf(sreason,"Jump here by sm1 error."); + oxSendCmoError2(ostream,sreason); */ Sm1_pushError2(SerialCurrent,-1,"Global jump by sm1 error"); + KSexecuteString(" ctrlC-hook "); /* Execute User Defined functions. */ signal(SIGUSR1,controlResetHandler); goto aaa ; } else { if (JmpMessage) fprintf(stderr,"Set EnvOfStackMachine.\n"); @@ -132,22 +171,22 @@ nullserver(int fdStream) { } while (1) { - message = OXprintMessage; + message = OXprintMessage; if (OxInterruptFlag) { OxCritical = 1; if (message) {fprintf(stderr,"Clearing the read buffer.\n");fflush(NULL); } - fp2clearReadBuf(ostream); /* clear the read buffer */ + fp2clearReadBuf(ostreamIn); /* clear the read buffer */ if (message) {fprintf(stderr,"Throwing OX_SYNC_BALL\n"); fflush(NULL);} - oxSendSyncBall(ostream); + oxSendSyncBall(ostreamOut); if (message) {fprintf(stderr,"Waiting for OX_SYNC_BALL\n");fflush(NULL);} - oxWaitSyncBall(ostream); + oxWaitSyncBall(ostreamIn); if (message) {fprintf(stderr,"Done changing OX_SYNC_BALL\n"); fflush(NULL);} OxInterruptFlag = 0; OxCritical = 0; goto aaa ; } OxCritical = 0; - if (fp2select(ostream,-1)) { + if (fp2select(ostreamIn,-1)) { /* If there is an data in the ostream, then read data in the buffer and read data in the communication stream. */ OxCritical = 1; @@ -156,7 +195,7 @@ nullserver(int fdStream) { /* This part is never reached. */ } OxCritical = 1; - mtag = oxGetOXheader(ostream,&SerialCurrent); /* get the message_tag */ + mtag = oxGetOXheader(ostreamIn,&SerialCurrent); /* get the message_tag */ if (message) { fprintf(stderr,"\nmtag is %d (serial=%d) : ",mtag,SerialCurrent); switch(mtag) { @@ -164,18 +203,18 @@ nullserver(int fdStream) { case OX_DATA: fprintf(stderr," OX_DATA \n"); break; case OX_SYNC_BALL: fprintf(stderr," OX_SYNC_BALL \n"); break; case -1: fprintf(stderr," End of file. Exiting the server child.\n"); - exit(); break; + exit(0); break; default: fprintf(stderr," ?! \n"); break; } } /*sleep(2); /* for dubug OX_SYNC_BALL */ switch(mtag) { case OX_COMMAND: - nullserverCommand(ostream); + nullserverCommand(ostreamIn,ostreamOut); goto aaa ; /* We always reset the jump vector. cf. memo1.txt 1998 2/13*/ break; case OX_DATA: - Sm1_pushCMO(ostream); + Sm1_pushCMO(ostreamIn); break; case OX_SYNC_BALL: /* if (OxInterruptFlag) think about it later. */ @@ -187,7 +226,7 @@ nullserver(int fdStream) { } } -nullserverCommand(ox_stream ostream) { +nullserverCommand(ox_stream ostreamIn,ox_stream ostreamOut) { int id; int mtag; int n; @@ -199,10 +238,10 @@ nullserverCommand(ox_stream ostream) { char *emsg; extern void controlResetHandler(); - message = OXprintMessage; + message = OXprintMessage; /* message_body */ - id = oxGetInt32(ostream); /* get the function_id */ - if (message) {fprintf(stderr,"\nfunction_id is %d\n",id);} + id = oxGetInt32(ostreamIn); /* get the function_id */ + if (message) {fprintf(stderr,"\nfunction_id is %d; %s\n",id,oxFIDtoStr(id));} switch( id ) { case SM_mathcap: if (message) fprintf(stderr," mathcap\n"); @@ -211,7 +250,7 @@ nullserverCommand(ox_stream ostream) { break; case SM_setMathCap: if (message) fprintf(stderr," setMathCap\n"); - Sm1_setMathCap(ostream); + Sm1_setMathCap(ostreamOut); break; case SM_pops: if (message) fprintf(stderr," pops \n"); @@ -228,7 +267,7 @@ nullserverCommand(ox_stream ostream) { case SM_pushCMOtag: if (message) fprintf(stderr," pushCMOtag \n"); Sm1_pushCMOtag(SerialCurrent); - break; + break; case SM_setName: if (message) fprintf(stderr," setName \n"); iresult = Sm1_setName(); @@ -267,20 +306,20 @@ nullserverCommand(ox_stream ostream) { break; case SM_popCMO: if (message) fprintf(stderr,"popCMO. Start to sending data.\n",n); - oxSendOXheader(ostream,OX_DATA,SerialOX++); - n=Sm1_popCMO(ostream,SerialCurrent); + oxSendOXheader(ostreamOut,OX_DATA,SerialOX++); + n=Sm1_popCMO(ostreamOut,SerialCurrent); if (message) fprintf(stderr,"Done.\n"); break; case SM_popString: if (message) fprintf(stderr,"popString. send data from the stack.\n",n); - oxSendOXheader(ostream,OX_DATA,SerialOX++); - oxSendCmoString(ostream,Sm1_popString()); + oxSendOXheader(ostreamOut,OX_DATA,SerialOX++); + oxSendCmoString(ostreamOut,Sm1_popString()); if (message) fprintf(stderr,"Done.\n"); break; case SM_shutdown: - fprintf(stderr,"Shutting down the engine.\n"); - exit(0); - break; + fprintf(stderr,"Shutting down the engine.\n"); + exit(0); + break; case SM_beginBlock: case SM_endBlock: fprintf(stderr,"This command has not yet been implemented.\n"); @@ -305,15 +344,20 @@ nullserver_simplest(int fd) { void controlResetHandler(sig) -int sig; + int sig; { signal(sig,SIG_IGN); + cancelAlarm(); fprintf(stderr,"From controlResetHandler. OxCritical = %d\n",OxCritical); OxInterruptFlag = 1; if (OxCritical) { return; }else{ +#if defined(__CYGWIN__) + siglongjmp(EnvOfChildServer,2); /* returns 2 for ctrl-C */ +#else longjmp(EnvOfChildServer,2); /* returns 2 for ctrl-C */ +#endif } }