fix build and update wait timeout

Author: BewareMyPower

lib/ClientConnection.h

@@ -410,7 +410,7 @@ class PULSAR_PUBLIC ClientConnection : public std::enable_shared_from_this<Clien
     // However, `close` could be called when a mutex is held, so we have to use a recursive mutex to avoid
     // deadlock.
     mutable std::recursive_mutex mutex_;
-    using Lock = std::lock_guard<std::recursive_mutex>;
+    using Lock = std::unique_lock<std::recursive_mutex>;
 
     // Pending buffers to write on the socket
     std::deque<std::any> pendingWriteBuffers_;

lib/ConnectionPool.cc

@@ -63,14 +63,15 @@ bool ConnectionPool::close() {
         if (cnx) {
             // The 2nd argument is false because removing a value during the iteration will cause segfault
             cnx->close(ResultDisconnected, false);
-            for (int i = 0; i < 5000 && cnx->pendingOperations() > 0; i++) {
+            for (int i = 0; i < clientConfiguration_.getConnectionTimeout() && cnx->pendingOperations() > 0;
+                 i++) {
                 using namespace std::chrono_literals;
                 std::this_thread::sleep_for(1ms);
             }
             if (cnx->pendingOperations() > 0) {
-                LOG_WARN(
-                    "Connection still has pending operations after waiting for 5 seconds, pending count: "
-                    << cnx->pendingOperations());
+                LOG_WARN("Connection still has pending operations after waiting for "
+                         << clientConfiguration_.getConnectionTimeout()
+                         << "ms, pending count: " << cnx->pendingOperations());
             }
         }
     }