Result:
found more than 814 distributions - search limited to the first 2001 files matching your query
( run in 0.675 )
Myriad
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;
}
Mythfs-perl
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",
NBU
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)) {
NIS
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
NISPlus
view release on metacpan or search on metacpan
#
# -M Master server only. This option specifies that the request should
# be sent to the master server of the named data. This guarantees that
# the most up-to-date information is seen at the possible expense
# of increasing the load on the master server and increasing the
# possibility of the NIS+ server being unavailable or busy for updates.
#
# -P Follow concatenation path. This option specifies that the request
# should follow the concatenation path of a table if the initial search
# is unsuccessful. This option is only useful when using an indexed
# name for name and the -o option.
Neo4j-Client
view release on metacpan or search on metacpan
build/build-aux/install-sh view on Meta::CPAN
# to itself, or perhaps because mv is so ancient that it does not
# support -f.
{
# Now remove or move aside any old file at destination location.
# We try this two ways since rm can't unlink itself on some
# systems and the destination file might be busy for other
# reasons. In this case, the final cleanup might fail but the new
# file should still install successfully.
{
test ! -f "$dst" ||
$doit $rmcmd -f "$dst" 2>/dev/null ||
Net-AMQP-RabbitMQ
view release on metacpan or search on metacpan
CONTRIBUTING.md view on Meta::CPAN
Your contributions are absolutely welcome!
## Reporting issues:
Hey all, it's just me maintaining this module. I'm a busy person, and my time working on this module is prescious and short. If you would like to submit an issue, please observe the following:
0. I'm going to try my best to resolve your issues, but if I can't figure out how to test or replicate the issue you report, I won't be able to help you.
1. If you are reporting a bug that you found, _please_ attach a simple test program to your bug. This will help me see what you're saying much more quickly, and it'll help me fix your issue more quickly.
2. I mostly develop on macOS, so if you have an issue that you suspect is OS-specific, please attach a `Dockerfile` (or equivalent) so that I can check the issue out inside that environment.
3. If you have an SSL-specific issue, please verify that it also occurs on the default test install, or help me figure out how to test it otherwise.
Net-AMQP
view release on metacpan or search on metacpan
spec/amqp0-10.xml view on Meta::CPAN
<choice name="normal" value="0">
<doc>
The session was detached by request.
</doc>
</choice>
<choice name="session-busy" value="1">
<doc>
The session is currently attached to another transport.
</doc>
</choice>
<choice name="transport-busy" value="2">
<doc>
The transport is currently attached to another session.
</doc>
</choice>
<choice name="not-attached" value="3">
spec/amqp0-10.xml view on Meta::CPAN
<doc>
Identifies the session to be attached to the current transport.
</doc>
</field>
<field name="force" type="bit" label="force attachment to a busy session">
<doc>
If set then a busy session will be forcibly detached from its other transport and
reattached to the current transport.
</doc>
</field>
</control>
Net-API-Telegram
view release on metacpan or search on metacpan
lib/Net/API/Telegram.pm view on Meta::CPAN
=item I<error_message>
This parameter type is String and is optional.
Required if ok is False. Error message in human readable form that explains the reason for failure to proceed with the checkout (e.g. "Sorry, somebody just bought the last of our amazing black T-shirts while you were busy filling out your payment det...
=item I<ok>
This parameter type is Boolean and is required.
Net-Analysis
view release on metacpan or search on metacpan
lib/Net/Analysis.pm view on Meta::CPAN
To look at how to write a listener that maintains session state, see
L<Net::Analysis::Listener::HTTP>.
=head1 TODO
Performance - this may not be fast enough to handle busy servers in real time.
More work on live capture, this is still experimental.
UDP support
Net-Async-Beanstalk
view release on metacpan or search on metacpan
lib/Net/Async/Beanstalk/Stack.pm view on Meta::CPAN
=item current_command
Returns the command the server is currently processing, or has just
sent a response to, without removing it from the stack.
=item is_busy
A boolean indicating whether the client is busy, ie. has a command
currently being processed or has commands waiting to be sent. Actually
implemented by the same method as L</count_commands>.
=item _pending_commands
lib/Net/Async/Beanstalk/Stack.pm view on Meta::CPAN
init_arg => undef,
default => sub { [] },
handles_via => 'Array',
handles => {
count_commands => 'count',
is_busy => 'count',
_pending_commands => 'all',
_push_command => 'push',
_shift_command => 'shift',
},
);
Net-Async-HTTP
view release on metacpan or search on metacpan
lib/Net/Async/HTTP.pm view on Meta::CPAN
=item max_connections_per_host > 1
In this mode, there can be more than one connection per host. If a new request
is made, it will try to re-use idle connections if there are any, or if they
are all busy it will create a new connection to the host, up to the configured
limit.
=item max_connections_per_host = 0
In this mode, there is no upper limit to the number of connections per host.
Every new request will try to reuse an idle connection, or else create a new
one if all the existing ones are busy.
=back
These modes all apply per hostname / server port pair; they do not affect the
behaviour of connections made to differing hostnames, or differing ports on
Net-Async-Redis
view release on metacpan or search on metacpan
examples/mutex.pl view on Meta::CPAN
my $removed = $loop->new_future;
die 'no cc cache?' unless $redis->is_client_side_cache_enabled;
my $src = $redis->clientside_cache_events
->each(sub {
$log->infof('Key change detected for %s', $_);
if($_ eq 'task.busy') {
my $f = $removed;
$removed = $loop->new_future;
$f->done
} else {
$log->infof('Nothing to do with us');
examples/mutex.pl view on Meta::CPAN
my $timeout = $loop->delay_future(after => 5);
until($timeout->is_ready) {
await $loop->delay_future(after => 0.005 * rand);
$log->infof('Try to set key');
if(my $res = await $redis->set('task.busy' => $id, qw(NX GET PX), 3_000)) {
$log->infof('We lost - res = %s', $res);
if(await $redis->get('task.busy')) {
await $removed;
$log->infof('Notified removal');
} else {
$log->infof('Key disappeared');
}
} else {
$log->infof('We won');
++$count{$id};
await $loop->delay_future(after => 0.003 * rand);
$log->infof('Release');
await $redis->del('task.busy');
}
}
return;
}, foreach => [1..10], concurrent => 10);
$log->infof('done');
Net-Bind-rbldnsdAccessor
view release on metacpan or search on metacpan
rbldnsdAccessor.pm view on Meta::CPAN
&ISC_R_CONNREFUSED => 'connection refused',
&ISC_R_NORESOURCES => 'not enough free resources',
&ISC_R_EOF => 'end of file',
&ISC_R_BOUND => 'socket already bound',
&ISC_R_RELOAD => 'reload',
&ISC_R_LOCKBUSY => 'lock busy',
&ISC_R_EXISTS => 'already exists',
&ISC_R_NOSPACE => 'ran out of space',
&ISC_R_CANCELED => 'operation canceled',
&ISC_R_NOTBOUND => 'socket is not bound',
&ISC_R_SHUTTINGDOWN => 'shutting down',
Net-BitTorrent
view release on metacpan or search on metacpan
lib/Net/BitTorrent/Peer.pm view on Meta::CPAN
allowed globally or per torrent.
=item DISCONNECT_HASHCHECKING
This reason is given when a remote peer connects to us while the torrent
they're seeking is busy being hash checked (potentially in another
thread).
=item DISCONNECT_SEED
This is given when we and the remote peer are both seeds.
Net-CDP
view release on metacpan or search on metacpan
libcdp/install-sh view on Meta::CPAN
&& { test -z "$stripcmd" || $doit $stripcmd "$dsttmp"; } \
&& { test -z "$chmodcmd" || $doit $chmodcmd "$dsttmp"; } &&
# Now remove or move aside any old file at destination location. We
# try this two ways since rm can't unlink itself on some systems and
# the destination file might be busy for other reasons. In this case,
# the final cleanup might fail but the new file should still install
# successfully.
{
if test -f "$dstdir/$dstfile"; then
$doit $rmcmd -f "$dstdir/$dstfile" 2>/dev/null \
Net-CSTA
view release on metacpan or search on metacpan
lib/Net/CSTA/ASN.pm view on Meta::CPAN
EventCause ::= ENUMERATED {
activeMonitor (1),
alternate (2),
busy (3),
callback (4),
callCancelled (5),
callForwardAlways (6),
callForwardBusy (7),
callForwardNoAnswer (8),
Net-CalDAVTalk
view release on metacpan or search on metacpan
lib/Net/CalDAVTalk.pm view on Meta::CPAN
$Priv = [] unless ($Priv and ref($Priv) eq 'ARRAY');
foreach my $item (@$Priv) {
$Privileges{'mayAdmin'} = $JSON::true if $item->{"{$NS_CY}admin"};
$Privileges{'mayWrite'} = $JSON::true if $item->{"{$NS_D}write-content"};
$Privileges{'mayRead'} = $JSON::true if $item->{"{$NS_D}read"};
$Privileges{'mayReadFreeBusy'} = $JSON::true if $item->{"{$NS_C}read-free-busy"};
}
my $CanSync;
my $Report = $Propstat->{"{$NS_D}prop"}{"{$NS_D}supported-report-set"}{"{$NS_D}supported-report"};
$Report = [] unless ($Report and ref($Report) eq 'ARRAY');
lib/Net/CalDAVTalk.pm view on Meta::CPAN
);
foreach my $item (@{$Acl->{"{$NS_D}grant"}{"{$NS_D}privilege"}}) {
$ShareObject{'mayAdmin'} = $JSON::true if $item->{"{$NS_CY}admin"};
$ShareObject{'mayWrite'} = $JSON::true if $item->{"{$NS_D}write-content"};
$ShareObject{'mayRead'} = $JSON::true if $item->{"{$NS_D}read"};
$ShareObject{'mayReadFreeBusy'} = $JSON::true if $item->{"{$NS_C}read-free-busy"};
}
push @ShareWith, \%ShareObject;
}
lib/Net/CalDAVTalk.pm view on Meta::CPAN
return $Events->[0];
}
=head2 $self->GetFreeBusy($calendarId, %Args)
Like 'GetEvents' but uses a free-busy-query and then generates
synthetic events out of the result.
Doesn't have a 'href' parameter, just the before/after range.
=cut
lib/Net/CalDAVTalk.pm view on Meta::CPAN
# }}}
my $Response = $Self->Request(
'REPORT',
"$calendarId/",
x('C:free-busy-query', $Self->NS(),
@Query,
),
Depth => 1,
);
lib/Net/CalDAVTalk.pm view on Meta::CPAN
my @result;
my @errors;
my $now = DateTime->now();
foreach my $item (@{$Data->{objects}[0]{objects}}) {
next unless $item->{type} eq 'vfreebusy';
foreach my $line (@{$item->{properties}{freebusy}}) {
my ($Start, $End) = split '/', $line->{value};
my ($StartTime, $IsAllDay) = $Self->_makeDateObj($Start, 'UTC', 'UTC');
my $EndTime;
if ($End =~ m/^[+-]?P/i) {
my $Duration = eval { DateTime::Format::ICal->parse_duration(uc $End) }
lib/Net/CalDAVTalk.pm view on Meta::CPAN
title => ($Args{name} // ''),
isAllDay => ($IsAllDay ? $JSON::true : $JSON::false),
updated => $now->iso8601(),
};
# Generate a uid that should remain the same for this freebusy entry
$NewEvent->{uid} = _hexkey($NewEvent) . '-freebusyauto';
$NewEvent->{isAllDay} =
$NewEvent->{isAllDay} ? $JSON::true : $JSON::false;
push @result, $NewEvent;
}
}
Net-Clacks
view release on metacpan or search on metacpan
lib/Net/Clacks/Server.pm view on Meta::CPAN
Run the server instance in it's own event loop. Only returns when server is shutdown.
=head2 runOnce
Run through the event loop once. This allows you to use your own programs event loop, and call runOnce a couple of times per second. It is a good idea to call runShutdown() to cleanly
disconnect clients before exiting your program. runOnce() returns a "work count" number, on which you *may* decide on how busy the server is and when to call runOnce() next.
=head2 runShutdown
Shuts down all connections. This is called automatically if you use run(), but not if you use runOnce()
Net-Connection-Sniffer
view release on metacpan or search on metacpan
0.25 Thu Oct 2 13:39:49 PDT 2008
add CPAN automated tester cutout if pcap lib is not installed
0.24 Mon Jan 14 11:48:04 PST 2008
force timecheck every second, even if very busy
so that old IP's will expire
0.23 Wed Apr 25 16:52:52 PDT 2007
add redundant DNS name reporting to compensate for occasional
missing rDNS entries for remote hosts
Net-DNS-Async
view release on metacpan or search on metacpan
lib/Net/DNS/Async.pm view on Meta::CPAN
# if ($_LEVEL) { add to Pending } else { recv/send }
$self->recv(0); # Perform fast case unconditionally.
# print "Queue size " . scalar(keys %{ $self->{Queue} });
while (scalar(keys %{ $self->{Queue} }) > $self->{QueueSize}) {
# I'm fairly sure this can't busy wait since it must
# either time out an entry or receive an entry when called
# with no arguments.
$self->recv();
}
Net-DNS-Codes
view release on metacpan or search on metacpan
extra_docs/af-saa-0069.000.txt view on Meta::CPAN
? Hierarchical naming structure (scalability)
? low latency of queries
? Toleration of temporary inconsistency, that is, that such
inconsistency does not damage the information in ANS.
? The service may sometimes be transiently unavailability, for
example, “a busy signal”
Other ANS requirements include:
? Independence between non-ATM network and transport layer
protocols
Net-DNS-Dig
view release on metacpan or search on metacpan
push @wmsg, $buffer;
push @who, $rsin;
}
}
if ($wout && @wmsg) { # if there is work
unless ($woff) { # if not busy
$wmsglen = $wmsglen[0];
}
if ($wlen = send($remotsock,$wmsg[0],0,$who[0])) {
$wmsglen -= $wlen;
$woff += $wlen;
Net-DNS-Multicast
view release on metacpan or search on metacpan
lib/Net/DNS/Multicast.pm view on Meta::CPAN
}
return $select;
}
sub Net::DNS::Resolver::bgbusy {
my ( $self, $select ) = @_;
my ($handle) = ( $select->can_read(0), $select->handles );
return Net::DNS::Resolver::Base::bgbusy( $self, $handle );
}
sub Net::DNS::Resolver::bgread {
my ( $self, $select ) = @_;
Net-DNS-Native
view release on metacpan or search on metacpan
lib/Net/DNS/Native.pm view on Meta::CPAN
requests will be queued until one of the threads will become free to process next request from the queue.
=item extra_thread => $bool
If pool option specified and $bool has true value will create temporary extra thread for each request that can't be handled by the
pool (when all workers in the pool are busy) instead of pushing it to the queue. This temporary thread will be finished immediatly
after it will process request.
=item notify_on_begin => $bool
Extra mechanizm to notify caller that resolving for some host started. This is usefull for those who uses thread pool without C<extra_thread>
lib/Net/DNS/Native.pm view on Meta::CPAN
=head2 timedout($handle)
Mark resolving operation associated with this handle as timed out. This will not interrupt resolving operation (because there is no way to interrupt getaddrinfo(3) correctly),
but will automatically discard any results returned when resolving will be done. So, after C<timedout($handle)> you can forget about C<$handle> and
associated resolving operation. And don't need to call C<get_result($handle)> to destroy resources associated with this handle. Furthermore, if you are using thread pool
and all threads in pool are busy and C<extra_thread> option not specified, but 1 resolving operation from this pool marked as timed out and you'll add one more resolving operation,
this operation will not be queued. Instead of this 1 temporary extra thread will be created to process this operation. So you can think about C<timedout> like about real interrupter of
long running resolving operation. But you are warned how it really works. B<Note:> since 0.16 handles will be automatically marked as timedout during destruction, so you no need more to
call C<timedout($handle)> yourself, just lose last reference to this handle.
=head1 AUTHOR
Net-DNS-QueryID
view release on metacpan or search on metacpan
$VERSION = do { my @r = (q$Revision: 0.02 $ =~ /\d+/g); sprintf "%d."."%02d" x $#r, @r };
@EXPORT_OK = qw(
id_get
id_clr
id_busy
);
sub DESTROY {};
=head1 NAME
http://en.wikipedia.org/wiki/DNS_cache_poisoning
use Net::DNS::QueryID qw(
id_get
id_clr
id_busy
);
$queryID = id_get();
$result = id_clr($queryID);
$result = id_busy($queryID);
=cut
my $idvec = '';
foreach(0..2047) { # set 65536 long vector string to zero
return 0 unless vec($idvec,$_[0],1);
vec($idvec,$_[0],1) = 0x0;
return $_[0];
}
=item * $result = id_busy($queryID);
input: Query ID
returns: true if Query ID is in the cache
false if Query ID is not in the cache
false if Query ID is out of range
i.e. not 1 -165535
=cut
sub id_busy($) {
return 0 if $_[0] < 1 or $_[0] > 65535;
vec($idvec,$_[0],1);
}
sub _mode {
=head1 EXPORTS_OK
id_get
id_clr
id_busy
=head1 AUTHOR
Michael Robinton <michael@bizsystems.com>
Net-DNS-Resolver-DoH
view release on metacpan or search on metacpan
lib/Net/DNS/Resolver/DoH.pm view on Meta::CPAN
}
#sub srcaddr { ## TODO
sub bgsend { die 'not implemented' }
sub bgbusy { die 'not implemented' }
sub bgread { die 'not implemented' }
sub bgisready { die 'not implemented' }
sub axfr { die 'not implemented' }
## TODO override methods not available via DoH
Net-DNS-Resolver-Unbound
view release on metacpan or search on metacpan
lib/Net/DNS/Resolver/Unbound.pm view on Meta::CPAN
}
sub nameserver { return &nameservers }
=head2 search, query, send, bgsend, bgbusy, bgread
See L<Net::DNS::Resolver>.
=cut
lib/Net/DNS/Resolver/Unbound.pm view on Meta::CPAN
my $ident = $query->header->id;
my ($q) = $query->question;
return $self->{ub_ctx}->ub_resolve_async( $q->name, $q->{qtype}, $q->{qclass}, $ident );
}
sub bgbusy {
my ( $self, $handle ) = @_;
return unless $handle;
return unless $handle->waiting;
$self->{ub_ctx}->ub_process;
eval { select( undef, undef, undef, 0.200 ) }; # avoid tight loop on bgbusy()
return $handle->waiting;
}
sub bgread {
my ( $self, $handle ) = @_;
Net-DNS
view release on metacpan or search on metacpan
lib/Net/DNS.pm view on Meta::CPAN
my $res = Net::DNS::Resolver->new;
$res->udp_timeout(10);
$res->tcp_timeout(20);
my $socket = $res->bgsend( "www.example.com", "AAAA" );
while ( $res->bgbusy($socket) ) {
# do some work here whilst awaiting the response
# ...and some more here
}
my $packet = $res->bgread($socket);
Net-DNSBL-MultiDaemon
view release on metacpan or search on metacpan
MultiDaemon.pm view on Meta::CPAN
}
elsif ($rip eq '2.0.0.127') { # checkfor DNSBL test
($msg) = _ansrbak($put,$id,1,$rip,$zone,$type,3600,A1272,$BLzone,$myip,'DNSBL test response to 127.0.0.2');
$comment = 'just testing';
}
### NOTE, $now does not get updated very often if the host is busy processing in this routine, but at least every 5 minutes.... good enough
elsif ( $csize && # cacheing enabled
exists $cache{$rip} && # item exists in cache
($expires = $cache{$rip}->{expires}) > $now ) { # cache not expired
$cache{$rip}->{used} = $now; # update last used time
my $blist_0 = $cache{$rip}->{who};
MultiDaemon.pm view on Meta::CPAN
}
}
last;
}
}
##################### TIMEOUT, do busywork #######################
else { # must be timeout
my $prpshadow = $prp;
$now = time; # check various alarm status
unless ($now < $next) {
average($STATs);
( run in 0.675 second using v1.01-cache-2.11-cpan-87723dcf8b7 )