mif.h

浏览该文件的文档.

 
#ifndef __xwmd_isc_xwmq_mif_h__
#define __xwmd_isc_xwmq_mif_h__
 
#include <xwos/standard.h>
#include <xwos/lib/object.h>
#include <xwos/lib/bclst.h>
#include <xwos/mm/memslice.h>
#include <xwos/osal/lock/spinlock.h>
#include <xwos/osal/sync/sem.h>
#include <xwos/osal/sync/sel.h>
 
struct xwmq_msg {
        void * data; 
        xwsq_t topic; 
        struct xwlib_bclst_node node; 
};
 
struct xwmq {
        struct xwos_object xwobj; 
        const char * name; 
        struct xwmm_memslice txq; 
        struct xwos_sem txqsem; 
        struct xwlib_bclst_head rxq; 
        struct xwos_splk rxqlock; 
        struct xwos_sem rxqsem; 
};
 
typedef struct {
        struct xwmq * mq; 
        xwsq_t tik; 
} xwmq_d;
 
xwer_t xwmq_init(struct xwmq * mq, struct xwmq_msg * txq, xwsz_t num);
 
xwer_t xwmq_fini(struct xwmq * mq);
 
xwer_t xwmq_grab(struct xwmq * mq);
 
xwer_t xwmq_put(struct xwmq * mq);
 
xwsq_t xwmq_get_tik(struct xwmq * mq);
 
static __xwos_inline_api
xwmq_d xwmq_get_d(struct xwmq * mq)
{
        xwmq_d mqd;
 
        mqd.mq = mq;
        mqd.tik = xwmq_get_tik(mq);
        return mqd;
}
 
xwer_t xwmq_acquire(xwmq_d mqd);
 
xwer_t xwmq_release(xwmq_d mqd);
 
xwer_t xwmq_eq(struct xwmq * mq, xwsq_t topic, void * data);
 
xwer_t xwmq_eq_to(struct xwmq * mq, xwsq_t topic, void * data, xwtm_t to);
 
xwer_t xwmq_eq_unintr(struct xwmq * mq, xwsq_t topic, void * data);
 
xwer_t xwmq_tryeq(struct xwmq * mq, xwsq_t topic, void * data);
 
xwer_t xwmq_jq(struct xwmq * mq, xwsq_t topic, void * data);
 
xwer_t xwmq_jq_to(struct xwmq * mq, xwsq_t topic, void * data, xwtm_t to);
 
xwer_t xwmq_jq_unintr(struct xwmq * mq, xwsq_t topic, void * data);
 
xwer_t xwmq_tryjq(struct xwmq * mq, xwsq_t topic, void * data);
 
xwer_t xwmq_dq(struct xwmq * mq, xwsq_t * topic, void ** databuf);
 
xwer_t xwmq_dq_to(struct xwmq * mq, xwsq_t * topic, void ** databuf, xwtm_t to);
 
xwer_t xwmq_dq_unintr(struct xwmq * mq, xwsq_t * topic, void ** databuf);
 
xwer_t xwmq_trydq(struct xwmq * mq, xwsq_t * topic, void ** databuf);
 
xwer_t xwmq_rq(struct xwmq * mq, xwsq_t * topic, void ** databuf);
 
xwer_t xwmq_rq_to(struct xwmq * mq, xwsq_t * topic, void ** databuf, xwtm_t to);
 
xwer_t xwmq_rq_unintr(struct xwmq * mq, xwsq_t * topic, void ** databuf);
 
xwer_t xwmq_tryrq(struct xwmq * mq, xwsq_t * topic, void ** databuf);
 
#endif /* xwmd/isc/xwmq/mif.h */