From 849d827486c75b2ab223d7b0e638dbb5b74d4d1d Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@proton.me>
Date: Thu, 9 Nov 2023 11:38:19 +0300
Subject: rename crates

---
 karyons_p2p/src/net/connection_queue.rs | 52 ---------------------------------
 1 file changed, 52 deletions(-)
 delete mode 100644 karyons_p2p/src/net/connection_queue.rs

(limited to 'karyons_p2p/src/net/connection_queue.rs')

diff --git a/karyons_p2p/src/net/connection_queue.rs b/karyons_p2p/src/net/connection_queue.rs
deleted file mode 100644
index fbc4bfc..0000000
--- a/karyons_p2p/src/net/connection_queue.rs
+++ /dev/null
@@ -1,52 +0,0 @@
-use std::sync::Arc;
-
-use smol::{channel::Sender, lock::Mutex};
-
-use karyons_core::async_utils::CondVar;
-
-use karyons_net::Conn;
-
-use crate::net::ConnDirection;
-
-pub struct NewConn {
-    pub direction: ConnDirection,
-    pub conn: Conn,
-    pub disconnect_signal: Sender<()>,
-}
-
-/// Connection queue
-pub struct ConnQueue {
-    queue: Mutex<Vec<NewConn>>,
-    conn_available: CondVar,
-}
-
-impl ConnQueue {
-    pub fn new() -> Arc<Self> {
-        Arc::new(Self {
-            queue: Mutex::new(Vec::new()),
-            conn_available: CondVar::new(),
-        })
-    }
-
-    /// Push a connection into the queue and wait for the disconnect signal
-    pub async fn handle(&self, conn: Conn, direction: ConnDirection) {
-        let (disconnect_signal, chan) = smol::channel::bounded(1);
-        let new_conn = NewConn {
-            direction,
-            conn,
-            disconnect_signal,
-        };
-        self.queue.lock().await.push(new_conn);
-        self.conn_available.signal();
-        let _ = chan.recv().await;
-    }
-
-    /// Receive the next connection in the queue
-    pub async fn next(&self) -> NewConn {
-        let mut queue = self.queue.lock().await;
-        while queue.is_empty() {
-            queue = self.conn_available.wait(queue).await;
-        }
-        queue.pop().unwrap()
-    }
-}
-- 
cgit v1.2.3