Struct veloren_server::connection_handler::ConnectionHandler

pub(crate) struct ConnectionHandler {
    _network_receiver: Receiver<Network>,
    thread_handle: Option<JoinHandle<()>>,
    pub client_receiver: Receiver<Client>,
    pub info_requester_receiver: Receiver<Sender<ServerInfoPacket>>,
    stop_sender: Option<Sender<()>>,
}

Fields

_network_receiver: Receiver<Network>

We never actually use this, but if it’s dropped before the network has a chance to exit, it won’t block the main thread, and if it is dropped after the network thread ends, it will drop the network here (rather than delaying the network thread). So it emulates the effects of storing the network in an Arc, without us losing mutability in the network thread.

thread_handle: Option<JoinHandle<()>>

client_receiver: Receiver<Client>

info_requester_receiver: Receiver<Sender<ServerInfoPacket>>

stop_sender: Option<Sender<()>>

Implementations

impl ConnectionHandler

Instead of waiting the main loop we are handling connections, especially their slow network .await part on a different thread. We need to communicate to the Server main thread sometimes though to get the current server_info and time

pub fn new(network: Network, runtime: &Runtime) -> Self

async fn work( network: Network, client_sender: Sender<Client>, info_requester_sender: Sender<Sender<ServerInfoPacket>>, stop_receiver: Receiver<()>, network_sender: Sender<Network>, )

async fn init_participant( participant: Participant, client_sender: Sender<Client>, info_requester_sender: Sender<Sender<ServerInfoPacket>>, ) -> Result<(), Box<dyn Error>>

Trait Implementations

impl Drop for ConnectionHandler

fn drop(&mut self)

Executes the destructor for this type.