@@ -3056,13 +3056,15 @@ static inline void rocksdb_register_tx(handlerton *hton, THD *thd,
3056
3056
*/
3057
3057
static int rocksdb_start_tx_and_assign_read_view (
3058
3058
handlerton* hton, /* !< in: RocksDB handlerton */
3059
- THD* thd, /* !< in: MySQL thread handle of the
3059
+ THD* thd) /* !< in: MySQL thread handle of the
3060
3060
user for whom the transaction should
3061
3061
be committed */
3062
+ #ifdef MARIAROCKS_NOT_YET // consistent snapshot with binlog
3062
3063
char * binlog_file, /* out: binlog file for last commit */
3063
3064
ulonglong* binlog_pos, /* out: binlog pos for last commit */
3064
3065
char ** gtid_executed, /* out: Gtids logged until last commit */
3065
3066
int * gtid_executed_length) /* out: Length of gtid_executed string */
3067
+ #endif
3066
3068
{
3067
3069
Rdb_perf_context_guard guard (thd);
3068
3070
@@ -3076,25 +3078,26 @@ static int rocksdb_start_tx_and_assign_read_view(
3076
3078
" in RocksDB Storage Engine." , MYF (0 ));
3077
3079
return 1 ;
3078
3080
}
3079
-
3081
+ # ifdef MARIAROCKS_NOT_YET // consistent snapshot with binlog
3080
3082
if (binlog_file)
3081
3083
{
3082
3084
if (binlog_pos && mysql_bin_log.is_open ())
3083
3085
mysql_bin_log_lock_commits ();
3084
3086
else
3085
3087
return 1 ;
3086
3088
}
3087
-
3089
+ # endif
3088
3090
Rdb_transaction* tx= get_or_create_tx (thd);
3089
3091
DBUG_ASSERT (!tx->has_snapshot ());
3090
3092
tx->set_tx_read_only (true );
3091
3093
rocksdb_register_tx (hton, thd, tx);
3092
3094
tx->acquire_snapshot (true );
3093
3095
3096
+ #ifdef MARIAROCKS_NOT_YET // consistent snapshot with binlog
3094
3097
if (binlog_file)
3095
3098
mysql_bin_log_unlock_commits (binlog_file, binlog_pos, gtid_executed,
3096
3099
gtid_executed_length);
3097
-
3100
+ # endif
3098
3101
return 0 ;
3099
3102
}
3100
3103
0 commit comments