Fsdb

 view release on metacpan or  search on metacpan

README  view on Meta::CPAN

       INCOMPATIBLE CHANGE
           dbmapreduce no longer copies the input field separator by  default.
           For multi-key-aware reducers, it never does (and cannot).  For non-
           multi-key-aware  reducers,  it  defaults  to  not copying the field
           separator,  but  it  will  copy  it  (the  old  default)  with  the
           "--copy-fs" option

   2.45, 2013-10-07 cleanup from de-thread-ification
       BUG FIX
           Corrected a fast busy-wait in dbmerge.

       ENHANCEMENT
           Endgame  mode  enabled  in  dbmerge;  it  (and  also large cases of
           dbsort) should now exploit greater parallelism.

       BUG FIX
           Test case with "Fsdb::BoundedQueue" (gone since 2.44) now removed.

   2.46, 2013-10-08 continuing cleanup of our no-threads version
       BUG FIX

README.html  view on Meta::CPAN

</dd>
</dl>

<h2 id="cleanup-from-de-thread-ification">2.45, 2013-10-07 cleanup from de-thread-ification</h2>

<dl>

<dt id="BUG-FIX57">BUG FIX</dt>
<dd>

<p>Corrected a fast busy-wait in <a>dbmerge</a>.</p>

</dd>
<dt id="ENHANCEMENT25">ENHANCEMENT</dt>
<dd>

<p>Endgame mode enabled in <a>dbmerge</a>; it (and also large cases of <a>dbsort</a>) should now exploit greater parallelism.</p>

</dd>
<dt id="BUG-FIX58">BUG FIX</dt>
<dd>

lib/Fsdb.pm  view on Meta::CPAN

=back

=head2 2.45, 2013-10-07
cleanup from de-thread-ification

=over 4

=item BUG FIX

Corrected a fast busy-wait in L<dbmerge>.

=item ENHANCEMENT

Endgame mode enabled in L<dbmerge>; it (and also large cases of L<dbsort>)
should now exploit greater parallelism.

=item BUG FIX

Test case with C<Fsdb::BoundedQueue> (gone since 2.44) now removed.

lib/Fsdb/Filter/dbmerge.pm  view on Meta::CPAN

	    # walk the whole work queue
	    if (++$i > $#{$self->{_work}[$depth]}) {
		last if (++$depth > $#{$self->{_work}});
		$i = 0;
	    };
	};

	#
	# Handle xargs, if any.
	#
	# Unfortunately, we busy-loop here,
	# because we need to alternate reaping finished processes
	# and xargs.
	#
	# Fortunately, this terminates when xargs are complete.
       	#
	if ($self->{_xargs_ipc_status}) {
	    my(@ready) = $xargs_select->can_read($progress_backoff);
	    foreach my $fh (@ready) {
		my ($fn) = $fh->getline;
		if (defined($fn)) {