Struct quilkin::components::proxy::SessionPool

pub struct SessionPool { /* private fields */ }

A data structure that is responsible for holding sessions, and pooling sockets between them. This means that we only provide new unique sockets to new connections to the same gameserver, and we share sockets across multiple gameservers.

Traffic from different gameservers is then demuxed using their address to send back to the original client.

Implementations

impl SessionPool

pub fn new( config: Arc<Config>, downstream_sender: Sender<(PoolBuffer, Option<IpNetEntry>, SocketAddr)>, buffer_pool: Arc<BufferPool>, shutdown_rx: ShutdownRx ) -> Arc<Self>

Constructs a new session pool, it’s created with an Arc as that’s required for the pool to provide a reference to the children to be able to release their sockets back to the parent.

pub async fn get<'pool>( self: &'pool Arc<Self>, key: SessionKey, asn_info: Option<IpNetEntry> ) -> Result<Sender<(FrozenPoolBuffer, Option<IpNetEntry>, SocketAddr)>, PipelineError>

Returns a reference to an existing session mapped to key, otherwise creates a new session either from a fresh socket, or if there are sockets allocated that are not reserved by an existing destination, using the existing socket.

pub fn sessions(&self) -> &TtlMap<SessionKey, Session>

Returns a map of active sessions.

pub async fn send( self: &Arc<Self>, key: SessionKey, asn_info: Option<IpNetEntry>, packet: FrozenPoolBuffer ) -> Result<(), PipelineError>

Sends packet data to the appropiate session based on its key.

Trait Implementations

impl Debug for SessionPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for SessionPool

fn drop(&mut self)

Executes the destructor for this type.