view release on metacpan or search on metacpan
eg/http_tiny.pl view on Meta::CPAN
use parent 'HTTP::Tiny';
sub _open_handle( $self, $request, $scheme, $host, $port, $peer ) {
My::HTTP::Handle->new(
timeout => $self->{timeout},
keep_alive => $self->{keep_alive},
keep_alive_timeout => $self->{keep_alive_timeout},
SSL_options => $self->{SSL_options},
verify_SSL => $self->{verify_SSL}
)->connect( $scheme, $host, $port, $peer );
}
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Acme/RPC.pm view on Meta::CPAN
EOF
# our $lt;
our $continuity; # don't lose this reference
our @keepalive; # stuff instances of objects created over RPC in there so they don't get garbage collected before the other end can use them
our $tree; # cached tree
our %registry; # oid=>objectrefs
sub import {
view all matches for this distribution
view release on metacpan or search on metacpan
local/lib/perl5/IO/Async/Function.pm view on Meta::CPAN
$future->on_fail( $on_fail ) if $on_fail;
return $future if defined wantarray;
# Caller is not going to keep hold of the Future, so we have to ensure it
# stays alive somehow
$self->adopt_future( $future->else( sub { Future->done } ) );
}
sub _worker_objects
{
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Acme/rafl/Everywhere.pm view on Meta::CPAN
facts => [@new_facts],
);
=head1 DESCRIPTION
If you haven't already seen C<rafl> somewhere, you probably haven't been alive
for too long, because he really is everywhere.
L<Moose>, L<MooseX::Declare>, L<Catalyst>, L<Dist::Zilla>, L<signatures>,
L<KiokuDB>, L<Gtk2>, Perl core, MetaCPAN and GSoC are just I<some> of the
projects he's involved in.
view all matches for this distribution
view release on metacpan or search on metacpan
share/apache2/conf/httpd.conf.tt view on Meta::CPAN
#
# The following directives modify normal HTTP response behavior to
# handle known problems with browser implementations.
#
BrowserMatch "Mozilla/2" nokeepalive
BrowserMatch "MSIE 4\.0b2;" nokeepalive downgrade-1.0 force-response-1.0
BrowserMatch "RealPlayer 4\.0" force-response-1.0
BrowserMatch "Java/1\.0" force-response-1.0
BrowserMatch "JDK/1\.0" force-response-1.0
#
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Activiti/Rest/UserAgent.pm view on Meta::CPAN
has default_headers => (
is => 'ro',
isa => sub { array_ref($_[0]); },
default => sub { [["Accept","application/json; charset=UTF-8"]]; }
);
has keep_alive => (
is => 'ro',
isa => sub { is_integer($_[0]) && $_[0] >= 0 || die("keep_alive should be natural number"); },
lazy => 1,
default => sub { 1; }
);
#usage: request($params,$method)
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Affix.c view on Meta::CPAN
new_pin->managed = false;
new_pin->owner_sv = pin->owner_sv ? pin->owner_sv : ST(0);
SvREFCNT_inc(new_pin->owner_sv);
// We need to keep the type info alive. For now, copy it.
new_pin->type_arena = infix_arena_create(256);
new_pin->type = _copy_type_graph_to_arena(new_pin->type_arena, elem_type);
ST(0) = sv_2mortal(_new_pointer_obj(aTHX_ new_pin));
}
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Agent/TCLI/Package/Net/HTTP.pm view on Meta::CPAN
use Object::InsideOut qw(Agent::TCLI::Package::Base);
use POE;
use POE::Component::Client::HTTP;
use POE::Component::Client::Keepalive;
use HTTP::Request::Common qw(GET POST);
use Agent::TCLI::Command;
use Agent::TCLI::Parameter;
use Getopt::Lucid qw(:all);
lib/Agent/TCLI/Package/Net/HTTP.pm view on Meta::CPAN
# :Type('POE::Session');
=item poco_cm
A POE connection manager session.
B<cm> will only accept POE::Component::Client::Keepalive type values.
=cut
my @poco_cm :Field
:All('poco_cm')
:Type('POE::Component::Client::KeepaliveRaw' );
=item poco_http
The POE http client.
B<poco_http> will only accept POE::Component::Client::HTTP type values.
lib/Agent/TCLI/Package/Net/HTTP.pm view on Meta::CPAN
# There is only one command object per TCLI
$kernel->alias_set($self->name);
# Keep the cm session so we can shut it down
$self->set(\@poco_cm , POE::Component::Client::Keepalive->new(
max_per_host => 4, # defaults to 4
max_open => 128, # defaults to 128
keep_alive => 15, # defaults to 15
timeout => 120, # defaults to 120
));
$self->set(\@poco_http , POE::Component::Client::HTTP->spawn(
Agent => $self->user_agents,
view all matches for this distribution
view release on metacpan or search on metacpan
examples/keepalive.pl view on Meta::CPAN
#!/usr/bin/perl
##
# Keepalive.pl - demonstrates sustained connections with TCP transport.
# Steve Purkis <spurkis@engsoc.carleton.ca>
# October 24, 1998
##
use Agent;
view all matches for this distribution
view release on metacpan or search on metacpan
my $weak2 = $obj2;
weaken($weak2);
$w->add($obj1, $obj2);
# Both should still be alive (held by window + our strong refs)
ok(defined $weak1, "obj1 alive before eviction");
ok(defined $weak2, "obj2 alive before eviction");
# Drop our strong reference to obj1; window should be the only owner now
undef $obj1;
ok(defined $weak1, "obj1 still alive (held by window)");
# Add another item; obj1 should be evicted and slot cleared -> weak should drop
$w->add(bless({}, 'T::Obj'));
ok(!defined $weak1, "obj1 freed after eviction (slot cleared)");
# Now test clear() releases remaining references
undef $obj2; # leave window holding obj2
ok(defined $weak2, "obj2 still alive (held by window)");
$w->clear;
ok(!defined $weak2, "obj2 freed after clear (slots cleared)");
}
view all matches for this distribution
view release on metacpan or search on metacpan
corpus/alien_build_plugin_fetch_wget/record/old.json view on Meta::CPAN
{"-k --content-disposition -S http://localhost/corpus/alien_build_plugin_fetch_wget/dir/foo-1.01.tar":{"stderr":"--2021-05-12 00:10:35-- http://localhost/corpus/alien_build_plugin_fetch_wget/dir/foo-1.01.tar\nResolving localhost (localhost)... ::1, ...
view all matches for this distribution
view release on metacpan or search on metacpan
src/Source/LibPNG/libpng-manual.txt view on Meta::CPAN
It should be noted that versions of libpng later than 0.96 are not
distributed by the original libpng author, Guy Schalnat, nor by
Andreas Dilger, who had taken over from Guy during 1996 and 1997, and
distributed versions 0.89 through 0.96, but rather by another member
of the original PNG Group, Glenn Randers-Pehrson. Guy and Andreas are
still alive and well, but they have moved on to other things.
The old libpng functions png_read_init(), png_write_init(),
png_info_init(), png_read_destroy(), and png_write_destroy() have been
moved to PNG_INTERNAL in version 0.95 to discourage their use. These
functions will be removed from libpng version 1.4.0.
view all matches for this distribution
view release on metacpan or search on metacpan
src/fetchsrc.pl view on Meta::CPAN
my $local = File::Spec->catfile('src', $tgz);
my $url = "$download_base_url/libiconv/$tgz";
my $ua = LWP::UserAgent->new(
agent => "Alien::Iconv source downloader",
keep_alive => 1,
env_proxy => 1,
);
print "downloading...\n",
" from: $url\n",
" local: $local\n";
view all matches for this distribution
view release on metacpan or search on metacpan
libjit/ChangeLog view on Meta::CPAN
2006-07-05 Aleksey Demakov <ademakov@gmail.com>
* configure.in: make new register allocator the default.
* jit/jit-reg-alloc.c (is_register_alive, compute_spill_cost): fix
problem with destroying the end register of a long pair.
2006-07-03 Aleksey Demakov <ademakov@gmail.com>
* jit/jit-rules-x86.ins: add JIT_OP_LOW_WORD, JIT_OP_EXPAND_INT,
view all matches for this distribution
view release on metacpan or search on metacpan
src/fetchsrc.pl view on Meta::CPAN
$url = "$download_base_url/mecab/$tgz";
}
my $ua = LWP::UserAgent->new(
agent => "Alien::MeCab source downloader",
keep_alive => 1,
env_proxy => 1,
);
print "downloading...\n",
" from: $url\n",
" local: $local\n";
view all matches for this distribution
view release on metacpan or search on metacpan
t/01-simple.t view on Meta::CPAN
my $ap = Alien::Packages->new();
ok( $ap, "Instantiating" );
my @packages = $ap->list_packages();
# can't check result: Slackware, Gentoo, OpenBSD, MirBSD, IRIX, HP-UX, ...
ok( 1, "still alive after list_packages" );
if( @packages )
{
# for the author, to see if there is something
my %pkgtypes = map { $_->{PkgType} => $_ } @packages;
t/01-simple.t view on Meta::CPAN
my %perls = map { $_ => 1 } ( @perls, $perlbin );
@perls = keys %perls;
my @files = @perls;
$extensive_tests and push( @files, values %INC );
my %assoc_pkgs = $ap->list_fileowners( @files );
ok( 1, "still alive after list_fileowners" );
# can't check result, could be unsupported pkg type or wild installation (e.g. blead)
if( keys %assoc_pkgs )
{
# for the author, to see if there is something
foreach my $perl (@perls)
view all matches for this distribution
view release on metacpan or search on metacpan
src/subversion/CHANGES view on Meta::CPAN
(19 Apr 2010, from /branches/1.6.x)
http://svn.apache.org/repos/asf/subversion/tags/1.6.11
User-visible changes:
* fix for repositories mounted via NFS (issue #3501)
* enable TCP keep-alives in svnserve (r880552)
* tighten restrictions on revprops for 'svnadmin verify' (r904594)
* make ra_serf give better out-of-date information (issue #3561)
* improve error message upon connection failure with svn+ssh:// (r922516)
* allow 'svn log' on an uncommitted copy/move destination (r901752)
* make 'svnadmin hotcopy' copy the fsfs config file (r905303)
src/subversion/CHANGES view on Meta::CPAN
* improve BASH completion (r36450, -52, -70, -79, -538)
* always show tree conflicts with 'svn st' (issue #3382)
* improve correctness of 'svn mergeinfo' (issue #3126)
* decrease the amount of memory needed for large commits (r37894, -6)
* work around an APR buffer overflow seen by svnsync (r37622)
* ra_svn clients now use TCP keep-alives if available (issue #3347)
* improve 'svn merge' perf by reducing server contact (r37491, -593, -618)
* stop propagating self-referential mergeinfo in reintegrate merges (r37931)
* fix NLS detection where -liconv is required for bindtextdomain() (r37827)
* don't delete unversioned files with 'rm --keep-local' (r38015, -17, -19)
* bump apr and apr-util versions included in deps to latest. (r37941)
view all matches for this distribution
view release on metacpan or search on metacpan
share/swagger-ui-bundle.js.map view on Meta::CPAN
{"version":3,"sources":["webpack://SwaggerUIBundle/webpack/universalModuleDefinition","webpack://SwaggerUIBundle/webpack/bootstrap","webpack://SwaggerUIBundle/./node_modules/react/react.js","webpack://SwaggerUIBundle/./node_modules/immutable/dist/imm...
view all matches for this distribution
view release on metacpan or search on metacpan
src/win32/include/winapi/mstcpip.h view on Meta::CPAN
#ifndef _MSTCPIP_
#define _MSTCPIP_
#include <_mingw_unicode.h>
struct tcp_keepalive {
u_long onoff;
u_long keepalivetime;
u_long keepaliveinterval;
};
#define SIO_RCVALL _WSAIOW(IOC_VENDOR,1)
#define SIO_RCVALL_MCAST _WSAIOW(IOC_VENDOR,2)
#define SIO_RCVALL_IGMPMCAST _WSAIOW(IOC_VENDOR,3)
view all matches for this distribution
view release on metacpan or search on metacpan
share/vendor/js/jquery-1.10.2.js view on Meta::CPAN
return "script";
}
});
var xhrCallbacks, xhrSupported,
xhrId = 0,
// #5280: Internet Explorer will keep connections alive if we don't abort on unload
xhrOnUnloadAbort = window.ActiveXObject && function() {
// Abort all pending requests
var key;
for ( key in xhrCallbacks ) {
xhrCallbacks[ key ]( undefined, true );
view all matches for this distribution
view release on metacpan or search on metacpan
xgboost/dmlc-core/include/dmlc/array_view.h view on Meta::CPAN
namespace dmlc {
/*!
* \brief Read only data structure to reference continuous memory region of array.
* Provide unified view for vector, array and C style array.
* This data structure do not guarantee aliveness of referenced array.
*
* Make sure do not use array_view to record data in async function closures.
* Also do not use array_view to create reference to temporary data structure.
*
* \tparam ValueType The value
view all matches for this distribution
view release on metacpan or search on metacpan
include/boost/intrusive/detail/generic_hook.hpp view on Meta::CPAN
{};
template<class Hook>
void destructor_impl(Hook &hook, detail::link_dispatch<safe_link>)
{ //If this assertion raises, you might have destroyed an object
//while it was still inserted in a container that is alive.
//If so, remove the object from the container before destroying it.
(void)hook; BOOST_INTRUSIVE_SAFE_HOOK_DESTRUCTOR_ASSERT(!hook.is_linked());
}
template<class Hook>
view all matches for this distribution
view release on metacpan or search on metacpan
libcares/README.cares view on Meta::CPAN
This package is dubbed 'c-ares' since Daniel wanted this for use within the
curl project (hence the letter C) and it makes a nice pun. c-ares is not API
compatible with ares: a new name makes that more obvious to the public.
The original libares was distributed at
ftp://athena-dist.mit.edu:pub/ATHENA/ares (which seems to not be alive
anymore). A local copy of the original ares package is kept here:
https://c-ares.haxx.se/download/ares-1.1.1.tar.gz
view all matches for this distribution
view release on metacpan or search on metacpan
libuv/test/test-ip6-addr.c
libuv/test/test-ipc-heavy-traffic-deadlock-bug.c
libuv/test/test-ipc-send-recv.c
libuv/test/test-ipc.c
libuv/test/test-list.h
libuv/test/test-loop-alive.c
libuv/test/test-loop-close.c
libuv/test/test-loop-configure.c
libuv/test/test-loop-handles.c
libuv/test/test-loop-stop.c
libuv/test/test-loop-time.c
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Request.pm view on Meta::CPAN
$self->{'http_head'} = {
'Accept' => 'application/json,*/*;q=0.8,',
'Accept-Encoding' => 'deflate',
'Accept-Language' => 'zh-CN',
'Cache-Control' => 'no-cache',
'Connection' => 'keep-alive',
'DNT' => '1',
'Pragma' => 'no-cache',
'Upgrade-Insecure-Requests' => '1',
'User-Agent' => "perl-Aliyun-Request V:$VERSION"
};
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Crypt/RSA/Errorhandler.pm view on Meta::CPAN
package Foo;
use Crypt::RSA::Errorhandler;
@ISA = qw(Crypt::RSA::Errorhandler);
sub alive {
..
..
return
$self->error ("Awake, awake! Ring the alarum bell. \
Murther and treason!", $dagger)
lib/Crypt/RSA/Errorhandler.pm view on Meta::CPAN
package main;
use Foo;
my $foo = new Foo;
$foo->alive($king) or print $foo->errstr();
# prints "Awake, awake! ... "
=head1 DESCRIPTION
Crypt::RSA::Errorhandler encapsulates the error handling mechanism used
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Amazon/CloudFront/Thin.pm view on Meta::CPAN
}
sub _default_ua {
require LWP::UserAgent;
my $ua = LWP::UserAgent->new(
keep_alive => 10,
# requests_redirectable => [qw(GET HEAD DELETE PUT)]
);
$ua->timeout(10);
$ua->env_proxy;
return $ua;
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Amazon/DynamoDB/LWP.pm view on Meta::CPAN
my $status = join ' ', $resp->code, $resp->message;
return Future->new->fail($status, $resp, $req)
}
sub ua { shift->{ua} ||= LWP::UserAgent->new(keep_alive => 10,
agent => 'Amazon::DynamoDB/1.0',
timeout => 90,
); }
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Amazon/S3/Lite.pm view on Meta::CPAN
. 'AWS_SECRET_ACCESS_KEY environment variables, '
. 'or install Amazon::Credentials for IAM role support.';
}
########################################################################
# HTTP::Tiny instance - one per object, keep-alive enabled
########################################################################
sub _init_ua {
########################################################################
my ($self) = @_;
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Amazon/S3.pm view on Meta::CPAN
my $ua;
if ( $self->retry ) {
$ua = LWP::UserAgent::Determined->new(
keep_alive => $KEEP_ALIVE_CACHESIZE,
requests_redirectable => [qw(GET HEAD DELETE)],
);
$ua->timing( join $COMMA, map { 2**$_ } 0 .. $MAX_RETRIES );
}
else {
$ua = LWP::UserAgent->new(
keep_alive => $KEEP_ALIVE_CACHESIZE,
requests_redirectable => [qw(GET HEAD DELETE)],
);
}
$ua->timeout( $self->timeout );
view all matches for this distribution