notifier.hxx

// dawn/include/dawn/io/notifier.hxx
//
// SPDX-License-Identifier: Apache-2.0
//
 
#pragma once
 
#include <poll.h>
 
#include <atomic>
#include <mutex>
 
#include "dawn/common/thread.hxx"
#include "dawn/io/factory.hxx"
#include "dawn/io/inotifier.hxx"
#include "dawn/porting/config.hxx"
 
namespace dawn
{
// Forward declaration
 
struct io_ddata_t;
 
class CIONotifier final : public IIONotifier
{
public:
  CIONotifier()
    : pfds(nullptr)
    , pfdsLen(0)
    , pfdsUpdate(false)
    , threadCtl()
  {
  }
 
  ~CIONotifier();
 
  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 notifyData(CIOCommon *io, io_ddata_t *data) override;
  int start();
  int stop();
 
private:
  struct
  {
    std::vector<SIONotifier> user; 
    io_ddata_t *data; 
    size_t batch;     
  } typedef SIONotifierPriv;
 
  std::vector<SIONotifierPriv> vnote; 
  struct pollfd *pfds;                
  size_t pfdsLen;                     
  std::atomic_bool pfdsUpdate;        
  std::mutex pfdsLock;                
 
  CThreadedObject threadCtl;          
 
  void updatePfds();
  void thread();
};
} // Namespace dawn