diff options
| author | Eskil Queseth <eskilq@kth.se> | 2021-05-21 14:53:58 +0200 |
|---|---|---|
| committer | Eskil Queseth <eskilq@kth.se> | 2021-05-21 14:53:58 +0200 |
| commit | d6779ca065a896d329a7634d69a5f4270d829b73 (patch) | |
| tree | 505cd0eef7a4981e44c06a7fc45062ce2b4e9b15 /mumd/src/command.rs | |
| parent | 5d05d292ddb7f8b28b71abd46930028b6e66dfde (diff) | |
| download | mum-d6779ca065a896d329a7634d69a5f4270d829b73.tar.gz | |
rework event system to allow multiple triggers
Diffstat (limited to 'mumd/src/command.rs')
| -rw-r--r-- | mumd/src/command.rs | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/mumd/src/command.rs b/mumd/src/command.rs index a1e8b21..f02ad19 100644 --- a/mumd/src/command.rs +++ b/mumd/src/command.rs @@ -22,9 +22,7 @@ pub async fn handle( let ping_count = AtomicU64::new(0); while let Some((command, mut response_sender)) = command_receiver.recv().await { debug!("Received command {:?}", command); - let mut state = state.write().unwrap(); - let event = state.handle_command(command, &mut packet_sender, &mut connection_info_sender); - drop(state); + let event = crate::state::handle_command(Arc::clone(&state), command, &mut packet_sender, &mut connection_info_sender); match event { ExecutionContext::TcpEventCallback(event, generator) => { tcp_event_queue.register_callback( |