메시지 큐를 이용해 우선순위가 있는 데이터를 주고받는 프로그램인데, 실행결과 예상과 다르게 출력됩니다.

26_3.c 에서 메시지 큐를 생성하고 우선순위와 데이터로 구성된 메시지를 보내고,
26_4.c 는 메시지 큐에서 우선순위가 높은 메시지부터 읽어오게 하려고 그럽니다.
소스는 아래부분에 있습니다.

실행결과가 아래와 같이 나와야 제대로 동작하는 겁니다.

$26_3
input data -> Hello
input priority -> 7
input data -> Programming
input priority -> 3
input data -> Linux
input priority -> 5
input data -> quit

$26_4
data : Programming [3]
data : Linux [5]
data : Hello [7]
no message

그런데 실행결과가 아래와 같이 data와 priority 를 한번밖에 받질못하고 msgsnd failed : Identifier removed 라고 나옵니다.

$26_3
input data => Hello
input priority => 7
msgsnd failed: Identifier removed

소스에 이상이 있는지 잘 봐주시기 바랍니다.
아래는 26_3.c와 26_4.c 입니다.

-----------------------------------26_3.c-----------------------------
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

#define SIZE 124
/* 메시지 형식을 저장하는 type 멤버를 우선순위를 저장하는 용도로 사용한다. */
struct {
long type;
char data[SIZE];
} msg_data;

main()
{
int msqid, data_len;
char buffer[SIZE];

/* 1234 키의 메시지 큐 생성 */
if(msqid = msgget((key_t)1234, IPC_CREAT|0666) == -1) {
perror("msgget failed");
exit(1);
}

while(1) {
/* 표준입력장치로부터 데이터 입력 */
printf("input data => ");
scanf("%s", buffer);
/* 입력받은 내용이 ‘quit’이면 while 문 벗어남 */
if(!strcmp(buffer, "quit"))
break;
/* 표준입력장치로부터 우선순위 입력 */
printf("input priority => ");
scanf("%ld", &(msg_data.type));
strcpy(msg_data.data, buffer);
/* msg_data 메시지를 msqid 메시지 큐에 전송 */
if(msgsnd(msqid, &msg_data, strlen(msg_data.data), 0) == -1) {
perror("msgsnd failed");
exit(1);
}
}
exit(0);
}
------------------------------26_4.c-------------------------------------

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <errno.h>

#define SIZE 124
#define PRIOR 10 /* 우선순위 최대값 */

struct {
long type;
char data[SIZE];
} msg_data;

main()
{
int msqid, data_len;

/* 1234 키의 메시지 큐가 있으면 접근해서 식별자 받음 */
if(msqid = msgget((key_t)1234, IPC_CREAT|0666) == -1) {
perror("msgget failed");
exit(1);
}

while(1) {
/* (-1*PRIOR)에 의해 메시지 큐에서 메시지 형식 값이 작은 메시지부터 읽음.
IPC_NOWAIT에 의해 메시지 없으면 실패로 -1 반환하는데 이때의 errno는 ENOMSG */
if((data_len=msgrcv(msqid, &msg_data, SIZE, (-1*PRIOR), IPC_NOWAIT)) == -1) {
if(errno == ENOMSG) {
printf("no message\n");
break;
}
perror("msgrcv failed");
break;
}
msg_data.data[data_len]='\0';
printf("data : %s [%ld]\n", msg_data.data, msg_data.type);
}

/* msqid 메시지 큐 삭제 */
if(msgctl(msqid, IPC_RMID, 0) == -1) {
perror("msgctl failed");
exit(1);
}

exit(0);
}