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	dpavlin	194	#!/usr/bin/perl
2			use strict;
3			use warnings;
4
5			my $debug = shift @ARGV;
6
7	dpavlin	197	use Test::More tests => 213;
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	197	ok( $obj->enqueue({
27	dpavlin	194	i => $i,
28			foo => 'bar',
29	dpavlin	197	}), "enqueue $i" );
30	dpavlin	194	};
31
32			my $i = 1;
33
34	dpavlin	197	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	dpavlin	194	$i++;
40			}