FIFO에 대한 질문입니다.

아.. process 1에 process 2가 FIFO의 내용을 읽었는지 않읽었는지 체크하는 부분이 없네요.

그냥 쓰고 close 하는 방식으로 해놨습니다.

그부분이 문제가 있는것 같으네요.

어떻게 해결해야 될까요?
그냥 sleep등으로 읽어갈때까지 시간여유를 좀 주어야 되나요?

감사합니다. ^^

에구.. 제가 바보같은 짓을.. ^^;;

read 할 때 while 루프 내에서 매번 FIFO를 열고닫고 해놓아서 않된 것 같으네여.. ^^;;

소스코드 다시한번 올려봅니다..
제 생각대로 수정해봤는데..
한군데서는 되고 한군데서는 않되기에 문제가 있나 싶어서 다시 질문드립니다.

아래는 process 1의 소스입니다.

    
처음에 constructor에서 한번만 실행합니다.
    if (access(FIFO_NAME, F_OK) == -1)  { 
            res = mkfifo(FIFO_NAME, 0777); 
            if (res != 0 )      { 
                    fprintf(stderr, " Could not create fifo %s\n", FIFO_NAME); 
                    exit(EXIT_FAILURE); 
            } 
    } 

    pipe_fd = open(FIFO_NAME, O_WRONLY); 


다음 부분은 write할 필요가 있을때마다 한번씩 실행합니다.


    if (pipe_fd != -1) { 
          while(bytes_sent < 50) { 
                res = write(pipe_fd, buffer.c_str(), BUFFER_SIZE); 
            if (res == -1) { 
                fprintf(stderr, "Write error on pipe\n"); 
                exit(EXIT_FAILURE); 
            } 
            bytes_sent += res; 
          } 
    }

다음부분은 destructor에서 한번만 실행합니다.
          (void)close(pipe_fd);  

아래는 process 2의 소스입니다.

    if (access(FIFO_NAME, F_OK) == -1)  { 
            res = mkfifo(FIFO_NAME, 0777); 
            if (res != 0 )      { 
                    fprintf(stderr, " Could not create fifo %s\n", FIFO_NAME); 
                    exit(EXIT_FAILURE); 
            } 
    } 


    memset(buffer, '\0', sizeof(buffer)); 

    pipe_fd = open(FIFO_NAME, O_RDONLY | O_NONBLOCK); 

    while(1)
    {

    if (pipe_fd != -1) { 
        do { 
            res = read(pipe_fd, buffer, BUFFER_SIZE); 
            bytes_read += res; 
        } while (res > 0); 
        printf("fifo content : %s:\n", buffer); 
    }
    sleep(1)
    }

    (void)close(pipe_fd); 

process 2는 while를 사용해서 1초당 한번씩 실행되게 되어있습니다.

process 2에서는 FIFO를 한번만 열고 닫으면서 while루프로 1초에 한번씩 process가 write 한 내용을 읽어옵니다.
그리고 원하는 작업이 끝나면 마지막에 process 2가 죽으면서 FIFO를 닫습니다.

이렇게 했는데 write 할수 없다고 에러가 자꾸 뜨네요..

그럼 조언 부탁드립니다.