232 record_type after,
const unsigned char *extra_row_info);
350 static char const *state_name[] = {
"START_STATE",
"TABLE_STATE",
351 "ROW_STATE",
"STATE_COUNT"};
353 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:34
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:437
Definition: rpl_injector.h:166
char const * m_file_name
Definition: rpl_injector.h:174
char const * file_name() const
Definition: rpl_injector.h:170
my_off_t file_pos() const
Definition: rpl_injector.h:171
my_off_t m_file_pos
Definition: rpl_injector.h:175
Definition: rpl_injector.h:125
MY_BITMAP * save_write_set
Definition: rpl_injector.h:143
TABLE *const m_table
Definition: rpl_injector.h:141
~save_sets()
Definition: rpl_injector.h:136
MY_BITMAP * save_read_set
Definition: rpl_injector.h:142
save_sets(table const &tbl, MY_BITMAP const *new_rs, MY_BITMAP const *new_ws)
Definition: rpl_injector.h:127
Definition: rpl_injector.h:123
char const * db_name() const
Definition: rpl_injector.h:151
const bool m_is_transactional
Definition: rpl_injector.h:159
const bool m_skip_hash
Definition: rpl_injector.h:160
TABLE * get_table() const
Definition: rpl_injector.h:153
TABLE *const m_table
Definition: rpl_injector.h:158
table(TABLE *table, bool is_transactional, bool skip_hash=false)
Definition: rpl_injector.h:146
bool skip_hash() const
Definition: rpl_injector.h:155
char const * table_name() const
Definition: rpl_injector.h:152
bool is_transactional() const
Definition: rpl_injector.h:154
Definition: rpl_injector.h:78
uchar * record_type
Definition: rpl_injector.h:83
bool good() const
Definition: rpl_injector.h:186
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:178
void clear()
Definition: rpl_injector.h:183
enum_state
Definition: rpl_injector.h:311
@ ROW_STATE
Definition: rpl_injector.h:314
@ START_STATE
Definition: rpl_injector.h:312
@ STATE_COUNT
Definition: rpl_injector.h:315
@ TABLE_STATE
Definition: rpl_injector.h:313
binlog_pos m_start_pos
Definition: rpl_injector.h:365
binlog_pos next_pos() const
Definition: rpl_injector.cc:283
~transaction()
Definition: rpl_injector.cc:79
binlog_pos m_next_pos
Definition: rpl_injector.h:366
THD * m_thd
Definition: rpl_injector.h:367
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:210
int commit()
Definition: rpl_injector.cc:99
int use_table(server_id_type sid, table tbl)
Definition: rpl_injector.cc:166
uint32 server_id_type
Definition: rpl_injector.h:84
int check_state(enum_state const target_state)
Definition: rpl_injector.h:348
transaction(transaction const &)
binlog_pos start_pos() const
Definition: rpl_injector.cc:279
void swap(transaction &o)
Definition: rpl_injector.h:283
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:242
enum injector::transaction::enum_state m_state
transaction()
Definition: rpl_injector.h:178
int rollback()
Definition: rpl_injector.cc:142
transaction & operator=(transaction t)
Definition: rpl_injector.h:189
Definition: rpl_injector.h:51
static injector * instance()
Definition: rpl_injector.cc:295
static void free_instance()
Definition: rpl_injector.cc:301
int record_incident(THD *, binary_log::Incident_event::enum_incident incident, LEX_CSTRING const message)
Definition: rpl_injector.cc:320
injector(injector const &)
void new_trans(THD *, transaction *)
Definition: rpl_injector.cc:310
Contains the classes representing events operating in the replication stream properties.
Fido Client Authentication nullptr
Definition: fido_client_plugin.cc:222
#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
static int record
Definition: mysqltest.cc:188
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:774
LEX_CSTRING db
Definition: table.h:773
void column_bitmaps_set_no_signal(MY_BITMAP *read_set_arg, MY_BITMAP *write_set_arg)
Definition: table.h:1906
TABLE_SHARE * s
Definition: table.h:1399