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

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.395 by root, Tue Jan 31 19:03:16 2012 UTC vs.
Revision 1.409 by root, Thu Dec 6 12:10:09 2012 UTC

 as you cannot do race-free signal handling in perl, requiring
 C libraries for this. AnyEvent will try to do its best, which
 means in some cases, signals will be delayed. The maximum time
 a signal might be delayed is 10 seconds by default, but can
 be overriden via C<$ENV{PERL_ANYEVENT_MAX_SIGNAL_LATENCY}> or
-C<$AnyEvent::MAX_SIGNAL_LATENCY> - see the Ö<ENVIRONMENT VARIABLES>
+C<$AnyEvent::MAX_SIGNAL_LATENCY> - see the L<ENVIRONMENT VARIABLES>
 section for details.
 All these problems can be avoided by installing the optional
 L<Async::Interrupt> module, which works with most event loops. It will not
 work with inherently broken event loops such as L<Event> or L<Event::Lib>
       };
    }
    $cv->end;
+   ...
+   my $results = $cv->recv;
 This code fragment supposedly pings a number of hosts and calls
 C<send> after results for all then have have been gathered - in any
 order. To achieve this, the code issues a call to C<begin> when it starts
 each ping request and calls C<end> when it has received some result for
 it. Since C<begin> and C<end> only maintain a counter, the order in which
 In list context, all parameters passed to C<send> will be returned,
 in scalar context only the first one will be returned.
 Note that doing a blocking wait in a callback is not supported by any
