testosmsgqreceive.c

ReWorks里一个有关消息队列的例子。

#include "msgqTest.h"

#define MESSAGE_SIZE (sizeof(long) * 4)  
static long    buffer[ MESSAGE_SIZE / sizeof(long) ];
static long    recBuf[ MESSAGE_SIZE / sizeof(long) ];
static unsigned32 MsgQ_id;
static unsigned32 msgq_size;

int testOSMsgQReceive()
{
    OS_STATUS status;
    
    
    printf("*** test of OSMsgQReceive ***\n");
    printf("create a MsgQ.\n");
    status = OSMsgQCreate("msg",10,20,OS_DEFAULT,&MsgQ_id); 
    if(status != OS_OK)
    {
 		printf("OSMsgQCreate error:[%s]\n",serrno(errno));
		return (-1);
 	}
 	
	strcpy( buffer, "hello world" );
 	printf("send the buf to MsgQ.\n");	
	status = OSMsgQSend( MsgQ_id, buffer, MESSAGE_SIZE ); 
    if(status != OS_OK)
    {
 		printf("OSMsgQSend error:[%s]\n",serrno(errno));
		return (-1);
 	}	
  	
  	printf("OSMsgQReceive receive the buf.\n");
  	status = OSMsgQReceive(MsgQ_id,recBuf,&msgq_size,OS_DEFAULT,OS_NO_TIMEOUT);
    if(status != OS_OK)
    {
 		printf("OSMsgQReceive error:[%s]\n",serrno(errno));
		return (-1);
 	}
 	else
 	{
    	printf("OSMsgQReceive success,recBuf[%s]\n",recBuf);  
  	}
  	
   	OSMsgQDelete(MsgQ_id); 
   	printf("*** OSMsgQReceive test OK! ***\n\n");
	return 1;
}