trunk/t/06-queue.t

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

my $debug = shift @ARGV;

use Test::More tests => 213;
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({
                i => $i,
                foo => 'bar',
        }), "enqueue $i" );
};

my $i = 1;

while ( my $job = $obj->dequeue ) {
        ok( $job, "dequeue $i" );
        ok( my $dispatch = $job->dispatch, "dispatch $i" );
        cmp_ok( $dispatch->{i}, '==', $i, "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 => 213;
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	i => $i,
28	foo => 'bar',
29	}), "enqueue $i" );
30	};
31
32	my $i = 1;
33
34	while ( my $job = $obj->dequeue ) {
35	ok( $job, "dequeue $i" );
36	ok( my $dispatch = $job->dispatch, "dispatch $i" );
37	cmp_ok( $dispatch->{i}, '==', $i, "i == $i" );
38	ok( $job->finish, "finish $i" );
39	$i++;
40	}