메시지 큐 생성에 관해서
안녕하세요..
이곳에 첨 글을 올려봅니다.
다름이 아니라 프로세스간 메시지 큐를 사용해서 통신을 하고자 하는데요
몇가지 궁금한 사항이 있어서 메일 드립니다.
리눅스에서는 프로세스당 생성할 수 있는 메시지 큐 수가 제한되어 있는지 궁금합니다.
제가 테스트 해 볼려고 아래와 같은 코드로 테스트 할려고 하니 16개 정도
메시지 큐를 생성하고 난 이후에는 나머지에서는 모두 에러로 떨어지는데
이것이 리눅스 시스템 제한 사항 때문인지 아니면 제가 사용한 아래의 코드가 잘 못 되어서 그런 것인지 조언 부탁 드립니다.
그리고 참고로 프로그램 실행시 에러 코드와 내용은 아래와 같습니다.
ErrorCode : 28, 에러 메시지 : No space left on device
그럼 부탁드립니다.
============================================
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define MAX_TEXT 512
//#define MSG_key (key_t)0xa0089000 /* 0xa0089900 ~ 0xa00899xx */
static int MSG_idx[1001];
struct my_msg_st {
long int my_msg_type;
char some_text[MAX_TEXT];
};
int main()
{
int run = 1;
int msgid;
int i;
char buffer[MAX_TEXT];
struct my_msg_st some_data;
long int msg_to_receive = 0;
printf("Enter some text : ");
fgets(buffer, BUFSIZ, stdin);
strcpy(some_data.some_text, buffer);
if( strncmp(some_data.some_text, "start", 5) == 0 )
{
for( i = 1; i <= 1000; i++ )
{
//msgid = msgget((key_t)MSG_key+(key_t)i, 0666|IPC_CREAT);
msgid = msgget((key_t)i, 0666|IPC_CREAT);
if( msgid == -1 )
{
fprintf(stderr, "msgget failed with error : [%d], [%s]\n", errno, sys_errlist[errno]);
//exit(EXIT_FAILURE);
}
else
{
MSG_idx[i] = msgid;
printf("QNUM - [%d], ID - [%d], [%d]\n", i, msgid, MSG_idx[i]);
sleep(1);
}
}
}
printf("Enter some text : ");
fgets(buffer, BUFSIZ, stdin);
strcpy(some_data.some_text, buffer);
if( strncmp(some_data.some_text, "end", 3) == 0 )
{
for( i = 1; i <= 1000; i++ )
{
if( msgctl(MSG_idx[i], IPC_RMID, 0) == -1 )
{
fprintf(stderr, "msgget failed with error : [%d]\n", errno);
//exit(EXIT_FAILURE);
}
else
{
printf("QNUM - [%d], ID - [%d]\n", i, MSG_idx[i]);
sleep(1);
}
}
}
/*
msgid = msgget((key_t)1234, 0666|IPC_CREAT);
if( msgid == -1 )
{
fprintf(stderr, "msgget failed with error : [%d]\n", errno);
exit(EXIT_FAILURE);
}
while(run)
{
printf("Enter some text : ");
fgets(buffer, BUFSIZ, stdin);
some_data.my_msg_type = 1;
strcpy(some_data.some_text, buffer);
if( msgsnd(msgid, (void *)&some_data, MAX_TEXT, 0) == -1 )
{
fprintf(stderr, "msgsnd failed with error : [%d]\n", errno);
exit(EXIT_FAILURE);
}
printf("Data : [%s}\n", some_data.some_text);
if( strncmp(some_data.some_text, "end", 3) == 0 )
{
run = 0;
}
}
*/
exit(EXIT_SUCCESS);
}
============================================


댓글 달기