~drizzle-trunk/drizzle/development

# Test creating a barrier with a number

connect (con1,localhost,root,,);

connect (con2,localhost,root,,);

connect (con3,localhost,root,,);

connect (con4,localhost,root,,);

connect (con5,localhost,root,,);

 

# The default connection will own everything.

connection default;

set @count_barrier= "count_barrier";

set @barrier_limit= 6;

SELECT create_barrier(@count_barrier, @barrier_limit);

SELECT if ((SESSION_ID = CONNECTION_ID()), "YES", "NO"), GENERATION, if ((WAITER_LIMIT = @barrier_limit), "YES", "NO") from DATA_DICTIONARY.USER_BARRIERS WHERE USER_BARRIER_NAME=@count_barrier;

 

connection con1;

set @count_barrier= "count_barrier";

send SELECT wait(@count_barrier), "con1";

 

connection con2;

set @count_barrier= "count_barrier";

send SELECT wait(@count_barrier), "con2";

 

connection con3;

set @count_barrier= "count_barrier";

send SELECT wait(@count_barrier), "con3";

 

connection con4;

set @count_barrier= "count_barrier";

send SELECT wait(@count_barrier), "con4";

 

# We don't budge until we know everyone is in place.

connection con5;

set @count_barrier= "count_barrier";

SELECT WAIT_UNTIL(@count_barrier, 4);

SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST ORDER BY ID;

SELECT if ((@id:=ID), "YES", "NO") FROM DATA_DICTIONARY.PROCESSLIST WHERE INFO LIKE "%con3%" AND ID != CONNECTION_ID();

kill QUERY (@id);

SELECT WAIT_UNTIL(@count_barrier, 3);

SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST ORDER BY ID;

SELECT USER_BARRIER_NAME FROM DATA_DICTIONARY.USER_BARRIERS;

SELECT signal(@count_barrier);