SerialBusQueue.h

 
#ifndef MFRAME_1571B467_887D_4AC9_A803_148C427F0C68
#define MFRAME_1571B467_887D_4AC9_A803_148C427F0C68
 
/* ***************************************************************************************
 * Include
 */
 
//----------------------------------------------------------------------------------------
 
//----------------------------------------------------------------------------------------
#include "./../util/ArrayQueue.h"
#include "./SerialBus.h"
 
/* ***************************************************************************************
 * Namespace
 */
namespace ufm::io {
  class SerialBusQueue;
}  // namespace ufm::io
 
/* ***************************************************************************************
 * Class/Interface/Struct/Enum
 */
 
class ufm::io::SerialBusQueue : public ufm::io::SerialBus,
                                public ufm::io::SerialBus::Event {
  /* *************************************************************************************
   * Struct
   */
 public:
  struct Block {
    ufm::io::SerialBus::Event* vEvent;   
    uint8*                     vBuffer;  
    uint16                     vLength;  
    uint16                     vAddress; 
  };
 
  /* *************************************************************************************
   * Variable
   */
 private:
  ufm::util::ArrayQueue      vQueue;
  ufm::io::SerialBus::Event* vEvent;
 
  /* *************************************************************************************
   * Abstract Method
   */
 
  /* *************************************************************************************
   * Construct Method
   */
 public:
  SerialBusQueue(hal::serial::IICMaster& iicMaster, int queueSize);
 
  SerialBusQueue(hal::serial::IICMaster& iicMaster,
                 ufm::lang::Memory       queueBuffer) noexcept;
 
  virtual ~SerialBusQueue(void) override;
 
  /* *************************************************************************************
   * Operator Method
   */
 public:
  /* *************************************************************************************
   * Override Method - ufm::io::SerialBus
   */
  virtual bool isBusy(void) override;
 
  virtual bool write(uint16            address,
                     int               length,
                     const void*       source,
                     SerialBus::Event* event) override;
 
  virtual bool read(uint16            address,
                    int               length,
                    void*             buffer,
                    SerialBus::Event* event) override;
 
  /* *************************************************************************************
   * Override Method - ufm::io::SerialBusEvent
   */
 public:
  virtual void onComplete(void) override;
 
  virtual void onNoResponseEvent(int completedQuantity) override;
 
  virtual void onBusErrorEvent(int completedQuantity) override;
 
  virtual void onCancel(int completedQuantity) override;
 
  /* *************************************************************************************
   * Public Method
   */
 public:
  void cancelAll(void);
 
  bool isEmpty(void);
 
  /* *************************************************************************************
   * Protected Method
   */
 
  /* *************************************************************************************
   * Private Method
   */
 private:
  bool pushBlock(
      uint16 address, int length, void* buffer, SerialBus::Event* event, bool write);
 
  void pollBlock(void);
 
  /* *************************************************************************************
   * Static Variable
   */
 
  /* *************************************************************************************
   * Static Method
   */
};
 
/* ***************************************************************************************
 * End of file
 */
 
#endif /* MFRAME_1571B467_887D_4AC9_A803_148C427F0C68 */