Skip to content

Commit c9f8088

Browse files
authored
Merge pull request ceph#57951 from mohit84/issue_66231
AsyncMessenger: Don't decrease l_msgr_active_connections if it is negative Reviewed-by: Radoslaw Zarzynski <[email protected]>
2 parents ed30494 + b931251 commit c9f8088

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/msg/async/AsyncMessenger.cc

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -611,6 +611,7 @@ void AsyncMessenger::add_accept(Worker *w, ConnectedSocket cli_socket,
611611
listen_addr.is_msgr2(), false);
612612
conn->accept(std::move(cli_socket), listen_addr, peer_addr);
613613
accepting_conns.insert(conn);
614+
w->get_perf_counter()->inc(l_msgr_active_connections);
614615
}
615616

616617
AsyncConnectionRef AsyncMessenger::create_connect(
@@ -865,7 +866,6 @@ int AsyncMessenger::accept_conn(const AsyncConnectionRef& conn)
865866
conn->policy.lossy &&
866867
!conn->policy.register_lossy_clients) {
867868
anon_conns.insert(conn);
868-
conn->get_perf_counter()->inc(l_msgr_active_connections);
869869
return 0;
870870
}
871871
auto it = conns.find(*conn->peer_addrs);
@@ -884,7 +884,6 @@ int AsyncMessenger::accept_conn(const AsyncConnectionRef& conn)
884884
}
885885
ldout(cct, 10) << __func__ << " " << conn << " " << *conn->peer_addrs << dendl;
886886
conns[*conn->peer_addrs] = conn;
887-
conn->get_perf_counter()->inc(l_msgr_active_connections);
888887
accepting_conns.erase(conn);
889888
return 0;
890889
}

0 commit comments

Comments
 (0)