4 |
|
|
5 |
my $debug = shift @ARGV; |
my $debug = shift @ARGV; |
6 |
|
|
7 |
use Test::More tests => 213; |
use Test::More tests => 255; |
8 |
use Data::Dump qw/dump/; |
use Data::Dump qw/dump/; |
9 |
use lib 'lib'; |
use lib 'lib'; |
10 |
|
|
23 |
isa_ok( $obj, 'CWMP::Queue' ); |
isa_ok( $obj, 'CWMP::Queue' ); |
24 |
|
|
25 |
for my $i ( 1 .. 42 ) { |
for my $i ( 1 .. 42 ) { |
26 |
ok( $obj->enqueue({ |
ok( $obj->enqueue( |
27 |
i => $i, |
"command-$i", |
28 |
foo => 'bar', |
{ |
29 |
}), "enqueue $i" ); |
i => $i, |
30 |
|
foo => 'bar', |
31 |
|
} |
32 |
|
), "enqueue $i" ); |
33 |
}; |
}; |
34 |
|
|
35 |
my $i = 1; |
my $i = 1; |
36 |
|
|
37 |
while ( my $job = $obj->dequeue ) { |
while ( my $job = $obj->dequeue ) { |
38 |
ok( $job, "dequeue $i" ); |
ok( $job, "dequeue $i" ); |
39 |
ok( my $dispatch = $job->dispatch, "dispatch $i" ); |
ok( my ( $dispatch, $args ) = $job->dispatch, "job->dispatch $i" ); |
40 |
cmp_ok( $dispatch->{i}, '==', $i, "i == $i" ); |
cmp_ok( $dispatch, 'eq', "command-$i", "dispatch $i" ); |
41 |
|
diag "args = ",dump( $args ) if $debug; |
42 |
|
cmp_ok( $args->{i}, '==', $i, "args i == $i" ); |
43 |
ok( $job->finish, "finish $i" ); |
ok( $job->finish, "finish $i" ); |
44 |
$i++; |
$i++; |
45 |
} |
} |