ack_state(const Clone_Desc_State *state_desc) | Clone_Task_Manager | |
add_incomplete_chunk(Clone_Task *task) | Clone_Task_Manager | |
add_task(THD *thd, const byte *ref_loc, uint loc_len, uint &task_id) | Clone_Task_Manager | |
alloc_buffer(Clone_Task *task) | Clone_Task_Manager | |
change_state(Clone_Task *task, Clone_Desc_State *state_desc, Snapshot_State new_state, Clone_Alert_Func cbk, uint &num_wait) | Clone_Task_Manager | |
check_ack(const Clone_Desc_State *state_desc) | Clone_Task_Manager | inline |
check_state(Clone_Task *task, Snapshot_State new_state, bool exit_on_wait, int in_err, uint32_t &num_wait) | Clone_Task_Manager | |
debug_restart(Clone_Task *task, int in_err, int restart_count) | Clone_Task_Manager | |
debug_sync_check(uint32_t chunk_num, Clone_Task *task) | Clone_Task_Manager | |
debug_wait(uint chunk_num, Clone_Task *task) | Clone_Task_Manager | |
debug_wait_ddl_meta() | Clone_Task_Manager | |
drop_task(THD *thd, uint task_id, bool &is_master) | Clone_Task_Manager | |
find_master_task() | Clone_Task_Manager | |
finish_state(Clone_Task *task) | Clone_Task_Manager | |
get_mutex() | Clone_Task_Manager | inline |
get_next_chunk() | Clone_Task_Manager | private |
get_next_incomplete_chunk(uint32_t &block_num) | Clone_Task_Manager | private |
get_snapshot() | Clone_Task_Manager | inline |
get_state() | Clone_Task_Manager | inline |
get_task_by_index(uint index) | Clone_Task_Manager | inline |
handle_error_other_task(bool raise_error) | Clone_Task_Manager | |
in_transit_state() | Clone_Task_Manager | inline |
init(Clone_Snapshot *snapshot) | Clone_Task_Manager | |
init_state() | Clone_Task_Manager | |
is_chunk_reserved(uint32_t chunk_num) | Clone_Task_Manager | inline |
is_file_metadata_transferred() const | Clone_Task_Manager | inline |
is_network_error(int err) | Clone_Task_Manager | inlineprivate |
is_restart_metadata(Clone_Task *task) | Clone_Task_Manager | inline |
is_restarted() | Clone_Task_Manager | inline |
m_ack_state | Clone_Task_Manager | private |
m_chunk_info | Clone_Task_Manager | private |
m_clone_snapshot | Clone_Task_Manager | private |
m_clone_tasks | Clone_Task_Manager | private |
m_current_state | Clone_Task_Manager | private |
m_err_file_name | Clone_Task_Manager | private |
m_next_state | Clone_Task_Manager | private |
m_num_tasks | Clone_Task_Manager | private |
m_num_tasks_finished | Clone_Task_Manager | private |
m_num_tasks_transit | Clone_Task_Manager | private |
m_restart_count | Clone_Task_Manager | private |
m_saved_error | Clone_Task_Manager | private |
m_send_state_meta | Clone_Task_Manager | private |
m_state_mutex | Clone_Task_Manager | private |
m_transferred_file_meta | Clone_Task_Manager | private |
process_inclomplete_chunk() | Clone_Task_Manager | inlineprivate |
reinit_apply_state(const byte *ref_loc, uint ref_len, byte *&new_loc, uint &new_len, uint &alloc_len) | Clone_Task_Manager | |
reinit_copy_state(const byte *loc, uint loc_len) | Clone_Task_Manager | |
reserve_next_chunk(Clone_Task *task, uint32_t &ret_chunk, uint32_t &ret_block) | Clone_Task_Manager | |
reserve_task(THD *thd, uint &task_id) | Clone_Task_Manager | private |
reset_chunk(Clone_Task *task) | Clone_Task_Manager | inline |
reset_error() | Clone_Task_Manager | inline |
reset_transition() | Clone_Task_Manager | inline |
set_chunk(Clone_Task *task, Clone_Task_Meta *new_meta) | Clone_Task_Manager | |
set_error(int err, const char *file_name) | Clone_Task_Manager | inline |
set_file_meta_transferred() | Clone_Task_Manager | inline |
wait_ack(Clone_Handle *clone, Clone_Task *task, Ha_clone_cbk *callback) | Clone_Task_Manager | |
wait_before_add(const byte *ref_loc, uint loc_len) | Clone_Task_Manager | private |