我试图运行此代码,但当我从管道中读取时,没有任何信息:

Statitics:
Hora de inicio:(null)
Total pedidos:0
Pedidos recusados:0
Dominios locais:0
Dominios externos:0
Hora atual:17:5:14

我不知道怎么了。。。我需要帮助。
typedef struct{
   int pedidos;
   int loc;
   int ext;
   int rej;
   char* start;
} esta;
int fdpipe;
fd_set write_set;

//PROCESS 1--------------------------------------------------------------

作者:
esta* estatisticas;

estatisticas=(esta* )malloc(sizeof(esta));
estatisticas->start=convertTime(time(NULL));

 estatisticas->ext=1;
 estatisticas->loc=1;
 estatisticas->rej=1;
estatisticas->pedidos=1;

if (mkfifo(mpconfs->pipe_stats,0600)<0)
{
        perror("Cannot create pipe: ");
        exit(0);
}
//escrever no pipe
if ((fdpipe=open(mpconfs->pipe_stats, O_WRONLY)) < 0)
{
        perror("Cannot open pipe for writing: ");
        exit(0);
}

while(1) {
    //escrever no pipe
    FD_ZERO(&write_set);

    FD_SET(fdpipe, &write_set);



    if (select(fdpipe+1, NULL, &write_set, NULL, NULL)>0) {
        if(FD_ISSET(fdpipe,&write_set)){
            write(fdpipe, &estatisticas, sizeof(esta));
        }
    }
}

读者:
//过程2------------------------------------------------------------
fd_set read_set;
esta* estatisticas;
signal(SIGINT,catch_ctrlcProcEsts);

sleep(2);
if ((fdpipe=open(mpconfs->pipe_stats, O_RDWR)) < 0)
{
    perror("Cannot open pipe for reading: ");
    exit(0);
}

while(1){

    FD_ZERO(&read_set);
    // prepares read set to "listen" to the following FD
    FD_SET(fdpipe, &read_set);
    if (select(fdpipe+1, &read_set, NULL, NULL, NULL)>0) {
        if(FD_ISSET(fdpipe,&read_set)){

            read(fdpipe, &estatisticas, sizeof(esta));
            imprimeStats(estatisticas);
        }
    }

}
}

void imprimeStats(esta* estatisticas){
   char *horaAtual=convertTime(time(NULL));
   printf("\nStatitics:\n");
   printf("Hora de inicio:%s\n",estatisticas->start);
   printf("Total pedidos:%d\n",estatisticas->pedidos);
   printf("Pedidos recusados:%d\n",estatisticas->rej);
   printf("Dominios locais:%d\n",estatisticas->loc);
   printf("Dominios externos:%d\n",estatisticas->ext);
   printf("Hora atual:%s\n\n",horaAtual);
}

   char *convertTime(time_t time){
   char *res;
   int h, min, sec;
   res=(char*)malloc(9*sizeof(char));
   res[0]='\0';

   h=(time/3600);
   min=(time-3600*h)/60;
   sec = time%60;
   h=h%24;
   sprintf(res,"%d:%d:%d", h, min, sec);
   return res;
}

我想我什么都没忘记。

最佳答案

你可能误用了读写:
您编写了read(fdpipe, &estatisticas, sizeof(esta));但声明了esta* estatisticas;,因此您实际上发送了分配的地址和一些垃圾(未定义的行为)
你可能想写:read(fdpipe, estatisticas, sizeof(*estatisticas))
顺便说一句,你应该检查你读的字节的数量,作为读没有总是读所有的字节,你要求(可能更少)
小心,你在写端也犯了同样的错误,别忘了把它也修复掉。

关于c - 命名管道Linux,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/33962958/

10-09 21:31