Sel.hxx

浏览该文件的文档.

 
#ifndef __xwos_cxx_sync_Sel_hxx__
#define __xwos_cxx_sync_Sel_hxx__
 
#include <xwos/cxx/Bmp.hxx>
 
extern "C" {
#include <xwos/osal/sync/sel.h>
}
 
namespace xwos {
namespace sync {
 
template<xwsz_t TNum>
class Sel
{
  public:
    enum WaitMode : xwu32_t {
        SelWait = 0, 
        SelWaitTimed, 
        SelWaitUninterruptable, 
        SelTryWait, 
    };
 
  protected:
    struct xwos_sel * mSelPtr;
 
  protected:
    Sel()
        : mSelPtr(nullptr)
    {
    }
    ~Sel() { mSelPtr = nullptr; }
 
  public:
    xwsz_t num() { return TNum; }
 
    xwer_t select(xwos::Bmp<TNum> * msk, xwos::Bmp<TNum> * trigger, enum WaitMode mode,
                  xwtm_t to)
    {
        xwer_t rc;
        switch (mode) {
            case WaitMode::SelWait:
                rc = xwos_sel_select(mSelPtr, msk->mData, trigger->mData);
                break;
            case WaitMode::SelWaitTimed:
                rc = xwos_sel_select_to(mSelPtr, msk->mData, trigger->mData, to);
                break;
            case WaitMode::SelWaitUninterruptable:
                rc = xwos_sel_select_unintr(mSelPtr, msk->mData, trigger->mData);
                break;
            case WaitMode::SelTryWait:
                rc = xwos_sel_tryselect(mSelPtr, msk->mData, trigger->mData);
                break;
            default:
                rc = xwos_sel_select(mSelPtr, msk->mData, trigger->mData);
                break;
        }
        return rc;
    }
 
    template<xwsz_t TSelNum>
    xwer_t bind(Sel<TSelNum> * src, long pos)
    {
        return xwos_sel_bind(src->getXwosObj(), mSelPtr, (xwsq_t)pos);
    }
    template<xwsz_t TSelNum>
    xwer_t bind(Sel<TSelNum> & src, long pos)
    {
        return xwos_sel_bind(src.getXwosObj(), mSelPtr, (xwsq_t)pos);
    }
 
    template<xwsz_t TSelNum>
    xwer_t unbind(Sel<TSelNum> * src)
    {
        return xwos_sel_unbind(src->getXwosObj(), mSelPtr);
    }
    template<xwsz_t TSelNum>
    xwer_t unbind(Sel<TSelNum> & src)
    {
        return xwos_sel_unbind(src.getXwosObj(), mSelPtr);
    }
 
    struct xwos_sel * getXwosObj() { return mSelPtr; }
};
 
} // namespace sync
} // namespace xwos
 
#endif /* xwos/cxx/sync/Sel.hxx */