Home
last modified time | relevance | path

Searched refs:CHANNEL_APPLIER_THREAD (Results 1 – 25 of 55) sorted by relevance

123

/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc128 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
175 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
201 return(channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
206 return(channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
256 CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
271 CHANNEL_APPLIER_THREAD, in is_own_event_applier()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc123 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
170 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
196 return(channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
201 return(channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
251 CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
266 CHANNEL_APPLIER_THREAD, in is_own_event_applier()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc128 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
175 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
201 return(channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
206 return(channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
256 CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
271 CHANNEL_APPLIER_THREAD, in is_own_event_applier()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc128 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
175 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
201 return(channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
206 return(channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
256 CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
271 CHANNEL_APPLIER_THREAD, in is_own_event_applier()
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc128 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
175 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
201 return(channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
206 return(channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
256 CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
271 CHANNEL_APPLIER_THREAD, in is_own_event_applier()
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc128 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
175 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
201 return(channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
206 return(channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
256 CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
271 CHANNEL_APPLIER_THREAD, in is_own_event_applier()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/src/
H A Dreplication_threads_api.cc120 thread_mask |= CHANNEL_APPLIER_THREAD; in start_threads()
159 thread_mask |= CHANNEL_APPLIER_THREAD; in stop_threads()
179 return (channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_running()
183 return (channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD)); in is_applier_thread_stopping()
234 return channel_get_thread_id(interface_channel, CHANNEL_APPLIER_THREAD, in get_applier_thread_ids()
248 channel_get_thread_id(name, CHANNEL_APPLIER_THREAD, &thread_ids); in is_own_event_applier()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/plugin/replication_observers_example/
H A Dreplication_observers_example.cc697 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
702 bool running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
723 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
745 running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
774 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
781 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
972 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_is_sql_stopping()
991 bool sql_stopping= channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
995 bool sql_running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1047 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_relay_log_renamed()
/dports/databases/percona57-server/percona-server-5.7.36-39/plugin/replication_observers_example/
H A Dreplication_observers_example.cc697 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
702 bool running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
723 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
745 running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
774 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
781 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
972 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_is_sql_stopping()
991 bool sql_stopping= channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
995 bool sql_running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1047 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_relay_log_renamed()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/plugin/replication_observers_example/
H A Dreplication_observers_example.cc697 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
702 bool running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
723 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
745 running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
774 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
781 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
972 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_is_sql_stopping()
991 bool sql_stopping= channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
995 bool sql_running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1047 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_relay_log_renamed()
/dports/databases/percona57-client/percona-server-5.7.36-39/plugin/replication_observers_example/
H A Dreplication_observers_example.cc697 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
702 bool running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
723 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
745 running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
774 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
781 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
972 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_is_sql_stopping()
991 bool sql_stopping= channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
995 bool sql_running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1047 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_relay_log_renamed()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/plugin/replication_observers_example/
H A Dreplication_observers_example.cc697 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
702 bool running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
723 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
745 running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
774 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
781 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
972 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_is_sql_stopping()
991 bool sql_stopping= channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
995 bool sql_running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1047 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_relay_log_renamed()
/dports/databases/mysql57-client/mysql-5.7.36/plugin/replication_observers_example/
H A Dreplication_observers_example.cc697 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
702 bool running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
723 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
745 running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
774 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
781 CHANNEL_APPLIER_THREAD, in test_channel_service_interface()
972 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_is_sql_stopping()
991 bool sql_stopping= channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
995 bool sql_running= channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1047 CHANNEL_APPLIER_THREAD, in test_channel_service_interface_relay_log_renamed()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/replication_observers_example/
H A Dreplication_observers_example.cc671 CHANNEL_APPLIER_THREAD, true); in test_channel_service_interface()
675 bool running = channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
696 channel_get_thread_id(interface_channel, CHANNEL_APPLIER_THREAD, &applier_id); in test_channel_service_interface()
713 running = channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface()
741 CHANNEL_APPLIER_THREAD, true); in test_channel_service_interface()
747 CHANNEL_APPLIER_THREAD, &applier_id); in test_channel_service_interface()
941 CHANNEL_APPLIER_THREAD, true); in test_channel_service_interface_is_sql_stopping()
959 channel_is_stopping(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
964 channel_is_active(interface_channel, CHANNEL_APPLIER_THREAD); in test_channel_service_interface_is_sql_stopping()
1011 CHANNEL_APPLIER_THREAD, true); in test_channel_service_interface_relay_log_renamed()
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Drpl_channel_service_interface.cc389 if (threads_to_start & CHANNEL_APPLIER_THREAD) in channel_start()
500 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) in channel_stop()
643 case CHANNEL_APPLIER_THREAD: in channel_is_active()
683 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
890 CHANNEL_APPLIER_THREAD, in channel_is_applier_waiting()
1025 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h121 CHANNEL_APPLIER_THREAD=2 enumerator
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Drpl_channel_service_interface.cc389 if (threads_to_start & CHANNEL_APPLIER_THREAD) in channel_start()
500 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) in channel_stop()
643 case CHANNEL_APPLIER_THREAD: in channel_is_active()
683 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
890 CHANNEL_APPLIER_THREAD, in channel_is_applier_waiting()
1025 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h121 CHANNEL_APPLIER_THREAD=2 enumerator
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Drpl_channel_service_interface.cc389 if (threads_to_start & CHANNEL_APPLIER_THREAD) in channel_start()
500 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) in channel_stop()
643 case CHANNEL_APPLIER_THREAD: in channel_is_active()
683 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
890 CHANNEL_APPLIER_THREAD, in channel_is_applier_waiting()
1025 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Drpl_channel_service_interface.cc389 if (threads_to_start & CHANNEL_APPLIER_THREAD) in channel_start()
500 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) in channel_stop()
643 case CHANNEL_APPLIER_THREAD: in channel_is_active()
683 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
890 CHANNEL_APPLIER_THREAD, in channel_is_applier_waiting()
1025 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Drpl_channel_service_interface.cc383 if (threads_to_start & CHANNEL_APPLIER_THREAD) in channel_start()
494 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) in channel_stop()
637 case CHANNEL_APPLIER_THREAD: in channel_is_active()
677 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
884 CHANNEL_APPLIER_THREAD, in channel_is_applier_waiting()
1019 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h119 CHANNEL_APPLIER_THREAD=2 enumerator
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Drpl_channel_service_interface.cc389 if (threads_to_start & CHANNEL_APPLIER_THREAD) in channel_start()
500 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) in channel_stop()
643 case CHANNEL_APPLIER_THREAD: in channel_is_active()
683 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
890 CHANNEL_APPLIER_THREAD, in channel_is_applier_waiting()
1025 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h121 CHANNEL_APPLIER_THREAD=2 enumerator
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Drpl_channel_service_interface.cc422 if (threads_to_start & CHANNEL_APPLIER_THREAD) { in channel_start()
525 if ((threads_to_stop & CHANNEL_APPLIER_THREAD) && in channel_stop()
688 case CHANNEL_APPLIER_THREAD: in channel_is_active()
723 case CHANNEL_APPLIER_THREAD: in channel_get_thread_id()
947 channel_get_thread_id(channel, CHANNEL_APPLIER_THREAD, &thread_ids); in channel_is_applier_waiting()
1098 case CHANNEL_APPLIER_THREAD: in channel_is_stopping()

123