← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to tests/suite/execute/t/concurrent.test

  • Committer: Monty Taylor
  • Date: 2011-02-13 17:26:39 UTC
  • mfrom: (2157.2.2 give-in-to-pkg-config)
  • mto: This revision was merged to the branch mainline in revision 2166.
  • Revision ID: mordred@inaugust.com-20110213172639-nhy7i72sfhoq13ms
Merged in pkg-config fixes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
tests/suite/execute/t/concurrent.test
1
1
# we are going to have everything owned by a particular connection
2
 
connect (barrier_owner,localhost,root,,);
 
2
connect (barrier_owner,localhost,bob,,);
3
3
connection barrier_owner;
4
4
set @my_barrier= "barrier";
5
5
SELECT CREATE_BARRIER(@my_barrier);
 
6
SELECT USER_BARRIER_NAME FROM DATA_DICTIONARY.USER_DEFINED_BARRIERS WHERE USER_BARRIER_NAME=@my_barrier;
6
7
 
7
8
connection default;
8
9
set @my_barrier= "barrier";
9
 
SELECT USER_BARRIER_NAME FROM DATA_DICTIONARY.USER_BARRIERS WHERE USER_BARRIER_NAME=@my_barrier;
 
10
SELECT USER_BARRIER_NAME FROM DATA_DICTIONARY.USER_DEFINED_BARRIERS WHERE USER_BARRIER_NAME=@my_barrier;
10
11
SET @execute= "SELECT WAIT('barrier')";
11
 
SELECT SIGNAL(@my_barrier);
12
 
 
13
 
EXECUTE @execute CONCURRENT;
14
 
EXECUTE @execute CONCURRENT;
15
 
EXECUTE @execute CONCURRENT;
16
 
 
17
 
SELECT WAIT_UNTIL(@my_barrier, 3);
18
 
 
19
 
### Now lets see what the processlist shows.
20
 
SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST ORDER BY ID;
21
 
SELECT SIGNAL(@my_barrier);
 
12
#SELECT SIGNAL(@my_barrier);
 
13
#
 
14
#EXECUTE @execute CONCURRENT;
 
15
#EXECUTE @execute CONCURRENT;
 
16
#EXECUTE @execute CONCURRENT;
 
17
 
 
18
#SELECT WAIT_UNTIL(@my_barrier, 3);
 
19
# 
 
20
#### Now lets see what the processlist shows.
 
21
#SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST WHERE ID != CONNECTION_ID() AND USERNAME="bob" ORDER BY ID;
 
22
#SELECT SIGNAL(@my_barrier);
22
23
 
23
24
## Wait till we know the above is done (this will be replaced with broadcast() in the future)
24
25
#EXECUTE @sleep;