diff options
Diffstat (limited to 'src/server/ConnectionImpl.cpp')
| -rw-r--r-- | src/server/ConnectionImpl.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/server/ConnectionImpl.cpp b/src/server/ConnectionImpl.cpp index 7a4d7dda..7abda828 100644 --- a/src/server/ConnectionImpl.cpp +++ b/src/server/ConnectionImpl.cpp @@ -30,6 +30,7 @@ #include "Engine.hpp" #include "InputPort.hpp" #include "MessageContext.hpp" +#include "NodeImpl.hpp" #include "OutputPort.hpp" #include "PortImpl.hpp" #include "ProcessContext.hpp" @@ -151,7 +152,8 @@ ConnectionImpl::must_mix() const bool ConnectionImpl::must_queue() const { - return _src_port->context() != _dst_port->context(); + return _src_port->parent_node()->context() + != _dst_port->parent_node()->context(); } bool |