23 #include <plugin/slave/queue_consumer.h>
24 #include <plugin/slave/queue_producer.h>
25 #include <plugin/slave/replication_schema.h>
26 #include <drizzled/plugin/daemon.h>
27 #include <boost/thread.hpp>
28 #include <boost/unordered_map.hpp>
51 boost::unordered_map<uint32_t, Master *>::const_iterator it;
55 it->second->thread().interrupt();
80 boost::thread &thread()
118 return *(_masters[index]);
Master & master(size_t index)
boost::thread _consumer_thread
TODO: Rename this file - func.h is stupid.
boost::unordered_map< uint32_t, Master * > _masters
boost::thread _producer_thread
void startup(drizzled::Session &session)