comm.c

#include "comm.h"

int commMsgQueue(int flags){
    key_t _key= ftok(PATHNAME,PROJ_ID);
    if(_key < 0){
        perror("ftok");
        exit(1);
    }
    //int msgget(_key,IPC_CREAT | IPC_EXCL)；
    int msgid = msgget(_key,flags);
    if(msgid < 0){
        perror("msgget");
        exit(2);
    }
    return msgid;
}

int createMsgQueue(){
    return commMsgQueue(IPC_CREAT|IPC_EXCL|0644);
}

int  getMsgQueue(){
    return commMsgQueue(IPC_CREAT);
}

int destroyMsgQueue(int msgid){
    if(msgctl(msgid,IPC_RMID,NULL) <0){
        perror("msgctl");
        return -1;
    }
    return 0;
}

int sendMsg(int msgid,int who,char *msg){
    struct msgbuf buf;
    buf.mtype = who;
    strcpy(buf.mtext,msg);
    if(msgsnd(msgid,(void *)&buf,sizeof(buf.mtext),0) < 0){
        perror("msgsnd");
        return -1;
    }
    return 0;
}

int recvMsg(int msgid,int recvType,char out[]){
    struct msgbuf buf;
    if(msgrcv(msgid,(void *)&buf,sizeof(buf.mtext),recvType,0) < 0){
        perror("msgrcv");
        return -1;
    }
    strcpy(out,buf.mtext);
    return 0;
}