summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp')
-rw-r--r--cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp13
1 files changed, 5 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp b/cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp
index 676f9e4b3d..6c3d960d1f 100644
--- a/cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp
+++ b/cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp
@@ -64,7 +64,7 @@ void MultiVersionConnectionInputHandler::idleIn()
bool MultiVersionConnectionInputHandler::doOutput()
{
- return check(false) && handler->doOutput();
+ return handler.get() && handler->doOutput();
}
qpid::framing::ProtocolInitiation MultiVersionConnectionInputHandler::getInitiation()
@@ -74,17 +74,14 @@ qpid::framing::ProtocolInitiation MultiVersionConnectionInputHandler::getInitiat
void MultiVersionConnectionInputHandler::closed()
{
- check();
- handler->closed();
+ if (handler.get()) handler->closed();
+ //else closed before initiated, nothing to do
}
-bool MultiVersionConnectionInputHandler::check(bool fail)
+void MultiVersionConnectionInputHandler::check()
{
if (!handler.get()) {
- if (fail) throw qpid::framing::InternalErrorException("Handler not initialised!");
- else return false;
- } else {
- return true;
+ throw qpid::framing::InternalErrorException("Handler not initialised!");
}
}