SunnyQjm/ChronoSync
1
0 Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Synchronization correction in scheduler

Browse Source
This commit is contained in:
Alexander Afanasyev committed 2012-06-07 10:30:12 -07:00
1 parent 641c079c45
commit 97b5d401e9
1 file changed
+8 -10
Download Patch File Download Diff File Expand all files Collapse all files
ccnx/sync-scheduler.cc
+8 -10
View File
@@ -110,10 +110,9 @@ Scheduler::threadLoop ()
void
Scheduler::schedule (const TimeDuration &reltime, Event event, uint32_t label)
{
{
lock_guard<mutex> lock (m_eventsMutex);
m_events.insert (LogicEvent (boost::get_system_time () + reltime, event, label));
}
lock_guard<mutex> lock (m_eventsMutex);
m_events.insert (LogicEvent (boost::get_system_time () + reltime, event, label));
m_eventsCondition.notify_one ();
m_thread.interrupt (); // interrupt sleep, if currently sleeping
}
@@ -121,12 +120,11 @@ Scheduler::schedule (const TimeDuration &reltime, Event event, uint32_t label)
void
Scheduler::cancel (uint32_t label)
{
{
// cout << "Canceling label " << label << " size: " << m_events.size () << endl;
lock_guard<mutex> lock (m_eventsMutex);
m_events.get<byLabel> ().erase (label);
// cout << "Canceled label " << label << " size: " << m_events.size () << endl;
}
// cout << "Canceling label " << label << " size: " << m_events.size () << endl;
lock_guard<mutex> lock (m_eventsMutex);
m_events.get<byLabel> ().erase (label);
// cout << "Canceled label " << label << " size: " << m_events.size () << endl;
m_eventsCondition.notify_one ();
m_thread.interrupt (); // interrupt sleep, if currently sleeping
}