Skip to content

Commit

Permalink
Merge branch '10.1' into 10.2
Browse files Browse the repository at this point in the history
  • Loading branch information
vuvova committed Oct 5, 2020
2 parents fbcae42 + f4c85ef commit a464917
Show file tree
Hide file tree
Showing 2 changed files with 47 additions and 6 deletions.
2 changes: 1 addition & 1 deletion VERSION
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
MYSQL_VERSION_MAJOR=10
MYSQL_VERSION_MINOR=2
MYSQL_VERSION_PATCH=33
MYSQL_VERSION_PATCH=34
51 changes: 46 additions & 5 deletions sql/wsrep_sst.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1723,24 +1723,65 @@ static int sst_donate_other (const char* method,
return arg.err;
}

/* return true if character can be a part of a filename */
static bool filename_char(int const c)
{
return isalnum(c) || (c == '-') || (c == '_') || (c == '.');
}

/* return true if character can be a part of an address string */
static bool address_char(int const c)
{
return filename_char(c) ||
(c == ':') || (c == '[') || (c == ']') || (c == '/');
}

static bool check_request_str(const char* const str,
bool (*check) (int c))
{
for (size_t i(0); str[i] != '\0'; ++i)
{
if (!check(str[i]))
{
WSREP_WARN("Illegal character in state transfer request: %i (%c).",
str[i], str[i]);
return true;
}
}

return false;
}

wsrep_cb_status_t wsrep_sst_donate_cb (void* app_ctx, void* recv_ctx,
const void* msg, size_t msg_len,
const wsrep_gtid_t* current_gtid,
const char* state, size_t state_len,
bool bypass)
{
/* This will be reset when sync callback is called.
* Should we set wsrep_ready to FALSE here too? */

wsrep_config_state->set(WSREP_MEMBER_DONOR);

const char* method = (char*)msg;
size_t method_len = strlen (method);

if (check_request_str(method, filename_char))
{
WSREP_ERROR("Bad SST method name. SST canceled.");
return WSREP_CB_FAILURE;
}

const char* data = method + method_len + 1;

if (check_request_str(data, address_char))
{
WSREP_ERROR("Bad SST address string. SST canceled.");
return WSREP_CB_FAILURE;
}

char uuid_str[37];
wsrep_uuid_print (&current_gtid->uuid, uuid_str, sizeof(uuid_str));

/* This will be reset when sync callback is called.
* Should we set wsrep_ready to FALSE here too? */
wsrep_config_state->set(WSREP_MEMBER_DONOR);

wsp::env env(NULL);
if (env.error())
{
Expand Down

0 comments on commit a464917

Please sign in to comment.