summaryrefslogtreecommitdiff
path: root/sql/log_event.cc
diff options
context:
space:
mode:
authorDavi Arnaut <Davi.Arnaut@Sun.COM>2010-06-28 17:59:41 -0300
committerDavi Arnaut <Davi.Arnaut@Sun.COM>2010-06-28 17:59:41 -0300
commit1b504ab0b133e81c4e1aec6b948341e885cadadd (patch)
tree1496d4c5a961584fa7eb53f2e3bb14728c515594 /sql/log_event.cc
parentaa1dddd5cae5f9e0e950d2bf765c2f08a7327a99 (diff)
downloadmariadb-git-1b504ab0b133e81c4e1aec6b948341e885cadadd.tar.gz
Revert Bug#48321 due to build breakage and failing tests.
Diffstat (limited to 'sql/log_event.cc')
-rw-r--r--sql/log_event.cc67
1 files changed, 1 insertions, 66 deletions
diff --git a/sql/log_event.cc b/sql/log_event.cc
index c5bbe324ae8..5ff4b50c6df 100644
--- a/sql/log_event.cc
+++ b/sql/log_event.cc
@@ -2307,53 +2307,6 @@ bool Query_log_event::write(IO_CACHE* file)
start+= 4;
}
- if (thd && thd->is_current_user_used())
- {
- LEX_STRING user;
- LEX_STRING host;
- bzero(&user, sizeof(user));
- bzero(&host, sizeof(host));
-
- if (thd->slave_thread)
- {
- /* user will be null, if master is older than this patch */
- user= thd->variables.current_user.user;
- host= thd->variables.current_user.host;
- }
- else if (thd->security_ctx->priv_user)
- {
- Security_context *ctx= thd->security_ctx;
-
- user.length= strlen(ctx->priv_user);
- user.str= ctx->priv_user;
- if (ctx->priv_host[0] != '\0')
- {
- host.str= ctx->priv_host;
- host.length= strlen(ctx->priv_host);
- }
- }
-
- if (user.length > 0)
- {
- *start++= Q_INVOKER;
-
- /*
- Store user length and user. The max length of use is 16, so 1 byte is
- enough to store the user's length.
- */
- *start++= (uchar)user.length;
- memcpy(start, user.str, user.length);
- start+= user.length;
-
- /*
- Store host length and host. The max length of host is 60, so 1 byte is
- enough to store the host's length.
- */
- *start++= (uchar)host.length;
- memcpy(start, host.str, host.length);
- start+= host.length;
- }
- }
/*
NOTE: When adding new status vars, please don't forget to update
the MAX_SIZE_LOG_EVENT_STATUS in log_event.h and update the function
@@ -2622,8 +2575,6 @@ Query_log_event::Query_log_event(const char* buf, uint event_len,
bool catalog_nz= 1;
DBUG_ENTER("Query_log_event::Query_log_event(char*,...)");
- bzero(&user, sizeof(user));
- bzero(&host, sizeof(host));
common_header_len= description_event->common_header_len;
post_header_len= description_event->post_header_len[event_type-1];
DBUG_PRINT("info",("event_len: %u common_header_len: %d post_header_len: %d",
@@ -2778,20 +2729,6 @@ Query_log_event::Query_log_event(const char* buf, uint event_len,
data_written= master_data_written= uint4korr(pos);
pos+= 4;
break;
- case Q_INVOKER:
- {
- CHECK_SPACE(pos, end, 1);
- user.length= *pos++;
- CHECK_SPACE(pos, end, user.length);
- user.str= my_strndup((const char *)pos, user.length, MYF(0));
- pos+= user.length;
-
- CHECK_SPACE(pos, end, 1);
- host.length= *pos++;
- CHECK_SPACE(pos, end, host.length);
- host.str= my_strndup((const char *)pos, host.length, MYF(0));
- pos+= host.length;
- }
default:
/* That's why you must write status vars in growing order of code */
DBUG_PRINT("info",("Query_log_event has unknown status vars (first has\
@@ -3241,9 +3178,7 @@ int Query_log_event::do_apply_event(Relay_log_info const *rli,
thd->variables.collation_database= thd->db_charset;
thd->table_map_for_update= (table_map)table_map_for_update;
- thd->variables.current_user.user= user;
- thd->variables.current_user.host= host;
- thd->variables.current_user.password= {0, 0};
+
/* Execute the query (note that we bypass dispatch_command()) */
const char* found_semicolon= NULL;
mysql_parse(thd, thd->query(), thd->query_length(), &found_semicolon);