view release on metacpan or search on metacpan
lib/App/RabbitTail.pm view on Meta::CPAN
my $self = shift;
my $tail_started = 0;
while (1) {
$self->_clear_cv;
$self->_ch; # Build channel before going into the event loop
$self->tail # Setup all the timers
unless $tail_started++;
$self->_cv->recv; # Enter event loop. We will leave here if channel dies..
}
}
view release on metacpan or search on metacpan
'connection' => 'keep-alive',
'accept-ranges' => 'bytes',
'content-length' => '7840',
'x-xss-protection' => '1; mode=block',
'expires' => 'Thu, 07 Jun 2018 20:20:24 GMT',
'x-timer' => 'S1528402525.672062,VS0,VE96',
'content-security-policy' => 'default-src \'none\'; style-src \'unsafe-inline\'; sandbox',
'x-cache' => 'MISS',
'x-fastly-request-id' => 'a46d6b434a76506ced7a5caf7ef0ff54e70b6569',
'via' => '1.1 varnish',
'content-type' => 'text/plain; charset=utf-8',
view release on metacpan or search on metacpan
lib/App/Repository.pm view on Meta::CPAN
}
return 0;
}
#############################################################################
# _get_timer()
#############################################################################
sub _get_timer {
my ($self) = @_;
my ($seconds_start, $microseconds_start) = gettimeofday;
my $timer = { seconds_start => $seconds_start, microseconds_start => $microseconds_start };
return($timer);
}
#############################################################################
# _read_timer()
#############################################################################
sub _read_timer {
my ($self, $timer, $reset) = @_;
my ($seconds_finish, $microseconds_finish) = gettimeofday;
my $seconds_elapsed = $seconds_finish - $timer->{seconds_start};
my $microseconds_elapsed = $microseconds_finish - $timer->{microseconds_start};
if ($microseconds_elapsed < 0) {
$microseconds_elapsed += 1000000;
$seconds_elapsed -= 1;
}
my $time_elapsed = sprintf("%d.%06d", $seconds_elapsed, $microseconds_elapsed);
if (defined $reset) {
# store values. don't reset the timer.
if ($reset == 0) {
$timer->{seconds_start} = $seconds_finish;
$timer->{microseconds_start} = $microseconds_finish;
delete $timer->{time_elapsed};
}
# reset the timer to be ready for another reading.
elsif ($reset) {
$timer->{seconds_finish} = $seconds_finish;
$timer->{microseconds_finish} = $microseconds_finish;
$timer->{time_elapsed} = $time_elapsed;
}
}
return($time_elapsed);
}
view release on metacpan or search on metacpan
lib/App/RoboBot/Network/Slack.pm view on Meta::CPAN
$self->client(AnyEvent::SlackRTM->new(
$self->token
));
$self->client->on( 'hello' => sub {
$self->keepalive(AnyEvent->timer(
interval => 60,
cb => sub { $self->reconnect if $self->client->finished }
));
});
view release on metacpan or search on metacpan
t/data/04-arista.input view on Meta::CPAN
[?1h=
BGP neighbor is 192.0.2.12, remote AS 65000, internal link
BGP version 4, remote router ID 0.0.0.0, VRF default
Last read never, last write never
Hold time is 0, keepalive interval is 0 seconds
Configured hold time is 180, keepalive interval is 60 seconds
Hold timer is inactive
Keepalive timer is inactive
Connect timer is active, time left: 00:00:21
Connection interval is 20 seconds
Failed connection attempts is 88804
Idle-restart timer is inactive
BGP state is Connect
Number of transitions to established: 0
Last state was Active
Last event was ConnectRetry
Last sent socket-error:Connect (Network is unreachable), Last time 23d14h, First time 202d21 h, Repeats 8
Types of communities advertised: none
Neighbor Capabilities:
Restart timer is inactive
End of rib timer is inactive
AIGP attribute send and receive for IPv4 Unicast are enabled
AIGP attribute send and receive for IPv6 Unicast are enabled
Message Statistics:
Sent Rcvd
Opens: 0 0
t/data/04-arista.input view on Meta::CPAN
Description: "Raku BGP Test Session"
BGP version 4, remote router ID 0.0.0.0, VRF default
Last read never, last write never
Hold time is 0, keepalive interval is 0 seconds
Configured hold time is 180, keepalive interval is 60 seconds
Hold timer is inactive
Keepalive timer is inactive
Connect timer is active, time left: 00:00:04
Connection interval is 20 seconds
Failed connection attempts is 88813
Idle-restart timer is inactive
BGP state is Connect
Number of transitions to established: 0
Last state was Active
Last event was ConnectRetry
Last sent socket-error:Connect (Network is unreachable), Last time 23d14h, First time 202d21 h, Repeats 7
Types of communities advertised: none
Neighbor is a route reflector client
Neighbor Capabilities:
Restart timer is inactive
End of rib timer is inactive
AIGP attribute send and receive for IPv4 Unicast are enabled
AIGP attribute send and receive for IPv6 Unicast are enabled
Message Statistics:
Sent Rcvd
Opens: 0 0
t/data/04-arista.input view on Meta::CPAN
BGP neighbor is 192.0.2.3, remote AS 65000, internal link
BGP version 4, remote router ID 192.0.2.3, VRF default
Last read 00:00:20, last write 00:00:46
Hold time is 180, keepalive interval is 60 seconds
Configured hold time is 180, keepalive interval is 60 seconds
Hold timer is active, time left: 00:01:39
Keepalive timer is active, time left: 00:00:06
Connect timer is inactive
Idle-restart timer is inactive
BGP state is Established, up for 52d04h
Number of transitions to established: 5
Last state was OpenConfirm
Last event was RecvKeepAlive
Last sent notification:Hold Timer Expired Error/None, Last time 52d04h, First time 197d21h, Repeats 3
t/data/04-arista.input view on Meta::CPAN
Enhanced route refresh: advertised
Send End-of-RIB messages: advertised
Additional-paths recv capability:
IPv4 Unicast: advertised
Additional-paths send capability:
Restart timer is inactive
End of rib timer is inactive
IPv4 Unicast End-of-RIB received: No
AIGP attribute send and receive for IPv4 Unicast are enabled
AIGP attribute send and receive for IPv6 Unicast are enabled
Message Statistics:
Sent Rcvd
t/data/04-arista.input view on Meta::CPAN
BGP neighbor is 192.0.2.17, remote AS 65000, internal link
BGP version 4, remote router ID 192.0.2.17, VRF default
Last read 00:00:02, last write 00:00:15
Hold time is 180, keepalive interval is 60 seconds
Configured hold time is 180, keepalive interval is 60 seconds
Hold timer is active, time left: 00:01:04
Keepalive timer is active, time left: 00:00:40
Connect timer is inactive
Idle-restart timer is inactive
BGP state is Established, up for 23d14h
Number of transitions to established: 4
Last state was OpenConfirm
Last event was RecvKeepAlive
Last sent socket-error:Connect (Network is unreachable), Last time 23d14h, First time 113d20 h, Repeats 5
t/data/04-arista.input view on Meta::CPAN
Enhanced route refresh: advertised
Send End-of-RIB messages: advertised
Additional-paths recv capability:
IPv4 Unicast: advertised
Additional-paths send capability:
Restart timer is inactive
End of rib timer is inactive
IPv4 Unicast End-of-RIB received: No
AIGP attribute send and receive for IPv4 Unicast are enabled
AIGP attribute send and receive for IPv6 Unicast are enabled
[3m --More-- [23m[K
[K Message Statistics:
Sent Rcvd
view release on metacpan or search on metacpan
script/prevent-screensaver-activated view on Meta::CPAN
read_env => 0,
);
$cmdline->run;
# ABSTRACT: Prevent screensaver from being activated by resetting idle timer
# PODNAME: prevent-screensaver-activated
__END__
=pod
=encoding UTF-8
=head1 NAME
prevent-screensaver-activated - Prevent screensaver from being activated by resetting idle timer
=head1 VERSION
This document describes version 0.010 of prevent-screensaver-activated (from Perl distribution App-ScreensaverUtils), released on 2020-11-22.
view release on metacpan or search on metacpan
lib/App/Shotgun/Target/SFTP.pm view on Meta::CPAN
# the master told us to shutdown
event shutdown => sub {
my $self = shift;
# remove the timeout timer
$poe_kernel->delay( 'timeout_event' );
# tell poco-generic to shutdown
if ( defined $self->sftp ) {
# TODO ARGH poco-generic NEEDS TO SHUTDOWN NOW
lib/App/Shotgun/Target/SFTP.pm view on Meta::CPAN
],
# ( 'debug' => 1, 'error' => 'sftp_generic_error' ),
) );
# set a timer in case the password negotiation/whatever doesnt work
$poe_kernel->delay( 'timeout_event' => 120 );
# check for connection error
$self->sftp->error( { 'event' => 'sftp_connect' } );
lib/App/Shotgun/Target/SFTP.pm view on Meta::CPAN
}
event sftp_connect => sub {
my( $self, $response ) = @_;
# remove the timeout timer
$poe_kernel->delay( 'timeout_event' );
# TODO poco-generic sucks for not properly shutting down
return if ! defined $self->sftp;
view release on metacpan or search on metacpan
share/public/jquery-3.3.1.min.js view on Meta::CPAN
/*! jQuery v3.3.1 | (c) JS Foundation and other contributors | jquery.org/license */
!function(e,t){"use strict";"object"==typeof module&&"object"==typeof module.exports?module.exports=e.document?t(e,!0):function(e){if(!e.document)throw new Error("jQuery requires a window with a document");return t(e)}:t(e)}("undefined"!=typeof windo...
view release on metacpan or search on metacpan
socialcalc/simpleedit15.pl view on Meta::CPAN
}
// Additional formula functions
var funccache = {};
var functimer = null;
var funcquery = "";
SocialCalc.Formula.SocialtextFunction = function(fname, operand, foperand, sheet) {
var value1, t;
view release on metacpan or search on metacpan
share/res/js/jquery-2.0.1.min.js view on Meta::CPAN
/*! jQuery v2.0.1 | (c) 2005, 2013 jQuery Foundation, Inc. | jquery.org/license
//@ sourceMappingURL=jquery-2.0.1.min.map
*/
(function(e,undefined){var t,n,r=typeof undefined,i=e.location,o=e.document,s=o.documentElement,a=e.jQuery,u=e.$,l={},c=[],f="2.0.1",p=c.concat,h=c.push,d=c.slice,g=c.indexOf,m=l.toString,y=l.hasOwnProperty,v=f.trim,x=function(e,n){return new x.fn.in...
},_queueHooks:function(e,t){var n=t+"queueHooks";return H.get(e,n)||H.access(e,n,{empty:x.Callbacks("once memory").add(function(){H.remove(e,[t+"queue",n])})})}}),x.fn.extend({queue:function(e,t){var n=2;return"string"!=typeof e&&(t=e,e="fx",n--),n>a...
}});var Xt,Ut,Yt=x.now(),Vt=/\?/,Gt=/#.*$/,Jt=/([?&])_=[^&]*/,Qt=/^(.*?):[ \t]*([^\r\n]*)$/gm,Kt=/^(?:about|app|app-storage|.+-extension|file|res|widget):$/,Zt=/^(?:GET|HEAD)$/,en=/^\/\//,tn=/^([\w.+-]+:)(?:\/\/([^\/?#:]*)(?::(\d+)|)|)/,nn=x.fn.load,...
view release on metacpan or search on metacpan
[Major]
* First public release
1.1.0 2014-07-24
[Minor]
* Script can be used as a timer with new `--run` option
* Added `--help` option
1.2.0 2014-09-09
[Minor]
* Added link to App::stopw in POD
view release on metacpan or search on metacpan
lib/App/SuperviseMe.pm view on Meta::CPAN
sub _restart_cmd {
my ($self, $cmd) = @_;
$self->_progress("Restarting cmd '@{$cmd->{cmd}}' in 1 second");
my $t;
$t = AE::timer 1, 0, sub { $self->_start_cmd($cmd); undef $t };
}
sub _signal_all_cmds {
my ($self, $signal, $cv) = @_;
$self->_debug("Received signal $signal");
view release on metacpan or search on metacpan
lib/App/Sv.pm view on Meta::CPAN
$svc->{pid} = $pid;
$svc->{watcher} = AE::child $pid, sub {
$self->_child_exited($svc, @_);
};
$svc->{start_ts} = time;
my $t; $t = AE::timer $svc->{start_wait}, 0, sub {
$self->_check_svc_up($svc);
undef $t;
};
}
lib/App/Sv.pm view on Meta::CPAN
return;
}
my $debug = $self->{log}->logger(8);
$svc->{state} = 'restart';
$debug->("Restarting '$svc->{name}' in $svc->{restart_delay} seconds");
my $t; $t = AE::timer $svc->{restart_delay}, 0, sub {
$self->_start_svc($svc);
undef $t;
};
}
lib/App/Sv.pm view on Meta::CPAN
my ($self, $svc) = @_;
$svc->{state} = 'stop';
my $st = $self->_signal_svc($svc, 'TERM');
if ($svc->{stop_wait} && $svc->{stop_wait} > 0) {
my $t; $t = AE::timer $svc->{stop_wait}, 0, sub {
$self->_check_svc_down($svc);
undef $t;
};
}
view release on metacpan or search on metacpan
local/lib/perl5/Module/ScanDeps.pm view on Meta::CPAN
}
return 'pod/perldiag.pod';
},
'Email/Send.pm' => 'sub',
'Event.pm' => [ map "Event/$_.pm", qw(idle io signal timer var)],
'ExtUtils/MakeMaker.pm' => sub {
grep /\bMM_/, _glob_in_inc('ExtUtils', 1);
},
'File/Basename.pm' => [qw( re.pm )],
'File/BOM.pm' => [qw( Encode/Unicode.pm )],
view release on metacpan or search on metacpan
lib/App/TeleGramma/Plugin/Core/Timer.pm view on Meta::CPAN
package App::TeleGramma::Plugin::Core::Timer;
$App::TeleGramma::Plugin::Core::Timer::VERSION = '0.14';
# ABSTRACT: TeleGramma plugin to set timers
use Mojo::Base 'App::TeleGramma::Plugin::Base';
use App::TeleGramma::BotAction::Listen;
use App::TeleGramma::Constants qw/:const/;
use Time::Duration::Parse qw/parse_duration/;
sub synopsis {
"Set timers for a future reminder"
}
sub default_config {
my $self = shift;
return { };
}
sub register {
my $self = shift;
my $timer_help = App::TeleGramma::BotAction::Listen->new(
command => qr{/timer}i,
response => sub { $self->timer_help(@_) }
);
my $timer_set_exact = App::TeleGramma::BotAction::Listen->new(
command => qr{/timer\s(.*)}i,
response => sub { $self->timer_set(@_) }
);
return ($timer_set_exact, $timer_help);
}
sub timer_help {
my $self = shift;
my $msg = shift;
$self->reply_to($msg, "examples: /timer remind me to weed and feed in 3 hours");
return PLUGIN_RESPONDED_LAST;
}
sub timer_set {
my $self = shift;
my $msg = shift;
my $text = $msg->text;
my ($request) = ($text =~ m{/timer\s+(.*)}i);
# remove some common prefixes from the request
$request =~ s/^remind me to//;
$request =~ s/^remind me//;
$request =~ s/^tell me to//;
# try to parse the thing, starting at the first number
my ($timer_text, $duration_text) = ($request =~ /^\s*(.+)\s+in\s+(\d.*)/);
if (! $duration_text) {
$self->reply_to($msg, "Sorry, I can't work out when you mean from '$text'");
return PLUGIN_RESPONDED_LAST;
}
lib/App/TeleGramma/Plugin/Core/Timer.pm view on Meta::CPAN
if ($@ || ! $duration) {
$self->reply_to($msg, "Sorry, I can't work out when you mean from '$duration_text'");
return PLUGIN_RESPONDED_LAST;
}
Mojo::IOLoop->timer($duration => sub {
my $loop = shift;
my $message = "Hey \@" . $msg->from->username . ", this is your reminder to $timer_text";
$self->reply_to($msg, $message);
});
$self->reply_to($msg, "Will remind you '$timer_text' in $duration_text");
return PLUGIN_RESPONDED_LAST;
}
1;
lib/App/TeleGramma/Plugin/Core/Timer.pm view on Meta::CPAN
=encoding UTF-8
=head1 NAME
App::TeleGramma::Plugin::Core::Timer - TeleGramma plugin to set timers
=head1 VERSION
version 0.14
view release on metacpan or search on metacpan
templates/perl/timer.pl view on Meta::CPAN
{
my $start;
my $previous;
sub timer {
my ($msg) = @_;
my $time = `/tmp/iwills/perl/bin/perl -I/home/isdtc/iwills/lib -MTime::HiRes=time -e 'print time'`;
$start ||= $time;
$previous ||= $time;
view release on metacpan or search on metacpan
bin/templer view on Meta::CPAN
#
# Record the start time.
#
my $timer = Templer::Timer->new();
#
# Build/rebuild the site.
#
bin/templer view on Meta::CPAN
#
# All done.
#
my $duration = $timer->elapsed();
print "\nAll done: $rebuilt page(s) updated in $duration.\n"
unless ( $CONFIG{ 'quiet' } );
exit(0);
view release on metacpan or search on metacpan
lib/App/Test/Tapat.pm view on Meta::CPAN
$self->test_name($file) || confess "Not sure how to assign filename.";
}
=head2 parsetest
This is where the TAP from your test gets parsed. A timer is created here as
well.
=cut
sub parsetest {
lib/App/Test/Tapat.pm view on Meta::CPAN
my $planned = 0;
my $aggregate = TAP::Parser::Aggregator->new;
# Create parser object
my $parser = TAP::Parser->new( { source => $file } );
$aggregate->start(); # start timer
$aggregate->add($file, $parser);
while ( my $result = $parser->next ) {
my $out = $result->as_string;
print "$out\n";
if ($result->is_plan) {
$planned = $result->tests_planned;
}
}
$aggregate->stop(); # stop timer
my $elapsed = $aggregate->elapsed_timestr();
my $failed = $parser->failed;
my $passed = $parser->passed;
view release on metacpan or search on metacpan
lib/App/TestOnTap/Args.pm view on Meta::CPAN
define => {}, # arbitrary key=value defines
skip => undef, # no skip filter
include => undef, # no include filter
jobs => 1, # run only one job at a time (no parallelism)
order => undef, # have no particular strategy for test order
timer => 0, # don't show timing output
workdirectory => undef, # explicit directory to use
savedirectory => undef, # don't save results (unless -archive is used)
archive => 0, # don't save results as archive
v => 0, # don't let through output from tests
harness => 1, # use the normal test harness
lib/App/TestOnTap/Args.pm view on Meta::CPAN
'define|D=s%',
'skip=s',
'include=s',
'jobs=i',
'order=s',
'timer!',
'workdirectory=s',
'savedirectory=s',
'archive',
'v|verbose+',
'harness!',
lib/App/TestOnTap/Args.pm view on Meta::CPAN
pod2usage(-input => $argsPodInput, -message => "Failure parsing options:\n $@", -exitval => 255, -verbose => 0);
}
# simple copies
#
$self->{$_} = $rawOpts{$_} foreach (qw(v archive timer harness dryrun));
$self->{defines} = $rawOpts{define};
# help with the hidden flags...
#
lib/App/TestOnTap/Args.pm view on Meta::CPAN
sub getTimer
{
my $self = shift;
return $self->{timer};
}
sub getArchive
{
my $self = shift;
view release on metacpan or search on metacpan
lib/App/TimeTracker/Gtk2TrayIcon.pm view on Meta::CPAN
my $window = Gtk2::TrayIcon->new(__PACKAGE__);
my $eventbox = Gtk2::EventBox->new;
$eventbox->add($img);
my $current;
my $t = AnyEvent->timer(
after => 0,
interval => 5,
cb => sub {
my $task =
App::TimeTracker::Data::Task->current($storage_location);
lib/App/TimeTracker/Gtk2TrayIcon.pm view on Meta::CPAN
'other', 'none', $current );
$dialog->set_decorated(0);
$dialog->set_gravity('south-west');
my $t = AnyEvent->timer(
after => 5,
cb => sub {
$dialog->destroy;
} );
my $retval = $dialog->run;
view release on metacpan or search on metacpan
lib/App/TimelogTxt/Manual.pod view on Meta::CPAN
=back
I decided that this would be a better basis for a new time logging program than
some binary format. So I wrote a quickie Perl script to allow me to start and
stop task timers and to generate simple reports.
As I used the program, I found other commands and reports that could be useful.
In the end, it was obvious that this tool needed to be cleaned up a re-written.
This module is the result of that rewrite.
view release on metacpan or search on metacpan
lib/App/Timer.pm view on Meta::CPAN
I found somewhat similar work done in L<Timer::Runtime>. The only issue
is that it has dependency on a non-core module L<Time::Elapse>.
=head1 SYNOPSIS
To get the timer enable for your command line tool, just add the line
below at the top of the script and you are good to go.
use App::Timer;
Or if you don't want to pollute your script then you can do this too.
lib/App/Timer.pm view on Meta::CPAN
L<Timer::Runtime>
=head1 BUGS
Please report any bugs or feature requests to C<bug-app-timer at rt.cpan.org>,
or through the web interface at L<http://rt.cpan.org/NoAuth/ReportBug.html?Queue=App-Timer>.
I will be notified and then you'll automatically be notified of progress on your
bug as I make changes.
=head1 SUPPORT
view release on metacpan or search on metacpan
lib/App/Timestamper/WithElapsed.pm view on Meta::CPAN
}
my $last_line_time = time();
my $init_time = $self->_from_start ? ( $last_line_time + 0 ) : 0;
STDOUT->autoflush(1);
my $timer = IO::Async::Timer::Periodic->new(
interval => 0.1,
on_tick => scalar(
$self->_absolute()
? sub {
lib/App/Timestamper/WithElapsed.pm view on Meta::CPAN
return 0;
}
);
$loop->add($stream);
$timer->start();
$loop->add($timer);
$loop->run();
return;
}
view release on metacpan or search on metacpan
lib/App/Toodledo/TaskRole.pm view on Meta::CPAN
has status => ( is => 'rw', isa => 'Int' );
has length => ( is => 'rw', isa => 'Int' );
has priority => ( is => 'rw', isa => 'Int' );
has star => ( is => 'rw', isa => 'Int' );
has added => ( is => 'rw', isa => 'Int' );
has timer => ( is => 'rw', isa => 'Int' );
has timeron => ( is => 'rw', isa => 'Int' );
has note => ( is => 'rw', isa => 'Str' );
has meta => ( is => 'rw', isa => 'Str' );
no Moose;
lib/App/Toodledo/TaskRole.pm view on Meta::CPAN
=head2 star
=head2 added
=head2 timer
=head2 timeron
=head2 note
=head2 meta
view release on metacpan or search on metacpan
lib/App/USBKeyCopyCon.pm view on Meta::CPAN
if it is necessary to prompt for a password. This method handles the different
semantics required to pass environment variables through C<gksudo> and C<sudo>.
=head2 tick ( )
This timer event handler is used to take the child process exit status values
collected by the SIGCHLD handler and pass them to C<master_copy_finished> or
C<copy_finished> as appropriate.
=head2 update_key_progress ( udi, status )
view release on metacpan or search on metacpan
benchmark.pl view on Meta::CPAN
$script = $ARGV[0];
# declare array
my @data;
# start timer
$start = new Benchmark;
for ($x = 0; $x <= 100; $x++) {
$output = `perl ./$script`;
}
# end timer
$end = new Benchmark;
# calculate difference
$diff = timediff($end, $start);
view release on metacpan or search on metacpan
bin/bmkpasswd view on Meta::CPAN
chomp $pwd;
STDERR->print("\n");
}
my $timer = $bench ? [gettimeofday] : ();
if ($check) {
if ( passwdcmp($pwd, $check) ) {
print "Match\n", "$check\n";
} else {
bin/bmkpasswd view on Meta::CPAN
}
} else {
print mkpasswd($pwd, $type, $bcost, $strong)."\n";
}
if ($bench) {
my $interval = tv_interval($timer);
print " bench: $type, time: $interval\n";
}
__END__
=pod
bin/bmkpasswd view on Meta::CPAN
sha256 (requires recent libc or Crypt::Passwd::XS)
-w, --workcost=NUM Bcrypt work-cost factor; default 08.
Higher is slower. Should be a two-digit power of 2.
-c, --check=HASH Compare password against given HASH
-s, --strong Use strongly-random salt generation
-b, --benchmark Show timers; useful for comparing hash generation
--available List available methods (one per line)
--version Display version information and available methods
If PASSWD is missing, it is prompted for interactively.
view release on metacpan or search on metacpan
#print Dumper(\@args);
#print "lines before=\n";
#print Dumper(\@lines);
# Unusual inputs, namely /* within strings without
# a corresponding */ can cause huge delays so put a timer on this.
my $max_duration_sec = scalar(@lines)/1000.0; # est lines per second
$max_duration_sec = 1.0 if $max_duration_sec < 1;
#print "max_duration_sec=$max_duration_sec\n";
eval {
local $SIG{ALRM} = sub { die "alarm\n" };
view release on metacpan or search on metacpan
script/cpan-outdated-coro view on Meta::CPAN
my ( $sub, $name ) = @{$ref};
my $num = $num{$name};
### spawn: $name => $num
for my $x (1..$num) {
$cv->begin;
my $w;$w=AE::timer 0,0.0001, sub{
## enter: $name
if ($sub->()) {
undef $w;
$cv->end;
}