У меня есть программа, которая ожидает список команд, которые будут выполнены executeCommand3
.Цель состоит в том, чтобы выполнить список команд, которые на данный момент хранятся в этом списке, но в будущем будут набираться в оболочке в виде оболочки для выполнения, вот код:
MAIN.c
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h> //for getpid()
#include <sys/types.h> // for pid_t
#include "routines.h" //for executeCommand3()
#define SUB_PROCESSES_NUMBER 2
char *command0[] = {"ls", "tos", NULL};
char *command1[] = {"wc", NULL};
char *command2[] = {"wc", NULL};
char **commands[SUB_PROCESSES_NUMBER + 1] = {command0, command1, command2};
int main()
{
char input[1024];
printf("scan: ");
fgets(input,1024,stdin);
int value=0;
while((strcmp(input,"q\n")!=0))
{
value=executeCommand3(commands, SUB_PROCESSES_NUMBER+1);
char buffer[1024];
printf("value %i\nscan: ",value);
fgets(input,1024,stdin);
fgets(buffer,1024,stdin);
printf("%s\n",input);
}
return 0;
}
routines.c
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h> // for open, close,read,write on FD
#include <error.h> // for error handling
#include <sys/types.h> // structs like time_t
#include <sys/wait.h> // wait, waitpid, waitid - wait for process to change state
#include "routines.h"
#define READ 0 // for file descriptor index
#define WRITE 1 // for file descriptor index
#define STDIN 0
#define STDOUT 1
int executeCommand3(char ***args, int processNumb)
{
pid_t pidList[processNumb]; //list of id of cmd processes (one for each child)
int fdBackLog[processNumb][2]; // list of file desrciptors relative for each cmd (a pair for each child)
int lastProcessFlag = 0;
int i;
for (i = 0; i < processNumb; i++) //cycle through the list of commands
{
if ((i + 1) == processNumb){
lastProcessFlag = 1;
}
if (lastProcessFlag != 1)
{
int retPipe = pipe(fdBackLog[i]);
if (retPipe < 0) // generating pipe for comunication between cmd(i) and cmd(i+1)
{
perror("pipe error");
if (i > 0)
{
close(fdBackLog[i - 1][READ]);
}
exit(EXIT_FAILURE); //exit with failure code
}
}
pidList[i] = fork();
if (pidList[i] < 0) // error fork
{
perror("error fork()");
if (i > 0)
{
close(fdBackLog[i - 1][READ]);
}
close(fdBackLog[i][READ]); // close the read pipe end of cmd(i)
close(fdBackLog[i][WRITE]); //close the write pipe end of cmd(i)
exit(EXIT_FAILURE);
}
if (pidList[i] == 0) // CHILD PROCESS
{
printf("children %i process parent %i for: %s \n", getpid(), getppid(), args[i][0]);
if (lastProcessFlag != 1)
{
close(fdBackLog[i][READ]);
dup2(fdBackLog[i][WRITE], STDOUT);
close(fdBackLog[i][WRITE]); // duplicated pipes are not useful any more
}
else
{
close(fdBackLog[i][WRITE]); //last process has nothing to write on pipe
}
if (i > 0)
{
// Also need to redirect stdin if this is not first process
dup2(fdBackLog[i - 1][READ], STDIN);
close(fdBackLog[i - 1][READ]);
}
int exitValue = execvp(args[i][0], args[i]);
perror(args[i][0]);
exit(EXIT_FAILURE); // Should not be reached;
}
close(fdBackLog[i][WRITE]);
if (i > 0)
{
close(fdBackLog[i - 1][READ]);
}
}
int wPid, status;
while((wPid = wait(&status))>0)
{
printf("Child #%i (%i)\n", wPid, status);
}
}
Моя проблема связана с обработкой ошибок, фактически второй элемент первого списка команднекоторые случайные слова.
Когда я выполняю команду, вывод выводится goood (как в обычной оболочке), но проблема в том, что цикл while в MAIN.c продолжает вызывать функцию executeCommand3()
.Я думал, что это может произойти, потому что какой-то процесс в executeCommand3()
оставляет что-то в stdin файла MAIN.c, поэтому fgets
получает это из потока и сохраняет цикл цикла while.Поэтому я добавил еще один fget для прерывания цикла, но проблема все еще остается ...
Как я могу исправить программу, чтобы, даже если у меня ошибка с executeCommand3()
, цикл while останавливается, и я могу повторитьцикл нормально?Проблема в функции executeCommand3()
(может быть, в некоторых dup2()
, pipe()
...) или в MAIN.c ?