apply gxu patch

Author: magniloquency

scaler/io/ymq/tcp_client.cpp

@@ -70,6 +70,7 @@ void TcpClient::onCreated()
         sock->onConnectionCreated(setNoDelay(sockfd), getLocalAddr(sockfd), getRemoteAddr(sockfd), responsibleForRetry);
         if (_retryTimes == 0) {
             _onConnectReturn({});
+            _onConnectReturn = {};
         }
         return;
     }
@@ -78,6 +79,7 @@ void TcpClient::onCreated()
         _eventLoopThread->_eventLoop.addFdToLoop(sockfd, EPOLLOUT | EPOLLET, this->_eventManager.get());
         if (_retryTimes == 0) {
             _onConnectReturn(std::unexpected {Error::ErrorCode::InitialConnectFailedWithInProgress});
+            _onConnectReturn = {};
         }
         return;
     }
@@ -361,6 +363,9 @@ TcpClient::~TcpClient() noexcept
     if (_retryTimes > 0) {
         _eventLoopThread->_eventLoop.cancelExecution(_retryIdentifier);
     }
+    if (_onConnectReturn) {
+        _onConnectReturn({});
+    }
 }
 
 }  // namespace ymq