wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-09-10 12:38:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

lint fix. (#1842)

Browse Source
This commit is contained in:
Melih Elibol
2018-04-06 13:28:52 -07:00
committed by Robert Nishihara
parent 24a8cede88
commit c7e11e9057
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/object_manager/connection_pool.cc
+3 -3
View File
@@ -17,13 +17,13 @@ void ConnectionPool::RegisterReceiver(ConnectionType type, const ClientID &clien
}
}
void ConnectionPool::RemoveReceiver(std::shared_ptr<TcpClientConnection> conn){
void ConnectionPool::RemoveReceiver(std::shared_ptr<TcpClientConnection> conn) {
std::unique_lock<std::mutex> guard(connection_mutex);
ClientID client_id = conn->GetClientID();
if (message_receive_connections_.count(client_id) != 0){
if (message_receive_connections_.count(client_id) != 0) {
Remove(message_receive_connections_, client_id, conn);
}
if (transfer_receive_connections_.count(client_id) != 0){
if (transfer_receive_connections_.count(client_id) != 0) {
Remove(transfer_receive_connections_, client_id, conn);
}
}