mirror of
https://gitlab.com/veloren/veloren.git
synced 2024-08-30 18:12:32 +00:00
Only try to connect to the singleplayer server after it has been initialized
This commit is contained in:
parent
47b06658b0
commit
325695e937
@ -51,7 +51,7 @@ impl PlayState for MainMenuState {
|
|||||||
&crate::i18n::i18n_asset_key(&global_state.settings.language.selected_language),
|
&crate::i18n::i18n_asset_key(&global_state.settings.language.selected_language),
|
||||||
);
|
);
|
||||||
|
|
||||||
//Poll server creation
|
// Poll server creation
|
||||||
#[cfg(feature = "singleplayer")]
|
#[cfg(feature = "singleplayer")]
|
||||||
{
|
{
|
||||||
if let Some(singleplayer) = &global_state.singleplayer {
|
if let Some(singleplayer) = &global_state.singleplayer {
|
||||||
@ -62,6 +62,18 @@ impl PlayState for MainMenuState {
|
|||||||
self.client_init = None;
|
self.client_init = None;
|
||||||
self.main_menu_ui.cancel_connection();
|
self.main_menu_ui.cancel_connection();
|
||||||
self.main_menu_ui.show_info(format!("Error: {:?}", error));
|
self.main_menu_ui.show_info(format!("Error: {:?}", error));
|
||||||
|
} else {
|
||||||
|
let server_settings = singleplayer.settings();
|
||||||
|
// Attempt login after the server is finished initializing
|
||||||
|
attempt_login(
|
||||||
|
&mut global_state.settings,
|
||||||
|
&mut global_state.info_message,
|
||||||
|
"singleplayer".to_owned(),
|
||||||
|
"".to_owned(),
|
||||||
|
server_settings.gameserver_address.ip().to_string(),
|
||||||
|
server_settings.gameserver_address.port(),
|
||||||
|
&mut self.client_init,
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -208,7 +220,8 @@ impl PlayState for MainMenuState {
|
|||||||
server_address,
|
server_address,
|
||||||
} => {
|
} => {
|
||||||
attempt_login(
|
attempt_login(
|
||||||
global_state,
|
&mut global_state.settings,
|
||||||
|
&mut global_state.info_message,
|
||||||
username,
|
username,
|
||||||
password,
|
password,
|
||||||
server_address,
|
server_address,
|
||||||
@ -229,18 +242,9 @@ impl PlayState for MainMenuState {
|
|||||||
},
|
},
|
||||||
#[cfg(feature = "singleplayer")]
|
#[cfg(feature = "singleplayer")]
|
||||||
MainMenuEvent::StartSingleplayer => {
|
MainMenuEvent::StartSingleplayer => {
|
||||||
let (singleplayer, server_settings) = Singleplayer::new(None); // TODO: Make client and server use the same thread pool
|
let singleplayer = Singleplayer::new(None); // TODO: Make client and server use the same thread pool
|
||||||
|
|
||||||
global_state.singleplayer = Some(singleplayer);
|
global_state.singleplayer = Some(singleplayer);
|
||||||
|
|
||||||
attempt_login(
|
|
||||||
global_state,
|
|
||||||
"singleplayer".to_owned(),
|
|
||||||
"".to_owned(),
|
|
||||||
server_settings.gameserver_address.ip().to_string(),
|
|
||||||
server_settings.gameserver_address.port(),
|
|
||||||
&mut self.client_init,
|
|
||||||
);
|
|
||||||
},
|
},
|
||||||
MainMenuEvent::Settings => {}, // TODO
|
MainMenuEvent::Settings => {}, // TODO
|
||||||
MainMenuEvent::Quit => return PlayStateResult::Shutdown,
|
MainMenuEvent::Quit => return PlayStateResult::Shutdown,
|
||||||
@ -279,19 +283,20 @@ impl PlayState for MainMenuState {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn attempt_login(
|
fn attempt_login(
|
||||||
global_state: &mut GlobalState,
|
settings: &mut Settings,
|
||||||
|
info_message: &mut Option<String>,
|
||||||
username: String,
|
username: String,
|
||||||
password: String,
|
password: String,
|
||||||
server_address: String,
|
server_address: String,
|
||||||
server_port: u16,
|
server_port: u16,
|
||||||
client_init: &mut Option<ClientInit>,
|
client_init: &mut Option<ClientInit>,
|
||||||
) {
|
) {
|
||||||
let mut net_settings = &mut global_state.settings.networking;
|
let mut net_settings = &mut settings.networking;
|
||||||
net_settings.username = username.clone();
|
net_settings.username = username.clone();
|
||||||
if !net_settings.servers.contains(&server_address) {
|
if !net_settings.servers.contains(&server_address) {
|
||||||
net_settings.servers.push(server_address.clone());
|
net_settings.servers.push(server_address.clone());
|
||||||
}
|
}
|
||||||
if let Err(e) = global_state.settings.save_to_file() {
|
if let Err(e) = settings.save_to_file() {
|
||||||
warn!(?e, "Failed to save settings");
|
warn!(?e, "Failed to save settings");
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -301,11 +306,11 @@ fn attempt_login(
|
|||||||
*client_init = Some(ClientInit::new(
|
*client_init = Some(ClientInit::new(
|
||||||
(server_address, server_port, false),
|
(server_address, server_port, false),
|
||||||
username,
|
username,
|
||||||
Some(global_state.settings.graphics.view_distance),
|
Some(settings.graphics.view_distance),
|
||||||
password,
|
password,
|
||||||
));
|
));
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
global_state.info_message = Some("Invalid username".to_string());
|
*info_message = Some("Invalid username".to_string());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -26,10 +26,12 @@ pub struct Singleplayer {
|
|||||||
pub receiver: Receiver<Result<(), ServerError>>,
|
pub receiver: Receiver<Result<(), ServerError>>,
|
||||||
// Wether the server is stopped or not
|
// Wether the server is stopped or not
|
||||||
paused: Arc<AtomicBool>,
|
paused: Arc<AtomicBool>,
|
||||||
|
// Settings that the server was started with
|
||||||
|
settings: server::Settings,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Singleplayer {
|
impl Singleplayer {
|
||||||
pub fn new(client: Option<&Client>) -> (Self, server::Settings) {
|
pub fn new(client: Option<&Client>) -> Self {
|
||||||
let (sender, receiver) = unbounded();
|
let (sender, receiver) = unbounded();
|
||||||
|
|
||||||
// Determine folder to save server data in
|
// Determine folder to save server data in
|
||||||
@ -119,16 +121,17 @@ impl Singleplayer {
|
|||||||
run_server(server, receiver, paused1);
|
run_server(server, receiver, paused1);
|
||||||
});
|
});
|
||||||
|
|
||||||
(
|
|
||||||
Singleplayer {
|
Singleplayer {
|
||||||
_server_thread: thread,
|
_server_thread: thread,
|
||||||
sender,
|
sender,
|
||||||
receiver: result_receiver,
|
receiver: result_receiver,
|
||||||
paused,
|
paused,
|
||||||
},
|
|
||||||
settings,
|
settings,
|
||||||
)
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Returns reference to the settings the server was started with
|
||||||
|
pub fn settings(&self) -> &server::Settings { &self.settings }
|
||||||
|
|
||||||
/// Returns wether or not the server is paused
|
/// Returns wether or not the server is paused
|
||||||
pub fn is_paused(&self) -> bool { self.paused.load(Ordering::SeqCst) }
|
pub fn is_paused(&self) -> bool { self.paused.load(Ordering::SeqCst) }
|
||||||
|
Loading…
Reference in New Issue
Block a user