Fitter.h

#ifndef FITTER_H
#define FITTER_H

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

#include <string>
#include <memory>

#include <boost/thread.hpp>

#include "FitterI.hh"
#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 IPCObject, public virtual FitterI_T_FitterInterface, private boost::noncopyable{
private:
    Fitter(const string& fitStrategyName) throw(ConfigurationException);
    ~Fitter() throw();
    static Fitter* fitter;
    
public:
    static Fitter& instance();
    
    static Fitter& initialize(const string& fitStrategyName = "RootFitStrategy") throw(ConfigurationException);
    
    void go(unsigned nWorker) throw(IsException);
    const char* status() const throw();
    virtual char* status(FitterIStatus* status) throw();
    void setFitOptions(const string opt) throw(LogicError) ;
    virtual void setFitOptions(FitterIStatus* status, char* opt) throw() ;
    virtual void setFitStrategy(FitterIStatus* status, char* strategy) throw() ;
    virtual char* getFitStrategy(FitterIStatus* status) throw() ;
    // Fit all RawScanResults currently in IS.
    void fitAll(FitterIStatus* status) throw();
    void fit(FitterIStatus* status, char* name) throw();
    virtual char* getFitOptions(FitterIStatus* status) throw() ;
    static void doFits(ISCallbackInfo * isc) throw(IsException, LogicError);
    
    long busy(FitterIStatus* status);

    long queueLength(FitterIStatus* status);

    long nFitsDone() const throw();
    long nFitsDone(FitterIStatus* status) throw();
    long nFitErrors() const throw();

    long nFitErrors(FitterIStatus* status) throw();
    const char* lastScan() const throw();
    char* lastScan(FitterIStatus* status) throw();
    
    void useAnalyticAlgorithm (FitterIStatus *_status, ilu_Boolean use);
        
    bool isUsingAnalyticAlgorithm() const;
    
    ilu_Boolean isUsingAnalyticAlgorithm(FitterIStatus *_status);

    
    void setFitStrategy(string name) throw(LogicError) ;

    FitStrategy& getFitStrategy() const throw(LogicError) ;

    FitterWorkerGroup* workergroup;
    
    void incrementFitErrors() throw();
    
    void incrementFitsDone() throw();
    
    void scanDone(double time) throw();
    
    void addIOTime(double time) throw();
    
    double getAverageTimePerScan() const throw();
    
    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;
    std::auto_ptr<ISInfoReceiver> m_infoReceiver;

    void setLastScanName(const char* name){
    m_scan = name;
    }
    
    friend class FitterWorkerGroup;

}
; // end of definition of class Fitter;
}// end of namespace SctFitter
#endif // #ifndef FITTER_H

---