=================================================================== RCS file: /home/cvs/OpenXM/src/kan96xx/Kan/shell.c,v retrieving revision 1.2 retrieving revision 1.13 diff -u -p -r1.2 -r1.13 --- OpenXM/src/kan96xx/Kan/shell.c 2003/12/03 01:21:43 1.2 +++ OpenXM/src/kan96xx/Kan/shell.c 2005/06/16 05:07:23 1.13 @@ -1,4 +1,4 @@ -/* $OpenXM: OpenXM/src/kan96xx/Kan/shell.c,v 1.1 2003/11/24 12:38:17 takayama Exp $ */ +/* $OpenXM: OpenXM/src/kan96xx/Kan/shell.c,v 1.12 2004/10/14 10:08:09 takayama Exp $ */ #include #include #include @@ -17,14 +17,98 @@ #include "ox_pathfinder.h" static struct object KoxShell_test1(struct object ob); +static struct object oxsExecuteBlocked(struct object ob); +static struct object oxsSetenv(struct object ob); +static char *oxsIsURI(char *s); +static char *oxsURIgetVarName(char *s); +static char *oxsURIgetExtension(char *s); +static char *oxsURIgetFileName(char *s); +static char *oxsRemoveOpt(char *s); +static char *oxsGetOpt(char *s); +static char *oxsVarToFile(char *v,char *extension,char *comamnd,int tmp); +static int oxsFileToVar(char *v,char *fname); +static char **oxsBuildArgv(struct object ob); +static char **oxsBuildArgvRedirect(char **argv); +static struct object testmain(struct object ob); +#define mymalloc(n) sGC_malloc(n) +#define nomemory(n) errorKan1("%s\n","No more memory in shell.c"); + +#define MAXFILES 256 +static char *AfterReadFile[MAXFILES]; +static char *AfterSetVar[MAXFILES]; +static int AfterPt=0; +static char *AfterDeleteFile[MAXFILES]; +static int AfterD=0; + +static int KeepTmpFiles = 0; + +extern int OX_P_stdin; +extern int OX_P_stdout; +extern int OX_P_stderr; + struct object KoxShell(struct object ob) { return KoxShell_test1(ob); } +/* A temporary help system */ +void KoxShellHelp(char *key,FILE *fp) { + char *keys[]={"command","export","keep_tmp_files", + "killall","redirect","which","@@@@gatekeeper"}; + int i; +#define HSIZE 20 + char *s[HSIZE]; + if (key == NULL) { + fprintf(fp,"\n"); + for (i=0; strcmp(keys[i],"@@@@gatekeeper") != 0; i++) { + fprintf(fp,"%s\n",keys[i]); + KoxShellHelp(keys[i],fp); + fprintf(fp,"\n",keys[i]); + } + return; + } + for (i=0; i> or << which command-name path >>"); - } - return(rob); + if (strcmp(cmd,"testmain")==0) { + rob = testmain(ob); + }else if (strcmp(cmd,"which")==0) { + if (n == 2) { + pathFinderErrorVerbose(0); + rob = KoxWhich(getoa(ob,1),KpoInteger(0)); + pathFinderErrorVerbose(-1); + }else if (n==3) { + pathFinderErrorVerbose(0); + rob = KoxWhich(getoa(ob,1),getoa(ob,2)); + pathFinderErrorVerbose(-1); + }else{ + errorKan1("%s\n","shell: << which command-name >> or << which command-name path >>"); + } + return(rob); }else if (strcmp(cmd,"export")==0) { + rob=oxsSetenv(ob); + }else if (strcmp(cmd,"keep_tmp_files")==0) { + if (n != 2) errorKan1("%s\n","shell: << keep_tmp_files value >>"); + if (strcmp("0",KopString(getoa(ob,1))) == 0) { + KeepTmpFiles = 0; + }else{ + KeepTmpFiles = 1; + } + rob = KpoInteger(KeepTmpFiles); + }else if (strcmp(cmd,"killall")==0) { + /* It is called from ctrl-C hook of oxrfc103.sm1 */ + fprintf(stderr,"Killing all child processes (oxshell) ..."); + rob = KpoInteger(oxKillAll()); + fprintf(stderr,"\nDone.\n"); }else{ + rob = oxsExecuteBlocked(ob); } return(rob); } /* Functions for ox_shell */ struct object KoxWhich(struct object cmdo,struct object patho) { - struct object rob; + struct object rob = OINIT; char *sss; rob = NullObject; if (cmdo.tag != Sdollar) errorKan1("%s\n","KoxWhich(str-obj,str-obj)"); @@ -72,4 +177,481 @@ struct object KoxWhich(struct object cmdo,struct objec return(rob); } +static int mysetenv(char *name, char *value, int overwrite); +static int myunsetenv(char *name); +static int mysetenv(char *name, char *value, int overwrite) { + char *s; + char *orig; + s = (char *)getenv(name); + if ((s == NULL) || overwrite) { + s = (char *) mymalloc(strlen(name)+strlen(value)+5); + if (s == 0) { fprintf(stderr,"No more memory.\n"); exit(10); } + strcpy(s,name); + strcat(s,"="); strcat(s,value); + return(putenv(s)); + } + return (0); +} +/* bug on Solaris. It does not unsetenv. + libc4, libc5, glibc. It does unsetenv. */ +static myunsetenv(char *name) { + return(putenv(name)); +} + +/* Example. [(export) (PATH) (=) (/usr/new/bin:$PATH)] */ +static struct object oxsSetenv(struct object ob) { + struct object rob = OINIT; + int i,n; + char *envp; + char *new; + int r; + rob = NullObject; + if (ob.tag != Sarray) errorKan1("%s\n","oxsSetenv requires an array of srings."); + n = getoaSize(ob); + if ((n != 4) && (n != 3)) errorKan1("%s\n","oxsSetenv requires an array of srings. Length must be 3 or 4."); + for (i=0; i stringIn + s="stringInOut://abc.poly" ==> stringInOut +*/ +char *oxsIsURI(char *s) { + int n,i,j; + char *u; + if (s == NULL) return((char *)NULL); + s = oxsRemoveOpt(s); + n = strlen(s); + for (i=0; i abc + s="stringInOut://abc.poly" ==> abc + s="stringInOut://abc" ==> abc +*/ +char *oxsURIgetVarName(char *s) { + int n,i,j; + char *u; + if (s == NULL) return((char *)NULL); + s = oxsRemoveOpt(s); + n = strlen(s); + for (i=0; i poly + s="stringInOut://abc.poly" ==> poly + s="stringInOut://abc" ==> NULL +*/ +char *oxsURIgetExtension(char *s) { + int n,i,j,k; + char *u; + if (s == NULL) return((char *)NULL); + s = oxsRemoveOpt(s); + n = strlen(s); + for (i=0; i limit - 10) { + sold = s; limit *= 2; + s = (char *)mymalloc(limit); + if (s == NULL) errorKan1("%s\n","No more memory in oxsFileToVar()."); + strcpy(s,sold); + } + i++; + } + fclose(fp); + + KputUserDictionary(v,KpoString(s)); + return(0); +} + +static char **oxsBuildArgv(struct object ob) { + int n,i; + char **argv; + char *s; + char *type; + char *ext, *v; + int usetmp=1; + int win=0; + struct object ocmd = OINIT; + + /* bug: win variable must be properly set on windows native. */ + + if (ob.tag != Sarray) errorKan1("%s\n","oxsBuildArgv() requires an array as an argument."); + n = getoaSize(ob); + for (i=0; i= MAXFILES) { + AfterPt=0; + errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); + } + }else if (strcmp(type,"stringOut") == 0) { + argv[i] = generateTMPfileName2(v,ext,usetmp,win); + AfterDeleteFile[AfterD++] = argv[i]; + AfterReadFile[AfterPt] = argv[i]; + AfterSetVar[AfterPt] = v; + AfterPt++; + if (AfterPt >= MAXFILES) { + AfterPt=0; + errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); + } + }else { + errorKan1("%s\n","This URI type has not yet been implemented."); + } + if (AfterD >= MAXFILES) { + AfterD=0; + errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); + } + } + } + return(argv); +} + + +static struct object oxsExecuteBlocked(struct object ob) +{ + int r,i,n; + char **argv; + int errorf; + + argv = oxsBuildArgv(ob); + argv = oxsBuildArgvRedirect(argv); + r=oxForkExecBlocked(argv); /* bug: what happen when NoX? */ + /* + if (1) { + for (i=0; argv[i] != NULL; i++) { + fprintf(stderr,"argv[%d]=%s\n",i,argv[i]); + } + errorKan1("%s\n","ForkExecBlocked failed."); + } + */ + errorf=0; + if (AfterPt > 0) { + for (i=0; i< AfterPt; i++) { + if (oxsFileToVar(AfterSetVar[i],AfterReadFile[i]) != 0) { + errorf=1; + } + } + } + AfterPt = 0; + + if (AfterD > 0) { + for (i=0; i< AfterD; i++) { + if (!KeepTmpFiles) { + oxDeleteFile(AfterDeleteFile[i]); + } + } + } + AfterD = 0; + if (errorf) errorKan1("%s\n","Some errors in oxsFileToVar()."); + + return(KpoInteger(r)); +} + +static char **oxsBuildArgvRedirect(char **argv) { + char **newargv; + int n,i,j; + FILE *fp; + char *fname; + + n = 0; while (argv[n] != NULL) n++; + newargv = (char **) mymalloc(sizeof(char *)*(n+1)); + for (i=0; i<=n; i++) newargv[i]=(char *)NULL; + j=0; + /* bug: Critical area, do not make an interruption. */ + for (i=0; i")==0) { + fname = argv[i+1]; + fp == NULL; + if (fname != NULL) { + fp = fopen(fname,"w"); + } + if (fp == NULL) { + oxResetRedirect(); + errorKan1("%s\n","oxsBuildArgvRedirect, cannot open the output file.\n"); + } + fclose(fp); /* touch */ + OX_P_stdout = open(fname,O_WRONLY); + i++; + }else if (strcmp(argv[i],"2>") == 0) { + fname = argv[i+1]; + fp == NULL; + if (fname != NULL) { + fp = fopen(fname,"w"); + } + if (fp == NULL) { + oxResetRedirect(); + errorKan1("%s\n","oxsBuildArgvRedirect, cannot open the output (stderr) file.\n"); + } + fclose(fp); /* touch */ + OX_P_stderr = open(fname,O_WRONLY); + i++; + }else{ + newargv[j++] = argv[i]; + } + } + return( newargv ); +}