POD fixes (PodChecker.t)
This commit is contained in:
parent
2a929b83bd
commit
fe9e46336d
4 changed files with 46 additions and 36 deletions
|
|
@ -73,7 +73,9 @@ sub config {
|
|||
|
||||
Prints out debug information if debug is enabled.
|
||||
|
||||
=head3
|
||||
=head3 output
|
||||
|
||||
The debug message to be printed if debug is enabled.
|
||||
|
||||
=cut
|
||||
|
||||
|
|
@ -92,7 +94,9 @@ sub debug {
|
|||
|
||||
Prints out error information.
|
||||
|
||||
=head3
|
||||
=head3 output
|
||||
|
||||
The error message to be printed if debug is enabled.
|
||||
|
||||
=cut
|
||||
|
||||
|
|
@ -211,4 +215,3 @@ sub runTests {
|
|||
|
||||
|
||||
1;
|
||||
|
||||
|
|
|
|||
|
|
@ -32,7 +32,7 @@ Initializes the scheduler.
|
|||
=cut
|
||||
|
||||
sub _start {
|
||||
my ( $kernel, $self, $publicEvents) = @_[ KERNEL, OBJECT, ARG0 ];
|
||||
my ($kernel, $self, $publicEvents) = @_[ KERNEL, OBJECT, ARG0 ];
|
||||
$self->debug("Starting Spectre scheduler.");
|
||||
my $serviceName = "cron";
|
||||
$kernel->alias_set($serviceName);
|
||||
|
|
@ -60,8 +60,6 @@ sub _stop {
|
|||
undef $self;
|
||||
}
|
||||
|
||||
|
||||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 addJob ( params )
|
||||
|
|
@ -154,10 +152,9 @@ sub addJob {
|
|||
};
|
||||
}
|
||||
|
||||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 checkSchedule ( job, now )
|
||||
=head2 checkSchedule ( jobId, now )
|
||||
|
||||
Compares a schedule with the current time and kicks off an event if necessary. This method should only ever need to be called by checkSchedules().
|
||||
|
||||
|
|
@ -172,12 +169,12 @@ A DateTime object representing the time to compare the schedule with.
|
|||
=cut
|
||||
|
||||
sub checkSchedule {
|
||||
my ($kernel, $self, $id, $now) = @_[KERNEL, OBJECT, ARG0, ARG1];
|
||||
$self->debug("Checking schedule ".$id." against the current time.");
|
||||
my $cron = DateTime::Cron::Simple->new($self->getJob($id)->{schedule});
|
||||
my ($kernel, $self, $jobId, $now) = @_[KERNEL, OBJECT, ARG0, ARG1];
|
||||
$self->debug("Checking schedule ".$jobId." against the current time.");
|
||||
my $cron = DateTime::Cron::Simple->new($self->getJob($jobId)->{schedule});
|
||||
if ($cron->validate_time($now)) {
|
||||
$self->debug("It's time to run ".$id.". Creating workflow instance.");
|
||||
$kernel->yield("runJob",$id);
|
||||
$self->debug("It's time to run ".$jobId.". Creating workflow instance.");
|
||||
$kernel->yield("runJob",$jobId);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -199,7 +196,6 @@ sub checkSchedules {
|
|||
$kernel->delay_set("checkSchedules",60);
|
||||
}
|
||||
|
||||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 config
|
||||
|
|
@ -219,7 +215,9 @@ sub config {
|
|||
|
||||
Prints out debug information if debug is enabled.
|
||||
|
||||
=head3
|
||||
=head3 output
|
||||
|
||||
The debug message to be printed if debug is enabled.
|
||||
|
||||
=cut
|
||||
|
||||
|
|
@ -255,14 +253,15 @@ sub deleteJob {
|
|||
delete $self->{_jobs}{$id};
|
||||
}
|
||||
|
||||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 error ( output )
|
||||
|
||||
Prints out error information if debug is enabled.
|
||||
|
||||
=head3
|
||||
=head3 output
|
||||
|
||||
The error message to be printed if debug is enabled.
|
||||
|
||||
=cut
|
||||
|
||||
|
|
@ -373,7 +372,6 @@ sub new {
|
|||
);
|
||||
}
|
||||
|
||||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 runJob ( )
|
||||
|
|
@ -456,4 +454,3 @@ sub runJobResponse {
|
|||
|
||||
|
||||
1;
|
||||
|
||||
|
|
|
|||
|
|
@ -57,8 +57,6 @@ sub _stop {
|
|||
undef $self;
|
||||
}
|
||||
|
||||
|
||||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 addInstance ( params )
|
||||
|
|
@ -73,11 +71,11 @@ A hash reference containing important information about the workflow instance to
|
|||
|
||||
The host and domain of the site this instance belongs to.
|
||||
|
||||
=head3 instanceId
|
||||
=head4 instanceId
|
||||
|
||||
The unqiue id for this workflow instance.
|
||||
|
||||
=head3 priority
|
||||
=head4 priority
|
||||
|
||||
The priority (1,2, or 3) that this instance should be run at.
|
||||
|
||||
|
|
@ -134,7 +132,7 @@ sub checkInstances {
|
|||
|
||||
#-------------------------------------------------------------------
|
||||
|
||||
=head2 config
|
||||
=head2 config ( )
|
||||
|
||||
Returns a reference to the config object.
|
||||
|
||||
|
|
@ -167,7 +165,9 @@ sub countRunningInstances {
|
|||
|
||||
Prints out debug information if debug is enabled.
|
||||
|
||||
=head3
|
||||
=head3 output
|
||||
|
||||
The debug message to be printed if debug is enabled.
|
||||
|
||||
=cut
|
||||
|
||||
|
|
@ -210,7 +210,9 @@ sub deleteInstance {
|
|||
|
||||
Prints out error information if debug is enabled.
|
||||
|
||||
=head3
|
||||
=head3 output
|
||||
|
||||
The error message to be printed if debug is enabled.
|
||||
|
||||
=cut
|
||||
|
||||
|
|
@ -439,7 +441,4 @@ sub workerResponse {
|
|||
}
|
||||
|
||||
|
||||
|
||||
1;
|
||||
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue