Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(107)

Unified Diff: webrtc/base/sigslot.h

Issue 2847243006: Revert of Fixing crash that can occur if signal is modified while firing. (Closed)
Patch Set: Created 3 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « no previous file | webrtc/base/sigslot_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webrtc/base/sigslot.h
diff --git a/webrtc/base/sigslot.h b/webrtc/base/sigslot.h
index 652d63c0d23bd3bbf41a9bb237327b6525bd4d60..45e0da216bf5c4acc09dd47f4e11c54edfbd2165 100644
--- a/webrtc/base/sigslot.h
+++ b/webrtc/base/sigslot.h
@@ -394,8 +394,7 @@
protected:
typedef std::list< _opaque_connection > connections_list;
- _signal_base() : _signal_base_interface(&_signal_base::do_slot_disconnect, &_signal_base::do_slot_duplicate),
- m_current_iterator(m_connected_slots.end())
+ _signal_base() : _signal_base_interface(&_signal_base::do_slot_disconnect, &_signal_base::do_slot_duplicate)
{
}
@@ -408,8 +407,7 @@
_signal_base& operator= (_signal_base const& that);
public:
- _signal_base(const _signal_base& o) : _signal_base_interface(&_signal_base::do_slot_disconnect, &_signal_base::do_slot_duplicate),
- m_current_iterator(m_connected_slots.end()) {
+ _signal_base(const _signal_base& o) : _signal_base_interface(&_signal_base::do_slot_disconnect, &_signal_base::do_slot_duplicate) {
lock_block<mt_policy> lock(this);
for (const auto& connection : o.m_connected_slots)
{
@@ -462,14 +460,7 @@
{
if(it->getdest() == pclass)
{
- // If we're currently using this iterator,
- // don't erase it and invalidate it yet; set a
- // flag to do so afterwards.
- if (m_current_iterator == it) {
- m_erase_current_iterator = true;
- } else {
- m_connected_slots.erase(it);
- }
+ m_connected_slots.erase(it);
pclass->signal_disconnect(static_cast< _signal_base_interface* >(this));
return;
}
@@ -493,15 +484,8 @@
if(it->getdest() == pslot)
{
- // If we're currently using this iterator,
- // don't erase it and invalidate it yet; set a
- // flag to do so afterwards.
- if (self->m_current_iterator == it) {
- self->m_erase_current_iterator = true;
- } else {
- self->m_connected_slots.erase(it);
- }
- }
+ self->m_connected_slots.erase(it);
+ }
it = itNext;
}
@@ -527,12 +511,7 @@
protected:
connections_list m_connected_slots;
-
- // Used to handle a slot being disconnected while a signal is
- // firing (iterating m_connected_slots).
- connections_list::iterator m_current_iterator;
- bool m_erase_current_iterator = false;
- };
+ };
template<class mt_policy = SIGSLOT_DEFAULT_MT_POLICY>
class has_slots : public has_slots_interface, public mt_policy
@@ -626,22 +605,16 @@
void emit(Args... args)
{
lock_block<mt_policy> lock(this);
- this->m_current_iterator =
- this->m_connected_slots.begin();
- while (this->m_current_iterator !=
- this->m_connected_slots.end()) {
- _opaque_connection const& conn =
- *this->m_current_iterator;
- conn.emit<Args...>(args...);
- if (this->m_erase_current_iterator) {
- this->m_current_iterator =
- this->m_connected_slots.erase(
- this->m_current_iterator);
- this->m_erase_current_iterator = false;
- } else {
- ++(this->m_current_iterator);
- }
- }
+ typename connections_list::const_iterator it = this->m_connected_slots.begin();
+ typename connections_list::const_iterator itEnd = this->m_connected_slots.end();
+
+ while(it != itEnd)
+ {
+ _opaque_connection const& conn = *it;
+ ++it;
+
+ conn.emit<Args...>(args...);
+ }
}
void operator()(Args... args)
« no previous file with comments | « no previous file | webrtc/base/sigslot_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698