Record a connection close for a tenant.
(&self, tenant_id: TenantId)
| 319 | |
| 320 | /// Record a connection close for a tenant. |
| 321 | pub fn tenant_connection_end(&self, tenant_id: TenantId) { |
| 322 | match self.tenants.lock() { |
| 323 | Ok(mut t) => t.connection_end(tenant_id), |
| 324 | Err(poisoned) => poisoned.into_inner().connection_end(tenant_id), |
| 325 | } |
| 326 | } |
| 327 | |
| 328 | /// Poll responses from all Data Plane cores and route them to waiting sessions. |
| 329 | /// Returns the number of responses routed — callers use this for adaptive |
no test coverage detected