Struct server::gameplay_socket::GameplaySocket

pub struct GameplaySocket {
    socket: UdpSocket,
    peer_refresh_times: HashMap<PeerIdentifier, Instant>,
    peer_addrs: HashMap<PeerIdentifier, SocketAddr>,
    peer_queues: HashMap<PeerIdentifier, MessageOrderer<ServerAction, ClientAction>>,
}

Sends effects and receives actions over UDP.

Fields

socket: UdpSocket

peer_refresh_times: HashMap<PeerIdentifier, Instant>

peer_addrs: HashMap<PeerIdentifier, SocketAddr>

peer_queues: HashMap<PeerIdentifier, MessageOrderer<ServerAction, ClientAction>>

Implementations

impl GameplaySocket

pub fn new() -> Result<GameplaySocket>

Binds a UdpSocket to 0.0.0.0:7812 to start listening for messages and sets up initial state.

pub fn add_peer(&mut self, peer_id: PeerIdentifier, encryption_key: [u8; 32])

Used by the LoginServer, adds a new peer identifier to listen for, and their associated encryption key.

pub fn transport(&mut self)

Sends and receives all pending messages on the UDP socket.

pub fn recv_actions(&mut self) -> Option<(PeerIdentifier, ClientAction)>

Returns queued messages as long as there are any. These are queued up by GameplaySocket::transport.

pub fn refresh(&mut self) -> Vec<PeerIdentifier>

Disconnects clients that haven’t been refreshed in a while, returns all of the current peers.

pub fn send_action(&mut self, peer: PeerIdentifier, action: ServerAction)

Queues up the action to the peer, for sending during the next GameplaySocket::transport.