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

Comparing AnyEvent/lib/AnyEvent/Handle.pm (file contents):
Revision 1.25 by root, Sat May 24 15:19:43 2008 UTC vs.
Revision 1.28 by root, Sat May 24 22:27:11 2008 UTC

 When this parameter is given, it enables TLS (SSL) mode, that means it
 will start making tls handshake and will transparently encrypt/decrypt
 data.
+TLS mode requires Net::SSLeay to be installed (it will be loaded
+automatically when you try to create a TLS handle).
 For the TLS server side, use C<accept>, and for the TLS client side of a
 connection, use C<connect> mode.
 You can also provide your own TLS connection object, but you have
 to make sure that you call either C<Net::SSLeay::set_connect_state>
 or C<Net::SSLeay::set_accept_state> on it before you pass it to
 AnyEvent::Handle.
+See the C<starttls> method if you need to start TLs negotiation later.
 =item tls_ctx => $ssl_ctx
 Use the given Net::SSLeay::CTX object to create the new TLS connection
 (unless a connection object was specified directly). If this parameter is
 missing, then AnyEvent::Handle will use C<AnyEvent::Handle::TLS_CTX>.
 =back
 =cut
+our (%RH, %WH);
+sub register_read_type($$) {
+   $RH{$_[0]} = $_[1];
+}
+sub register_write_type($$) {
+   $WH{$_[0]} = $_[1];
+}
 sub new {
    my $class = shift;
    my $self = bless { @_ }, $class;
 true, it will be removed from the queue.
 =cut
 sub push_read {
-   my ($self, $cb) = @_;
+   my $self = shift;
+   my $cb = pop;
+   if (@_) {
+      my $type = shift;
+      $cb = ($RH{$type} or Carp::croak "unsupported type passed to AnyEvent::Handle::push_read")
+            ->($self, $cb, @_);
+   }
    push @{ $self->{queue} }, $cb;
    $self->_drain_rbuf;
 }
 sub unshift_read {
-   my ($self, $cb) = @_;
+   my $self = shift;
+   my $cb = pop;
+   if (@_) {
+      my $type = shift;
+      $cb = ($RH{$type} or Carp::croak "unsupported type passed to AnyEvent::Handle::unshift_read")
+            ->($self, $cb, @_);
+   }
-   push @{ $self->{queue} }, $cb;
+   unshift @{ $self->{queue} }, $cb;
    $self->_drain_rbuf;
 }
-=item $handle->push_read_chunk ($len, $cb->($self, $data))
+=item $handle->push_read (type => @args, $cb)
-=item $handle->unshift_read_chunk ($len, $cb->($self, $data))
+=item $handle->unshift_read (type => @args, $cb)
-Append the given callback to the end of the queue (C<push_read_chunk>) or
+Instead of providing a callback that parses the data itself you can chose
-prepend it (C<unshift_read_chunk>).
+between a number of predefined parsing formats, for chunks of data, lines
+etc.
-The callback will be called only once C<$len> bytes have been read, and
+The types currently supported are:
-these C<$len> bytes will be passed to the callback.
-=cut
+=over 4
-sub _read_chunk($$) {
+=item chunk => $octets, $cb->($self, $data)
+Invoke the callback only once C<$octets> bytes have been read. Pass the
+data read to the callback. The callback will never be called with less
+data.
+Example: read 2 bytes.
+   $handle->push_read (chunk => 2, sub {
+      warn "yay ", unpack "H*", $_[1];
+   });
+=cut
+register_read_type chunk => sub {
-   my ($self, $len, $cb) = @_;
+   my ($self, $cb, $len) = @_;
    sub {
       $len <= length $_[0]{rbuf} or return;
       $cb->($_[0], substr $_[0]{rbuf}, 0, $len, "");
       1
    }
-}
+};
+# compatibility with older API
 sub push_read_chunk {
-   $_[0]->push_read (&_read_chunk);
+   $_[0]->push_read (chunk => $_[1], $_[2]);
 }
 sub unshift_read_chunk {
-   $_[0]->unshift_read (&_read_chunk);
+   $_[0]->unshift_read (chunk => $_[1], $_[2]);
 }
-=item $handle->push_read_line ([$eol, ]$cb->($self, $line, $eol))
+=item line => [$eol, ]$cb->($self, $line, $eol)
-=item $handle->unshift_read_line ([$eol, ]$cb->($self, $line, $eol))
-Append the given callback to the end of the queue (C<push_read_line>) or
-prepend it (C<unshift_read_line>).
 The callback will be called only once a full line (including the end of
 line marker, C<$eol>) has been read. This line (excluding the end of line
 marker) will be passed to the callback as second argument (C<$line>), and
 the end of line marker as the third argument (C<$eol>).
 Partial lines at the end of the stream will never be returned, as they are
 not marked by the end of line marker.
 =cut
-sub _read_line($$) {
+register_read_type line => sub {
-   my $self = shift;
+   my ($self, $cb, $eol) = @_;
-   my $cb = pop;
-   my $eol = @_ ? shift : qr|(\015?\012)|;
-   my $pos;
+   $eol = qr|(\015?\012)| if @_ < 3;
    $eol = quotemeta $eol unless ref $eol;
    $eol = qr|^(.*?)($eol)|s;
    sub {
       $_[0]{rbuf} =~ s/$eol// or return;
       $cb->($_[0], $1, $2);
       1
    }
-}
+};
+# compatibility with older API
 sub push_read_line {
-   $_[0]->push_read (&_read_line);
+   my $self = shift;
+   $self->push_read (line => @_);
 }
 sub unshift_read_line {
-   $_[0]->unshift_read (&_read_line);
+   my $self = shift;
+   $self->unshift_read (line => @_);
 }
+=back
 =item $handle->stop_read
 =item $handle->start_read
    # basically, this is deep magic (because SSL_read should have the same issues)
    # but the openssl maintainers basically said: "trust us, it just works".
    # (unfortunately, we have to hardcode constants because the abysmally misdesigned
    # and mismaintained ssleay-module doesn't even offer them).
+   # http://www.mail-archive.com/openssl-dev@openssl.org/msg22420.html
    Net::SSLeay::CTX_set_mode ($self->{tls},
       (eval { Net::SSLeay::MODE_ENABLE_PARTIAL_WRITE () } || 1)
       | (eval { Net::SSLeay::MODE_ACCEPT_MOVING_WRITE_BUFFER () } || 2));
    $self->{tls_rbio} = Net::SSLeay::BIO_new (Net::SSLeay::BIO_s_mem ());

Diff Legend

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

Comparing AnyEvent/lib/AnyEvent/Handle.pm (file contents): Revision 1.25 by root, Sat May 24 15:19:43 2008 UTC vs. Revision 1.28 by root, Sat May 24 22:27:11 2008 UTC

Diff Legend

Comparing AnyEvent/lib/AnyEvent/Handle.pm (file contents):
Revision 1.25 by root, Sat May 24 15:19:43 2008 UTC vs.
Revision 1.28 by root, Sat May 24 22:27:11 2008 UTC