Svchost.h

 
#ifndef MFRAME_90F75476_6982_4BDD_B9ED_0A250FE9C324
#define MFRAME_90F75476_6982_4BDD_B9ED_0A250FE9C324
 
/* ***************************************************************************************
 * Include
 */
 
//----------------------------------------------------------------------------------------
 
//----------------------------------------------------------------------------------------
#include "./../func/Runnable.h"
#include "./../io/InputStream.h"
#include "./../io/PrintBuffer.h"
#include "./../io/RingBuffer.h"
#include "./../lang/Data.h"
#include "./../lang/Object.h"
#include "./../sys/Allocator.h"
#include "./../sys/Kernel.h"
#include "./../sys/SystemConfig.h"
#include "./../sys/SystemControl.h"
#include "./../sys/Thread.h"
#include "./../util/PArrayQueue.h"
 
/* ***************************************************************************************
 * Namespace
 */
namespace mframe::sys {
  class Svchost;
}
 
/* ***************************************************************************************
 * Class/struct/Struct/Enum
 */
class mframe::sys::Svchost : public mframe::lang::Object,
                             public mframe::func::Runnable,
                             public mframe::io::CompletionHandler<int>,
                             public mframe::sys::SystemControl {
  /* *************************************************************************************
   * Variable
   */
 public:
  mframe::io::OutputStream& mOutputStream;
  mframe::io::InputStream&  mInputStream;
  mframe::io::PrintBuffer   mPrintBuffer;
  mframe::io::RingBuffer    mRingBuffer;
 
 private:
  mframe::util::PArrayQueue mArrayQueue;
  mframe::sys::Thread*      mThread;
  mframe::sys::Thread*      mUserThread;
  mframe::lang::Readable*   mCustomReadBuffer;
  mframe::lang::Appendable* mCustomWriteBuffer;
  int                       mDelay;
  bool                      mStart;
  bool                      mAction;
  bool                      mStream;
 
  /* *************************************************************************************
   * Abstract Method
   */
 
  /* *************************************************************************************
   * Construct Method
   */
 public:
  Svchost(mframe::sys::SystemConfig& systemConfig);
 
  virtual ~Svchost(void) override;
 
  /* *************************************************************************************
   * Operator Method
   */
 
  /* *************************************************************************************
   * Public Method <Override> - mframe::func::Runnable
   */
 public:
  virtual void run(void) override;
 
  /* *************************************************************************************
   * Public Method <Override> - mframe::lang::CompletionHandler<int, void*>
   */
 public:
  virtual void completed(int& result, void* attachment) override;
 
  virtual void failed(void* attachment) override;
 
  /* *************************************************************************************
   * Public Method <Override> - mframe::sys::SystemControl
   */
 public:
  virtual void setCustomReadBuffer(mframe::lang::Readable* readable) override;
 
  virtual void setCustomWriteBuffer(mframe::lang::Appendable* appendable) override;
 
  /* *************************************************************************************
   * Public Method
   */
 public:
  inline Svchost& setServiceDelay(int value) {
    this->mDelay = value;
    return *this;
  }
 
  inline int getServiceDelay(void) {
    return this->mDelay;
  }
 
  bool start(mframe::func::Runnable& task, int stackSize);
 
  void stop(void);
 
  bool execute(mframe::func::Runnable& task);
 
  bool action(void);
 
  /* *************************************************************************************
   * Protected Method
   */
 
  /* *************************************************************************************
   * Private Method
   */
 private:
  bool checkOutputStream(void);
  bool checkInputStream(void);
 
  /* *************************************************************************************
   * Static Variable
   */
 
  /* *************************************************************************************
   * Static Method
   */
};
 
/* ***************************************************************************************
 * End of file
 */
 
#endif /* MFRAME_90F75476_6982_4BDD_B9ED_0A250FE9C324 */