]> git.proxmox.com Git - proxmox-backup.git/blame - src/bin/proxmox-backup-proxy.rs
proxy: move prune logic into new file
[proxmox-backup.git] / src / bin / proxmox-backup-proxy.rs
CommitLineData
c040ec22 1use std::sync::{Arc};
2ab5acac 2use std::path::{Path, PathBuf};
97168f92 3use std::os::unix::io::AsRawFd;
a2479cfa 4
f7d4e4b5 5use anyhow::{bail, format_err, Error};
a2479cfa
WB
6use futures::*;
7use hyper;
8use openssl::ssl::{SslMethod, SslAcceptor, SslFiletype};
9
9ea4bce4 10use proxmox::try_block;
a2479cfa
WB
11use proxmox::api::RpcEnvironmentType;
12
1298618a
DM
13use proxmox_backup::{
14 backup::DataStore,
15 server::{
16 UPID,
17 WorkerTask,
18 ApiConfig,
19 rest::*,
20 jobstate::{
21 self,
22 Job,
23 },
24 rotate_task_log_archive,
25 },
26 tools::systemd::time::{
27 parse_calendar_event,
28 compute_next_event,
29 },
30};
31
32
e6dc35ac 33use proxmox_backup::api2::types::{Authid, Userid};
a2ca7137 34use proxmox_backup::configdir;
4a7de56e 35use proxmox_backup::buildcfg;
e3f41f21 36use proxmox_backup::server;
d01e2420 37use proxmox_backup::auth_helpers::*;
97168f92 38use proxmox_backup::tools::{
e4f5f59e 39 daemon,
97168f92
DM
40 disks::{
41 DiskManage,
42 zfs_pool_stats,
43 },
44 socket::{
45 set_tcp_keepalive,
46 PROXMOX_BACKUP_TCP_KEEPALIVE_TIME,
47 },
48};
02c7a755 49
a13573c2 50use proxmox_backup::api2::pull::do_sync_job;
1298618a 51use proxmox_backup::server::do_verification_job;
b8d90798 52use proxmox_backup::server::do_prune_job;
a13573c2 53
946c3e8a 54fn main() -> Result<(), Error> {
ac7513e3
DM
55 proxmox_backup::tools::setup_safe_path_env();
56
843880f0
TL
57 let backup_uid = proxmox_backup::backup::backup_user()?.uid;
58 let backup_gid = proxmox_backup::backup::backup_group()?.gid;
59 let running_uid = nix::unistd::Uid::effective();
60 let running_gid = nix::unistd::Gid::effective();
61
62 if running_uid != backup_uid || running_gid != backup_gid {
63 bail!("proxy not running as backup user or group (got uid {} gid {})", running_uid, running_gid);
64 }
65
946c3e8a 66 proxmox_backup::tools::runtime::main(run())
4223d9f8
DM
67}
68
fda5797b 69async fn run() -> Result<(), Error> {
02c7a755
DM
70 if let Err(err) = syslog::init(
71 syslog::Facility::LOG_DAEMON,
72 log::LevelFilter::Info,
73 Some("proxmox-backup-proxy")) {
4223d9f8 74 bail!("unable to inititialize syslog - {}", err);
02c7a755
DM
75 }
76
d01e2420
DM
77 let _ = public_auth_key(); // load with lazy_static
78 let _ = csrf_secret(); // load with lazy_static
79
02c7a755 80 let mut config = ApiConfig::new(
f9e3b110 81 buildcfg::JS_DIR, &proxmox_backup::api2::ROUTER, RpcEnvironmentType::PUBLIC)?;
02c7a755 82
02c7a755
DM
83 config.add_alias("novnc", "/usr/share/novnc-pve");
84 config.add_alias("extjs", "/usr/share/javascript/extjs");
85 config.add_alias("fontawesome", "/usr/share/fonts-font-awesome");
86 config.add_alias("xtermjs", "/usr/share/pve-xtermjs");
abd4c4cb 87 config.add_alias("locale", "/usr/share/pbs-i18n");
02c7a755 88 config.add_alias("widgettoolkit", "/usr/share/javascript/proxmox-widget-toolkit");
2d694f8f 89 config.add_alias("css", "/usr/share/javascript/proxmox-backup/css");
9c01e73c 90 config.add_alias("docs", "/usr/share/doc/proxmox-backup/html");
02c7a755 91
2ab5acac
DC
92 let mut indexpath = PathBuf::from(buildcfg::JS_DIR);
93 indexpath.push("index.hbs");
94 config.register_template("index", &indexpath)?;
01ca99da 95 config.register_template("console", "/usr/share/pve-xtermjs/index.html.hbs")?;
2ab5acac 96
8e7e2223
TL
97 config.enable_file_log(buildcfg::API_ACCESS_LOG_FN)?;
98
02c7a755
DM
99 let rest_server = RestServer::new(config);
100
6d1f61b2
DM
101 //openssl req -x509 -newkey rsa:4096 -keyout /etc/proxmox-backup/proxy.key -out /etc/proxmox-backup/proxy.pem -nodes
102 let key_path = configdir!("/proxy.key");
103 let cert_path = configdir!("/proxy.pem");
104
62c74d77 105 let mut acceptor = SslAcceptor::mozilla_intermediate_v5(SslMethod::tls()).unwrap();
6d1f61b2
DM
106 acceptor.set_private_key_file(key_path, SslFiletype::PEM)
107 .map_err(|err| format_err!("unable to read proxy key {} - {}", key_path, err))?;
108 acceptor.set_certificate_chain_file(cert_path)
109 .map_err(|err| format_err!("unable to read proxy cert {} - {}", cert_path, err))?;
110 acceptor.check_private_key().unwrap();
111
112 let acceptor = Arc::new(acceptor.build());
0d176f36 113
a690ecac
WB
114 let server = daemon::create_daemon(
115 ([0,0,0,0,0,0,0,0], 8007).into(),
083ff3fd 116 |listener, ready| {
db0cb9ce 117 let connections = proxmox_backup::tools::async_io::StaticIncoming::from(listener)
a690ecac 118 .map_err(Error::from)
db0cb9ce 119 .try_filter_map(move |(sock, _addr)| {
fda5797b
WB
120 let acceptor = Arc::clone(&acceptor);
121 async move {
122 sock.set_nodelay(true).unwrap();
97168f92
DM
123
124 let _ = set_tcp_keepalive(sock.as_raw_fd(), PROXMOX_BACKUP_TCP_KEEPALIVE_TIME);
125
fda5797b
WB
126 Ok(tokio_openssl::accept(&acceptor, sock)
127 .await
128 .ok() // handshake errors aren't be fatal, so return None to filter
129 )
a690ecac 130 }
a690ecac 131 });
db0cb9ce 132 let connections = proxmox_backup::tools::async_io::HyperAccept(connections);
083ff3fd
WB
133
134 Ok(ready
135 .and_then(|_| hyper::Server::builder(connections)
136 .serve(rest_server)
137 .with_graceful_shutdown(server::shutdown_future())
138 .map_err(Error::from)
139 )
140 .map_err(|err| eprintln!("server error: {}", err))
141 .map(|_| ())
a690ecac 142 )
a2ca7137 143 },
083ff3fd 144 );
a2ca7137 145
d98c9a7a
WB
146 daemon::systemd_notify(daemon::SystemdNotify::Ready)?;
147
fda5797b
WB
148 let init_result: Result<(), Error> = try_block!({
149 server::create_task_control_socket()?;
150 server::server_state_init()?;
151 Ok(())
152 });
d607b886 153
fda5797b
WB
154 if let Err(err) = init_result {
155 bail!("unable to start daemon - {}", err);
156 }
e3f41f21 157
8545480a 158 start_task_scheduler();
eaeda365 159 start_stat_generator();
8545480a 160
083ff3fd 161 server.await?;
a546a8a0
WB
162 log::info!("server shutting down, waiting for active workers to complete");
163 proxmox_backup::server::last_worker_future().await?;
fda5797b 164 log::info!("done - exit server");
e3f41f21 165
4223d9f8 166 Ok(())
02c7a755 167}
8545480a 168
eaeda365
DM
169fn start_stat_generator() {
170 let abort_future = server::shutdown_future();
171 let future = Box::pin(run_stat_generator());
172 let task = futures::future::select(future, abort_future);
173 tokio::spawn(task.map(|_| ()));
174}
175
8545480a
DM
176fn start_task_scheduler() {
177 let abort_future = server::shutdown_future();
178 let future = Box::pin(run_task_scheduler());
179 let task = futures::future::select(future, abort_future);
180 tokio::spawn(task.map(|_| ()));
181}
182
6a7be83e 183use std::time::{SystemTime, Instant, Duration, UNIX_EPOCH};
8545480a
DM
184
185fn next_minute() -> Result<Instant, Error> {
6a7be83e
DM
186 let now = SystemTime::now();
187 let epoch_now = now.duration_since(UNIX_EPOCH)?;
188 let epoch_next = Duration::from_secs((epoch_now.as_secs()/60 + 1)*60);
8545480a
DM
189 Ok(Instant::now() + epoch_next - epoch_now)
190}
191
192async fn run_task_scheduler() {
193
194 let mut count: usize = 0;
195
196 loop {
197 count += 1;
198
199 let delay_target = match next_minute() { // try to run very minute
200 Ok(d) => d,
201 Err(err) => {
202 eprintln!("task scheduler: compute next minute failed - {}", err);
203 tokio::time::delay_until(tokio::time::Instant::from_std(Instant::now() + Duration::from_secs(60))).await;
204 continue;
205 }
206 };
207
208 if count > 2 { // wait 1..2 minutes before starting
209 match schedule_tasks().catch_unwind().await {
210 Err(panic) => {
211 match panic.downcast::<&str>() {
212 Ok(msg) => {
213 eprintln!("task scheduler panic: {}", msg);
214 }
215 Err(_) => {
216 eprintln!("task scheduler panic - unknown type");
217 }
218 }
219 }
220 Ok(Err(err)) => {
221 eprintln!("task scheduler failed - {:?}", err);
222 }
223 Ok(Ok(_)) => {}
224 }
225 }
226
227 tokio::time::delay_until(tokio::time::Instant::from_std(delay_target)).await;
228 }
229}
230
231async fn schedule_tasks() -> Result<(), Error> {
232
233 schedule_datastore_garbage_collection().await;
25829a87 234 schedule_datastore_prune().await;
a6160cdf 235 schedule_datastore_sync_jobs().await;
73df9c51 236 schedule_datastore_verify_jobs().await;
9a760917 237 schedule_task_log_rotate().await;
8545480a
DM
238
239 Ok(())
240}
241
8545480a
DM
242async fn schedule_datastore_garbage_collection() {
243
b9e7bcc2
DM
244 use proxmox_backup::config::{
245 datastore::{
246 self,
247 DataStoreConfig,
248 },
d7a122a0 249 };
8545480a 250
b9e7bcc2
DM
251 let email = server::lookup_user_email(Userid::root_userid());
252
25829a87 253 let config = match datastore::config() {
8545480a
DM
254 Err(err) => {
255 eprintln!("unable to read datastore config - {}", err);
256 return;
257 }
258 Ok((config, _digest)) => config,
259 };
260
261 for (store, (_, store_config)) in config.sections {
262 let datastore = match DataStore::lookup_datastore(&store) {
263 Ok(datastore) => datastore,
264 Err(err) => {
265 eprintln!("lookup_datastore failed - {}", err);
266 continue;
267 }
268 };
269
25829a87 270 let store_config: DataStoreConfig = match serde_json::from_value(store_config) {
8545480a
DM
271 Ok(c) => c,
272 Err(err) => {
273 eprintln!("datastore config from_value failed - {}", err);
274 continue;
275 }
276 };
277
278 let event_str = match store_config.gc_schedule {
279 Some(event_str) => event_str,
280 None => continue,
281 };
282
283 let event = match parse_calendar_event(&event_str) {
284 Ok(event) => event,
285 Err(err) => {
286 eprintln!("unable to parse schedule '{}' - {}", event_str, err);
287 continue;
288 }
289 };
290
291 if datastore.garbage_collection_running() { continue; }
292
293 let worker_type = "garbage_collection";
294
295 let stat = datastore.last_gc_status();
296 let last = if let Some(upid_str) = stat.upid {
297 match upid_str.parse::<UPID>() {
298 Ok(upid) => upid.starttime,
299 Err(err) => {
300 eprintln!("unable to parse upid '{}' - {}", upid_str, err);
301 continue;
302 }
303 }
304 } else {
d7a122a0
DC
305 match jobstate::last_run_time(worker_type, &store) {
306 Ok(time) => time,
8545480a 307 Err(err) => {
d7a122a0 308 eprintln!("could not get last run time of {} {}: {}", worker_type, store, err);
8545480a
DM
309 continue;
310 }
311 }
312 };
313
314 let next = match compute_next_event(&event, last, false) {
15ec790a
DC
315 Ok(Some(next)) => next,
316 Ok(None) => continue,
8545480a
DM
317 Err(err) => {
318 eprintln!("compute_next_event for '{}' failed - {}", event_str, err);
319 continue;
320 }
321 };
e693818a 322
6a7be83e
DM
323 let now = proxmox::tools::time::epoch_i64();
324
8545480a
DM
325 if next > now { continue; }
326
d7a122a0
DC
327 let mut job = match Job::new(worker_type, &store) {
328 Ok(job) => job,
329 Err(_) => continue, // could not get lock
330 };
331
8545480a 332 let store2 = store.clone();
b9e7bcc2 333 let email2 = email.clone();
8545480a
DM
334
335 if let Err(err) = WorkerTask::new_thread(
336 worker_type,
337 Some(store.clone()),
e6dc35ac 338 Authid::backup_auth_id().clone(),
8545480a
DM
339 false,
340 move |worker| {
d7a122a0
DC
341 job.start(&worker.upid().to_string())?;
342
8545480a
DM
343 worker.log(format!("starting garbage collection on store {}", store));
344 worker.log(format!("task triggered by schedule '{}'", event_str));
d7a122a0 345
f6b1d1cc 346 let result = datastore.garbage_collection(&*worker, worker.upid());
d7a122a0
DC
347
348 let status = worker.create_state(&result);
349
350 if let Err(err) = job.finish(status) {
351 eprintln!("could not finish job state for {}: {}", worker_type, err);
352 }
353
b9e7bcc2
DM
354 if let Some(email2) = email2 {
355 let gc_status = datastore.last_gc_status();
356 if let Err(err) = crate::server::send_gc_status(&email2, datastore.name(), &gc_status, &result) {
357 eprintln!("send gc notification failed: {}", err);
358 }
359 }
360
d7a122a0 361 result
8545480a
DM
362 }
363 ) {
364 eprintln!("unable to start garbage collection on store {} - {}", store2, err);
365 }
366 }
367}
25829a87
DM
368
369async fn schedule_datastore_prune() {
370
1298618a
DM
371 use proxmox_backup::{
372 backup::{
373 PruneOptions,
1298618a
DM
374 },
375 config::datastore::{
376 self,
377 DataStoreConfig,
378 },
9866de5e 379 };
25829a87
DM
380
381 let config = match datastore::config() {
382 Err(err) => {
383 eprintln!("unable to read datastore config - {}", err);
384 return;
385 }
386 Ok((config, _digest)) => config,
387 };
388
389 for (store, (_, store_config)) in config.sections {
25829a87
DM
390
391 let store_config: DataStoreConfig = match serde_json::from_value(store_config) {
392 Ok(c) => c,
393 Err(err) => {
a6160cdf 394 eprintln!("datastore '{}' config from_value failed - {}", store, err);
25829a87
DM
395 continue;
396 }
397 };
398
399 let event_str = match store_config.prune_schedule {
400 Some(event_str) => event_str,
401 None => continue,
402 };
403
404 let prune_options = PruneOptions {
405 keep_last: store_config.keep_last,
406 keep_hourly: store_config.keep_hourly,
407 keep_daily: store_config.keep_daily,
408 keep_weekly: store_config.keep_weekly,
409 keep_monthly: store_config.keep_monthly,
410 keep_yearly: store_config.keep_yearly,
411 };
412
413 if !prune_options.keeps_something() { // no prune settings - keep all
414 continue;
415 }
416
417 let event = match parse_calendar_event(&event_str) {
418 Ok(event) => event,
419 Err(err) => {
420 eprintln!("unable to parse schedule '{}' - {}", event_str, err);
421 continue;
422 }
423 };
424
25829a87
DM
425 let worker_type = "prune";
426
9866de5e
DC
427 let last = match jobstate::last_run_time(worker_type, &store) {
428 Ok(time) => time,
25829a87 429 Err(err) => {
9866de5e 430 eprintln!("could not get last run time of {} {}: {}", worker_type, store, err);
25829a87
DM
431 continue;
432 }
433 };
434
435 let next = match compute_next_event(&event, last, false) {
15ec790a
DC
436 Ok(Some(next)) => next,
437 Ok(None) => continue,
25829a87
DM
438 Err(err) => {
439 eprintln!("compute_next_event for '{}' failed - {}", event_str, err);
440 continue;
441 }
442 };
443
6a7be83e
DM
444 let now = proxmox::tools::time::epoch_i64();
445
25829a87
DM
446 if next > now { continue; }
447
b8d90798 448 let job = match Job::new(worker_type, &store) {
9866de5e
DC
449 Ok(job) => job,
450 Err(_) => continue, // could not get lock
451 };
452
b8d90798
HL
453 let auth_id = Authid::backup_auth_id();
454 if let Err(err) = do_prune_job(job, prune_options, store.clone(), &auth_id, Some(event_str)) {
455 eprintln!("unable to start datastore prune job {} - {}", &store, err);
25829a87 456 }
b8d90798 457
25829a87
DM
458 }
459}
a6160cdf
DM
460
461async fn schedule_datastore_sync_jobs() {
462
1298618a
DM
463 use proxmox_backup::config::sync::{
464 self,
465 SyncJobConfig,
a6160cdf
DM
466 };
467
468 let config = match sync::config() {
469 Err(err) => {
470 eprintln!("unable to read sync job config - {}", err);
471 return;
472 }
473 Ok((config, _digest)) => config,
474 };
475
a6160cdf
DM
476 for (job_id, (_, job_config)) in config.sections {
477 let job_config: SyncJobConfig = match serde_json::from_value(job_config) {
478 Ok(c) => c,
479 Err(err) => {
480 eprintln!("sync job config from_value failed - {}", err);
481 continue;
482 }
483 };
484
485 let event_str = match job_config.schedule {
486 Some(ref event_str) => event_str.clone(),
487 None => continue,
488 };
489
490 let event = match parse_calendar_event(&event_str) {
491 Ok(event) => event,
492 Err(err) => {
493 eprintln!("unable to parse schedule '{}' - {}", event_str, err);
494 continue;
495 }
496 };
497
c67b1fa7 498 let worker_type = "syncjob";
a6160cdf 499
a13573c2
DC
500 let last = match jobstate::last_run_time(worker_type, &job_id) {
501 Ok(time) => time,
a6160cdf 502 Err(err) => {
a13573c2 503 eprintln!("could not get last run time of {} {}: {}", worker_type, job_id, err);
a6160cdf
DM
504 continue;
505 }
506 };
507
508 let next = match compute_next_event(&event, last, false) {
15ec790a
DC
509 Ok(Some(next)) => next,
510 Ok(None) => continue,
a6160cdf
DM
511 Err(err) => {
512 eprintln!("compute_next_event for '{}' failed - {}", event_str, err);
513 continue;
514 }
515 };
516
6a7be83e
DM
517 let now = proxmox::tools::time::epoch_i64();
518
a6160cdf
DM
519 if next > now { continue; }
520
a13573c2 521 let job = match Job::new(worker_type, &job_id) {
93bb51fe 522 Ok(job) => job,
a13573c2 523 Err(_) => continue, // could not get lock
a6160cdf
DM
524 };
525
e6dc35ac 526 let auth_id = Authid::backup_auth_id();
a6160cdf 527
e6dc35ac 528 if let Err(err) = do_sync_job(job, job_config, &auth_id, Some(event_str)) {
a13573c2 529 eprintln!("unable to start datastore sync job {} - {}", &job_id, err);
a6160cdf
DM
530 }
531 }
532}
eaeda365 533
73df9c51 534async fn schedule_datastore_verify_jobs() {
1298618a
DM
535
536 use proxmox_backup::config::verify::{
537 self,
538 VerificationJobConfig,
73df9c51 539 };
1298618a 540
73df9c51
HL
541 let config = match verify::config() {
542 Err(err) => {
543 eprintln!("unable to read verification job config - {}", err);
544 return;
545 }
546 Ok((config, _digest)) => config,
547 };
548 for (job_id, (_, job_config)) in config.sections {
549 let job_config: VerificationJobConfig = match serde_json::from_value(job_config) {
550 Ok(c) => c,
551 Err(err) => {
552 eprintln!("verification job config from_value failed - {}", err);
553 continue;
554 }
555 };
556 let event_str = match job_config.schedule {
557 Some(ref event_str) => event_str.clone(),
558 None => continue,
559 };
560 let event = match parse_calendar_event(&event_str) {
561 Ok(event) => event,
562 Err(err) => {
563 eprintln!("unable to parse schedule '{}' - {}", event_str, err);
564 continue;
565 }
566 };
567 let worker_type = "verificationjob";
568 let last = match jobstate::last_run_time(worker_type, &job_id) {
569 Ok(time) => time,
570 Err(err) => {
571 eprintln!("could not get last run time of {} {}: {}", worker_type, job_id, err);
572 continue;
573 }
574 };
575 let next = match compute_next_event(&event, last, false) {
576 Ok(Some(next)) => next,
577 Ok(None) => continue,
578 Err(err) => {
579 eprintln!("compute_next_event for '{}' failed - {}", event_str, err);
580 continue;
581 }
582 };
583 let now = proxmox::tools::time::epoch_i64();
584 if next > now { continue; }
585 let job = match Job::new(worker_type, &job_id) {
586 Ok(job) => job,
587 Err(_) => continue, // could not get lock
588 };
e6dc35ac
FG
589 let auth_id = Authid::backup_auth_id();
590 if let Err(err) = do_verification_job(job, job_config, &auth_id, Some(event_str)) {
73df9c51
HL
591 eprintln!("unable to start datastore verification job {} - {}", &job_id, err);
592 }
593 }
594}
595
9a760917 596async fn schedule_task_log_rotate() {
9a760917
DC
597
598 let worker_type = "logrotate";
4ebda996 599 let job_id = "task_archive";
9a760917
DC
600
601 let last = match jobstate::last_run_time(worker_type, job_id) {
602 Ok(time) => time,
603 Err(err) => {
604 eprintln!("could not get last run time of task log archive rotation: {}", err);
605 return;
606 }
607 };
608
609 // schedule daily at 00:00 like normal logrotate
610 let schedule = "00:00";
611
612 let event = match parse_calendar_event(schedule) {
613 Ok(event) => event,
614 Err(err) => {
615 // should not happen?
616 eprintln!("unable to parse schedule '{}' - {}", schedule, err);
617 return;
618 }
619 };
620
621 let next = match compute_next_event(&event, last, false) {
622 Ok(Some(next)) => next,
623 Ok(None) => return,
624 Err(err) => {
625 eprintln!("compute_next_event for '{}' failed - {}", schedule, err);
626 return;
627 }
628 };
629
630 let now = proxmox::tools::time::epoch_i64();
631
632 if next > now {
633 // if we never ran the rotation, schedule instantly
634 match jobstate::JobState::load(worker_type, job_id) {
635 Ok(state) => match state {
636 jobstate::JobState::Created { .. } => {},
637 _ => return,
638 },
639 _ => return,
640 }
641 }
642
643 let mut job = match Job::new(worker_type, job_id) {
644 Ok(job) => job,
645 Err(_) => return, // could not get lock
646 };
647
648 if let Err(err) = WorkerTask::new_thread(
649 worker_type,
650 Some(job_id.to_string()),
e6dc35ac 651 Authid::backup_auth_id().clone(),
9a760917
DC
652 false,
653 move |worker| {
654 job.start(&worker.upid().to_string())?;
655 worker.log(format!("starting task log rotation"));
e4f5f59e 656
9a760917 657 let result = try_block!({
e4f5f59e
TL
658 // rotate task log archive
659 let max_size = 500000; // a normal entry has about 100b, so ~ 5000 entries/file
660 let max_files = 20; // times twenty files gives at least 100000 task entries
9a760917
DC
661 let has_rotated = rotate_task_log_archive(max_size, true, Some(max_files))?;
662 if has_rotated {
663 worker.log(format!("task log archive was rotated"));
664 } else {
665 worker.log(format!("task log archive was not rotated"));
666 }
667
668 Ok(())
669 });
670
671 let status = worker.create_state(&result);
672
673 if let Err(err) = job.finish(status) {
674 eprintln!("could not finish job state for {}: {}", worker_type, err);
675 }
676
677 result
678 },
679 ) {
680 eprintln!("unable to start task log rotation: {}", err);
681 }
682
683}
684
eaeda365
DM
685async fn run_stat_generator() {
686
013fa7bb 687 let mut count = 0;
eaeda365 688 loop {
013fa7bb 689 count += 1;
a720894f 690 let save = if count >= 6 { count = 0; true } else { false };
013fa7bb 691
eaeda365
DM
692 let delay_target = Instant::now() + Duration::from_secs(10);
693
013fa7bb 694 generate_host_stats(save).await;
eaeda365
DM
695
696 tokio::time::delay_until(tokio::time::Instant::from_std(delay_target)).await;
013fa7bb
DM
697
698 }
eaeda365
DM
699
700}
701
013fa7bb 702fn rrd_update_gauge(name: &str, value: f64, save: bool) {
309ef20d 703 use proxmox_backup::rrd;
013fa7bb 704 if let Err(err) = rrd::update_value(name, value, rrd::DST::Gauge, save) {
309ef20d
DM
705 eprintln!("rrd::update_value '{}' failed - {}", name, err);
706 }
707}
708
013fa7bb 709fn rrd_update_derive(name: &str, value: f64, save: bool) {
309ef20d 710 use proxmox_backup::rrd;
013fa7bb 711 if let Err(err) = rrd::update_value(name, value, rrd::DST::Derive, save) {
309ef20d
DM
712 eprintln!("rrd::update_value '{}' failed - {}", name, err);
713 }
714}
715
013fa7bb 716async fn generate_host_stats(save: bool) {
8f0cec26 717 use proxmox::sys::linux::procfs::{
485841da 718 read_meminfo, read_proc_stat, read_proc_net_dev, read_loadavg};
309ef20d 719 use proxmox_backup::config::datastore;
8c03041a 720
eaeda365 721
4f951399
DM
722 proxmox_backup::tools::runtime::block_in_place(move || {
723
724 match read_proc_stat() {
725 Ok(stat) => {
013fa7bb
DM
726 rrd_update_gauge("host/cpu", stat.cpu, save);
727 rrd_update_gauge("host/iowait", stat.iowait_percent, save);
4f951399
DM
728 }
729 Err(err) => {
730 eprintln!("read_proc_stat failed - {}", err);
eaeda365
DM
731 }
732 }
2c66a590 733
4f951399
DM
734 match read_meminfo() {
735 Ok(meminfo) => {
013fa7bb
DM
736 rrd_update_gauge("host/memtotal", meminfo.memtotal as f64, save);
737 rrd_update_gauge("host/memused", meminfo.memused as f64, save);
738 rrd_update_gauge("host/swaptotal", meminfo.swaptotal as f64, save);
739 rrd_update_gauge("host/swapused", meminfo.swapused as f64, save);
a4a3f7ca 740 }
4f951399
DM
741 Err(err) => {
742 eprintln!("read_meminfo failed - {}", err);
a4a3f7ca
DM
743 }
744 }
8f0cec26 745
4f951399
DM
746 match read_proc_net_dev() {
747 Ok(netdev) => {
748 use proxmox_backup::config::network::is_physical_nic;
749 let mut netin = 0;
750 let mut netout = 0;
751 for item in netdev {
752 if !is_physical_nic(&item.device) { continue; }
753 netin += item.receive;
754 netout += item.send;
755 }
013fa7bb
DM
756 rrd_update_derive("host/netin", netin as f64, save);
757 rrd_update_derive("host/netout", netout as f64, save);
8f0cec26 758 }
4f951399
DM
759 Err(err) => {
760 eprintln!("read_prox_net_dev failed - {}", err);
8f0cec26
DM
761 }
762 }
dd15c0aa 763
485841da
DM
764 match read_loadavg() {
765 Ok(loadavg) => {
013fa7bb 766 rrd_update_gauge("host/loadavg", loadavg.0 as f64, save);
485841da
DM
767 }
768 Err(err) => {
769 eprintln!("read_loadavg failed - {}", err);
770 }
771 }
772
8c03041a
DM
773 let disk_manager = DiskManage::new();
774
013fa7bb 775 gather_disk_stats(disk_manager.clone(), Path::new("/"), "host", save);
91e5bb49 776
d0833a70
DM
777 match datastore::config() {
778 Ok((config, _)) => {
779 let datastore_list: Vec<datastore::DataStoreConfig> =
780 config.convert_to_typed_array("datastore").unwrap_or(Vec::new());
781
782 for config in datastore_list {
8c03041a 783
91e5bb49 784 let rrd_prefix = format!("datastore/{}", config.name);
8c03041a 785 let path = std::path::Path::new(&config.path);
013fa7bb 786 gather_disk_stats(disk_manager.clone(), path, &rrd_prefix, save);
d0833a70
DM
787 }
788 }
789 Err(err) => {
790 eprintln!("read datastore config failed - {}", err);
791 }
792 }
793
4f951399 794 });
eaeda365 795}
dd15c0aa 796
013fa7bb 797fn gather_disk_stats(disk_manager: Arc<DiskManage>, path: &Path, rrd_prefix: &str, save: bool) {
91e5bb49 798
934f5bb8 799 match proxmox_backup::tools::disks::disk_usage(path) {
33070956 800 Ok(status) => {
91e5bb49 801 let rrd_key = format!("{}/total", rrd_prefix);
33070956 802 rrd_update_gauge(&rrd_key, status.total as f64, save);
91e5bb49 803 let rrd_key = format!("{}/used", rrd_prefix);
33070956 804 rrd_update_gauge(&rrd_key, status.used as f64, save);
91e5bb49
DM
805 }
806 Err(err) => {
807 eprintln!("read disk_usage on {:?} failed - {}", path, err);
808 }
809 }
810
934f5bb8
DM
811 match disk_manager.find_mounted_device(path) {
812 Ok(None) => {},
813 Ok(Some((fs_type, device, source))) => {
814 let mut device_stat = None;
815 match fs_type.as_str() {
816 "zfs" => {
817 if let Some(pool) = source {
818 match zfs_pool_stats(&pool) {
819 Ok(stat) => device_stat = stat,
820 Err(err) => eprintln!("zfs_pool_stats({:?}) failed - {}", pool, err),
91e5bb49
DM
821 }
822 }
934f5bb8
DM
823 }
824 _ => {
825 if let Ok(disk) = disk_manager.clone().disk_by_dev_num(device.into_dev_t()) {
826 match disk.read_stat() {
827 Ok(stat) => device_stat = stat,
828 Err(err) => eprintln!("disk.read_stat {:?} failed - {}", path, err),
91e5bb49
DM
829 }
830 }
831 }
91e5bb49 832 }
934f5bb8
DM
833 if let Some(stat) = device_stat {
834 let rrd_key = format!("{}/read_ios", rrd_prefix);
835 rrd_update_derive(&rrd_key, stat.read_ios as f64, save);
836 let rrd_key = format!("{}/read_bytes", rrd_prefix);
837 rrd_update_derive(&rrd_key, (stat.read_sectors*512) as f64, save);
dd15c0aa 838
934f5bb8
DM
839 let rrd_key = format!("{}/write_ios", rrd_prefix);
840 rrd_update_derive(&rrd_key, stat.write_ios as f64, save);
841 let rrd_key = format!("{}/write_bytes", rrd_prefix);
842 rrd_update_derive(&rrd_key, (stat.write_sectors*512) as f64, save);
dd15c0aa 843
934f5bb8
DM
844 let rrd_key = format!("{}/io_ticks", rrd_prefix);
845 rrd_update_derive(&rrd_key, (stat.io_ticks as f64)/1000.0, save);
8c03041a
DM
846 }
847 }
934f5bb8
DM
848 Err(err) => {
849 eprintln!("find_mounted_device failed - {}", err);
850 }
8c03041a 851 }
8c03041a 852}