Result:
found more than 817 distributions - search limited to the first 2001 files matching your query
( run in 2.726 )
Net-Nostr-Core
view release on metacpan or search on metacpan
lib/Net/Nostr/Calendar.pm view on Meta::CPAN
my $rsvp = Net::Nostr::Calendar->rsvp(
pubkey => $hex_pubkey,
identifier => 'rsvp-1',
event_coord => "31922:$organizer_pk:vacation-2024",
status => 'accepted',
fb => 'busy',
);
# Parse any calendar event
my $parsed = Net::Nostr::Calendar->from_event($event);
lib/Net/Nostr/Calendar.pm view on Meta::CPAN
event_coord => $coord, # required (a tag)
status => 'accepted', # required
event_relay => $url, # optional (a tag relay)
event_id => $eid, # optional (e tag)
event_id_relay => $url, # optional (e tag relay)
fb => 'busy', # optional (free/busy)
event_author => $pk, # optional (p tag)
event_author_relay => $url, # optional (p tag relay)
content => $note, # optional, defaults to ''
);
lib/Net/Nostr/Calendar.pm view on Meta::CPAN
RSVP status: C<accepted>, C<declined>, or C<tentative>.
=head2 fb
Free/busy indicator: C<free> or C<busy>. Must be omitted or ignored if
C<status> is C<declined>.
=head2 event_author
Pubkey of the calendar event author (RSVP only).
Net-OpenVAS
view release on metacpan or search on metacpan
lib/Net/OpenVAS/OMP/Response.pm view on Meta::CPAN
sub is_not_found {
my ($self) = @_;
return ( $self->status == 404 ) ? 1 : 0;
}
sub is_busy {
my ($self) = @_;
return ( $self->status == 409 ) ? 1 : 0;
}
sub is_server_error {
lib/Net/OpenVAS/OMP/Response.pm view on Meta::CPAN
=head3 $response->is_forbidden (403)
=head3 $response->is_not_found (404)
=head3 $response->is_busy (409)
=head3 $response->is_server_error (>500)
=head1 SUPPORT
Net-PH
view release on metacpan or search on metacpan
per match from the server.
=item change( SEARCH , MAKE )
$r = $ph->change({ email => "*.domain.name" },
{ schedule => "busy");
Change field values for matching entries.
The C<SEARCH> argument is a reference to a HASH which contains field/value
pairs which will be passed to the Nameserver as the search criteria.
will set new values to designated fields.
The alternative syntax is to pass strings instead of references, for example
$r = $ph->change('email="*.domain.name"',
'schedule="busy"');
The C<SEARCH> argument is a string to be passed to the Nameserver as the
search criteria. The strings being passed should B<not> contain any carriage
returns, or else the query command might fail or return invalid data.
Net-Ping
view release on metacpan or search on metacpan
Patch by jef@linuxbe.org (Jean-Francois Dive).
- Changed default behavior of "syn" protocol to
disabled tcp_service_check instead of enabled.
- Win32 compatibility changes ("syn" protocol).
- Increase timeouts for tests in case client or
server network(s) are busy.
2.21 Oct 14 12:00 2002
- Preserve/restore ALRM settings for tcp mode pings.
Spot by d@niel-berlin.de (Daniel Berlin)
- Can now select device for udp and icmp protocols.
Net-Prometheus-ServerStatusLiteCollector
view release on metacpan or search on metacpan
lib/Net/Prometheus/ServerStatusLiteCollector.pm view on Meta::CPAN
next if $line =~ m/^\D/;
my ($ppid, $pid) = split /\s+/, $line, 2;
push @all_workers, $pid if $ppid == $parent_pid;
}
# Count busy and idle workers
my $idle = 0;
my $busy = 0;
my @process_status;
for my $pid (@all_workers) {
my $json = $stats->{$pid};
$pstatus = eval {
$JSON->decode($json || '{}');
};
$pstatus ||= {};
if ($pstatus->{status} && $pstatus->{status} eq 'A') {
$busy++;
}
else {
$idle++;
}
lib/Net/Prometheus/ServerStatusLiteCollector.pm view on Meta::CPAN
delete $pstatus->{ppid};
delete $pstatus->{uptime};
push @process_status, $pstatus;
}
push @samples,
MetricSamples('plack_busy_workers', gauge => 'Number of busy Plack workers',
[Sample('plack_busy_workers', $self->labels, $busy)]);
push @samples,
MetricSamples('plack_idle_workers', gauge => 'Number of idle Plack workers',
[Sample('plack_idle_workers', $self->labels, $idle)]);
$stats = {};
Net-RCON-Minecraft
view release on metacpan or search on metacpan
lib/Net/RCON/Minecraft.pod view on Meta::CPAN
this many seconds to send all the bytes we are expecting, we will C<croak()>
with a timeout error message.
The default of 30 seconds is normally enough, but may need to be set higher if
you are running a command that takes a long time, or the Minecraft server is
very busy.
=head2 connect
B<This method is optional.> By default, this module will connect to the
Minecraft server automatically as soon as the first C<command()> is run. It
Net-RVP
view release on metacpan or search on metacpan
Event->timer(interval => ($ival < 1 ? 1 : $ival), cb => sub {
$_->watch() for values %$users; });
}
=pod
my @state = qw(offline online idle on-phone at-lunch busy);
Event->timer(interval => 60,
cb => sub { $rvp->status($state[rand @state]) });
=cut
# add a STDIN I/O event
Net-Radio-Location-SUPL-Test
view release on metacpan or search on metacpan
asn1/AbsentSubscriberReason.c view on Meta::CPAN
{ 0, 10, "imsiDetach" },
{ 1, 14, "restrictedArea" },
{ 2, 14, "noPageResponse" },
{ 3, 8, "purgedMS" },
{ 4, 14, "mtRoamingRetry" },
{ 5, 14, "busySubscriber" }
/* This list is extensible */
};
static unsigned int asn_MAP_AbsentSubscriberReason_enum2value_1[] = {
5, /* busySubscriber(5) */
0, /* imsiDetach(0) */
4, /* mtRoamingRetry(4) */
2, /* noPageResponse(2) */
3, /* purgedMS(3) */
1 /* restrictedArea(1) */
Net-Radius-Server
view release on metacpan or search on metacpan
examples/nrsd.cfg view on Meta::CPAN
# background 1
# setsid 1
# These keys control the number of processes to keep running and a few
# other aspects related to performance. Pay attention to max_requests,
# as memory growth can be an issue in busy serves.
#
# See Net::Server::PreFork for more information
min_servers 5
min_spare_servers 2
Net-Radius
view release on metacpan or search on metacpan
dicts/dictionary.3com-o view on Meta::CPAN
VENDORVALUE USR USR-Call-Event-Code calledPartyReject 19
VENDORVALUE USR USR-Call-Event-Code blocked 20
VENDORVALUE USR USR-Call-Event-Code analogBlocked 21
VENDORVALUE USR USR-Call-Event-Code digitalBlocked 22
VENDORVALUE USR USR-Call-Event-Code outOfService 23
VENDORVALUE USR USR-Call-Event-Code busy 24
VENDORVALUE USR USR-Call-Event-Code congestion 25
VENDORVALUE USR USR-Call-Event-Code protocolError 26
VENDORVALUE USR USR-Call-Event-Code noFreeBchannel 27
VENDORVALUE USR USR-Call-Event-Code inOutCallCollision 28
VENDORVALUE USR USR-Call-Event-Code inCallArrival 29
Net-Random
view release on metacpan or search on metacpan
2.3 2013-07-25 Fix nasty context bug. scalar($rand->get(1)) would
always give you 1 (the number of elements in the
list returned) instead of a useful number.
2.22 2012-05-26 Cope with broken JSON from QRNG when they're busy
2.21 2012-05-20 Use JSON API for qrng, thanks to Syed Assad for
telling me about it
2.2 2012-05-16 Add support for qrng.anu.edu.au, thanks to Steve Wills
Net-SNMP
view release on metacpan or search on metacpan
- The methods that expect a SNMP GetResponse-PDU in "blocking" mode now ignore
messages with request-ids that do not match the current request-id. This
change addresses a common occurrence of the "Received request-id xxxx is
not equal to transmitted request-id xxxx" error. The manifestation of this
error that has been corrected occurs when a remote agent is too busy to
respond immediately, buffers the request, and responds to the request after
the Net::SNMP timeout has expired.
- A new argument "-delay" was added to all methods that can function in "non-
blocking" mode.
- The Net::SNMP::FSM "event loop" sub-module was completely rewritten to more
RELEASE 3.01 JAN-01-2000
- Performance enhancements were made to the most heavily used methods.
- Changed the default timeout to 5.0 seconds and the default number of retries
to 1 to reduce network traffic and to work around a problem with responses
from certain routers when they are busy. The total default timeout period
remains the same at 10 seconds.
- Removed the verify_ip() method and the "-verifyip" argument to the
constructor.
RELEASE 3.00 SEP-09-1999
Net-Server-Framework
view release on metacpan or search on metacpan
lib/Net/Server/Framework.pm view on Meta::CPAN
This version uses SQLite as the standard DB. Most parameters in the
system (including the database type) are configurable via INI style
config files.
This framework is used in some quite busy environments and some things
might look strange but are the result of optimization or problems we ran
into when scaling. One such thing is the DB abstraction which is tuned
for the least possible overhead (memory and cpu wise).
The source code and some working examples can be found on github:
Net-SloppyXMPP
view release on metacpan or search on metacpan
lib/Net/SloppyXMPP.pm view on Meta::CPAN
#usesasl => 0, # set this if you don't want SASL
domain => 'yourdomain.xyz',
username => 'yourusername',
password => 'yourpassword',
resource => 'yourresourcename', # or don't set and a default will be supplied
initialpresence => 'available', # available, busy, dnd, defaults to available
initialstatus => 'I am alive!', # defaults to ''
message_callback => \&messageCallback,
);
die qq(XMPP didn't create.\n) unless $xmpp;
Net-Squid-Auth-Plugin-SimpleLDAP
view release on metacpan or search on metacpan
lib/Net/Squid/Auth/Plugin/SimpleLDAP.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 *
Net-Telnet-Gearman
view release on metacpan or search on metacpan
lib/Net/Telnet/Gearman/Function.pm view on Meta::CPAN
use strict;
use warnings;
use base qw/Class::Accessor::Fast/;
use Scalar::Util qw(looks_like_number);
__PACKAGE__->mk_accessors(qw/name queue busy free running/);
sub parse_line {
my ( $package, $line ) = @_;
my ( $name, $queue, $busy, $running ) = split /[\s]+/, $line;
return
if !looks_like_number($queue)
|| !looks_like_number($busy)
|| !looks_like_number($running);
my $free = $running - $busy;
return $package->new(
{
name => $name,
queue => $queue,
busy => $busy,
free => $free,
running => $running,
}
);
}
lib/Net/Telnet/Gearman/Function.pm view on Meta::CPAN
print Dumper @functions
# $VAR1 = bless(
# {
# 'busy' => 10,
# 'free' => 0,
# 'name' => 'resize_image',
# 'queue' => 74,
# 'running' => 10
# },
lib/Net/Telnet/Gearman/Function.pm view on Meta::CPAN
=head2 queue
Returns the amount of queued jobs for this function.
=head2 busy
Returns the amount of workers currently working on this function.
=head2 free
Net-Tomcat
view release on metacpan or search on metacpan
lib/Net/Tomcat/Connector/Statistics.pm view on Meta::CPAN
package Net::Tomcat::Connector::Statistics;
use strict;
use warnings;
our @ATTR = qw(max_threads current_thread_count current_thread_busy max_processing_time
processing_time request_count error_count bytes_received bytes_sent);
foreach my $attr ( @ATTR ) {{
no strict 'refs';
*{ __PACKAGE__ . "::$attr" } = sub { my $self = shift; return $self->{$attr} }
lib/Net/Tomcat/Connector/Statistics.pm view on Meta::CPAN
=head3 current_thread_count
Returns the number of threads currently in use by the connector.
=head3 current_thread_busy
Returns the number of threads currently marked busy by the connector.
=head3 max_processing_time
Returns the maximum request processing time for the connector.
Net-UPS
view release on metacpan or search on metacpan
lib/Net/UPS.pm view on Meta::CPAN
=back
=head1 BUGS AND KNOWN ISSUES
No bugs are known of as of this release. If you think you found a bug, document it at http://rt.cpan.org/NoAuth/Bugs.html?Dist=Net-UPS. It's more likely to get noticed in there than in my busy inbox.
=head1 TODO
There are still a lot of features UPS.com offers in its Online Tools API that Net::UPS doesn't handle. This is the list of features that need to be supported before Net::UPS can claim full compliance.
Net-Waiter
view release on metacpan or search on metacpan
lib/Net/Waiter.pm view on Meta::CPAN
$self->{ 'PREFORK' } = abs( $pf );
$self->{ 'MAXFORK' } = abs( $pf ) unless $mf > 0;
}
# timeout cap
$self->{ 'TIMEOUT' } = 1 if $self->{ 'TIMEOUT' } < 1; # avoid busyloop
$self->{ 'TIMEOUT' } = 3600 if $self->{ 'TIMEOUT' } > 3600; # 1 hour max should be enough :)
$self->{ 'PX_IDLE' } = 31 if $self->{ 'PX_IDLE' } < 1;
bless $self, $class;
lib/Net/Waiter.pm view on Meta::CPAN
$SIG{ 'CHLD' } = sub { $self->__sig_child(); };
$SIG{ 'HUP' } = sub { $self->__sig_hup(); };
$SIG{ 'USR1' } = sub { $self->__sig_usr1(); };
$SIG{ 'USR2' } = sub { $self->__sig_usr2(); };
$SIG{ 'RTMIN' } = sub { $self->__sig_kid_idle() };
$SIG{ 'RTMAX' } = sub { $self->__sig_kid_busy() };
srand();
$self->on_server_begin();
lib/Net/Waiter.pm view on Meta::CPAN
last if $self->{ 'BREAK_MAIN_LOOP' };
if( $self->{ 'PREFORK' } > 0 )
{
$self->__run_prefork( $server_socket );
sleep(4); # will be interrupted by busy/free signals
}
else
{
$self->__run_forking( $server_socket );
# no need for sleep since, select/accept will block for a while (4 sec)
lib/Net/Waiter.pm view on Meta::CPAN
$SIG{ 'TERM' } = sub { $self->break_main_loop(); };
$SIG{ 'HUP' } = sub { $self->__child_sig_hup(); };
$SIG{ 'USR1' } = sub { $self->__child_sig_usr1(); };
$SIG{ 'USR2' } = sub { $self->__child_sig_usr2(); };
$SIG{ 'RTMIN' } = sub { $self->__sig_kid_idle() };
$SIG{ 'RTMAX' } = sub { $self->__sig_kid_busy() };
# ignored here, if smb needs it, should reinstall
$SIG{ 'CHLD' } = 'IGNORE';
$self->{ 'SHA' } = new IPC::Shareable key => $self->{ 'SHA_KEY' } or die "fatal: cannot attach shared memory segment\n";
srand();
$client_socket->autoflush( 1 );
$self->on_child_start();
$self->im_busy();
$self->on_process( $client_socket );
$self->on_close( $client_socket );
$client_socket->close();
$self->im_idle();
lib/Net/Waiter.pm view on Meta::CPAN
my $server_socket = shift;
my $prefork_count = $self->{ 'PREFORK' };
my $kk = $self->{ 'KIDS' }; # kids k'ount ;)
my $bk = $self->get_busy_kids_count(); # busy count
my $ik = $kk - $bk; # idle kids count
my $tk = $prefork_count;
#$tk = $kk + $prefork_count / 2 if $kk > $prefork_count and $ik < ( 1 + $prefork_count / 10 );
$tk = $kk + $prefork_count if $ik <= ( 1 + $kk / 10 );
lib/Net/Waiter.pm view on Meta::CPAN
$self->{ 'STAT' }{ 'IDLE_FREQ' }{ int( $ik / 5 ) * 5 }++ if $bk > 0;
$self->__prefork_print_stat() if $self->{ 'DEBUG' };
$__prefork_next_stat = time() + 4;
}
my $tbk = $self->{ 'STAT' }{ 'BUSY_COUNT' };
$self->log_debug( "debug: kids: $kk busy: $bk idle: $ik to_fork: $tk will_fork?: $kk < $tk total busy count: $tbk" );
while( $self->{ 'KIDS' } < $tk )
{
my $pid;
$pid = fork();
lib/Net/Waiter.pm view on Meta::CPAN
$SIG{ 'TERM' } = sub { $self->break_main_loop(); };
$SIG{ 'HUP' } = sub { $self->__child_sig_hup(); };
$SIG{ 'USR1' } = sub { $self->__child_sig_usr1(); };
$SIG{ 'USR2' } = sub { $self->__child_sig_usr2(); };
$SIG{ 'RTMIN' } = sub { $self->__sig_kid_idle() };
$SIG{ 'RTMAX' } = sub { $self->__sig_kid_busy() };
# ignored here, if smb needs it, should reinstall
$SIG{ 'CHLD' } = 'IGNORE';
$self->{ 'SHA' } = new IPC::Shareable key => $self->{ 'SHA_KEY' } or die "fatal: cannot attach shared memory segment\n";
lib/Net/Waiter.pm view on Meta::CPAN
my $sockport = $client_socket->sockport();
$self->on_accept_ok( $client_socket );
$self->{ 'BUSY_COUNT' }++;
$self->im_busy();
$client_socket->autoflush( 1 );
my $res = $self->on_process( $client_socket );
$self->on_close( $client_socket );
$client_socket->close();
$self->im_idle();
lib/Net/Waiter.pm view on Meta::CPAN
my $self = shift;
return exists $self->{ 'CLIENT_SOCKET' } ? $self->{ 'CLIENT_SOCKET' } : undef;
}
sub get_busy_kids_count
{
my $self = shift;
return wantarray ? ( $self->{ 'KIDS_BUSY' }, $self->{ 'KIDS' } ) : $self->{ 'KIDS_BUSY' };
}
lib/Net/Waiter.pm view on Meta::CPAN
return () if $self->is_child();
return keys %{ $self->{ 'KID_PIDS' } || {} };
}
sub im_busy
{
my $self = shift;
return $self->__im_in_state( '*' );
}
lib/Net/Waiter.pm view on Meta::CPAN
$SIG{ 'RTMIN' } = sub { $self->__sig_kid_idle() };
}
# used only for waking up preforked servers main loop sleep
sub __sig_kid_busy
{
my $self = shift;
$SIG{ 'RTMAX' } = sub { $self->__sig_kid_busy() };
}
##############################################################################
sub on_server_begin
lib/Net/Waiter.pm view on Meta::CPAN
=head2 get_client_socket()
Returns connected client socket.
=head2 get_busy_kids_count()
Returns the count of all forked busy processes (which are already accepted connection).
In array contect returns two integers: busy process count and all forked processes count.
This method is accessible from parent and all forked processes and reflect all processes.
Returns client (connected) socket object. Valid in kids only, otherwise returns undef.
=head2 get_kid_pids()
Net-Whois
view release on metacpan or search on metacpan
=head1 DESCRIPTION
Net::Whois::Domain new() attempts to retrieve and parse the given
domain's "whois" information from the InterNIC (whois.internic.net).
If the server could not be contacted, is too busy, or otherwise does not process
the query then the constructor does not return a reference and your object is undefined.
If the constructor returns a reference, that reference can be used to access the various
attributes of the domains' whois entry assuming that there was a match.
The member function ok returns 1 if a match 0 if no match.
Net-Wire10
view release on metacpan or search on metacpan
lib/Net/Wire10.pm view on Meta::CPAN
}
# Fail if currently connected to a streaming data reader
sub _check_streaming {
my $self = shift;
$self->_vanilla_error("Connection is busy streaming") if $self->{streaming};
}
# Connects to the database server
sub _connect {
my $self = shift;
Net-YMSG
view release on metacpan or search on metacpan
}
=head2 $yahoo->change_state($busy, $status_message)
This method sets the I<status messages> for the current user. 'Status message' is set by C<$status_message>. 'Busy icon' is set by the numerical value of C<$busy>.
The C<$busy> should be called with following arguments:
0 - I'm Available
1 - Busy
2 - Sleep
=cut
sub change_state
{
my $self = shift;
my $busy = shift;
my $message = join '', @_;
my $server = $self->handle;
my $event = $self->create('ChangeState');
$event->status_code(99); # 99 : Custom status
$event->busy($busy);
$event->body($message);
$server->send($event->to_raw_string, 0);
}
my $status_code = shift || 0;
my $server = $self->handle;
my $event = $self->create('ChangeState');
$event->status_code($status_code);
$event->busy(1);
$server->send($event->to_raw_string, 0);
}
id => 'yahoo_id',
password => 'password',
);
$yahoo->login or die "Can't login Yahoo!Messenger";;
$yahoo->change_state(IN_BUSY, q{I'm very busy now!});
sleep 5;
__END__
=head2 Become Invisible
Net-YahooMessenger
view release on metacpan or search on metacpan
lib/Net/YahooMessenger.pm view on Meta::CPAN
$event->body($message);
$event->option(1515563606); # in Buddy list then 1515563606 else 1515563605
$server->send( $event->to_raw_string, 0 );
}
=head2 $yahoo->change_state($busy, $status_message)
This method sets the I<status messages> for the current user. 'Status message' is set by C<$status_message>. 'Busy icon' is set by the numerical value of C<$busy>.
The C<$busy> should be called with following arguments:
0 - I'm Available
1 - Busy
2 - Sleep
=cut
sub change_state {
my $self = shift;
my $busy = shift;
my $message = join '', @_;
my $server = $self->handle;
my $event = $self->create('ChangeState');
$event->status_code(99); # 99 : Custom status
$event->busy($busy);
$event->body($message);
$server->send( $event->to_raw_string, 0 );
}
lib/Net/YahooMessenger.pm view on Meta::CPAN
my $status_code = shift || 0;
my $server = $self->handle;
my $event = $self->create('ChangeState');
$event->status_code($status_code);
$event->busy(1);
$server->send( $event->to_raw_string, 0 );
}
sub ping {
lib/Net/YahooMessenger.pm view on Meta::CPAN
id => 'yahoo_id',
password => 'password',
);
$yahoo->login or die "Can't login Yahoo!Messenger";;
$yahoo->change_state(IN_BUSY, q{I'm very busy now!});
sleep 5;
__END__
=head2 Received message output to STDOUT
Net-Z3950-AsyncZ
view release on metacpan or search on metacpan
{
my @results=();
my @errors=();
my @recSize = ();
my $busy = 0;
my $utf8_init = 0;
sub is_utf8_init {
$utf8_init;
}
$results[$index]->[$i] = $cs->to_utf8($results[$index]->[$i]);
}
}
sub _saveResults {
$busy = 1;
my ($arr, $index) = @_;
$results[$index] = $arr;
$busy = 0;
}
sub _saveErrors {
@errors = @_;
}
sub _isBusy { return $busy; }
# returns reference to results array
sub getResult {
my ($self,$index) = @_;
_utf8($index) if $self->{options}[$index]-> _getFieldValue('utf8');
sub getMaxErrors { return scalar @errors; }
sub _callback {
$busy = 1;
my ($self, $index) = @_;
_utf8($index) if $self->{options}[$index]-> _getFieldValue('utf8');
my $cb = $self->{options}[$index]-> _getFieldValue('cb');
$cb = $self->{cb} if !$cb;
$size =~ /\*==(\d+)==\*/;
$recSize[$index] = $1 ? $1 : 0;
$results[$index]->[$last_el] =~s/\*==(\d+)==\*//;
&$cb($index, $results[$index]) if $cb;
$busy = 0;
}
}
NetAddr-BridgeID
view release on metacpan or search on metacpan
lib/NetAddr/BridgeID.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 *
NetApp
view release on metacpan or search on metacpan
lib/NetApp/Volume.pm view on Meta::CPAN
croak(__PACKAGE__ . "->delete_all_snapshots not yet implemented\n");
# XXX: This one's tricky to implement. Should we parse the
# output, and attempt to return a list of what was delete, and
# what was busy? Probably too ugly.
my $self = shift;
return $self->get_filer->_run_command(
command => [ qw( snap delete -a -f -q ), $self->get_name ],
NetSDS
view release on metacpan or search on metacpan
lib/NetSDS/EDR.pm view on Meta::CPAN
This methods converts records to JSON and write to file.
Each record writing to one separate string.
Example:
$edr->write({from => '380441234567', to => '5552222', status => 'busy'});
=cut
#-----------------------------------------------------------------------
sub write {
NetServer-Generic
view release on metacpan or search on metacpan
$SIG{CHLD} = \&reap_child;
my @buffer = ();
my $buffer = "";
$NetServer::Debug && print STDERR "$n: About to loop on scoreboard file\n";
my $loopcnt = 0;
my $busycnt = 0;
my @busyvec = ();
#while(@buffer = $self->_read_fifo()) {
*READ_PIPE = $self->read_pipe();
while($buffer = <READ_PIPE>) {
$NetServer::Debug
&& print STDERR "busyvec: [", join("][", @busyvec), "]\n";
$loopcnt++;
$NetServer::Debug
&& print STDERR "$n: in pipe read loop $loopcnt\n";
$buffer =~ tr/ //;
chomp $buffer;
$NetServer::Debug
&& print STDERR "$n: buffer: $buffer\n";
my ($child_pid, $status) = split(/:/, $buffer);
# kids write $$:busy or $$:idle into the pipe whenever
# they change state.
if ($status eq "exit") {
# a child just exited on us
$NetServer::Debug
&& print STDERR "$n: child $child_pid just died\n";
delete($scoreboard->{$child_pid});
} elsif ($status eq "busy") {
$scoreboard->{$child_pid} = "busy";
push(@busyvec, $child_pid);
$busycnt++;
} elsif ($status eq "idle") {
$scoreboard->{$child_pid} = "idle";
@busyvec = grep(!/$child_pid/, @busyvec);
$busycnt--;
} elsif ($status eq "start") {
$scoreboard->{$child_pid} = "idle";
}
$NetServer::Debug && print STDERR "$n: $child_pid has status [",
$scoreboard->{$child_pid}, "]\n",
"$n: got ", scalar(@busyvec), " busy kids\n";
$busycnt = scalar(@busyvec);
my $all_kids = scalar keys %$scoreboard;
$NetServer::Debug &&
print STDERR "$n: $busycnt children busy of $all_kids total\n";
# busy_kids is number of kids currently busy; all_kids is number of kids
if ((($all_kids - $busycnt) < $spare_servers) and
($all_kids <= $max_servers)) {
my $kids_to_launch = ($spare_servers - ($all_kids - $busycnt)) +1;
$NetServer::Debug &&
print STDERR "spare servers: $spare_servers, ",
"all kids: $all_kids, ",
"busycnt: $busycnt\n",
"kids to launch = spares - (all - busy) +1 ",
" => $kids_to_launch\n";
# launch new children
for (my ($i) = 0; $i < $kids_to_launch; $i++) {
my $pid = fork();
sub _do_preforked_child {
my $self = shift;
# we are a preforked child process. We have an IO::Pipe called
# $self->writer() that we write strange things to. Each "strange thing"
# consists of a line containing our PID, a colon, and one of three strings:
# busy, idle, or exit. We run like a run_select server, except that we
# write a busy line whenever we accept a connection, an idle line whenever
# we finish handling a connection, and an exit line when our age exceeds
# $self->server_lifespan() and we suicide.
#
my $n = "_do_preforked_child($$)"; # for reporting status
my $server_lifespan = ( $self->server_lifespan() or 1000 );
}
} else {
if (! eof($sock)) {
$my_age++;
$NetServer::Debug
&& print STDERR "$n: print WRITE_PIPE ($$:busy)\n";
print WRITE_PIPE "$$:busy\n";
$NetServer::Debug
&& print STDERR "$n: serving connection\n";
$sock->autoflush(1);
my ($in_port, $in_addr) = sockaddr_in($sock->sockname());
$self->servername([$in_port, $in_addr]);
NetServer-Portal
view release on metacpan or search on metacpan
lib/NetServer/Portal/Top.pm view on Meta::CPAN
$s .= $tm."\n";
my @load;
my @events = all_watchers();
for my $sec (15,60,60*15) {
my $busy = 0;
for (@events) { $busy += ($_->stats($sec))[2] }
my $idle = (idle_time($sec))[2];
my $tm = $idle + $busy;
push @load, $tm? $busy / $tm : 0;
}
my @all = map {
[{ obj => $_,
id => assign_id($_),
NexposeSimpleXML-Parser
view release on metacpan or search on metacpan
t/test1.xml view on Meta::CPAN
/doc/libmysqlclient15off/
</key>
</vulnerability>
<vulnerability id="http-generic-browsable-dir" resultCode="VE">
<key>
/doc/busybox-initramfs/
</key>
</vulnerability>
<vulnerability id="http-generic-browsable-dir" resultCode="VE">
<key>
/doc/gstreamer0.10-plugins-base/
( run in 2.726 seconds using v1.01-cache-2.11-cpan-600a1bdf6e4 )