IReader.h

Go to the documentation of this file.

//
// Created by Nico on 27/11/2018.
//
 
#ifndef JODA_IREADER_H
#define JODA_IREADER_H
 
#include <joda/parser/ParserFlags.h>
#include <joda/parser/ReaderFlags.h>
#include "../../../concurrency/include/joda/concurrency/IThreadUser.h"
 
template <ReaderFlag R_FLAGS, ParserFlag P_FLAGS>
class IReader : public IThreadUser {
 public:
  /*
   * Types
   */
  typedef typename JODA_READER_QUEUE<R_FLAGS>::queue_t RQueue;
  typedef typename JODA_PARSER_QUEUE<P_FLAGS>::queue_t PQueue;
  typedef typename JODA_READER_QUEUE<R_FLAGS>::payload_t RPayload;
  typedef typename JODA_PARSER_QUEUE<P_FLAGS>::payload_t PPayload;
  typedef JODA_READER_QUEUE<R_FLAGS> RQueueFactory;
  typedef JODA_PARSER_QUEUE<P_FLAGS> PQueueFactory;
  /*
   * Constructor/Destructor
   */
  IReader(std::unique_ptr<RQueue>& rqueue, std::unique_ptr<PQueue>& pqueue);
  IReader(std::unique_ptr<RQueue>& rqueue, std::unique_ptr<PQueue>& pqueue,
          unsigned int maxThreads);
  virtual ~IReader() = default;
 
  /*
   * Read
   */
  virtual void read() { read(1); }
 
  virtual void read(double sample) = 0;
 
  virtual bool finishedReading() const = 0;
 
 protected:
  std::unique_ptr<RQueue>& rqueue;
  std::unique_ptr<PQueue>& pqueue;
 
 public:
};
 
template <ReaderFlag R_FLAGS, ParserFlag P_FLAGS>
IReader<R_FLAGS, P_FLAGS>::IReader(std::unique_ptr<IReader::RQueue>& rqueue,
                                   std::unique_ptr<IReader::PQueue>& pqueue)
    : IReader(rqueue, pqueue, 1) {}
 
template <ReaderFlag R_FLAGS, ParserFlag P_FLAGS>
IReader<R_FLAGS, P_FLAGS>::IReader(std::unique_ptr<IReader::RQueue>& rqueue,
                                   std::unique_ptr<IReader::PQueue>& pqueue,
                                   unsigned int maxThreads)
    : IThreadUser(maxThreads), rqueue(rqueue), pqueue(pqueue) {
  DLOG(INFO) << "Started IReader<" << JODA_FLAG_T(R_FLAGS) << ","
             << JODA_FLAG_T(P_FLAGS) << "> with " << maxThreads << " threads";
}
 
#endif  // JODA_IREADER_H