TySS-Dev/nearby
1
0
Fork 0
mirror of https://github.com/kidfromjupiter/nearby.git synced 2026-09-14 22:56:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

Internal change

Browse Source 
PiperOrigin-RevId: 372018877
This commit is contained in:
hai007
2021-05-04 16:29:09 -07:00
committed by Copybara-Service
parent 49c5ecb5a8
commit 1e5416bdcb
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cpp/core/internal/endpoint_manager.cc
+12 -12
View File
@@ -409,12 +409,12 @@ void EndpointManager::RegisterEndpoint(ClientProxy* client,
absl::Milliseconds(options.keep_alive_interval_millis);
absl::Duration keep_alive_timeout =
absl::Milliseconds(options.keep_alive_timeout_millis);
NEARBY_LOG(INFO,
"Registering endpoint %s for client %d with keep-alive frame as "
"interval=%s, timeout=%s",
endpoint_id.c_str(), client->GetClientId(),
absl::FormatDuration(keep_alive_interval).c_str(),
absl::FormatDuration(keep_alive_timeout).c_str());
NEARBY_LOGS(INFO) << "Registering endpoint " << endpoint_id.c_str()
<< " for client " << client->GetClientId()
<< " with keep-alive frame as interval="
<< absl::FormatDuration(keep_alive_interval).c_str()
<< ", timeout="
<< absl::FormatDuration(keep_alive_timeout).c_str();
// Pass ownership of channel to EndpointChannelManager
NEARBY_LOG(INFO, "Registering endpoint with channel manager: id=%s",
@@ -487,12 +487,12 @@ void EndpointManager::UnregisterEndpoint(ClientProxy* client,
const std::string& endpoint_id) {
NEARBY_LOG(ERROR, "UnregisterEndpoint for endpoint %s", endpoint_id.c_str());
CountDownLatch latch(1);
RunOnEndpointManagerThread("unregister-endpoint", [this, client, endpoint_id,
&latch]() {
RemoveEndpoint(client, endpoint_id,
client->IsConnectedToEndpoint(endpoint_id));
latch.CountDown();
});
RunOnEndpointManagerThread(
"unregister-endpoint", [this, client, endpoint_id, &latch]() {
RemoveEndpoint(client, endpoint_id,
client->IsConnectedToEndpoint(endpoint_id));
latch.CountDown();
});
latch.Await();
}