[ViewVC] Diff of: cvs/AnyEvent-MP/MP/Transport.pm

Comparing AnyEvent-MP/MP/Transport.pm (file contents):
Revision 1.3 by root, Fri Jul 31 21:00:37 2009 UTC vs.
Revision 1.4 by root, Sat Aug 1 15:04:31 2009 UTC

       peername => $peername, # for verification
    ;
 =cut
+our @FRAMING_WANT = qw(json storable);#d##TODO#
 sub new {
    my ($class, %arg) = @_;
    my $self = bless \%arg, $class;
          unless exists $arg{secret};
       $self->{hdl} = new AnyEvent::Handle
          fh       => delete $arg{fh},
          rbuf_max => 64 * 1024,
+         autocork => 1,
+         no_delay => 1,
          on_error => sub {
             $self->error ($_[2]);
          },
          peername => delete $arg{peername},
       ;
 }
 sub error {
    my ($self, $msg) = @_;
+   if ($self->{node} && $self->{node}{transport} == $self) {
+      $self->{node}->clr_transport;
+   }
-   $self->{on_error}($self, $msg);
+#   $self->{on_error}($self, $msg);
-   $self->{hdl}->destroy;
+   $self->destroy;
 }
 sub connected {
    my ($self) = @_;
-   (AnyEvent::MP::add_node ($self->{remote_node}))
+   my $node = AnyEvent::MP::add_node ($self->{remote_node});
+   Scalar::Util::weaken ($self->{node} = $node);
-      ->set_transport ($self);
+   $node->set_transport ($self);
 }
 sub send {
    $_[0]{hdl}->push_write ($_[0]{s_framing} => $_[1]);
 }

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines