Result:
found more than 725 distributions - search limited to the first 2001 files matching your query
( run in 0.997 )
Apache-DB
view release on metacpan or search on metacpan
lib/Apache/DProf.pm view on Meta::CPAN
method. When a child server is starting the C<Apache::DProf::handler>
subroutine will called. This handler will create a directory
C<dprof/$$> relative to B<ServerRoot> where Devel::DProf will create
it's I<tmon.out> file. Then, the handler will initialize the Perl
debugger and pull in Devel::DProf who will then install it's hooks
into the debugger and start it's profile timer. The C<END> subroutine
installed by Devel::DProf will be run when the child server is
shutdown and the I<$ServerRoot/dprof/$$/tmon.out> file will be
generated and ready for B<dprofpp>.
B<NOTE:> I<$ServerRoot/logs/dprof/> will need to be writable by the user
Apache-SdnFw
view release on metacpan or search on metacpan
lib/Apache/SdnFw/js/controls.js view on Meta::CPAN
Form.Element.DelayedObserver = Class.create({
initialize: function(element, delay, callback) {
this.delay = delay || 0.5;
this.element = $(element);
this.callback = callback;
this.timer = null;
this.lastValue = $F(this.element);
Event.observe(this.element,'keyup',this.delayedListener.bindAsEventListener(this));
},
delayedListener: function(event) {
if(this.lastValue == $F(this.element)) return;
if(this.timer) clearTimeout(this.timer);
this.timer = setTimeout(this.onTimerEvent.bind(this), this.delay * 1000);
this.lastValue = $F(this.element);
},
onTimerEvent: function() {
this.timer = null;
this.callback(this.element, $F(this.element));
}
});
Apache-SecSess
view release on metacpan or search on metacpan
A session idle for the specified number of minutes will time out.
renewRate => <minutes>
A session which is constantly active will have a transparent
renewal (resetting an implicit 'idle timer') every period of the
specified number of minutes.
=head2 Quality of Protection Arguments
minSessQOP => 128, minAuthQOP => 128, authQOP => 128, sessQOP => 128
Apache-TS-AdminClient
view release on metacpan or search on metacpan
lib/Apache/TS/AdminClient.pm view on Meta::CPAN
proxy.config.cluster.mcport
proxy.config.cluster.mc_ttl
proxy.config.cluster.monitor_interval_secs
proxy.config.cluster.msecs_per_ping_response_bucket
proxy.config.cluster.peer_timeout
proxy.config.cluster.periodic_timer_interval_msecs
proxy.config.cluster.ping_history_buf_length
proxy.config.cluster.ping_latency_threshold_msecs
proxy.config.cluster.ping_response_buckets
proxy.config.cluster.ping_send_interval_msecs
proxy.config.cluster.receive_buffer_size
Apache-UploadMeter
view release on metacpan or search on metacpan
lib/Apache/UploadMeter/Resources/JavaScript.pm view on Meta::CPAN
this.registerCallback();
},
registerCallback: function() {
this.timer = setInterval(this.onTimerEvent.bind(this), this.frequency * 1000);
},
stop: function() {
if (!this.timer) return;
clearInterval(this.timer);
this.timer = null;
},
onTimerEvent: function() {
if (!this.currentlyExecuting) {
try {
lib/Apache/UploadMeter/Resources/JavaScript.pm view on Meta::CPAN
this.onTimerEvent();
},
stop: function() {
this.updater.options.onComplete = undefined;
clearTimeout(this.timer);
(this.onComplete || Prototype.emptyFunction).apply(this, arguments);
},
updateComplete: function(request) {
if (this.options.decay) {
this.decay = (request.responseText == this.lastText ?
this.decay * this.options.decay : 1);
this.lastText = request.responseText;
}
this.timer = setTimeout(this.onTimerEvent.bind(this),
this.decay * this.frequency * 1000);
},
onTimerEvent: function() {
this.updater = new Ajax.Updater(this.container, this.url, this.options);
Apache-Voodoo
view release on metacpan or search on metacpan
lib/Apache/Voodoo/Engine.pm view on Meta::CPAN
target => $self->_adjust_url("/timeout"),
error => "Session has expired"
);
}
# update the session timer
$session->touch();
return $session;
}
Apache-Watchdog-RunAway
view release on metacpan or search on metacpan
unshift @args, $pool;
}
my $image = Apache::Scoreboard->fetch(@args);
unless ($image){
# reset the counters and timers
%req_proc_time = ();
%req_number = ();
debug "couldn't retrieve the scoreboard image ",
"from $Apache::Watchdog::RunAway::SCOREBOARD_URL";
return;
Apache2-AuthCookieDBImg
view release on metacpan or search on metacpan
lib/Apache2/AuthCookieDBImg.pm view on Meta::CPAN
v2.1 - February 2006
Significant portions based on AuthCookieDBI v2.03
v2.2 - April 2006
Added SessionActiveReset configuration variable (reset logout timer)
=head1 REQUIRES
Apache::DBI
Apache2::AuthCookie
Apache2-EmbedFLV
view release on metacpan or search on metacpan
lib/Apache2/EmbedFLV/Template.pm view on Meta::CPAN
* along with Flowplayer. If not, see <http://www.gnu.org/licenses/>.
*
* Version: 3.0.3 - Wed Jan 07 2009 13:22:30 GMT-0000 (GMT+00:00)
*/
(function(){function log(args){console.log("$f.fireEvent",[].slice.call(args));}function clone(obj){if(!obj||typeof obj!='object'){return obj;}var temp=new obj.constructor();for(var key in obj){if(obj.hasOwnProperty(key)){temp[key]=clone(obj[key]);}}...
self=this,api=null,html,commonClip,playlist=[],plugins={},listeners={},playerId,apiId,playerIndex,activeIndex,swfHeight,wrapperHeight;extend(self,{id:function(){return playerId;},isLoaded:function(){return(api!==null);},getParent:function(){return wr...
Apache2-Translation
view release on metacpan or search on metacpan
lib/Apache2/Translation/Admin/prototype.js view on Meta::CPAN
this.registerCallback();
},
registerCallback: function() {
this.timer = setInterval(this.onTimerEvent.bind(this), this.frequency * 1000);
},
execute: function() {
this.callback(this);
},
stop: function() {
if (!this.timer) return;
clearInterval(this.timer);
this.timer = null;
},
onTimerEvent: function() {
if (!this.currentlyExecuting) {
try {
lib/Apache2/Translation/Admin/prototype.js view on Meta::CPAN
this.onTimerEvent();
},
stop: function() {
this.updater.options.onComplete = undefined;
clearTimeout(this.timer);
(this.onComplete || Prototype.emptyFunction).apply(this, arguments);
},
updateComplete: function(response) {
if (this.options.decay) {
this.decay = (response.responseText == this.lastText ?
this.decay * this.options.decay : 1);
this.lastText = response.responseText;
}
this.timer = this.onTimerEvent.bind(this).delay(this.decay * this.frequency);
},
onTimerEvent: function() {
this.updater = new Ajax.Updater(this.container, this.url, this.options);
}
lib/Apache2/Translation/Admin/prototype.js view on Meta::CPAN
(function() {
/* Support for the DOMContentLoaded event is based on work by Dan Webb,
Matthias Miller, Dean Edwards and John Resig. */
var timer, fired = false;
function fireContentLoadedEvent() {
if (fired) return;
if (timer) window.clearInterval(timer);
document.fire("dom:loaded");
fired = true;
}
if (document.addEventListener) {
if (Prototype.Browser.WebKit) {
timer = window.setInterval(function() {
if (/loaded|complete/.test(document.readyState))
fireContentLoadedEvent();
}, 0);
Event.observe(window, "load", fireContentLoadedEvent);
ApacheBench
view release on metacpan or search on metacpan
src/apachebench/socket_io.c view on Meta::CPAN
registry->postlen[c->url] = 0;
registry->posting[c->url] = 0; // change back to a GET request
}
}
gettimeofday(&c->connect_time, 0); // start timer
reset_request(registry, c); // this generates the request headers; must call the above first to determine POST content
#ifdef AB_DEBUG
printf("AB_DEBUG: write_request() - stage 2, registry->done = %d\n", registry->done);
App-Adenosine
view release on metacpan or search on metacpan
lib/App/Adenosine/Plugin/Stopwatch.pm view on Meta::CPAN
version 2.002000
=head1 DESCRIPTION
Appends handy timer information to curl's stderr, giving the user a simple way
to understand the duration of a requestion.
=head1 METHODS
=head2 render_duration
App-Alice
view release on metacpan or search on metacpan
lib/App/Alice.pm view on Meta::CPAN
else {
print "\n";
$self->shutdown;
return;
}
$self->{shutdown_timer} = AnyEvent->timer(
after => 3,
cb => sub{$self->shutdown}
);
}
sub shutdown {
my $self = shift;
$self->_ircs([]);
$self->httpd->shutdown;
$_->buffer->clear for $self->windows;
delete $self->{shutdown_timer} if $self->{shutdown_timer};
$self->{on_shutdown}->() if $self->{on_shutdown};
$self->condvar->send if $self->condvar;
}
sub handle_command {
App-ArduinoBuilder
view release on metacpan or search on metacpan
lib/App/ArduinoBuilder/JsonTool.pm view on Meta::CPAN
out => '', # Out from the JsonTool class point of view, this will be the tool STDIN
in => '', # This will be the tool STDOUT.
cmd => $cmd,
}, $class;
$this->{tool} = start [split_cmd($cmd)], \$this->{out}, \$this->{in}, ($this->{timer} = timeout('inf'));
$this->{timer}->exception(\$timeout_exn);
trace "Creating tool for command: ${cmd}";
return $this;
}
sub DESTROY {
my ($this) = @_;
local($., $@, $!, $^E, $?);
return unless $this->{tool};
$this->{timer}->start(5);
trace "Waiting for tool to stop";
eval {
$this->{tool}->finish();
};
if ($@) {
lib/App/ArduinoBuilder/JsonTool.pm view on Meta::CPAN
my $json = '';
my $braces = 0;
my $primed = 0;
$this->{timer}->start(5);
while (1) {
eval { pump $this->{tool} };
if (my $err = $@) {
$this->{tool}->kill_kill(grace => 5);
lib/App/ArduinoBuilder/JsonTool.pm view on Meta::CPAN
$this->{in} = '';
if ($primed && $braces == 0) {
my $data = eval { decode_json ${json} };
trace "Received following JSON:\n%s", $json;
fatal "Could not parse JSON from tool output: $@" if $@;
$this->{timer}->reset();
return $data;
}
}
}
App-Beeminder-Hook
view release on metacpan or search on metacpan
public/javascripts/jquery.js view on Meta::CPAN
"json"||!b&&f.indexOf("json")>=0)a=c.parseJSON(a);else if(b==="script"||!b&&f.indexOf("javascript")>=0)c.globalEval(a);return a},param:function(a,b){function d(i,o){if(c.isArray(o))c.each(o,function(k,n){b||/\[\]$/.test(i)?f(i,n):d(i+"["+(typeof n===...
if(c.isArray(a)||a.jquery)c.each(a,function(){f(this.name,this.value)});else for(var j in a)d(j,a[j]);return e.join("&").replace(yb,"+")}});var la={},Ab=/toggle|show|hide/,Bb=/^([+-]=)?([\d+-.]+)(.*)$/,W,va=[["height","marginTop","marginBottom","padd...
this[a].style.display=d||"";if(c.css(this[a],"display")==="none"){d=this[a].nodeName;var f;if(la[d])f=la[d];else{var e=c("<"+d+" />").appendTo("body");f=e.css("display");if(f==="none")f="block";e.remove();la[d]=f}c.data(this[a],"olddisplay",f)}}a=0;f...
"olddisplay",c.css(this[a],"display"))}a=0;for(b=this.length;a<b;a++)this[a].style.display="none";return this}},_toggle:c.fn.toggle,toggle:function(a,b){var d=typeof a==="boolean";if(c.isFunction(a)&&c.isFunction(b))this._toggle.apply(this,arguments)...
animate:function(a,b,d,f){var e=c.speed(b,d,f);if(c.isEmptyObject(a))return this.each(e.complete);return this[e.queue===false?"each":"queue"](function(){var j=c.extend({},e),i,o=this.nodeType===1&&c(this).is(":hidden"),k=this;for(i in a){var n=i.repl...
j.specialEasing||{})[i]=a[i][1];a[i]=a[i][0]}}if(j.overflow!=null)this.style.overflow="hidden";j.curAnim=c.extend({},a);c.each(a,function(r,u){var z=new c.fx(k,j,r);if(Ab.test(u))z[u==="toggle"?o?"show":"hide":u](a);else{var C=Bb.exec(u),B=z.cur(true...
this.each(function(){for(var f=d.length-1;f>=0;f--)if(d[f].elem===this){b&&d[f](true);d.splice(f,1)}});b||this.dequeue();return this}});c.each({slideDown:K("show",1),slideUp:K("hide",1),slideToggle:K("toggle",1),fadeIn:{opacity:"show"},fadeOut:{opaci...
"number"?f.duration:c.fx.speeds[f.duration]||c.fx.speeds._default;f.old=f.complete;f.complete=function(){f.queue!==false&&c(this).dequeue();c.isFunction(f.old)&&f.old.call(this)};return f},easing:{linear:function(a,b,d,f){return d+f*a},swing:function...
c.fx.step._default)(this);if((this.prop==="height"||this.prop==="width")&&this.elem.style)this.elem.style.display="block"},cur:function(a){if(this.elem[this.prop]!=null&&(!this.elem.style||this.elem.style[this.prop]==null))return this.elem[this.prop]...
this.pos=this.state=0;var e=this;f.elem=this.elem;if(f()&&c.timers.push(f)&&!W)W=setInterval(c.fx.tick,13)},show:function(){this.options.orig[this.prop]=c.style(this.elem,this.prop);this.options.show=true;this.custom(this.prop==="width"||this.prop===...
this.end;this.pos=this.state=1;this.update();this.options.curAnim[this.prop]=true;for(var f in this.options.curAnim)if(this.options.curAnim[f]!==true)d=false;if(d){if(this.options.display!=null){this.elem.style.overflow=this.options.overflow;a=c.data...
e,this.options.orig[e]);this.options.complete.call(this.elem)}return false}else{e=b-this.startTime;this.state=e/this.options.duration;a=this.options.easing||(c.easing.swing?"swing":"linear");this.pos=c.easing[this.options.specialEasing&&this.options....
c.fx.stop()},stop:function(){clearInterval(W);W=null},speeds:{slow:600,fast:200,_default:400},step:{opacity:function(a){c.style(a.elem,"opacity",a.now)},_default:function(a){if(a.elem.style&&a.elem.style[a.prop]!=null)a.elem.style[a.prop]=(a.prop==="...
function(a){var b=this[0];if(a)return this.each(function(e){c.offset.setOffset(this,a,e)});if(!b||!b.ownerDocument)return null;if(b===b.ownerDocument.body)return c.offset.bodyOffset(b);var d=b.getBoundingClientRect(),f=b.ownerDocument;b=f.body;f=f.do...
this[0];if(a)return this.each(function(r){c.offset.setOffset(this,a,r)});if(!b||!b.ownerDocument)return null;if(b===b.ownerDocument.body)return c.offset.bodyOffset(b);c.offset.initialize();var d=b.offsetParent,f=b,e=b.ownerDocument,j,i=e.documentElem...
k-=b.scrollTop;n-=b.scrollLeft;if(b===d){k+=b.offsetTop;n+=b.offsetLeft;if(c.offset.doesNotAddBorder&&!(c.offset.doesAddBorderForTableAndCells&&/^t(able|d|h)$/i.test(b.nodeName))){k+=parseFloat(j.borderTopWidth)||0;n+=parseFloat(j.borderLeftWidth)||0...
f.position==="fixed"){k+=Math.max(i.scrollTop,o.scrollTop);n+=Math.max(i.scrollLeft,o.scrollLeft)}return{top:k,left:n}};c.offset={initialize:function(){var a=s.body,b=s.createElement("div"),d,f,e,j=parseFloat(c.curCSS(a,"marginTop",true))||0;c.extend...
a.insertBefore(b,a.firstChild);d=b.firstChild;f=d.firstChild;e=d.nextSibling.firstChild.firstChild;this.doesNotAddBorder=f.offsetTop!==5;this.doesAddBorderForTableAndCells=e.offsetTop===5;f.style.position="fixed";f.style.top="20px";this.supportsFixed...
App-Chart
view release on metacpan or search on metacpan
lib/App/Chart/Gtk2/Subprocess.pm view on Meta::CPAN
my ($self, $pspec, $newval) = @_;
my $pname = $pspec->get_name;
$self->{$pname} = $newval; # per default GET_PROPERTY
if ($pname eq 'job') {
_update_idle_timer ($self);
}
}
# 'notify' signal class closure
sub _do_notify {
lib/App/Chart/Gtk2/Subprocess.pm view on Meta::CPAN
}
}
return Glib::SOURCE_CONTINUE;
}
sub _update_idle_timer {
my ($self) = @_;
my $want_timer = ($self->pid && ! $self->{'job'});
if ($want_timer) {
$self->{'timer_ids'} ||= Glib::Ex::SourceIds->new
(Glib::Timeout->add (IDLE_TIMEOUT_SECONDS * 1000,
\&_do_idle_timeout,
App::Chart::Glib::Ex::MoreUtils::ref_weak($self)));
} else {
$self->{'timer_ids'} = undef;
}
}
sub _do_idle_timeout {
my ($ref_weak_self) = @_;
lib/App/Chart/Gtk2/Subprocess.pm view on Meta::CPAN
Gtk2::Ex::TreeModelBits::remove_matching_rows
($store, sub { my ($store, $iter) = @_;
$store->get_value($iter,0) == $self });
$self->{'timer_ids'} = undef;
return Glib::SOURCE_REMOVE;
}
# send out a 'row-changed' on the global $store for subprocesses $self
sub _emit_row_changed {
App-Cheats
view release on metacpan or search on metacpan
/\Vlinux /boot/vmlinuz-3.16.51+20180205+1524
# Add this to
isolcpus=0,1,2,3,4,5,6,7,8,9
cat /proc/cmdline
# Check timer frequency (DES,UI,CONFIG_HZ_1000)
cat /usr/src/linux.config | OR CONFIG_COMPAT_BRK CONFIG_HZ_PERIODIC CONFIG_X86_GENERIC CONFIG_SCHED_SMT CONFIG_HZ_1000
# find biggest binary number on the machine
perl -lE '@a=split //, sprintf "%b", ~~-1; print @a'
perl -lE '@a=split //, sprintf "%b", ~~-1; print scalar @a'
# Prompt on a control-C (signal handling)
signal_handler(){ echo -e "\n${RED}Caught Control-C$RESTORE "; read -p "Are you sure you want to abort? (y/n): " ans; [[ $ans =~ [yY] ]] && echo "continue" || echo "exit"; }
trap signal_handler SIGINT
<Control-C>
# Create a timer in bash (aborts the session)
handler(){ echo "done"; exit 1; }
set_timer(){ (sleep $1; kill -ALRM $$)& }
trap handler SIGALRM
set_timer 5
while [ 1 ]; do echo $$; sleep 1; done
# Trap alarm signal
trap 'echo "Hit alarm"; break' SIGALRM
while true; do echo $$; sleep 1; done
SIGLOST - Term File lock lost (unused)
SIGPIPE P1990 Term Broken pipe: write to pipe with no
readers; see pipe(7)
SIGPOLL P2001 Term Pollable event (Sys V);
synonym for SIGIO
SIGPROF P2001 Term Profiling timer expired
SIGPWR - Term Power failure (System V)
SIGQUIT P1990 Core Quit from keyboard
SIGSEGV P1990 Core Invalid memory reference
SIGSTKFLT - Term Stack fault on coprocessor (unused)
SIGSTOP P1990 Stop Stop process
});
#
# Then send the notification:
deferred.notify(value);
# Promise based timer (JQuery,Deferred,Promises)
function timeout(milliseconds) {
var deferred = $.Deferred();
setTimeout(deferred.resolve, milliseconds);
return deferred.promise();
}
#############################################################
# Simple exmplae of parallel processing
# (Perl Modules - AnyEvent)
# NOT WORKING!
perl -MAnyEvent -E 'my @files = (1..30); my $cv = AnyEvent->condvar; foreach my $file (@files) { $cv->begin; AnyEvent->timer(after => 0, cb => sub { say "Processing file $file"; sleep(1); $cv->end; }); } $cv->recv;'
#############################################################
## Perl Modules - Automake::Config
#############################################################
# Simple Mojo promise example
perl -MMojo::Promise -E '$p = Mojo::Promise->new; $p->then(sub{say "OK"}); $p->resolve; $p->wait'
perl -MMojo::Promise -E '$p = Mojo::Promise->new; $p->then(sub{say "OK"}, sub{say "BAD"}); $p->resolve; $p->wait'
perl -MMojo::Promise -E '$p = Mojo::Promise->new; $p->then(sub{say "OK"}, sub{say "BAD"}); $p->reject; $p->wait'
# Simple Mojo promise example - timer (OK)/ timeout (BAD)
perl -MMojo::Promise -E "$p = Mojo::Promise->new; $p->then(sub{say 'OK'}, sub{say 'BAD'}); $p->timeout(1); $p->wait"
perl -MMojo::Promise -E "$p = Mojo::Promise->new; $p->then(sub{say 'OK'}, sub{say 'BAD'}); $p->timer(1); $p->wait"
# Chain of promises - short way, but not working for the 2nd level
perl -Mojo -MMojo::Promise -E "my $p = Mojo::Promise->new; $p->then(sub{say '1-OK'}, sub{say '1-BAD'})->then(sub{say '2-OK'}, sub{say '2-BAD'}); $p->reject; $p->wait"
# Chain of promises - long way
# Setup vue webpack (many files)
npm install --global vue-cli
vue init webpack
# Vue - Watch for changes to this.$refs
this.$watch(() => this.timerRef ? this.timerRef.timer.time : null, (newTime, oldTime) => {
console.log('Watched time: ', newTime, oldTime);
this.$refs.form.values.AccountedTime = newTime;
});
App-Chronicle
view release on metacpan or search on metacpan
themes/bs2/static/js/jquery-1.7.1.min.js view on Meta::CPAN
/*! jQuery v1.7.1 jquery.com | jquery.org/license */
(function(a,b){function cy(a){return f.isWindow(a)?a:a.nodeType===9?a.defaultView||a.parentWindow:!1}function cv(a){if(!ck[a]){var b=c.body,d=f("<"+a+">").appendTo(b),e=d.css("display");d.remove();if(e==="none"||e===""){cl||(cl=c.createElement("ifram...
f.event={add:function(a,c,d,e,g){var h,i,j,k,l,m,n,o,p,q,r,s;if(!(a.nodeType===3||a.nodeType===8||!c||!d||!(h=f._data(a)))){d.handler&&(p=d,d=p.handler),d.guid||(d.guid=f.guid++),j=h.events,j||(h.events=j={}),i=h.handle,i||(h.handle=i=function(a){ret...
{for(var a=0,b;(b=this[a])!=null;a++){b.nodeType===1&&f.cleanData(b.getElementsByTagName("*"));while(b.firstChild)b.removeChild(b.firstChild)}return this},clone:function(a,b){a=a==null?!1:a,b=b==null?a:b;return this.map(function(){return f.clone(this...
App-Config-Chronicle
view release on metacpan or search on metacpan
t/07_full_build.t view on Meta::CPAN
chronicle_writer => $chronicle_w,
refresh_interval => 1,
);
is($app_config2->current_revision, $new_revision, "revision is correct even if we create a new instance");
is($app_config2->system->email, 'test@abc.com', "email is updated");
# force check & trigger internal timer
$app_config2->check_for_update;
$app_config->system->email('test2@abc.com');
$app_config->save_dynamic;
# will not refresh as not enough time has passed
$app_config2->check_for_update;
App-Context
view release on metacpan or search on metacpan
lib/App/Context.pm view on Meta::CPAN
# 16. cutime - This process and its children in user mode
# 17. cstime - in kernel mode
# 18. counter - The maximum time of this processes next time slice.
# 19. priority - The priority of the nice(1) (process priority) value plus fifteen.
# 20. timeout - The time in jiffies of the process's next timeout.
# 21. itrealvalue - The time in jiffies before the next SIGALRM is sent to the process because of an internal timer.
# 22. starttime - Time the process started after system boot
# 23. vsize - Virtual memory size
# 24. rlim - Current limit in bytes of the rss of the process.
# 25. startcode - The address above which program text can run.
# 26. endcode - The address below which program text can run.
App-Countdown
view release on metacpan or search on metacpan
'console',
'countdown',
'modulino',
'sleep',
'terminal',
'timer',
],
},
);
$builder->create_build_script();
App-Device-Chip-UI
view release on metacpan or search on metacpan
lib/App/Device/Chip/UI.pm view on Meta::CPAN
$tickit->term->await_started( 0.5 );
my $update;
$update = sub {
$updatesub and $updatesub->();
$tickit->timer( after => 0.05, $update );
};
$update->();
$tickit->run;
App-Diskd
view release on metacpan or search on metacpan
lib/App/Diskd.pm view on Meta::CPAN
##
## The DiskWatcher package sets up a session to periodically run
## blkid, parse the results and store them in our Info object. Since
## blkid can sometimes hang (due to expected devices or media not
## being present), a timer is set and if the command hasn't completed
## within that timeout, the child process is killed and the child
## session garbage collected.
##
package Local::DiskWatcher;
lib/App/Diskd.pm view on Meta::CPAN
# start_child is responsible for running the program with a timeout
sub start_child {
my ($kernel, $heap) = @_[KERNEL, HEAP];
# Using a named timer for timeouts. Set it to undef to deactivate.
$kernel->delay(child_timeout => $heap->{timeout});
$heap->{child} = POE::Wheel::Run->new(
Program => [$heap->{program}],
StdioFilter => POE::Filter::Line->new(),
lib/App/Diskd.pm view on Meta::CPAN
#print "DiskWatcher: child_cleanup args: ". (join ", ", @_). "\n";
my ($heap,$kernel) = @_[HEAP,KERNEL];
# Deactivate the kill timer
$kernel->delay(child_timeout => undef);
# We need to commit the new list of disks and recycle the child
# object. Both of these should only be called once, even if this
# routine is called twice.
App-Dochazka-CLI
view release on metacpan or search on metacpan
lib/App/Dochazka/CLI/CommandMap.pm view on Meta::CPAN
interval_month
interval_num_num1
interval_promptdate
interval_new_date_time_date1_time1
interval_new_time_time1
interval_new_timerange
);
use App::Dochazka::CLI::Commands::Misc qw(
change_prompt_date
noop
);
lib/App/Dochazka/CLI/CommandMap.pm view on Meta::CPAN
"EMPLOYEE_SPEC INTERVAL FILLUP DATELIST DRY_RUN _TERM" => \&interval_datelist,
# add/insert new intervals
"INTERVAL _TIME _TIME1 _TERM" => \&interval_new_time_time1,
"INTERVAL _TIME _HYPHEN _TIME1 _TERM" => \&interval_new_time_time1,
"INTERVAL _TIMERANGE _TERM" => \&interval_new_timerange,
"INTERVAL _DATE _TIME _TIME1 _TERM" => \&interval_new_time_time1,
"INTERVAL _DATE _TIME _HYPHEN _TIME1 _TERM" => \&interval_new_time_time1,
"INTERVAL _DATE _TIMERANGE _TERM" => \&interval_new_timerange,
"INTERVAL _DATE _TIME _DATE1 _TIME1 _TERM" => \&interval_new_date_time_date1_time1,
"INTERVAL _DATE _TIME _HYPHEN _DATE1 _TIME1 _TERM" => \&interval_new_date_time_date1_time1,
# Lock commands
App-Dochazka-WWW
view release on metacpan or search on metacpan
share/js/dochazka-www/caches.js view on Meta::CPAN
populateContinue(populateArray);
},
populateLastPlusOffsetFormFields = function (buf) {
var formField = $('#iNlastplusoffset'),
formInput = $('input[id="iNtimerange"');
formField.html(String(buf));
formInput.val(String(buf));
},
populateNextScheduled = function (populateArray) {
share/js/dochazka-www/caches.js view on Meta::CPAN
},
};
sc = function (st) {
if (st.code === "DISPATCH_SCHEDULED_INTERVALS_IDENTIFIED") {
appLib.displayIntervals([st.payload.success.intervals[0]], $('#iNnextscheduled'));
$('input[id="iNtimerange"]').val(
dt.tsrangeToTimeRange(st.payload.success.intervals[0].intvl)
);
} else {
if (date) {
m = "No unfulfilled scheduled intervals for " + date;
App-DubiousHTTP
view release on metacpan or search on metacpan
lib/App/DubiousHTTP/TestServer.pm view on Meta::CPAN
if ($wbuf[0] eq '') {
shift @wbuf;
if (@wbuf) {
# delay sending of next packet
$SELECT->mask($cl,1,0); # disable write
$SELECT->timer($cl,1, sub { $write->($cl); });
return;
}
}
goto handle_data;
};
lib/App/DubiousHTTP/TestServer.pm view on Meta::CPAN
my $maxfn = 0;
my @handler;
my @didit;
my @timeout;
my @timer;
my @mask = ('','');
my @tmpmask;
my $now = gettimeofday();
*_debug = \&App::DubiousHTTP::TestServer::_debug;
lib/App/DubiousHTTP/TestServer.pm view on Meta::CPAN
my ($self,$cl) = @_;
defined( my $fn = fileno($cl) ) or die "invalid fd";
$DEBUG && _debug("remove fd $fn");
vec($mask[0],$fn,1) = vec($mask[1],$fn,1) = 0;
vec($tmpmask[0],$fn,1) = vec($tmpmask[1],$fn,1) = 0 if @tmpmask;
$handler[$fn] = $didit[$fn] = $timeout[$fn] = $timer[$fn] = undef;
if ($maxfn == $fn) {
$maxfn-- while ($maxfn>=0 && !$handler[$maxfn]);
}
}
lib/App/DubiousHTTP/TestServer.pm view on Meta::CPAN
$handler[$fn][$rw] = $sub;
$DEBUG && _debug("add handler($fn,$rw)");
}
}
sub timer {
my ($self,$cl,$to,$cb) = @_;
defined( my $fn = fileno($cl) ) or die "invalid fd";
($cb, my @arg) = ref($cb) eq 'CODE' ? ($cb):@$cb;
push @{ $timer[$fn] }, [ $now+$to,$cb,@arg ];
@{ $timer[$fn] } = sort { $a->[0] <=> $b->[0] } @{ $timer[$fn] };
}
sub timeout {
my ($self,$cl,$to,$cb) = @_;
defined( my $fn = fileno($cl) ) or die "invalid fd";
lib/App/DubiousHTTP/TestServer.pm view on Meta::CPAN
my $to;
loop:
$to = undef;
for( my $fn=0;$fn<=$maxfn;$fn++ ) {
$timer[$fn] or next;
while (1) {
my $t = $timer[$fn][0];
if (!$t) {
$timer[$fn] = undef;
last;
}
my ($fire,$cb,@arg) = @$t;
if ($fire>$now) {
# timer in future, update $to
$to = $fire-$now if !$to || $fire-$now < $to;
last;
}
# fire timer now
shift(@{$timer[$fn]});
$DEBUG && _debug("fire timer($fn)");
$cb->(@arg);
}
}
for( my $fn=0;$fn<=$maxfn;$fn++ ) {
App-DuckPAN
view release on metacpan or search on metacpan
In duckduckgo/zeroclickinfo-spice the Time spice's name is a
substring of the Timer spice's name. When looking for resources for
the Timer IA, paths of the form
.../timer/...
got mangled to
.../time/r/...
Timer) resources, and path handling got confused.
By making the guard for identifying the relevant the share directory
also check on the trailing '/', the share directories of Time and
Timer are properly matched and the Timer IA again properly loads for
'timer 10 seconds'.
Fixes duckduckgo/zeroclickinfo-spice#1625
Change: 79e8a5ed255e7d6044c1ad2574ece786f7344023
Author: moollaza <moollaza@fastmail.fm>
App-EventStreamr
view release on metacpan or search on metacpan
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
}
};
}
});
}
var fxNow, timerId,
rfxtypes = /^(?:toggle|show|hide)$/,
rfxnum = new RegExp( "^(?:([+-])=|)(" + core_pnum + ")([a-z%]*)$", "i" ),
rrun = /queueHooks$/,
animationPrefilters = [ defaultPrefilter ],
tweeners = {
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
if ( jQuery.isFunction( animation.opts.start ) ) {
animation.opts.start.call( elem, animation );
}
jQuery.fx.timer(
jQuery.extend( tick, {
elem: elem,
anim: animation,
queue: animation.opts.queue
})
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
}
return this.each(function() {
var dequeue = true,
index = type != null && type + "queueHooks",
timers = jQuery.timers,
data = jQuery._data( this );
if ( index ) {
if ( data[ index ] && data[ index ].stop ) {
stopQueue( data[ index ] );
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
stopQueue( data[ index ] );
}
}
}
for ( index = timers.length; index--; ) {
if ( timers[ index ].elem === this && (type == null || timers[ index ].queue === type) ) {
timers[ index ].anim.stop( gotoEnd );
dequeue = false;
timers.splice( index, 1 );
}
}
// start the next in the queue if the last step wasn't forced
// timers currently will call their complete callbacks, which will dequeue
// but only if they were gotoEnd
if ( dequeue || !gotoEnd ) {
jQuery.dequeue( this, type );
}
});
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
return this.each(function() {
var index,
data = jQuery._data( this ),
queue = data[ type + "queue" ],
hooks = data[ type + "queueHooks" ],
timers = jQuery.timers,
length = queue ? queue.length : 0;
// enable finishing flag on private data
data.finish = true;
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
if ( hooks && hooks.stop ) {
hooks.stop.call( this, true );
}
// look for any active animations, and finish them
for ( index = timers.length; index--; ) {
if ( timers[ index ].elem === this && timers[ index ].queue === type ) {
timers[ index ].anim.stop( true );
timers.splice( index, 1 );
}
}
// look for any animations in the old queue and finish them
for ( index = 0; index < length; index++ ) {
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
swing: function( p ) {
return 0.5 - Math.cos( p*Math.PI ) / 2;
}
};
jQuery.timers = [];
jQuery.fx = Tween.prototype.init;
jQuery.fx.tick = function() {
var timer,
timers = jQuery.timers,
i = 0;
fxNow = jQuery.now();
for ( ; i < timers.length; i++ ) {
timer = timers[ i ];
// Checks the timer has not already been removed
if ( !timer() && timers[ i ] === timer ) {
timers.splice( i--, 1 );
}
}
if ( !timers.length ) {
jQuery.fx.stop();
}
fxNow = undefined;
};
jQuery.fx.timer = function( timer ) {
if ( timer() && jQuery.timers.push( timer ) ) {
jQuery.fx.start();
}
};
jQuery.fx.interval = 13;
jQuery.fx.start = function() {
if ( !timerId ) {
timerId = setInterval( jQuery.fx.tick, jQuery.fx.interval );
}
};
jQuery.fx.stop = function() {
clearInterval( timerId );
timerId = null;
};
jQuery.fx.speeds = {
slow: 600,
fast: 200,
share/status/app/lib/bootstrap/jquery.js view on Meta::CPAN
// Back Compat <1.8 extension point
jQuery.fx.step = {};
if ( jQuery.expr && jQuery.expr.filters ) {
jQuery.expr.filters.animated = function( elem ) {
return jQuery.grep(jQuery.timers, function( fn ) {
return elem === fn.elem;
}).length;
};
}
jQuery.fn.offset = function( options ) {
App-FastishCGI
view release on metacpan or search on metacpan
lib/App/FastishCGI.pm view on Meta::CPAN
}
$self->clear_request($rid);
},
);
$self->{requests}->{$rid}->{timer} = AnyEvent->timer(
after => $self->{timeout},
cb => sub {
$self->html_error( $req, "Script '$script_filename' exceeded timeout value" );
$self->clear_request($rid);
}
App-FonBot-Daemon
view release on metacpan or search on metacpan
lib/App/FonBot/Plugin/Email.pm view on Meta::CPAN
=over
=item C<$email_batch_seconds>
When receiving an email send request, C<App::FonBot::Plugin::Email> waits this many seconds for further email send requests to the same email address. The timer is reset for each email send request. When the timer expires, all pending send requests a...
=item C<$email_from>
C<From:> header of all emails sent by this plugin. If not set the email plugin is disabled.
( run in 0.997 second using v1.01-cache-2.11-cpan-49f99fa48dc )