23 #include <client/client_priv.h>
24 #include <drizzled/error_t.h>
25 #include <plugin/slave/queue_thread.h>
26 #include <plugin/slave/sql_executor.h>
42 _last_return(DRIZZLE_RETURN_OK),
44 _saved_max_commit_id(0),
46 _seconds_between_reconnects(30)
55 void setSleepInterval(uint32_t seconds)
60 uint32_t getSleepInterval()
65 void setMasterHost(
const std::string &host)
70 void setMasterPort(uint16_t port)
75 void setMasterUser(
const std::string &user)
80 void setMasterPassword(
const std::string &password)
82 _master_pass= password;
85 void setMaxReconnectAttempts(uint32_t max)
90 void setSecondsBetweenReconnects(uint32_t seconds)
92 _seconds_between_reconnects= seconds;
95 void setCachedMaxCommitId(uint64_t value)
97 _saved_max_commit_id= value;
100 uint64_t cachedMaxCommitId()
102 return _saved_max_commit_id;
105 void setMasterId(uint32_t value)
120 std::string _master_host;
121 uint16_t _master_port;
122 std::string _master_user;
123 std::string _master_pass;
127 drizzle_st *_drizzle;
128 drizzle_con_st *_connection;
129 drizzle_return_t _last_return;
132 uint64_t _saved_max_commit_id;
133 uint32_t _max_reconnects;
134 uint32_t _seconds_between_reconnects;
136 std::string _last_error_message;
184 bool queryForTrxIdList(uint64_t max_commit_id, std::vector<uint64_t> &list);
185 bool queueInsert(
const char *trx_id,
187 const char *commit_id,
188 const char *originating_server_uuid,
189 const char *originating_commit_id,
191 const char *msg_length);
199 void setIOState(
const std::string &err_msg,
bool status);
enum drizzled::error_t queryForReplicationEvents(uint64_t max_commit_id)
bool reconnect(bool initial_connection)
bool queryForMaxCommitId(uint64_t *max_commit_id)
void setIOState(const std::string &err_msg, bool status)