version 1.4, 2003/12/03 23:26:39 |
version 1.9, 2003/12/13 13:29:44 |
|
|
/* $OpenXM: OpenXM/src/kan96xx/Kan/shell.c,v 1.3 2003/12/03 09:00:46 takayama Exp $ */ |
/* $OpenXM: OpenXM/src/kan96xx/Kan/shell.c,v 1.8 2003/12/05 07:05:24 takayama Exp $ */ |
#include <stdio.h> |
#include <stdio.h> |
#include <sys/types.h> |
#include <sys/types.h> |
#include <sys/stat.h> |
#include <sys/stat.h> |
Line 22 static struct object oxsSetenv(struct object ob); |
|
Line 22 static struct object oxsSetenv(struct object ob); |
|
static char *oxsIsURI(char *s); |
static char *oxsIsURI(char *s); |
static char *oxsURIgetVarName(char *s); |
static char *oxsURIgetVarName(char *s); |
static char *oxsURIgetExtension(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 char *oxsVarToFile(char *v,char *extension,char *comamnd,int tmp); |
static int oxsFileToVar(char *v,char *fname); |
static int oxsFileToVar(char *v,char *fname); |
static char **oxsBuildArgv(struct object ob); |
static char **oxsBuildArgv(struct object ob); |
|
static char **oxsBuildArgvRedirect(char **argv); |
static struct object testmain(struct object ob); |
static struct object testmain(struct object ob); |
|
|
#define mymalloc(n) sGC_malloc(n) |
#define mymalloc(n) sGC_malloc(n) |
Line 37 static int AfterPt=0; |
|
Line 41 static int AfterPt=0; |
|
static char *AfterDeleteFile[MAXFILES]; |
static char *AfterDeleteFile[MAXFILES]; |
static int AfterD=0; |
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) { |
struct object KoxShell(struct object ob) { |
return KoxShell_test1(ob); |
return KoxShell_test1(ob); |
} |
} |
|
|
/* A temporary help system */ |
/* A temporary help system */ |
void KoxShellHelp(char *key,FILE *fp) { |
void KoxShellHelp(char *key,FILE *fp) { |
char *keys[]={"command","export","which","@@@@gatekeeper"}; |
char *keys[]={"command","export","keep_tmp_files", |
|
"killall","redirect","which","@@@@gatekeeper"}; |
int i; |
int i; |
#define HSIZE 20 |
#define HSIZE 20 |
char *s[HSIZE]; |
char *s[HSIZE]; |
if (key == NULL) { |
if (key == NULL) { |
|
fprintf(fp,"\n"); |
for (i=0; strcmp(keys[i],"@@@@gatekeeper") != 0; i++) { |
for (i=0; strcmp(keys[i],"@@@@gatekeeper") != 0; i++) { |
fprintf(fp,"%s\n",keys[i]); |
fprintf(fp,"%s\n",keys[i]); |
KoxShellHelp(keys[i],fp); |
KoxShellHelp(keys[i],fp); |
fprintf(fp,"\n",keys[i]); |
fprintf(fp,"\n",keys[i]); |
} |
} |
return; |
return; |
} |
} |
for (i=0; i<HSIZE; i++) s[i] = NULL; |
for (i=0; i<HSIZE; i++) s[i] = NULL; |
if (strcmp(key,"export")==0) { |
if (strcmp(key,"export")==0) { |
s[0] = "export env_name = value"; |
s[0] = "export env_name = value"; |
s[1] = "export env_name = "; |
s[1] = "export env_name = "; |
s[2] = "Example: [(export) (PATH) (=) (/usr/new/bin:${PATH})] oxshell"; |
s[2] = "Example: [(export) (PATH) (=) (/usr/new/bin:${PATH})] oxshell"; |
s[3] = NULL; |
s[3] = NULL; |
}else if (strcmp(key,"which")==0) { |
}else if (strcmp(key,"which")==0) { |
s[0] = "which cmd_name"; |
s[0] = "which cmd_name"; |
s[1] = "which cmd_name path"; |
s[1] = "which cmd_name path"; |
s[2] = "Example: [(which) (ls)] oxshell"; |
s[2] = "Example: [(which) (ls)] oxshell"; |
s[3] = NULL; |
s[3] = NULL; |
}else if (strcmp(key,"command")==0) { |
}else if (strcmp(key,"command")==0) { |
s[0] = "Executing a command"; |
s[0] = "Executing a command"; |
s[1] = "cmdname arg1 arg2 ... "; |
s[1] = "cmdname arg1 arg2 ... "; |
s[2] = "Example 1: /afo (Hello! ) def [(cat) (stringIn://afo)] oxshell"; |
s[2] = "Example 1: /afo (Hello! ) def [(cat) (stringIn://afo)] oxshell"; |
s[3] = "Example 2: [(polymake) (stringInOut://afo.poly) (FACETS)] oxshell"; |
s[3] = "Example 2: [(polymake) (stringInOut://afo.poly) (FACETS)] oxshell"; |
s[4] = NULL; |
s[4] = NULL; |
|
}else if (strcmp(key,"redirect")==0) { |
|
s[0] = "The following redirect operators are implemented."; |
|
s[1] = "< > 2>"; |
|
s[2] = "Example 1: [(ls) (hoge) (2>) (stringOut://afo)] oxshell\n afo ::"; |
|
s[3] = "Example 2: [(cp) ] addStdoutStderr oxshell\n [@@@stdout @@@stderr] ::"; |
|
s[4] = NULL; |
|
}else if (strcmp(key,"killall")==0) { |
|
s[0] = "Kill all the processes envoked by oxshell"; |
|
s[1] = NULL; |
|
}else if (strcmp(key,"keep_tmp_files")==0) { |
|
s[0] = "keep_tmp_files value"; |
|
s[1] = "If value is zero, then temporary files are removed after execution."; |
|
s[2] = NULL; |
}else{ |
}else{ |
} |
} |
i = 0; |
i = 0; |
while (s[i] != NULL) { |
while (s[i] != NULL) { |
fprintf(fp,"%s\n",s[i++]); |
fprintf(fp,"%s\n",s[i++]); |
} |
} |
} |
} |
|
|
Line 91 static struct object KoxShell_test1(struct object ob) |
|
Line 116 static struct object KoxShell_test1(struct object ob) |
|
if (ob.tag != Sarray) errorKan1("%s\n","KoxShell requires an array as an argument."); |
if (ob.tag != Sarray) errorKan1("%s\n","KoxShell requires an array as an argument."); |
n = getoaSize(ob); |
n = getoaSize(ob); |
for (i=0; i<n; i++) { |
for (i=0; i<n; i++) { |
if (getoa(ob,i).tag != Sdollar) errorKan1("%s\n","KoxShell requires an array of string as an argument."); |
if (getoa(ob,i).tag != Sdollar) errorKan1("%s\n","KoxShell requires an array of string as an argument."); |
} |
} |
|
|
if (n == 0) return(rob); |
if (n == 0) return(rob); |
Line 99 static struct object KoxShell_test1(struct object ob) |
|
Line 124 static struct object KoxShell_test1(struct object ob) |
|
if (strcmp(cmd,"testmain")==0) { |
if (strcmp(cmd,"testmain")==0) { |
rob = testmain(ob); |
rob = testmain(ob); |
}else if (strcmp(cmd,"which")==0) { |
}else if (strcmp(cmd,"which")==0) { |
if (n == 2) { |
if (n == 2) { |
rob = KoxWhich(getoa(ob,1),KpoInteger(0)); |
rob = KoxWhich(getoa(ob,1),KpoInteger(0)); |
}else if (n==3) { |
}else if (n==3) { |
rob = KoxWhich(getoa(ob,1),getoa(ob,2)); |
rob = KoxWhich(getoa(ob,1),getoa(ob,2)); |
}else{ |
}else{ |
errorKan1("%s\n","shell: << which command-name >> or << which command-name path >>"); |
errorKan1("%s\n","shell: << which command-name >> or << which command-name path >>"); |
} |
} |
return(rob); |
return(rob); |
}else if (strcmp(cmd,"export")==0) { |
}else if (strcmp(cmd,"export")==0) { |
rob=oxsSetenv(ob); |
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{ |
}else{ |
rob = oxsExecuteBlocked(ob); |
rob = oxsExecuteBlocked(ob); |
} |
} |
return(rob); |
return(rob); |
} |
} |
Line 147 static struct object oxsSetenv(struct object ob) { |
|
Line 185 static struct object oxsSetenv(struct object ob) { |
|
n = getoaSize(ob); |
n = getoaSize(ob); |
if ((n != 4) && (n != 3)) errorKan1("%s\n","oxsSetenv requires an array of srings. Length must be 3 or 4."); |
if ((n != 4) && (n != 3)) errorKan1("%s\n","oxsSetenv requires an array of srings. Length must be 3 or 4."); |
for (i=0; i<n; i++) { |
for (i=0; i<n; i++) { |
if (getoa(ob,i).tag != Sdollar) errorKan1("%s\n","oxsSetenv requires an array of srings. Length must be 3 or 4."); |
if (getoa(ob,i).tag != Sdollar) errorKan1("%s\n","oxsSetenv requires an array of srings. Length must be 3 or 4."); |
} |
} |
|
|
if (strcmp(KopString(getoa(ob,2)),"=") != 0) { |
if (strcmp(KopString(getoa(ob,2)),"=") != 0) { |
errorKan1("%s\n","oxsSetenv, example [(export) (PATH) (=) (/usr/new/bin:$PATH)] oxshell"); |
errorKan1("%s\n","oxsSetenv, example [(export) (PATH) (=) (/usr/new/bin:$PATH)] oxshell"); |
} |
} |
envp = KopString(getoa(ob,1)); |
envp = KopString(getoa(ob,1)); |
if (n == 4) { |
if (n == 4) { |
new = KopString(getoa(ob,3)); |
new = KopString(getoa(ob,3)); |
/* printf("%s\n",new); */ |
/* printf("%s\n",new); */ |
new = oxEvalEnvVar(new); |
new = oxEvalEnvVar(new); |
/* printf("%s\n",new); */ |
/* printf("%s\n",new); */ |
r = setenv(envp,new,1); |
r = setenv(envp,new,1); |
}else{ |
}else{ |
unsetenv(envp); r = 0; |
unsetenv(envp); r = 0; |
} |
} |
if (r != 0) errorKan1("%s\n","setenv failed."); |
if (r != 0) errorKan1("%s\n","setenv failed."); |
new = (char *) getenv(envp); |
new = (char *) getenv(envp); |
if (new != NULL) { |
if (new != NULL) { |
rob = KpoString((char *) getenv(envp)); |
rob = KpoString((char *) getenv(envp)); |
} |
} |
return(rob); |
return(rob); |
} |
} |
Line 178 char *oxsIsURI(char *s) { |
|
Line 216 char *oxsIsURI(char *s) { |
|
int n,i,j; |
int n,i,j; |
char *u; |
char *u; |
if (s == NULL) return((char *)NULL); |
if (s == NULL) return((char *)NULL); |
|
s = oxsRemoveOpt(s); |
n = strlen(s); |
n = strlen(s); |
for (i=0; i<n-3;i++) { |
for (i=0; i<n-3;i++) { |
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
Line 201 char *oxsURIgetVarName(char *s) { |
|
Line 240 char *oxsURIgetVarName(char *s) { |
|
int n,i,j; |
int n,i,j; |
char *u; |
char *u; |
if (s == NULL) return((char *)NULL); |
if (s == NULL) return((char *)NULL); |
|
s = oxsRemoveOpt(s); |
n = strlen(s); |
n = strlen(s); |
for (i=0; i<n-3;i++) { |
for (i=0; i<n-3;i++) { |
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
Line 225 char *oxsURIgetExtension(char *s) { |
|
Line 265 char *oxsURIgetExtension(char *s) { |
|
int n,i,j,k; |
int n,i,j,k; |
char *u; |
char *u; |
if (s == NULL) return((char *)NULL); |
if (s == NULL) return((char *)NULL); |
|
s = oxsRemoveOpt(s); |
n = strlen(s); |
n = strlen(s); |
for (i=0; i<n-3;i++) { |
for (i=0; i<n-3;i++) { |
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
Line 244 char *oxsURIgetExtension(char *s) { |
|
Line 285 char *oxsURIgetExtension(char *s) { |
|
return(NULL); |
return(NULL); |
} |
} |
|
|
|
/* stringInOut://abc.poly=:file://pqr.txt */ |
|
static char *oxsRemoveOpt(char *s) { |
|
int n,i,j; |
|
char *u; |
|
if (s == NULL) return((char *)NULL); |
|
n = strlen(s); |
|
for (i=0; i<n-1;i++) { |
|
if ((s[i] == '=') && (s[i+1] == ':')) { |
|
u = (char *) mymalloc(i+1); |
|
if (u == NULL) nomemory(1); |
|
u[0]=0; |
|
for (j=0; j<i; j++) { |
|
u[j] = s[j]; u[j+1]=0; |
|
} |
|
return(u); |
|
} |
|
} |
|
return(s); |
|
} |
|
|
|
/* stringInOut://abc.poly=:file://pqr.txt */ |
|
/* stringInOut://abc.poly */ |
|
char *oxsGetOpt(char *s) { |
|
int n,i,j; |
|
char *u; |
|
if (s == NULL) return((char *)NULL); |
|
n = strlen(s); |
|
for (i=0; i<n-1;i++) { |
|
if ((s[i] == '=') && (s[i+1] == ':')) { |
|
u = (char *) mymalloc(n-i+1); |
|
if (u == NULL) nomemory(1); |
|
u[0]=0; |
|
for (j=i+2; j<n; j++) { |
|
u[j-i-2] = s[j]; u[j-i-2+1]=0; |
|
} |
|
return(u); |
|
} |
|
} |
|
return(NULL); |
|
} |
|
|
|
char *oxsURIgetFileName(char *s) { |
|
int n,i,j; |
|
char *u; |
|
if (s == NULL) return((char *)NULL); |
|
s = oxsRemoveOpt(s); |
|
n = strlen(s); |
|
for (i=0; i<n-3;i++) { |
|
if ((s[i] == ':') && (s[i+1] == '/') && (s[i+2] == '/')) { |
|
u = (char *) mymalloc(n-i+1); |
|
if (u == NULL) nomemory(1); |
|
u[0]=0; |
|
for (j=i+3; j<n; j++) { |
|
u[j-i-3] = s[j]; u[j-i-3+1]=0; |
|
} |
|
return(u); |
|
} |
|
} |
|
return(NULL); |
|
} |
|
|
|
|
static struct object testmain(struct object ob) { |
static struct object testmain(struct object ob) { |
struct object rob; |
struct object rob; |
char *s; |
char *s; |
Line 260 static struct object testmain(struct object ob) { |
|
Line 363 static struct object testmain(struct object ob) { |
|
getoa(ot,2)=KpoString("${HOME}/t.t"); |
getoa(ot,2)=KpoString("${HOME}/t.t"); |
av=oxsBuildArgv(ot); |
av=oxsBuildArgv(ot); |
for (i=0; av[i] != NULL; i++) { |
for (i=0; av[i] != NULL; i++) { |
printf("%s\n",av[i]); |
printf("%s\n",av[i]); |
} |
} |
printf("------------------------------\n"); |
printf("------------------------------\n"); |
|
|
Line 296 char *oxsVarToFile(char *v,char *ext,char *command,int |
|
Line 399 char *oxsVarToFile(char *v,char *ext,char *command,int |
|
n = strlen(prog); |
n = strlen(prog); |
prevc = 0; |
prevc = 0; |
for (i=0; i<n ; i++) { |
for (i=0; i<n ; i++) { |
c = prog[i]; |
c = prog[i]; |
if (winname) { |
if (winname) { |
if ((c == '\n') && (prevc != 0xd)) { |
if ((c == '\n') && (prevc != 0xd)) { |
fputc(0xd,fp); fputc(c,fp); |
fputc(0xd,fp); fputc(c,fp); |
} |
} |
}else{ |
}else{ |
fputc(c,fp); |
fputc(c,fp); |
} |
} |
prevc = c; |
prevc = c; |
} |
} |
if (fclose(fp) != 0) errorKan1("%s\n","oxsVarToFile(), fail to close the file."); |
if (fclose(fp) != 0) errorKan1("%s\n","oxsVarToFile(), fail to close the file."); |
|
|
Line 317 int oxsFileToVar(char *v,char *fname) { |
|
Line 420 int oxsFileToVar(char *v,char *fname) { |
|
int limit; |
int limit; |
int c,i; |
int c,i; |
|
|
if (v == NULL) errorKan1("%s\n","oxsFileToVar(), v is NULL."); |
if (v == NULL) { |
|
/* errorKan1("%s\n","oxsFileToVar(), v is NULL."); */ |
|
fprintf(stderr,"oxsFileToVar(), v is NULL."); |
|
return(-1); |
|
} |
limit = 1024; |
limit = 1024; |
fp = fopen(fname,"r"); |
fp = fopen(fname,"r"); |
if (fp == NULL) { |
if (fp == NULL) { |
fprintf(stderr,"Filename=%s\n",fname); |
fprintf(stderr,"Filename=%s\n",fname); |
errorKan1("%s\n","oxsFileToVar(), the file cannot be opened."); |
/* errorKan1("%s\n","oxsFileToVar(), the file cannot be opened."); */ |
|
fprintf(stderr,"oxsFileToVar(), the file cannot be opened."); |
|
return(-1); |
} |
} |
s = (char *)mymalloc(limit); |
s = (char *)mymalloc(limit); |
if (s == NULL) errorKan1("%s\n","No more memory in oxsFileToVar()."); |
if (s == NULL) errorKan1("%s\n","No more memory in oxsFileToVar()."); |
|
|
i = 0; |
i = 0; |
while ((c=fgetc(fp)) != EOF) { |
while ((c=fgetc(fp)) != EOF) { |
s[i] = c; s[i+1] = 0; |
s[i] = c; s[i+1] = 0; |
if (i > limit - 10) { |
if (i > limit - 10) { |
sold = s; limit *= 2; |
sold = s; limit *= 2; |
s = (char *)mymalloc(limit); |
s = (char *)mymalloc(limit); |
if (s == NULL) errorKan1("%s\n","No more memory in oxsFileToVar()."); |
if (s == NULL) errorKan1("%s\n","No more memory in oxsFileToVar()."); |
strcpy(s,sold); |
strcpy(s,sold); |
} |
} |
i++; |
i++; |
} |
} |
fclose(fp); |
fclose(fp); |
Line 359 static char **oxsBuildArgv(struct object ob) { |
|
Line 468 static char **oxsBuildArgv(struct object ob) { |
|
if (ob.tag != Sarray) errorKan1("%s\n","oxsBuildArgv() requires an array as an argument."); |
if (ob.tag != Sarray) errorKan1("%s\n","oxsBuildArgv() requires an array as an argument."); |
n = getoaSize(ob); |
n = getoaSize(ob); |
for (i=0; i<n; i++) { |
for (i=0; i<n; i++) { |
if (getoa(ob,i).tag != Sdollar) errorKan1("%s\n","oxsBuildArgv() requires an array of string as an argument."); |
if (getoa(ob,i).tag != Sdollar) errorKan1("%s\n","oxsBuildArgv() requires an array of string as an argument."); |
} |
} |
|
|
argv = (char **) mymalloc(sizeof(char *)*(n+2)); |
argv = (char **) mymalloc(sizeof(char *)*(n+2)); |
Line 370 static char **oxsBuildArgv(struct object ob) { |
|
Line 479 static char **oxsBuildArgv(struct object ob) { |
|
s = oxEvalEnvVar(s); |
s = oxEvalEnvVar(s); |
ocmd = KoxWhich(KpoString(s),KpoInteger(0)); |
ocmd = KoxWhich(KpoString(s),KpoInteger(0)); |
if (ocmd.tag != Sdollar) { |
if (ocmd.tag != Sdollar) { |
argv[0] = NULL; |
argv[0] = NULL; |
}else{ |
}else{ |
argv[0] = KopString(ocmd); |
argv[0] = KopString(ocmd); |
} |
} |
argv[1] = (char *)NULL; |
argv[1] = (char *)NULL; |
if (argv[0] == NULL) { |
if (argv[0] == NULL) { |
fprintf(stderr,"cmdname=%s\n",s); |
fprintf(stderr,"cmdname=%s\n",s); |
errorKan1("%s\n","oxsBuildArgv() Command is not found.\n"); |
errorKan1("%s\n","oxsBuildArgv() Command is not found.\n"); |
} |
} |
for (i=1; i<n; i++) { |
for (i=1; i<n; i++) { |
argv[i] = argv[i+1] = NULL; |
argv[i] = argv[i+1] = NULL; |
s = KopString(getoa(ob,i)); |
s = KopString(getoa(ob,i)); |
s = oxEvalEnvVar(s); |
s = oxEvalEnvVar(s); |
type = oxsIsURI(s); |
type = oxsIsURI(s); |
if (type == NULL) { |
if (type == NULL) { |
argv[i] = s; |
argv[i] = s; |
}else{ |
}else{ |
/* Case when argv[i] is like "stringInOut:abc.poly" */ |
/* Case when argv[i] is like "stringInOut:abc.poly" */ |
v = oxsURIgetVarName(s); |
v = oxsURIgetVarName(s); |
ext = oxsURIgetExtension(s); |
ext = oxsURIgetExtension(s); |
if (strcmp(type,"stringIn") == 0) { |
if (strcmp(type,"stringIn") == 0) { |
argv[i] = oxsVarToFile(v,ext,argv[0],usetmp); |
argv[i] = oxsVarToFile(v,ext,argv[0],usetmp); |
AfterDeleteFile[AfterD++] = argv[i]; |
AfterDeleteFile[AfterD++] = argv[i]; |
}else if (strcmp(type,"stringInOut") == 0) { |
}else if (strcmp(type,"stringInOut") == 0) { |
argv[i] = oxsVarToFile(v,ext,argv[0],usetmp); |
argv[i] = oxsVarToFile(v,ext,argv[0],usetmp); |
AfterDeleteFile[AfterD++] = argv[i]; |
AfterDeleteFile[AfterD++] = argv[i]; |
AfterReadFile[AfterPt] = argv[i]; |
AfterReadFile[AfterPt] = argv[i]; |
AfterSetVar[AfterPt] = v; |
AfterSetVar[AfterPt] = v; |
AfterPt++; |
AfterPt++; |
if (AfterPt >= MAXFILES) { |
if (AfterPt >= MAXFILES) { |
AfterPt=0; |
AfterPt=0; |
errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); |
errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); |
} |
} |
}else if (strcmp(type,"stringOut") == 0) { |
}else if (strcmp(type,"stringOut") == 0) { |
argv[i] = generateTMPfileName2(v,ext,usetmp,win); |
argv[i] = generateTMPfileName2(v,ext,usetmp,win); |
AfterDeleteFile[AfterD++] = argv[i]; |
AfterDeleteFile[AfterD++] = argv[i]; |
AfterReadFile[AfterPt] = argv[i]; |
AfterReadFile[AfterPt] = argv[i]; |
AfterSetVar[AfterPt] = v; |
AfterSetVar[AfterPt] = v; |
AfterPt++; |
AfterPt++; |
if (AfterPt >= MAXFILES) { |
if (AfterPt >= MAXFILES) { |
AfterPt=0; |
AfterPt=0; |
errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); |
errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); |
} |
} |
}else { |
}else { |
errorKan1("%s\n","This URI type has not yet been implemented."); |
errorKan1("%s\n","This URI type has not yet been implemented."); |
} |
} |
if (AfterD >= MAXFILES) { |
if (AfterD >= MAXFILES) { |
AfterD=0; |
AfterD=0; |
errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); |
errorKan1("%s\n","oxsBuildArgv(), Too may files to open."); |
} |
} |
} |
} |
} |
} |
return(argv); |
return(argv); |
} |
} |
Line 430 static struct object oxsExecuteBlocked(struct object o |
|
Line 539 static struct object oxsExecuteBlocked(struct object o |
|
{ |
{ |
int r,i,n; |
int r,i,n; |
char **argv; |
char **argv; |
|
int errorf; |
|
|
/* bug: Set stdout, stderr to result variables. */ |
|
argv = oxsBuildArgv(ob); |
argv = oxsBuildArgv(ob); |
|
argv = oxsBuildArgvRedirect(argv); |
r=oxForkExecBlocked(argv); /* bug: what happen when NoX? */ |
r=oxForkExecBlocked(argv); /* bug: what happen when NoX? */ |
/* |
/* |
if (1) { |
if (1) { |
for (i=0; argv[i] != NULL; i++) { |
for (i=0; argv[i] != NULL; i++) { |
fprintf(stderr,"argv[%d]=%s\n",i,argv[i]); |
fprintf(stderr,"argv[%d]=%s\n",i,argv[i]); |
} |
} |
errorKan1("%s\n","ForkExecBlocked failed."); |
errorKan1("%s\n","ForkExecBlocked failed."); |
} |
} |
*/ |
*/ |
|
errorf=0; |
if (AfterPt > 0) { |
if (AfterPt > 0) { |
for (i=0; i< AfterPt; i++) { |
for (i=0; i< AfterPt; i++) { |
oxsFileToVar(AfterSetVar[i],AfterReadFile[i]); |
if (oxsFileToVar(AfterSetVar[i],AfterReadFile[i]) != 0) { |
} |
errorf=1; |
|
} |
|
} |
} |
} |
AfterPt = 0; |
AfterPt = 0; |
|
|
if (AfterD > 0) { |
if (AfterD > 0) { |
for (i=0; i< AfterD; i++) { |
for (i=0; i< AfterD; i++) { |
/* oxDeleteFile(AfterDeleteFile[i]); not implemented. */ |
if (!KeepTmpFiles) { |
} |
oxDeleteFile(AfterDeleteFile[i]); |
|
} |
|
} |
} |
} |
AfterD = 0; |
AfterD = 0; |
|
if (errorf) errorKan1("%s\n","Some errors in oxsFileToVar()."); |
|
|
return(KpoInteger(r)); |
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<n; i++) { |
|
if (strcmp(argv[i],"<")==0) { |
|
fname=argv[i+1]; |
|
OX_P_stdin = open(fname,O_RDONLY); |
|
if (OX_P_stdin < 0) { |
|
OX_P_stdin = -1; |
|
oxResetRedirect(); |
|
errorKan1("%s\n","oxsBuildArgvRedirect fails to open the input file."); |
|
} |
|
i++; |
|
}else if (strcmp(argv[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 ); |
} |
} |