1

私がやりたいのは、pipe1を使用して親から子に乱数を送信することです。次に、子プロセスexecsortプログラムを使用して、これらの番号を並べ替え、pipe2を使用して親プロセスに送り返します。これで、「if（pipe2In> = 0）{dup2（pipe2In、1）; close（pipe2In）;}」とコメントアウトすると、stdoutから正しい並べ替え結果を取得できますが、次のように親のpipe2から読み取ることができません。 。実際には、読み取り呼び出しは戻ることができません。私は何かが足りないのですか？助けに感謝します。

const int READ = 0, WRITE = 1;
{
pid_t pid;
int pipe1[2], pipe2[2];

if ( pipe(pipe1) ) 
{
    cerr << "Error! Pipe 1 Failed. errno = "<< errno << endl;
    exit(1);
}

int pipe1In = pipe1[WRITE];
int pipe1Out = pipe1[READ];

if ( pipe(pipe2) ) 
{
    cerr << "Error! Pipe 2 Failed. errno = "<< errno << endl;
    exit(1);
}
int pipe2In = pipe2[WRITE];
int pipe2Out = pipe2[READ];

pid = fork();
if( pid < 0 )
{
    cerr << "Error! Fork Failed!\n";
    exit( 1 );
}
else if ( pid == 0 ) // child
{
    close(pipe1In);
    close(pipe2Out);

    if( pipe1Out >= 0 )
    {
        dup2( pipe1Out, 0 );
        close(pipe1Out);
    }
    if( pipe2In >= 0)
        {
            dup2(pipe2In, 1);
        close(pipe2In);
    }

    execlp("sort", "sort", "-nr", (char *)NULL);
    cerr << "Error - Exec Failed!\n";
    exit( -2 );
} // end of child


close(pipe1Out);         // parent continues from here
close(pipe2In);

// generate random numbers
int rn, tem, i, len;
for (i = 0; i < nWks; i++)
{
    rn = rand();
    tem = rn;
    len = 1;
    while (tem /= 10) len++;
    char *bufWrite = (char *) malloc(len+1);
        sprintf(bufWrite, "%d\n", rn);
    write(pipe1In, bufWrite, len+1);
}
char bufRead[1024];
int n;
while ( n = read(pipe2Out, bufRead, sizeof(bufRead)) != 0)
{
    printf("read count %d\n", n);
}
}
4

1 に答える 1

2

sortEOF入力ストリームでを受信するまで、出力を提供しません。これをトリガーするには、親プロセスでclose(pipe1In);読み取りループの前に行う必要があります。

于 2013-03-10T05:10:38.930 に答える