Show
Ignore:
Timestamp:
01/29/08 15:59:20 (5 years ago)
Author:
kazuho
Message:

fix load adjustment

Files:
1 modified

Legend:

Unmodified
Added
Removed

  • lang/perl/DBIx-Replicate/trunk/lib/DBIx/Replicate.pm

    r5781 r5783  
    2828    $args->{block} = 1000 
    2929        unless $args->{block}; 
    30     $args->{load} = 1 
    31         unless $args->{load}; 
    3230    my $columns_str = join ',', @{$args->{columns}}; 
    3331    my $extra_cond = $args->{extra_cond} ? "and ($args->{extra_cond})" : ''; 
    … …  
    9997            $args->{dest_conn}->commit 
    10098                or die $args->{dest_conn}->errstr; 
    101             sleep(min(time - $start, 0) / (1 - $args->{load})) 
     99            sleep(min(time - $start, 0) * (1 - $args->{load}) / $args->{load}) 
    102100                if $args->{load}; 
    103101        } 
    … …  
    166164            $args->{dest_conn}->commit 
    167165                or die $args->{dest_conn}->errstr; 
    168             sleep(min(time - $start, 0) / (1 - $args->{load})) 
     166            sleep(min(time - $start, 0) * (1 - $args->{load}) / $args->{load}) 
    169167                if $args->{load}; 
    170168            ($start_srcconn, $start_destconn)