32#ifndef CLONE_API_INCLUDE
33#define CLONE_API_INCLUDE
88 uint task_id,
int in_err);
101 const char *data_dir);
113 uint loc_len, uint task_id,
int in_err,
125 uint loc_len, uint task_id,
int in_err);
uint32_t space_id_t
Tablespace identifier.
Definition: api0api.h:50
Clone Notification handler.
Definition: clone0api.h:178
Clone_notify(Type type, space_id_t space, bool no_wait)
Constructor to initiate notification.
Definition: clone0api.cc:2491
space_id_t m_space_id
Tablespace ID for which notification is sent.
Definition: clone0api.h:253
void get_mesg(bool begin, std::string &mesg)
Get notification message for printing.
Definition: clone0api.cc:2624
Type m_type
Notification type.
Definition: clone0api.h:256
uint32_t m_blocked_state
Blocked clone state if clone is blocked.
Definition: clone0api.h:262
Type
Notification type.
Definition: clone0api.h:181
@ SPACE_ALTER_ENCRYPT_GENERAL
@ SPACE_ALTER_INPLACE_BULK
@ SPACE_ALTER_ENCRYPT_GENERAL_FLAGS
int get_error() const
Definition: clone0api.h:230
~Clone_notify()
Destructor to automatically end notification.
Definition: clone0api.cc:2594
Clone_notify & operator=(Clone_notify const &)=delete
Disable assignment.
Wait_at
Notification wait type set.
Definition: clone0api.h:240
int m_error
Saved error.
Definition: clone0api.h:265
Wait_at m_wait
Wait type set.
Definition: clone0api.h:259
bool failed() const
Definition: clone0api.h:227
Clone_notify(Clone_notify &)=delete
Disable copy construction.
Definition: handler.h:1017
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:35
void clone_remove_list_file(const char *file_name)
Remove one of the clone list files.
Definition: clone0api.cc:230
int clone_add_to_list_file(const char *list_file_name, const char *file_name)
Add file name to clone list file for future replacement or rollback.
Definition: clone0api.cc:235
int innodb_clone_apply_end(handlerton *hton, THD *thd, const byte *loc, uint loc_len, uint task_id, int in_err)
End apply to destination database.
Definition: clone0api.cc:980
bool clone_check_active()
Check if active clone is running.
Definition: clone0api.cc:1663
bool clone_check_recovery_crashpoint(bool is_cloned_db)
Debug function to check and crash during recovery.
Definition: clone0api.cc:1531
void clone_init_list_files()
Check and delete any old list files.
Definition: clone0api.cc:212
void clone_files_recovery(bool finished)
Change cloned file states during recovery.
Definition: clone0api.cc:1545
void clone_update_gtid_status(std::string >ids)
Update cloned GTIDs to recovery status file.
Definition: clone0api.cc:1422
int innodb_clone_apply_begin(handlerton *hton, THD *thd, const byte *&loc, uint &loc_len, uint &task_id, Ha_clone_mode mode, const char *data_dir)
Begin apply to destination database.
Definition: clone0api.cc:782
int innodb_clone_end(handlerton *hton, THD *thd, const byte *loc, uint loc_len, uint task_id, int in_err)
End copy from source database.
Definition: clone0api.cc:635
int innodb_clone_copy(handlerton *hton, THD *thd, const byte *loc, uint loc_len, uint task_id, Ha_clone_cbk *cbk)
Copy data from source database in chunks via callback.
Definition: clone0api.cc:548
void clone_free()
Uninitialize Clone system.
Definition: clone0api.cc:1649
int innodb_clone_begin(handlerton *hton, THD *thd, const byte *&loc, uint &loc_len, uint &task_id, Ha_clone_type type, Ha_clone_mode mode)
Begin copy from source database.
Definition: clone0api.cc:394
int innodb_clone_apply(handlerton *hton, THD *thd, const byte *loc, uint loc_len, uint task_id, int in_err, Ha_clone_cbk *cbk)
Apply data to destination database in chunks via callback.
Definition: clone0api.cc:948
void innodb_clone_get_capability(Ha_clone_flagset &flags)
Get capability flags for clone operation.
Definition: clone0api.cc:310
void clone_files_error()
Revert back clone changes in case of an error.
Definition: clone0api.cc:1495
bool fix_cloned_tables(THD *thd)
Fix cloned non-Innodb tables during recovery.
Definition: clone0api.cc:2239
bool clone_check_provisioning()
Definition: clone0api.cc:1661
dberr_t clone_init()
Initialize Clone system.
Definition: clone0api.cc:1629
int innodb_clone_ack(handlerton *hton, THD *thd, const byte *loc, uint loc_len, uint task_id, int in_err, Ha_clone_cbk *cbk)
Acknowledge data to source database.
Definition: clone0api.cc:567
dberr_t
Definition: db0err.h:38
static int flags[50]
Definition: hp_test1.cc:39
void * begin(THD *thd, const TABLE *table, size_t data_size, size_t memory, size_t num_threads) noexcept
Definition: bulk_data_service.cc:1533
std::string file_name(Log_file_id file_id)
Provides name of the log file with the given file id, e.g.
Definition: log0pre_8_0_30.cc:93
mode
Definition: file_handle.h:59
required string type
Definition: replication_group_member_actions.proto:33
Ha_clone_mode
Clone start operation mode.
Definition: handler.h:947
std::bitset< HA_CLONE_TYPE_MAX > Ha_clone_flagset
Definition: handler.h:989
Ha_clone_type
Clone operation types.
Definition: handler.h:965
handlerton is a singleton structure - one instance per storage engine - to provide access to storage ...
Definition: handler.h:2692
Version control for database, common definitions, and include files.
static int finished(pax_machine *p)
Definition: xcom_base.cc:731