Fitter.h

#ifndef FITTER_H
#define FITTER_H

#include <is/info.h>
#include <is/inforeceiver.h>

#include <ipc/object.h>
#include <ipc/server.h>

#include <string>
#include <memory>

#include <boost/thread.hpp>

#include "FitterInterface.hh"
#include "FitterArguments.h"
#include "Sct/Exception.h"
#include "Sct/ConfigurationException.h"
#include "Sct/LogicErrors.h"
#include "Sct/IoExceptions.h"

class TH1;
class TF1;

using namespace Sct;

namespace SctFitter {
    class FitStrategy;
    class FitterWorkerGroup;

class Fitter:
  public IPCNamedObject<POA_FitterI::FitterInterface,
                        ipc::multi_thread>,
  private boost::noncopyable {
private:
  void shutdown();
  Fitter(FitterArguments args) throw(ConfigurationException);
  ~Fitter() throw();
  static Fitter* fitter;
    
public:
    static Fitter& instance();
    
    static Fitter& initialize(FitterArguments args) throw(ConfigurationException);
    
    void go() throw(IsException);
  private:
    // INTERNAL METHODS:
    std::string internal_status() const throw();
    std::string internal_lastScan() const throw();
  public:
    FitStrategy& internal_getFitStrategy() const throw(LogicError) ;
  private:
    void internal_setFitOptions(const string & opt) throw(LogicError) ;
    void internal_setFitStrategy(const string & name) throw(LogicError) ;
    long internal_nFitsDone() const throw();
    long internal_nFitErrors() const throw();
    static void doFits(ISCallbackInfo * isc) throw(IsException, LogicError);
    
  public:
    // CORBA METHODS:
    virtual char* status() throw();
    char* lastScan() throw();
    virtual char* getFitOptions() throw() ;
    virtual char* getFitStrategy() throw() ;

    virtual void setFitOptions(const char* opt) throw() ;
    virtual void setFitStrategy(const char* strategy) throw() ;
    // Fit all RawScanResults currently in IS.
    void fitAll() throw();
    void fit(const char* name) throw();
    long busy();
    long queueLength();
    long nFitsDone() throw();
    long nFitErrors() throw();
    void setFifo(bool);
    bool isFifo();
    FitterI::StringList* listFitAlgorithms();
    FitterI::StringList* listFitStrategies();
    void setDebug(CORBA::Boolean value);
    bool debug();
  public:
    void incrementFitErrors() throw();
    
    void incrementFitsDone() throw();
    
    void scanDone(double time) throw();
    
    void addIOTime(double time) throw();
    
    double getAverageTimePerScan() const throw();
    
    std::string getOutputIsServer() const;
    
    static IPCServer& getFitterServer() throw();
    
private:      

    /*
     * counters:      
     */
    long m_nFitsDone;
    long m_nFitErrors;
    long m_nScans;
    double m_scanTimeTaken;
    double m_ioTimeTaken;
    mutable boost::recursive_mutex counterMutex;
    
    /*
     * name of the last scan attempted.
     */
    string m_scan;
    mutable string m_status;
    FitStrategy* m_fitStrategy;
    FitterWorkerGroup* workergroup;    
    std::auto_ptr<ISInfoReceiver> m_infoReceiver;

    void setLastScanName(const std::string& name){
    m_scan = name;
    }

    void updateSubscriptions();

    friend class FitterWorkerGroup;
    FitterArguments m_args;
}
; // end of definition of class Fitter;
}// end of namespace SctFitter
#endif // #ifndef FITTER_H

---