File manager - Edit - /usr/local/cpanel/3rdparty/perl/542/cpanel-lib/MCE/Channel/SimpleFast.pm
Back
############################################################################### ## ---------------------------------------------------------------------------- ## Channel tuned for one producer and one consumer involving no locking. ## ############################################################################### package MCE::Channel::SimpleFast; use strict; use warnings; no warnings qw( uninitialized once ); our $VERSION = '1.901'; use base 'MCE::Channel'; my $LF = "\012"; Internals::SvREADONLY($LF, 1); my $is_MSWin32 = ( $^O eq 'MSWin32' ) ? 1 : 0; sub new { my ( $class, %obj ) = ( @_, impl => 'SimpleFast' ); $obj{init_pid} = MCE::Channel::_pid(); MCE::Util::_sock_pair( \%obj, 'p_sock', 'c_sock' ); return bless \%obj, $class; } ############################################################################### ## ---------------------------------------------------------------------------- ## Queue-like methods. ## ############################################################################### sub end { my ( $self ) = @_; local $\ = undef if (defined $\); MCE::Util::_sock_ready_w( $self->{p_sock} ) if $is_MSWin32; print { $self->{p_sock} } pack('i', -1); $self->{ended} = 1; } sub enqueue { my $self = shift; return MCE::Channel::_ended('enqueue') if $self->{ended}; local $\ = undef if (defined $\); MCE::Util::_sock_ready_w( $self->{p_sock} ) if $is_MSWin32; while ( @_ ) { my $data = ''.shift; print { $self->{p_sock} } pack('i', length $data) . $data; } return 1; } sub dequeue { my ( $self, $count ) = @_; $count = 1 if ( !$count || $count < 1 ); local $/ = $LF if ( $/ ne $LF ); if ( $count == 1 ) { my ( $plen, $data ); MCE::Util::_sock_ready( $self->{c_sock} ) if $is_MSWin32; $is_MSWin32 ? sysread( $self->{c_sock}, $plen, 4 ) : read( $self->{c_sock}, $plen, 4 ); my $len = unpack('i', $plen); if ( $len < 0 ) { $self->end; return wantarray ? () : undef; } return '' unless $len; $is_MSWin32 ? MCE::Channel::_read( $self->{c_sock}, $data, $len ) : read( $self->{c_sock}, $data, $len ); $data; } else { my ( $plen, @ret ); MCE::Util::_sock_ready( $self->{c_sock} ) if $is_MSWin32; while ( $count-- ) { my $data; $is_MSWin32 ? sysread( $self->{c_sock}, $plen, 4 ) : read( $self->{c_sock}, $plen, 4 ); my $len = unpack('i', $plen); if ( $len < 0 ) { $self->end; last; } push(@ret, ''), next unless $len; $is_MSWin32 ? MCE::Channel::_read( $self->{c_sock}, $data, $len ) : read( $self->{c_sock}, $data, $len ); push @ret, $data; } wantarray ? @ret : $ret[-1]; } } sub dequeue_nb { my ( $self, $count ) = @_; $count = 1 if ( !$count || $count < 1 ); my ( $plen, @ret ); local $/ = $LF if ( $/ ne $LF ); while ( $count-- ) { my $data; MCE::Util::_nonblocking( $self->{c_sock}, 1 ); $is_MSWin32 ? sysread( $self->{c_sock}, $plen, 4 ) : read( $self->{c_sock}, $plen, 4 ); MCE::Util::_nonblocking( $self->{c_sock}, 0 ); my $len; $len = unpack('i', $plen) if $plen; if ( !$len || $len < 0 ) { $self->end if defined $len && $len < 0; push @ret, '' if defined $len && $len == 0; last; } $is_MSWin32 ? MCE::Channel::_read( $self->{c_sock}, $data, $len ) : read( $self->{c_sock}, $data, $len ); push @ret, $data; } wantarray ? @ret : $ret[-1]; } ############################################################################### ## ---------------------------------------------------------------------------- ## Methods for two-way communication; producer(s) to consumers. ## ############################################################################### sub send { my $self = shift; return MCE::Channel::_ended('send') if $self->{ended}; my $data = ''.shift; local $\ = undef if (defined $\); MCE::Util::_sock_ready_w( $self->{p_sock} ) if $is_MSWin32; print { $self->{p_sock} } pack('i', length $data) . $data; return 1; } sub recv { my ( $self ) = @_; my ( $plen, $data ); local $/ = $LF if ( $/ ne $LF ); MCE::Util::_sock_ready( $self->{c_sock} ) if $is_MSWin32; $is_MSWin32 ? sysread( $self->{c_sock}, $plen, 4 ) : read( $self->{c_sock}, $plen, 4 ); my $len = unpack('i', $plen); if ( $len < 0 ) { $self->end; return wantarray ? () : undef; } return '' unless $len; $is_MSWin32 ? MCE::Channel::_read( $self->{c_sock}, $data, $len ) : read( $self->{c_sock}, $data, $len ); $data; } sub recv_nb { my ( $self ) = @_; my ( $plen, $data ); local $/ = $LF if ( $/ ne $LF ); MCE::Util::_nonblocking( $self->{c_sock}, 1 ); $is_MSWin32 ? sysread( $self->{c_sock}, $plen, 4 ) : read( $self->{c_sock}, $plen, 4 ); MCE::Util::_nonblocking( $self->{c_sock}, 0 ); my $len; $len = unpack('i', $plen) if $plen; if ( !$len || $len < 0 ) { $self->end if defined $len && $len < 0; return '' if defined $len && $len == 0; return wantarray ? () : undef; } $is_MSWin32 ? MCE::Channel::_read( $self->{c_sock}, $data, $len ) : read( $self->{c_sock}, $data, $len ); $data; } ############################################################################### ## ---------------------------------------------------------------------------- ## Methods for two-way communication; consumers to producer(s). ## ############################################################################### sub send2 { my $self = shift; my $data = ''.shift; local $\ = undef if (defined $\); MCE::Util::_sock_ready_w( $self->{c_sock} ) if $is_MSWin32; print { $self->{c_sock} } pack('i', length $data) . $data; return 1; } sub recv2 { my ( $self ) = @_; my ( $plen, $data ); local $/ = $LF if ( $/ ne $LF ); MCE::Util::_sock_ready( $self->{p_sock} ) if $is_MSWin32; $is_MSWin32 ? sysread( $self->{p_sock}, $plen, 4 ) : read( $self->{p_sock}, $plen, 4 ); my $len = unpack('i', $plen); return '' unless $len; $is_MSWin32 ? MCE::Channel::_read( $self->{p_sock}, $data, $len ) : read( $self->{p_sock}, $data, $len ); $data; } sub recv2_nb { my ( $self ) = @_; my ( $plen, $data ); local $/ = $LF if ( $/ ne $LF ); MCE::Util::_nonblocking( $self->{p_sock}, 1 ); $is_MSWin32 ? sysread( $self->{p_sock}, $plen, 4 ) : read( $self->{p_sock}, $plen, 4 ); MCE::Util::_nonblocking( $self->{p_sock}, 0 ); my $len; $len = unpack('i', $plen) if $plen; return '' if defined $len && $len == 0; return wantarray ? () : undef unless $len; $is_MSWin32 ? MCE::Channel::_read( $self->{p_sock}, $data, $len ) : read( $self->{p_sock}, $data, $len ); $data; } 1; __END__ ############################################################################### ## ---------------------------------------------------------------------------- ## Module usage. ## ############################################################################### =head1 NAME MCE::Channel::SimpleFast - Fast channel tuned for one producer and one consumer =head1 VERSION This document describes MCE::Channel::SimpleFast version 1.901 =head1 DESCRIPTION A channel class providing queue-like and two-way communication for one process or thread on either end; no locking needed. This is similar to L<MCE::Channel::Simple> but optimized for non-Unicode strings only. The main difference is that this module lacks freeze-thaw serialization. Non-string arguments become stringified; i.e. numbers and undef. The API is described in L<MCE::Channel> with the sole difference being C<send> and C<send2> handle one argument. Current module available since MCE 1.877. =over 3 =item new use MCE::Channel; my $chnl = MCE::Channel->new( impl => 'SimpleFast' ); =back =head1 QUEUE-LIKE BEHAVIOR =over 3 =item enqueue =item dequeue =item dequeue_nb =item end =back =head1 TWO-WAY IPC - PRODUCER TO CONSUMER =over 3 =item send =item recv =item recv_nb =back =head1 TWO-WAY IPC - CONSUMER TO PRODUCER =over 3 =item send2 =item recv2 =item recv2_nb =back =head1 AUTHOR Mario E. Roy, S<E<lt>marioeroy AT gmail DOT comE<gt>> =cut
| ver. 1.4 |
Github
|
.
| PHP 8.1.34 | Generation time: 0.04 |
proxy
|
phpinfo
|
Settings