OutputDADABuffer.h

/***************************************************************************
 *                                                                         *
 *   Copyright (C) 2024 by Jesmigel A. Cantos                              *
 *   Licensed under the Academic Free License version 2.1                  *
 *                                                                         *
 ***************************************************************************/
 
#ifndef __dsp_OutputDADABuffer_h
#define __dsp_OutputDADABuffer_h
 
#include "dsp/Sink.h"
#include "dsp/BitSeries.h"
#include "dsp/DADAHeader.h"
 
#include "dada_hdu.h"
 
#include <ipcio.h>
#include <ipcbuf.h>
 
namespace dsp {
 
  class OutputDADABuffer : public Sink<BitSeries>
  {
    public:
      OutputDADABuffer(const std::string &key_string);
 
      ~OutputDADABuffer();
 
      void calculation ();
 
      void reopen();
 
      void close();
 
      DADAHeader* get_header () { return &dada_header; }
 
    private:
      void connect(key_t smrb_key);
 
      void disconnect();
 
      void write_header();
 
      void unload_bytes(const void* buffer, uint64_t nbytes);
 
      key_t parse_psrdada_key(const std::string &key_string);
 
    protected:
 
      dada_hdu_t* hdu = nullptr;
 
      bool connected = false;
 
      bool locked = false;
 
      bool header_written = false;
 
      DADAHeader dada_header;
 
    private:
 
      void display_input_contents();
 
  };
} // namespace dsp
 
#endif // __dsp_OutputDADABuffer_h