LevelMonitor.h

//-*-C++-*-
/***************************************************************************
 *
 *   Copyright (C) 2008 by Willem van Straten
 *   Licensed under the Academic Free License version 2.1
 *
 ***************************************************************************/
 
// dspsr/Signal/General/dsp/LevelMonitor.h
 
#ifndef __LevelMonitor_h
#define __LevelMonitor_h
 
#include "Reference.h"
#include "environ.h"
 
#include <vector>
 
namespace dsp {
 
  class WeightedTimeSeries;
  class LevelHistory;
  class IOManager;
  class HistUnpacker;
 
  class LevelMonitor : public Reference::Able
  {
    
  public:
 
    static bool verbose;
  
    static bool connect;
 
    LevelMonitor ();
    
    virtual ~LevelMonitor ();
    
    void set_integration (uint64_t npts);
 
    virtual void monitor ();
    
    virtual void monitor_abort ();
    
    virtual int change_gain (unsigned ichan, unsigned ipol, unsigned idim, double scale);
    
    virtual int change_levels (unsigned ichan, unsigned ipol, unsigned idim, double offset);
    
    virtual int accumulate_stats (std::vector<double>& mean, 
                                  std::vector<double>& variance);
    
    virtual int set_thresholds (std::vector<double>& mean, 
                                std::vector<double>& variance);
 
    void set_max_iterations (unsigned);
 
    void set_between_iterations (double seconds);
 
    void set_history (LevelHistory* history);
    
    void set_input (IOManager* input);
 
    void set_swap_polarizations (bool swap);
 
    void set_consecutive (bool swap);
 
  protected:
    
    void init();
    
    uint64_t n_integrate;
    
    uint64_t block_size;
 
    unsigned max_iterations;
 
    double between_iterations;
 
    bool abort;
 
    bool stop_after_good;
    bool setting_thresholds;
 
    double optimal_variance;
    double optimal_dBm;
 
    double mean_tolerance;
 
    double var_tolerance;
 
    bool far_from_good;
 
    bool swap_polarizations;
 
    bool consecutive;
 
  private:
 
    Reference::To<WeightedTimeSeries> data;
 
    Reference::To<IOManager> input;
    
    Reference::To<LevelHistory> history;
 
    Reference::To<HistUnpacker> unpacker;
 
    void connect_bits ();
 
    unsigned nchan, npol, ndim, ndig;
    
  };
 
}
 
double variance2dBm (double);
 
#endif