diff options
Diffstat (limited to 'sql/wsrep_applier.h')
| -rw-r--r-- | sql/wsrep_applier.h | 37 |
1 files changed, 4 insertions, 33 deletions
diff --git a/sql/wsrep_applier.h b/sql/wsrep_applier.h index 70361987cc7..fefca306a70 100644 --- a/sql/wsrep_applier.h +++ b/sql/wsrep_applier.h @@ -1,4 +1,4 @@ -/* Copyright 2013-2015 Codership Oy <http://www.codership.com> +/* Copyright 2013-2019 Codership Oy <http://www.codership.com> This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -16,16 +16,15 @@ #ifndef WSREP_APPLIER_H #define WSREP_APPLIER_H -#include <my_config.h> - #include "sql_class.h" // THD class +#include "rpl_rli.h" // Relay_log_info +#include "log_event.h" // Format_description_log_event int wsrep_apply_events(THD* thd, Relay_log_info* rli, const void* events_buf, size_t buf_len); - /* Applier error codes, when nothing better is available. */ #define WSREP_RET_SUCCESS 0 // Success #define WSREP_ERR_GENERIC 1 // When in doubt (MySQL default error code) @@ -36,38 +35,10 @@ int wsrep_apply_events(THD* thd, #define WSREP_ERR_FAILED 6 // Operation failed for some internal reason #define WSREP_ERR_ABORTED 7 // Operation was aborted externally -class wsrep_apply_error -{ -public: - wsrep_apply_error() : str_(NULL), len_(0) {}; - ~wsrep_apply_error() { ::free(str_); } - /* stores the current THD error info from the diagnostic area. Works only - * once, subsequent invocations are ignored in order to preserve the original - * condition. */ - void store(const THD* thd); - const char* c_str() const { return str_; } - size_t length() const { return len_; } - bool is_null() const { return (c_str() == NULL && length() == 0); } - wsrep_buf_t get_buf() const - { - wsrep_buf_t ret= { c_str(), length() }; - return ret; - } -private: - char* str_; - size_t len_; -}; +void wsrep_store_error(const THD* thd, wsrep::mutable_buffer& buf); class Format_description_log_event; void wsrep_set_apply_format(THD*, Format_description_log_event*); Format_description_log_event* wsrep_get_apply_format(THD* thd); -int wsrep_apply(void* ctx, - uint32_t flags, - const wsrep_buf_t* buf, - const wsrep_trx_meta_t* meta, - wsrep_apply_error& err); - -wsrep_cb_status_t wsrep_unordered_cb(void* ctx, - const wsrep_buf_t* data); #endif /* WSREP_APPLIER_H */ |