Skip to content

Commit

Permalink
msg/async/AsyncConnection: unregister connection when racing happened
Browse files Browse the repository at this point in the history
Signed-off-by: Haomai Wang <[email protected]>
  • Loading branch information
yuyuyu101 committed Dec 13, 2017
1 parent ef54a05 commit 5216309
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions src/msg/async/AsyncMessenger.h
Original file line number Diff line number Diff line change
Expand Up @@ -356,9 +356,6 @@ class AsyncMessenger : public SimplePolicyMessenger {
Mutex::Locker l(deleted_lock);
if (deleted_conns.erase(existing)) {
existing->get_perf_counter()->dec(l_msgr_active_connections);
conns.erase(it);
} else if (conn != existing) {
return -1;
}
}
conns[conn->peer_addr] = conn;
Expand Down

0 comments on commit 5216309

Please sign in to comment.