add IPC Message Queue sample code

Guo Wenxue

2018-12-08 1243ecf308a35e81f98d1e519602b5ddf3cab494

add IPC Message Queue sample code

 ch6_ipc/msgqueue_recver.c

New file
@@ -0,0 +1,61 @@
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

#define FTOK_PATH            "/dev/zero"
#define FTOK_PROJID          0x22

typedef struct s_msgbuf 
{
     long  mtype; 
     char  mtext[512]; 
} t_msgbuf;

int main(int argc, char **argv)
{
    key_t             key;
    int               msgid;
    t_msgbuf          msgbuf;
    int               msgtype;
    int               i;

    if( (key=ftok(FTOK_PATH, FTOK_PROJID)) < 0 ) 
    {   
    printf("ftok() get IPC token failure: %s\n", strerror(errno)); 
    return -1;
    }

    msgid = msgget(key, IPC_CREAT|0666);
    if( msgid < 0)
    {
    printf("shmget() create shared memroy failure: %s\n", strerror(errno));
    return -2;
    }

    msgtype = msgtype = (int)key;
    printf("key[%d] msgid[%d] msgypte[%d]\n", (int)key, msgid, msgtype);

    for(i=0; i<4; i++)
    {
    memset(&msgbuf,0,sizeof(msgbuf));
    if( msgrcv(msgid, &msgbuf, sizeof(msgbuf.mtext), msgtype, IPC_NOWAIT) < 0 )
    {
            printf("msgsnd() receive message failure: %s\n", strerror(errno));
        break;
    }

    printf("Receive Message: %s\n", msgbuf.mtext);
    sleep(1);
    }

    msgctl(msgid, IPC_RMID, NULL);

    return 0;
}


 ch6_ipc/msgqueue_sender.c

New file
@@ -0,0 +1,63 @@
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

#define FTOK_PATH            "/dev/zero"
#define FTOK_PROJID          0x22

typedef struct s_msgbuf 
{
     long  mtype; 
     char  mtext[512]; 
} t_msgbuf;

int main(int argc, char **argv)
{
    key_t             key;
    int               msgid;
    t_msgbuf          msgbuf;
    int               msgtype;
    int               i;

    if( (key=ftok(FTOK_PATH, FTOK_PROJID)) < 0 ) 
    {   
    printf("ftok() get IPC token failure: %s\n", strerror(errno)); 
    return -1;
    }

    msgid = msgget(key, IPC_CREAT|0666);
    if( msgid < 0)
    {
    printf("shmget() create shared memroy failure: %s\n", strerror(errno));
    return -2;
    }

    msgtype = (int)key;
    printf("key[%d] msgid[%d] msgypte[%d]\n", (int)key, msgid, msgtype);

    for(i=0; i<4; i++)
    {
        msgbuf.mtype = msgtype;
        strcpy(msgbuf.mtext,"Ping");

    if( msgsnd(msgid, &msgbuf, sizeof(msgbuf.mtext), IPC_NOWAIT) < 0)
    {
            printf("msgsnd() send message failure: %s\n", strerror(errno));
        break;
    }
    printf("Send message: %s\n", msgbuf.mtext);

    sleep(1);
    }

    msgctl(msgid, IPC_RMID, NULL);

    return 0;
}


 ch6_ipc/semaphore.c

@@ -57,8 +57,7 @@
    semaphore_p(semid);
    printf("Parent start do something now...\n");
    sleep(2);
    printf("Child process exit and ");

    printf("Perent process destroy semaphore and exit\n");

    semaphore_term(semid);
    return 0;