select（）とO_NONBLOCKを使用してFIFOから2つの連続した書き込みを読み取る

Question

2つの連続した文字列を書き込もうとしています。問題は、リーダーにO_NONBLOCKを使用すると、EAGAINに対して挨拶を続けていることです。

O_NONBLOCKを使用しているときに機能しない理由があれば、select()はブロックを処理してはいけませんか？

reader.c

#include <fcntl.h> 
#include <stdlib.h> 
#include <stdint.h> 
#include <string.h> 

int main() { 
    int fd; 
    char * myfifo = "/tmp/myfifo"; 

    mkfifo(myfifo, 0666); 
    fd = open(myfifo, O_RDWR | O_NONBLOCK); 

    write(fd, "12345678", strlen("12345678")); 
    write(fd, "HelloWorld", strlen("HelloWorld")); 
    close(fd); 

    return 0; 
} 

writer.c

#include <fcntl.h> 
#include <unistd.h> 
#include <stdlib.h> 
#include <stdio.h> 
#include <string.h> 
#include <errno.h> 
#include <stdint.h> 

char buf[BUFSIZ] = { 0 }, buf2[BUFSIZ] = { 0 }; 
int read1 = 0, read2 = 0; 

int main() { 
    int fd = 0, a = 0, b = 0 ; 
    char *myfifo= "/tmp/myfifo"; 

    mkfifo(myfifo, 0666); 
    fd_set set; 

    if ((fd = open(myfifo, O_RDWR | O_NONBLOCK)) < 0) 
     exit(1); 

    while (1) { 
     FD_ZERO(&set); 
     FD_SET(fd, &set); 

     if ((select(fd+1, &set, NULL, NULL, NULL)) < 1) 
      exit(1); 

     if (FD_ISSET(fd, &set)) { 
      int total = 0; 

      if ((total = read(fd, buf + read1, sizeof(uint32_t) * 2) - read1) <= 0) { 
       fprintf(stderr, "%s\n", strerror(errno)); 
       continue; 
      } 
      read1 += total; 

      if ((total = read(fd, buf2 + read2, BUFSIZ - read2)) <= 0) { 
       fprintf(stderr, "%s\n", strerror(errno)); 
       continue; 
      } 
      read2 += total; 

      fprintf(stderr, "%s %d, %d, %s\n", buf, a, b, buf2); 
      memset(buf, 0, BUFSIZ); 
      memset(buf2, 0, BUFSIZ); 
      read1 = read2 = 0; 
     } 
    } 

    return 0; 
} 

Answer 1

あなたがループ内で二回FDにreadを呼び出している、最初readがデータを読み取ることは可能です2番目のreadは、EAGAINで失敗します。 最初のものだけでなく、readを実行する前に、selectを使用して準備状況をテストする必要があります。 FIFOはストリームなので、つまり、データの異なる部分の境界を維持する必要があります。

char buf[BUFSIZ]; 
if (FD_ISSET(fd, &set)) { 
    int total = 0; 
    int off = 0; 
    total = read(fd, buf, sizeof buf); 
    if (total <= 0) { 
      fprintf(stderr, "%s\n", strerror(errno)); 
      continue; 
    } 
    // retrieve the data based on how many bytes you have read 
    if (total >= sizeof(uint32_t) * 2) { 
     ... 
    } 
} 

また、FIFOの書き込み終了を読み終わりのためのO_RDONLY、およびO_WRONLYで開くことをお勧めします。