chore: debugging server refactoring with channels

This commit is contained in:
michel
2024-09-09 20:50:33 +02:00
committed by Michel de Graaf
parent d67ed4742a
commit 1461e385cf
4 changed files with 5 additions and 16 deletions
-1
View File
@@ -16,7 +16,6 @@ impl Client {
}
pub fn connect(&self) {
// Attempt to create a server instance
match Server::new(self.address.clone()) {
Ok(mut server) => {
println!(
+1 -4
View File
@@ -1,7 +1,4 @@
use crate::{
dispatcher::MessageHandler,
message::{factory::build_shared_folders_message, Message},
};
use crate::{dispatcher::MessageHandler, message::Message};
pub struct PrivilegedUsersHandler;
impl MessageHandler for PrivilegedUsersHandler {
+1 -10
View File
@@ -1,13 +1,4 @@
use std::{
collections::VecDeque,
sync::{Arc, Condvar, Mutex},
};
use crate::{
dispatcher::MessageHandler,
message::{factory::build_shared_folders_message, Message},
server::Room,
};
use crate::{dispatcher::MessageHandler, message::Message, server::Room};
pub struct RoomListHandler;
impl MessageHandler for RoomListHandler {
+3 -1
View File
@@ -1,6 +1,6 @@
use crate::dispatcher::MessageDispatcher;
use crate::message::factory::{build_init_message, build_login_message};
use crate::message::{MessageReader, MessageType};
use crate::message::MessageReader;
use std::collections::VecDeque;
use std::io::{self, Write};
use std::net::{TcpStream, ToSocketAddrs};
@@ -172,6 +172,8 @@ impl Server {
}
}
});
// introduce a channel , get rid of the thread ?
thread::spawn(move || {
write_barrier.wait();