communication-interface.c

smcp报文处理,阅读您的文件包然后写出其具体功能

#include "communication-interface.h"

int create_msg_queue(int key)
{
    int msgfd;
    if( (msgfd = msgget(key, IPC_CREAT|IPC_EXCL| 00666)) < 0)
    {
        if( (msgfd = msgget(key, IPC_CREAT|00666)) < 0)
            return -1;
        else
            return 0;
    }
    return msgfd;
}
int set_msg_queue_length(int msgfd, int length)
{
    struct msqid_ds msg_sinfo;
    msg_sinfo.msg_qbytes = length;
    if(msgctl(msgfd, IPC_SET,&msg_sinfo) < 0)
    {
        return -1;
    }
    return 0;
}
int delete_msg_queue(int msgfd)
{
    if(msgctl(msgfd, IPC_RMID,NULL) < 0)
    {
        return -1;
    }
    return 0;
}
int sndto_msg_queue(int msgfd, unsigned char *message,int length)
{
    int ret;
    msg_sbuf_t msg_sbuf;
    msg_sbuf.mtype = 10;
    memcpy(msg_sbuf.mtext, message,length);
    if( (ret = msgsnd(msgfd, &msg_sbuf, length, IPC_NOWAIT)) < 0)
    {
        return -1;
    }
    return ret;

}
int rcvfrm_msg_queue(int msgfd, unsigned char *message)
{
    int ret;
    msg_sbuf_t msg_rbuf;
    if( (ret=msgrcv(msgfd, &msg_rbuf, MAX_MSG_LENGTH,
            10, IPC_NOWAIT|MSG_NOERROR) ) < 0)
    {
        return -1;
    }
    memcpy(message,msg_rbuf.mtext,ret);
    return ret;

}