Home
last modified time | relevance | path

Searched refs:CHANNEL_RECEIVER_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.cc132 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
179 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
191 return(channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
196 return(channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
313 CHANNEL_RECEIVER_THREAD, in is_own_event_receiver()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc127 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
174 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
186 return(channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
191 return(channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
308 CHANNEL_RECEIVER_THREAD, in is_own_event_receiver()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc132 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
179 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
191 return(channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
196 return(channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
313 CHANNEL_RECEIVER_THREAD, in is_own_event_receiver()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc132 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
179 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
191 return(channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
196 return(channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
313 CHANNEL_RECEIVER_THREAD, in is_own_event_receiver()
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc132 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
179 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
191 return(channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
196 return(channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
313 CHANNEL_RECEIVER_THREAD, in is_own_event_receiver()
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/src/
H A Dreplication_threads_api.cc132 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
179 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
191 return(channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
196 return(channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
313 CHANNEL_RECEIVER_THREAD, in is_own_event_receiver()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/src/
H A Dreplication_threads_api.cc123 thread_mask |= CHANNEL_RECEIVER_THREAD; in start_threads()
162 thread_mask |= CHANNEL_RECEIVER_THREAD; in stop_threads()
171 return (channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_running()
175 return (channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD)); in is_receiver_thread_stopping()
285 interface_channel, CHANNEL_RECEIVER_THREAD, &thread_id); in is_own_event_receiver()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/plugin/replication_observers_example/
H A Dreplication_observers_example.cc823 bool running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
829 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_io_thread()
854 running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
886 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_io_stopping()
909 bool io_stopping= channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
913 bool io_running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
965 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_sql_stopping()
/dports/databases/percona57-server/percona-server-5.7.36-39/plugin/replication_observers_example/
H A Dreplication_observers_example.cc823 bool running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
829 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_io_thread()
854 running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
886 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_io_stopping()
909 bool io_stopping= channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
913 bool io_running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
965 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_sql_stopping()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/plugin/replication_observers_example/
H A Dreplication_observers_example.cc823 bool running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
829 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_io_thread()
854 running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
886 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_io_stopping()
909 bool io_stopping= channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
913 bool io_running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
965 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_sql_stopping()
/dports/databases/percona57-client/percona-server-5.7.36-39/plugin/replication_observers_example/
H A Dreplication_observers_example.cc823 bool running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
829 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_io_thread()
854 running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
886 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_io_stopping()
909 bool io_stopping= channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
913 bool io_running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
965 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_sql_stopping()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/plugin/replication_observers_example/
H A Dreplication_observers_example.cc823 bool running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
829 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_io_thread()
854 running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
886 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_io_stopping()
909 bool io_stopping= channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
913 bool io_running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
965 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_sql_stopping()
/dports/databases/mysql57-client/mysql-5.7.36/plugin/replication_observers_example/
H A Dreplication_observers_example.cc823 bool running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
829 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_io_thread()
854 running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
886 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_io_stopping()
909 bool io_stopping= channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
913 bool io_running= channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
965 CHANNEL_RECEIVER_THREAD, in test_channel_service_interface_is_sql_stopping()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/replication_observers_example/
H A Dreplication_observers_example.cc804 bool running = channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
810 CHANNEL_RECEIVER_THREAD, &thread_id); in test_channel_service_interface_io_thread()
832 running = channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_io_thread()
862 CHANNEL_RECEIVER_THREAD, true); in test_channel_service_interface_is_io_stopping()
884 channel_is_stopping(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
889 channel_is_active(interface_channel, CHANNEL_RECEIVER_THREAD); in test_channel_service_interface_is_io_stopping()
936 CHANNEL_RECEIVER_THREAD, true); in test_channel_service_interface_is_sql_stopping()
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Drpl_channel_service_interface.cc393 if (threads_to_start & CHANNEL_RECEIVER_THREAD) in channel_start()
505 if ((threads_to_stop & CHANNEL_RECEIVER_THREAD) in channel_stop()
641 case CHANNEL_RECEIVER_THREAD: in channel_is_active()
671 case CHANNEL_RECEIVER_THREAD: in channel_get_thread_id()
1022 case CHANNEL_RECEIVER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h120 CHANNEL_RECEIVER_THREAD=1, enumerator
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Drpl_channel_service_interface.cc393 if (threads_to_start & CHANNEL_RECEIVER_THREAD) in channel_start()
505 if ((threads_to_stop & CHANNEL_RECEIVER_THREAD) in channel_stop()
641 case CHANNEL_RECEIVER_THREAD: in channel_is_active()
671 case CHANNEL_RECEIVER_THREAD: in channel_get_thread_id()
1022 case CHANNEL_RECEIVER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h120 CHANNEL_RECEIVER_THREAD=1, enumerator
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Drpl_channel_service_interface.cc393 if (threads_to_start & CHANNEL_RECEIVER_THREAD) in channel_start()
505 if ((threads_to_stop & CHANNEL_RECEIVER_THREAD) in channel_stop()
641 case CHANNEL_RECEIVER_THREAD: in channel_is_active()
671 case CHANNEL_RECEIVER_THREAD: in channel_get_thread_id()
1022 case CHANNEL_RECEIVER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h120 CHANNEL_RECEIVER_THREAD=1, enumerator
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Drpl_channel_service_interface.cc393 if (threads_to_start & CHANNEL_RECEIVER_THREAD) in channel_start()
505 if ((threads_to_stop & CHANNEL_RECEIVER_THREAD) in channel_stop()
641 case CHANNEL_RECEIVER_THREAD: in channel_is_active()
671 case CHANNEL_RECEIVER_THREAD: in channel_get_thread_id()
1022 case CHANNEL_RECEIVER_THREAD: in channel_is_stopping()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Drpl_channel_service_interface.cc387 if (threads_to_start & CHANNEL_RECEIVER_THREAD) in channel_start()
499 if ((threads_to_stop & CHANNEL_RECEIVER_THREAD) in channel_stop()
635 case CHANNEL_RECEIVER_THREAD: in channel_is_active()
665 case CHANNEL_RECEIVER_THREAD: in channel_get_thread_id()
1016 case CHANNEL_RECEIVER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h118 CHANNEL_RECEIVER_THREAD=1, enumerator
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Drpl_channel_service_interface.cc393 if (threads_to_start & CHANNEL_RECEIVER_THREAD) in channel_start()
505 if ((threads_to_stop & CHANNEL_RECEIVER_THREAD) in channel_stop()
641 case CHANNEL_RECEIVER_THREAD: in channel_is_active()
671 case CHANNEL_RECEIVER_THREAD: in channel_get_thread_id()
1022 case CHANNEL_RECEIVER_THREAD: in channel_is_stopping()
H A Drpl_channel_service_interface.h120 CHANNEL_RECEIVER_THREAD=1, enumerator

123