-event loop, that is, recursive invocation of a blocking C<< ->recv
+event loop, that is, recursive invocation of a blocking C<< ->recv >> is
->> is not allowed, and the C<recv> call will C<croak> if such a
+not allowed and the C<recv> call will C<croak> if such a condition is
-condition is detected. This condition can be slightly loosened by using
+detected. This requirement can be dropped by relying on L<Coro::AnyEvent>
-L<Coro::AnyEvent>, which allows you to do a blocking C<< ->recv >> from
+, which allows you to do a blocking C<< ->recv >> from any thread
-any thread that doesn't run the event loop itself.
+that doesn't run the event loop itself. L<Coro::AnyEvent> is loaded
+automatically when L<Coro> is used with L<AnyEvent>, so code does not need
+to do anything special to take advantage of that: any code that would
+normally block your program because it calls C<recv>, be executed in an
+C<async> thread instead without blocking other threads.
 Not all event models support a blocking wait - some die in that case
 (programs might want to do that to stay interactive), so I<if you are
 using this from a module, never require a blocking wait>. Instead, let the
 caller decide whether the call will block or not (for example, by coupling
 package AnyEvent;
 # basically a tuned-down version of common::sense
 sub common_sense {
-   # from common:.sense 3.4
+   # from common:.sense 3.5
+   local $^W;
    ${^WARNING_BITS} ^= ${^WARNING_BITS} ^ "\x3c\x3f\x33\x00\x0f\xf0\x0f\xc0\xf0\xfc\x33\x00";
    # use strict vars subs - NO UTF-8, as Util.pm doesn't like this atm. (uts46data.pl)
    $^H |= 0x00000600;
 }
 BEGIN { AnyEvent::common_sense }
 use Carp ();
-our $VERSION = '6.14';
+our $VERSION = '7.04';
 our $MODEL;
 our @ISA;
 our @REGISTRY;
 our $VERBOSE;
 our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred
    # IO::Async::Loop::AnyEvent is extremely evil, refuse to work with it
    # the author knows about the problems and what it does to AnyEvent as a whole
    # (and the ability of others to use AnyEvent), but simply wants to abuse AnyEvent
    # anyway.
-   AnyEvent::log fatal => "AnyEvent: IO::Async::Loop::AnyEvent detected - that module is broken by\n"
+   AnyEvent::log fatal => "IO::Async::Loop::AnyEvent detected - that module is broken by\n"
                         . "design, abuses internals and breaks AnyEvent - will not continue."
       if exists $INC{"IO/Async/Loop/AnyEvent.pm"};
    local $!; # for good measure
    local $SIG{__DIE__}; # we use eval
    if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z0-9:]+)$/) {
       my $model = $1;
       $model = "AnyEvent::Impl::$model" unless $model =~ s/::$//;
       if (eval "require $model") {
-         AnyEvent::log 7 => "loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it.";
+         AnyEvent::log 7 => "Loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it.";
          $MODEL = $model;
       } else {
-         AnyEvent::log 4 => "unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@";
+         AnyEvent::log 4 => "Unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@";
       }
    }
    # check for already loaded models
    unless ($MODEL) {
       for (@REGISTRY, @models) {
          my ($package, $model) = @$_;
          if (${"$package\::VERSION"} > 0) {
             if (eval "require $model") {
-               AnyEvent::log 7 => "autodetected model '$model', using it.";
+               AnyEvent::log 7 => "Autodetected model '$model', using it.";
                $MODEL = $model;
                last;
             } else {
-               AnyEvent::log 8 => "detected event loop $package, but cannot load '$model', skipping: $@";
+               AnyEvent::log 8 => "Detected event loop $package, but cannot load '$model', skipping: $@";
             }
          }
       }
       unless ($MODEL) {
             if (
                eval "require $package"
                and ${"$package\::VERSION"} > 0
                and eval "require $model"
             ) {
-               AnyEvent::log 7 => "autoloaded model '$model', using it.";
+               AnyEvent::log 7 => "Autoloaded model '$model', using it.";
                $MODEL = $model;
                last;
             }
          }
          $MODEL
-           or AnyEvent::log fatal => "AnyEvent: backend autodetection failed - did you properly install AnyEvent?";
+           or AnyEvent::log fatal => "Backend autodetection failed - did you properly install AnyEvent?";
       }
    }
    # free memory only needed for probing
    undef @models;
       # probe for availability of Time::HiRes
       if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {
          *time     = sub { Time::HiRes::time () };
          *AE::time = \&    Time::HiRes::time     ;
          *now      = \&time;
-         AnyEvent::log 8 => "AnyEvent: using Time::HiRes for sub-second timing accuracy.";
+         AnyEvent::log 8 => "using Time::HiRes for sub-second timing accuracy.";
          # if (eval "use POSIX (); (POSIX::times())...
       } else {
          *time     = sub   { CORE::time };
          *AE::time = sub (){ CORE::time };
          *now      = \&time;
-         AnyEvent::log 3 => "using built-in time(), WARNING, no sub-second resolution!";
+         AnyEvent::log 3 => "Using built-in time(), no sub-second resolution!";
       }
    };
    die if $@;
    &time
 sub signal {
    eval q{ # poor man's autoloading {}
       # probe for availability of Async::Interrupt
       if (_have_async_interrupt) {
-         AnyEvent::log 8 => "using Async::Interrupt for race-free signal handling.";
+         AnyEvent::log 8 => "Using Async::Interrupt for race-free signal handling.";
          $SIGPIPE_R = new Async::Interrupt::EventPipe;
          $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;
       } else {
-         AnyEvent::log 8 => "using emulated perl signal handling with latency timer.";
+         AnyEvent::log 8 => "Using emulated perl signal handling with latency timer.";
          if (AnyEvent::WIN32) {
             require AnyEvent::Util;
             ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();
 =over 4
 =item C<PERL_ANYEVENT_VERBOSE>
-By default, AnyEvent will only log messages with loglevel C<3>
+By default, AnyEvent will log messages with loglevel C<4> (C<error>) or
-(C<critical>) or higher (see L<AnyEvent::Log>). You can set this
+higher (see L<AnyEvent::Log>). You can set this environment variable to a
-environment variable to a numerical loglevel to make AnyEvent more (or
+numerical loglevel to make AnyEvent more (or less) talkative.
-less) talkative.
 If you want to do more than just set the global logging level
 you should have a look at C<PERL_ANYEVENT_LOG>, which allows much more
 complex specifications.
 When set to C<0> (C<off>), then no messages whatsoever will be logged with
-the default logging settings.
+everything else at defaults.
-When set to C<5> or higher (C<warn>), causes AnyEvent to warn about
+When set to C<5> or higher (C<warn>), AnyEvent warns about unexpected
-unexpected conditions, such as not being able to load the event model
+conditions, such as not being able to load the event model specified by
-specified by C<PERL_ANYEVENT_MODEL>, or a guard callback throwing an
+C<PERL_ANYEVENT_MODEL>, or a guard callback throwing an exception - this
-exception - this is the minimum recommended level.
+is the minimum recommended level for use during development.
-When set to C<7> or higher (info), cause AnyEvent to report which event model it
+When set to C<7> or higher (info), AnyEvent reports which event model it
 chooses.
-When set to C<8> or higher (debug), then AnyEvent will report extra information on
+When set to C<8> or higher (debug), then AnyEvent will report extra
-which optional modules it loads and how it implements certain features.
+information on which optional modules it loads and how it implements
+certain features.
 =item C<PERL_ANYEVENT_LOG>
 Accepts rather complex logging specifications. For example, you could log
 all C<debug> messages of some module to stderr, warnings and above to
 This variable is evaluated when AnyEvent (or L<AnyEvent::Log>) is loaded,
 so will take effect even before AnyEvent has initialised itself.
 Note that specifying this environment variable causes the L<AnyEvent::Log>
 module to be loaded, while C<PERL_ANYEVENT_VERBOSE> does not, so only
-using the latter saves a few hundred kB of memory until the first message
+using the latter saves a few hundred kB of memory unless a module
-is being logged.
+explicitly needs the extra features of AnyEvent::Log.
 =item C<PERL_ANYEVENT_STRICT>
 AnyEvent does not do much argument checking by default, as thorough
 argument checking is very costly. Setting this variable to a true value
 For example, to force the pure perl model (L<AnyEvent::Loop::Perl>) you
 could start your program like this:
    PERL_ANYEVENT_MODEL=Perl perl ...
+=item C<PERL_ANYEVENT_IO_MODEL>
+The current file I/O model - see L<AnyEvent::IO> for more info.
+At the moment, only C<Perl> (small, pure-perl, synchronous) and
+C<IOAIO> (truly asynchronous) are supported. The default is C<IOAIO> if
+L<AnyEvent::AIO> can be loaded, otherwise it is C<Perl>.
 =item C<PERL_ANYEVENT_PROTOCOLS>
 Used by both L<AnyEvent::DNS> and L<AnyEvent::Socket> to determine preferences
 for IPv4 or IPv6. The default is unspecified (and might change, or be the result
 L<AnyEvent::Impl::FLTK>.
 Non-blocking handles, pipes, stream sockets, TCP clients and
 servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>.
+Asynchronous File I/O: L<AnyEvent::IO>.
 Asynchronous DNS: L<AnyEvent::DNS>.
 Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV>, L<Coro::Event>.
 Nontrivial usage examples: L<AnyEvent::GPSD>, L<AnyEvent::IRC>,
 =head1 AUTHOR
    Marc Lehmann <schmorp@schmorp.de>
-   http://home.schmorp.de/
+   http://anyevent.schmorp.de
 =cut
 1

Diff Legend

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

Comparing AnyEvent/lib/AnyEvent.pm (file contents): Revision 1.395 by root, Tue Jan 31 19:03:16 2012 UTC vs. Revision 1.409 by root, Thu Dec 6 12:10:09 2012 UTC

Diff Legend

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.395 by root, Tue Jan 31 19:03:16 2012 UTC vs.
Revision 1.409 by root, Thu Dec 6 12:10:09 2012 UTC