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
|
#
# (c) Jan Gehring <jan.gehring@gmail.com>
#
package Rex::TaskList;
use v5.12.5;
use warnings;
our $VERSION = '1.14.1'; # VERSION
use Data::Dumper;
use Rex::Config;
use Rex::Logger;
use Rex::Interface::Executor;
use vars qw(%tasks);
# will be set from Rex::Transaction::transaction()
our $task_list = {};
sub create {
my ($class) = @_;
# create only one object
if ( ref($task_list) =~ m/^Rex::TaskList::/ ) {
Rex::Logger::debug(
"Returning existing distribution class of type: " . ref($task_list) );
return $task_list;
}
my $type = Rex::Config->get_distributor;
Rex::Logger::debug("Creating new distribution class of type: $type");
my $class_name = "Rex::TaskList::$type";
eval "use $class_name";
if ($@) {
die("TaskList module not found: $@");
}
$task_list = $class_name->new;
Rex::Logger::debug(
"new distribution class of type " . ref($task_list) . " created." );
return $task_list;
}
sub run {
my ( $class, $task_name, %option ) = @_;
$class = ref $class ? $class : $class->create;
my $task = ref $task_name ? $task_name : $class->get_task($task_name);
my $old_task = $class->{__current_task__};
$class->{__current_task__} = $task;
$_->($task) for @{ $task->{before_task_start} };
$class->run( $task, %option );
$_->($task) for @{ $task->{after_task_finished} };
$class->{__current_task__} = $old_task;
}
|
