eneller/GdBShell
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

improved pipe behaviour

Browse Source
This commit is contained in:
eneller
2020-08-14 11:22:00 +02:00
parent e83c261923
commit 377fcae345
1 changed files with 34 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
GdBShell.java
View File

@@ -175,6 +175,7 @@ public class GdBShell {
int returnValue = parsePipe(command, fd_in, fd_out); int returnValue = parsePipe(command, fd_in, fd_out);
//close potential files //close potential files
if (fd_in != -1) { if (fd_in != -1) {
close(fd_in); close(fd_in);
} }
@@ -196,12 +197,16 @@ public class GdBShell {
//first command gets stdin //first command gets stdin
int lastIn = -1; int lastIn = -1;
int[] pipefd = new int[2];//array to pass to pipe as out parameter, then contains the read end[0] and write end[1] int[] pipefd = new int[2];//array to pass to pipe as out parameter, then contains the read end[0] and write end[1]
if (command.length > 1) { if (command.length > 1) {
returnValue = pipe(pipefd); returnValue = pipe(pipefd);
if(returnValue!=0){printColor("error","cyan", true);return returnValue;} if(returnValue!=0){printColor("Error opening pipe","red", true);return returnValue;}
returnValue = execute(command[0], fd_in, pipefd[1]);//execute first command with potential input from file
returnValue = execute(command[0], fd_in,false, pipefd[1],true);//execute first command with potential input from file
for (int i = 1; i < command.length - 1; i++) { for (int i = 1; i < command.length - 1; i++) {
returnValue = execute(command[i], pipefd[0], pipefd[1]);
returnValue = execute(command[i], pipefd[0],false, pipefd[1],true);
} }
lastIn = pipefd[0]; lastIn = pipefd[0];
@@ -210,14 +215,17 @@ public class GdBShell {
} }
// execute last (or only) command // execute last (or only) command
returnValue = execute(command[command.length - 1], lastIn, fd_out); returnValue = execute(command[command.length - 1], lastIn,true, fd_out,true);
return returnValue; return returnValue;
} }
static int execute(String[] inputArray, int fd_in, int fd_out) {//0 for read, 1 for write static int execute(String[] inputArray, int fd_in,boolean closefdIn, int fd_out, boolean closefdOut) {//0 for read, 1 for write
System.out.println(Arrays.toString(inputArray)+ " fd_in: "+fd_in+" fd_out: "+fd_out); System.out.println(Arrays.toString(inputArray)+ " fd_in: "+fd_in+" fd_out: "+fd_out);
int[] intArray = new int[]{Integer.MIN_VALUE};//to pass to the waitpid function int[] intArray = new int[]{Integer.MIN_VALUE};//to pass to the waitpid function
//split the Array into path and arguments //split the Array into path and arguments
@@ -281,8 +289,9 @@ public class GdBShell {
return forkInt; return forkInt;
} }
//close open files that only the child process needs //close open files that only the child process needs
if(fd_in!=-1){close(fd_in);} if(closefdIn&&fd_in!=-1){close(fd_in);}
if(fd_out!=-1){close(fd_out);} if(closefdOut&&fd_out!=-1){close(fd_out);}
//wait for child //wait for child
if(waitpid(forkInt, intArray, 0)<0){ if(waitpid(forkInt, intArray, 0)<0){
printColor("Error: waiting for child", "red",true); printColor("Error: waiting for child", "red",true);