Changeset 5827

Timestamp:

07/04/09 15:55:41 (3 years ago)

Author:

submersible_toaster

Message:

...any moment

File:

• trunk/Padre-Plugin-Swarm/lib/Padre/Swarm/Transport/IRC.pm (modified) (4 diffs)

trunk/Padre-Plugin-Swarm/lib/Padre/Swarm/Transport/IRC.pm

@@ -30 +30 @@
         }
     );
+    
     $self->{connection} = $con;
+    $self->_register_irc_callbacks($con);
     my $c = AnyEvent->condvar;
     $self->{condvar} = $c;
@@ -46 +48 @@
 sub _register_irc_callbacks {
     my ($self,$con) = @_;
-
+warn "REGISTER CALLBACKS";
 
     $con->reg_cb (
@@ -55 +57 @@
          $self->condvar->broadcast;
           } else {
-         warn "Connected! Yay!\n";
+         Padre::Util::debug( "Connected! Yay!\n" );
           }
 
-        $con->register( 
-          $self->nickname,
-          'Padre-Swarm-Transport-IRC',
-          , getlogin() 
-        );
         $con->send_srv( JOIN => '#padre' );
-       
+#       $con->register( 
+#         $self->nickname,
+#         'Padre-Swarm-Transport-IRC',
+#         , getlogin() 
+#       );
+        
        },
        disconnect => sub {
@@ -109 +111 @@
 sub poll {
     my ($self,$time) = @_;
-    warn "Polling for $time:";
-    $self->condvar->recv();
+#   warn "Polling for $time:";
+    my $c = AnyEvent->condvar;
+    my $timer = AnyEvent->timer( after=>$time,
+        cb=>sub{ $c->send } );
+    $c->recv;
+#   warn "Returned from poll wait";
     if ( keys %{ $self->{incoming_buffer} } ) {
+        warn "DATA IN BUFFER!";
         return keys %{ $self->{incoming_buffer} };
     }