commit perl-MCE for openSUSE:Factory
Hello community, here is the log from the commit of package perl-MCE for openSUSE:Factory checked in at 2019-12-30 12:34:55 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Comparing /work/SRC/openSUSE:Factory/perl-MCE (Old) and /work/SRC/openSUSE:Factory/.perl-MCE.new.6675 (New) ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Package is "perl-MCE" Mon Dec 30 12:34:55 2019 rev:15 rq:759928 version:1.865 Changes: -------- --- /work/SRC/openSUSE:Factory/perl-MCE/perl-MCE.changes 2019-12-06 12:08:45.760130181 +0100 +++ /work/SRC/openSUSE:Factory/.perl-MCE.new.6675/perl-MCE.changes 2019-12-30 12:35:04.227812230 +0100 @@ -1,0 +2,16 @@ +Thu Dec 26 03:09:26 UTC 2019 - <timueller+perl@suse.de> + +- updated to 1.865 + see /usr/share/doc/packages/perl-MCE/Changes + + 1.865 Wed Dec 25 18:00:00 EST 2019 + + * Bug fix for two-way IPC stalling on Windows in MCE::Channel::Threads. + See https://www.perlmonks.org/?node_id=11110612 + + * Remove the check for MSWin32 in MCE::Channel::Mutex. MCE::Channel since + the 1st release silently defaults to MCE::Channel::Threads on Windows. + + * Small tweak to MCE::Signal. + +------------------------------------------------------------------- Old: ---- MCE-1.864.tar.gz New: ---- MCE-1.865.tar.gz ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Other differences: ------------------ ++++++ perl-MCE.spec ++++++ --- /var/tmp/diff_new_pack.ADhWes/_old 2019-12-30 12:35:05.343812829 +0100 +++ /var/tmp/diff_new_pack.ADhWes/_new 2019-12-30 12:35:05.343812829 +0100 @@ -17,7 +17,7 @@ Name: perl-MCE -Version: 1.864 +Version: 1.865 Release: 0 %define cpan_name MCE Summary: Many-Core Engine for Perl providing parallel processing capabilities ++++++ MCE-1.864.tar.gz -> MCE-1.865.tar.gz ++++++ diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/Changes new/MCE-1.865/Changes --- old/MCE-1.864/Changes 2019-12-04 18:58:04.000000000 +0100 +++ new/MCE-1.865/Changes 2019-12-26 01:39:48.000000000 +0100 @@ -1,11 +1,22 @@ Revision history for Perl module MCE. +1.865 Wed Dec 25 18:00:00 EST 2019 + + * Bug fix for two-way IPC stalling on Windows in MCE::Channel::Threads. + See https://www.perlmonks.org/?node_id=11110612 + + * Remove the check for MSWin32 in MCE::Channel::Mutex. MCE::Channel since + the 1st release silently defaults to MCE::Channel::Threads on Windows. + + * Small tweak to MCE::Signal. + 1.864 Wed Dec 04 13:00:00 EST 2019 - * Bug fix to MCE::Signal - Shared manager not exiting, introduced in 1.863. + * Bug fix in MCE::Signal - Shared manager not exiting, introduced in 1.863. * Use monotonic clock if available in MCE->yield and MCE::Child->yield. + See https://www.perlmonks.org/?node_id=11109673 1.863 Sun Nov 26 20:00:00 EST 2019 diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/META.json new/MCE-1.865/META.json --- old/MCE-1.864/META.json 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/META.json 2019-12-26 01:42:50.000000000 +0100 @@ -65,123 +65,123 @@ "provides" : { "MCE" : { "file" : "lib/MCE.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Candy" : { "file" : "lib/MCE/Candy.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Channel" : { "file" : "lib/MCE/Channel.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Channel::Mutex" : { "file" : "lib/MCE/Channel/Mutex.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Channel::Simple" : { "file" : "lib/MCE/Channel/Simple.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Channel::Threads" : { "file" : "lib/MCE/Channel/Threads.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Child" : { "file" : "lib/MCE/Child.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Input::Generator" : { "file" : "lib/MCE/Core/Input/Generator.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Input::Handle" : { "file" : "lib/MCE/Core/Input/Handle.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Input::Iterator" : { "file" : "lib/MCE/Core/Input/Iterator.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Input::Request" : { "file" : "lib/MCE/Core/Input/Request.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Input::Sequence" : { "file" : "lib/MCE/Core/Input/Sequence.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Manager" : { "file" : "lib/MCE/Core/Manager.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Validation" : { "file" : "lib/MCE/Core/Validation.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Core::Worker" : { "file" : "lib/MCE/Core/Worker.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Flow" : { "file" : "lib/MCE/Flow.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Grep" : { "file" : "lib/MCE/Grep.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Loop" : { "file" : "lib/MCE/Loop.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Map" : { "file" : "lib/MCE/Map.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Mutex" : { "file" : "lib/MCE/Mutex.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Mutex::Channel" : { "file" : "lib/MCE/Mutex/Channel.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Mutex::Channel2" : { "file" : "lib/MCE/Mutex/Channel2.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Mutex::Flock" : { "file" : "lib/MCE/Mutex/Flock.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Queue" : { "file" : "lib/MCE/Queue.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Relay" : { "file" : "lib/MCE/Relay.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Signal" : { "file" : "lib/MCE/Signal.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Step" : { "file" : "lib/MCE/Step.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Stream" : { "file" : "lib/MCE/Stream.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Subs" : { "file" : "lib/MCE/Subs.pm", - "version" : "1.864" + "version" : "1.865" }, "MCE::Util" : { "file" : "lib/MCE/Util.pm", - "version" : "1.864" + "version" : "1.865" } }, "release_status" : "stable", @@ -197,5 +197,5 @@ "url" : "https://github.com/marioroy/mce-perl.git" } }, - "version" : "1.864" + "version" : "1.865" } diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/META.yml new/MCE-1.865/META.yml --- old/MCE-1.864/META.yml 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/META.yml 2019-12-26 01:42:50.000000000 +0100 @@ -25,94 +25,94 @@ provides: MCE: file: lib/MCE.pm - version: '1.864' + version: '1.865' MCE::Candy: file: lib/MCE/Candy.pm - version: '1.864' + version: '1.865' MCE::Channel: file: lib/MCE/Channel.pm - version: '1.864' + version: '1.865' MCE::Channel::Mutex: file: lib/MCE/Channel/Mutex.pm - version: '1.864' + version: '1.865' MCE::Channel::Simple: file: lib/MCE/Channel/Simple.pm - version: '1.864' + version: '1.865' MCE::Channel::Threads: file: lib/MCE/Channel/Threads.pm - version: '1.864' + version: '1.865' MCE::Child: file: lib/MCE/Child.pm - version: '1.864' + version: '1.865' MCE::Core::Input::Generator: file: lib/MCE/Core/Input/Generator.pm - version: '1.864' + version: '1.865' MCE::Core::Input::Handle: file: lib/MCE/Core/Input/Handle.pm - version: '1.864' + version: '1.865' MCE::Core::Input::Iterator: file: lib/MCE/Core/Input/Iterator.pm - version: '1.864' + version: '1.865' MCE::Core::Input::Request: file: lib/MCE/Core/Input/Request.pm - version: '1.864' + version: '1.865' MCE::Core::Input::Sequence: file: lib/MCE/Core/Input/Sequence.pm - version: '1.864' + version: '1.865' MCE::Core::Manager: file: lib/MCE/Core/Manager.pm - version: '1.864' + version: '1.865' MCE::Core::Validation: file: lib/MCE/Core/Validation.pm - version: '1.864' + version: '1.865' MCE::Core::Worker: file: lib/MCE/Core/Worker.pm - version: '1.864' + version: '1.865' MCE::Flow: file: lib/MCE/Flow.pm - version: '1.864' + version: '1.865' MCE::Grep: file: lib/MCE/Grep.pm - version: '1.864' + version: '1.865' MCE::Loop: file: lib/MCE/Loop.pm - version: '1.864' + version: '1.865' MCE::Map: file: lib/MCE/Map.pm - version: '1.864' + version: '1.865' MCE::Mutex: file: lib/MCE/Mutex.pm - version: '1.864' + version: '1.865' MCE::Mutex::Channel: file: lib/MCE/Mutex/Channel.pm - version: '1.864' + version: '1.865' MCE::Mutex::Channel2: file: lib/MCE/Mutex/Channel2.pm - version: '1.864' + version: '1.865' MCE::Mutex::Flock: file: lib/MCE/Mutex/Flock.pm - version: '1.864' + version: '1.865' MCE::Queue: file: lib/MCE/Queue.pm - version: '1.864' + version: '1.865' MCE::Relay: file: lib/MCE/Relay.pm - version: '1.864' + version: '1.865' MCE::Signal: file: lib/MCE/Signal.pm - version: '1.864' + version: '1.865' MCE::Step: file: lib/MCE/Step.pm - version: '1.864' + version: '1.865' MCE::Stream: file: lib/MCE/Stream.pm - version: '1.864' + version: '1.865' MCE::Subs: file: lib/MCE/Subs.pm - version: '1.864' + version: '1.865' MCE::Util: file: lib/MCE/Util.pm - version: '1.864' + version: '1.865' recommends: Sereal::Decoder: '3.015' Sereal::Encoder: '3.015' @@ -139,4 +139,4 @@ homepage: https://github.com/marioroy/mce-perl license: http://dev.perl.org/licenses/ repository: https://github.com/marioroy/mce-perl.git -version: '1.864' +version: '1.865' diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/Makefile.PL new/MCE-1.865/Makefile.PL --- old/MCE-1.864/Makefile.PL 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/Makefile.PL 2019-12-26 01:42:50.000000000 +0100 @@ -17,7 +17,7 @@ ABSTRACT => 'Many-Core Engine for Perl providing parallel processing capabilities', AUTHOR => 'Mario E. Roy <marioeroy AT gmail DOT com>', NAME => 'MCE', - VERSION => '1.864', + VERSION => '1.865', EXE_FILES => [ @exe_files ], @@ -68,123 +68,123 @@ 'provides' => { 'MCE' => { 'file' => 'lib/MCE.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Candy' => { 'file' => 'lib/MCE/Candy.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Channel' => { 'file' => 'lib/MCE/Channel.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Channel::Mutex' => { 'file' => 'lib/MCE/Channel/Mutex.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Channel::Simple' => { 'file' => 'lib/MCE/Channel/Simple.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Channel::Threads' => { 'file' => 'lib/MCE/Channel/Threads.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Child' => { 'file' => 'lib/MCE/Child.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Input::Generator' => { 'file' => 'lib/MCE/Core/Input/Generator.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Input::Handle' => { 'file' => 'lib/MCE/Core/Input/Handle.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Input::Iterator' => { 'file' => 'lib/MCE/Core/Input/Iterator.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Input::Request' => { 'file' => 'lib/MCE/Core/Input/Request.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Input::Sequence' => { 'file' => 'lib/MCE/Core/Input/Sequence.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Manager' => { 'file' => 'lib/MCE/Core/Manager.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Validation' => { 'file' => 'lib/MCE/Core/Validation.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Core::Worker' => { 'file' => 'lib/MCE/Core/Worker.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Flow' => { 'file' => 'lib/MCE/Flow.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Grep' => { 'file' => 'lib/MCE/Grep.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Loop' => { 'file' => 'lib/MCE/Loop.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Map' => { 'file' => 'lib/MCE/Map.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Mutex' => { 'file' => 'lib/MCE/Mutex.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Mutex::Channel' => { 'file' => 'lib/MCE/Mutex/Channel.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Mutex::Channel2' => { 'file' => 'lib/MCE/Mutex/Channel2.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Mutex::Flock' => { 'file' => 'lib/MCE/Mutex/Flock.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Queue' => { 'file' => 'lib/MCE/Queue.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Relay' => { 'file' => 'lib/MCE/Relay.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Signal' => { 'file' => 'lib/MCE/Signal.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Step' => { 'file' => 'lib/MCE/Step.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Stream' => { 'file' => 'lib/MCE/Stream.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Subs' => { 'file' => 'lib/MCE/Subs.pm', - 'version' => '1.864' + 'version' => '1.865' }, 'MCE::Util' => { 'file' => 'lib/MCE/Util.pm', - 'version' => '1.864' + 'version' => '1.865' } }, 'prereqs' => { diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/README.md new/MCE-1.865/README.md --- old/MCE-1.864/README.md 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/README.md 2019-12-26 01:42:50.000000000 +0100 @@ -1,6 +1,6 @@ ## Many-Core Engine for Perl -This document describes MCE version 1.864. +This document describes MCE version 1.865. Many-Core Engine (MCE) for Perl helps enable a new level of performance by maximizing all available cores. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Candy.pm new/MCE-1.865/lib/MCE/Candy.pm --- old/MCE-1.864/lib/MCE/Candy.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Candy.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; our @CARP_NOT = qw( MCE ); @@ -240,7 +240,7 @@ =head1 VERSION -This document describes MCE::Candy version 1.864 +This document describes MCE::Candy version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Channel/Mutex.pm new/MCE-1.865/lib/MCE/Channel/Mutex.pm --- old/MCE-1.864/lib/MCE/Channel/Mutex.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Channel/Mutex.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,14 +11,13 @@ no warnings qw( uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; use base 'MCE::Channel'; use MCE::Mutex (); use bytes; my $LF = "\012"; Internals::SvREADONLY($LF, 1); -my $is_MSWin32 = ( $^O eq 'MSWin32' ) ? 1 : 0; my $freeze = MCE::Channel::_get_freeze(); my $thaw = MCE::Channel::_get_thaw(); @@ -53,7 +52,6 @@ return if $self->{ended}; 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; @@ -67,8 +65,6 @@ my $p_mutex = $self->{p_mutex}; $p_mutex->lock2 if $p_mutex; - MCE::Util::_sock_ready_w( $self->{p_sock} ) if $is_MSWin32; - while ( @_ ) { my $data; if ( ref $_[0] || !defined $_[0] ) { @@ -90,7 +86,6 @@ if ( $count == 1 ) { ( my $c_mutex = $self->{c_mutex} )->lock; - MCE::Util::_sock_ready( $self->{c_sock} ) if $is_MSWin32; MCE::Util::_sysread( $self->{c_sock}, my($plen), 4 ); my $len = unpack('i', $plen); @@ -110,7 +105,6 @@ my ( $plen, @ret ); ( my $c_mutex = $self->{c_mutex} )->lock; - MCE::Util::_sock_ready( $self->{c_sock} ) if $is_MSWin32; while ( $count-- ) { MCE::Util::_sysread( $self->{c_sock}, $plen, 4 ); @@ -179,7 +173,6 @@ my $p_mutex = $self->{p_mutex}; $p_mutex->lock2 if $p_mutex; - MCE::Util::_sock_ready_w( $self->{p_sock} ) if $is_MSWin32; print { $self->{p_sock} } pack('i', length $data), $data; $p_mutex->unlock2 if $p_mutex; @@ -190,7 +183,6 @@ my ( $self ) = @_; ( my $c_mutex = $self->{c_mutex} )->lock; - MCE::Util::_sock_ready( $self->{c_sock} ) if $is_MSWin32; MCE::Util::_sysread( $self->{c_sock}, my($plen), 4 ); my $len = unpack('i', $plen); @@ -253,7 +245,6 @@ local $MCE::Signal::IPC = 1; ( my $c_mutex = $self->{c_mutex} )->lock2; - MCE::Util::_sock_ready_w( $self->{c_sock} ) if $is_MSWin32; print { $self->{c_sock} } pack('i', length $data), $data; $c_mutex->unlock2; } @@ -271,15 +262,13 @@ my $p_mutex = $self->{p_mutex}; $p_mutex->lock if $p_mutex; - MCE::Util::_sock_ready( $self->{p_sock} ) if $is_MSWin32; - - ( $p_mutex || $is_MSWin32 ) + ( $p_mutex ) ? MCE::Util::_sysread( $self->{p_sock}, $plen, 4 ) : read( $self->{p_sock}, $plen, 4 ); my $len = unpack('i', $plen); - ( $p_mutex || $is_MSWin32 ) + ( $p_mutex ) ? MCE::Channel::_read( $self->{p_sock}, $data, $len ) : read( $self->{p_sock}, $data, $len ); @@ -300,7 +289,7 @@ MCE::Util::_nonblocking( $self->{p_sock}, 1 ); - ( $p_mutex || $is_MSWin32 ) + ( $p_mutex ) ? MCE::Util::_sysread( $self->{p_sock}, $plen, 4 ) : read( $self->{p_sock}, $plen, 4 ); @@ -312,7 +301,7 @@ return wantarray ? () : undef; } - ( $p_mutex || $is_MSWin32 ) + ( $p_mutex ) ? MCE::Channel::_read( $self->{p_sock}, $data, $len ) : read( $self->{p_sock}, $data, $len ); @@ -339,7 +328,7 @@ =head1 VERSION -This document describes MCE::Channel::Mutex version 1.864 +This document describes MCE::Channel::Mutex version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Channel/Simple.pm new/MCE-1.865/lib/MCE/Channel/Simple.pm --- old/MCE-1.864/lib/MCE/Channel/Simple.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Channel/Simple.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; use base 'MCE::Channel'; use bytes; @@ -328,7 +328,7 @@ =head1 VERSION -This document describes MCE::Channel::Simple version 1.864 +This document describes MCE::Channel::Simple version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Channel/Threads.pm new/MCE-1.865/lib/MCE/Channel/Threads.pm --- old/MCE-1.864/lib/MCE/Channel/Threads.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Channel/Threads.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; use threads; use threads::shared; @@ -29,6 +29,7 @@ $obj{init_pid} = MCE::Channel::_pid(); MCE::Util::_sock_pair( \%obj, 'p_sock', 'c_sock' ); + MCE::Util::_sock_pair( \%obj, 'p2_sock', 'c2_sock' ) if $is_MSWin32; # locking for the consumer side of the channel $obj{cr_mutex} = threads::shared::share( my $cr_mutex ); @@ -255,11 +256,13 @@ local $MCE::Signal::SIG; { + my $c_sock = $self->{c2_sock} || $self->{c_sock}; + local $MCE::Signal::IPC = 1; CORE::lock $self->{cw_mutex}; - MCE::Util::_sock_ready_w( $self->{c_sock} ) if $is_MSWin32; - print { $self->{c_sock} } pack('i', length $data), $data; + MCE::Util::_sock_ready_w( $c_sock ) if $is_MSWin32; + print { $c_sock } pack('i', length $data), $data; } CORE::kill($MCE::Signal::SIG, $$) if $MCE::Signal::SIG; @@ -274,19 +277,21 @@ local $/ = $LF if ( $/ ne $LF ); { + my $p_sock = $self->{p2_sock} || $self->{p_sock}; my $pr_mutex = $self->{pr_mutex}; + CORE::lock $pr_mutex if $pr_mutex; - MCE::Util::_sock_ready( $self->{p_sock} ) if $is_MSWin32; + MCE::Util::_sock_ready( $p_sock ) if $is_MSWin32; ( $pr_mutex || $is_MSWin32 ) - ? MCE::Util::_sysread( $self->{p_sock}, $plen, 4 ) - : read( $self->{p_sock}, $plen, 4 ); + ? MCE::Util::_sysread( $p_sock, $plen, 4 ) + : read( $p_sock, $plen, 4 ); my $len = unpack('i', $plen); ( $pr_mutex || $is_MSWin32 ) - ? MCE::Channel::_read( $self->{p_sock}, $data, $len ) - : read( $self->{p_sock}, $data, $len ); + ? MCE::Channel::_read( $p_sock, $data, $len ) + : read( $p_sock, $data, $len ); } chop( $data ) @@ -301,23 +306,25 @@ local $/ = $LF if ( $/ ne $LF ); { + my $p_sock = $self->{p2_sock} || $self->{p_sock}; my $pr_mutex = $self->{pr_mutex}; + CORE::lock $pr_mutex if $pr_mutex; - MCE::Util::_nonblocking( $self->{p_sock}, 1 ); + MCE::Util::_nonblocking( $p_sock, 1 ); ( $pr_mutex || $is_MSWin32 ) - ? MCE::Util::_sysread( $self->{p_sock}, $plen, 4 ) - : read( $self->{p_sock}, $plen, 4 ); + ? MCE::Util::_sysread( $p_sock, $plen, 4 ) + : read( $p_sock, $plen, 4 ); - MCE::Util::_nonblocking( $self->{p_sock}, 0 ); + MCE::Util::_nonblocking( $p_sock, 0 ); my $len; $len = unpack('i', $plen) if $plen; return wantarray ? () : undef unless $len; ( $pr_mutex || $is_MSWin32 ) - ? MCE::Channel::_read( $self->{p_sock}, $data, $len ) - : read( $self->{p_sock}, $data, $len ); + ? MCE::Channel::_read( $p_sock, $data, $len ) + : read( $p_sock, $data, $len ); } chop( $data ) @@ -341,7 +348,7 @@ =head1 VERSION -This document describes MCE::Channel::Threads version 1.864 +This document describes MCE::Channel::Threads version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Channel.pm new/MCE-1.865/lib/MCE/Channel.pm --- old/MCE-1.864/lib/MCE/Channel.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Channel.pm 2019-12-26 01:51:19.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (TestingAndDebugging::ProhibitNoStrict) @@ -76,7 +76,7 @@ my ( $pid, $self ) = ( $tid ? $$ .'.'. $tid : $$, @_ ); if ( $self->{'init_pid'} && $self->{'init_pid'} eq $pid ) { - MCE::Util::_destroy_socks( $self, qw(c_sock p_sock) ); + MCE::Util::_destroy_socks($self, qw(c_sock c2_sock p_sock p2_sock)); delete($self->{c_mutex}), delete($self->{p_mutex}); } @@ -128,7 +128,7 @@ =head1 VERSION -This document describes MCE::Channel version 1.864 +This document describes MCE::Channel version 1.865 =head1 SYNOPSIS @@ -212,18 +212,21 @@ =head2 new ( impl => STRING, mp => BOOLEAN ) -This creates a new channel. Three implementations are provided C<Mutex> (default), -C<Threads>, and C<Simple> indicating the locking mechanism to use C<MCE::Mutex>, -C<threads::shared>, and no locking respectively. +This creates a new channel. Three implementations are provided C<Mutex>, +C<Threads>, and C<Simple> indicating the locking mechanism to use +C<MCE::Mutex>, C<threads::shared>, and no locking respectively. $chnl = MCE::Channel->new(); # default: impl => 'Mutex', mp => 0 + # default: impl => 'Threads' on Windows -The C<Mutex> channel implementation supports processes and threads whereas the -C<Threads> channel implementation is suited for threads only. +The C<Mutex> implementation supports processes and threads whereas the +C<Threads> implementation is suited for Windows and threads only. $chnl = MCE::Channel->new( impl => 'Mutex' ); # MCE::Mutex locking $chnl = MCE::Channel->new( impl => 'Threads' ); # threads::shared locking + # on Windows, silently becomes impl => 'Threads' when specifying 'Mutex' + Set the C<mp> (m)any (p)roducers option to a true value if there will be two or more workers calling C<enqueue>, <send>, C<recv2>, or C<recv2_nb> on the left end of the channel. This is important to not incur a race condition. @@ -231,6 +234,8 @@ $chnl = MCE::Channel->new( impl => 'Mutex', mp => 1 ); $chnl = MCE::Channel->new( impl => 'Threads', mp => 1 ); + # on Windows, silently becomes impl => 'Threads' when specifying 'Mutex' + The C<Simple> implementation is optimized for one producer and one consumer max. It omits locking for maximum performance. This implementation is preferred for parent to child communication not shared by another worker. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Child.pm new/MCE-1.865/lib/MCE/Child.pm --- old/MCE-1.864/lib/MCE/Child.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Child.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ package MCE::Child; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitExplicitReturnUndef) @@ -972,7 +972,7 @@ =head1 VERSION -This document describes MCE::Child version 1.864 +This document describes MCE::Child version 1.865 =head1 SYNOPSIS @@ -1565,7 +1565,7 @@ A demonstration is provided in the next section for fetching URLs in parallel. The default C<floating_seconds> is 0.008 and 0.015 on UNIX and Windows, -respectively. Pass 0 if you want to give other workers a chance to run. +respectively. Pass 0 if simply wanting to give other workers a chance to run. # total run time: 1.00 second diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Input/Generator.pm new/MCE-1.865/lib/MCE/Core/Input/Generator.pm --- old/MCE-1.864/lib/MCE/Core/Input/Generator.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Input/Generator.pm 2019-12-26 01:42:50.000000000 +0100 @@ -15,7 +15,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## Items below are folded into MCE. @@ -220,7 +220,7 @@ =head1 VERSION -This document describes MCE::Core::Input::Generator version 1.864 +This document describes MCE::Core::Input::Generator version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Input/Handle.pm new/MCE-1.865/lib/MCE/Core/Input/Handle.pm --- old/MCE-1.864/lib/MCE/Core/Input/Handle.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Input/Handle.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## Items below are folded into MCE. @@ -282,7 +282,7 @@ =head1 VERSION -This document describes MCE::Core::Input::Handle version 1.864 +This document describes MCE::Core::Input::Handle version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Input/Iterator.pm new/MCE-1.865/lib/MCE/Core/Input/Iterator.pm --- old/MCE-1.864/lib/MCE/Core/Input/Iterator.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Input/Iterator.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## Items below are folded into MCE. @@ -137,7 +137,7 @@ =head1 VERSION -This document describes MCE::Core::Input::Iterator version 1.864 +This document describes MCE::Core::Input::Iterator version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Input/Request.pm new/MCE-1.865/lib/MCE/Core/Input/Request.pm --- old/MCE-1.864/lib/MCE/Core/Input/Request.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Input/Request.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## Items below are folded into MCE. @@ -206,7 +206,7 @@ =head1 VERSION -This document describes MCE::Core::Input::Request version 1.864 +This document describes MCE::Core::Input::Request version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Input/Sequence.pm new/MCE-1.865/lib/MCE/Core/Input/Sequence.pm --- old/MCE-1.864/lib/MCE/Core/Input/Sequence.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Input/Sequence.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## Items below are folded into MCE. @@ -231,7 +231,7 @@ =head1 VERSION -This document describes MCE::Core::Input::Sequence version 1.864 +This document describes MCE::Core::Input::Sequence version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Manager.pm new/MCE-1.865/lib/MCE/Core/Manager.pm --- old/MCE-1.864/lib/MCE/Core/Manager.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Manager.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (TestingAndDebugging::ProhibitNoStrict) @@ -1041,7 +1041,7 @@ =head1 VERSION -This document describes MCE::Core::Manager version 1.864 +This document describes MCE::Core::Manager version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Validation.pm new/MCE-1.865/lib/MCE/Core/Validation.pm --- old/MCE-1.864/lib/MCE/Core/Validation.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Validation.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## Items below are folded into MCE. @@ -391,7 +391,7 @@ =head1 VERSION -This document describes MCE::Core::Validation version 1.864 +This document describes MCE::Core::Validation version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core/Worker.pm new/MCE-1.865/lib/MCE/Core/Worker.pm --- old/MCE-1.864/lib/MCE/Core/Worker.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core/Worker.pm 2019-12-26 01:42:50.000000000 +0100 @@ -14,7 +14,7 @@ use strict; use warnings; -our $VERSION = '1.864'; +our $VERSION = '1.865'; my $_tid = $INC{'threads.pm'} ? threads->tid() : 0; @@ -744,7 +744,7 @@ =head1 VERSION -This document describes MCE::Core::Worker version 1.864 +This document describes MCE::Core::Worker version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Core.pod new/MCE-1.865/lib/MCE/Core.pod --- old/MCE-1.864/lib/MCE/Core.pod 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Core.pod 2019-12-26 01:42:50.000000000 +0100 @@ -5,7 +5,7 @@ =head1 VERSION -This document describes MCE::Core version 1.864 +This document describes MCE::Core version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Examples.pod new/MCE-1.865/lib/MCE/Examples.pod --- old/MCE-1.864/lib/MCE/Examples.pod 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Examples.pod 2019-12-26 01:42:50.000000000 +0100 @@ -5,7 +5,7 @@ =head1 VERSION -This document describes MCE::Examples version 1.864 +This document describes MCE::Examples version 1.865 =head1 INCLUDED WITH THE DISTRIBUTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Flow.pm new/MCE-1.865/lib/MCE/Flow.pm --- old/MCE-1.864/lib/MCE/Flow.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Flow.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -479,7 +479,7 @@ =head1 VERSION -This document describes MCE::Flow version 1.864 +This document describes MCE::Flow version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Grep.pm new/MCE-1.865/lib/MCE/Grep.pm --- old/MCE-1.864/lib/MCE/Grep.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Grep.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -434,7 +434,7 @@ =head1 VERSION -This document describes MCE::Grep version 1.864 +This document describes MCE::Grep version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Loop.pm new/MCE-1.865/lib/MCE/Loop.pm --- old/MCE-1.864/lib/MCE/Loop.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Loop.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -349,7 +349,7 @@ =head1 VERSION -This document describes MCE::Loop version 1.864 +This document describes MCE::Loop version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Map.pm new/MCE-1.865/lib/MCE/Map.pm --- old/MCE-1.864/lib/MCE/Map.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Map.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -434,7 +434,7 @@ =head1 VERSION -This document describes MCE::Map version 1.864 +This document describes MCE::Map version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Mutex/Channel.pm new/MCE-1.865/lib/MCE/Mutex/Channel.pm --- old/MCE-1.864/lib/MCE/Mutex/Channel.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Mutex/Channel.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; use base 'MCE::Mutex'; use Scalar::Util qw(refaddr weaken); @@ -139,7 +139,7 @@ =head1 VERSION -This document describes MCE::Mutex::Channel version 1.864 +This document describes MCE::Mutex::Channel version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Mutex/Channel2.pm new/MCE-1.865/lib/MCE/Mutex/Channel2.pm --- old/MCE-1.864/lib/MCE/Mutex/Channel2.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Mutex/Channel2.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; use base 'MCE::Mutex::Channel'; use MCE::Util (); @@ -114,7 +114,7 @@ =head1 VERSION -This document describes MCE::Mutex::Channel2 version 1.864 +This document describes MCE::Mutex::Channel2 version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Mutex/Flock.pm new/MCE-1.865/lib/MCE/Mutex/Flock.pm --- old/MCE-1.864/lib/MCE/Mutex/Flock.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Mutex/Flock.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; use base 'MCE::Mutex'; use Fcntl ':flock'; @@ -181,7 +181,7 @@ =head1 VERSION -This document describes MCE::Mutex::Flock version 1.864 +This document describes MCE::Mutex::Flock version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Mutex.pm new/MCE-1.865/lib/MCE/Mutex.pm --- old/MCE-1.864/lib/MCE/Mutex.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Mutex.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (TestingAndDebugging::ProhibitNoStrict) @@ -76,7 +76,7 @@ =head1 VERSION -This document describes MCE::Mutex version 1.864 +This document describes MCE::Mutex version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Queue.pm new/MCE-1.865/lib/MCE/Queue.pm --- old/MCE-1.864/lib/MCE/Queue.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Queue.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (Subroutines::ProhibitExplicitReturnUndef) ## no critic (TestingAndDebugging::ProhibitNoStrict) @@ -1601,7 +1601,7 @@ =head1 VERSION -This document describes MCE::Queue version 1.864 +This document describes MCE::Queue version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Relay.pm new/MCE-1.865/lib/MCE/Relay.pm --- old/MCE-1.864/lib/MCE/Relay.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Relay.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized numeric ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -370,7 +370,7 @@ =head1 VERSION -This document describes MCE::Relay version 1.864 +This document describes MCE::Relay version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Signal.pm new/MCE-1.865/lib/MCE/Signal.pm --- old/MCE-1.864/lib/MCE/Signal.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Signal.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized once ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) @@ -206,10 +206,10 @@ $SIG{__DIE__} = $SIG{__WARN__} = sub {}; if (exists $_sig_name_lkup{$_sig_name}) { - $SIG{INT} = $SIG{$_sig_name} = sub {}; $_exit_status = $MCE::Signal::KILLED = $_is_sig = 1; - $_exit_status = 255 if ($_sig_name eq '__DIE__'); - $_exit_status = 0 if ($_sig_name eq 'PIPE'); + $_exit_status = 255, $_sig_name = 'TERM' if ($_sig_name eq '__DIE__'); + $_exit_status = 0 if ($_sig_name eq 'PIPE'); + $SIG{INT} = $SIG{$_sig_name} = sub {}; } else { $_exit_status = $_sig_name if ($_sig_name =~ /^\d+$/); @@ -438,7 +438,7 @@ =head1 VERSION -This document describes MCE::Signal version 1.864 +This document describes MCE::Signal version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Step.pm new/MCE-1.865/lib/MCE/Step.pm --- old/MCE-1.864/lib/MCE/Step.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Step.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -715,7 +715,7 @@ =head1 VERSION -This document describes MCE::Step version 1.864 +This document describes MCE::Step version 1.865 =head1 DESCRIPTION diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Stream.pm new/MCE-1.865/lib/MCE/Stream.pm --- old/MCE-1.864/lib/MCE/Stream.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Stream.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) @@ -671,7 +671,7 @@ =head1 VERSION -This document describes MCE::Stream version 1.864 +This document describes MCE::Stream version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Subs.pm new/MCE-1.865/lib/MCE/Subs.pm --- old/MCE-1.864/lib/MCE/Subs.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Subs.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (Subroutines::ProhibitSubroutinePrototypes) ## no critic (TestingAndDebugging::ProhibitNoStrict) @@ -204,7 +204,7 @@ =head1 VERSION -This document describes MCE::Subs version 1.864 +This document describes MCE::Subs version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE/Util.pm new/MCE-1.865/lib/MCE/Util.pm --- old/MCE-1.864/lib/MCE/Util.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE/Util.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized numeric ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) @@ -410,7 +410,7 @@ =head1 VERSION -This document describes MCE::Util version 1.864 +This document describes MCE::Util version 1.865 =head1 SYNOPSIS diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE.pm new/MCE-1.865/lib/MCE.pm --- old/MCE-1.864/lib/MCE.pm 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE.pm 2019-12-26 01:42:50.000000000 +0100 @@ -11,7 +11,7 @@ no warnings qw( threads recursion uninitialized ); -our $VERSION = '1.864'; +our $VERSION = '1.865'; ## no critic (BuiltinFunctions::ProhibitStringyEval) ## no critic (Subroutines::ProhibitSubroutinePrototypes) diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/MCE-1.864/lib/MCE.pod new/MCE-1.865/lib/MCE.pod --- old/MCE-1.864/lib/MCE.pod 2019-12-04 18:56:35.000000000 +0100 +++ new/MCE-1.865/lib/MCE.pod 2019-12-26 01:42:50.000000000 +0100 @@ -5,7 +5,7 @@ =head1 VERSION -This document describes MCE version 1.864 +This document describes MCE version 1.865 Many-Core Engine (MCE) for Perl helps enable a new level of performance by maximizing all available cores.
participants (1)
-
root