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	#!/usr/bin/perl
2	use strict;
3	use warnings;
4
5	my $debug = shift @ARGV;
6
7	use Test::More tests => 255;
8	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	ok( $obj->enqueue(
27	"command-$i",
28	{
29	i => $i,
30	foo => 'bar',
31	}
32	), "enqueue $i" );
33	};
34
35	my $i = 1;
36
37	while ( my $job = $obj->dequeue ) {
38	ok( $job, "dequeue $i" );
39	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	ok( $job->finish, "finish $i" );
44	$i++;
45	}