testosmsgqurgent.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 testOSMsgQUrgent()
{
    OS_STATUS status;
    
    
    printf("*** test of OSMsgQUrgent ***\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, "normal send" );
 	printf("OSMsgQSend send the buffer \"normal send\" to MsgQ.\n");	
	status = OSMsgQSend( MsgQ_id, buffer, MESSAGE_SIZE ); 
    if(status != OS_OK)
    {
 		printf("OSMsgQSend error:[%s]\n",serrno(errno));
		return (-1);
 	}	
  	
  	memset(buffer,0,20);
  	strcpy( buffer, "urgent send" );
 	printf("OSMsgQUrgent send the buffer \"urgent send\" to MsgQ.\n");	
	status = OSMsgQUrgent( MsgQ_id, buffer, MESSAGE_SIZE ); 
    if(status != OS_OK)
    {
 		printf("OSMsgQUrgent error:[%s]\n",serrno(errno));
		return (-1);
 	}
  	
  	printf("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
 	{
 	    if(strcmp(recBuf,"urgent send")==0)
    		printf("OSMsgQUrgent success,the recBuf \"%s\"\n",recBuf);  
		else
		{
    		printf("OSMsgQUrgent error,the recBuf[%s]\n",recBuf);  
    		return (-1);
  		}  	  
  	}
  	
   	OSMsgQDelete(MsgQ_id); 
   	printf("*** OSMsgQUrgent test OK! ***\n\n");
	return 1;
}