lsst::pex::harness::LogUtils Class Reference

Pipeline class manages the operation of a multi-stage parallel pipeline. More...

#include <LogUtils.h>

Public Member Functions
	LogUtils ()
	~LogUtils ()
void	initializeLogger (bool isLocalLogMode, const std::string &name, const std::string &runId, const std::string &logdir, const std::string &workerid, int resourceUsageFlags=0)
void	initializeSliceLogger (bool isLocalLogMode, const std::string &name, const std::string &runId, const std::string &logdir, const int rank, const std::string &workerid, int resourceUsageFlags=0)
lsst::pex::logging::BlockTimingLog &	getLogger ()
void	setEventBrokerHost (const std::string &host)
const std::string &	getEventBrokerHost ()

Public Attributes
lsst::pex::logging::BlockTimingLog	pipelineLog
std::string	_evbHost
std::ofstream *	outlog

Detailed Description

Pipeline class manages the operation of a multi-stage parallel pipeline.

Pipeline spawns Slice workers and coordinates serial and parallel processing between the main thread and the workers by means of MPI communciations. Pipeline loops over the collection of Stages for processing on Image. The Pipeline is configured by reading a Policy file.

Definition at line 59 of file LogUtils.h.

Constructor & Destructor Documentation

lsst::pex::harness::LogUtils::LogUtils

(

)

Constructor.

Definition at line 56 of file LogUtils.cc.

    : pipelineLog(Log::getDefaultLog(),"harness"), _evbHost(""), outlog(0) 
{ }

lsst::pex::harness::LogUtils::~LogUtils

(

void

)

Destructor.

Definition at line 62 of file LogUtils.cc.

                        {
    delete outlog;
}

Member Function Documentation

const std::string& lsst::pex::harness::LogUtils::getEventBrokerHost ( )

inline

Definition at line 90 of file LogUtils.h.

{  return _evbHost;  }

lsst::pex::logging::BlockTimingLog& lsst::pex::harness::LogUtils::getLogger ( )

inline

Definition at line 83 of file LogUtils.h.

                                              {
        return pipelineLog;
    }

void lsst::pex::harness::LogUtils::initializeLogger	(	bool	isLocalLogMode,
		const std::string &	name,
		const std::string &	runId,
		const std::string &	logdir,
		const std::string &	workerid,
		int	resourceUsageFlags = 0
	)

Initialize the logger "pipelineLog" to be used globally in the Pipeline class. Add an ofstream Destination to the default logger if the localLogMode is True local file is on

Parameters

isLocalLogMode

A flag for writing logs to local files

Definition at line 70 of file LogUtils.cc.

                                  {
    std::stringstream logfileBuffer;
    std::string logfile;

    if (logdir.length() > 0) { 
        logfileBuffer << logdir;
        logfileBuffer << "/";
    }

    logfileBuffer << "Pipeline.log";
    logfileBuffer >> logfile;

    if(isLocalLogMode) {
        /* Make output file stream   */
        outlog =  new ofstream(logfile.c_str());
    }

    /* Create LSSTLogging transmitter here. (Moved from setupHarnessLogging in TracingLog.cc 
       Need to re-check this for MPI SLices. */ 
    if (_evbHost.length() > 0) { 
        EventSystem& eventSystem = EventSystem::getDefaultEventSystem();
        /* eventSystem.createTransmitter(_evbHost, EventLog::LOGGING_TOPIC); */
        eventSystem.createTransmitter(_evbHost, "logging");
    }

    boost::shared_ptr<BlockTimingLog> 
        lp(setupHarnessLogging(std::string(runId), -1, _evbHost, name, workerid,
                               outlog, "harness.pipeline",resourceUsageFlags));
                               
                               
    pipelineLog = *lp;

    pipelineLog.format(Log::INFO, 
                       "Pipeline Logger initialized for pid=%d", getpid());
    if (outlog) 
        pipelineLog.format(Log::INFO, "replicating messages to %s", logfile.c_str());
}

void lsst::pex::harness::LogUtils::initializeSliceLogger	(	bool	isLocalLogMode,
		const std::string &	name,
		const std::string &	runId,
		const std::string &	logdir,
		const int	rank,
		const std::string &	workerid,
		int	resourceUsageFlags = 0
	)

Initialize the logger "sliceLog" to be used globally in the Slice class. Add an ofstreamDestination to the default logger if the localLogMode is True

Parameters

isLocalLogMode

A flag for writing logs to local files

Definition at line 117 of file LogUtils.cc.

{
    std::string logfile;
    if(isLocalLogMode) {
        /* Make a log file name coded to the rank    */
        std::stringstream logfileBuffer;

        if (logdir.length() > 0) {
            logfileBuffer << logdir;
            logfileBuffer << "/";
        }

        logfileBuffer << "Slice";
        logfileBuffer << rank;
        logfileBuffer << ".log";

        logfileBuffer >> logfile;

        /* Make output file stream   */
        outlog =  new ofstream(logfile.c_str());
    }

    
    boost::shared_ptr<BlockTimingLog>
        lp(setupHarnessLogging(std::string(runId), rank, _evbHost,
                               name, workerid, outlog, "harness.slice",
                               resourceUsageFlags));
    pipelineLog = *lp;

    pipelineLog.format(Log::INFO, "Slice Logger initialized for pid=%d", getpid());

    if (outlog)
        pipelineLog.format(Log::INFO,
                        "replicating messages to %s", logfile.c_str());
}

void lsst::pex::harness::LogUtils::setEventBrokerHost ( const std::string &  host )

inline

Definition at line 87 of file LogUtils.h.

                                                   {
        _evbHost = host;
    }

Member Data Documentation

std::string lsst::pex::harness::LogUtils::_evbHost

Definition at line 93 of file LogUtils.h.

std::ofstream* lsst::pex::harness::LogUtils::outlog

Definition at line 94 of file LogUtils.h.

lsst::pex::logging::BlockTimingLog lsst::pex::harness::LogUtils::pipelineLog

Definition at line 92 of file LogUtils.h.

---

The documentation for this class was generated from the following files:

• /lsst/home/lsstsw/stack/Linux64/pex_harness/master-g084aeec0a4/include/lsst/pex/harness/LogUtils.h
• /lsst/home/lsstsw/stack/Linux64/pex_harness/master-g084aeec0a4/src/LogUtils.cc