boost/thread
2
0
Fork 0
mirror of https://github.com/boostorg/thread.git synced 2026-02-11 00:02:12 +00:00
Code Issues Projects Releases Wiki Activity

Remove line that could cause unnecessary extra waiting.

Browse Source 
[SVN r28330]
This commit is contained in:
Michael Glassford
2005-04-19 20:49:59 +00:00
parent 3068f0c62c
commit bc73368c96
1 changed files with 0 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/read_write_mutex.cpp
View File

@@ -411,7 +411,6 @@ void read_write_mutex_impl<Mutex>::do_read_lock()
adjust_count adjust_waiting(m_num_waiting_readers);
adjust_waking.set_adjust(true);
m_waiting_readers.wait(l);
adjust_waking.adjust_now();
};
}
else if (m_sp == read_write_scheduling_policy::writer_priority)
@@ -429,7 +428,6 @@ void read_write_mutex_impl<Mutex>::do_read_lock()
adjust_count adjust_waiting(m_num_waiting_readers);
adjust_waking.set_adjust(true);
m_waiting_readers.wait(l);
adjust_waking.adjust_now();
}
}
else BOOST_ASSERT_ELSE(m_sp == read_write_scheduling_policy::alternating_single_read || m_sp == read_write_scheduling_policy::alternating_many_reads)
@@ -445,7 +443,6 @@ void read_write_mutex_impl<Mutex>::do_read_lock()
adjust_count adjust_waiting(m_num_waiting_readers);
adjust_waking.set_adjust(true);
m_waiting_readers.wait(l);
adjust_waking.adjust_now();
}
}
@@ -492,7 +489,6 @@ void read_write_mutex_impl<Mutex>::do_write_lock()
adjust_count adjust_waiting(m_num_waiting_writers);
adjust_waking.set_adjust(true);
m_waiting_writers.wait(l);
adjust_waking.adjust_now();
}
}
else if (m_sp == read_write_scheduling_policy::writer_priority)
@@ -508,7 +504,6 @@ void read_write_mutex_impl<Mutex>::do_write_lock()
adjust_count adjust_waiting(m_num_waiting_writers);
adjust_waking.set_adjust(true);
m_waiting_writers.wait(l);
adjust_waking.adjust_now();
}
}
else BOOST_ASSERT_ELSE(m_sp == read_write_scheduling_policy::alternating_single_read || m_sp == read_write_scheduling_policy::alternating_many_reads)
@@ -529,7 +524,6 @@ void read_write_mutex_impl<Mutex>::do_write_lock()
adjust_count adjust_waiting(m_num_waiting_writers);
adjust_waking.set_adjust(true);
m_waiting_writers.wait(l);
adjust_waking.adjust_now();
}
}
@@ -694,7 +688,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_read_lock(const boost::xtime &xt)
fail = true;
break;
}
adjust_waking.adjust_now();
}
}
else if (m_sp == read_write_scheduling_policy::writer_priority)
@@ -717,7 +710,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_read_lock(const boost::xtime &xt)
fail = true;
break;
}
adjust_waking.adjust_now();
}
}
else BOOST_ASSERT_ELSE(m_sp == read_write_scheduling_policy::alternating_single_read || m_sp == read_write_scheduling_policy::alternating_many_reads)
@@ -738,7 +730,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_read_lock(const boost::xtime &xt)
fail = true;
break;
}
adjust_waking.adjust_now();
}
}
@@ -803,7 +794,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_write_lock(const boost::xtime &xt)
fail = true;
break;
}
adjust_waking.adjust_now();
}
}
else if (m_sp == read_write_scheduling_policy::writer_priority)
@@ -824,7 +814,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_write_lock(const boost::xtime &xt)
fail = true;
break;
}
adjust_waking.adjust_now();
}
}
else BOOST_ASSERT_ELSE(m_sp == read_write_scheduling_policy::alternating_single_read || m_sp == read_write_scheduling_policy::alternating_many_reads)
@@ -850,7 +839,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_write_lock(const boost::xtime &xt)
fail = true;
break;
}
adjust_waking.adjust_now();
}
}
@@ -1015,7 +1003,6 @@ void read_write_mutex_impl<Mutex>::do_promote_to_write_lock()
adjust_state adjust_waiting_promotion(m_state_waiting_promotion);
adjust_waking.set_adjust(true);
m_waiting_promotion.wait(l);
adjust_waking.adjust_now();
}
BOOST_ASSERT(m_num_waiting_writers >= 0);
@@ -1119,7 +1106,6 @@ bool read_write_mutex_impl<Mutex>::do_timed_promote_to_write_lock(const boost::x
fail = true;
break;
}
adjust_waking.adjust_now();
}
}