Lines Matching refs:recovery_node
48 … *conn, BackendInfo * main_backend, BackendInfo * recovery_backend, char stage, int recovery_node);
63 start_recovery(int recovery_node) in start_recovery() argument
74 (errmsg("starting recovering node %d", recovery_node))); in start_recovery()
76 if ((recovery_node < 0) || (recovery_node >= pool_config->backend_desc->num_backends)) in start_recovery()
78 (errmsg("node recovery failed, node id: %d is not valid", recovery_node))); in start_recovery()
80 if (*(my_backend_status[(recovery_node)]) == CON_UNUSED) in start_recovery()
82 (errmsg("node recovery failed, node id: %d is unused", recovery_node))); in start_recovery()
84 if (VALID_BACKEND(recovery_node)) in start_recovery()
86 (errmsg("node recovery failed, node id: %d is alive", recovery_node))); in start_recovery()
93 recovery_backend = &pool_config->backend_desc->backend_info[recovery_node]; in start_recovery()
110 exec_recovery(conn, backend, recovery_backend, FIRST_STAGE, recovery_node); in start_recovery()
143 exec_recovery(conn, backend, recovery_backend, SECOND_STAGE, recovery_node); in start_recovery()
151 (errmsg("node recovery, node: %d restarted", recovery_node))); in start_recovery()
160 send_failback_request(recovery_node, false, REQ_DETAIL_CONFIRMED); in start_recovery()
240 …n *conn, BackendInfo * main_backend, BackendInfo * recovery_backend, char stage, int recovery_node) in exec_recovery() argument
276 recovery_node, in exec_recovery()