Skip to content

Commit a622c85

Browse files
committed
random interval settings
1 parent 94131c1 commit a622c85

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

rasp/plugin/settings.toml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,8 @@ pid_queue_length = 1000
8585
pid_poll_interval = 60
8686
clean_up_interval = 60
8787
report_interval = 120
88+
report_interval_random_min = 1
89+
report_interval_random_min = 30
8890

8991
[eBPF]
9092
## DISABLE only using inline hook probe

rasp/plugin/src/monitor.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -304,16 +304,19 @@ fn internal_main(
304304
})?;
305305
let mut reporter_ctrl = ctrl.clone();
306306
let reporter_sender = internal_message_sender.clone();
307+
let reporter_interval = settings_int("internal", "report_interval").unwrap_or(600) as u64;
308+
let report_interval_random_min = settings_int("internal", "report_interval_random_min").unwrap_or(30) as u64;
309+
let report_interval_random_max = settings_int("internal", "report_interval_random_max").unwrap_or(30) as u64;
307310
let reporter_thread = Builder::new()
308311
.name("reporter".to_string())
309312
.spawn(move || loop {
310313
debug!("reporter thread looping");
311314
if !reporter_ctrl.check() {
312315
break;
313316
}
314-
sleep(Duration::from_secs(settings_int("internal", "report_interval").unwrap_or(120) as u64));
317+
sleep(Duration::from_secs(reporter_interval));
315318
let mut rng = rand::thread_rng();
316-
let random = rng.gen_range(1..30);
319+
let random = rng.gen_range(report_interval_random_min..report_interval_random_max);
317320
sleep(Duration::from_secs(random));
318321
let watched_process = report_process_r.read();
319322
let watched_process_cloned = watched_process.clone();

0 commit comments

Comments
 (0)