voxel/kubi
1
1
Fork 0
mirror of https://github.com/griffi-gh/kubi.git synced 2024-12-25 13:18:21 -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 db1a48f876
commit 5d8f253c3c
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,
endpoint_config: EndpointConfig {
active_timeout_ms: config.server.timeout_ms,
keepalive: true,
keepalive_interval_ms: 1000,
..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 glium::glutin::event_loop::ControlFlow;
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::{
messages::{ClientToServerMessage, ServerToClientMessage, S_SERVER_HELLO},
state::ClientJoinState,
@ -54,7 +54,14 @@ fn connect_client(
) {
log::info!("Creating client");
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(ClientJoinState::Disconnected);
}