You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2026-01-06 08:21:10 +03:00
MCOL-2001 make redistribute parameters case insensitive.
This commit is contained in:
@@ -32,7 +32,6 @@ extern int h_errno;
|
||||
#include "boost/filesystem/path.hpp"
|
||||
#include "boost/scoped_ptr.hpp"
|
||||
#include "boost/tokenizer.hpp"
|
||||
#include "boost/algorithm/string/predicate.hpp"
|
||||
#include "sessionmanager.h"
|
||||
#include "dbrm.h"
|
||||
#include "messagequeue.h"
|
||||
@@ -678,7 +677,11 @@ int processCommand(string* arguments)
|
||||
vector<uint32_t> srcDbroots; // all of the currently configured dbroots
|
||||
vector<uint32_t> destDbroots; // srcDbroots - removeDbroots
|
||||
set<int>::iterator dbiter;
|
||||
if (boost::iequals(arguments[1], "start"))
|
||||
#if _MSC_VER
|
||||
if (_strnicmp(arguments[1].c_str(), "start", 5) == 0))
|
||||
#else
|
||||
if (strncasecmp(arguments[1].c_str(), "start", 5) == 0)
|
||||
#endif
|
||||
{
|
||||
// Get a list of all the configured dbroots in the xml file.
|
||||
DBRootConfigList dbRootConfigList;
|
||||
@@ -689,7 +692,11 @@ int processCommand(string* arguments)
|
||||
|
||||
// The user may choose to redistribute in such a way as to
|
||||
// leave certain dbroots empty, presumably for later removal.
|
||||
if (boost::iequals(arguments[2], "remove"))
|
||||
#if _MSC_VER
|
||||
if (_strnicmp(arguments[1].c_str(), "remove", 6) == 0))
|
||||
#else
|
||||
if (strncasecmp(arguments[1].c_str(), "remove", 6) == 0)
|
||||
#endif
|
||||
{
|
||||
int dbroot;
|
||||
bool error = false;
|
||||
@@ -793,7 +800,11 @@ int processCommand(string* arguments)
|
||||
|
||||
SendToWES(oam, bs);
|
||||
}
|
||||
else if (boost::iequals(arguments[1], "stop"))
|
||||
#if _MSC_VER
|
||||
if (_strnicmp(arguments[1].c_str(), "stop", 4) == 0))
|
||||
#else
|
||||
if (strncasecmp(arguments[1].c_str(), "stop", 4) == 0)
|
||||
#endif
|
||||
{
|
||||
ByteStream bs;
|
||||
// message WES ID, sequence #, action id
|
||||
@@ -803,7 +814,11 @@ int processCommand(string* arguments)
|
||||
bs.append((const ByteStream::byte*) &header, sizeof(header));
|
||||
SendToWES(oam, bs);
|
||||
}
|
||||
else if (boost::iequals(arguments[1], "status"))
|
||||
#if _MSC_VER
|
||||
if (_strnicmp(arguments[1].c_str(), "status", 6) == 0))
|
||||
#else
|
||||
if (strncasecmp(arguments[1].c_str(), "status", 6) == 0)
|
||||
#endif
|
||||
{
|
||||
ByteStream bs;
|
||||
// message WES ID, sequence #, action id
|
||||
|
||||
Reference in New Issue
Block a user