InputSource.h

//-*-C++-*-
/***************************************************************************
 *
 *   Copyright (C) 2023 Willem van Straten
 *   Licensed under the Academic Free License version 2.1
 *
 ***************************************************************************/
 
// dspsr/Kernel/Classes/dsp/InputSource.h
 
#ifndef __dsp_Kernel_Classes_InputSource_h
#define __dsp_Kernel_Classes_InputSource_h
 
#include "dsp/Source.h"
#include "templates.h"
 
namespace dsp {
 
  template<class Type>
  class InputSource : public Source
  {
 
  public:
 
    InputSource (const char* name) : Source(name) {}
 
    virtual void set_input (Type* input) = 0;
 
    virtual const Type* get_input () const = 0;
 
    virtual Type* get_input () = 0;
 
    const Observation* get_info() const override { return get_input()->get_info(); }
 
    Observation* get_info() override { return get_input()->get_info(); }
 
    uint64_t get_total_samples () const override { return get_info()->get_ndat(); }
 
    uint64_t get_current_sample () const override { return get_input()->tell(); }
 
    double get_current_time () const override { return get_input()->tell_seconds(); }
 
    void seek_time (double second) override { return get_input()->set_start_seconds(second); }
 
    void set_total_time (double second) { return get_input()->set_total_seconds(second); }
 
    bool end_of_data () const override { return get_input()->eod(); }
 
    void restart () override { get_input()->restart(); }
 
    void set_block_size (uint64_t block_size) override { get_input()->set_block_size(multiple_greater(block_size,get_resolution())); }
 
    uint64_t get_block_size () const override { return get_input()->get_block_size(); }
 
    void set_overlap (uint64_t overlap) override { get_input()->set_overlap(multiple_greater(overlap,get_resolution())); }
 
    uint64_t get_overlap () const override { return get_input()->get_overlap(); }
 
    virtual uint64_t get_resolution () const { return get_input()->get_resolution(); }
 
    void share (Source* that) override
    {
      auto same = dynamic_cast<InputSource*>(that);
      if (!same)
        throw Error (InvalidParam, "dsp::InputSource::share",
        "mismatch between this type=%s and that type=%s", this->get_name().c_str(), that->get_name().c_str());
 
      set_input(same->get_input());
    }
 
    void set_context (ThreadContext* context) override { get_input()->set_context(context); }
  };
 
}
 
 
#endif // !defined(__dsp_Kernel_Classes_InputSource_h)