Home
last modified time | relevance | path

Searched refs:Object_queue (Results 1 – 25 of 28) sorted by relevance

12

/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/client/dump/
H A Dobject_queue.cc32 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
60 void Object_queue::queue_thread() in queue_thread()
104 void Object_queue::read_object(Item_processing_data* item_to_process) in read_object()
158 void Object_queue::stop_queue() in stop_queue()
173 Object_queue::~Object_queue() in ~Object_queue()
184 Object_queue::Object_queue( in Object_queue() function in Object_queue
191 this, &Object_queue::task_availability_callback), in Object_queue()
199 boost::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h46 class Object_queue : public Abstract_object_reader_wrapper,
50 Object_queue(
56 ~Object_queue();
85 Mysql::Instance_callback<void, const Abstract_dump_task*, Object_queue>
H A Dmysqldump_tool_chain_maker.cc141 std::map<int, Object_queue*>::iterator it= in create_chain()
147 Object_queue* queue= new Object_queue( in create_chain()
161 std::map<int, Object_queue*>::const_iterator iter; in stop_queues()
H A Dmysqldump_tool_chain_maker.h75 std::map<int, Object_queue*> m_object_queues;
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/client/dump/
H A Dobject_queue.cc35 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
58 void Object_queue::queue_thread() { in queue_thread()
93 void Object_queue::read_object(Item_processing_data *item_to_process) { in read_object()
140 void Object_queue::stop_queue() { in stop_queue()
154 Object_queue::~Object_queue() { in ~Object_queue()
163 Object_queue::Object_queue( in Object_queue() function in Object_queue
171 std::bind(&Object_queue::task_availability_callback, this, _1)), in Object_queue()
176 m_thread_group.create_thread(std::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h50 class Object_queue : public Abstract_object_reader_wrapper,
53 Object_queue(std::function<bool(const Mysql::Tools::Base::Message_data &)>
59 ~Object_queue();
H A Dmysqldump_tool_chain_maker.cc167 std::map<int, Object_queue *>::iterator it = in create_chain()
172 Object_queue *queue = new Object_queue( in create_chain()
186 std::map<int, Object_queue *>::const_iterator iter; in stop_queues()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/client/dump/
H A Dobject_queue.cc32 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
60 void Object_queue::queue_thread() in queue_thread()
104 void Object_queue::read_object(Item_processing_data* item_to_process) in read_object()
158 void Object_queue::stop_queue() in stop_queue()
181 Object_queue::~Object_queue() in ~Object_queue()
192 Object_queue::Object_queue( in Object_queue() function in Object_queue
199 this, &Object_queue::task_availability_callback), in Object_queue()
207 boost::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h46 class Object_queue : public Abstract_object_reader_wrapper,
50 Object_queue(
56 ~Object_queue();
85 Mysql::Instance_callback<void, const Abstract_dump_task*, Object_queue>
H A Dmysqldump_tool_chain_maker.cc141 std::map<int, Object_queue*>::iterator it= in create_chain()
147 Object_queue* queue= new Object_queue( in create_chain()
161 std::map<int, Object_queue*>::const_iterator iter; in stop_queues()
H A Dmysqldump_tool_chain_maker.h75 std::map<int, Object_queue*> m_object_queues;
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/client/dump/
H A Dobject_queue.cc32 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
60 void Object_queue::queue_thread() in queue_thread()
104 void Object_queue::read_object(Item_processing_data* item_to_process) in read_object()
158 void Object_queue::stop_queue() in stop_queue()
181 Object_queue::~Object_queue() in ~Object_queue()
192 Object_queue::Object_queue( in Object_queue() function in Object_queue
199 this, &Object_queue::task_availability_callback), in Object_queue()
207 boost::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h46 class Object_queue : public Abstract_object_reader_wrapper,
50 Object_queue(
56 ~Object_queue();
85 Mysql::Instance_callback<void, const Abstract_dump_task*, Object_queue>
H A Dmysqldump_tool_chain_maker.cc141 std::map<int, Object_queue*>::iterator it= in create_chain()
147 Object_queue* queue= new Object_queue( in create_chain()
161 std::map<int, Object_queue*>::const_iterator iter; in stop_queues()
H A Dmysqldump_tool_chain_maker.h75 std::map<int, Object_queue*> m_object_queues;
/dports/databases/percona57-server/percona-server-5.7.36-39/client/dump/
H A Dobject_queue.cc32 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
60 void Object_queue::queue_thread() in queue_thread()
104 void Object_queue::read_object(Item_processing_data* item_to_process) in read_object()
158 void Object_queue::stop_queue() in stop_queue()
181 Object_queue::~Object_queue() in ~Object_queue()
192 Object_queue::Object_queue( in Object_queue() function in Object_queue
199 this, &Object_queue::task_availability_callback), in Object_queue()
207 boost::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h46 class Object_queue : public Abstract_object_reader_wrapper,
50 Object_queue(
56 ~Object_queue();
85 Mysql::Instance_callback<void, const Abstract_dump_task*, Object_queue>
H A Dmysqldump_tool_chain_maker.cc141 std::map<int, Object_queue*>::iterator it= in create_chain()
147 Object_queue* queue= new Object_queue( in create_chain()
161 std::map<int, Object_queue*>::const_iterator iter; in stop_queues()
H A Dmysqldump_tool_chain_maker.h75 std::map<int, Object_queue*> m_object_queues;
/dports/databases/percona57-client/percona-server-5.7.36-39/client/dump/
H A Dobject_queue.cc32 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
60 void Object_queue::queue_thread() in queue_thread()
104 void Object_queue::read_object(Item_processing_data* item_to_process) in read_object()
158 void Object_queue::stop_queue() in stop_queue()
181 Object_queue::~Object_queue() in ~Object_queue()
192 Object_queue::Object_queue( in Object_queue() function in Object_queue
199 this, &Object_queue::task_availability_callback), in Object_queue()
207 boost::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h46 class Object_queue : public Abstract_object_reader_wrapper,
50 Object_queue(
56 ~Object_queue();
85 Mysql::Instance_callback<void, const Abstract_dump_task*, Object_queue>
H A Dmysqldump_tool_chain_maker.cc141 std::map<int, Object_queue*>::iterator it= in create_chain()
147 Object_queue* queue= new Object_queue( in create_chain()
161 std::map<int, Object_queue*>::const_iterator iter; in stop_queues()
/dports/databases/mysql57-client/mysql-5.7.36/client/dump/
H A Dobject_queue.cc32 void Object_queue::add_ready_items_to_queue( in add_ready_items_to_queue()
47 void Object_queue::task_availability_callback( in task_availability_callback()
60 void Object_queue::queue_thread() in queue_thread()
104 void Object_queue::read_object(Item_processing_data* item_to_process) in read_object()
158 void Object_queue::stop_queue() in stop_queue()
181 Object_queue::~Object_queue() in ~Object_queue()
192 Object_queue::Object_queue( in Object_queue() function in Object_queue
199 this, &Object_queue::task_availability_callback), in Object_queue()
207 boost::bind(&Object_queue::queue_thread, this)); in Object_queue()
H A Dobject_queue.h46 class Object_queue : public Abstract_object_reader_wrapper,
50 Object_queue(
56 ~Object_queue();
85 Mysql::Instance_callback<void, const Abstract_dump_task*, Object_queue>
H A Dmysqldump_tool_chain_maker.cc141 std::map<int, Object_queue*>::iterator it= in create_chain()
147 Object_queue* queue= new Object_queue( in create_chain()
161 std::map<int, Object_queue*>::const_iterator iter; in stop_queues()

12