Changeset 13200

Timestamp:

06/04/08 15:22:28 (5 years ago)

Author:

daisuke

Message:

move condvar and handle exception

Location:

lang/perl/XMPP-Bomber/trunk

Files:

• lib/XMPP/Bomber/Client/Flooder.pm (modified) (2 diffs)
• lib/XMPP/Bomber/Role/Client.pm (modified) (2 diffs)
• t/client/01_flood.t (modified) (2 diffs)

lang/perl/XMPP-Bomber/trunk/lib/XMPP/Bomber/Client/Flooder.pm

@@ -5 +5 @@
 
 with 'XMPP::Bomber::Role::Client';
-
-has 'condvar' => (
-    is => 'rw',
-    default => sub { AnyEvent->condvar }
-);
 
 has 'max_delay' => (
@@ -64 +59 @@
     $cb->();
     $client->start();
-        
     $self->condvar->wait;
 }

lang/perl/XMPP-Bomber/trunk/lib/XMPP/Bomber/Role/Client.pm

@@ -25 +25 @@
 );
 
+has 'condvar' => (
+    is => 'rw',
+    default => sub { AnyEvent->condvar }
+);
+
 has 'content_provider' => (
     is => 'rw',
@@ -41 +46 @@
 
     my $client = Net::XMPP2::Client->new( $self->xmpp_args );
+
+    $client->set_exception_cb( sub {
+        print STDERR "Received exception $_[0]\n";
+        $self->condvar->broadcast
+    } );
     my $server = $self->server;
 

lang/perl/XMPP-Bomber/trunk/t/client/01_flood.t

@@ -5 +5 @@
 {
     use_ok("XMPP::Bomber::Client::Flooder");
+    use_ok("XMPP::Bomber::ContentProvider::Gibberish");
 }
 
@@ -18 +19 @@
                 password => "bar",
             )
-        ]
+        ],
+        content_provider => XMPP::Bomber::ContentProvider::Gibberish->new()
     );