스파게티 한 젓가락/ 저붐 하시죠(msg qu, sender측)

당연하게 될거라고 생각했는데 안되니까 짜증이 밀려오는군요.

뭐가 잘못되었을까요? -_-;;

중간의 printf는 while(1)안에서의 block을 위해서(관찰용)
집어넣은 것입니다.

#include<stdio.h>       // 표준 입출력을 위해

#include<sys/types.h>   // types    (정확치 않음)
#include<sys/ipc.h>     // System V IPC (semaphore, shared mem, msg qu)
#include<sys/msg.h>     // msg qu 관련 함수 사용을 위해

#include<time.h>     // rand() 함수의 seed로 time()을 사용하기 위해
#include<stdlib.h>   // rand() 함수의 사용을 위해

/*________________________________________________
clnt_three_module.c

형태: 무한정 또는 일정 횟수를 반복하면서
      random number를 발생시키며, msg qu에 저장하고
      읽어들여서 데이터를 화면으로 print한다.
      (중간에 시간 간격 둘 것)
________________________________________________*/

typedef struct
{
	long type;   //  msgsnd()가 요구하는 형식에 맞추기 위한 dummy
	char str[30];    // 실제 데이터를 저장할 것
}MSG;


int main(int argc, char* argv[])
{
	int mode;       // 무한정 반복: 0, 일정횟수 반복: 1
	int num_iteration;   // 반복횟수
	int i;          // for문에서 사용되는 첨자
	int snd_qu;     // send용 msg qu.   반대쪽에서는 'rcv_qu'
	int rcv_qu;     // recv용 msg qu.   반대쪽에서는 'snd_qu'
	int num_2send;  // 생성해서 보낼 숫자
	int num_recvd;  // 받은 숫자     
//	char str_num[30];   // 데이터를 주고 받을 때 사용하는 버퍼
	MSG str_num;

	if(argc == 1)
	{
		mode =0;
	}
	else
	{
		mode = 1;
		num_iteration = atoi(argv[1]);  // 반복횟수
	}

	srand((unsigned)time(NULL));   // time()을 seed로


	snd_qu = msgget((key_t)1234,IPC_CREAT);    // snd_qu 생성. 반대쪽에서는 'rcv_qu'
	rcv_qu = msgget((key_t)12340,IPC_CREAT);   // rcv_qu 생성. 반대쪽에서는 'snd_qu'
if(snd_qu == -1)printf("snd_qu 생성 실패\n");
	if(mode == 0)
	{
		while(1)   // 탈출방법은 없다. 오직 ctrl + c 만이...
		{
			num_2send = rand() % 1000000;   // 숫자 생성
printf("Enter a num: ");
scanf("%d",&num_2send);
printf("\n");
			str_num.type = 1;
			memset(str_num.str,'\0',30);    // 버퍼 초기화
			sprintf(str_num.str,"%d",num_2send);
			
			if(msgsnd(snd_qu, (MSG*)&str_num, 30, 0) == -1)   
			{
				printf("msgsnd failed!\n");
			//	break;
			}
			else
			{
				memset(str_num.str,'\0',30);   // 버퍼 초기화

				if(msgrcv(rcv_qu, (void*)&str_num, 30, 0, 0) == -1)
				{
					printf("recv qu, empty!\n");
					sleep(3);
				}
			
				num_recvd = atoi(str_num.str);

				printf("생성한 숫자:%d     받은 숫자:%d \n",num_2send,num_recvd);
			}
			
		}     // End of 'while(1)'
	}
	else   // mode = 1
	{
		for(i=0; i<num_iteration; i++)
		{

		}    // End of 'for(i=0;...'
	}     // End of 'if(mode == 0)'




	if(msgctl(rcv_qu, IPC_RMID, 0) == -1) // msg qu 닫기 실패면
	{
		printf("msg qu 닫기(IPC_RMID) 실패\n");
		exit(1);
	}

	if(msgctl(snd_qu, IPC_RMID, 0) == -1) // msg qu 닫기 실패면
	{
		printf("msg qu 닫기(IPC_RMID) 실패\n");
		exit(1);
	}

	return 0;
}