227 record_type after,
const unsigned char *extra_row_info);
345 static char const *state_name[] = {
"START_STATE",
"TABLE_STATE",
346 "ROW_STATE",
"STATE_COUNT"};
348 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:33
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:436
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:124
MY_BITMAP * save_write_set
Definition: rpl_injector.h:142
~save_sets()
Definition: rpl_injector.h:135
MY_BITMAP * save_read_set
Definition: rpl_injector.h:141
save_sets(table const &tbl, MY_BITMAP const *new_rs, MY_BITMAP const *new_ws)
Definition: rpl_injector.h:126
TABLE * m_table
Definition: rpl_injector.h:140
Definition: rpl_injector.h:122
table(TABLE *table, bool is_transactional)
Definition: rpl_injector.h:145
char const * db_name() const
Definition: rpl_injector.h:148
TABLE * get_table() const
Definition: rpl_injector.h:150
TABLE * m_table
Definition: rpl_injector.h:154
bool m_is_transactional
Definition: rpl_injector.h:155
char const * table_name() const
Definition: rpl_injector.h:149
bool is_transactional() const
Definition: rpl_injector.h:151
Definition: rpl_injector.h:77
uchar * record_type
Definition: rpl_injector.h:82
bool good() const
Definition: rpl_injector.h:181
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:166
void clear()
Definition: rpl_injector.h:178
enum_state
Definition: rpl_injector.h:306
@ ROW_STATE
Definition: rpl_injector.h:309
@ START_STATE
Definition: rpl_injector.h:307
@ STATE_COUNT
Definition: rpl_injector.h:310
@ TABLE_STATE
Definition: rpl_injector.h:308
binlog_pos m_start_pos
Definition: rpl_injector.h:360
binlog_pos next_pos() const
Definition: rpl_injector.cc:244
~transaction()
Definition: rpl_injector.cc:77
binlog_pos m_next_pos
Definition: rpl_injector.h:361
THD * m_thd
Definition: rpl_injector.h:362
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:190
int commit()
Definition: rpl_injector.cc:97
int use_table(server_id_type sid, table tbl)
Definition: rpl_injector.cc:151
uint32 server_id_type
Definition: rpl_injector.h:83
int check_state(enum_state const target_state)
Definition: rpl_injector.h:343
transaction(transaction const &)
binlog_pos start_pos() const
Definition: rpl_injector.cc:240
void swap(transaction &o)
Definition: rpl_injector.h:278
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:213
enum injector::transaction::enum_state m_state
transaction()
Definition: rpl_injector.h:173
int rollback()
Definition: rpl_injector.cc:140
transaction & operator=(transaction t)
Definition: rpl_injector.h:184
Definition: rpl_injector.h:50
static injector * instance()
Definition: rpl_injector.cc:256
static void free_instance()
Definition: rpl_injector.cc:262
int record_incident(THD *, binary_log::Incident_event::enum_incident incident, LEX_CSTRING const message)
Definition: rpl_injector.cc:281
injector(injector const &)
void new_trans(THD *, transaction *)
Definition: rpl_injector.cc:271
Contains the classes representing events operating in the replication stream properties.
Fido Client Authentication nullptr
Definition: fido_client_plugin.cc:221
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:180
Some integer typedefs for easier portability.
ulonglong my_off_t
Definition: my_inttypes.h:71
unsigned char uchar
Definition: my_inttypes.h:51
uint32_t uint32
Definition: my_inttypes.h:66
Definition: mysql_lex_string.h:39
const char * str
Definition: mysql_lex_string.h:40
Definition: my_bitmap.h:42
LEX_CSTRING table_name
Definition: table.h:771
LEX_CSTRING db
Definition: table.h:770
void column_bitmaps_set_no_signal(MY_BITMAP *read_set_arg, MY_BITMAP *write_set_arg)
Definition: table.h:1883
TABLE_SHARE * s
Definition: table.h:1396
Definition: mi_test3.cc:54