0

私は仕事で忙しいのですが、行き詰まっています。エラーが発生し、何が間違っているのかわかりません。

ですから、主に私は3人の子供を作ります。1番目と2番目の間にパイプ（pipe12）があります。2番目と3番目の間にパイプ（pipe23）があります。これで、最初の子（reader）が読み取りの準備ができると、閉じますpipe12が、2番目の子の読み取りは。を取得しませんEOF。次に、2番目の子が書き込みを行う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]);
}

そして2番目の子供：

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()-1やEOFではなく、EOFで0を返すことです。

コードには次のようなループが必要です。

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

プログラムを 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 に答える