apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-14 18:02:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

Use unique pointer to avoid memory leak.

Browse Source
This commit is contained in:
Renxuan Wang 2022-05-27 11:02:52 -07:00 committed by Zhe Wu
parent d502c47bfe
commit 0500bcb3a7
1 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
fdbrpc/genericactors.actor.h
View File

@ -137,13 +137,11 @@ Future<REPLY_TYPE(Req)> retryGetReplyFromHostname(Req request, Hostname hostname
// Suitable for use with hostname, where RequestStream is NOT initialized yet.
// Not normally useful for endpoints initialized with NetworkAddress.
state double reconnetInterval = FLOW_KNOBS->HOSTNAME_RECONNECT_INIT_INTERVAL;
state RequestStream<Req>* to;
state std::unique_ptr<RequestStream<Req>> to;
loop {
NetworkAddress address = wait(hostname.resolveWithRetry());
if (to == nullptr) {
to = new RequestStream<Req>(Endpoint::wellKnown({ address }, token));
} else if (to->getEndpoint().getPrimaryAddress() != address) {
*to = RequestStream<Req>(Endpoint::wellKnown({ address }, token));
if (to == nullptr || to->getEndpoint().getPrimaryAddress() != address) {
to = std::make_unique<RequestStream<Req>>(Endpoint::wellKnown({ address }, token));
}
state ErrorOr<REPLY_TYPE(Req)> reply = wait(to->tryGetReply(request));
if (reply.isError()) {
@ -171,13 +169,11 @@ Future<REPLY_TYPE(Req)> retryGetReplyFromHostname(Req request,
// Suitable for use with hostname, where RequestStream is NOT initialized yet.
// Not normally useful for endpoints initialized with NetworkAddress.
state double reconnetInterval = FLOW_KNOBS->HOSTNAME_RECONNECT_INIT_INTERVAL;
state RequestStream<Req>* to;
state std::unique_ptr<RequestStream<Req>> to;
loop {
NetworkAddress address = wait(hostname.resolveWithRetry());
if (to == nullptr) {
to = new RequestStream<Req>(Endpoint::wellKnown({ address }, token));
} else if (to->getEndpoint().getPrimaryAddress() != address) {
*to = RequestStream<Req>(Endpoint::wellKnown({ address }, token));
if (to == nullptr || to->getEndpoint().getPrimaryAddress() != address) {
to = std::make_unique<RequestStream<Req>>(Endpoint::wellKnown({ address }, token));
}
state ErrorOr<REPLY_TYPE(Req)> reply = wait(to->tryGetReply(request, taskID));
if (reply.isError()) {