like an inverse of systemd-timers 'persistent'.
so that the user can configure it to not be run after powering up
when it was previously missed
Signed-off-by: Dominik Csapak <d.csa...@proxmox.com>
---
PVE/API2/Backup.pm | 19 ++++++++++++++++++-
PVE/Jobs.pm | 5 +++++
PVE/Jobs/Plugin.pm | 6 ++++++
PVE/Jobs/VZDump.pm | 1 +
PVE/Service/pvescheduler.pm | 6 +++++-
5 files changed, 35 insertions(+), 2 deletions(-)
diff --git a/PVE/API2/Backup.pm b/PVE/API2/Backup.pm
index 5d36789a..7b00567a 100644
--- a/PVE/API2/Backup.pm
+++ b/PVE/API2/Backup.pm
@@ -180,6 +180,12 @@ __PACKAGE__->register_method({
description => "Enable or disable the job.",
default => '1',
},
+ 'skip-missed' => {
+ optional => 1,
+ type => 'boolean',
+ description => "If true, the job will not be run after boot if
it was missed earlier.",
+ default => 0,
+ },
comment => {
optional => 1,
type => 'string',
@@ -381,6 +387,12 @@ __PACKAGE__->register_method({
description => "Enable or disable the job.",
default => '1',
},
+ 'skip-missed' => {
+ optional => 1,
+ type => 'boolean',
+ description => "If true, the job will not be run after boot if
it was missed earlier.",
+ default => 0,
+ },
comment => {
optional => 1,
type => 'string',
@@ -440,8 +452,13 @@ __PACKAGE__->register_method({
die "no such vzdump job\n" if !$job || $job->{type} ne 'vzdump';
}
+ my $deletable = {
+ comment => 1,
+ 'skip-missed' => 1,
+ };
+
foreach my $k (@$delete) {
- if (!PVE::VZDump::option_exists($k) && $k ne 'comment') {
+ if (!PVE::VZDump::option_exists($k) && !$deletable->{$k}) {
raise_param_exc({ delete => "unknown option '$k'" });
}
diff --git a/PVE/Jobs.pm b/PVE/Jobs.pm
index da648630..299fddd6 100644
--- a/PVE/Jobs.pm
+++ b/PVE/Jobs.pm
@@ -209,6 +209,7 @@ sub get_last_runtime {
}
sub run_jobs {
+ my ($first_run) = @_;
synchronize_job_states_with_config();
my $jobs_cfg = cfs_read_file('jobs.cfg');
@@ -228,6 +229,10 @@ sub run_jobs {
next;
}
+ # update last_run_time on the first run when 'skip-missed' is 1, so
that a missed job will not
+ # start immediately after boot
+ updated_job_schedule($id, $type) if $first_run && $cfg->{'skip-missed'};
+
next if defined($cfg->{enabled}) && !$cfg->{enabled}; # only schedule
actually enabled jobs
my $last_run = get_last_runtime($id, $type);
diff --git a/PVE/Jobs/Plugin.pm b/PVE/Jobs/Plugin.pm
index 6098360b..f5111442 100644
--- a/PVE/Jobs/Plugin.pm
+++ b/PVE/Jobs/Plugin.pm
@@ -39,6 +39,12 @@ my $defaultData = {
description => "Description for the Job.",
maxLength => 512,
},
+ 'skip-missed' => {
+ optional => 1,
+ type => 'boolean',
+ description => "If true, the job will not be run after boot if it
was missed earlier.",
+ default => 0,
+ },
},
};
diff --git a/PVE/Jobs/VZDump.pm b/PVE/Jobs/VZDump.pm
index 44fe33dc..70e1e130 100644
--- a/PVE/Jobs/VZDump.pm
+++ b/PVE/Jobs/VZDump.pm
@@ -26,6 +26,7 @@ sub options {
enabled => { optional => 1 },
schedule => {},
comment => { optional => 1 },
+ 'skip-missed' => { optional => 1 },
};
foreach my $opt (keys %$props) {
if ($props->{$opt}->{optional}) {
diff --git a/PVE/Service/pvescheduler.pm b/PVE/Service/pvescheduler.pm
index f05f3bb9..40be5977 100755
--- a/PVE/Service/pvescheduler.pm
+++ b/PVE/Service/pvescheduler.pm
@@ -97,6 +97,8 @@ sub run {
$jobs->{$type}->{$child} = 1;
};
+ my $first_run = 1;
+
my $run_jobs = sub {
# TODO: actually integrate replication in PVE::Jobs and do not always
fork here, we could
# do the state lookup and check if there's new work scheduled before
doing so, e.g., by
@@ -109,8 +111,10 @@ sub run {
});
$fork->('jobs', sub {
- PVE::Jobs::run_jobs();
+ PVE::Jobs::run_jobs($first_run);
});
+
+ $first_run = 0;
};
PVE::Jobs::setup_dirs();
--
2.30.2
_______________________________________________
pve-devel mailing list
pve-devel@lists.proxmox.com
https://lists.proxmox.com/cgi-bin/mailman/listinfo/pve-devel
