Categories: Open C | Code Examples

This page was last modified 05:56, 1 October 2007.

From Forum Nokia Wiki

Message Queues Description

The following code shows the message queues usage(follows the steps involved in the above link):

#include <sys/msg.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
 
#define MSG_KEY 1000
pthread_t threadid;
 
void* MsgDSndThread(void* arg)
{
   struct msgbuf *snd = (struct msgbuf*)malloc(16);
   key_t fd;
   snd->mtype = 1;
   strcpy(snd->mtext, "message");
   fd = msgget(MSG_KEY, IPC_CREAT);
   msgsnd(fd, snd, 12, 0);
   free(snd);
   return 0;
}
 
void CreateThreadL()
   {
   pthread_create(&threadid,(pthread_attr_t *)NULL,MsgDSndThread, NULL);
   }
 
int main()
{
   struct msgbuf *rcv = (struct msgbuf*)malloc(16);
   key_t fd = msgget(MSG_KEY, IPC_CREAT);
   CreateThreadL();
   msgrcv(fd, rcv, 6, 0, 0);
   msgctl(fd, IPC_RMID, NULL);
   free(rcv);
   return 0;
}