Ex13. 프로세스 간 데이터 송수신 - 메세지 큐

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #define MAX_MSG_CONTENTS 10 typedef struct _MSG_DATA { long msg_type; int msg_id; int contents[MAX_MSG_CONTENTS]; } MSG_DATA; int MSG_Test(int key) { MSG_DATA snd_data; MSG_DATA rcv_data; int ndx; snd_data.msg_type = 1; snd_data.msg_id = 2; for ( ndx = 0; ndx < MAX_MSG_CONTENTS; ndx++ ) { snd_data.contents[ndx] = ndx; } MSG_Snd(MSG_SYS_TO_GUI, snd_data); MSG_Rcv(MSG_SYS_TO_GUI, &rcv_data); printf("msg_type[%d] msg_id[%d] ", rcv_data.msg_type, rcv_data.msg_id); for ( ndx = 0; ndx < MAX_MSG_CONTENTS; ndx++ ) { printf("[%d]", rcv_data.contents[ndx]); } printf("\n"); return 1; } int MSG_Snd(int keyValue, MSG_DATA data) { int msqid; if ( -1 == ( msqid = msgget( (key_t)keyValue, IPC_CREAT | 0666 ))) { perror("msgget snd failed"); return -1; } if ( -1 == msgsnd( msqid, &data, sizeof(data) - sizeof(data.msg_type), 0 )) { perror("msgsnd msqid faild"); return -1; } //IPC_STAT 메시지 큐의 현재 상태를 buf에 저장합니다. //IPC_SET 메시지 큐의 상태를 buf 값으로 변경합니다. 그러나 모든 정보는 안되고 msg_perm과 msg_qbytes 내용만 변경할 수 있습니다. //IPC_RMID 메시지 큐를 삭제합니다. 이럴 때에는 buf가 필요 없으므로 buf 를 0 으로 지정합니다. //msgctl( msqid, IPC_RMID, 0); return 1; } int MSG_Rcv(int keyValue, MSG_DATA *data) { int msqid; struct msqid_ds msqstat; int ndx; MSG_DATA rcvData; if ( -1 == ( msqid == msgget( (key_t)keyValue, IPC_CREAT | 0666 ))) { perror("msgget rcv failed"); return -1; } if ( -1 == msgctl ( msqid, IPC_STAT, &msqstat )) { perror("msgctl rcv faild"); return -1; } //printf("number of msg : %d\n", msqstat.msg_qum); //0 : Wait until receiving a message //IPC_NOWAIT : Return immediately if no message of the requested type is in the queue. The system call fails with errno set to ENOMSG. //MSG_EXCEPT : Used with msgtyp greater than 0 to read the first message in the queue with message type that differs from msgtyp. //MSG_NOERROR : To truncate the message text if longer than msgsz bytes. if ( -1 == msgrcv( msqid, &rcvData, sizeof(rcvData) - sizeof(rcvData.msg_type), 0, IPC_NOWAIT )) { perror("msgrcv faild"); return -1; } memcpy(data, &rcvData, sizeof(rcvData)); return 1; } int main(int argc, char** argv) { int key = 0x1000; MSG_Test(key); return 0; }