voxel/kubi
1
1
Fork 0
mirror of https://github.com/griffi-gh/kubi.git synced 2024-11-24 07:48:42 -06:00
Code Issues Packages Projects Releases Wiki Activity

enable keepalive

Browse source
This commit is contained in:
griffi-gh 2023-03-13 02:34:09 +01:00
parent a719427eb5
commit e9977c3aa4
2 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
kubi-server/src/server.rs
View file

@ -34,6 +34,8 @@ pub fn bind_server(
enable_handshake_errors: true, enable_handshake_errors: true,
endpoint_config: EndpointConfig { endpoint_config: EndpointConfig {
active_timeout_ms: config.server.timeout_ms, active_timeout_ms: config.server.timeout_ms,
keepalive: true,
keepalive_interval_ms: 1000,
..Default::default() ..Default::default()
}, },
..Default::default() ..Default::default()

11
kubi/src/networking.rs
View file

@ -1,7 +1,7 @@
use shipyard::{Unique, AllStoragesView, UniqueView, UniqueViewMut, Workload, IntoWorkload, EntitiesViewMut, Component, ViewMut, SystemModificator, View, IntoIter, WorkloadModificator}; use shipyard::{Unique, AllStoragesView, UniqueView, UniqueViewMut, Workload, IntoWorkload, EntitiesViewMut, Component, ViewMut, SystemModificator, View, IntoIter, WorkloadModificator};
use glium::glutin::event_loop::ControlFlow; use glium::glutin::event_loop::ControlFlow;
use std::net::SocketAddr; use std::net::SocketAddr;
use uflow::client::{Client, Config as ClientConfig, Event as ClientEvent}; use uflow::{client::{Client, Config as ClientConfig, Event as ClientEvent}, EndpointConfig};
use kubi_shared::networking::{ use kubi_shared::networking::{
messages::{ClientToServerMessage, ServerToClientMessage, S_SERVER_HELLO}, messages::{ClientToServerMessage, ServerToClientMessage, S_SERVER_HELLO},
state::ClientJoinState, state::ClientJoinState,
@ -54,7 +54,14 @@ fn connect_client(
) { ) {
log::info!("Creating client"); log::info!("Creating client");
let address = storages.borrow::<UniqueView<ServerAddress>>().unwrap(); let address = storages.borrow::<UniqueView<ServerAddress>>().unwrap();
let client = Client::connect(address.0, ClientConfig::default()).expect("Client connection failed"); let client = Client::connect(address.0, ClientConfig {
endpoint_config: EndpointConfig {
active_timeout_ms: 10000,
keepalive: true,
keepalive_interval_ms: 1000,
..Default::default()
},
}).expect("Client connection failed");
storages.add_unique(UdpClient(client)); storages.add_unique(UdpClient(client));
storages.add_unique(ClientJoinState::Disconnected); storages.add_unique(ClientJoinState::Disconnected);
} }