File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Original file line number Diff line number Diff line change @@ -4297,14 +4297,16 @@ extern "C" int thd_non_transactional_update(const MYSQL_THD thd)
4297
4297
extern " C" int thd_binlog_format (const MYSQL_THD thd)
4298
4298
{
4299
4299
#ifdef WITH_WSREP
4300
- if (((WSREP (thd) && wsrep_emulate_bin_log) || mysql_bin_log.is_open ()) &&
4301
- (thd->variables .option_bits & OPTION_BIN_LOG))
4302
- #else
4300
+ if (WSREP (thd))
4301
+ {
4302
+ /* for wsrep binlog format is meaningful also when binlogging is off */
4303
+ return (int ) WSREP_BINLOG_FORMAT (thd->variables .binlog_format );
4304
+ }
4305
+ #endif /* WITH_WSREP */
4303
4306
if (mysql_bin_log.is_open () && (thd->variables .option_bits & OPTION_BIN_LOG))
4304
- #endif
4305
- return (int ) WSREP_BINLOG_FORMAT (thd->variables .binlog_format );
4307
+ return (int ) thd->variables .binlog_format ;
4306
4308
else
4307
- return BINLOG_FORMAT_UNSPEC;
4309
+ return BINLOG_FORMAT_UNSPEC;
4308
4310
}
4309
4311
4310
4312
extern " C" void thd_mark_transaction_to_rollback (MYSQL_THD thd, bool all)
You can’t perform that action at this time.
0 commit comments