diff options
Diffstat (limited to 'sql/log_event.h')
| -rw-r--r-- | sql/log_event.h | 17 |
1 files changed, 16 insertions, 1 deletions
diff --git a/sql/log_event.h b/sql/log_event.h index cccab93e0d5..19a77f03b84 100644 --- a/sql/log_event.h +++ b/sql/log_event.h @@ -284,6 +284,13 @@ struct sql_ex_info MAX_SIZE_LOG_EVENT_STATUS + /* status */ \ NAME_LEN + 1) +/* + The new option is added to handle large packets that are sent from the master + to the slave. It is used to increase the thd(max_allowed) for both the + DUMP thread on the master and the SQL/IO thread on the slave. +*/ +#define MAX_MAX_ALLOWED_PACKET 1024*1024*1024 + /* Event header offsets; these point to places inside the fixed header. @@ -2666,6 +2673,7 @@ public: bool is_null; uchar flags; #ifdef MYSQL_SERVER + bool deferred; User_var_log_event(THD* thd_arg, char *name_arg, uint name_len_arg, char *val_arg, ulong val_len_arg, Item_result type_arg, uint charset_number_arg, uchar flags_arg, @@ -2673,7 +2681,7 @@ public: :Log_event(thd_arg, 0, using_trans), name(name_arg), name_len(name_len_arg), val(val_arg), val_len(val_len_arg), type(type_arg), charset_number(charset_number_arg), - flags(flags_arg) + flags(flags_arg), deferred(false) { is_null= !val; if (direct) @@ -2690,6 +2698,13 @@ public: Log_event_type get_type_code() { return USER_VAR_EVENT;} #ifdef MYSQL_SERVER bool write(IO_CACHE* file); + /* + Getter and setter for deferred User-event. + Returns true if the event is not applied directly + and which case the applier adjusts execution path. + */ + bool is_deferred() { return deferred; } + void set_deferred() { deferred= val; } #endif bool is_valid() const { return 1; } |