Home
last modified time | relevance | path

Searched refs:exit_synode (Results 1 – 7 of 7) sorted by relevance

/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.c2473 synode_no exit_synode; in executor_task() local
2488 ep->exit_synode = null_synode; in executor_task()
2545 ep->exit_synode = decr_synode(site->start); in executor_task()
2547 delay_until = ep->exit_synode; in executor_task()
2554 ep->exit_synode = compute_delay(site->start); in executor_task()
2556 if (!synode_lt(ep->exit_synode, max_synode)){ in executor_task()
2558 set_max_synode(incr_synode(ep->exit_synode)); in executor_task()
2560 delay_until = ep->exit_synode; in executor_task()
2579 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
2592 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.c2473 synode_no exit_synode; in executor_task() local
2488 ep->exit_synode = null_synode; in executor_task()
2545 ep->exit_synode = decr_synode(site->start); in executor_task()
2547 delay_until = ep->exit_synode; in executor_task()
2554 ep->exit_synode = compute_delay(site->start); in executor_task()
2556 if (!synode_lt(ep->exit_synode, max_synode)){ in executor_task()
2558 set_max_synode(incr_synode(ep->exit_synode)); in executor_task()
2560 delay_until = ep->exit_synode; in executor_task()
2579 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
2592 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.c2473 synode_no exit_synode; in executor_task() local
2488 ep->exit_synode = null_synode; in executor_task()
2545 ep->exit_synode = decr_synode(site->start); in executor_task()
2547 delay_until = ep->exit_synode; in executor_task()
2554 ep->exit_synode = compute_delay(site->start); in executor_task()
2556 if (!synode_lt(ep->exit_synode, max_synode)){ in executor_task()
2558 set_max_synode(incr_synode(ep->exit_synode)); in executor_task()
2560 delay_until = ep->exit_synode; in executor_task()
2579 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
2592 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.c2473 synode_no exit_synode; in executor_task() local
2488 ep->exit_synode = null_synode; in executor_task()
2545 ep->exit_synode = decr_synode(site->start); in executor_task()
2547 delay_until = ep->exit_synode; in executor_task()
2554 ep->exit_synode = compute_delay(site->start); in executor_task()
2556 if (!synode_lt(ep->exit_synode, max_synode)){ in executor_task()
2558 set_max_synode(incr_synode(ep->exit_synode)); in executor_task()
2560 delay_until = ep->exit_synode; in executor_task()
2579 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
2592 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.c2473 synode_no exit_synode; in executor_task() local
2488 ep->exit_synode = null_synode; in executor_task()
2545 ep->exit_synode = decr_synode(site->start); in executor_task()
2547 delay_until = ep->exit_synode; in executor_task()
2554 ep->exit_synode = compute_delay(site->start); in executor_task()
2556 if (!synode_lt(ep->exit_synode, max_synode)){ in executor_task()
2558 set_max_synode(incr_synode(ep->exit_synode)); in executor_task()
2560 delay_until = ep->exit_synode; in executor_task()
2579 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
2592 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
[all …]
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.c2473 synode_no exit_synode; in executor_task() local
2488 ep->exit_synode = null_synode; in executor_task()
2545 ep->exit_synode = decr_synode(site->start); in executor_task()
2547 delay_until = ep->exit_synode; in executor_task()
2554 ep->exit_synode = compute_delay(site->start); in executor_task()
2556 if (!synode_lt(ep->exit_synode, max_synode)){ in executor_task()
2558 set_max_synode(incr_synode(ep->exit_synode)); in executor_task()
2560 delay_until = ep->exit_synode; in executor_task()
2579 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
2592 SYCEXP(ep->exit_synode); NDBG(ep->exit_type, d)); in executor_task()
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/
H A Dxcom_base.cc3066 synode_no exit_synode; member
3124 xc->exit_synode = compute_delay(site->start, site->event_horizon); in setup_exit_handling()
3134 if (!synode_lt(xc->exit_synode, max_synode)) { in setup_exit_handling()
3136 set_max_synode(incr_synode(xc->exit_synode)); in setup_exit_handling()
3139 delay_until = xc->exit_synode; in setup_exit_handling()
3143 IFDBG(D_EXEC, FN; SYCEXP(xc->exit_synode); SYCEXP(executed_msg); in setup_exit_handling()
3207 SYCEXP(xc->exit_synode); NDBG(xc->exit_flag, d)); in x_check_execute_inform()
3228 return (xc->exit_flag && !synode_lt(executed_msg, xc->exit_synode) && in x_check_exit()
3266 SYCEXP(executed_msg); SYCEXP(xc->exit_synode); NDBG(xc->exit_flag, d)); in x_execute()
3309 SYCEXP(fifo_front()); SYCEXP(xc->exit_synode); in dump_exec_state()
[all …]