diff options
Diffstat (limited to 'cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp')
-rw-r--r-- | cpp/src/qpid/broker/MultiVersionConnectionInputHandler.cpp | 13 |
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!"); } } |