From 4ba54ccfca2ff8e56c58d0a652de256428282490 Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Sat, 18 Apr 2020 19:39:08 +0200 Subject: [PATCH] Reorder imports. Trying to separate: 1. Stuff for handling the swarm of nodes and generic table data replication 2. Stuff for the object store core application: metadata tables and block management 3. Stuff for the S3 API --- src/api_server.rs | 7 ++++--- src/block.rs | 1 + src/block_ref_table.rs | 3 ++- src/object_table.rs | 1 + src/rpc_client.rs | 4 ++-- src/server.rs | 10 ++++++---- src/version_table.rs | 3 ++- 7 files changed, 18 insertions(+), 11 deletions(-) diff --git a/src/api_server.rs b/src/api_server.rs index 14c58fc4..4070be6c 100644 --- a/src/api_server.rs +++ b/src/api_server.rs @@ -9,14 +9,15 @@ use hyper::server::conn::AddrStream; use hyper::service::{make_service_fn, service_fn}; use hyper::{Body, Method, Request, Response, Server, StatusCode}; -use crate::block::INLINE_THRESHOLD; -use crate::block_ref_table::*; use crate::data::*; use crate::error::Error; use crate::http_util::*; +use crate::table::EmptySortKey; + +use crate::block::INLINE_THRESHOLD; +use crate::block_ref_table::*; use crate::object_table::*; use crate::server::Garage; -use crate::table::EmptySortKey; use crate::version_table::*; type BodyType = Box + Send + Unpin>; diff --git a/src/block.rs b/src/block.rs index 60121ac5..d7daea01 100644 --- a/src/block.rs +++ b/src/block.rs @@ -16,6 +16,7 @@ use crate::error::Error; use crate::membership::System; use crate::rpc_client::*; use crate::rpc_server::*; + use crate::server::Garage; pub const INLINE_THRESHOLD: usize = 3072; diff --git a/src/block_ref_table.rs b/src/block_ref_table.rs index 5f6ce21b..17efa155 100644 --- a/src/block_ref_table.rs +++ b/src/block_ref_table.rs @@ -3,10 +3,11 @@ use serde::{Deserialize, Serialize}; use std::sync::Arc; use crate::background::*; -use crate::block::*; use crate::data::*; use crate::table::*; +use crate::block::*; + #[derive(PartialEq, Clone, Debug, Serialize, Deserialize)] pub struct BlockRef { // Primary key diff --git a/src/object_table.rs b/src/object_table.rs index a55af7db..82a64cd1 100644 --- a/src/object_table.rs +++ b/src/object_table.rs @@ -5,6 +5,7 @@ use std::sync::Arc; use crate::background::BackgroundRunner; use crate::data::*; use crate::table::*; + use crate::version_table::*; #[derive(PartialEq, Clone, Debug, Serialize, Deserialize)] diff --git a/src/rpc_client.rs b/src/rpc_client.rs index 6d26d86a..95288269 100644 --- a/src/rpc_client.rs +++ b/src/rpc_client.rs @@ -12,12 +12,12 @@ use hyper::client::{Client, HttpConnector}; use hyper::{Body, Method, Request, StatusCode}; use tokio::sync::watch; -use crate::background::*; +use crate::background::BackgroundRunner; use crate::data::*; use crate::error::Error; use crate::membership::Status; use crate::rpc_server::RpcMessage; -use crate::server::*; +use crate::server::TlsConfig; use crate::tls_util; pub struct RpcClient { diff --git a/src/server.rs b/src/server.rs index 099e087e..e728c667 100644 --- a/src/server.rs +++ b/src/server.rs @@ -8,18 +8,20 @@ pub use futures_util::future::FutureExt; use serde::Deserialize; use tokio::sync::watch; -use crate::api_server; use crate::background::*; -use crate::block::*; -use crate::block_ref_table::*; use crate::data::*; use crate::error::Error; use crate::membership::System; -use crate::object_table::*; use crate::rpc_server::RpcServer; use crate::table::*; + +use crate::block::*; +use crate::block_ref_table::*; +use crate::object_table::*; use crate::version_table::*; +use crate::api_server; + pub const DEFAULT_TIMEOUT: Duration = Duration::from_secs(10); #[derive(Deserialize, Debug, Clone)] diff --git a/src/version_table.rs b/src/version_table.rs index 62d6a702..7e7623fc 100644 --- a/src/version_table.rs +++ b/src/version_table.rs @@ -3,10 +3,11 @@ use serde::{Deserialize, Serialize}; use std::sync::Arc; use crate::background::BackgroundRunner; -use crate::block_ref_table::*; use crate::data::*; use crate::table::*; +use crate::block_ref_table::*; + #[derive(PartialEq, Clone, Debug, Serialize, Deserialize)] pub struct Version { // Primary key