231 record_type after,
const unsigned char *extra_row_info);
329 static char const *state_name[] = {
"START_STATE",
"TABLE_STATE",
330 "ROW_STATE",
"STATE_COUNT"};
332 assert(0 <= target_state && target_state <=
STATE_COUNT);
367 void new_trans(
THD *, transaction *,
bool calc_writeset_hash);
Kerberos Client Authentication nullptr
Definition: auth_kerberos_client_plugin.cc:250
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:35
Definition: rpl_injector.h:165
char const * m_file_name
Definition: rpl_injector.h:173
char const * file_name() const
Definition: rpl_injector.h:169
my_off_t file_pos() const
Definition: rpl_injector.h:170
my_off_t m_file_pos
Definition: rpl_injector.h:174
Definition: rpl_injector.h:124
MY_BITMAP * save_write_set
Definition: rpl_injector.h:142
TABLE *const m_table
Definition: rpl_injector.h:140
~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
Definition: rpl_injector.h:122
char const * db_name() const
Definition: rpl_injector.h:150
const bool m_is_transactional
Definition: rpl_injector.h:158
const bool m_skip_hash
Definition: rpl_injector.h:159
TABLE * get_table() const
Definition: rpl_injector.h:152
TABLE *const m_table
Definition: rpl_injector.h:157
table(TABLE *table, bool is_transactional, bool skip_hash=false)
Definition: rpl_injector.h:145
bool skip_hash() const
Definition: rpl_injector.h:154
char const * table_name() const
Definition: rpl_injector.h:151
bool is_transactional() const
Definition: rpl_injector.h:153
Definition: rpl_injector.h:77
uchar * record_type
Definition: rpl_injector.h:82
bool good() const
Definition: rpl_injector.h:185
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:180
void clear()
Definition: rpl_injector.h:182
enum_state
Definition: rpl_injector.h:290
@ ROW_STATE
Definition: rpl_injector.h:293
@ START_STATE
Definition: rpl_injector.h:291
@ STATE_COUNT
Definition: rpl_injector.h:294
@ TABLE_STATE
Definition: rpl_injector.h:292
binlog_pos m_start_pos
Definition: rpl_injector.h:344
binlog_pos next_pos() const
Definition: rpl_injector.cc:282
~transaction()
Definition: rpl_injector.cc:81
binlog_pos m_next_pos
Definition: rpl_injector.h:345
THD * m_thd
Definition: rpl_injector.h:346
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:211
int commit()
Definition: rpl_injector.cc:101
int use_table(server_id_type sid, table tbl)
Definition: rpl_injector.cc:168
uint32 server_id_type
Definition: rpl_injector.h:83
int check_state(enum_state const target_state)
Definition: rpl_injector.h:327
transaction(transaction const &)
binlog_pos start_pos() const
Definition: rpl_injector.cc:278
void swap(transaction &o)
Definition: rpl_injector.h:282
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
bool m_calc_writeset_hash
Definition: rpl_injector.h:347
enum injector::transaction::enum_state m_state
transaction()
Definition: rpl_injector.h:177
int rollback()
Definition: rpl_injector.cc:144
transaction & operator=(transaction t)
Definition: rpl_injector.h:188
Definition: rpl_injector.h:50
static injector * instance()
Definition: rpl_injector.cc:294
void new_trans(THD *, transaction *, bool calc_writeset_hash)
Definition: rpl_injector.cc:309
int record_incident(THD *, mysql::binlog::event::Incident_event::enum_incident incident, const LEX_CSTRING &message)
Definition: rpl_injector.cc:320
static void free_instance()
Definition: rpl_injector.cc:300
injector(injector const &)
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:444
Contains the classes representing events operating in the replication stream properties.
#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
static int record
Definition: mysqltest.cc:194
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
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:777
LEX_CSTRING db
Definition: table.h:776
void column_bitmaps_set_no_signal(MY_BITMAP *read_set_arg, MY_BITMAP *write_set_arg)
Definition: table.h:1957
TABLE_SHARE * s
Definition: table.h:1404
void swap(const varlen_element &a, const varlen_element &b)
Definition: varlen_sort.h:65