This is an automated email from the ASF dual-hosted git repository.
bnolsen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/trafficserver.git
The following commit(s) were added to refs/heads/master by this push:
new 71ff1ec5ce revert #10996 move session pool metrics outside critical
section (#12233)
71ff1ec5ce is described below
commit 71ff1ec5cecc871d6d0db7163b6a550e5f737c94
Author: Brian Olsen <[email protected]>
AuthorDate: Mon May 12 12:59:48 2025 -0600
revert #10996 move session pool metrics outside critical section (#12233)
Co-authored-by: Brian Olsen <[email protected]>
---
src/proxy/http/HttpSessionManager.cc | 19 ++++++-------------
1 file changed, 6 insertions(+), 13 deletions(-)
diff --git a/src/proxy/http/HttpSessionManager.cc
b/src/proxy/http/HttpSessionManager.cc
index 6e081ca026..5ce19b158e 100644
--- a/src/proxy/http/HttpSessionManager.cc
+++ b/src/proxy/http/HttpSessionManager.cc
@@ -441,7 +441,6 @@ HttpSessionManager::_acquire_session(sockaddr const *ip,
CryptoHash const &hostn
{
PoolableSession *to_return = nullptr;
HSMresult_t retval = HSM_NOT_FOUND;
- bool acquired = false;
// Extend the mutex window until the acquired Server session is attached
// to the SM. Releasing the mutex before that results in race conditions
@@ -458,12 +457,10 @@ HttpSessionManager::_acquire_session(sockaddr const *ip,
CryptoHash const &hostn
if (locked) {
if (TS_SERVER_SESSION_SHARING_POOL_THREAD == pool_type) {
- retval = ethread->server_session_pool->acquireSession(ip,
hostname_hash, match_style, sm, to_return);
- acquired = (HSM_DONE == retval);
+ retval = ethread->server_session_pool->acquireSession(ip,
hostname_hash, match_style, sm, to_return);
Dbg(dbg_ctl_http_ss, "[acquire session] thread pool search %s",
to_return ? "successful" : "failed");
} else {
- retval = m_g_pool->acquireSession(ip, hostname_hash, match_style,
sm, to_return);
- acquired = (HSM_DONE == retval);
+ retval = m_g_pool->acquireSession(ip, hostname_hash, match_style, sm,
to_return);
Dbg(dbg_ctl_http_ss, "[acquire session] global pool search %s",
to_return ? "successful" : "failed");
// At this point to_return has been removed from the pool. Do we need
to move it
// to the same thread?
@@ -517,10 +514,6 @@ HttpSessionManager::_acquire_session(sockaddr const *ip,
CryptoHash const &hostn
}
}
- if (acquired) {
- Metrics::Gauge::decrement(http_rsb.pooled_server_connections);
- }
-
return retval;
}
@@ -552,10 +545,6 @@ HttpSessionManager::release_session(PoolableSession
*to_release)
}
}
- if (released_p) {
- Metrics::Gauge::increment(http_rsb.pooled_server_connections);
- }
-
return released_p ? HSM_DONE : HSM_RETRY;
}
@@ -576,6 +565,8 @@ ServerSessionPool::removeSession(PoolableSession *to_remove)
Dbg(dbg_ctl_http_ss, "After Remove session %p m_fqdn_pool size=%zu
m_ip_pool_size=%zu", to_remove, m_fqdn_pool.count(),
m_ip_pool.count());
}
+
+ Metrics::Gauge::decrement(http_rsb.pooled_server_connections);
}
void
@@ -592,4 +583,6 @@ ServerSessionPool::addSession(PoolableSession *ss)
ats_ip_nptop(ss->get_remote_addr(), peer_ip, sizeof(peer_ip));
Dbg(dbg_ctl_http_ss, "[%" PRId64 "] [add session] session placed into
shared pool under ip %s", ss->connection_id(), peer_ip);
}
+
+ Metrics::Gauge::increment(http_rsb.pooled_server_connections);
}