line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
1
|
|
|
|
|
|
|
package TAP::Parser::Scheduler::Job; |
2
|
|
|
|
|
|
|
|
3
|
16
|
|
|
16
|
|
60
|
use strict; |
|
16
|
|
|
|
|
22
|
|
|
16
|
|
|
|
|
409
|
|
4
|
16
|
|
|
16
|
|
57
|
use warnings; |
|
16
|
|
|
|
|
22
|
|
|
16
|
|
|
|
|
353
|
|
5
|
16
|
|
|
16
|
|
57
|
use Carp; |
|
16
|
|
|
|
|
18
|
|
|
16
|
|
|
|
|
4407
|
|
6
|
|
|
|
|
|
|
|
7
|
|
|
|
|
|
|
=head1 NAME |
8
|
|
|
|
|
|
|
|
9
|
|
|
|
|
|
|
TAP::Parser::Scheduler::Job - A single testing job. |
10
|
|
|
|
|
|
|
|
11
|
|
|
|
|
|
|
=head1 VERSION |
12
|
|
|
|
|
|
|
|
13
|
|
|
|
|
|
|
Version 3.38 |
14
|
|
|
|
|
|
|
|
15
|
|
|
|
|
|
|
=cut |
16
|
|
|
|
|
|
|
|
17
|
|
|
|
|
|
|
our $VERSION = '3.38'; |
18
|
|
|
|
|
|
|
|
19
|
|
|
|
|
|
|
=head1 SYNOPSIS |
20
|
|
|
|
|
|
|
|
21
|
|
|
|
|
|
|
use TAP::Parser::Scheduler::Job; |
22
|
|
|
|
|
|
|
|
23
|
|
|
|
|
|
|
=head1 DESCRIPTION |
24
|
|
|
|
|
|
|
|
25
|
|
|
|
|
|
|
Represents a single test 'job'. |
26
|
|
|
|
|
|
|
|
27
|
|
|
|
|
|
|
=head1 METHODS |
28
|
|
|
|
|
|
|
|
29
|
|
|
|
|
|
|
=head2 Class Methods |
30
|
|
|
|
|
|
|
|
31
|
|
|
|
|
|
|
=head3 C |
32
|
|
|
|
|
|
|
|
33
|
|
|
|
|
|
|
my $job = TAP::Parser::Scheduler::Job->new( |
34
|
|
|
|
|
|
|
$filename, $description |
35
|
|
|
|
|
|
|
); |
36
|
|
|
|
|
|
|
|
37
|
|
|
|
|
|
|
Given the filename and description of a test as scalars, returns a new |
38
|
|
|
|
|
|
|
L object. |
39
|
|
|
|
|
|
|
|
40
|
|
|
|
|
|
|
=cut |
41
|
|
|
|
|
|
|
|
42
|
|
|
|
|
|
|
sub new { |
43
|
448
|
|
|
448
|
1
|
423
|
my ( $class, $name, $desc, @ctx ) = @_; |
44
|
448
|
50
|
|
|
|
1494
|
return bless { |
45
|
|
|
|
|
|
|
filename => $name, |
46
|
|
|
|
|
|
|
description => $desc, |
47
|
|
|
|
|
|
|
@ctx ? ( context => \@ctx ) : (), |
48
|
|
|
|
|
|
|
}, $class; |
49
|
|
|
|
|
|
|
} |
50
|
|
|
|
|
|
|
|
51
|
|
|
|
|
|
|
=head2 Instance Methods |
52
|
|
|
|
|
|
|
|
53
|
|
|
|
|
|
|
=head3 C |
54
|
|
|
|
|
|
|
|
55
|
|
|
|
|
|
|
$self->on_finish(\&method). |
56
|
|
|
|
|
|
|
|
57
|
|
|
|
|
|
|
Register a closure to be called when this job is destroyed. The callback |
58
|
|
|
|
|
|
|
will be passed the C object as it's only argument. |
59
|
|
|
|
|
|
|
|
60
|
|
|
|
|
|
|
=cut |
61
|
|
|
|
|
|
|
|
62
|
|
|
|
|
|
|
sub on_finish { |
63
|
448
|
|
|
448
|
1
|
452
|
my ( $self, $cb ) = @_; |
64
|
448
|
|
|
|
|
880
|
$self->{on_finish} = $cb; |
65
|
|
|
|
|
|
|
} |
66
|
|
|
|
|
|
|
|
67
|
|
|
|
|
|
|
=head3 C |
68
|
|
|
|
|
|
|
|
69
|
|
|
|
|
|
|
$self->finish; |
70
|
|
|
|
|
|
|
|
71
|
|
|
|
|
|
|
Called when a job is complete to unlock it. If a callback has been registered |
72
|
|
|
|
|
|
|
with C, it calls it. Otherwise, it does nothing. |
73
|
|
|
|
|
|
|
|
74
|
|
|
|
|
|
|
=cut |
75
|
|
|
|
|
|
|
|
76
|
|
|
|
|
|
|
sub finish { |
77
|
427
|
|
|
427
|
1
|
6252
|
my $self = shift; |
78
|
427
|
50
|
|
|
|
769
|
if ( my $cb = $self->{on_finish} ) { |
79
|
427
|
|
|
|
|
1024
|
$cb->($self); |
80
|
|
|
|
|
|
|
} |
81
|
|
|
|
|
|
|
} |
82
|
|
|
|
|
|
|
|
83
|
|
|
|
|
|
|
=head2 Attributes |
84
|
|
|
|
|
|
|
|
85
|
|
|
|
|
|
|
$self->filename; |
86
|
|
|
|
|
|
|
$self->description; |
87
|
|
|
|
|
|
|
$self->context; |
88
|
|
|
|
|
|
|
|
89
|
|
|
|
|
|
|
These are all "getters" which return the data set for these attributes during object construction. |
90
|
|
|
|
|
|
|
|
91
|
|
|
|
|
|
|
|
92
|
|
|
|
|
|
|
=head3 C |
93
|
|
|
|
|
|
|
|
94
|
|
|
|
|
|
|
=head3 C |
95
|
|
|
|
|
|
|
|
96
|
|
|
|
|
|
|
=head3 C |
97
|
|
|
|
|
|
|
|
98
|
|
|
|
|
|
|
=cut |
99
|
|
|
|
|
|
|
|
100
|
4334
|
|
|
4334
|
1
|
12957
|
sub filename { shift->{filename} } |
101
|
640
|
|
|
640
|
1
|
4104
|
sub description { shift->{description} } |
102
|
0
|
0
|
|
0
|
1
|
0
|
sub context { @{ shift->{context} || [] } } |
|
0
|
|
|
|
|
0
|
|
103
|
|
|
|
|
|
|
|
104
|
|
|
|
|
|
|
=head3 C |
105
|
|
|
|
|
|
|
|
106
|
|
|
|
|
|
|
For backwards compatibility in callbacks. |
107
|
|
|
|
|
|
|
|
108
|
|
|
|
|
|
|
=cut |
109
|
|
|
|
|
|
|
|
110
|
|
|
|
|
|
|
sub as_array_ref { |
111
|
319
|
|
|
319
|
1
|
401
|
my $self = shift; |
112
|
319
|
|
100
|
|
|
619
|
return [ $self->filename, $self->description, $self->{context} ||= [] ]; |
113
|
|
|
|
|
|
|
} |
114
|
|
|
|
|
|
|
|
115
|
|
|
|
|
|
|
=head3 C |
116
|
|
|
|
|
|
|
|
117
|
|
|
|
|
|
|
$self->is_spinner; |
118
|
|
|
|
|
|
|
|
119
|
|
|
|
|
|
|
Returns false indicating that this is a real job rather than a |
120
|
|
|
|
|
|
|
'spinner'. Spinners are returned when the scheduler still has pending |
121
|
|
|
|
|
|
|
jobs but can't (because of locking) return one right now. |
122
|
|
|
|
|
|
|
|
123
|
|
|
|
|
|
|
=cut |
124
|
|
|
|
|
|
|
|
125
|
283
|
|
|
283
|
1
|
623
|
sub is_spinner {0} |
126
|
|
|
|
|
|
|
|
127
|
|
|
|
|
|
|
1; |