trunk/t/06-queue.t

#!/usr/bin/perl
use strict;
use warnings;

my $debug = shift @ARGV;

use Test::More tests => 255;
use Data::Dump qw/dump/;
use lib 'lib';

BEGIN {
        use_ok('CWMP::Queue');
}

#use Cwd qw/abs_path/;
#ok(my $abs_path = abs_path($0), "abs_path");
#$abs_path =~ s!/[^/]*$!/!;     #!fix-vim

ok( my $obj = CWMP::Queue->new({
        id => 'test',
        debug => $debug,
}), 'new' );
isa_ok( $obj, 'CWMP::Queue' );

for my $i ( 1 .. 42 ) {
        ok( $obj->enqueue(
                "command-$i",
                {
                        i => $i,
                        foo => 'bar',
                }
        ), "enqueue $i" );
};

my $i = 1;

while ( my $job = $obj->dequeue ) {
        ok( $job, "dequeue $i" );
        ok( my ( $dispatch, $args ) = $job->dispatch, "job->dispatch $i" );
        cmp_ok( $dispatch, 'eq', "command-$i", "dispatch $i" );
        diag "args = ",dump( $args ) if $debug;
        cmp_ok( $args->{i}, '==', $i, "args i == $i" );
        ok( $job->finish, "finish $i" );
        $i++;
}
1	dpavlin	194	#!/usr/bin/perl
2			use strict;
3			use warnings;
4
5			my $debug = shift @ARGV;
6
7	dpavlin	199	use Test::More tests => 255;
8	dpavlin	194	use Data::Dump qw/dump/;
9			use lib 'lib';
10
11			BEGIN {
12			use_ok('CWMP::Queue');
13			}
14
15			#use Cwd qw/abs_path/;
16			#ok(my $abs_path = abs_path($0), "abs_path");
17			#$abs_path =~ s!/[^/]*$!/!; #!fix-vim
18
19			ok( my $obj = CWMP::Queue->new({
20			id => 'test',
21			debug => $debug,
22			}), 'new' );
23			isa_ok( $obj, 'CWMP::Queue' );
24
25			for my $i ( 1 .. 42 ) {
26	dpavlin	199	ok( $obj->enqueue(
27			"command-$i",
28			{
29			i => $i,
30			foo => 'bar',
31			}
32			), "enqueue $i" );
33	dpavlin	194	};
34
35			my $i = 1;
36
37	dpavlin	197	while ( my $job = $obj->dequeue ) {
38			ok( $job, "dequeue $i" );
39	dpavlin	199	ok( my ( $dispatch, $args ) = $job->dispatch, "job->dispatch $i" );
40			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	dpavlin	197	ok( $job->finish, "finish $i" );
44	dpavlin	194	$i++;
45			}