| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
| H A D | log_event.cc | 3035 (rli->curr_group_da.back().data-> in get_slave_worker()
3041 (rli->curr_group_da.back().data-> in get_slave_worker()
3296 if (rli->curr_group_da.size() < 1) in apply_gtid_event()
3299 Log_event* ev= rli->curr_group_da[0].data; in apply_gtid_event()
3307 rli->curr_group_da.clear(); in apply_gtid_event()
3395 if (rli->curr_group_da.size() > 0 && in apply_event()
3417 rli->curr_group_da.size() > 0 && in apply_event()
3457 rli->curr_group_da.size() > 0) in apply_event()
3500 (rli->curr_group_da.back().data-> in apply_event()
3507 (rli->curr_group_da.back().data-> in apply_event()
[all …]
|
| H A D | rpl_rli.h | 648 Prealloced_array<Slave_job_item, 8, true> curr_group_da; variable
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/ |
| H A D | log_event.cc | 3032 (rli->curr_group_da.back().data-> in get_slave_worker()
3038 (rli->curr_group_da.back().data-> in get_slave_worker()
3293 if (rli->curr_group_da.size() < 1) in apply_gtid_event()
3296 Log_event* ev= rli->curr_group_da[0].data; in apply_gtid_event()
3304 rli->curr_group_da.clear(); in apply_gtid_event()
3392 if (rli->curr_group_da.size() > 0 && in apply_event()
3414 rli->curr_group_da.size() > 0 && in apply_event()
3454 rli->curr_group_da.size() > 0) in apply_event()
3497 (rli->curr_group_da.back().data-> in apply_event()
3504 (rli->curr_group_da.back().data-> in apply_event()
[all …]
|
| H A D | rpl_rli.h | 648 Prealloced_array<Slave_job_item, 8, true> curr_group_da; variable
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
| H A D | log_event.cc | 2971 rli->curr_group_da.push_back(job_item); in get_slave_worker()
3003 rli->curr_group_da.push_back(job_item); in get_slave_worker()
3032 (rli->curr_group_da.back().data-> in get_slave_worker()
3038 (rli->curr_group_da.back().data-> in get_slave_worker()
3293 if (rli->curr_group_da.size() < 1) in apply_gtid_event()
3296 Log_event* ev= rli->curr_group_da[0].data; in apply_gtid_event()
3304 rli->curr_group_da.clear(); in apply_gtid_event()
3392 if (rli->curr_group_da.size() > 0 && in apply_event()
3414 rli->curr_group_da.size() > 0 && in apply_event()
3454 rli->curr_group_da.size() > 0) in apply_event()
[all …]
|
| H A D | rpl_rli.h | 648 Prealloced_array<Slave_job_item, 8, true> curr_group_da; variable
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | log_event.cc | 3165 (rli->curr_group_da.back().data-> in get_slave_worker()
3171 (rli->curr_group_da.back().data-> in get_slave_worker()
3426 if (rli->curr_group_da.size() < 1) in apply_gtid_event()
3429 Log_event* ev= rli->curr_group_da[0].data; in apply_gtid_event()
3437 rli->curr_group_da.clear(); in apply_gtid_event()
3525 if (rli->curr_group_da.size() > 0 && in apply_event()
3547 rli->curr_group_da.size() > 0 && in apply_event()
3587 rli->curr_group_da.size() > 0) in apply_event()
3630 (rli->curr_group_da.back().data-> in apply_event()
3637 (rli->curr_group_da.back().data-> in apply_event()
[all …]
|
| H A D | rpl_rli.h | 653 Prealloced_array<Slave_job_item, 8, true> curr_group_da; variable
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | log_event.cc | 3165 (rli->curr_group_da.back().data-> in get_slave_worker()
3171 (rli->curr_group_da.back().data-> in get_slave_worker()
3426 if (rli->curr_group_da.size() < 1) in apply_gtid_event()
3429 Log_event* ev= rli->curr_group_da[0].data; in apply_gtid_event()
3437 rli->curr_group_da.clear(); in apply_gtid_event()
3525 if (rli->curr_group_da.size() > 0 && in apply_event()
3547 rli->curr_group_da.size() > 0 && in apply_event()
3587 rli->curr_group_da.size() > 0) in apply_event()
3630 (rli->curr_group_da.back().data-> in apply_event()
3637 (rli->curr_group_da.back().data-> in apply_event()
[all …]
|
| H A D | rpl_rli.h | 653 Prealloced_array<Slave_job_item, 8, true> curr_group_da; variable
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
| H A D | log_event.cc | 2707 rli->curr_group_da.push_back(job_item); in get_slave_worker()
2744 rli->curr_group_da.push_back(job_item); in get_slave_worker()
2752 DBUG_ASSERT(rli->curr_group_da.size() == 2); in get_slave_worker()
2771 rli->curr_group_da.push_back(job_item); in get_slave_worker()
2923 rli->curr_group_da.push_back(job_item); in get_slave_worker()
3071 if (rli->curr_group_da.size() < 1) return 1; in apply_gtid_event()
3073 Log_event *ev = rli->curr_group_da[0].data; in apply_gtid_event()
3080 rli->curr_group_da.clear(); in apply_gtid_event()
3186 rli->curr_group_da.size() > 0 && in apply_event()
3224 rli->curr_group_da.size() > 0) { in apply_event()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | log_event.cc | 3165 (rli->curr_group_da.back().data-> in get_slave_worker()
3171 (rli->curr_group_da.back().data-> in get_slave_worker()
3426 if (rli->curr_group_da.size() < 1) in apply_gtid_event()
3429 Log_event* ev= rli->curr_group_da[0].data; in apply_gtid_event()
3437 rli->curr_group_da.clear(); in apply_gtid_event()
3525 if (rli->curr_group_da.size() > 0 && in apply_event()
3547 rli->curr_group_da.size() > 0 && in apply_event()
3587 rli->curr_group_da.size() > 0) in apply_event()
3630 (rli->curr_group_da.back().data-> in apply_event()
3637 (rli->curr_group_da.back().data-> in apply_event()
[all …]
|
| H A D | rpl_rli.h | 653 Prealloced_array<Slave_job_item, 8, true> curr_group_da; variable
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
| H A D | rpl_slave.cc | 4054 if (rli->curr_group_da.elements > 0) in apply_event_and_update_pos()
4060 for (uint i= 0; i < rli->curr_group_da.elements; i++) in apply_event_and_update_pos()
4073 if (rli->curr_group_da.elements > rli->curr_group_da.max_element) in apply_event_and_update_pos()
4076 rli->curr_group_da.elements= rli->curr_group_da.max_element; in apply_event_and_update_pos()
4077 rli->curr_group_da.max_element= 0; in apply_event_and_update_pos()
4078 freeze_size(&rli->curr_group_da); // restores max_element in apply_event_and_update_pos()
4080 rli->curr_group_da.elements= 0; in apply_event_and_update_pos()
6075 my_init_dynamic_array(&rli->curr_group_da, sizeof(Log_event*), 8, 2); in slave_start_workers()
6244 for (uint i= 0; i < rli->curr_group_da.elements; i++) in slave_stop_workers()
6245 delete *(Log_event**) dynamic_array_ptr(&rli->curr_group_da, i); in slave_stop_workers()
[all …]
|
| H A D | rpl_rli.h | 524 DYNAMIC_ARRAY curr_group_da; // deferred array to hold partition-info-free events variable
|
| H A D | log_event.cc | 2775 insert_dynamic(&rli->curr_group_da, in get_slave_worker()
2778 DBUG_ASSERT(rli->curr_group_da.elements == 1); in get_slave_worker()
2798 insert_dynamic(&rli->curr_group_da, (uchar*) &ptr_curr_ev); in get_slave_worker()
2801 DBUG_ASSERT(rli->curr_group_da.elements == 2); in get_slave_worker()
2832 dynamic_array_ptr(&rli->curr_group_da, in get_slave_worker()
2931 insert_dynamic(&rli->curr_group_da, (uchar*) &ptr_curr_ev); in get_slave_worker()
3096 if (rli->curr_group_da.elements > 0) in apply_event()
3134 for (uint k= 0; k < rli->curr_group_da.elements; k++) in apply_event()
3165 dynamic_array_ptr(&rli->curr_group_da, in apply_event()
3191 for (uint k= 0; k < rli->curr_group_da.elements; k++) in apply_event()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
| H A D | rpl_slave.cc | 4054 if (rli->curr_group_da.elements > 0) in apply_event_and_update_pos()
4060 for (uint i= 0; i < rli->curr_group_da.elements; i++) in apply_event_and_update_pos()
4073 if (rli->curr_group_da.elements > rli->curr_group_da.max_element) in apply_event_and_update_pos()
4076 rli->curr_group_da.elements= rli->curr_group_da.max_element; in apply_event_and_update_pos()
4077 rli->curr_group_da.max_element= 0; in apply_event_and_update_pos()
4078 freeze_size(&rli->curr_group_da); // restores max_element in apply_event_and_update_pos()
4080 rli->curr_group_da.elements= 0; in apply_event_and_update_pos()
6075 my_init_dynamic_array(&rli->curr_group_da, sizeof(Log_event*), 8, 2); in slave_start_workers()
6244 for (uint i= 0; i < rli->curr_group_da.elements; i++) in slave_stop_workers()
6245 delete *(Log_event**) dynamic_array_ptr(&rli->curr_group_da, i); in slave_stop_workers()
[all …]
|
| H A D | rpl_rli.h | 524 DYNAMIC_ARRAY curr_group_da; // deferred array to hold partition-info-free events variable
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
| H A D | rpl_slave.cc | 4054 if (rli->curr_group_da.elements > 0) in apply_event_and_update_pos()
4060 for (uint i= 0; i < rli->curr_group_da.elements; i++) in apply_event_and_update_pos()
4073 if (rli->curr_group_da.elements > rli->curr_group_da.max_element) in apply_event_and_update_pos()
4076 rli->curr_group_da.elements= rli->curr_group_da.max_element; in apply_event_and_update_pos()
4077 rli->curr_group_da.max_element= 0; in apply_event_and_update_pos()
4078 freeze_size(&rli->curr_group_da); // restores max_element in apply_event_and_update_pos()
4080 rli->curr_group_da.elements= 0; in apply_event_and_update_pos()
6075 my_init_dynamic_array(&rli->curr_group_da, sizeof(Log_event*), 8, 2); in slave_start_workers()
6244 for (uint i= 0; i < rli->curr_group_da.elements; i++) in slave_stop_workers()
6245 delete *(Log_event**) dynamic_array_ptr(&rli->curr_group_da, i); in slave_stop_workers()
[all …]
|
| H A D | rpl_rli.h | 524 DYNAMIC_ARRAY curr_group_da; // deferred array to hold partition-info-free events variable
|
| H A D | log_event.cc | 2775 insert_dynamic(&rli->curr_group_da, in get_slave_worker()
2778 DBUG_ASSERT(rli->curr_group_da.elements == 1); in get_slave_worker()
2798 insert_dynamic(&rli->curr_group_da, (uchar*) &ptr_curr_ev); in get_slave_worker()
2801 DBUG_ASSERT(rli->curr_group_da.elements == 2); in get_slave_worker()
2832 dynamic_array_ptr(&rli->curr_group_da, in get_slave_worker()
2931 insert_dynamic(&rli->curr_group_da, (uchar*) &ptr_curr_ev); in get_slave_worker()
3096 if (rli->curr_group_da.elements > 0) in apply_event()
3134 for (uint k= 0; k < rli->curr_group_da.elements; k++) in apply_event()
3165 dynamic_array_ptr(&rli->curr_group_da, in apply_event()
3191 for (uint k= 0; k < rli->curr_group_da.elements; k++) in apply_event()
[all …]
|
| /dports/databases/mysql56-client/mysql-5.6.51/sql/ |
| H A D | rpl_slave.cc | 3990 if (rli->curr_group_da.elements > 0) in apply_event_and_update_pos()
3996 for (uint i= 0; i < rli->curr_group_da.elements; i++) in apply_event_and_update_pos()
4009 if (rli->curr_group_da.elements > rli->curr_group_da.max_element) in apply_event_and_update_pos()
4012 rli->curr_group_da.elements= rli->curr_group_da.max_element; in apply_event_and_update_pos()
4013 rli->curr_group_da.max_element= 0; in apply_event_and_update_pos()
4014 freeze_size(&rli->curr_group_da); // restores max_element in apply_event_and_update_pos()
4016 rli->curr_group_da.elements= 0; in apply_event_and_update_pos()
5929 my_init_dynamic_array(&rli->curr_group_da, sizeof(Log_event*), 8, 2); in slave_start_workers()
6098 for (uint i= 0; i < rli->curr_group_da.elements; i++) in slave_stop_workers()
6099 delete *(Log_event**) dynamic_array_ptr(&rli->curr_group_da, i); in slave_stop_workers()
[all …]
|
| H A D | rpl_rli.h | 519 DYNAMIC_ARRAY curr_group_da; // deferred array to hold partition-info-free events variable
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
| H A D | rpl_slave.cc | 4122 if (rli->curr_group_da.elements > 0) in apply_event_and_update_pos()
4128 for (uint i= 0; i < rli->curr_group_da.elements; i++) in apply_event_and_update_pos()
4141 if (rli->curr_group_da.elements > rli->curr_group_da.max_element) in apply_event_and_update_pos()
4144 rli->curr_group_da.elements= rli->curr_group_da.max_element; in apply_event_and_update_pos()
4145 rli->curr_group_da.max_element= 0; in apply_event_and_update_pos()
4146 freeze_size(&rli->curr_group_da); // restores max_element in apply_event_and_update_pos()
4148 rli->curr_group_da.elements= 0; in apply_event_and_update_pos()
6071 my_init_dynamic_array(&rli->curr_group_da, sizeof(Log_event*), 8, 2); in slave_start_workers()
6240 for (uint i= 0; i < rli->curr_group_da.elements; i++) in slave_stop_workers()
6241 delete *(Log_event**) dynamic_array_ptr(&rli->curr_group_da, i); in slave_stop_workers()
[all …]
|
| H A D | rpl_rli.h | 519 DYNAMIC_ARRAY curr_group_da; // deferred array to hold partition-info-free events variable
|