aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/network
diff options
context:
space:
mode:
authorGustav Sörnäs <gustav@sornas.net>2021-04-10 17:12:39 +0200
committerGustav Sörnäs <gustav@sornas.net>2021-04-10 19:57:09 +0200
commitb6c4a90703def5fbd28e334f2c417c1b75627fd9 (patch)
tree1fee22875df927d926cf4c4860f358a32d2ae4c0 /mumd/src/network
parent7070a9b345afb62f0da5d083a416b46c1efae409 (diff)
downloadmum-b6c4a90703def5fbd28e334f2c417c1b75627fd9.tar.gz
remove unneeded rc
Diffstat (limited to 'mumd/src/network')
-rw-r--r--mumd/src/network/udp.rs8
1 files changed, 3 insertions, 5 deletions
diff --git a/mumd/src/network/udp.rs b/mumd/src/network/udp.rs
index cc085b5..94a1d11 100644
--- a/mumd/src/network/udp.rs
+++ b/mumd/src/network/udp.rs
@@ -3,6 +3,7 @@ use crate::network::ConnectionInfo;
use crate::state::{State, StatePhase};
use futures_util::{FutureExt, SinkExt, StreamExt};
+use futures_util::future::join4;
use futures_util::stream::{SplitSink, SplitStream, Stream};
use log::*;
use mumble_protocol::crypt::ClientCryptState;
@@ -12,16 +13,13 @@ use mumble_protocol::Serverbound;
use std::collections::HashMap;
use std::convert::TryFrom;
use std::net::{Ipv6Addr, SocketAddr};
-use std::rc::Rc;
-use std::sync::atomic::{AtomicU64, Ordering};
-use std::sync::{Arc, RwLock};
+use std::sync::{atomic::{AtomicU64, Ordering}, Arc, RwLock};
use tokio::{join, net::UdpSocket};
use tokio::sync::{mpsc, watch, Mutex};
use tokio::time::{interval, Duration};
use tokio_util::udp::UdpFramed;
use super::{run_until, VoiceStreamType};
-use futures_util::future::join4;
pub type PingRequest = (u64, SocketAddr, Box<dyn FnOnce(PongPacket)>);
@@ -228,7 +226,7 @@ pub async fn handle_pings(
.await
.expect("Failed to bind UDP socket");
- let pending = Rc::new(Mutex::new(HashMap::new()));
+ let pending = Mutex::new(HashMap::new());
let sender_handle = async {
while let Some((id, socket_addr, handle)) = ping_request_receiver.recv().await {