2012-05-12 20 views
0

我有使用命名管道兩個簡單的程序,這裏是第一:閱讀命名管道導致inifnite循環

int main(int argc,char **argv) 
{ 
    if (argc<2) 
    error_nsys_f("usage: [fifo]"); 

    if (mkfifo(argv[1],S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH)<0) 
    error_sys_f("error while creating named pipe"); 

    int fd=open(argv[1],O_RDONLY); 
    int log_file=open("wyniki.log",O_WRONLY | O_CREAT| O_TRUNC,S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH); 
    long result; 
    size_t len; 
    if (fd<0) 
    error_sys_f("error while openning pipe"); 
    if (log_file<0) 
    error_sys_f("error while openning log file"); 
    //unlink(argv[1]); 
    char path[MAXLINE]; 
    char buffer[BUF]; 
    while(1) 
    { 
    if (read(fd,&len,sizeof(size_t)) == -1) 
    { 
     cleanup(fd,argv[1]); 
     error_sys_f("error while reading from file-name queue"); 
    } 
    if (read(fd,path,len) == -1) 
    { 
     cleanup(fd,argv[1]); 
     error_sys_f("error while reading from file-name queue"); 
    } 
    result=count(path,buffer); 
    if (result>-1) 
    { 
     sprintf(buffer,"%s: %ld\n",path,result); 
     if (write(log_file,buffer,strlen(buffer)) == -1) 
     { 
     cleanup(fd,argv[1]); 
     error_sys_f("error while writing to log-file"); 
     } 
    } 
    } 
} 

,並在第二個節目,我給了他第二個

int main(int argc,char **argv) 
{ 

if (argc<3) 
    error_nsys_f("usage: [fifo] [plik1] [plik2]...\n"); 

int fd=open(argv[1],O_WRONLY); 
int i; 
int s; 
if (fd<1) 
    error_sys_f("nie udalo sie otrzymac dostepu do kolejki"); 

for(i=2;i<argc;++i) 
{ 
    s=strlen(argv[i])+1; 
    if (write(fd,&s,sizeof(size_t)) == -1) 
    { 
     close(fd); 
     error_sys_f("error while writing to queue"); 
    } 
    if (write(fd,argv[i],strlen(argv[i])+1) == -1) 
    { 
     close(fd); 
     error_sys_f("error while writing to queue"); 
    } 
} 
close(fd); 
return EXIT_SUCCESS; 
} 

要寫入的fifo的名稱和文件的名稱,在第一個中,我讀取名稱和文件名的長度,計算字節數並將其寫入日誌文件。

但是有一個問題,如果我嘗試寫入例如一個文件名稱的fifo,第一個程序讀取名稱和長度ok,preforms計數,但在此之後,他讀取相同的文件名全部來自fifo的時間。他表現得像他沒有刪除從fifo讀取的消息。這是什麼原因?

+1

嚴重的是,如何「錯誤而打開管道」一個有用的錯誤消息?把路徑放在錯誤信息中! 「錯誤打開/富/酒吧:不是目錄」是有幫助的。 「錯誤開放管道:不是目錄」只是加重。 –

+0

好點,我沒有想到這一點,因爲現在它只是爲我個人使用。 – Andna

回答

3

您不處理read()返回0的情況,這意味着沒有更多數據,另一端關閉了管道。

所以,你的代碼應該停止,如果read()返回0,以及循環,不只是當它返回-1