stream_notifier.hxx

// dawn/include/dawn/io/stream_notifier.hxx
//
// SPDX-License-Identifier: Apache-2.0
//
 
#pragma once
 
#include <vector>
 
#include "dawn/common/thread.hxx"
#include "dawn/io/inotifier.hxx"
#include "dawn/porting/config.hxx"
 
namespace dawn
{
// Forward declaration
 
struct io_ddata_t;
 
class CStreamNotifier final : public IIONotifier
{
public:
  CStreamNotifier();
  ~CStreamNotifier();
 
  CStreamNotifier(const CStreamNotifier &) = delete;
  CStreamNotifier &operator=(const CStreamNotifier &) = delete;
 
  void setThreadConfig(const CThreadedObject::SThreadConfig &config)
  {
    threadCtl.setThreadConfig(config);
  }
 
  void setThreadStackSize(size_t stackSize)
  {
    threadCtl.setThreadStackSize(stackSize);
  }
 
  void setThreadPriority(int priority)
  {
    threadCtl.setThreadPriority(priority);
  }
 
  void setThreadScheduler(int scheduler)
  {
    threadCtl.setThreadScheduler(scheduler);
  }
 
  int regNotifier(SIONotifier n) override;
  int start();
  int stop();
 
private:
  std::vector<SIONotifier> users; 
  CIOCommon *io;                  
  io_ddata_t *data;               
  size_t batch;                   
  CThreadedObject threadCtl;      
 
  void thread();
};
} // Namespace dawn