32 #include <drizzled/atomics.h>
33 #include <drizzled/plugin/transaction_replicator.h>
48 const std::string &sch_filter,
49 const std::string &tab_filter,
50 const std::string &sch_regex,
51 const std::string &tab_regex);
73 drizzled::plugin::ReplicationReturnCode
120 *var_ptr= _tab_filter.c_str();
121 pthread_mutex_unlock(&sysvar_tab_lock);
132 *var_ptr= _sch_filter.c_str();
133 pthread_mutex_unlock(&sysvar_sch_lock);
147 std::vector<std::string> &filter);
179 std::string &in_schema_name,
180 std::string &in_table_name)
const;
194 std::string &schema_name,
195 std::string &table_name);
200 std::vector<std::string> schemas_to_filter;
201 std::vector<std::string> tables_to_filter;
207 std::string _sch_filter;
208 std::string _tab_filter;
210 const std::string _sch_regex;
211 const std::string _tab_regex;
220 pthread_mutex_t sch_vector_lock;
221 pthread_mutex_t tab_vector_lock;
228 pthread_mutex_t sysvar_sch_lock;
229 pthread_mutex_t sysvar_tab_lock;
const std::string & getTableFilter() const
bool isTableFiltered(const std::string &table_name)
void updateSchemaSysvar(const char **var_ptr)
void parseQuery(const std::string &sql, std::string &schema_name, std::string &table_name)
void setTableFilter(const std::string &input)
drizzled::plugin::ReplicationReturnCode replicate(drizzled::plugin::TransactionApplier *in_applier, drizzled::Session &in_session, drizzled::message::Transaction &to_replicate)
void setSchemaFilter(const std::string &input)
const std::string & getSchemaFilter() const
bool isSchemaFiltered(const std::string &schema_name)
void updateTableSysvar(const char **var_ptr)
void populateFilter(std::string input, std::vector< std::string > &filter)
void parseStatementTableMetadata(const drizzled::message::Statement &in_statement, std::string &in_schema_name, std::string &in_table_name) const