/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
H A D | rpl_rli_pdb.h | 474 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 D | rpl_rli_pdb.cc | 62 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 D | rpl_rli_pdb.h | 474 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 D | rpl_rli_pdb.cc | 62 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 D | rpl_rli_pdb.h | 474 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 D | rpl_rli_pdb.cc | 62 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 D | rpl_rli.h | 55 } 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 D | rpl_rli_pdb.h | 474 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 D | rpl_rli_pdb.cc | 62 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 D | rpl_rli_pdb.h | 474 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 D | rpl_rli_pdb.cc | 62 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 D | rpl_rli_pdb.h | 474 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 D | rpl_rli_pdb.cc | 62 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 D | rpl_rli_pdb.h | 505 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 D | rpl_rli_pdb.cc | 103 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 D | rpl_rli_pdb.h | 90 } 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 D | rpl_rli_pdb.cc | 61 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 D | rpl_rli_pdb.h | 90 } 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 D | rpl_rli_pdb.cc | 61 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 D | rpl_rli_pdb.h | 90 } 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 D | rpl_rli_pdb.cc | 61 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 D | rpl_rli_pdb.h | 90 } 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 D | rpl_rli_pdb.cc | 61 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 D | rpl_rli_pdb.h | 90 } 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 D | rpl_rli_pdb.cc | 61 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()
|