Linux-C: 从管道读取 returns 写入的第一个缓冲区

Question

此程序模拟 Dijkstra 问题的变体 Producer/Consumer。首先创建管道，然后使用 fork() 创建 child 进程。然后 child 将 粗略地 随机生成的 "stock market ticker information" 写入管道。等待child/producer进程写入此信息后，parent/consumer进程将其读出。

第一次输出正确：

Produced: FPOO 57.83 +0.43
Consumed: FPOO 57.83 +0.43

然而，此后的任何输出将始终显示 "Consumed: info from first read":

Produced: RJII 71.30 -2.71
Consumed: FPOO 57.83 +0.43

我不确定为什么会发生这种情况，因为我的 tickerInfo 正在更改。这就是为什么我怀疑我没有正确读取管道或者我的分叉进程可能结构不正确。

我用g++编译了代码。它需要一个参数作为您希望程序运行的秒数。

#include <stdio.h>
#include <stdlib.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <unistd.h>
#include <time.h>
#include <string.h>

// generate info for each stock entry
void generateTickerInfo(char * info) {
    int i;
    int randNum = 0;
    srand(time(NULL)); // generate seed for random

    // generate 4 characters for STOCK sym
    for(i = 0; i < 4; i++) {
        randNum = rand() % 26 + 65;
        info[i] = (char)(randNum);
    }
    info[4] = ' ';

    // generate price traded
    for(i = 5; i < 7; i++) {
        randNum = rand() % 8 + 1;
        info[i] = '0' + randNum;
    }
    info[7] = '.';
    for(i = 8; i < 10; i++) {
        randNum = rand() % 9;
        info[i] = '0' + randNum;
    }
    info[10] = ' ';

    // determine if + or - for change amount
    randNum = rand();
    if(randNum % 2 == 1) {
        info[11] = '+';
    }
    else {
        info[11] = '-';
    }

    // generate change amount
    randNum = rand() % 9;
    info[12] = '0' + randNum;
    info[13] = '.';
    for(i = 14; i < 16; i++) {
        randNum = rand() % 9;
        info[i] = '0' + randNum;
    }
}

// ** constant and global variables **
const int BUFFER_SIZE = 25;

// ** main code **
int main(int argc, char *argv[]) {
    pid_t cpid; // child process id
    int myPipe[2]; // [0] read, [1] write
    char * tickerInfo; // hold current tickerInfo
    tickerInfo = new char[BUFFER_SIZE]; // info passed through pipe
    char buf[BUFFER_SIZE];
    time_t currentTime, stopTime;

    // initialize time variables
    if(argc < 2) {
        printf("Invalid arg. Type as 'foo.out (# seconds)'");
        exit(0);
    }
    else {
        currentTime = time(NULL);
        stopTime = time(NULL) + (time_t)atoi(argv[1]);
    }

    int pipeReturn = pipe(myPipe);

    if(pipeReturn == -1) { // handle pipe creation error
        perror("pipe error...");
        exit(0);
    }   

// main loop; continue until desired time has elapsed
    while(currentTime < stopTime) {             
        cpid = fork();

        if(cpid < 0) { // handle process creation error
            perror("forking error...\n");
            exit(0);
        }
        else if(cpid == 0) { // child process
            close(myPipe[0]); // child does not need to read
            generateTickerInfo(tickerInfo);     
            write(myPipe[1], tickerInfo, BUFFER_SIZE); 
            printf("Produced: %s\n", tickerInfo);
            exit(0);
        }
        else if(cpid > 0) { // parent process
            wait(0);
            close(myPipe[1]); // parent does not need to write
            read(myPipe[0], buf, BUFFER_SIZE);
            printf("Consumed: %s\n", buf);
        }
        sleep(1);
        currentTime = time(NULL);
    }
    return 0;
}

Answer 1

在第一个 child 完成并关闭 parent 进程中管道的写入端后，您返回到循环顶部并创建另一个 child .此 child 不继承写入 fd。写入的 fd 不见了。第二个 child 中的 write 失败，但您没有检查其 return 值是否有错误，所以您没有注意到。

parent 然后从管道读取 EOF，因为没有剩余的写入器。由于您也没有检查 read return 值（您有一个坏习惯！）您没有注意到这一点，只是打印仍然包含其先前内容的缓冲区。

Linux-C: 从管道读取 returns 写入的第一个缓冲区

Linux-C: reading from pipe returns first buffer written to it

c

linux

pipe

fork

inter-process-communicat