Home
last modified time | relevance | path

Searched refs:Slave_job_item (Results 1 – 25 of 50) sorted by relevance

12

/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Drpl_rli_pdb.h474 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item>
477 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
789 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
790 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
792 Slave_job_item *job_item);
801 Slave_job_item* de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc62 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
284 Slave_job_item empty= Slave_job_item(); in init_worker()
2189 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
2220 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
2239 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2510 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Drpl_rli_pdb.h474 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item>
477 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
830 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
831 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
833 Slave_job_item *job_item);
842 Slave_job_item* de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc62 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
284 Slave_job_item empty= Slave_job_item(); in init_worker()
2199 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
2252 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
2271 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2542 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Drpl_rli_pdb.h474 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item>
477 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
835 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
836 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
838 Slave_job_item *job_item);
847 Slave_job_item* de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc62 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
284 Slave_job_item empty= Slave_job_item(); in init_worker()
2289 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
2342 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
2361 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2632 Slave_job_item *job_item) in pop_jobs_item()
H A Drpl_rli.h55 } Slave_job_item; typedef
653 Prealloced_array<Slave_job_item, 8, true> curr_group_da;
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Drpl_rli_pdb.h474 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item>
477 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
835 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
836 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
838 Slave_job_item *job_item);
847 Slave_job_item* de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc62 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
284 Slave_job_item empty= Slave_job_item(); in init_worker()
2289 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
2342 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
2361 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2632 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Drpl_rli_pdb.h474 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item>
477 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
830 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
831 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
833 Slave_job_item *job_item);
842 Slave_job_item* de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc62 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
284 Slave_job_item empty= Slave_job_item(); in init_worker()
2199 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
2252 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
2271 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2542 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Drpl_rli_pdb.h474 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item>
477 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
835 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
836 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
838 Slave_job_item *job_item);
847 Slave_job_item* de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc62 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
284 Slave_job_item empty= Slave_job_item(); in init_worker()
2289 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
2342 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
2361 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2632 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Drpl_rli_pdb.h505 class Slave_jobs_queue : public circular_buffer_queue<Slave_job_item> {
507 Slave_jobs_queue() : circular_buffer_queue<Slave_job_item>() {} in Slave_jobs_queue()
952 void *head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
953 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
955 Slave_job_item *job_item);
964 Slave_job_item *de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
H A Drpl_rli_pdb.cc103 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item) { in handle_slave_worker_stop()
168 Slave_job_item *job_item) { in set_max_updated_index_on_stop()
312 Slave_job_item empty = Slave_job_item(); in init_worker()
2067 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) { in en_queue()
2095 void *head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) { in head_queue()
2111 Slave_job_item *de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) { in de_queue()
2359 Slave_job_item *job_item) { in pop_jobs_item()
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Drpl_rli_pdb.h90 } Slave_job_item; typedef
466 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
467 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
469 Slave_job_item *job_item);
H A Drpl_rli_pdb.cc61 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
261 Slave_job_item empty= {NULL}; in init_worker()
289 my_init_dynamic_array(&jobs.Q, sizeof(Slave_job_item), jobs.size, 0); in init_worker()
1799 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
1830 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
1849 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2020 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Drpl_rli_pdb.h90 } Slave_job_item; typedef
466 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
467 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
469 Slave_job_item *job_item);
H A Drpl_rli_pdb.cc61 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
261 Slave_job_item empty= {NULL}; in init_worker()
289 my_init_dynamic_array(&jobs.Q, sizeof(Slave_job_item), jobs.size, 0); in init_worker()
1799 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
1830 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
1849 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2020 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Drpl_rli_pdb.h90 } Slave_job_item; typedef
461 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
462 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
464 Slave_job_item *job_item);
H A Drpl_rli_pdb.cc61 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
261 Slave_job_item empty= {NULL}; in init_worker()
289 my_init_dynamic_array(&jobs.Q, sizeof(Slave_job_item), jobs.size, 0); in init_worker()
1746 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
1777 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
1796 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
1967 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Drpl_rli_pdb.h90 } Slave_job_item; typedef
466 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
467 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
469 Slave_job_item *job_item);
H A Drpl_rli_pdb.cc61 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
261 Slave_job_item empty= {NULL}; in init_worker()
289 my_init_dynamic_array(&jobs.Q, sizeof(Slave_job_item), jobs.size, 0); in init_worker()
1799 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
1830 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
1849 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
2020 Slave_job_item *job_item) in pop_jobs_item()
/dports/databases/mysql56-client/mysql-5.6.51/sql/
H A Drpl_rli_pdb.h90 } Slave_job_item; typedef
461 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret);
462 bool handle_slave_worker_stop(Slave_worker *worker, Slave_job_item *job_item);
464 Slave_job_item *job_item);
H A Drpl_rli_pdb.cc61 Slave_job_item *job_item) in handle_slave_worker_stop()
132 Slave_job_item *job_item) in set_max_updated_index_on_stop()
261 Slave_job_item empty= {NULL}; in init_worker()
289 my_init_dynamic_array(&jobs.Q, sizeof(Slave_job_item), jobs.size, 0); in init_worker()
1746 static int en_queue(Slave_jobs_queue *jobs, Slave_job_item *item) in en_queue()
1777 void * head_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in head_queue()
1796 Slave_job_item * de_queue(Slave_jobs_queue *jobs, Slave_job_item *ret) in de_queue()
1967 Slave_job_item *job_item) in pop_jobs_item()

12