msgrcv 비어있는 메시지 받기

IPC 큐를 통해 서로 메시지를주고받는 두 개의 프로그램이 있습니다. 그러나 때때로 msgrcv 함수는 실제로 대기열을 통해 보낸 내용을 수신하는 대신 빈 메시지를받습니다. 내가해야한다고 생각하는 수정 프로그램을 주석 달았지만 여기를 확인하고 이것이 msgrcv와 msgsnd를 사용하는 적절한 방법인지 확인하고 싶었다.msgrcv 비어있는 메시지 받기

위해 msgrcv :

int readqueue(int qid, long type, char *msg) 
{ 
    int retval; 

    // Current fix for blank messages 
    /* strcpy(MsgQueue.Message, ""); 

    while (strcmp(MsgQueue.Message, "") == 0) 
    { 
     retval = msgrcv(qid, &MsgQueue, MSGSIZE, (long)type, 0); 

     if (strcmp(MsgQueue.Message, "") == 0) 
      printf("msgrcv fail\n"); 
    }*/ 

    retval = msgrcv(qid, &MsgQueue, MSGSIZE, (long)type, 0); 
    strcpy(msg, MsgQueue.Message); 

    return retval; 
}

msgsnd는 :

int sendqueue(int qid, long type, char *msg) 
{ 
    struct msqid_ds stat_buf, *pstat_buf; 
    int av, retval; 

    pstat_buf = &stat_buf; 
    av = 0; 

    /* Make sure there's space in the queue */ 
    do 
    {     
     retval = msgctl(qid, IPC_STAT, pstat_buf); 
     if (retval == -1) 
     { 
      fprintf(stderr, "msgctl in sendqueue failed! Error = %d\n", errno); 
      return retval; 
     } 
    } while (pstat_buf->msg_qbytes - pstat_buf->msg_cbytes == 0); 

    strcpy(MsgQueue.Message, msg); 
    MsgQueue.MsgType = (long)type; 

    retval = msgsnd(qid, &MsgQueue, MSGSIZE, 0); 

    memset(MsgQueue.Message, '\0', MSGSIZE-1); 
    return retval; 
}

출처

2011-05-04 Zac

당신은 말 : "그러나, 때로는 위해 msgrcv 함수는 빈 메시지가 대신 실제로 통해 전송 무엇을 수신한다 대기열 "

나는 ou 실제로 문제를 디버깅하는 방법으로 무엇이 일어나고 있는지.

msgrcv은 읽은 바이트 수 또는 -1을 오류로 반환하려고합니다. 실제로 확인하고 확인해야합니다.

-1 일 경우 errno이 설정되고 알려줄 수있는 여러 가지 사항이 있습니다. 맨 페이지에 모두 나열되어 있습니다.

출처

2011-05-04 17:30:12

msgrcv는 큐 메시지에 설정된 최대 바이트 크기 인 128 바이트를받습니다. 그러나 문자열은 여전히 빈 것처럼 보입니다. – Zac

msgrcv 비어있는 메시지 받기

답변

관련 문제