qmsg.cpp

Linux 下 Qte IPC通信程序

#include "Qmsg.h"

QMsg::QMsg()
{
    msgid = 0;
    key = 6789; //radom number
    buffer[BUFFER] = 0;
}
/*
 * Send message (Put to first position)
 */
int QMsg::sendMsg(const char * msg, int debug)
{
    
    if(msgid == 0 ) {
        if((msgid=msgget(key, 0660|IPC_CREAT))==-1){
    	    fprintf(stderr,"QMsg::MSG Init Error(s):%s\n",strerror(errno));
    	    return -1;
        }
    }

    msgrcv(msgid,buffer, BUFFER, 0, IPC_NOWAIT);
    sprintf(buffer, "%s", msg); //over flow?
    buffer[BUFFER] = 0;
    
    if(msgsnd(msgid, buffer, BUFFER, 0)==-1)
    {
    	fprintf(stderr, "QMsg::MSG Send Error\n");
    	return -1;
    }
    
    if(debug !=0 )
        fprintf(stderr, "QMsg::sendMsg = %s\n", buffer);

    return 0;
}

/*
 * Get message (Just the first one)
 */

int QMsg::getMsg()
{
    if(msgid == 0 ) {
        if((msgid=msgget(key, 0660|IPC_CREAT))==-1){
    	    fprintf(stderr, "QMsg::MSG Init Error(c):%s\n", strerror(errno));
    	    return -1;
        }
    }

    return msgrcv(msgid, buffer, BUFFER, 0, IPC_NOWAIT);
    
}