From cbd47819330149e666941d44f31b50bf6333b478 Mon Sep 17 00:00:00 2001 From: Bernard Normier Date: Mon, 22 Apr 2024 16:43:31 +0200 Subject: [PATCH] Fix review comments --- cpp/src/Ice/ConnectionI.cpp | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/cpp/src/Ice/ConnectionI.cpp b/cpp/src/Ice/ConnectionI.cpp index 437d319ce32..82a733cb898 100644 --- a/cpp/src/Ice/ConnectionI.cpp +++ b/cpp/src/Ice/ConnectionI.cpp @@ -414,6 +414,11 @@ Ice::ConnectionI::startAsync( if (!initialize() || !validate()) { + if (_connectTimeout > chrono::seconds::zero()) + { + _timer->schedule(make_shared(shared_from_this()), _connectTimeout); + } + if (connectionStartCompleted && connectionStartFailed) { _connectionStartCompleted = std::move(connectionStartCompleted); @@ -2620,7 +2625,7 @@ Ice::ConnectionI::connectTimedOut() noexcept { setState(StateClosed, make_exception_ptr(ConnectTimeoutException(__FILE__, __LINE__))); } - // else ignore since we're no longer in the "connect" phase. + // else ignore since we're already connected. } void @@ -2631,7 +2636,7 @@ Ice::ConnectionI::closeTimedOut() noexcept { setState(StateClosed, make_exception_ptr(CloseTimeoutException(__FILE__, __LINE__))); } - // else ignore since we're no longer in the "close" phase. + // else ignore since we're already closed. } void @@ -2702,11 +2707,6 @@ Ice::ConnectionI::sendResponse(OutgoingResponse response, uint8_t compress) bool Ice::ConnectionI::initialize(SocketOperation operation) { - if (_connectTimeout > chrono::seconds::zero()) - { - _timer->schedule(make_shared(shared_from_this()), _connectTimeout); - } - SocketOperation s = _transceiver->initialize(_readStream, _writeStream); if (s != SocketOperationNone) {