database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-11-06 16:09:29 +03:00
Code Activity

MCOL-2001 Make the parameters for redistribute case insensitive

Browse Source
This commit is contained in:
David Hall
2019-01-23 10:29:12 -06:00
parent d87b9a6084
commit 098e49bd01
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
oamapps/mcsadmin/mcsadmin.cpp
View File

@@ -32,6 +32,7 @@ extern int h_errno;
#include "boost/filesystem/path.hpp" #include "boost/filesystem/path.hpp"
#include "boost/scoped_ptr.hpp" #include "boost/scoped_ptr.hpp"
#include "boost/tokenizer.hpp" #include "boost/tokenizer.hpp"
#include "boost/algorithm/string/predicate.hpp"
#include "sessionmanager.h" #include "sessionmanager.h"
#include "dbrm.h" #include "dbrm.h"
#include "messagequeue.h" #include "messagequeue.h"
@@ -677,7 +678,7 @@ int processCommand(string* arguments)
vector<uint32_t> srcDbroots; // all of the currently configured dbroots vector<uint32_t> srcDbroots; // all of the currently configured dbroots
vector<uint32_t> destDbroots; // srcDbroots - removeDbroots vector<uint32_t> destDbroots; // srcDbroots - removeDbroots
set<int>::iterator dbiter; set<int>::iterator dbiter;
if (arguments[1] == "start") if (boost::iequals(arguments[1], "start"))
{ {
// Get a list of all the configured dbroots in the xml file. // Get a list of all the configured dbroots in the xml file.
DBRootConfigList dbRootConfigList; DBRootConfigList dbRootConfigList;
@@ -688,7 +689,7 @@ int processCommand(string* arguments)
// The user may choose to redistribute in such a way as to // The user may choose to redistribute in such a way as to
// leave certain dbroots empty, presumably for later removal. // leave certain dbroots empty, presumably for later removal.
if (arguments[2] == "remove") if (boost::iequals(arguments[2], "remove"))
{ {
int dbroot; int dbroot;
bool error = false; bool error = false;
@@ -792,7 +793,7 @@ int processCommand(string* arguments)
SendToWES(oam, bs); SendToWES(oam, bs);
} }
else if (arguments[1] == "stop") else if (boost::iequals(arguments[1], "stop"))
{ {
ByteStream bs; ByteStream bs;
// message WES ID, sequence #, action id // message WES ID, sequence #, action id
@@ -802,7 +803,7 @@ int processCommand(string* arguments)
bs.append((const ByteStream::byte*) &header, sizeof(header)); bs.append((const ByteStream::byte*) &header, sizeof(header));
SendToWES(oam, bs); SendToWES(oam, bs);
} }
else if (arguments[1] == "status") else if (boost::iequals(arguments[1], "status"))
{ {
ByteStream bs; ByteStream bs;
// message WES ID, sequence #, action id // message WES ID, sequence #, action id