#include "common.h"


int main(int argc,char **argv)
{
//    int msqid;
    int msgflg = IPC_CREAT | 0666;
    key_t key;
    message_buf sbuf;
    MQ_Interface MQ;

    if(argc != 2){
    	fprintf(stderr, "usage %s type\n",argv[0]);
    	exit(-1);
    }

    key = 1234;

	// (void) fprintf(stderr, "\nmsgget: Calling msgget(%#lx,\
	// 	%#o)\n",key, msgflg);

    if ((MQ.msqid = msgget(key, msgflg )) < 0) {
        perror("msgget");
        exit(1);
    }
    else 
     (void) fprintf(stderr,"msgget: msgget succeeded: msqid = %d\n", MQ.msqid);

     
    MQ.sbuf.mtype = atoi(argv[1]);
    while(1){
    
	send_message(MQ);
	recv_message(MQ,atoi(argv[1])+1);
      	
	}
    msgrcv(MQ.msqid, &MQ.rbuf, 0, MQ.sbuf.mtype, 0);
	exit(0);
}