SerialBusQueue.h

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