InputBuffering.h

//-*-C++-*-
/***************************************************************************
 *
 *   Copyright (C) 2005 by Willem van Straten
 *   Licensed under the Academic Free License version 2.1
 *
 ***************************************************************************/
 
#ifndef __InputBuffering_h
#define __InputBuffering_h
 
#include "dsp/BufferingPolicy.h"
#include "dsp/TimeSeries.h"
#include "dsp/Transformation.h"
 
namespace dsp {
 
  class Reserve;
 
  class InputBuffering : public BufferingPolicy
  {
 
  public:
    
    InputBuffering (HasInput<TimeSeries>* target = 0);
 
    void set_target (HasInput<TimeSeries>* input);
    
    void pre_transformation ();
    
    void post_transformation ();
    
    void set_next_start (uint64_t next_start_sample);
    
    void set_maximum_samples (uint64_t samples);
 
    int64_t get_next_contiguous () const;
 
    uint64_t bytes_storage() const override;
 
    class Share;
 
    virtual const TimeSeries* get_input () { return target->get_input(); }
 
  protected:
    
    uint64_t next_start_sample = 0;
 
    HasInput<TimeSeries>* target = nullptr;
    
    Reference::To<TimeSeries> buffer;
 
    void resize_buffer ();
 
    Reference::To<Reserve> reserve;
 
  };
 
}
 
#endif // !defined(__InputBuffering_h)