Changeset 5780

Timestamp:

01/29/08 15:16:44 (5 years ago)

Author:

kazuho

Message:

add load property, to control avg. load of the replication

Files:

• lang/perl/DBIx-Replicate/trunk/lib/DBIx/Replicate.pm (modified) (6 diffs)

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

@@ -8 +8 @@
 use DBI;
 use List::Util qw/min/;
+use Time::HiRes qw/time sleep/;
 
 use base qw/Exporter/;
@@ -27 +28 @@
     $args->{block} = 1000
         unless $args->{block};
+    $args->{load} = 1
+        unless $args->{load};
     my $columns_str = join ',', @{$args->{columns}};
     my $extra_cond = $args->{extra_cond} ? "and ($args->{extra_cond})" : '';
@@ -41 +44 @@
         my $last_key;
         while (1) {
+            my $start = time;
             $sql = sprintf(
                 'select %s from %s where %s=(select min(%s) from %s where %s) %s',
@@ -95 +99 @@
             $args->{dest_conn}->commit
                 or die $args->{dest_conn}->errstr;
+            sleep(min(time - $start, 0) / ($args->{load} - 1))
+                if $args->{load};
         }
         $sql = sprintf(
@@ -117 +123 @@
         my ($start_srcconn, $start_destconn) = qw/1 1/;
         while (1) {
+            my $start = time;
             $sql = "select $columns_str from $args->{src_table} where $start_srcconn $extra_cond order by $order_by limit $args->{block}";
             my $rows = $args->{src_conn}->selectall_arrayref(
@@ -159 +166 @@
             $args->{dest_conn}->commit
                 or die $args->{dest_conn}->errstr;
+            sleep(min(time - $start, 0) / ($args->{load} - 1))
+                if $args->{load};
             ($start_srcconn, $start_destconn)
                 = ($next_srcconn, $next_destconn);