blob: 6065c6a0405523ead03ba739535fd05cd22ef213 (
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
# PerlDaemon (c) 2010, 2011, Dipl.-Inform. (FH) Paul Buetow (http://perldaemon.buetow.org)
package PerlDaemon::RunModules;
use strict;
use warnings;
use threads qw(exit stringify);
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");
eval "require '$module'";
$logger->warn("Could not load module source file $module: $@")
if defined $@ and length $@;
}
for my $name (grep /PerlDaemonModules/, keys %INC) {
$name =~ s#.*(PerlDaemonModules)/(.*)\.pm$#$1::$2#;
my $module = eval "${name}->new(\$conf)";
if (defined $@ and length $@) {
$logger->warn("Could not create module instance $name: $@");
} else {
$loadedmodules{$name} = $module;
$scheduler{$name}{lastrun} = [0,0];
$scheduler{$name}{carrysum} = 0;
$scheduler{$name}{firstloop} = 1;
$scheduler{$name}{interval} = $conf->{'daemon.modules.runinterval'};
$logger->logmsg("Created module instance $name");
}
}
} 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};
my $carrytimediff = $timediff + $scheduler->{$k}{carrysum};
if ($carrytimediff >= $interval) {
my $carry = $carrytimediff - $interval;
$logger->logmsg("Triggering $k (last triggered before ${timediff}s; carry: ${carry}s; wanted interval: ${interval}s)");
if ($scheduler->{$k}{firstloop} == 0) {
$scheduler->{$k}{carrysum} = $carry;
} else {
$scheduler->{$k}{firstloop} = 0;
}
$scheduler->{$k}{lastrun} = $now;
$v->do();
}
}
}
}
1;
|
