Congegni
/
sintonia
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

minor edit: breaking up some overlong lines

This commit is contained in:
fgerlits 2006-12-01 17:53:38 +00:00
parent 93dbbeaa6d
commit 6c48e9d63d
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
campcaster/src/modules/eventScheduler/src/SchedulerThread.cxx
View File

@ -87,9 +87,12 @@ SchedulerThread :: getNextEvent(Ptr<ptime>::Ref when) throw ()
- *nextEvent->maxTimeToInitialize())); - *nextEvent->maxTimeToInitialize()));
nextEventEnd.reset(new ptime(*nextEventTime nextEventEnd.reset(new ptime(*nextEventTime
+ *nextEvent->eventLength())); + *nextEvent->eventLength()));
debug() << "::getNextEvent() - nextInitTime: " << to_simple_string(*nextInitTime) << endl; debug() << "::getNextEvent() - nextInitTime: "
debug() << " - nextEventTime: " << to_simple_string(*nextEventTime) << endl; << to_simple_string(*nextInitTime) << endl;
debug() << " - nextEventEnd: " << to_simple_string(*nextEventEnd) << endl; debug() << " - nextEventTime: "
<< to_simple_string(*nextEventTime) << endl;
debug() << " - nextEventEnd: "
<< to_simple_string(*nextEventEnd) << endl;
} }
} }
@ -102,7 +105,8 @@ SchedulerThread :: nextStep(Ptr<ptime>::Ref now) throw ()
{ {
if (nextEvent) { if (nextEvent) {
if (imminent(now, nextInitTime)) { if (imminent(now, nextInitTime)) {
debug() << "::nextStep() - Init [" << *TimeConversion::now() << "]" << endl; debug() << "::nextStep() - Init [" << *TimeConversion::now()
<< "]" << endl;
try { try {
nextEvent->initialize(); nextEvent->initialize();
} catch (std::exception &e) { } catch (std::exception &e) {
@ -118,7 +122,8 @@ SchedulerThread :: nextStep(Ptr<ptime>::Ref now) throw ()
Ptr<time_duration>::Ref timeLeft(new time_duration(*nextEventTime Ptr<time_duration>::Ref timeLeft(new time_duration(*nextEventTime
- *now)); - *now));
TimeConversion::sleep(timeLeft); TimeConversion::sleep(timeLeft);
debug() << "::nextStep() - Start [" << *TimeConversion::now() << "]" << endl; debug() << "::nextStep() - Start [" << *TimeConversion::now()
<< "]" << endl;
nextEvent->start(); nextEvent->start();
currentEvent = nextEvent; currentEvent = nextEvent;
currentEventEnd = nextEventEnd; currentEventEnd = nextEventEnd;
@ -135,7 +140,8 @@ SchedulerThread :: nextStep(Ptr<ptime>::Ref now) throw ()
currentEvent->deInitialize(); currentEvent->deInitialize();
currentEvent.reset(); currentEvent.reset();
isPreloading = false; isPreloading = false;
debug() << "::nextStep() - End [" << *TimeConversion::now() << "]" << endl; debug() << "::nextStep() - End [" << *TimeConversion::now()
<< "]" << endl;
} }
} }