AnyEvent-Net-Curl-Queued

 view release on metacpan or  search on metacpan

MANIFEST  view on Meta::CPAN

t/60-cleanup.t
t/61-nest.t
t/70-timeout.t
t/71-bad-address.t
t/72-non-http.t
t/73-cycle.t
t/74-exception.t
t/Loopbacker.pm
t/Recursioner.pm
t/Retrier.pm
t/Timeouter.pm
t/author-critic.t
t/author-distmeta.t
t/author-eol.t
t/author-minimum-version.t
t/author-mojibake.t
t/author-no-tabs.t
t/author-pod-coverage.t
t/author-pod-linkcheck.t
t/author-pod-syntax.t
t/author-portability.t

README  view on Meta::CPAN

 share

    Net::Curl::Share instance.

 stats

    AnyEvent::Net::Curl::Queued::Stats instance.

 timeout

    Timeout (default: 60 seconds).

 unique

    Signature cache.

 watchdog

    The last resort against the non-deterministic chaos of evil lurking
    sockets.

inc/Test/HTTP/AnyEvent/Server.pm  view on Meta::CPAN

Port to bind the server.
Picks the first available by default.

=head2 maxconn

Limit the number of accepted connections to this.
Default: 10.

=head2 timeout

Timeout connection after this number of seconds.
Default: 60.

=head2 disable_proxy

Reset the proxy-controlling environment variables (C<no_proxy>/C<http_proxy>/C<ftp_proxy>/C<all_proxy>).
I guess you don't need a proxy to connect to yourself.
Default: true.

=head2 forked

lib/AnyEvent/Net/Curl/Queued.pm  view on Meta::CPAN

=head2 share

L<Net::Curl::Share> instance.

=head2 stats

L<AnyEvent::Net::Curl::Queued::Stats> instance.

=head2 timeout

Timeout (default: 60 seconds).

=head2 unique

Signature cache.

=head2 watchdog

The last resort against the non-deterministic chaos of evil lurking sockets.

=head1 METHODS

lib/AnyEvent/Net/Curl/Queued/Multi.pm  view on Meta::CPAN

    # deregister old io events
    unless ($keep) {
        delete $self->pool->{"r$socket"};
        delete $self->pool->{"w$socket"};
    }

    return 0;
}

# timer callback: It triggers timeout update. Timeout value tells
# us how soon socket_action must be called if there were no actions
# on sockets. This will allow curl to trigger timeout events.
sub _cb_timer {
    my ($self, $timeout_ms) = @_;

    # deregister old timer
    $self->clear_timer;

    my $cb = sub {
        $self->socket_action(Net::Curl::Multi::CURL_SOCKET_TIMEOUT)

t/Timeouter.pm  view on Meta::CPAN

package Timeouter;
use strict;
use utf8;
use warnings qw(all);

use Data::Dumper;
use Moo;
use MooX::Types::MooseLike::Base qw(Num);
use Test::More;
use Time::HiRes qw(time);

t/author-eol.t  view on Meta::CPAN

    't/60-cleanup.t',
    't/61-nest.t',
    't/70-timeout.t',
    't/71-bad-address.t',
    't/72-non-http.t',
    't/73-cycle.t',
    't/74-exception.t',
    't/Loopbacker.pm',
    't/Recursioner.pm',
    't/Retrier.pm',
    't/Timeouter.pm',
    't/author-critic.t',
    't/author-distmeta.t',
    't/author-eol.t',
    't/author-minimum-version.t',
    't/author-mojibake.t',
    't/author-no-tabs.t',
    't/author-pod-coverage.t',
    't/author-pod-linkcheck.t',
    't/author-pod-syntax.t',
    't/author-portability.t',

t/author-no-tabs.t  view on Meta::CPAN

    't/60-cleanup.t',
    't/61-nest.t',
    't/70-timeout.t',
    't/71-bad-address.t',
    't/72-non-http.t',
    't/73-cycle.t',
    't/74-exception.t',
    't/Loopbacker.pm',
    't/Recursioner.pm',
    't/Retrier.pm',
    't/Timeouter.pm',
    't/author-critic.t',
    't/author-distmeta.t',
    't/author-eol.t',
    't/author-minimum-version.t',
    't/author-mojibake.t',
    't/author-no-tabs.t',
    't/author-pod-coverage.t',
    't/author-pod-linkcheck.t',
    't/author-pod-syntax.t',
    't/author-portability.t',

 view all matches for this distribution
 view release on metacpan -  search on metacpan