fix: correct listening port

This commit is contained in:
Michel de Graaf
2025-11-02 19:57:56 +01:00
parent 7958fe9a29
commit a9d0101a58
2 changed files with 30 additions and 26 deletions
+26 -25
View File
@@ -120,33 +120,34 @@ impl Client {
let client_sender = sender.clone();
self.server = match Server::new(self.address.clone(), sender) {
Ok(server) => {
info!(
"Connected to server at {}:{}",
server.get_address().get_host(),
server.get_address().get_port()
);
self.server =
match Server::new(self.address.clone(), sender, self.listen_port) {
Ok(server) => {
info!(
"Connected to server at {}:{}",
server.get_address().get_host(),
server.get_address().get_port()
);
thread::spawn(move || {
Listen::start(listen_port, client_sender.clone());
});
let mut unlocked_context = self.context.write().unwrap();
unlocked_context.server_sender =
Some(server.get_sender().clone());
thread::spawn(move || {
Listen::start(listen_port, client_sender.clone());
});
let mut unlocked_context = self.context.write().unwrap();
unlocked_context.server_sender =
Some(server.get_sender().clone());
Self::listen_to_client_operations(
message_reader,
self.context.clone(),
self.username.clone(),
);
Some(server)
}
Err(e) => {
error!("Error connecting to server: {}", e);
None
}
};
Self::listen_to_client_operations(
message_reader,
self.context.clone(),
self.username.clone(),
);
Some(server)
}
Err(e) => {
error!("Error connecting to server: {}", e);
None
}
};
}
pub fn login(&self) -> Result<bool> {
+4 -1
View File
@@ -194,11 +194,13 @@ pub struct Server {
address: PeerAddress,
sender: Sender<ServerOperation>,
context: Arc<RwLock<Context>>,
listen_port: u32,
}
impl Server {
pub fn new(
address: PeerAddress,
client_channel: Sender<ClientOperation>,
listen_port: u32,
) -> std::result::Result<Self, io::Error> {
let (sender, server_channel): (
Sender<ServerOperation>,
@@ -211,6 +213,7 @@ impl Server {
address,
context,
sender,
listen_port,
};
server.start_read_write_loops(server_channel, client_channel)?;
@@ -473,7 +476,7 @@ impl Server {
self.queue_message(MessageFactory::build_no_parent_message());
self.queue_message(MessageFactory::build_set_status_message(2));
self.queue_message(MessageFactory::build_set_wait_port_message(
2235,
self.listen_port,
));
}