23#ifndef APPLIER_CHANNEL_STATE_OBSERVER_INCLUDE
24#define APPLIER_CHANNEL_STATE_OBSERVER_INCLUDE
51 unsigned long len,
const char **event_buf,
52 unsigned long *event_len)
override;
Definition: applier_channel_state_observer.h:29
int thread_start(Binlog_relay_IO_param *param) override
Observer for receiver thread starts.
Definition: applier_channel_state_observer.cc:29
int after_queue_event(Binlog_relay_IO_param *param, const char *event_buf, unsigned long event_len, uint32 flags) override
Observer for whenever a event is queued by the receiver thread.
Definition: applier_channel_state_observer.cc:60
int applier_stop(Binlog_relay_IO_param *param, bool aborted) override
Observer for applier thread stops.
Definition: applier_channel_state_observer.cc:41
int before_request_transmit(Binlog_relay_IO_param *param, uint32 flags) override
Observer for when a new transmission from a another server is requested.
Definition: applier_channel_state_observer.cc:47
int after_reset_slave(Binlog_relay_IO_param *param) override
Observer for whenever a reset slave is executed.
Definition: applier_channel_state_observer.cc:66
int thread_stop(Binlog_relay_IO_param *param) override
Observer for receiver thread stops.
Definition: applier_channel_state_observer.cc:33
int applier_log_event(Binlog_relay_IO_param *param, Trans_param *trans_param, int &out) override
Observer for applier log event.
Definition: applier_channel_state_observer.cc:70
int after_read_event(Binlog_relay_IO_param *param, const char *packet, unsigned long len, const char **event_buf, unsigned long *event_len) override
Observer for whenever a event is read by the receiver thread.
Definition: applier_channel_state_observer.cc:52
Applier_channel_state_observer()
int applier_start(Binlog_relay_IO_param *param) override
Observer for applier thread starts.
Definition: applier_channel_state_observer.cc:37
A interface class to code channel state response methods.
Definition: channel_observation_manager.h:37
static int flags[50]
Definition: hp_test1.cc:39
Some integer typedefs for easier portability.
uint32_t uint32
Definition: my_inttypes.h:66
Replication binlog relay IO observer parameter.
Definition: replication.h:588
Transaction observer parameter.
Definition: replication.h:135