From 1e77745a84c399c2256ceff450d7f6a3cf41026b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Sat, 27 Nov 2021 18:26:57 +0100
Subject: [PATCH] http: move network.rs and handlers.rs to new workers dir,
 rename

---
 aquatic_http/src/lib.rs                              | 7 +++----
 aquatic_http/src/workers/mod.rs                      | 2 ++
 aquatic_http/src/{handlers.rs => workers/request.rs} | 0
 aquatic_http/src/{network.rs => workers/socket.rs}   | 4 +---
 4 files changed, 6 insertions(+), 7 deletions(-)
 create mode 100644 aquatic_http/src/workers/mod.rs
 rename aquatic_http/src/{handlers.rs => workers/request.rs} (100%)
 rename aquatic_http/src/{network.rs => workers/socket.rs} (99%)

diff --git a/aquatic_http/src/lib.rs b/aquatic_http/src/lib.rs
index 48ade1c..54ed266 100644
--- a/aquatic_http/src/lib.rs
+++ b/aquatic_http/src/lib.rs
@@ -15,9 +15,8 @@ use std::{
 use crate::config::Config;
 
 mod common;
+mod workers;
 pub mod config;
-mod handlers;
-mod network;
 
 pub const APP_NAME: &str = "aquatic_http: HTTP/TLS BitTorrent tracker";
 
@@ -86,7 +85,7 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> {
                 WorkerIndex::SocketWorker(i),
             );
 
-            network::run_socket_worker(
+            workers::socket::run_socket_worker(
                 config,
                 state,
                 tls_config,
@@ -116,7 +115,7 @@ pub fn run_inner(config: Config, state: State) -> anyhow::Result<()> {
                 WorkerIndex::RequestWorker(i),
             );
 
-            handlers::run_request_worker(config, state, request_mesh_builder, response_mesh_builder)
+            workers::request::run_request_worker(config, state, request_mesh_builder, response_mesh_builder)
                 .await
         });
 
diff --git a/aquatic_http/src/workers/mod.rs b/aquatic_http/src/workers/mod.rs
new file mode 100644
index 0000000..5f41ab1
--- /dev/null
+++ b/aquatic_http/src/workers/mod.rs
@@ -0,0 +1,2 @@
+pub mod request;
+pub mod socket;
\ No newline at end of file
diff --git a/aquatic_http/src/handlers.rs b/aquatic_http/src/workers/request.rs
similarity index 100%
rename from aquatic_http/src/handlers.rs
rename to aquatic_http/src/workers/request.rs
diff --git a/aquatic_http/src/network.rs b/aquatic_http/src/workers/socket.rs
similarity index 99%
rename from aquatic_http/src/network.rs
rename to aquatic_http/src/workers/socket.rs
index 51ed339..a3fb70b 100644
--- a/aquatic_http/src/network.rs
+++ b/aquatic_http/src/workers/socket.rs
@@ -24,11 +24,9 @@ use glommio::timer::TimerActionRepeat;
 use glommio::{enclose, prelude::*};
 use slab::Slab;
 
-use crate::common::num_digits_in_usize;
+use crate::common::*;
 use crate::config::Config;
 
-use super::common::*;
-
 const INTERMEDIATE_BUFFER_SIZE: usize = 1024;
 const MAX_REQUEST_SIZE: usize = 2048;