aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/main.rs
diff options
context:
space:
mode:
authorEskil Queseth <eskilq@kth.se>2020-10-21 01:53:38 +0200
committerEskil Queseth <eskilq@kth.se>2020-10-21 04:20:05 +0200
commit46a53f38cde86439a2ca8b6d24887f842530f679 (patch)
treeab820e232149ea437497aa1cdd3463dc244fcdff /mumd/src/main.rs
parent685eb0ebb072ce2f3da562e828a6ab89c2b0fa65 (diff)
downloadmum-46a53f38cde86439a2ca8b6d24887f842530f679.tar.gz
add tcp event system
Diffstat (limited to 'mumd/src/main.rs')
-rw-r--r--mumd/src/main.rs4
1 files changed, 3 insertions, 1 deletions
diff --git a/mumd/src/main.rs b/mumd/src/main.rs
index 75726f8..e88eede 100644
--- a/mumd/src/main.rs
+++ b/mumd/src/main.rs
@@ -33,6 +33,7 @@ async fn main() {
)>();
let (connection_info_sender, connection_info_receiver) =
watch::channel::<Option<ConnectionInfo>>(None);
+ let (response_sender, response_receiver) = mpsc::unbounded_channel();
let state = State::new(packet_sender, connection_info_sender);
let state = Arc::new(Mutex::new(state));
@@ -43,13 +44,14 @@ async fn main() {
connection_info_receiver.clone(),
crypt_state_sender,
packet_receiver,
+ response_receiver,
),
network::udp::handle(
Arc::clone(&state),
connection_info_receiver.clone(),
crypt_state_receiver,
),
- command::handle(state, command_receiver,),
+ command::handle(state, command_receiver, response_sender),
spawn_blocking(move || {
// IpcSender is blocking
receive_oneshot_commands(command_sender);