From 7549114c9f7b7222aa90a6e69fb809cabceb6909 Mon Sep 17 00:00:00 2001 From: Dominik Csapak Date: Wed, 1 Dec 2021 09:45:07 +0100 Subject: [PATCH] adapt compute_next_event to new signature the 'utc' flag is now contained in the event itself and not given as a flag to 'compute_next_event' anymore Signed-off-by: Dominik Csapak Signed-off-by: Dietmar Maurer --- Cargo.toml | 2 +- src/bin/proxmox-backup-proxy.rs | 4 ++-- src/server/jobstate.rs | 2 +- src/tape/inventory.rs | 2 +- src/tape/media_pool.rs | 2 +- 5 files changed, 6 insertions(+), 6 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index d4af37e3..d7ad2085 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -100,7 +100,7 @@ proxmox-router = { version = "1.1", features = [ "cli" ] } proxmox-schema = { version = "1", features = [ "api-macro" ] } proxmox-section-config = "1" proxmox-tfa = { version = "2", features = [ "api", "api-types" ] } -proxmox-time = "1.1.1" +proxmox-time = "1.1.2" proxmox-uuid = "1" proxmox-serde = "0.1" proxmox-shared-memory = "0.2" diff --git a/src/bin/proxmox-backup-proxy.rs b/src/bin/proxmox-backup-proxy.rs index 16ae67bb..07a53687 100644 --- a/src/bin/proxmox-backup-proxy.rs +++ b/src/bin/proxmox-backup-proxy.rs @@ -585,7 +585,7 @@ async fn schedule_datastore_garbage_collection() { } }; - let next = match event.compute_next_event(last, false) { + let next = match event.compute_next_event(last) { Ok(Some(next)) => next, Ok(None) => continue, Err(err) => { @@ -1040,7 +1040,7 @@ fn check_schedule(worker_type: &str, event_str: &str, id: &str) -> bool { } }; - let next = match event.compute_next_event(last, false) { + let next = match event.compute_next_event(last) { Ok(Some(next)) => next, Ok(None) => return false, Err(err) => { diff --git a/src/server/jobstate.rs b/src/server/jobstate.rs index f874725a..25fb2f9b 100644 --- a/src/server/jobstate.rs +++ b/src/server/jobstate.rs @@ -341,7 +341,7 @@ pub fn compute_schedule_status( if let Some(schedule) = schedule { if let Ok(event) = schedule.parse::() { // ignore errors - status.next_run = event.compute_next_event(last, false).unwrap_or(None); + status.next_run = event.compute_next_event(last).unwrap_or(None); } } diff --git a/src/tape/inventory.rs b/src/tape/inventory.rs index 1f0b41f8..c76e50cd 100644 --- a/src/tape/inventory.rs +++ b/src/tape/inventory.rs @@ -533,7 +533,7 @@ impl Inventory { set_start_time } MediaSetPolicy::CreateAt(ref event) => { - match event.compute_next_event(set_start_time, false) { + match event.compute_next_event(set_start_time) { Ok(Some(next)) => next, Ok(None) | Err(_) => return i64::MAX, } diff --git a/src/tape/media_pool.rs b/src/tape/media_pool.rs index 70713cc3..6a947b22 100644 --- a/src/tape/media_pool.rs +++ b/src/tape/media_pool.rs @@ -290,7 +290,7 @@ impl MediaPool { } MediaSetPolicy::CreateAt(event) => { if let Some(set_start_time) = self.inventory.media_set_start_time(&self.current_media_set.uuid()) { - if let Ok(Some(alloc_time)) = event.compute_next_event(set_start_time as i64, false) { + if let Ok(Some(alloc_time)) = event.compute_next_event(set_start_time as i64) { if current_time >= alloc_time { create_new_set = Some(String::from("policy CreateAt event triggered")); }