summaryrefslogtreecommitdiffstats
path: root/src/engine/events
diff options
context:
space:
mode:
Diffstat (limited to 'src/engine/events')
-rw-r--r--src/engine/events/DisconnectAll.cpp34
-rw-r--r--src/engine/events/DisconnectAll.hpp2
2 files changed, 21 insertions, 15 deletions
diff --git a/src/engine/events/DisconnectAll.cpp b/src/engine/events/DisconnectAll.cpp
index cc5bf42d..c49cd9d7 100644
--- a/src/engine/events/DisconnectAll.cpp
+++ b/src/engine/events/DisconnectAll.cpp
@@ -74,6 +74,17 @@ DisconnectAll::~DisconnectAll()
}
void
+DisconnectAll::remove_connection(ConnectionImpl* c)
+{
+ const bool reconnect_input = !_deleting || (c->dst_port()->parent_node() != _node);
+ Disconnect* ev = new Disconnect(_engine, SharedPtr<Request>(), _time,
+ c->src_port(), c->dst_port(), reconnect_input);
+ ev->pre_process();
+ _disconnect_events.push_back(new Raul::List<Disconnect*>::Node(ev));
+ c->pending_disconnection(true);
+}
+
+void
DisconnectAll::pre_process()
{
if (!_deleting) {
@@ -110,27 +121,20 @@ DisconnectAll::pre_process()
for (PatchImpl::Connections::const_iterator i = _parent->connections().begin();
i != _parent->connections().end(); ++i) {
ConnectionImpl* c = (ConnectionImpl*)i->second.get();
- const bool reconnect_input = !_deleting || (c->dst_port()->parent_node() != _node);
- if ((c->src_port()->parent_node() == _node || c->dst_port()->parent_node() == _node)
- && !c->pending_disconnection()) {
- Disconnect* ev = new Disconnect(_engine,
- SharedPtr<Request>(), _time, c->src_port(), c->dst_port(), reconnect_input);
- ev->pre_process();
- _disconnect_events.push_back(new Raul::List<Disconnect*>::Node(ev));
- c->pending_disconnection(true);
+ if (!c->pending_disconnection()
+ && (c->src_port()->parent_node() == _node
+ || c->dst_port()->parent_node() == _node)) {
+ remove_connection(c);
}
}
} else { // _port
for (PatchImpl::Connections::const_iterator i = _parent->connections().begin();
i != _parent->connections().end(); ++i) {
ConnectionImpl* c = (ConnectionImpl*)i->second.get();
- const bool reconnect_input = !_deleting || (c->dst_port()->parent_node() != _node);
- if ((c->src_port() == _port || c->dst_port() == _port) && !c->pending_disconnection()) {
- Disconnect* ev = new Disconnect(_engine,
- SharedPtr<Request>(), _time, c->src_port(), c->dst_port(), reconnect_input);
- ev->pre_process();
- _disconnect_events.push_back(new Raul::List<Disconnect*>::Node(ev));
- c->pending_disconnection(true);
+ if (!c->pending_disconnection()
+ && (c->src_port() == _port
+ || c->dst_port() == _port)) {
+ remove_connection(c);
}
}
}
diff --git a/src/engine/events/DisconnectAll.hpp b/src/engine/events/DisconnectAll.hpp
index 0d89901d..ee8fbade 100644
--- a/src/engine/events/DisconnectAll.hpp
+++ b/src/engine/events/DisconnectAll.hpp
@@ -67,6 +67,8 @@ private:
OBJECT_NOT_FOUND,
};
+ void remove_connection(ConnectionImpl* c);
+
Raul::Path _parent_path;
Raul::Path _path;
PatchImpl* _parent;