Xwcq.hxx

浏览该文件的文档.

 
#ifndef __xwmd_isc_xwcq_cxx_XwcqProxy_hxx__
#define __xwmd_isc_xwcq_cxx_XwcqProxy_hxx__
 
extern "C" {
#include "xwmd/isc/xwcq/mif.h"
}
 
namespace xwisc {
 
template<xwsz_t TSlotNum, typename T>
class Xwcq
{
  private:
    struct xwcq mCq;
    __xwcc_alignl1cache xwu8_t mPool[sizeof(T) * TSlotNum];
 
  public:
    Xwcq() { xwcq_init(&mCq, sizeof(T), TSlotNum, mPool); }
    ~Xwcq() {}
 
    struct xwcq * get() { return &mCq; }
 
    /******** 查询 ********/
    xwsz_t capacity() {
        xwsz_t cap;
        xwcq_get_capacity(&mCq, &cap);
        return cap;
    }
 
    xwsz_t size() {
        xwsz_t size;
        xwcq_get_size(&mCq, &size);
        return size;
    }
 
    xwsz_t availability() {
        xwsz_t availability;
        xwcq_get_availability(&mCq, &availability);
        return availability;
    }
 
    /******** 维护 ********/
    void flush() { xwcq_flush(&mCq); }
 
    /******** 发送 ********/
    xwer_t eq(T * data, xwsz_t * size) {
        return xwcq_eq(&mCq, (const xwu8_t *)data, size);
    }
 
    xwer_t jq(T * data, xwsz_t * size) {
        return xwcq_jq(&mCq, (const xwu8_t *)data, size);
    }
 
    /******** 接收 ********/
 
    xwer_t dq(T * data, xwsz_t * size) {
        return xwcq_dq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t dq(T * data, xwsz_t * size, xwtm_t to) {
        return xwcq_dq_to(&mCq, (xwu8_t *)data, size, to);
    }
 
    xwer_t dqUnintr(T * data, xwsz_t * size) {
        return xwcq_dq_unintr(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t tryDq(T * data, xwsz_t * size) {
        return xwcq_trydq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t rq(T * data, xwsz_t * size) {
        return xwcq_rq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t rq(T * data, xwsz_t * size, xwtm_t to) {
        return xwcq_rq_to(&mCq, (xwu8_t *)data, size, to);
    }
 
    xwer_t rqUnintr(T * data, xwsz_t * size) {
        return xwcq_rq_unintr(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t tryRq(T * data, xwsz_t * size) {
        return xwcq_tryrq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t pfq(T * data, xwsz_t * size) {
        return xwcq_pfq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t pfq(T * data, xwsz_t * size, xwtm_t to) {
        return xwcq_pfq_to(&mCq, (xwu8_t *)data, size, to);
    }
 
    xwer_t pfqUnintr(T * data, xwsz_t * size) {
        return xwcq_pfq_unintr(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t tryPfq(T * data, xwsz_t * size) {
        return xwcq_trypfq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t prq(T * data, xwsz_t * size) {
        return xwcq_prq(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t prq(T * data, xwsz_t * size, xwtm_t to) {
        return xwcq_prq_to(&mCq, (xwu8_t *)data, size, to);
    }
 
    xwer_t prqUnintr(T * data, xwsz_t * size) {
        return xwcq_prq_unintr(&mCq, (xwu8_t *)data, size);
    }
 
    xwer_t tryPrq(T * data, xwsz_t * size) {
        return xwcq_tryprq(&mCq, (xwu8_t *)data, size);
    }
};
 
} // namespace xwisc
 
#endif /* xwmd/isc/xwcq/cxx/Xwcq.hxx */