diff options
| author | Rubens Brandao <git@rubens.io> | 2021-04-09 20:02:51 +0200 |
|---|---|---|
| committer | Rubens Brandao <git@rubens.io> | 2021-04-09 20:02:51 +0200 |
| commit | 14b0ce912735243e566a95838e9ed0c93a2e7f3e (patch) | |
| tree | a51f0d74230bad33d183deb7e5eaeee34c13d941 /mumd/src/network | |
| parent | a39934e562fd2755fcb7b1ed271bcf3f31aaa0d5 (diff) | |
| download | mum-14b0ce912735243e566a95838e9ed0c93a2e7f3e.tar.gz | |
Resolved merge upstream conflicts
Diffstat (limited to 'mumd/src/network')
| -rw-r--r-- | mumd/src/network/udp.rs | 14 |
1 files changed, 2 insertions, 12 deletions
diff --git a/mumd/src/network/udp.rs b/mumd/src/network/udp.rs index f24d4b4..11a3f27 100644 --- a/mumd/src/network/udp.rs +++ b/mumd/src/network/udp.rs @@ -33,11 +33,7 @@ pub async fn handle( mut connection_info_receiver: watch::Receiver<Option<ConnectionInfo>>, mut crypt_state_receiver: mpsc::Receiver<ClientCryptState>, ) -> Result<(), UdpError> { -<<<<<<< HEAD - let receiver = state.lock().await.audio_input().receiver(); -======= - let receiver = state.read().unwrap().audio().input_receiver(); ->>>>>>> 48f0d38 (Replace State tokio::sync::Mutex by std::sync::RwLock) + let receiver = state.read().unwrap().audio_input().receiver(); loop { let connection_info = 'data: loop { @@ -153,15 +149,9 @@ async fn listen( .. } => { state -<<<<<<< HEAD - .lock() //TODO change so that we only have to lock audio and not the whole state - .await - .audio_output() -======= .read() .unwrap() - .audio() ->>>>>>> 48f0d38 (Replace State tokio::sync::Mutex by std::sync::RwLock) + .audio_output() .decode_packet_payload(VoiceStreamType::UDP, session_id, payload); } } |
