[ViewVC] Diff of: cvs/AnyEvent/lib/AnyEvent/Handle.pm

Comparing AnyEvent/lib/AnyEvent/Handle.pm (file contents):
Revision 1.165 by root, Mon Jul 27 22:49:23 2009 UTC vs.
Revision 1.170 by root, Sat Aug 1 09:14:54 2009 UTC

 AnyEvent::Handle - non-blocking I/O on file handles via AnyEvent
 =cut
-our $VERSION = 4.87;
+our $VERSION = 4.9;
 =head1 SYNOPSIS
    use AnyEvent;
    use AnyEvent::Handle;
 =cut
 sub on_starttls {
    $_[0]{on_stoptls} = $_[1];
+}
+=item $handle->rbuf_max ($max_octets)
+Configures the C<rbuf_max> setting (C<undef> disables it).
+=cut
+sub rbuf_max {
+   $_[0]{rbuf_max} = $_[1];
 }
 #############################################################################
 =item $handle->timeout ($seconds)
 sub _drain_rbuf {
    my ($self) = @_;
    # avoid recursion
-   return if exists $self->{_skip_drain_rbuf};
+   return if $self->{_skip_drain_rbuf};
    local $self->{_skip_drain_rbuf} = 1;
-   if (
-      defined $self->{rbuf_max}
-      && $self->{rbuf_max} < length $self->{rbuf}
-   ) {
-      $self->_error (Errno::ENOSPC, 1), return;
-   }
    while () {
       # we need to use a separate tls read buffer, as we must not receive data while
       # we are draining the buffer, and this can only happen with TLS.
       $self->{rbuf} .= delete $self->{_tls_rbuf}
       $self->{on_eof}
          ? $self->{on_eof}($self)
          : $self->_error (0, 1, "Unexpected end-of-file");
       return;
+   }
+   if (
+      defined $self->{rbuf_max}
+      && $self->{rbuf_max} < length $self->{rbuf}
+   ) {
+      $self->_error (Errno::ENOSPC, 1), return;
    }
    # may need to restart read watcher
    unless ($self->{_rw}) {
       $self->start_read

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