4

アイデアは、情報をツリーの下に送信し、値をツリーの上に送り返し、上に行くにつれて情報を集約するバイナリ プロセス ツリーを作成することです。

私が抱えている問題はselect()、パイプをいつ読み取る準備ができているかを判断するために使用することです。私がこれまでに書いたことでは、最初のパイプ (最初の左側の子) は情報を受け取り、それを出力することができます。ただし、2 番目のパイプ (最初の右側の子) は、情報を受け取る前にタイムアウトします。最初のパイプは問題なく動作するため、理由はわかりません。

それぞれの子は、最終的には独自の子を作成します。プロセスのこの部分を開始するには、select().

int bit_count(char *passed, int len){
//initialize file descriptors
int fd1[2] = {1, 2};
int fd2[2] = {3, 4};

fd_set read_set;
fd_set write_set;

//set timeval structure for timeout
struct timeval tv;
tv.tv_sec = 10;
tv.tv_usec = 0;

FD_ZERO(&read_set);             //clear the set
FD_SET(fd1[0], &read_set);      //add first file descriptor to set
FD_SET(fd2[0], &read_set);      //add second file descriptor to set

//open the pipes
pipe(fd1);
pipe(fd2);

//fork a child process
pid_t kid = fork();
if(kid == -1) printf("forking failed.");

if (kid == 0){  //first child process
    int status = 1;
    while(status){
        int retval = select(fd1[0]+1, &read_set, NULL, NULL, &tv);

        switch(retval) {
                case -1:
                        printf("Select Error.\n");
                        exit (-1);
                        status = 0;
                        break;

                case 0:
                        printf("Timeout...");
                        status = 0;
                        break;

                default:
                        if (FD_ISSET(fd1[0], &read_set)) {
                            char *lstring = malloc(sizeof(char)*(len/2));
                            read(fd1[0], lstring, len);
                            printf("Child Left: %s\n", lstring);
                            close(fd1);
                            //execl("child.c", parent);
                            status = 0;
                            }
                    }
    }
}

else{       //parent process
    //fork a second child process
    pid_t kid2 = fork();

    if (kid2 == 0) {    //second child process
        int status = 1;
        while(status){
            int retval = select(fd2[0]+1, &read_set, NULL, NULL, &tv);

            switch(retval) {
            case -1:
                    printf("Select Error.\n");
                    exit (-1);
                    status = 0;
                    break;

            case 0:
                    printf("Timeout...");
                    status = 0;
                    break;

            default:
                    if (FD_ISSET(fd2[0], &read_set)) {
                        char *rstring = malloc(sizeof(char)*((len/2)+(len%2)));
                        read(fd2[0], rstring, len);
                        printf("Child Right: %s\n", rstring);
                            //execl("child.c", parent);
                        status = 0;
                    }
            }
    }
    }

    else{
        int status;
        //create character arrays for
        printf("\n\nParent Original String: %s\n", passed);
        printf("Measured Length: %d\n", len);
        int left = (len/2);
        int right =(len/2)+(len % 2);
        char *lstring = malloc(sizeof(char)*(left+1));
        char *rstring = malloc(sizeof(char)*(right+1));
        memcpy(lstring, passed, left);
        lstring[left] = '\0';
        memcpy(rstring, passed+left, right);
        rstring[right] = '\0';
        printf("Parent Left: %s\n", lstring);
        printf("Parent Right: %s\n", rstring);
        write(fd1[1], lstring, sizeof(char)*(left+1));
        write(fd2[1], rstring, sizeof(char)*(right+1));
        waitpid(kid, &status, NULL);
        waitpid(kid2, &status, NULL);
        }
    return 0;
}
return 0;
}
4

1 に答える 1

5

参考ページを読めば分かると思いますが、

正常に完了すると、pselect() または select() 関数は、readfds、writefds、および errorfds 引数が指すオブジェクトを変更します。

したがって、 を呼び出す前に、ループの繰り返しごとに記述子セットを設定する必要がありますselect。

また、タイムアウト構造も変更される可能性があることに注意してください。

また、最初の引数として最大の記述子 (プラス 1) を使用する必要があります。fd2[0]より大きい場合、fd1[0]呼び出しは期待どおりに機能しません。

于 2013-10-15T05:17:08.877 に答える