This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 05dc8c8  [pulsar-client] Fix pulsar-cpp crash on lookup timeout (#3862)
05dc8c8 is described below

commit 05dc8c88aba193d64002ff8cc229c01790fcef72
Author: Rajan Dhabalia <[email protected]>
AuthorDate: Tue Mar 19 07:42:22 2019 -0700

    [pulsar-client] Fix pulsar-cpp crash on lookup timeout (#3862)
---
 pulsar-client-cpp/lib/ClientConnection.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client-cpp/lib/ClientConnection.cc 
b/pulsar-client-cpp/lib/ClientConnection.cc
index 9cf27e3..e16aa5c 100644
--- a/pulsar-client-cpp/lib/ClientConnection.cc
+++ b/pulsar-client-cpp/lib/ClientConnection.cc
@@ -1106,11 +1106,11 @@ void ClientConnection::newLookup(const SharedBuffer& 
cmd, const uint64_t request
         return;
     }
     LookupRequestData requestData;
+    requestData.promise = promise;
     requestData.timer = executor_->createDeadlineTimer();
     requestData.timer->expires_from_now(operationsTimeout_);
     
requestData.timer->async_wait(std::bind(&ClientConnection::handleLookupTimeout, 
shared_from_this(),
                                             std::placeholders::_1, 
requestData));
-    requestData.promise = promise;
 
     pendingLookupRequests_.insert(std::make_pair(requestId, requestData));
     numOfPendingLookupRequest_++;

Reply via email to