Skip to content

Commit

Permalink
Address wadeliuyi's comments
Browse files Browse the repository at this point in the history
  • Loading branch information
heng committed Jul 15, 2019
1 parent 6fd9bc7 commit f00dc93
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/meta/processors/admin/AdminClient.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ folly::Future<Status> AdminClient::addLearner(GraphSpaceID spaceId, PartitionID
}
folly::Promise<Status> pro;
auto f = pro.getFuture();
getResponse(ret.value(), 0, req, [] (auto client, auto request) {
getResponse(ret.value(), 0, std::move(req), [] (auto client, auto request) {
return client->future_addLearner(request);
}, 0, std::move(pro), FLAGS_max_retry_times_admin_op);
return f;
Expand All @@ -95,7 +95,7 @@ folly::Future<Status> AdminClient::waitingForCatchUpData(GraphSpaceID spaceId,
}
folly::Promise<Status> pro;
auto f = pro.getFuture();
getResponse(ret.value(), 0, req, [] (auto client, auto request) {
getResponse(ret.value(), 0, std::move(req), [] (auto client, auto request) {
return client->future_waitingForCatchUpData(request);
}, 0, std::move(pro), FLAGS_max_retry_times_admin_op);
return f;
Expand All @@ -114,7 +114,7 @@ folly::Future<Status> AdminClient::memberChange(GraphSpaceID spaceId, PartitionI
}
folly::Promise<Status> pro;
auto f = pro.getFuture();
getResponse(ret.value(), 0, req, [] (auto client, auto request) {
getResponse(ret.value(), 0, std::move(req), [] (auto client, auto request) {
return client->future_memberChange(request);
}, 0, std::move(pro), FLAGS_max_retry_times_admin_op);
return f;
Expand Down Expand Up @@ -203,7 +203,7 @@ folly::Future<Status> AdminClient::getResponse(
t.exception().what().c_str())));
return;
}
auto&& resp = t.value();
auto&& resp = std::move(t).value();
p.setValue(respGen(std::move(resp)));
});
return f;
Expand Down

0 comments on commit f00dc93

Please sign in to comment.