/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_base.c | 1011 task_new(generator_task, null_arg, "generator_task", XCOM_THREAD_DEBUG); in taskmain() 1012 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in taskmain() 1035 set_task(&sweeper, task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1037 set_task(&alive_t, task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1059 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain() 1060 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain() 1132 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1133 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 2269 task_new(terminator_task, double_arg(t), "terminator_task", XCOM_THREAD_DEBUG); in delayed_terminate_and_exit() 4389 task_new(client_task, void_arg(e), "client_task", XCOM_THREAD_DEBUG); in send_client_app_data() [all …]
|
H A D | xcom_base.h | 36 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_transport.c | 766 s->sender = task_new(local_sender_task, void_arg(s), "local_sender_task", XCOM_THREAD_DEBUG); in mksrv() 768 s->sender = task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 770 …reply_handler = task_new(reply_handler_task, void_arg(s), "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 964 XCOM_THREAD_DEBUG); in tcp_server()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_base.c | 1011 task_new(generator_task, null_arg, "generator_task", XCOM_THREAD_DEBUG); in taskmain() 1012 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in taskmain() 1035 set_task(&sweeper, task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1037 set_task(&alive_t, task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1059 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain() 1060 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain() 1132 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1133 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 2269 task_new(terminator_task, double_arg(t), "terminator_task", XCOM_THREAD_DEBUG); in delayed_terminate_and_exit() 4389 task_new(client_task, void_arg(e), "client_task", XCOM_THREAD_DEBUG); in send_client_app_data() [all …]
|
H A D | xcom_base.h | 36 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_transport.c | 750 s->sender = task_new(local_sender_task, void_arg(s), "local_sender_task", XCOM_THREAD_DEBUG); in mksrv() 752 s->sender = task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 754 …reply_handler = task_new(reply_handler_task, void_arg(s), "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 948 XCOM_THREAD_DEBUG); in tcp_server()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_base.c | 1011 task_new(generator_task, null_arg, "generator_task", XCOM_THREAD_DEBUG); in taskmain() 1012 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in taskmain() 1035 set_task(&sweeper, task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1037 set_task(&alive_t, task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1059 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain() 1060 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain() 1132 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1133 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 2269 task_new(terminator_task, double_arg(t), "terminator_task", XCOM_THREAD_DEBUG); in delayed_terminate_and_exit() 4389 task_new(client_task, void_arg(e), "client_task", XCOM_THREAD_DEBUG); in send_client_app_data() [all …]
|
H A D | xcom_base.h | 36 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_transport.c | 766 s->sender = task_new(local_sender_task, void_arg(s), "local_sender_task", XCOM_THREAD_DEBUG); in mksrv() 768 s->sender = task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 770 …reply_handler = task_new(reply_handler_task, void_arg(s), "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 964 XCOM_THREAD_DEBUG); in tcp_server()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_base.c | 1011 task_new(generator_task, null_arg, "generator_task", XCOM_THREAD_DEBUG); in taskmain() 1012 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in taskmain() 1035 set_task(&sweeper, task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1037 set_task(&alive_t, task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1059 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain() 1060 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain() 1132 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1133 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 2269 task_new(terminator_task, double_arg(t), "terminator_task", XCOM_THREAD_DEBUG); in delayed_terminate_and_exit() 4389 task_new(client_task, void_arg(e), "client_task", XCOM_THREAD_DEBUG); in send_client_app_data() [all …]
|
H A D | xcom_base.h | 36 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_transport.c | 750 s->sender = task_new(local_sender_task, void_arg(s), "local_sender_task", XCOM_THREAD_DEBUG); in mksrv() 752 s->sender = task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 754 …reply_handler = task_new(reply_handler_task, void_arg(s), "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 948 XCOM_THREAD_DEBUG); in tcp_server()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_base.c | 1011 task_new(generator_task, null_arg, "generator_task", XCOM_THREAD_DEBUG); in taskmain() 1012 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in taskmain() 1035 set_task(&sweeper, task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1037 set_task(&alive_t, task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1059 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain() 1060 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain() 1132 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1133 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 2269 task_new(terminator_task, double_arg(t), "terminator_task", XCOM_THREAD_DEBUG); in delayed_terminate_and_exit() 4389 task_new(client_task, void_arg(e), "client_task", XCOM_THREAD_DEBUG); in send_client_app_data() [all …]
|
H A D | xcom_base.h | 36 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_transport.c | 766 s->sender = task_new(local_sender_task, void_arg(s), "local_sender_task", XCOM_THREAD_DEBUG); in mksrv() 768 s->sender = task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 770 …reply_handler = task_new(reply_handler_task, void_arg(s), "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 964 XCOM_THREAD_DEBUG); in tcp_server()
|
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_base.c | 1011 task_new(generator_task, null_arg, "generator_task", XCOM_THREAD_DEBUG); in taskmain() 1012 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in taskmain() 1035 set_task(&sweeper, task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1037 set_task(&alive_t, task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in start_run_tasks() 1059 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain() 1060 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain() 1132 task_new(tcp_server, int_arg(fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1133 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 2269 task_new(terminator_task, double_arg(t), "terminator_task", XCOM_THREAD_DEBUG); in delayed_terminate_and_exit() 4389 task_new(client_task, void_arg(e), "client_task", XCOM_THREAD_DEBUG); in send_client_app_data() [all …]
|
H A D | xcom_base.h | 36 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_transport.c | 750 s->sender = task_new(local_sender_task, void_arg(s), "local_sender_task", XCOM_THREAD_DEBUG); in mksrv() 752 s->sender = task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 754 …reply_handler = task_new(reply_handler_task, void_arg(s), "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 948 XCOM_THREAD_DEBUG); in tcp_server()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
H A D | xcom_transport.cc | 576 XCOM_THREAD_DEBUG); in mksrv() 579 task_new(sender_task, void_arg(s), "sender_task", XCOM_THREAD_DEBUG); in mksrv() 583 "reply_handler_task", XCOM_THREAD_DEBUG); in mksrv() 753 XCOM_THREAD_DEBUG); in tcp_server()
|
H A D | xcom_base.h | 44 #define XCOM_THREAD_DEBUG 1 macro
|
H A D | xcom_base.cc | 917 XCOM_THREAD_DEBUG)); in create_proposers() 1270 task_new(tcp_server, int_arg(tcp_fd.val), "tcp_server", XCOM_THREAD_DEBUG); in xcom_taskmain2() 1271 task_new(tcp_reaper_task, null_arg, "tcp_reaper_task", XCOM_THREAD_DEBUG); in xcom_taskmain2() 5240 XCOM_THREAD_DEBUG); in acceptor_learner_task() 5768 XCOM_THREAD_DEBUG)); in start_x_timer() 5796 XCOM_THREAD_DEBUG); in send_x_fsm_complete() 6245 XCOM_THREAD_DEBUG)); in xcom_fsm_run_enter() 6247 task_new(sweeper_task, null_arg, "sweeper_task", XCOM_THREAD_DEBUG)); in xcom_fsm_run_enter() 6249 XCOM_THREAD_DEBUG)); in xcom_fsm_run_enter() 6251 task_new(alive_task, null_arg, "alive_task", XCOM_THREAD_DEBUG)); in xcom_fsm_run_enter() [all …]
|