aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/network
diff options
context:
space:
mode:
authorRubens Brandao <git@rubens.io>2021-04-09 20:02:51 +0200
committerRubens Brandao <git@rubens.io>2021-04-09 20:02:51 +0200
commit14b0ce912735243e566a95838e9ed0c93a2e7f3e (patch)
treea51f0d74230bad33d183deb7e5eaeee34c13d941 /mumd/src/network
parenta39934e562fd2755fcb7b1ed271bcf3f31aaa0d5 (diff)
downloadmum-14b0ce912735243e566a95838e9ed0c93a2e7f3e.tar.gz
Resolved merge upstream conflicts
Diffstat (limited to 'mumd/src/network')
-rw-r--r--mumd/src/network/udp.rs14
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);
}
}