apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-15 10:22:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Apply clang-format to Net2.actor.cpp

Browse Source
This commit is contained in:
sfc-gh-tclinkenbeard 2021-12-02 10:22:22 -08:00
parent 6b45ef98ca
commit 70c8f98eb9
1 changed files with 24 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
flow/Net2.actor.cpp
View File

@ -1819,33 +1819,33 @@ ACTOR static Future<std::vector<NetworkAddress>> resolveTCPEndpoint_impl(Net2* s
Promise<std::vector<NetworkAddress>> promise; Promise<std::vector<NetworkAddress>> promise;
state Future<std::vector<NetworkAddress>> result = promise.getFuture(); state Future<std::vector<NetworkAddress>> result = promise.getFuture();
tcpResolver.async_resolve( tcpResolver.async_resolve(tcp::resolver::query(host, service),
tcp::resolver::query(host, service), [=](const boost::system::error_code& ec, tcp::resolver::iterator iter) { [=](const boost::system::error_code& ec, tcp::resolver::iterator iter) {
if (ec) { if (ec) {
promise.sendError(lookup_failed()); promise.sendError(lookup_failed());
return; return;
} }
std::vector<NetworkAddress> addrs; std::vector<NetworkAddress> addrs;
tcp::resolver::iterator end; tcp::resolver::iterator end;
while (iter != end) { while (iter != end) {
auto endpoint = iter->endpoint(); auto endpoint = iter->endpoint();
auto addr = endpoint.address(); auto addr = endpoint.address();
if (addr.is_v6()) { if (addr.is_v6()) {
addrs.emplace_back(IPAddress(addr.to_v6().to_bytes()), endpoint.port()); addrs.emplace_back(IPAddress(addr.to_v6().to_bytes()), endpoint.port());
} else { } else {
addrs.emplace_back(IPAddress(addr.to_v4().to_ulong(), endpoint.port())); addrs.emplace_back(IPAddress(addr.to_v4().to_ulong(), endpoint.port()));
} }
++iter; ++iter;
} }
if (addrs.empty()) { if (addrs.empty()) {
promise.sendError(lookup_failed()); promise.sendError(lookup_failed());
} else { } else {
promise.send(addrs); promise.send(addrs);
} }
}); });
wait(ready(result)); wait(ready(result));
tcpResolver.cancel(); tcpResolver.cancel();