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