JobInfoSvc.h

Go to the documentation of this file.

#ifndef JOBINFOSVC_JOBINFOSVC_H
#define JOBINFOSVC_JOBINFOSVC_H 1

#include "DataSvc/IJobInfoSvc.h"

#include "GaudiKernel/Service.h"

#include <string>
#include <vector>
#include <map>

class JobInfoSvc :
  public Service,
  virtual public IJobInfoSvc {

  public:
    JobInfoSvc(const std::string& name,
               ISvcLocator* svc);

    virtual StatusCode initialize();
    virtual StatusCode finalize();


    virtual const DayaBay::JobInfo* currentJobInfo();
    virtual const DayaBay::JobInfo* jobInfo(const DayaBay::JobId& jobId);
    virtual StatusCode setJobInfo(const DayaBay::JobInfo& jobInfo);
    virtual const std::vector<DayaBay::JobInfo*>& cachedJobInfo();

    virtual StatusCode queryInterface(const InterfaceID& id,
                                      void** interface );

  private:
    StatusCode readDataFromDatabase(const DayaBay::JobId& jobId);
    StatusCode readDataFromFile();

    // Property: Load job info from the current input file?
    bool m_readFromFile;

    // Property: Load job info from the Database?
    bool m_readFromDatabase;

    // Property: Path for job info if reading from file?
    std::string m_jobInfoLocation;

    // Internal cached list of job info objects
    std::vector<DayaBay::JobInfo*> m_jobInfoList;

    // Internal handle to current job info
    DayaBay::JobInfo* m_currentJobInfo;

    // Keep tack of whether job info has been loaded from file
    bool m_fileIsInitialized;

    // Property JobId: Specify the current job ID
    // (Used by nuwa.py to initialize job information)
    std::string m_jobIdString;

    // Current Job Id
    DayaBay::JobId m_jobId;

    // Property JobConfig: Specify list of current job configuration parameters
    // (Used by nuwa.py to initialize job information)
    std::map<std::string, std::string> m_jobConfig;

  };

#endif /* JOBINFOSVC_JOBINFOSVC_H */