posix message queue测试

//////////////////////////////////////////
//author 	zhouhh
//date 		2010.11.18
//notes
//history
//copyright( 2010 ) allright reserved!
/////////////////////////////////////////
 
#include 
#include 
#include 
#include 
#include 
#include 
 #include 
//       mqd_t mq_open(const char *name, int oflag);
//       mqd_t mq_open(const char *name, int oflag, mode_t mode,
//                     struct mq_attr *attr);
#define _XOPEN_SOURCE 600
#define FILE_MODE (S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH)
void main(void)
{
    mqd_t mqdes = mq_open("testmymq",O_RDWR|O_CREAT, FILE_MODE,NULL);
    if( mqdes == (mqd_t) -1)
    {
        perror("mq_open error");
    }
 
    struct sigevent se;
    //se.sigev_notify = SIGEV_SIGNAL;
    //se.sigev_signo =
    char buf[1024];
    size_t msg_len = 1024;
    const struct timespec abs_timeout = {1000,0};//* seconds *//* nanoseconds */
    int i = 0;
    for( i = 0; i < 10; i++)
    {
        //ssize_t mqsize =  mq_timedreceive( mqdes, buf,  msg_len, NULL, &abs_timeout);
        ssize_t mqsize =  mq_receive( mqdes, buf,  msg_len, NULL);
        if( mqsize < 0 )
        {
            if(errno == EAGAIN)
            {
                printf("the mq is empty and nonblock\n");
            //printf("timeout \n");
            }
 
            printf("timeout \n");
            continue;
        }
        printf("received msg:%s\n",buf);
    }
}