my$master = get_new_node("master");

$master->init;

$master->append_conf('postgresql.conf',qq(

));

my$shard1 = get_new_node("shard1");

$shard1->init;

$shard1->append_conf('postgresql.conf',qq(

));

my$shard2 = get_new_node("shard2");

$shard2->init;

$shard2->append_conf('postgresql.conf',qq(

));

diag("done$host$port");

}

$shard1->psql('postgres',"insert into accounts select 2*id-1, 0 from generate_series(1, 1000) as id;");

$shard2->psql('postgres',"insert into accounts select 2*id, 0 from generate_series(1, 1000) as id;");

$shard1->psql('postgres',"insert into accounts select 2*id-1, 0 from generate_series(1, 10000) as id;");

$shard2->psql('postgres',"insert into accounts select 2*id, 0 from generate_series(1, 10000) as id;");

diag($master->connstr() );

my ($err,$rc);

my$seconds = 30;

my$total =0;

my$oldtotal =0;

my$total ='0';

my$oldtotal ='0';

my$isolation_error = 0;

my$pgb_handle =$master->pgbench_async(-n,-c=> 1,-T=>$seconds,-f=>"$TestLib::log_path/../../t/bank.pgb",'postgres' );

$master->pgbench(-n,-c=> 5,-t=> 10,-f=>"$TestLib::log_path/../../t/bank.pgb",'postgres' );

my$pgb_handle =$master->pgbench_async(-n,-c=> 5,-T=>$seconds,-f=>"$TestLib::log_path/../../t/bank.pgb",'postgres' );

my$started =time();

while (time() -$started <$seconds)

{

($rc,$total,$err) =$master->psql('postgres',"select sum(amount) from accounts");

if ($oldtotal !=$total)

if ( ($totalne$oldtotal)and ($totalne''))

{

$isolation_error = 1;

$oldtotal =$total;

\set id random(1,2000)

\set id random(1,20000)

BEGIN;

UPDATE accounts SET amount = amount - 1 WHERE id = :id;