XwsscProxy.hxx

浏览该文件的文档.

 
#ifndef __xwmd_isc_xwssc_cxx_XwsscProxy_hxx__
#define __xwmd_isc_xwssc_cxx_XwsscProxy_hxx__
 
extern "C" {
#include "xwmd/isc/xwssc/mi.h"
}
 
namespace xwisc {
 
class XwsscProxy
{
  private:
    struct xwssc * mProxy;
    xwu8_t mPort; 
    xwu8_t mDefaultPriority; 
    xwu8_t mDefaultQos; 
  public:
    XwsscProxy(struct xwssc * xwssc, xwu8_t port, xwu8_t default_priority, xwu8_t default_qos);
    XwsscProxy() = delete;
    ~XwsscProxy() {}
 
    xwer_t write(const xwu8_t data[], xwsz_t * size);
 
    xwer_t write(const xwu8_t data[], xwsz_t * size, xwu8_t pri, xwu8_t qos);
 
    xwer_t write(const xwu8_t data[], xwsz_t * size, xwtm_t to);
 
    xwer_t write(const xwu8_t data[], xwsz_t * size, xwu8_t pri, xwu8_t qos, xwtm_t to);
 
    xwer_t asyncWrite(const xwu8_t data[], xwsz_t * size, xwssc_txh_t * txhbuf);
 
    xwer_t asyncWrite(const xwu8_t data[], xwsz_t * size,
                      xwu8_t pri, xwu8_t qos, xwssc_txh_t * txhbuf);
 
    xwer_t abortAsyncWrite(xwssc_txh_t txh);
 
    enum xwssc_carrier_state_em getAsyncWriteState(xwssc_txh_t txh) {
        return (enum xwssc_carrier_state_em)xwssc_get_txstate(txh);
    }
 
    xwer_t read(xwu8_t rxbuf[], xwsz_t * size);
 
    xwer_t read(xwu8_t rxbuf[], xwsz_t * size, xwu8_t * qos, xwtm_t to);
 
    xwer_t tryRead(xwu8_t rxbuf[], xwsz_t * size);
 
    xwer_t tryRead(xwu8_t rxbuf[], xwsz_t * size, xwu8_t * qos);
 
  protected:
    virtual void onAsyncWrited(xwssc_txh_t txh, xwer_t rc);
 
 
  private:
    static void sOnAsyncWrited(struct xwssc * xwssc, xwssc_txh_t txh,
                               xwer_t rc, void * arg);
};
 
} // namespace xwisc
 
#endif /* xwmd/isc/xwssc/cxx/XwsscProxy.hxx */