From 5d91ead06c62fd7c3cd846659b935012616ce5ae Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@proton.me>
Date: Sun, 12 Nov 2023 11:26:38 +0300
Subject: p2p: remove net directory

---
 p2p/src/net/slots.rs | 54 ----------------------------------------------------
 1 file changed, 54 deletions(-)
 delete mode 100644 p2p/src/net/slots.rs

(limited to 'p2p/src/net/slots.rs')

diff --git a/p2p/src/net/slots.rs b/p2p/src/net/slots.rs
deleted file mode 100644
index 99f0a78..0000000
--- a/p2p/src/net/slots.rs
+++ /dev/null
@@ -1,54 +0,0 @@
-use std::sync::atomic::{AtomicUsize, Ordering};
-
-use karyons_core::async_utils::CondWait;
-
-/// Manages available inbound and outbound slots.
-pub struct ConnectionSlots {
-    /// A condvar for notifying when a slot become available.
-    signal: CondWait,
-    /// The number of occupied slots
-    slots: AtomicUsize,
-    /// The maximum number of slots.
-    max_slots: usize,
-}
-
-impl ConnectionSlots {
-    /// Creates a new ConnectionSlots
-    pub fn new(max_slots: usize) -> Self {
-        Self {
-            signal: CondWait::new(),
-            slots: AtomicUsize::new(0),
-            max_slots,
-        }
-    }
-
-    /// Returns the number of occupied slots
-    pub fn load(&self) -> usize {
-        self.slots.load(Ordering::SeqCst)
-    }
-
-    /// Increases the occupied slots by one.
-    pub fn add(&self) {
-        self.slots.fetch_add(1, Ordering::SeqCst);
-    }
-
-    /// Decreases the occupied slots by one and notifies the waiting signal
-    /// to start accepting/connecting new connections.
-    pub async fn remove(&self) {
-        self.slots.fetch_sub(1, Ordering::SeqCst);
-        if self.slots.load(Ordering::SeqCst) < self.max_slots {
-            self.signal.signal().await;
-        }
-    }
-
-    /// Waits for a slot to become available.
-    pub async fn wait_for_slot(&self) {
-        if self.slots.load(Ordering::SeqCst) < self.max_slots {
-            return;
-        }
-
-        // Wait for a signal
-        self.signal.wait().await;
-        self.signal.reset().await;
-    }
-}
-- 
cgit v1.2.3