SleepModule.cxx

Go to the documentation of this file.

#include "SleepModule.h"

#include <Conventions/Munits.h>
#include <JobControl/JobCModuleRegistry.h>
#include <JobControl/JobCResult.h>
#include <MessageService/MsgService.h>

#include <JobControl/JobCPath.h>

// For current_file
#include <IoModules/IoInputModule.h>

#include <TSystem.h>
#include <TStopwatch.h>

CVSID("$Id: SleepModule.cxx,v 1.2 2005/04/15 14:50:02 bv Exp $");
JOBMODULE(SleepModule,"Sleep","Sleep for a while");

SleepModule::SleepModule()
{
}
SleepModule::~SleepModule()
{
}

void SleepModule::BeginRun()
{
    MSG("Sleep",Msg::kDebug) << " begin run \n";
}
void SleepModule::EndRun()
{
    MSG("Sleep",Msg::kDebug) << " end run \n";
}

void SleepModule::BeginFile()
{
    const char* file = this->GetCurrentFile();
    if (!file) file = "unknown";
    MSG("Sleep",Msg::kDebug)
        << " begin file:" << file << endl;
}
void SleepModule::EndFile()
{
    const char* file = this->GetCurrentFile();
    if (!file) file = "unknown";
    MSG("Sleep",Msg::kDebug)
        << " end file:" << file << endl;
}

JobCResult SleepModule::Ana(const MomNavigator *)
{
    double delay = 1.0;
    this->GetConfig().Get("delay",delay);
    
    MSG("Sleep",Msg::kVerbose)
        << "Sleeping for " << delay/Munits::millisecond << " msec\n";
    TStopwatch timer;
    timer.Start();    
    gSystem->Sleep((int)(delay/Munits::millisecond));
    timer.Stop();
    MSG("Sleep",Msg::kVerbose)
        << "Slept for: " << timer.RealTime() << endl;
    
    return JobCResult::kAOK;
}
const Registry& SleepModule::DefaultConfig() const
{
    static Registry cfg;
    if (cfg.Size() == 0) {
        cfg.Set("delay",1.0);
    }
    return cfg;
}

---