@@ -9,23 +9,45 @@ select @curr_session_epoch:=Variable_value
9
9
from information_schema .global_status
10
10
where Variable_name = " ndb_last_commit_epoch_session" ;
11
11
12
+ # Wait for latest committed transaction to reach binlog
12
13
show binlog events;
13
14
15
+ -- source include/get_ndb_epochs.inc
16
+
14
17
select @binlog_max_epoch:= max (epoch)
15
18
from mysql .ndb_binlog_index ;
16
19
17
20
-- enable_result_log
18
21
19
- select (@init_server_epoch + 0 ) >= (@init_session_epoch + 0 )
22
+ select @a: = (@init_server_epoch + 0 ) >= (@init_session_epoch + 0 )
20
23
as init_server_epoch_includes_session_epoch,
21
- (@curr_server_epoch + 0 ) >= (@curr_session_epoch + 0 )
24
+ @b: = (@curr_server_epoch + 0 ) >= (@curr_session_epoch + 0 )
22
25
as curr_server_epoch_includes_session_epoch,
23
- (@curr_server_epoch + 0 ) >= (@init_server_epoch + 0 )
26
+ @c: = (@curr_server_epoch + 0 ) >= (@init_server_epoch + 0 )
24
27
as server_epoch_does_not_regress,
25
- (@curr_session_epoch + 0 ) >= (@init_session_epoch + 0 )
28
+ @d: = (@curr_session_epoch + 0 ) >= (@init_session_epoch + 0 )
26
29
as session_epoch_does_not_regress;
27
30
28
- select @binlog_max_epoch = @curr_session_epoch as
31
+ select ( @binlog_max_epoch+ 0 ) = ( @curr_session_epoch+ 0 ) as
29
32
binlog_contains_last_session_epoch;
30
33
34
+ -- disable_result_log
35
+
36
+ eval select @e:= (($ndb_latest_applied_binlog_epoch + 0 ) = @binlog_max_epoch);
37
+
38
+ -- let $problem=query_get_value("SELECT 5 - (@a+@b+@c+@d+@e) AS p", p, 1)
39
+
40
+ -- enable_result_log
41
+ if ($problem)
42
+ {
43
+ -- echo Unexpected result. Details :
44
+
45
+ SELECT @init_server_epoch, @init_session_epoch,
46
+ @curr_server_epoch, @curr_session_epoch;
47
+
48
+ eval select $ndb_latest_applied_binlog_epoch as ndb_latest_applied_binlog_epoch, @binlog_max_epoch;
49
+
50
+ SELECT * FROM mysql .ndb_binlog_index ;
51
+ }
52
+
31
53
-- enable_query_log
0 commit comments