=================================================================== RCS file: /home/cvs/OpenXM/src/kxx/ox_texmacs.c,v retrieving revision 1.2 retrieving revision 1.8 diff -u -p -r1.2 -r1.8 --- OpenXM/src/kxx/ox_texmacs.c 2004/02/29 08:19:54 1.2 +++ OpenXM/src/kxx/ox_texmacs.c 2004/03/02 09:30:48 1.8 @@ -1,4 +1,4 @@ -/* $OpenXM: OpenXM/src/kxx/ox_texmacs.c,v 1.1 2004/02/29 03:00:37 takayama Exp $ */ +/* $OpenXM: OpenXM/src/kxx/ox_texmacs.c,v 1.7 2004/03/02 09:10:04 takayama Exp $ */ #include #include @@ -16,7 +16,11 @@ #define LONGJMP(env,p) longjmp(env,p) #endif -/* #define DEBUG */ +/* +#define DEBUG +*/ +/* #define DEBUG2 */ + #ifdef DEBUG #define DATA_BEGIN_V "" /* "\002verbatim:" */ #define DATA_BEGIN_L "" /* "\002latex:" */ @@ -34,10 +38,22 @@ */ #define END_OF_INPUT '\n' +/* Table for the engine type. */ +#define ASIR 1 +#define SM1 2 +#define K0 3 + extern int Quiet; extern JMP_BUF EnvOfStackMachine; -int Format=0; +int Format=1; /* 1 : latex mode */ +int OutputLimit_for_TeXmacs = (1024*10); +int TM_Engine = ASIR ; +int TM_asirStarted = 0; +int TM_sm1Started = 0; +int TM_k0Started = 0; +int TM_do_not_print = 0; + void ctrlC(); struct object KpoString(char *s); char *KSpopString(void); @@ -47,20 +63,35 @@ static void printv(char *s); static void printl(char *s); static void printp(char *s); static void printCopyright(char *s); +static int startEngine(int type,char *msg); /* tail -f /tmp/debug-texmacs.txt Debug output to understand the timing problem of pipe interface. */ -FILE *dfp; +FILE *Dfp; main() { char *s; char *r; char *sys; struct object ob; + int irt=0; + int vmode=1; + char *openxm_home; + char *asir_config; - dfp = fopen("/tmp/debug-texmacs.txt","w"); + openxm_home = (char *) getenv("OpenXM_HOME"); + asir_config = (char *) getenv("ASIR_CONFIG"); + if (openxm_home == NULL || asir_config == NULL) { + printv("The environmental variables OpenXM_HOME/ASIR_CONFIG are not set.\nStart the texmacs with openxm texmacs or ox_texmacs by openxm ox_texmacs\nBye..."); + exit(10); + } + +#ifdef DEBUG2 + Dfp = fopen("/tmp/debug-texmacs.txt","w"); +#endif + /* Set consts */ sys = "asir> "; Quiet = 1; @@ -68,55 +99,105 @@ main() { /* Initialize kanlib (gc is also initialized) */ KSstart(); + /* Main loop */ + printf("%s",DATA_BEGIN_V); + printCopyright(""); + /* Load ox engine here */ /* engine id should be set to ox.engine */ KSexecuteString(" [(parse) (ox.sm1) pushfile] extension "); - KSexecuteString(" asirconnectr /ox.engine oxasir.ccc def "); + startEngine(TM_Engine," "); if (signal(SIGINT,SIG_IGN) != SIG_IGN) { - signal(SIGINT,ctrlC); + signal(SIGINT,ctrlC); } - /* Main loop */ - printCopyright(""); + + irt = 0; while(1) { - /* printp(sys); no prompt */ - if (SETJMP(EnvOfStackMachine)) { - printv("Syntax error or an interruption\n"); - KSexecuteString(" ctrlC-hook "); /* Execute User Defined functions. */ - if (signal(SIGINT,SIG_IGN) != SIG_IGN) { - signal(SIGINT,ctrlC); - } - continue; - } else { } - s=readString(stdin, "if (1) { ", " ; }else{ };"); /* see test data */ - if (s == NULL) break; + /* printp(sys); no prompt */ + if (SETJMP(EnvOfStackMachine)) { + KSexecuteString(" ctrlC-hook "); /* Execute User Defined functions. */ + if (signal(SIGINT,SIG_IGN) != SIG_IGN) { + signal(SIGINT,ctrlC); + } + irt = 1; + continue; + } else { } + if (!irt) { + printf("%s",DATA_END); fflush(stdout); + } + irt = 0; + + /* Reading the input. */ + if (TM_Engine == K0) { + s=readString(stdin, " ", " "); /* see test data */ + }else if (TM_Engine == SM1) { + s=readString(stdin, " ", " "); /* see test data */ + }else{ + s=readString(stdin, "if (1) { ", " ; }else{ }"); /* see test data */ + } + + if (s == NULL) { irt = 1; continue; } + if (!irt) printf("%s",DATA_BEGIN_V); + /* Evaluate the input on the engine */ KSexecuteString(" ox.engine "); - ob = KpoString(s); - KSpush(ob); - KSexecuteString(" oxsubmit "); - + ob = KpoString(s); + KSpush(ob); + KSexecuteString(" oxsubmit "); + /* Get the result in string. */ - if (Format == 1) { - /* translate to latex form */ - }else{ - KSexecuteString(" ox.engine oxpopstring "); - r = KSpopString(); - printv(r); - } + if (Format == 1 && (! TM_do_not_print)) { + /* translate to latex form */ + KSexecuteString(" ox.engine oxpushcmotag ox.engine oxpopcmo "); + ob = KSpop(); + vmode = 0; + /* printf("id=%d\n",ob.tag); bug: matrix return 17 instead of Sinteger + or error. */ + if (ob.tag == Sinteger) { + /* printf("cmotag=%d\n",ob.lc.ival);*/ + if (ob.lc.ival == CMO_ERROR2) { + vmode = 1; + } + if (ob.lc.ival == CMO_STRING) { + vmode = 1; + } + } + if (vmode) { + KSexecuteString(" ox.engine oxpopstring "); + r = KSpopString(); + }else{ + KSexecuteString(" ox.engine 1 oxpushcmo ox.engine (print_tex_form) oxexec "); + KSexecuteString(" ox.engine oxpopstring "); + r = KSpopString(); + } + if (strlen(r) < OutputLimit_for_TeXmacs) { + if (vmode) printv(r); else printl(r); + } else printv("Output is too large.\n"); + }else{ + if (!TM_do_not_print) { + KSexecuteString(" ox.engine oxpopstring "); + r = KSpopString(); + if (strlen(r) < OutputLimit_for_TeXmacs) printv(r); + else printv("Output is too large.\n"); + }else{ + KSexecuteString(" ox.engine 1 oxpops "); /* Discard the result. */ + printv(""); + } + } } } #define SB_SIZE 1024 -#define INC_BUF if (n >= limit-3) { \ - tmp = s; \ - limit *= 2; \ - s = (char *) sGC_malloc(limit); \ - if (s == NULL) { \ - fprintf(stderr,"No more memory.\n"); \ - exit(10); \ - } \ - strcpy(s,tmp); \ - } +#define INC_BUF if (n >= limit-3) { \ + tmp = s; \ + limit *= 2; \ + s = (char *) sGC_malloc(limit); \ + if (s == NULL) { \ + fprintf(stderr,"No more memory.\n"); \ + exit(10); \ + } \ + strcpy(s,tmp); \ + } /* */ static char *readString(FILE *fp, char *prolog, char *epilog) { int n = 0; @@ -125,32 +206,77 @@ static char *readString(FILE *fp, char *prolog, char * int c; char *tmp; int i; - int m; + int m; + int start; if (limit == 0) { - limit = 1024; - s = (char *)sGC_malloc(limit); - if (s == NULL) { - fprintf(stderr,"No more memory.\n"); - exit(10); - } + limit = 1024; + s = (char *)sGC_malloc(limit); + if (s == NULL) { + fprintf(stderr,"No more memory.\n"); + exit(10); + } } s[0] = 0; n = 0; m = 0; for (i=0; i < strlen(prolog); i++) { - s[n++] = prolog[i]; s[n] = 0; + s[n++] = prolog[i]; s[n] = 0; INC_BUF ; } + start = n; while ((c = fgetc(fp)) != EOF) { - fprintf(dfp,"[%x] ",c); fflush(dfp); - if (c == END_OF_INPUT) { - break; - } - if (c == '\n') c=' '; - s[n++] = c; s[n] = 0; m++; +#ifdef DEBUG2 + fprintf(Dfp,"[%x] ",c); fflush(Dfp); +#endif + if (c == END_OF_INPUT) { + if (oxSocketSelect0(0,1)) { + /* If there remains data in the stream, + read the remaining data. */ + if (c == '\n') c=' '; + s[n++] = c; s[n] = 0; m++; + INC_BUF ; + continue; + } + break; + } + if (c == '\n') c=' '; + s[n++] = c; s[n] = 0; m++; INC_BUF ; } - if (m == 0) return (char *) NULL; + if (s[n-1] == '$' && TM_Engine == ASIR) TM_do_not_print = 1; + else TM_do_not_print = 0; + /* Check the escape sequence */ + if (strcmp(&(s[start]),"!quit;") == 0) { + printv("Terminated the process ox_texmacs.\n"); + exit(0); + } + /* Check the escape sequence to change the globa env. */ + if (strcmp(&(s[start]),"!verbatim;") == 0) { + printv("Output mode is changed to verbatim mode."); + Format=0; + return NULL; + } + if (strcmp(&(s[start]),"!latex;") == 0) { + printv("Output mode is changed to latex/verbose."); + Format = 1; + return NULL; + } + if (strcmp(&(s[start]),"!asir;") == 0) { + Format=1; + TM_Engine=ASIR; startEngine(TM_Engine,"Asir"); + return NULL; + } + if (strcmp(&(s[start]),"!sm1;") == 0) { + Format=0; + TM_Engine=SM1; startEngine(TM_Engine,"sm1"); + return NULL; + } + if (strcmp(&(s[start]),"!k0;") == 0) { + Format=0; + TM_Engine=K0; startEngine(TM_Engine,"k0"); + return NULL; + } + for (i=0; i < strlen(epilog); i++) { - s[n++] = epilog[i]; s[n] = 0; + s[n++] = epilog[i]; s[n] = 0; INC_BUF ; } return s; @@ -161,19 +287,14 @@ static void printv(char *s) { printf("%s",DATA_BEGIN_V); printf("%s",s); printf("%s",DATA_END); - fprintf(dfp,"<%s>",s); fflush(dfp); - /* for debug "hello; - for (i=0; i",s); fflush(Dfp); +#endif fflush(NULL); } static void printl(char *s) { printf("%s",DATA_BEGIN_L); - printf("%s",s); + printf(" $ %s $ ",s); printf("%s",DATA_END); fflush(NULL); } @@ -184,9 +305,43 @@ static void printp(char *s) { fflush(NULL); } static void printCopyright(char *s) { - printf("%s",DATA_BEGIN_P); - printf("OpenXM engine (ox engine) interface for TeXmacs\n2004 (C) openxm.org\n"); + printf("%s",DATA_BEGIN_V); + printf("OpenXM engine (ox engine) interface for TeXmacs\n2004 (C) openxm.org"); + printf(" under the BSD licence. !asir; !sm1; !k0; !verbatim;"); printf("%s",s); + printf("%s",DATA_END); + fflush(NULL); +} + +static int startEngine(int type,char *msg) { + struct object ob; + printf("%s",DATA_BEGIN_V); + if (type == SM1) { + if (!TM_sm1Started) KSexecuteString(" sm1connectr "); + KSexecuteString(" /ox.engine oxsm1.ccc def "); + TM_sm1Started = 1; + printf("%s\n",msg); + }else if (type == K0) { + if (!TM_k0Started) KSexecuteString(" k0connectr "); + KSexecuteString(" /ox.engine oxk0.ccc def "); + TM_k0Started = 1; + printf("%s\n",msg); + }else{ + if (!TM_asirStarted) KSexecuteString(" asirconnectr "); + KSexecuteString(" /ox.engine oxasir.ccc def "); + TM_asirStarted = 1; + printf("%s\n",msg); + KSexecuteString(" oxasir.ccc (copyright()+asir_contrib_copyright();) oxsubmit oxasir.ccc oxpopstring "); + ob = KSpop(); + if (ob.tag == Sdollar) { + printf("%s",ob.lc.str); + } + /* Initialize the setting of asir. */ + KSexecuteString(" oxasir.ccc (if(1) { Xm_server_mode = 1; Xm_helpdir = \"help-eg\"; } else { ; } ;) oxsubmit oxasir.ccc oxpopcmo "); + KSexecuteString(" oxasir.ccc (if(1) { ctrl(\"message\",0); } else { ; } ;) oxsubmit oxasir.ccc oxpopcmo "); + /* bug; if ctrl is written with Xm_helpdir = ... without oxpopcmo, then it does + not work. */ + } printf("%s",DATA_END); fflush(NULL); }