Function libc_mq

examples/libc/mq.c:92–127

}

int libc_mq()
{
    mqd_t mq1 = 0, mq2 = 0;
    struct mq_attr mqstat;
    int oflag = O_CREAT|O_RDWR;

    memset(&mqstat, 0, sizeof(mqstat));
    mqstat.mq_maxmsg = MAX_MSG;
    mqstat.mq_msgsize = MSG_SIZE;
    mqstat.mq_flags = 0;

    if( ((mqd_t) -1) == (mq1 = mq_open(MQ_NAME_1,oflag,0777, &mqstat)) ) {
        printf("mq_open doesn't return success \n");
        return -1;
    }
    if( ((mqd_t) -1) == (mq2 = mq_open(MQ_NAME_2,oflag,0777, &mqstat)) ) {
        printf("mq_open doesn't return success \n");
        return -1;
    }
    pthread_create(&send1, NULL, (void *)send_1, (void *)&mq1);
    pthread_create(&send2, NULL, (void *)send_2, (void *)&mq2);
        pthread_create(&rev1, NULL, (void *)receive_1, (void *)&mq1);
        pthread_create(&rev2, NULL, (void *)receive_2, (void *)&mq2);
    pthread_join(send1, NULL);
    pthread_join(send2, NULL);
    pthread_join(rev1, NULL);
    pthread_join(rev2, NULL);

    mq_close(mq1);
    mq_close(mq2);
    mq_unlink(MQ_NAME_1);
    mq_unlink(MQ_NAME_2);

    printf("PASSED\n");
    return 0;
}
#include <finsh.h>
FINSH_FUNCTION_EXPORT(libc_mq, posix mqueue test);