commit 4865bd6c4f828485a336ec69b4b7ab530cdd8292
author Zhenkai Zhu <zhenkai@cs.ucla.edu> Thu Jan 17 12:08:29 2013 -0800
committer Zhenkai Zhu <zhenkai@cs.ucla.edu> Thu Jan 17 12:08:29 2013 -0800
tree 08155e8e74a65e18afff0d3846da1eef5dc9fe3a
parent 20bc8e259fa77646434891c3c148fe9b69bc6aa7

hopefull correct all mutex lock mistakes

src/event-scheduler.cpp

diff --git a/src/event-scheduler.cpp b/src/event-scheduler.cpp
index 33697a5..f4603f0 100644
--- a/src/event-scheduler.cpp
+++ b/src/event-scheduler.cpp
@@ -156,7 +156,7 @@
     {
       cout << "scheduler loop break error" << endl;
     }
-    ReadLock(m_mutex);
+    ReadLock lock(m_mutex);
     if (!m_running)
     {
       cout << "scheduler loop break normal" << endl;
@@ -169,7 +169,7 @@
 Scheduler::start()
 {
   {
-    WriteLock(m_mutex);
+    WriteLock lock(m_mutex);
     m_running = true;
   }
   m_thread = boost::thread(&Scheduler::eventLoop, this);
@@ -179,7 +179,7 @@
 Scheduler::shutdown()
 {
   {
-    WriteLock(m_mutex);
+    WriteLock lock(m_mutex);
     m_running = false;
   }
   event_base_loopbreak(m_base);
@@ -213,7 +213,7 @@
 void
 Scheduler::rescheduleTask(const Task::Tag &tag)
 {
-  ReadLock(m_mutex);
+  ReadLock lock(m_mutex);
   TaskMapIt it = m_taskMap.find(tag);
   if (it != m_taskMap.end())
   {
@@ -230,7 +230,7 @@
 bool
 Scheduler::addToMap(const TaskPtr &task)
 {
-  WriteLock(m_mutex);
+  WriteLock lock(m_mutex);
   if (m_taskMap.find(task->tag()) == m_taskMap.end())
   {
     m_taskMap.insert(make_pair(task->tag(), task));
@@ -242,7 +242,7 @@
 void
 Scheduler::deleteTask(const Task::Tag &tag)
 {
-  WriteLock(m_mutex);
+  WriteLock lock(m_mutex);
   TaskMapIt it = m_taskMap.find(tag);
   if (it != m_taskMap.end())
   {
@@ -255,7 +255,7 @@
 void
 Scheduler::deleteTask(const Task::TaskMatcher &matcher)
 {
-  WriteLock(m_mutex);
+  WriteLock lock(m_mutex);
   TaskMapIt it = m_taskMap.begin();
   while(it != m_taskMap.end())
   {
@@ -278,6 +278,6 @@
 int
 Scheduler::size()
 {
-  ReadLock(m_mutex);
+  ReadLock lock(m_mutex);
   return m_taskMap.size();
 }