fixed clippy error
This commit is contained in:
@@ -20,7 +20,7 @@ use hashbrown;
|
|||||||
use hashbrown::HashMap;
|
use hashbrown::HashMap;
|
||||||
use serde_json::Value;
|
use serde_json::Value;
|
||||||
use std::fmt::Write;
|
use std::fmt::Write;
|
||||||
use std::path::PathBuf;
|
use std::path::Path;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use tokio::{runtime::Runtime, spawn, task::JoinHandle};
|
use tokio::{runtime::Runtime, spawn, task::JoinHandle};
|
||||||
|
|
||||||
|
|||||||
@@ -185,8 +185,9 @@ pub fn get_event_value<'a>(key: &str, event_value: &'a Value) -> Option<&'a Valu
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub fn get_thread_num() -> usize {
|
pub fn get_thread_num() -> usize {
|
||||||
|
let cpu_num = num_cpus::get();
|
||||||
let conf = configs::CONFIG.read().unwrap();
|
let conf = configs::CONFIG.read().unwrap();
|
||||||
conf.args.thread_number.unwrap_or_else(num_cpus::get())
|
conf.args.thread_number.unwrap_or(cpu_num)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn create_tokio_runtime() -> Runtime {
|
pub fn create_tokio_runtime() -> Runtime {
|
||||||
|
|||||||
Reference in New Issue
Block a user