mirror of
https://github.com/YGGverse/aquatic.git
synced 2026-03-31 17:55:36 +00:00
aquatic_udp: mio: update access list on SIGHUP instead of regularly
This commit is contained in:
parent
e332ac3052
commit
d922e5e680
5 changed files with 92 additions and 46 deletions
21
Cargo.lock
generated
21
Cargo.lock
generated
|
|
@ -79,6 +79,7 @@ dependencies = [
|
||||||
"hashbrown 0.11.2",
|
"hashbrown 0.11.2",
|
||||||
"hex",
|
"hex",
|
||||||
"indexmap",
|
"indexmap",
|
||||||
|
"log",
|
||||||
"privdrop",
|
"privdrop",
|
||||||
"rand",
|
"rand",
|
||||||
"serde",
|
"serde",
|
||||||
|
|
@ -181,6 +182,7 @@ dependencies = [
|
||||||
"quickcheck_macros",
|
"quickcheck_macros",
|
||||||
"rand",
|
"rand",
|
||||||
"serde",
|
"serde",
|
||||||
|
"signal-hook",
|
||||||
"socket2 0.4.2",
|
"socket2 0.4.2",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
@ -1754,6 +1756,25 @@ dependencies = [
|
||||||
"opaque-debug",
|
"opaque-debug",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "signal-hook"
|
||||||
|
version = "0.3.10"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "9c98891d737e271a2954825ef19e46bd16bdb98e2746f2eec4f7a4ef7946efd1"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
"signal-hook-registry",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "signal-hook-registry"
|
||||||
|
version = "1.4.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "e51e73328dc4ac0c7ccbda3a494dfa03df1de2f46018127f60c693f2648455b0"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "simd-json"
|
name = "simd-json"
|
||||||
version = "0.4.8"
|
version = "0.4.8"
|
||||||
|
|
|
||||||
|
|
@ -16,6 +16,7 @@ arc-swap = "1"
|
||||||
hashbrown = "0.11.2"
|
hashbrown = "0.11.2"
|
||||||
hex = "0.4"
|
hex = "0.4"
|
||||||
indexmap = "1"
|
indexmap = "1"
|
||||||
|
log = "0.4"
|
||||||
privdrop = "0.5"
|
privdrop = "0.5"
|
||||||
rand = { version = "0.8", features = ["small_rng"] }
|
rand = { version = "0.8", features = ["small_rng"] }
|
||||||
serde = { version = "1", features = ["derive"] }
|
serde = { version = "1", features = ["derive"] }
|
||||||
|
|
|
||||||
|
|
@ -75,17 +75,31 @@ impl AccessList {
|
||||||
}
|
}
|
||||||
|
|
||||||
pub trait AccessListQuery {
|
pub trait AccessListQuery {
|
||||||
fn update_from_path(&self, path: &PathBuf) -> anyhow::Result<()>;
|
fn update(&self, config: &AccessListConfig);
|
||||||
fn allows(&self, list_mode: AccessListMode, info_hash_bytes: &[u8; 20]) -> bool;
|
fn allows(&self, list_mode: AccessListMode, info_hash_bytes: &[u8; 20]) -> bool;
|
||||||
}
|
}
|
||||||
|
|
||||||
pub type AccessListArcSwap = ArcSwap<AccessList>;
|
pub type AccessListArcSwap = ArcSwap<AccessList>;
|
||||||
|
|
||||||
impl AccessListQuery for AccessListArcSwap {
|
impl AccessListQuery for AccessListArcSwap {
|
||||||
fn update_from_path(&self, path: &PathBuf) -> anyhow::Result<()> {
|
fn update(&self, config: &AccessListConfig) {
|
||||||
self.store(Arc::new(AccessList::create_from_path(path)?));
|
match config.mode {
|
||||||
|
AccessListMode::White | AccessListMode::Black => {
|
||||||
Ok(())
|
match AccessList::create_from_path(&config.path) {
|
||||||
|
Ok(new) => {
|
||||||
|
self.store(Arc::new(new));
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
::log::error!("Updating access list failed: {:?}", err);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
AccessListMode::Off => {
|
||||||
|
::log::error!(
|
||||||
|
"AccessListQuery::update_from_path called, but AccessListMode is Off"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn allows(&self, mode: AccessListMode, info_hash_bytes: &[u8; 20]) -> bool {
|
fn allows(&self, mode: AccessListMode, info_hash_bytes: &[u8; 20]) -> bool {
|
||||||
|
|
|
||||||
|
|
@ -34,6 +34,7 @@ mimalloc = { version = "0.1", default-features = false }
|
||||||
parking_lot = "0.11"
|
parking_lot = "0.11"
|
||||||
rand = { version = "0.8", features = ["small_rng"] }
|
rand = { version = "0.8", features = ["small_rng"] }
|
||||||
serde = { version = "1", features = ["derive"] }
|
serde = { version = "1", features = ["derive"] }
|
||||||
|
signal-hook = { version = "0.3" }
|
||||||
|
|
||||||
# mio
|
# mio
|
||||||
crossbeam-channel = { version = "0.5", optional = true }
|
crossbeam-channel = { version = "0.5", optional = true }
|
||||||
|
|
|
||||||
|
|
@ -9,15 +9,17 @@ use anyhow::Context;
|
||||||
use aquatic_common::privileges::drop_privileges_after_socket_binding;
|
use aquatic_common::privileges::drop_privileges_after_socket_binding;
|
||||||
use crossbeam_channel::unbounded;
|
use crossbeam_channel::unbounded;
|
||||||
|
|
||||||
|
use aquatic_common::access_list::AccessListQuery;
|
||||||
|
use signal_hook::consts::SIGHUP;
|
||||||
|
use signal_hook::iterator::Signals;
|
||||||
|
|
||||||
|
use crate::config::Config;
|
||||||
|
|
||||||
pub mod common;
|
pub mod common;
|
||||||
pub mod handlers;
|
pub mod handlers;
|
||||||
pub mod network;
|
pub mod network;
|
||||||
pub mod tasks;
|
pub mod tasks;
|
||||||
|
|
||||||
use aquatic_common::access_list::{AccessListArcSwap, AccessListMode, AccessListQuery};
|
|
||||||
|
|
||||||
use crate::config::Config;
|
|
||||||
|
|
||||||
use common::State;
|
use common::State;
|
||||||
|
|
||||||
pub fn run(config: Config) -> ::anyhow::Result<()> {
|
pub fn run(config: Config) -> ::anyhow::Result<()> {
|
||||||
|
|
@ -27,38 +29,42 @@ pub fn run(config: Config) -> ::anyhow::Result<()> {
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
let mut signals = Signals::new(::std::iter::once(SIGHUP))?;
|
||||||
|
|
||||||
let state = State::default();
|
let state = State::default();
|
||||||
|
|
||||||
update_access_list(&config, &state.access_list);
|
{
|
||||||
|
let config = config.clone();
|
||||||
|
let state = state.clone();
|
||||||
|
|
||||||
|
::std::thread::spawn(move || run_inner(config, state));
|
||||||
|
}
|
||||||
|
|
||||||
|
for signal in &mut signals {
|
||||||
|
match signal {
|
||||||
|
SIGHUP => {
|
||||||
|
::log::info!("Updating access list");
|
||||||
|
|
||||||
|
state.access_list.update(&config.access_list);
|
||||||
|
}
|
||||||
|
_ => unreachable!(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn run_inner(config: Config, state: State) -> ::anyhow::Result<()> {
|
||||||
|
if config.cpu_pinning.active {
|
||||||
|
core_affinity::set_for_current(core_affinity::CoreId {
|
||||||
|
id: config.cpu_pinning.offset,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
state.access_list.update(&config.access_list);
|
||||||
|
|
||||||
let num_bound_sockets = Arc::new(AtomicUsize::new(0));
|
let num_bound_sockets = Arc::new(AtomicUsize::new(0));
|
||||||
|
|
||||||
start_workers(config.clone(), state.clone(), num_bound_sockets.clone())?;
|
|
||||||
|
|
||||||
drop_privileges_after_socket_binding(
|
|
||||||
&config.privileges,
|
|
||||||
num_bound_sockets,
|
|
||||||
config.socket_workers,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
loop {
|
|
||||||
::std::thread::sleep(Duration::from_secs(config.cleaning.interval));
|
|
||||||
|
|
||||||
update_access_list(&config, &state.access_list);
|
|
||||||
|
|
||||||
state
|
|
||||||
.torrents
|
|
||||||
.lock()
|
|
||||||
.clean(&config, state.access_list.load_full().deref());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn start_workers(
|
|
||||||
config: Config,
|
|
||||||
state: State,
|
|
||||||
num_bound_sockets: Arc<AtomicUsize>,
|
|
||||||
) -> ::anyhow::Result<()> {
|
|
||||||
let (request_sender, request_receiver) = unbounded();
|
let (request_sender, request_receiver) = unbounded();
|
||||||
let (response_sender, response_receiver) = unbounded();
|
let (response_sender, response_receiver) = unbounded();
|
||||||
|
|
||||||
|
|
@ -132,16 +138,19 @@ pub fn start_workers(
|
||||||
.with_context(|| "spawn statistics worker")?;
|
.with_context(|| "spawn statistics worker")?;
|
||||||
}
|
}
|
||||||
|
|
||||||
Ok(())
|
drop_privileges_after_socket_binding(
|
||||||
}
|
&config.privileges,
|
||||||
|
num_bound_sockets,
|
||||||
|
config.socket_workers,
|
||||||
|
)
|
||||||
|
.unwrap();
|
||||||
|
|
||||||
pub fn update_access_list(config: &Config, access_list: &Arc<AccessListArcSwap>) {
|
loop {
|
||||||
match config.access_list.mode {
|
::std::thread::sleep(Duration::from_secs(config.cleaning.interval));
|
||||||
AccessListMode::White | AccessListMode::Black => {
|
|
||||||
if let Err(err) = access_list.update_from_path(&config.access_list.path) {
|
state
|
||||||
::log::error!("Update access list from path: {:?}", err);
|
.torrents
|
||||||
}
|
.lock()
|
||||||
}
|
.clean(&config, state.access_list.load_full().deref());
|
||||||
AccessListMode::Off => {}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue