view release on metacpan or search on metacpan
0.006
- Have a much longer timeout for HTTP response than general IO as
lighty will move the temporary file before responding.
0.005
- Bump timeout on read/write to 60 seconds for when machines are busy.
0.004
- Deal with servers which reply with HTTP 1.1 to 1.0 requests.
0.003
view release on metacpan or search on metacpan
lib/MogileFS/ConnectionPool.pm view on Meta::CPAN
my ($self, $ip, $port, $inflight_cb) = @_;
my $conn = $self->_conn_get($ip, $port);
if ($conn) {
$self->_conn_run($conn, $inflight_cb);
} else { # we're too busy right now, queue up
$self->enqueue($ip, $port, $inflight_cb);
}
}
# returns the total number of connections we have
view release on metacpan or search on metacpan
files/jquery/jquery-ui.custom.min.js view on Meta::CPAN
* http://jqueryui.com
* Includes: jquery.ui.core.js, jquery.ui.widget.js, jquery.ui.mouse.js, jquery.ui.position.js, jquery.ui.draggable.js, jquery.ui.droppable.js, jquery.ui.resizable.js, jquery.ui.selectable.js, jquery.ui.sortable.js, jquery.ui.accordion.js, jquery.ui.a...
* Copyright 2013 jQuery Foundation and other contributors Licensed MIT */
(function(e,t){function i(t,i){var a,n,r,o=t.nodeName.toLowerCase();return"area"===o?(a=t.parentNode,n=a.name,t.href&&n&&"map"===a.nodeName.toLowerCase()?(r=e("img[usemap=#"+n+"]")[0],!!r&&s(r)):!1):(/input|select|textarea|button|object/.test(o)?!t.d...
return isNaN(e)?d:e},f=p(u[0]),m=Math.max(f,p(u[1]||"")),f=s?Math.max(f,s.getFullYear()):f,m=n?Math.min(m,n.getFullYear()):m,t.yearshtml+="<select class='ui-datepicker-year' data-handler='selectYear' data-event='change'>";m>=f;f++)t.yearshtml+="<opti...
view release on metacpan or search on metacpan
_Deparsed_XSubs.pm view on Meta::CPAN
sub _login;
sub backup_from_dbh;
sub backup_from_file;
sub backup_to_dbh;
sub backup_to_file;
sub busy_timeout;
sub collation_needed;
sub commit;
sub commit_hook;
sub create_aggregate;
sub create_collation;
_Deparsed_XSubs.pm view on Meta::CPAN
sub set_authorizer;
sub sqlite_backup_from_dbh;
sub sqlite_backup_from_file;
sub sqlite_backup_to_dbh;
sub sqlite_backup_to_file;
sub sqlite_busy_timeout;
sub sqlite_collation_needed;
sub sqlite_commit_hook;
sub sqlite_create_aggregate;
sub sqlite_create_collation;
sub sqlite_create_function;
view release on metacpan or search on metacpan
t/samples/theguardian-rss20-media.xml view on Meta::CPAN
<dc:date>2018-05-06T05:00:12Z</dc:date>
</item>
<item>
<title>Good time girl: memories of a super groupie</title>
<link>https://www.theguardian.com/global/2018/may/06/good-time-girl-memories-of-a-super-groupie</link>
<description><p>Pamela Des Barres had the giants of rock’n’roll in the palm of her hand, as her candid memoir reveals</p><p>Barely 30 seconds in and Pamela Des Barres has not so much name-dropped as chucked her diary on th...
<category domain="https://www.theguardian.com/music/popandrock">Pop and rock</category>
<category domain="https://www.theguardian.com/music/music">Music</category>
<category domain="https://www.theguardian.com/culture/culture">Culture</category>
<category domain="https://www.theguardian.com/music/ledzeppelin">Led Zeppelin</category>
<category domain="https://www.theguardian.com/music/therollingstones">The Rolling Stones</category>
view release on metacpan or search on metacpan
lib/Mojo/JWT/Google.pm view on Meta::CPAN
scopes => [ '/my/scope/a', '/my/scope/b' ],
client_email => 'riche@cpan.org')->encode;
You can also get your information automatically from the .json you received
from Google. Your secret key is in that file, so it's best to keep it safe
somewhere. This will ease some busy work in configuring the object -- with
virtually the only things to do is determine the scopes and the user_as if you
need to impersonate.
my $gjwt = Mojo::JWT::Google
->new( from_json => '/my/secret.json',
view release on metacpan or search on metacpan
t/02_smtp.t view on Meta::CPAN
kill 15, $pid;
# 3
($pid, $sock, $host, $port) = Utils::make_smtp_server();
$smtp = Mojo::SMTP::Client->new(address => $host, port => $port, autodie => 1, tls_verify => 0);
syswrite($sock, '500 host.net is busy'.CRLF);
eval {
$smtp->send();
};
ok($e = $@, 'bad response');
isa_ok($e, 'Mojo::SMTP::Client::Exception::Response');
view release on metacpan or search on metacpan
lib/Mojo/Webqq.pm view on Meta::CPAN
has domain => 'w.qq.com';
has account => sub{ $ENV{MOJO_WEBQQ_ACCOUNT} || 'default'};
has start_time => time;
has pwd => undef;
has security => 0;
has mode => 'online'; #online|away|busy|silent|hidden|offline|callme,
has type => 'smartqq'; #smartqq
has login_type => 'qrlogin'; #qrlogin|login
has http_debug => sub{$ENV{MOJO_WEBQQ_HTTP_DEBUG} || 0 };
has ua_debug => sub{$_[0]->http_debug};
has ua_debug_req_body => sub{$_[0]->ua_debug};
view release on metacpan or search on metacpan
lib/MojoMojo/I18N/ca.po view on Meta::CPAN
#: root/base/edithelp/markdown.tt:17
msgid "bold"
msgstr "negreta"
#: root/base/page/edit.tt:59
msgid "busy spinner"
msgstr ""
#: root/base/page/search_inline.tt:35 root/base/page/view.tt:41 root/base/tag/recent.tt:26
msgid "by"
msgstr "per"
view release on metacpan or search on metacpan
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
return {
'reader' => undef,
'writer' => undef,
'socket' => undef,
'sock_no' => 0,
'is_busy' => 0,
'request' => undef,
'tx' => undef,
'exp_ts' => 0,
'tmp_response' => undef,
'reconnect_is_required' => 0,
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
sub _get_free_slot ($self) {
my $slot;
my %socks2slots = map { $_->{'sock_no'} => $_ }
grep { !$_->{'is_busy'} && $_->{'socket'} && !$_->{'reconnect_is_required'} }
$self->{'_conns'}->@*;
if (%socks2slots) {
local $!;
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
return $status;
}
sub _clear_slot ($self, $slot, $force = 0) {
$slot->{'is_busy'} = 0;
$slot->{'exp_ts'} = 0;
$slot->{'tx'} = undef;
$slot->{'request'} = undef;
$slot->{'tmp_response'} = undef;
if ($force) {
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
}
}
sub _mark_slot_as_broken($self, $slot) {
$slot->{'reconnect_is_required'} = 1;
$slot->{'is_busy'} = 1;
$slot->{'request'} //= Mojo::Message::Request->new();
$slot->{'tx'} //= Mojo::Transaction::HTTP->new(
'req' => $slot->{'request'},
'res' => Mojo::Message::Response->new()
);
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
$self->_mark_response_as_broken($slot, 524, $message);
}
sub _send_request ($self, $slot, $request, $timeout = undef) {
croak("slot is busy") if ($slot->{'is_busy'});
croak("request object is obligatory") if (!$request);
croak('request must be a descendant of Mojo::Message::Request package') if (!$request->isa('Mojo::Message::Request'));
my $required_scheme = $self->{'ssl'} ? 'https' : 'http';
my $url = $request->url();
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
my $h = $request->headers();
$h->host($self->{'host'}) if (! $h->host() );
$h->user_agent($default_ua_hdr) if (! $h->user_agent() );
$slot->{'request'} = $request;
$slot->{'is_busy'} = 1;
$slot->{'exp_ts'} = ($timeout > 0) ? ( time() + $timeout ) : 0;
my $plain_request = $request->to_string();
if ($self->{'ssl'}) {
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
return;
}
sub _try_to_read ($self, $slot) {
return if $slot->{'tx'} || ! $slot->{'is_busy'};
my $reader = $slot->{'reader'};
my $response = $slot->{'tmp_response'} // Mojo::Message::Response->new();
$response->parse($_) while (<$reader>);
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
}
}
=head2 not_empty($self)
Returns 1 if there even one slot is busy or slot contains a not processed response.
Otherwise the method returns 0.
=cut
sub not_empty ($self) {
my $not_empty = scalar $self->{'_conns'}->@*;
for my $slot ($self->{'_conns'}->@*) {
$not_empty-- if !$slot->{'is_busy'} && !$slot->{'tx'};
}
return $not_empty ? 1 : 0;
}
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
sub _get_response_from_ready_slot ($self) {
my $tx;
my %socks2slots = map { $_->{'sock_no'} => $_ }
grep { ! $_->{'tx'} && ! $_->{'reconnect_is_required'} && $_->{'is_busy'} }
$self->{'_conns'}->@*;
if (%socks2slots) {
local $!;
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
for my $sock_no (keys %socks2slots) {
my $slot = $socks2slots{ $sock_no };
if ( $nfound && vec($read_handles, $sock_no, 1) == 1 ) {
$self->_try_to_read($slot);
next if ! $slot->{'tx'};
next if ! $slot->{'is_busy'};
$tx = $slot->{'tx'};
} else {
if (!$slot->{'tx'} && ($slot->{'exp_ts'} && time() > $slot->{'exp_ts'})) {
$self->_mark_response_as_timeouted($slot);
$tx = $slot->{'tx'};
lib/MojoX/HTTP/Async.pm view on Meta::CPAN
=cut
sub DESTROY ($self) {
my $in_use = 0;
while ( my $slot = shift($self->{'_conns'}->@*) ) {
$in_use++ if ($slot->{'is_busy'});
$slot->{'socket'}->close() if ($slot->{'socket'});
}
warn ref($self) ." object destroyed but still in use" if $in_use;
}
view release on metacpan or search on metacpan
t/assets/js/DataTables-1.9.4/media/js/jquery.dataTables.js view on Meta::CPAN
*
* @example
* $(document).ready( function() {
* $('#example').dataTable( {
* "oLanguage": {
* "sProcessing": "DataTables is currently busy"
* }
* } );
* } );
*/
"sProcessing": "Processing...",
view release on metacpan or search on metacpan
lib/Mojolicious/Plugin/ServerStatus.pm view on Meta::CPAN
}
if ( my $scoreboard = $self->{__scoreboard} ) {
my $stats = $scoreboard->read_all();
my $idle = 0;
my $busy = 0;
my @all_workers = ();
my $parent_pid = getppid;
if ( $self->skip_ps_command ) {
lib/Mojolicious/Plugin/ServerStatus.pm view on Meta::CPAN
my $pstatus = eval {
$JSON->decode($json || '{}');
};
$pstatus ||= {};
if ( $pstatus->{status} && $pstatus->{status} eq 'A' ) {
$busy++;
}
else {
$idle++;
}
lib/Mojolicious/Plugin/ServerStatus.pm view on Meta::CPAN
$process_status .= sprintf "%s\n",
join(" ", map { defined $pstatus->{$_} ? $pstatus->{$_} : '' } qw/pid status remote_addr host user method uri protocol ss/);
push @process_status, $pstatus;
}
$body .= <<EOF;
BusyWorkers: $busy
IdleWorkers: $idle
--
pid status remote_addr host user method uri protocol ss
$process_status
EOF
chomp $body;
$status{BusyWorkers} = $busy;
$status{IdleWorkers} = $idle;
$status{stats} = \@process_status;
}
else {
$body .= "WARN: Scoreboard has been disabled\n";
view release on metacpan or search on metacpan
lib/Mojolicious/Plugin/SpectreCss/asset/public/spectre/0.5.3/core.min.css view on Meta::CPAN
/*! Spectre.css v0.5.3 | MIT License | github.com/picturepan2/spectre */html{font-family:sans-serif;-webkit-text-size-adjust:100%;-ms-text-size-adjust:100%}body{margin:0}article,aside,footer,header,nav,section{display:block}h1{font-size:2em;margin:.6...
view release on metacpan or search on metacpan
share/resources/public/swagger-ui/swagger-ui-bundle.js view on Meta::CPAN
*
* Copyright (c) Facebook, Inc. and its affiliates.
*
* This source code is licensed under the MIT license found in the
* LICENSE file in the root directory of this source tree.
*/Object.defineProperty(t,"__esModule",{value:!0});var r="function"==typeof Symbol&&Symbol.for,o=r?Symbol.for("react.element"):60103,i=r?Symbol.for("react.portal"):60106,a=r?Symbol.for("react.fragment"):60107,s=r?Symbol.for("react.strict_mode"):6010...
/*!
* https://github.com/Starcounter-Jack/JSON-Patch
* (c) 2017 Joachim Wester
* MIT license
*/
view release on metacpan or search on metacpan
t/020_simple.t view on Meta::CPAN
is $self->vparam( str4 => qr{^(www)$}, default => 'abc' ),
'abc', 'str4 default';
is $self->verror('str4'), 0, 'str4 no error';
is $self->vparam(
str5 => qr{^(online_)?(all|free|busy|auto)$},
default => 'all',
), 'auto', 'str5 regexp';
is $self->verror('str5'), 0,
'str5 no error, set default';
view release on metacpan or search on metacpan
lib/Monitoring/GLPlugin.pm view on Meta::CPAN
sub schimpf {
my ($self) = @_;
printf "statefilesdir %s is not writable.\nYou didn't run this plugin as root, didn't you?\n", $self->statefilesdir();
}
# $self->protect_value('1.1-flat_index', 'cpu_busy', 'percent');
sub protect_value {
my ($self, $ident, $key, $validfunc) = @_;
if (ref($validfunc) ne "CODE" && $validfunc eq "percent") {
$validfunc = sub {
my $value = shift;
view release on metacpan or search on metacpan
lib/MooX/Async/Console/TCP.pm view on Meta::CPAN
use namespace::clean '__line';
sub __on_line {
my $self = shift;
my $client = shift;
my ($cmd, @args) = split ' ', shift;
my $state; # for now - false nothing, true busy;
die 'One command at a time for now' if $state;
$state++;
my $quit;
$self->_logger->debugf('Received command %s %s', $cmd, \@args);
view release on metacpan or search on metacpan
lib/MooX/Types/CLike.pm view on Meta::CPAN
=head2 Internet Relay Chat
You can get live help by using IRC ( Internet Relay Chat ). If you don't know what IRC is,
please read this excellent guide: L<http://en.wikipedia.org/wiki/Internet_Relay_Chat>. Please
be courteous and patient when talking to us, as we might be busy or sleeping! You can join
those networks/channels and get help:
=over 4
=item *
view release on metacpan or search on metacpan
lib/Moonshine/Element.pm view on Meta::CPAN
headers height hidden high href hreflang http_equiv icon id integrity ismap itemprop keytype
kind label lang language list loop low manifest max maxlength media method min multiple muted
name novalidate open optimum pattern ping placeholder poster preload radiogroup readonly rel
required reversed rows rowspan sandbox scope scoped seamless selected shape size sizes span
spellcheck src srcdoc srclang srcset start step style summary tabindex target title type usemap
value width wrap aria_autocomplete aria_atomic aria_busy aria_checked aria_controls
aria_disabled aria_dropeffect aria_flowto aria_grabbed aria_expanded aria_haspopup aria_hidden
aria_invalid aria_label aria_labelledby aria_live aria_level aria_multiline aria_multiselectable
aria_orientation aria_pressed aria_readonly aria_required aria_selected aria_sort aria_valuemax
aria_valuemin aria_valuenow aria_valuetext aria_owns aria_relevant role data_toggle data_target
aria_describedby onkeyup onkeydown onclick onchange/;
view release on metacpan or search on metacpan
t/160-valid_attributes_for_tag.t view on Meta::CPAN
'onwaiting',
'spellcheck',
'aria-activedescendant',
'aria-atomic',
'aria-autocomplete',
'aria-busy',
'aria-checked',
'aria-controls',
'aria-describedby',
'aria-disabled',
'aria-dropeffect',
t/160-valid_attributes_for_tag.t view on Meta::CPAN
'onwaiting',
'spellcheck',
'aria-activedescendant',
'aria-atomic',
'aria-autocomplete',
'aria-busy',
'aria-checked',
'aria-controls',
'aria-describedby',
'aria-disabled',
'aria-dropeffect',
view release on metacpan or search on metacpan
lib/MozRepl/RemoteObject.pm view on Meta::CPAN
Note that you cannot block the execution of Javascript that way.
The Javascript code has long continued running when you receive
the event.
Currently, only busy-waiting is implemented and there is no
way yet for Javascript to tell Perl it has something to say.
So in absence of a real mainloop, you have to call
$repl->poll;
view release on metacpan or search on metacpan
lib/Mozilla/Mechanize/GUITester.pm view on Meta::CPAN
}
}
$self->_N("_countdown_requests finish");
}
sub _wait_while_busy {
my $self = shift;
$self->_countdown_requests;
$self->{$_} = undef for qw(forms cur_form links images);
return 1;
}
view release on metacpan or search on metacpan
lib/Mozilla/Mechanize.pm view on Meta::CPAN
# XXX: how to add headers?
# $agent->navigate({ URL => $uri->as_string,
# Headers => $self->_extra_headers($uri) });
$agent->embedded->load_url($uri->as_string);
$self->_wait_while_busy;
}
=head2 $moz->reload()
Reload the page.
=cut
sub reload {
$_[0]->agent->embedded->reload('reloadnormal');
$_[0]->_wait_while_busy;
}
=head2 $moz->back()
Go back a page in the browser history.
=cut
sub back {
$_[0]->agent->embedded->go_back;
$_[0]->_wait_while_busy;
}
=head1 STATUS METHODS
=head2 $moz->success
lib/Mozilla/Mechanize.pm view on Meta::CPAN
$self->{images} = \@images;
return wantarray ? @{ $self->{forms} } : $self->{forms};
}
}
=head2 $self->_wait_while_busy()
This adds a "single-shot" idle callback that does Gtk2->main_quit,
then does Gtk2->main. The result is that whenever the UI becomes idle
it will exit the main loop. Thanks to muppet for the idea.
This is repeated until the net_stop event fires, indicating that
the new page has finished loading. (Note therefore that you can only
call this when you expect a new page to load.)
=cut
sub _wait_while_busy {
my $self = shift;
my $agent = $self->agent;
do {
Glib::Idle->add(sub {
view release on metacpan or search on metacpan
test_data/README view on Meta::CPAN
might be relevant. You can of course also send patches to
actual bugs.
Mention the word "XBase" in the Subject line, otherwise your
post will probably just slip through my 1 MB daily email load
without even being read. Please note that I'm _very_ busy, so
try to help me to help you by using the latest version of the
module, minimalizing the script code that causes you problems,
providing me with tiny sample of datafile, anything that might
be related. Detailed description and small examples are the
best.
view release on metacpan or search on metacpan
htdocs/src-min/mode-php.js view on Meta::CPAN
define("ace/mode/doc_comment_highlight_rules",["require","exports","module","ace/lib/oop","ace/mode/text_highlight_rules"],function(e,t,n){"use strict";var r=e("../lib/oop"),i=e("./text_highlight_rules").TextHighlightRules,s=function(){this.$rules={s...
view release on metacpan or search on metacpan
bin/myriad-migrate-rpc-streams.pl view on Meta::CPAN
try {
await $redis->xgroup('CREATE', $old_rpc_stream, 'rpc_migration', 0);
} catch ($e) {
if ($e =~ /BUSYGROUP/) {
$log->fatalf('Got a busygroup for stream %s are you running another migration?', $old_rpc_stream);
} else {
$log->fatalf('Failed to create group for stream %s - %s', $old_rpc_stream, $e);
}
exit 1;
}
view release on metacpan or search on metacpan
lib/Net/MythTV/Fuse/Recordings.pm view on Meta::CPAN
-13 => "Other recording",
-12 => "Other tuning",
-11 => "Backend not running",
-10 => "The showing is being tuned",
-9 => "The recorder failed to record",
-8 => "The tuner card was busy",
-7 => "Low disk space",
-6 => "Manual cancel",
-5 => "Missed recording",
-4 => "Aborted",
-3 => "Recorded",
view release on metacpan or search on metacpan
```
For more detailed information on the available methods and options, please refer to the individual documentation of the NBI::Job and NBI::Opts classes.
Automatic tests check the functionality of the classes and methods even when Slurm is not available. From the cluster where NBI::Slurm
will be used, it's possible to run `prove -lv xt/hpc-*.t` to test the ability to submit jobs (but some tests might fail for busy partitions, drain, etc).
## Author
[NBI::Slurm](https://metacpan.org/dist/NBI-Slurm) is written by [Andrea Telatin](https://telatin.github.io)
view release on metacpan or search on metacpan
my $op = $job->operation;
if ($opts{'x'}) {
print " operation=\"$op\" elapsed=\"".dispInterval($job->elapsedTime)."\"";
}
else {
print " $op ".dispInterval($job->busy);
}
}
if ($state ne "Q") {
if (defined($job->filesWritten)) {
view release on metacpan or search on metacpan
the following values:
$Net::NIS::ERR_ACCESS Access violation
$Net::NIS::ERR_BADARGS Args to function are bad
$Net::NIS::ERR_BADDB yp data base is bad
$Net::NIS::ERR_BUSY Database is busy
$Net::NIS::ERR_DOMAIN Can't bind to a server which serves this domain
$Net::NIS::ERR_KEY No such key in map
$Net::NIS::ERR_MAP No such map in server's domain
$Net::NIS::ERR_NODOM Local domain name not set
$Net::NIS::ERR_PMAP Can't communicate with portmapper