=================================================================== RCS file: /home/cvs/OpenXM/src/kxx/ox_texmacs.c,v retrieving revision 1.2 retrieving revision 1.5 diff -u -p -r1.2 -r1.5 --- OpenXM/src/kxx/ox_texmacs.c 2004/02/29 08:19:54 1.2 +++ OpenXM/src/kxx/ox_texmacs.c 2004/03/01 09:37:05 1.5 @@ -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.4 2004/03/01 07:55:38 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,21 @@ */ #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; + void ctrlC(); struct object KpoString(char *s); char *KSpopString(void); @@ -47,19 +62,24 @@ 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; - dfp = fopen("/tmp/debug-texmacs.txt","w"); +#ifdef DEBUG2 + Dfp = fopen("/tmp/debug-texmacs.txt","w"); +#endif /* Set consts */ sys = "asir> "; @@ -68,16 +88,20 @@ 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); } - /* Main loop */ - printCopyright(""); + + irt = 0; while(1) { /* printp(sys); no prompt */ if (SETJMP(EnvOfStackMachine)) { @@ -86,10 +110,23 @@ main() { if (signal(SIGINT,SIG_IGN) != SIG_IGN) { signal(SIGINT,ctrlC); } + irt = 1; continue; } else { } - s=readString(stdin, "if (1) { ", " ; }else{ };"); /* see test data */ - if (s == NULL) break; + if (!irt) { + printf("%s",DATA_END); fflush(stdout); + } + irt = 0; + 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; } + printf("%s",DATA_BEGIN_V); KSexecuteString(" ox.engine "); ob = KpoString(s); KSpush(ob); @@ -98,10 +135,36 @@ main() { /* Get the result in string. */ if (Format == 1) { /* 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{ KSexecuteString(" ox.engine oxpopstring "); r = KSpopString(); - printv(r); + if (strlen(r) < OutputLimit_for_TeXmacs) printv(r); + else printv("Output is too large.\n"); } } } @@ -125,7 +188,8 @@ 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); @@ -139,16 +203,58 @@ static char *readString(FILE *fp, char *prolog, char * s[n++] = prolog[i]; s[n] = 0; INC_BUF ; } + start = n; while ((c = fgetc(fp)) != EOF) { - fprintf(dfp,"[%x] ",c); fflush(dfp); +#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; + /* 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; INC_BUF ; @@ -161,19 +267,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 +285,38 @@ 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."); 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();) oxsubmit oxasir.ccc oxpopstring "); + ob = KSpop(); + if (ob.tag == Sdollar) { + printf("%s",ob.lc.str); + } + } printf("%s",DATA_END); fflush(NULL); }