IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2024-11-28 02:43:48 -06:00
Code Issues Packages Projects Releases Wiki Activity

ISSUE #229 - Change "reload required" from a lock with a bool inside

Browse Source 
to a proper atomic bool, for a completely unnoticable performance
improvement.
This commit is contained in:
Herbert Wolverson 2023-02-14 20:37:09 +00:00
parent 1da10d7a23
commit c096226665
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/rust/lqos_node_manager/src/shaped_devices.rs
View File

@ -1,14 +1,15 @@
use std::sync::atomic::AtomicBool;
use crate::auth_guard::AuthGuard; use crate::auth_guard::AuthGuard;
use crate::cache_control::NoCache; use crate::cache_control::NoCache;
use crate::tracker::SHAPED_DEVICES; use crate::tracker::SHAPED_DEVICES;
use lazy_static::*; use lazy_static::*;
use lqos_bus::{bus_request, BusRequest, BusResponse}; use lqos_bus::{bus_request, BusRequest, BusResponse};
use lqos_config::ShapedDevice; use lqos_config::ShapedDevice;
use parking_lot::RwLock;
use rocket::serde::json::Json; use rocket::serde::json::Json;
lazy_static! { lazy_static! {
static ref RELOAD_REQUIRED: RwLock<bool> = RwLock::new(false); static ref RELOAD_REQUIRED: AtomicBool = AtomicBool::new(false);
} }
#[get("/api/all_shaped_devices")] #[get("/api/all_shaped_devices")]
@ -56,7 +57,7 @@ pub fn shaped_devices_search(
#[get("/api/reload_required")] #[get("/api/reload_required")]
pub fn reload_required() -> NoCache<Json<bool>> { pub fn reload_required() -> NoCache<Json<bool>> {
NoCache::new(Json(*RELOAD_REQUIRED.read())) NoCache::new(Json(RELOAD_REQUIRED.load(std::sync::atomic::Ordering::Relaxed)))
} }
#[get("/api/reload_libreqos")] #[get("/api/reload_libreqos")]
@ -72,6 +73,6 @@ pub async fn reload_libreqos(auth: AuthGuard) -> NoCache<Json<String>> {
_ => "Unable to reload LibreQoS".to_string(), _ => "Unable to reload LibreQoS".to_string(),
}; };
*RELOAD_REQUIRED.write() = false; RELOAD_REQUIRED.store(false, std::sync::atomic::Ordering::Relaxed);
NoCache::new(Json(result)) NoCache::new(Json(result))
} }