0

我正忙于一项任务，但我被困住了。我得到错误，我不明白我做错了什么。

所以我主要生了三个孩子。在第一个和第二个之间我有一个管道（pipe12）。在第二个和第三个之间我有一个管道（pipe23）。现在，当第一个孩子 ( reader) 准备好阅读时，它会关闭pipe12，但第二个孩子的阅读没有得到EOF. 其次，当第二个孩子想写信时pipe23，孩子崩溃了。

我想我在管道的初始化中做错了什么，但是什么？

这是家长

for(childnr=2; childnr>=0;childnr--)
{
    tasks[childnr].pid=fork();
    if(tasks[childnr].pid==-1)
    {
        printf("fork error\n");
        exit(1);
    }
    else if(tasks[childnr].pid==0)
    {
        switch(childnr)
        {
            case 0:
                close(pipe12[0]);
                close(pipe23[0]);
                close(pipe23[1]);
                reader();
                break;
            case 1:
                close(pipe12[1]);
                close(pipe23[0]);
                tokenizer();
                break;
            case 2:
                close(pipe12[0]);
                close(pipe12[1]);
                close(pipe23[1]);
                evaluator();
                break;
            default:
                printf("childnr error\n");                      //errorhandling
        }           
    }
    else
        close(tasks[childnr].errorpipe[1]);
}
close(pipe12[0]);
close(pipe12[1]);
close(pipe23[0]);
close(pipe23[1]);
... continue with the parent

这是第一个孩子：

void reader(void)
{   
    atexit(*reader_exit);
    if((readfile = fopen(calculatorfile,"r"))==NULL)
    {
        printf("R send error to errorHandler");     //errpipe!
        exit(0);
    }
    char line[50];
    const char *valid_characters = "0123456789 +-/*\n";
    while(fgets ( line, sizeof line, readfile ) != NULL)
    {
        printf("R reading ...%s",line);
        char *c = line;
        while(*c)
        {
            if(!strchr(valid_characters,*c))
            {
                printf("R invalid character: %c in %s",*c,line);
                line[0]=0;
                break;
            }
            c++;
        }
        write(pipe12[1],line,sizeof line);
    }
    exit(0);
}

void reader_exit(void)
{
    printf("R reader exit\n");
    fclose(readfile);
    close(pipe12[1]);
    close(tasks[childnr].errorpipe[1]);
}

第二个孩子：

void tokenizer(void)
{
    atexit(*tokenizer_exit);
    char buffer[50];
    while(read(pipe12[0],buffer,sizeof buffer)!=EOF)
    {
        printf("T %s",buffer);
        char *token = strtok(buffer," ");
        while(token!=NULL)
        {
            printf("T %s\n",token);
            write(pipe23[1],token,sizeof token);
            token = strtok(NULL, " ");
        }
        sleep(2);
    }
    exit(0);
}
4

1 回答 1

1

您的主要问题是read()在 EOF 上返回 0，而不是 -1 或 EOF。

您的代码应该有如下循环：

while (read(pipe12[0], buffer, sizeof buffer) > 0)

我建议避免使用atexit();注册的功能。他们强迫你使用全局变量。让您的主要子函数进行自己的清理。这将更容易实施评论中提出的建议：

您可以通过将文件描述符传递给阅读器来提高阅读器的通用性，并且与标记器和评估器类似：

reader(pipe12[1])
tokenizer(pipe12[0], pipe23[1]);
evaluator(pipe23[0]);

对于读者，您可能也应该传递文件名：

reader(calculatorfile, pipe12[1]);

这段代码几乎可以工作：

#include <stdio.h>
#include <unistd.h>
#include <sys/wait.h>
#include <stdlib.h>     /* atexit() */
#include <string.h>

static int pipe12[2];
static int pipe23[2];

struct task
{
    pid_t pid;
};
static struct task tasks[5];

static void evaluator(int i_fd);
static void tokenizer(int i_fd, int o_fd);
static void reader(char const *file, int o_fd);

int main(void)
{
    pipe(pipe12);
    pipe(pipe23);
    for (int childnr=2; childnr>=0;childnr--)
    {
        tasks[childnr].pid=fork();
        if (tasks[childnr].pid==-1)
        {
            printf("fork error\n");
            exit(1);
        }
        else if (tasks[childnr].pid==0)
        {
            switch (childnr)
            {
                case 0:
                    close(pipe12[0]);
                    close(pipe23[0]);
                    close(pipe23[1]);
                    reader("data-file", pipe12[1]);
                    break;
                case 1:
                    close(pipe12[1]);
                    close(pipe23[0]);
                    tokenizer(pipe12[0], pipe23[1]);
                    break;
                case 2:
                    close(pipe12[0]);
                    close(pipe12[1]);
                    close(pipe23[1]);
                    evaluator(pipe23[0]);
                    break;
                default:
                    printf("childnr error\n");                      //errorhandling
                    break;
            }           
        }
    }
    close(pipe12[0]);
    close(pipe12[1]);
    close(pipe23[0]);
    close(pipe23[1]);

    printf("Parent waiting...\n");
    while (wait(0) != -1)
        ;
    printf("Brats are all dead!\n");
    return(0);
}

static void reader(char const *file, int o_fd)
{   
    FILE *fp;
    if ((fp = fopen(file, "r"))==NULL)
    {
        printf("R send error to errorHandler");     //errpipe!
        exit(0);
    }
    char line[50];
    const char *valid_characters = "0123456789 +-/*\n";
    while (fgets(line, sizeof(line), fp) != NULL)
    {
        printf("RI %s", line);
        char *c = line;
        while (*c)
        {
            if (!strchr(valid_characters, *c))
            {
                printf("R invalid character: %c in %s\n", *c, line);
                line[0] = '\0';
                break;
            }
            c++;
        }
        if (line[0] != '\0')
        {
            printf("RO %s", line);
            write(o_fd, line, strlen(line));
        }
    }
    close(o_fd);
    fclose(fp);
    printf("Reader exiting\n");
    exit(0);
}

static void tokenizer(int i_fd, int o_fd)
{
    char buffer[50];
    int nbytes;
    while ((nbytes = read(i_fd, buffer, sizeof(buffer))) > 0)
    {
        buffer[nbytes] = '\0';
        printf("TI %*s\n", nbytes, buffer);
        char *token = strtok(buffer, " \n");
        while (token!=NULL)
        {
            printf("TO %s\n", token);
            write(o_fd, token, strlen(token));
            token = strtok(NULL, " ");
        }
        sleep(2);
    }
    printf("Tokenizer exiting\n");
    exit(0);
}

static void evaluator(int i_fd)
{
    char buffer[50];
    int nbytes;
    while ((nbytes = read(i_fd, buffer, sizeof(buffer))) > 0)
    {
        printf("EI %*s\n", nbytes, buffer);
        buffer[nbytes] = '\0';
        char *token = strtok(buffer, " ");
        while (token!=NULL)
        {
            printf("EO %s\n", token);
            token = strtok(NULL, " ");
        }
        sleep(2);
    }
    close(i_fd);
    printf("Evaluator exiting\n");
    exit(0);
}

给定一个数据文件，其中包含：

123 456
123 + 234 * 547 / 987 - 1

该程序的一次运行产生了：

Parent waiting...
RI 123 456
RO 123 456
RI 123 + 234 * 547 / 987 - 1
RO 123 + 234 * 547 / 987 - 1
Reader exiting
TI 123 456

TO 123
TO 456

EI 123
EO 123
TI 123 + 234 * 547 / 987 - 1
EI 456

TO 123
TO +
TO 234
TO *

TO 547
TO /
EO 456

TO 987
TO -
TO 1

EI 123+234*547/987-1

EO 123+234*547/987-1

Tokenizer exiting
Evaluator exiting
Brats are all dead!

请注意，读取的数据read()必须显式以 null 终止；读取的数据fgets()没有。还要注意基本调试是如何进行的；回显所有输入，也回显下一个程序的所有输出。这使得查看可能存在问题的位置变得容易（或者至少更容易）。在极端情况下，最好写到stderr，或者fflush()在每个 之后写printf()。有许多细节是次优的，例如printf()仅使用单个字符串参数。此代码中的任务结构是多余的。管道数组可以是修改后的代码中的局部变量。

于 2012-05-24T22:09:40.907 回答