diff options
Diffstat (limited to 'include/mysql/service_wsrep.h')
| -rw-r--r-- | include/mysql/service_wsrep.h | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/include/mysql/service_wsrep.h b/include/mysql/service_wsrep.h index 923ba57fcdc..f398ccad699 100644 --- a/include/mysql/service_wsrep.h +++ b/include/mysql/service_wsrep.h @@ -70,6 +70,7 @@ struct xid_t; struct wsrep; struct wsrep_ws_handle; struct wsrep_buf; +typedef struct wsrep_kill wsrep_kill_t; extern struct wsrep_service_st { struct wsrep * (*get_wsrep_func)(); @@ -114,7 +115,9 @@ extern struct wsrep_service_st { int (*wsrep_trx_order_before_func)(MYSQL_THD, MYSQL_THD); void (*wsrep_unlock_rollback_func)(); void (*wsrep_set_data_home_dir_func)(const char *data_dir); - my_bool (*wsrep_thd_is_applier_func)(MYSQL_THD); + my_bool (*wsrep_thd_is_applier_func)(MYSQL_THD thd); + bool (*wsrep_enqueue_background_kill_func)(wsrep_kill_t*); + wsrep_kill_t* (*wsrep_dequeue_background_kill_func)(); } *wsrep_service; #ifdef MYSQL_DYNAMIC_PLUGIN @@ -161,6 +164,8 @@ extern struct wsrep_service_st { #define wsrep_unlock_rollback() wsrep_service->wsrep_unlock_rollback_func() #define wsrep_set_data_home_dir(A) wsrep_service->wsrep_set_data_home_dir_func(A) #define wsrep_thd_is_applier(T) wsrep_service->wsrep_thd_is_applier_func(T) +#define wsrep_enqueue_background_kill(T) wsrep_service->wsrep_enqueue_background_kill_func(T); +#define wsrep_dequeue_background_kill() wsrep_service->wsrep_dequeue_background_kill_func(); #define wsrep_debug get_wsrep_debug() #define wsrep_log_conflicts get_wsrep_log_conflicts() @@ -223,6 +228,8 @@ bool wsrep_thd_ignore_table(THD *thd); void wsrep_unlock_rollback(); void wsrep_set_data_home_dir(const char *data_dir); my_bool wsrep_thd_is_applier(MYSQL_THD thd); +bool wsrep_enqueue_background_kill(wsrep_kill_t*); +wsrep_kill_t* wsrep_dequeue_background_kill(); #endif #ifdef __cplusplus |