blob: fe3d9ac579c6e55a6cb39076fa6f65cec8167823 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
package PerlDaemon::RunModules;
use Time::HiRes qw(gettimeofday tv_interval);
sub new ($$) {
my ($class, $conf) = @_;
my $self = bless { conf => $conf }, $class;
my $modulesdir = $conf->{'daemon.modules.dir'};
my $logger = $conf->{logger};
my %loadedmodules;
my %scheduler;
if (-d $modulesdir) {
$logger->logmsg("Loading modules from $modulesdir");
for my $module (<$modulesdir/*.pm>) {
$logger->logmsg("Loading $module");
require $module;
}
for my $name (grep /PerlDaemonModules/, keys %INC) {
$name =~ s#.*(PerlDaemonModules)/(.*)\.pm$#$1::$2#;
$logger->logmsg("Creating module instance of $name");
# TODO: Add eval catching jost un case for errors
$loadedmodules{$name} = eval "${name}->new(\$conf)";
$scheduler{$name}{lastrun} = [0,0];
$scheduler{$name}{interval} = $conf->{'daemon.modules.runinterval'};
}
} else {
$logger->warn("Modules dir $modulesdir does not exist!");
}
$conf->{modules} = \%loadedmodules;
$conf->{scheduler} = \%scheduler;
return $self;
}
sub do ($) {
my $self = shift;
my $conf = $self->{conf};
my $logger = $conf->{logger};
my $modules = $conf->{modules};
my $scheduler = $conf->{scheduler};
unless (%$modules) {
$logger->warn("No modules are loaded!");
} else {
while (my ($k, $v) = each %$modules) {
my $now = [gettimeofday];
my $timediff = tv_interval($scheduler->{$k}{lastrun}, $now);
my $interval = $scheduler->{$k}{interval};
if ($timediff >= $interval) {
$logger->logmsg("Triggering $k (last run before ${timediff}s; wanted interval: ${interval}s)");
$scheduler->{$k}{lastrun} = $now;
$v->do();
}
}
}
}
1;
|
