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_++;