mif.h

浏览该文件的文档.

 
#ifndef __xwmd_isc_xwcq_mif_h__
#define __xwmd_isc_xwcq_mif_h__
 
#include <xwos/standard.h>
#include <xwos/lib/object.h>
#include <xwos/lib/bclst.h>
#include <xwos/osal/lock/spinlock.h>
#include <xwos/osal/sync/sem.h>
#include <xwos/osal/sync/sel.h>
 
// cppcheck-suppress [misra-c2012-20.7]
#define XWCQ_DEF_MEMPOOL(name, slotsize, slotnum) \
        __xwcc_alignl1cache xwu8_t name[(slotsize) * (slotnum)]
 
struct xwcq {
        struct xwos_object xwobj; 
        xwsz_t slotsize; 
        xwsz_t slotnum; 
        struct xwos_sem sem; 
        struct xwos_splk lock; 
        xwssz_t rear; 
        xwssz_t front; 
        xwu8_t * q; 
};
 
typedef struct {
        struct xwcq * cq; 
        xwsq_t tik; 
} xwcq_d;
 
xwer_t xwcq_init(struct xwcq * cq, xwsz_t slotsize, xwsz_t slotnum, xwu8_t * mem);
 
xwer_t xwcq_fini(struct xwcq * cq);
 
xwsq_t xwcq_get_tik(struct xwcq * cq);
 
static __xwos_inline_api
xwcq_d xwcq_get_d(struct xwcq * cq)
{
        xwcq_d cqd;
 
        cqd.cq = cq;
        cqd.tik = xwcq_get_tik(cq);
        return cqd;
}
 
xwer_t xwcq_acquire(xwcq_d cqd);
 
xwer_t xwcq_release(xwcq_d cqd);
 
xwer_t xwcq_grab(struct xwcq * cq);
 
xwer_t xwcq_put(struct xwcq * cq);
 
xwer_t xwcq_eq(struct xwcq * cq, const xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_jq(struct xwcq * cq, const xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_dq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_dq_to(struct xwcq * cq, xwu8_t * data, xwsz_t * size, xwtm_t to);
 
xwer_t xwcq_dq_unintr(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_trydq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_rq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_rq_to(struct xwcq * cq, xwu8_t * data, xwsz_t * size, xwtm_t to);
 
xwer_t xwcq_rq_unintr(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_tryrq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_pfq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_pfq_to(struct xwcq * cq, xwu8_t * data, xwsz_t * size, xwtm_t to);
 
xwer_t xwcq_pfq_unintr(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_trypfq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_prq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_prq_to(struct xwcq * cq, xwu8_t * data, xwsz_t * size, xwtm_t to);
 
xwer_t xwcq_prq_unintr(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_tryprq(struct xwcq * cq, xwu8_t * data, xwsz_t * size);
 
xwer_t xwcq_flush(struct xwcq * cq);
 
xwer_t xwcq_get_capacity(struct xwcq * cq, xwsz_t * capbuf);
 
xwer_t xwcq_get_size(struct xwcq * cq, xwsz_t * szbuf);
 
xwer_t xwcq_get_availability(struct xwcq * cq, xwsz_t * avbbuf);
 
xwer_t xwcq_bind(struct xwcq * cq, struct xwos_sel * sel, xwsq_t pos);
 
xwer_t xwcq_unbind(struct xwcq * cq, struct xwos_sel * sel);
 
#endif /* xwmd/isc/xwcq/mif.h */