226 record_type after,
const unsigned char *extra_row_info);
311 static char const *state_name[] = {
"START_STATE",
"TABLE_STATE",
312 "ROW_STATE",
"STATE_COUNT"};
314 assert(0 <= target_state && target_state <=
STATE_COUNT);
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:36
Definition: rpl_injector.h:161
char const * m_file_name
Definition: rpl_injector.h:169
char const * file_name() const
Definition: rpl_injector.h:165
my_off_t file_pos() const
Definition: rpl_injector.h:166
my_off_t m_file_pos
Definition: rpl_injector.h:170
Definition: rpl_injector.h:122
MY_BITMAP * save_write_set
Definition: rpl_injector.h:140
TABLE *const m_table
Definition: rpl_injector.h:138
~save_sets()
Definition: rpl_injector.h:133
MY_BITMAP * save_read_set
Definition: rpl_injector.h:139
save_sets(table const &tbl, MY_BITMAP const *new_rs, MY_BITMAP const *new_ws)
Definition: rpl_injector.h:124
Definition: rpl_injector.h:120
const bool m_is_transactional
Definition: rpl_injector.h:154
const bool m_skip_hash
Definition: rpl_injector.h:155
TABLE * get_table() const
Definition: rpl_injector.h:148
TABLE *const m_table
Definition: rpl_injector.h:153
table(TABLE *table, bool is_transactional, bool skip_hash=false)
Definition: rpl_injector.h:143
bool skip_hash() const
Definition: rpl_injector.h:150
bool is_transactional() const
Definition: rpl_injector.h:149
Definition: rpl_injector.h:77
transaction(const transaction &)=delete
uchar * record_type
Definition: rpl_injector.h:80
int write_row(server_id_type sid, table tbl, MY_BITMAP const *cols, record_type record, const unsigned char *extra_row_info)
Definition: rpl_injector.cc:151
enum_state
Definition: rpl_injector.h:272
@ ROW_STATE
Definition: rpl_injector.h:275
@ START_STATE
Definition: rpl_injector.h:273
@ STATE_COUNT
Definition: rpl_injector.h:276
@ TABLE_STATE
Definition: rpl_injector.h:274
binlog_pos m_start_pos
Definition: rpl_injector.h:328
transaction & operator=(const transaction &&)=delete
binlog_pos next_pos() const
Definition: rpl_injector.cc:235
~transaction()
Definition: rpl_injector.h:190
binlog_pos m_next_pos
Definition: rpl_injector.h:329
THD *const m_thd
Definition: rpl_injector.h:330
char m_end_name_buf[FN_REFLEN]
Definition: rpl_injector.h:327
transaction & operator=(const transaction &)=delete
int delete_row(server_id_type sid, table tbl, MY_BITMAP const *cols, record_type record, const unsigned char *extra_row_info)
Definition: rpl_injector.cc:176
int commit()
Definition: rpl_injector.cc:72
int use_table(server_id_type sid, table tbl)
Definition: rpl_injector.cc:139
transaction(const transaction &&)=delete
uint32 server_id_type
Definition: rpl_injector.h:81
int check_state(enum_state const target_state)
Definition: rpl_injector.h:309
transaction(THD *thd, bool calc_writeset_hash)
Definition: rpl_injector.cc:37
binlog_pos start_pos() const
Definition: rpl_injector.cc:231
int update_row(server_id_type sid, table tbl, MY_BITMAP const *before_cols, MY_BITMAP const *after_cols, record_type before, record_type after, const unsigned char *extra_row_info)
Definition: rpl_injector.cc:201
char m_start_name_buf[FN_REFLEN]
Definition: rpl_injector.h:326
enum injector::transaction::enum_state m_state
int rollback()
Definition: rpl_injector.cc:115
const bool m_calc_writeset_hash
Definition: rpl_injector.h:331
Definition: rpl_injector.h:50
static injector * instance()
Definition: rpl_injector.cc:247
int record_incident(THD *, std::string_view message)
Definition: rpl_injector.cc:262
static void free_instance()
Definition: rpl_injector.cc:253
injector(injector const &)
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:181
Some integer typedefs for easier portability.
ulonglong my_off_t
Definition: my_inttypes.h:72
unsigned char uchar
Definition: my_inttypes.h:52
uint32_t uint32
Definition: my_inttypes.h:67
Common #defines and includes for file and socket I/O.
#define FN_REFLEN
Definition: my_io.h:83
static int record
Definition: mysqltest.cc:195
static PFS_engine_table_share_proxy table
Definition: pfs.cc:61
Definition: my_bitmap.h:43
void column_bitmaps_set_no_signal(MY_BITMAP *read_set_arg, MY_BITMAP *write_set_arg)
Definition: table.h:1969