File Coverage

blib/lib/Iterator/File/Status.pm

Criterion	Covered	Total	%
statement	12	40	30.0
branch	0	10	0.0
condition			n/a
subroutine	4	10	40.0
pod	4	6	66.6
total	20	66	30.3

package Iterator::File::Status;

## $Id: Status.pm,v 1.11 2008/06/18 06:47:51 wdr1 Exp $

use 5.006;
use strict;
use warnings;

use UNIVERSAL 'can';

our $VERSION = substr(q$Revision: 1.11 $, 10);

our %default_config =
  (
   '_status_scale'         => 1,
   'status_line_interval' => 10,
   'status_time_interval' => 2,
   'status_line'   => "Processing row '%d'...\n",
   'status_filehandle'    => \*STDERR,
   'status_method' => 'emit_status_logarithmic',

   '_status_time_last'     => time,
  );

sub new {
  my ($class, %config) = @_;

  %config = (%default_config, %config);
  my $self =  bless(\%config, $class);

  unless (can( __PACKAGE__, $config{'status_method'} )) {
    confess($default_config{'status_method'} .
            " is not a valid status_method arguement!");
  }

  return $self;
}


sub emit_status_logarithmic {
  my ($self, $marker) = @_;

  my $status = "";
  my $scale  = $self->{_status_scale};

  return if  ($marker % $scale);

  if ($marker >= $self->{_status_scale} * 10) {
    $self->{_status_scale} *= 10;
  }

  $self->emit_status_line( $marker );
}



sub emit_status_fixed_line_interval {
  my ($self, $marker) = @_;

  my $status   = "";
  my $interval = $self->{status_line_interval};

  return if ($marker % $interval);

  $self->emit_status_line( $marker );
}



sub emit_status_fixed_time_interval {
  my ($self, $marker) = @_;

  return unless (time - $self->{'_status_time_last'} >= $self->{'status_time_interval'});

  $self->{'_status_time_last'} = time;

  $self->emit_status_line( $marker );
}



sub emit_status_line {
  my ($self, $marker) = @_;

  my $fh = $self->{'status_filehandle'};
  printf $fh $self->{'status_line'}, $marker;
}



sub emit_status {
  my $self = shift;

  my $method = $self->{'status_method'};
  $self->$method( @_ );
}
1;
__END__