diff options
| author | Eskil Queseth <eskilq@kth.se> | 2020-10-21 01:53:38 +0200 |
|---|---|---|
| committer | Eskil Queseth <eskilq@kth.se> | 2020-10-21 04:20:05 +0200 |
| commit | 46a53f38cde86439a2ca8b6d24887f842530f679 (patch) | |
| tree | ab820e232149ea437497aa1cdd3463dc244fcdff /mumd/src/main.rs | |
| parent | 685eb0ebb072ce2f3da562e828a6ab89c2b0fa65 (diff) | |
| download | mum-46a53f38cde86439a2ca8b6d24887f842530f679.tar.gz | |
add tcp event system
Diffstat (limited to 'mumd/src/main.rs')
| -rw-r--r-- | mumd/src/main.rs | 4 |
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); |
