229 record_type after,
const unsigned char *extra_row_info);
314 static char const *state_name[] = {
"START_STATE",
"TABLE_STATE",
315 "ROW_STATE",
"STATE_COUNT"};
317 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:164
char const * m_file_name
Definition: rpl_injector.h:172
char const * file_name() const
Definition: rpl_injector.h:168
my_off_t file_pos() const
Definition: rpl_injector.h:169
my_off_t m_file_pos
Definition: rpl_injector.h:173
Definition: rpl_injector.h:123
MY_BITMAP * save_write_set
Definition: rpl_injector.h:141
TABLE *const m_table
Definition: rpl_injector.h:139
~save_sets()
Definition: rpl_injector.h:134
MY_BITMAP * save_read_set
Definition: rpl_injector.h:140
save_sets(table const &tbl, MY_BITMAP const *new_rs, MY_BITMAP const *new_ws)
Definition: rpl_injector.h:125
Definition: rpl_injector.h:121
char const * db_name() const
Definition: rpl_injector.h:149
const bool m_is_transactional
Definition: rpl_injector.h:157
const bool m_skip_hash
Definition: rpl_injector.h:158
TABLE * get_table() const
Definition: rpl_injector.h:151
TABLE *const m_table
Definition: rpl_injector.h:156
table(TABLE *table, bool is_transactional, bool skip_hash=false)
Definition: rpl_injector.h:144
bool skip_hash() const
Definition: rpl_injector.h:153
char const * table_name() const
Definition: rpl_injector.h:150
bool is_transactional() const
Definition: rpl_injector.h:152
Definition: rpl_injector.h:78
transaction(const transaction &)=delete
uchar * record_type
Definition: rpl_injector.h:81
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:152
enum_state
Definition: rpl_injector.h:275
@ ROW_STATE
Definition: rpl_injector.h:278
@ START_STATE
Definition: rpl_injector.h:276
@ STATE_COUNT
Definition: rpl_injector.h:279
@ TABLE_STATE
Definition: rpl_injector.h:277
binlog_pos m_start_pos
Definition: rpl_injector.h:331
transaction & operator=(const transaction &&)=delete
binlog_pos next_pos() const
Definition: rpl_injector.cc:236
~transaction()
Definition: rpl_injector.h:193
binlog_pos m_next_pos
Definition: rpl_injector.h:332
THD *const m_thd
Definition: rpl_injector.h:333
char m_end_name_buf[FN_REFLEN]
Definition: rpl_injector.h:330
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:177
int commit()
Definition: rpl_injector.cc:73
int use_table(server_id_type sid, table tbl)
Definition: rpl_injector.cc:140
transaction(const transaction &&)=delete
uint32 server_id_type
Definition: rpl_injector.h:82
int check_state(enum_state const target_state)
Definition: rpl_injector.h:312
transaction(THD *thd, bool calc_writeset_hash)
Definition: rpl_injector.cc:38
binlog_pos start_pos() const
Definition: rpl_injector.cc:232
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:202
char m_start_name_buf[FN_REFLEN]
Definition: rpl_injector.h:329
enum injector::transaction::enum_state m_state
int rollback()
Definition: rpl_injector.cc:116
const bool m_calc_writeset_hash
Definition: rpl_injector.h:334
Definition: rpl_injector.h:51
static injector * instance()
Definition: rpl_injector.cc:248
int record_incident(THD *, mysql::binlog::event::Incident_event::enum_incident incident, const LEX_CSTRING &message)
Definition: rpl_injector.cc:263
static void free_instance()
Definition: rpl_injector.cc:254
injector(injector const &)
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:445
Contains the classes representing events operating in the replication stream properties.
#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: mysql_lex_string.h:40
const char * str
Definition: mysql_lex_string.h:41
Definition: my_bitmap.h:43
LEX_CSTRING table_name
Definition: table.h:779
LEX_CSTRING db
Definition: table.h:778
void column_bitmaps_set_no_signal(MY_BITMAP *read_set_arg, MY_BITMAP *write_set_arg)
Definition: table.h:1961
TABLE_SHARE * s
Definition: table.h:1406