From e28a9274d089b45f2aec4852cf6de1e0d0ec6694 Mon Sep 17 00:00:00 2001
From: Mathias Hall-Andersen <mathias@hall-andersen.dk>
Date: Tue, 27 Aug 2019 11:37:20 +0200
Subject: Removed unused sub-module

---
 src/router/inbound.rs | 52 ---------------------------------------------------
 1 file changed, 52 deletions(-)
 delete mode 100644 src/router/inbound.rs

(limited to 'src/router')

diff --git a/src/router/inbound.rs b/src/router/inbound.rs
deleted file mode 100644
index eba63c4..0000000
--- a/src/router/inbound.rs
+++ /dev/null
@@ -1,52 +0,0 @@
-use std::thread;
-use spin;
-use lifeguard::Recycled;
-use super::anti_replay::AntiReplay;
-use std::sync::mpsc::{Receiver, sync_channel};
-use std::sync::Arc;
-
-struct ParallelJobInner {
-    done : bool,
-    msg  : Vec<u8>,
-    key  : [u8; 32]
-}
-
-type ParallelJob = spin::Mutex<ParallelJobInner>;
-
-struct InboundInorder {
-    job : Arc<ParallelJob>,
-    state : Arc<KeyState>,
-}
-
-struct Inorder<'a> (Arc<spin::Mutex<Option<Job<'a>>>>);
-
-struct Job<'a> {
-    msg : Recycled<'a, Vec<u8>>,
-    arp : Arc<KeyState>,                    // replay protector and key-pair
-    key : Option<(Arc<Peer>, Arc<KeyPair>)> // provided if the key has not been confirmed
-}
-
-fn worker_inorder<'a>(channel : Receiver<Inorder<'a>>) {
-    let mut current = 0;
-
-    // reads from inorder channel
-    for ordered in channel.recv().iter() {
-        
-        loop {
-            // check if job is complete
-            match ordered.0.try_lock() {
-                None => (),
-                Some(guard) => if let Some(job) = *guard {
-                    if job.arp.lock().update(6) {
-                        // write to output
-
-                        break;
-                    }
-                }
-            }
-
-            // wait for job to complete
-            thread::park();
-        }
-    }
-}
\ No newline at end of file
-- 
cgit v1.2.3-59-g8ed1b