Struct UdpListenerSession 

pub struct UdpListenerSession { /* private fields */ }

The ProxySession backing one UDP listener. The server’s generic readiness path drives this (UDP is not in the listen-accept arm). It owns the per-flow connected upstream sockets and demuxes events by token.

Implementations

impl UdpListenerSession

pub fn new( listener: Rc<RefCell<UdpListener>>, manager: Rc<RefCell<UdpManager>>, backends: Rc<RefCell<BackendMap>>, registry: Registry, sessions: Rc<RefCell<SessionManager>>, listener_token: Token, ) -> UdpListenerSession

pub fn close_all_flows(&mut self, now: Instant)

Tear down every active flow on this listener through the manager, so each close emits FlowEvicted + CloseFlow exactly once and the shell’s normal on_close_flow handler frees the upstream socket + slab slot and decrements udp.active_flows. Used on soft/hard stop, listener remove, and listener deactivate so the worker reaches its base_sessions_count and exits promptly instead of waiting out every flow’s idle timeout — and so the active-flows gauge does not leak by N (the bug the old direct-teardown path had: it cleared the shell maps without telling the manager, so FlowEvicted never fired).

On a deactivate where the manager is retained (not dropped), this also resets the manager’s flow table to empty, keeping manager and shell consistent. The listener socket and the listener-session slab slot are left intact (the listener slot is part of base_sessions_count and reclaimed when the worker exits); only the connectionless per-flow slots — which are NOT counted in nb_connections and so removed without decr — are freed.

Trait Implementations

impl ProxySession for UdpListenerSession

fn protocol(&self) -> Protocol

indicates the protocol associated with the session

fn update_readiness(&mut self, token: Token, events: Ready)

if the event loop got an event for a token associated with the session, it will call this method on the session

fn ready(&mut self, _session: Rc<RefCell<dyn ProxySession>>) -> bool

if a session received an event or can still execute, the event loop will call this method. Its result indicates if it can still execute, needs to connect to a backend server, close the session

fn timeout(&mut self, token: Token) -> bool

if a timeout associated with the session triggers, the event loop will call this method with the timeout’s token

fn close(&mut self)

close a session, frontend and backend sockets, remove the entries from the session manager slab

fn last_event(&self) -> Instant

last time the session got an event

fn print_session(&self)

display the session’s internal state (for debugging purpose)

fn frontend_token(&self) -> Token

get the token associated with the frontend

fn shutting_down(&mut self) -> bool

tell the session it has to shut down if possible

fn cluster_id(&self) -> Option<String>

Best-effort identifier of the cluster currently routed to by this session. Returns None for ListenSession (no per-session cluster), and for client sessions before routing has resolved. H2 sessions multiplex many streams over one frontend token and may touch several clusters; the returned value is whichever cluster the session most recently keep-alive’d to. Used for log/metric attribution, not for accounting (the tracker keeps the canonical per-stream (cluster, IP) set).

fn session_address(&self) -> Option<SocketAddr>

Source address as observed by Sōzu, with proxy-protocol awareness. HTTP/HTTPS/TCP client sessions return the parsed PROXY-protocol source when present, else peer_addr. ListenSession returns None. Used to attribute per-(cluster, source-IP) tracking and access logs to the real client behind a layer-4 PROXY frontend.