Changeset 15918

Show
Ignore:
Timestamp:
07/17/08 14:15:34 (5 years ago)
Author:
33rpm
Message:

split a test

Location:
lang/perl/Queue-Leaky/trunk/t
Files:
1 modified
1 copied

Legend:

Unmodified
Added
Removed

  • lang/perl/Queue-Leaky/trunk/t/01_basic.t

    r15889 r15918  
    11use strict; 
    2 use Test::More tests => 42; 
     2use Test::More tests => 24; 
    33use Queue::Leaky; 
    44 
    … …  
    5151    is( $queue->state_get($queue->queue), 0 ); 
    5252} 
    53  
    54 { 
    55     my $table = "q_incoming"; 
    56     my $queue = Queue::Leaky->new( 
    57         queue => { 
    58             module => 'Q4M', 
    59             connect_info => [ 
    60                 $ENV{QLEAKY_Q4M_DSN}, 
    61                 $ENV{QLEAKY_Q4M_USERNAME}, 
    62                 $ENV{QLEAKY_Q4M_PASSWORD}, 
    63                 { RaiseError => 1, AutoCommit => 1 }, 
    64             ], 
    65         }, 
    66     ); 
    67  
    68     ok( $queue, "queue ok" ); 
    69     isa_ok( $queue, "Queue::Leaky", "queue class ok" ); 
    70  
    71     my $message = { 
    72         destination => "world", 
    73         message     => "Hello!", 
    74     }; 
    75  
    76     ok( $queue->insert($table, $message) ); 
    77     my $rv = $queue->next($table); 
    78     is( $rv, $table ); 
    79     is( $queue->fetch($rv)->{message}, "Hello!" ); 
    80     ok( $queue->clear($table) ); 
    81 } 
    82  
    83 { 
    84     my $max = 3; 
    85     my $queue = Queue::Leaky->new( 
    86         max_items => $max, 
    87         state => { 
    88             module => 'Memcached', 
    89             memcached => { 
    90                 servers => [ qw(127.0.0.1:11211) ], 
    91             } 
    92         }, 
    93     ); 
    94  
    95     for my $count (1 .. $max) { 
    96         ok( $queue->insert($count) ); 
    97     } 
    98     ok( !$queue->insert("I'm not there") ); 
    99  
    100     for my $count (1 .. $max) { 
    101         ok( $queue->next ); 
    102         is( $queue->fetch, $count ); 
    103     } 
    104     ok( !$queue->next ); 
    105  
    106     is( $queue->state_get($queue->queue), 0 ); 
    107 } 

  • lang/perl/Queue-Leaky/trunk/t/02_extended.t

    r15889 r15918  
    11use strict; 
    2 use Test::More tests => 42; 
     2use Test::More tests => 19; 
    33use Queue::Leaky; 
    44 
    5 { 
    6     my $queue = Queue::Leaky->new; 
     5SKIP: { 
     6    skip "Define QLEAKY_Q4M_DSN to run this test", 7 unless $ENV{QLEAKY_Q4M_DSN}; 
    77 
    8     ok( $queue, "queue ok" ); 
    9     isa_ok( $queue, "Queue::Leaky", "queue class ok" ); 
    10  
    11     my $message = "Hello!"; 
    12  
    13     ok( $queue->insert($message) ); 
    14     ok( $queue->next ); 
    15     is( $queue->fetch, "Hello!" ); 
    16     ok( $queue->clear ); 
    17 } 
    18  
    19 { 
    20     my $max = 3; 
    21     my $queue = Queue::Leaky->new( 
    22         max_items => $max, 
    23     ); 
    24  
    25     for my $count (1 .. $max) { 
    26         ok( $queue->insert($count) ); 
    27     } 
    28     ok( !$queue->insert("I'm not there") ); 
    29  
    30     for my $count (1 .. $max) { 
    31         ok( $queue->next ); 
    32         is( $queue->fetch, $count ); 
    33     } 
    34     ok( !$queue->next ); 
    35  
    36     is( $queue->state_get($queue->queue), 0 ); 
    37 } 
    38  
    39 { 
    40     my $max = 3; 
    41     my $queue = Queue::Leaky->new; 
    42  
    43     for my $count (1 .. $max) { 
    44         ok( $queue->insert($count) ); 
    45     } 
    46  
    47     is( $queue->state_get($queue->queue), 3 ); 
    48  
    49     ok( $queue->clear ); 
    50  
    51     is( $queue->state_get($queue->queue), 0 ); 
    52 } 
    53  
    54 { 
    55     my $table = "q_incoming"; 
     8    my $table = join('_', qw(qleaky test), $$); 
    569    my $queue = Queue::Leaky->new( 
    5710        queue => { 
    … …  
    5912            connect_info => [ 
    6013                $ENV{QLEAKY_Q4M_DSN}, 
    61                 $ENV{QLEAKY_Q4M_USERNAME}, 
     14                $ENV{QLEAKY_Q4M_USERNAME} || 'root', 
    6215                $ENV{QLEAKY_Q4M_PASSWORD}, 
    6316                { RaiseError => 1, AutoCommit => 1 }, 
    … …  
    6619    ); 
    6720 
    68     ok( $queue, "queue ok" ); 
    69     isa_ok( $queue, "Queue::Leaky", "queue class ok" ); 
     21    isa_ok( $queue->queue, 'Queue::Leaky::Driver::Q4M' ); 
     22 
     23    my $dbh = $queue->queue->q4m->dbh; 
     24 
     25    ok( $dbh->do("create table $table (v text) engine=queue"), "create table ok" ); 
    7026 
    7127    my $message = { 
    72         destination => "world", 
    73         message     => "Hello!", 
     28        v => "Hello!", 
    7429    }; 
    7530 
    … …  
    7732    my $rv = $queue->next($table); 
    7833    is( $rv, $table ); 
    79     is( $queue->fetch($rv)->{message}, "Hello!" ); 
     34    is( $queue->fetch($rv)->{v}, "Hello!" ); 
    8035    ok( $queue->clear($table) ); 
     36 
     37    ok( $dbh->do("drop table $table"), "clean up ok" ); 
    8138} 
    8239 
    83 { 
     40SKIP: { 
     41    skip "Define QLEAKY_MEMCACHED_SERVERS to run this test", 12 unless $ENV{QLEAKY_MEMCACHED_SERVERS}; 
     42 
    8443    my $max = 3; 
    8544    my $queue = Queue::Leaky->new( 
    … …  
    8847            module => 'Memcached', 
    8948            memcached => { 
    90                 servers => [ qw(127.0.0.1:11211) ], 
     49                servers => [ split(/\s+/, $ENV{QLEAKY_MEMCACHED_SERVERS}) ], 
    9150            } 
    9251        },