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

change the amazon failover code, add it back in

Browse Source
This commit is contained in:
david hill
2016-03-04 10:53:35 -06:00
parent cd622d9cf9
commit d50d30f513
2 changed files with 24 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
procmgr/main.cpp
View File

@@ -49,6 +49,7 @@ string cloud;
bool amazon = false; bool amazon = false;
string PMInstanceType; string PMInstanceType;
string UMInstanceType; string UMInstanceType;
string AmazonPMFailover = "y";
string GlusterConfig = "n"; string GlusterConfig = "n";
bool rootUser = true; bool rootUser = true;
string USER = "root"; string USER = "root";
@@ -143,6 +144,7 @@ int main(int argc, char **argv)
{ {
oam.getSystemConfig("PMInstanceType", PMInstanceType); oam.getSystemConfig("PMInstanceType", PMInstanceType);
oam.getSystemConfig("UMInstanceType", UMInstanceType); oam.getSystemConfig("UMInstanceType", UMInstanceType);
// oam.getSystemConfig("AmazonPMFailover", AmazonPMFailover);
amazon = true; amazon = true;
} }
@@ -1279,8 +1281,9 @@ void pingDeviceThread()
int status; int status;
// if pm, move dbroots back to pm // if pm, move dbroots back to pm
if ( ( moduleName.find("pm") == 0 ) || if ( ( moduleName.find("pm") == 0 && !amazon ) ||
( moduleName.find("pm") == 0 && downActiveOAMModule ) ) { ( moduleName.find("pm") == 0 && amazon && downActiveOAMModule ) ||
( moduleName.find("pm") == 0 && amazon && AmazonPMFailover == "y") ) {
//restart to get the versionbuffer files closed so it can be unmounted //restart to get the versionbuffer files closed so it can be unmounted
processManager.restartProcessType("WriteEngineServer", moduleName); processManager.restartProcessType("WriteEngineServer", moduleName);
@@ -1556,8 +1559,8 @@ void pingDeviceThread()
aManager.sendAlarmReport(moduleName.c_str(), MODULE_DOWN_AUTO, SET); aManager.sendAlarmReport(moduleName.c_str(), MODULE_DOWN_AUTO, SET);
// if pm, move dbroots back to pm // if pm, move dbroots back to pm
if ( ( moduleName.find("pm") == 0 ) || if ( ( moduleName.find("pm") == 0 && !amazon ) ||
( moduleName.find("pm") == 0 && downActiveOAMModule ) ) { ( moduleName.find("pm") == 0 && amazon && downActiveOAMModule ) ) {
//move dbroots to other modules //move dbroots to other modules
try { try {
log.writeLog(__LINE__, "Call autoMovePmDbroot", LOG_TYPE_DEBUG); log.writeLog(__LINE__, "Call autoMovePmDbroot", LOG_TYPE_DEBUG);
@@ -1590,9 +1593,9 @@ void pingDeviceThread()
log.writeLog(__LINE__, "Module failed to auto start: " + moduleName, LOG_TYPE_CRITICAL); log.writeLog(__LINE__, "Module failed to auto start: " + moduleName, LOG_TYPE_CRITICAL);
// if ( amazon ) if ( amazon )
// processManager.setSystemState(oam::FAILED); processManager.setSystemState(oam::FAILED);
// else else
processManager.setSystemState(oam::ACTIVE); processManager.setSystemState(oam::ACTIVE);
//set query system state ready //set query system state ready
@@ -1660,8 +1663,8 @@ void pingDeviceThread()
log.writeLog(__LINE__, "'dbrmctl reload' done", LOG_TYPE_DEBUG); log.writeLog(__LINE__, "'dbrmctl reload' done", LOG_TYPE_DEBUG);
// if pm, move dbroots to other pms // if pm, move dbroots to other pms
// if ( !amazon || if ( !amazon ||
// ( amazon ) ) { ( amazon && AmazonPMFailover == "y") ) {
if( moduleName.find("pm") == 0 ) { if( moduleName.find("pm") == 0 ) {
try { try {
log.writeLog(__LINE__, "Call autoMovePmDbroot", LOG_TYPE_DEBUG); log.writeLog(__LINE__, "Call autoMovePmDbroot", LOG_TYPE_DEBUG);
@@ -1680,7 +1683,7 @@ void pingDeviceThread()
log.writeLog(__LINE__, "EXCEPTION ERROR on autoMovePmDbroot: Caught unknown exception!", LOG_TYPE_ERROR); log.writeLog(__LINE__, "EXCEPTION ERROR on autoMovePmDbroot: Caught unknown exception!", LOG_TYPE_ERROR);
} }
} }
// } }
// if Cloud Instance // if Cloud Instance
// state = running, then instance is rebooting, monitor for recovery // state = running, then instance is rebooting, monitor for recovery

34
procmgr/processmanager.cpp
View File

@@ -53,6 +53,7 @@ extern string USER;
extern bool HDFS; extern bool HDFS;
extern string localHostName; extern string localHostName;
extern string PMwithUM; extern string PMwithUM;
extern string AmazonPMFailover;
typedef map<string, int> moduleList; typedef map<string, int> moduleList;
extern moduleList moduleInfoList; extern moduleList moduleInfoList;
@@ -4398,7 +4399,6 @@ int ProcessManager::addModule(oam::DeviceNetworkList devicenetworklist, std::str
string mysqldPackage; string mysqldPackage;
string calpontPackage1; string calpontPackage1;
string calpontPackage2; string calpontPackage2;
string version;
string systemID; string systemID;
string packageType = "rpm"; string packageType = "rpm";
@@ -4431,7 +4431,6 @@ int ProcessManager::addModule(oam::DeviceNetworkList devicenetworklist, std::str
homedir = p; homedir = p;
} }
version = systemsoftware.Version + "-" + systemsoftware.Release;
if ( packageType != "binary") { if ( packageType != "binary") {
string separator = "-"; string separator = "-";
if ( packageType == "deb" ) if ( packageType == "deb" )
@@ -5026,7 +5025,7 @@ int ProcessManager::addModule(oam::DeviceNetworkList devicenetworklist, std::str
if ( packageType != "binary" ) { if ( packageType != "binary" ) {
log.writeLog(__LINE__, "addModule - user_installer run for " + remoteModuleName, LOG_TYPE_DEBUG); log.writeLog(__LINE__, "addModule - user_installer run for " + remoteModuleName, LOG_TYPE_DEBUG);
string cmd = installDir + "/bin/user_installer.sh " + remoteModuleName + " " + remoteModuleIP + " " + password + " " + version + " initial " + packageType + " --nodeps none " + MySQLPort + " 1 > /tmp/user_installer.log"; string cmd = installDir + "/bin/user_installer.sh " + remoteModuleName + " " + remoteModuleIP + " " + password + " " + calpontPackage + " " + calpontPackage1 + " " + calpontPackage2 + " " + mysqlPackage + " " + mysqldPackage + " initial " + packageType + " --nodeps none " + MySQLPort + " 1 > /tmp/user_installer.log";
log.writeLog(__LINE__, "addModule cmd: " + cmd, LOG_TYPE_DEBUG); log.writeLog(__LINE__, "addModule cmd: " + cmd, LOG_TYPE_DEBUG);
@@ -5064,7 +5063,7 @@ int ProcessManager::addModule(oam::DeviceNetworkList devicenetworklist, std::str
if ( remoteModuleType == "pm" ) { if ( remoteModuleType == "pm" ) {
if ( packageType != "binary" ) { if ( packageType != "binary" ) {
log.writeLog(__LINE__, "addModule - performance_installer run for " + remoteModuleName, LOG_TYPE_DEBUG); log.writeLog(__LINE__, "addModule - performance_installer run for " + remoteModuleName, LOG_TYPE_DEBUG);
string cmd = installDir + "/bin/performance_installer.sh " + remoteModuleName + " " + remoteModuleIP + " " + password + " " + version + " initial " + packageType + " --nodeps 1 > /tmp/performance_installer.log"; string cmd = installDir + "/bin/performance_installer.sh " + remoteModuleName + " " + remoteModuleIP + " " + password + " " + calpontPackage + " " + calpontPackage1 + " " + calpontPackage2 + " " + mysqlPackage + " " + mysqldPackage + " initial " + packageType + " --nodeps 1 > /tmp/performance_installer.log";
log.writeLog(__LINE__, "addModule cmd: " + cmd, LOG_TYPE_DEBUG); log.writeLog(__LINE__, "addModule cmd: " + cmd, LOG_TYPE_DEBUG);
rtnCode = system(cmd.c_str()); rtnCode = system(cmd.c_str());
@@ -8625,7 +8624,7 @@ int ProcessManager::OAMParentModuleChange()
noAckCount = 0; noAckCount = 0;
//if Amazon Parent PM is restarting, monitor when back active and take needed actions //if Amazon Parent PM is restarting, monitor when back active and take needed actions
/* if (amazonParentRestart) if (amazonParentRestart)
{ {
log.writeLog(__LINE__, "Amazon Parent pinging, waiting until it's active", LOG_TYPE_DEBUG); log.writeLog(__LINE__, "Amazon Parent pinging, waiting until it's active", LOG_TYPE_DEBUG);
sleep(60); sleep(60);
@@ -8658,7 +8657,7 @@ int ProcessManager::OAMParentModuleChange()
sleep(5); sleep(5);
} }
} }
*/
sleep(1); sleep(1);
break; break;
} }
@@ -8836,7 +8835,7 @@ int ProcessManager::OAMParentModuleChange()
{} {}
//do amazon failover //do amazon failover
/* if (amazon && AmazonPMFailover == "n") if (amazon && AmazonPMFailover == "n")
{ {
log.writeLog(__LINE__, " ", LOG_TYPE_DEBUG); log.writeLog(__LINE__, " ", LOG_TYPE_DEBUG);
log.writeLog(__LINE__, "*** OAMParentModule outage, AmazonPMFailover not set, wating for instance to restart ***", LOG_TYPE_DEBUG); log.writeLog(__LINE__, "*** OAMParentModule outage, AmazonPMFailover not set, wating for instance to restart ***", LOG_TYPE_DEBUG);
@@ -8911,7 +8910,7 @@ int ProcessManager::OAMParentModuleChange()
//clear and go monitor again //clear and go monitor again
failover = false; failover = false;
}*/ }
} }
} }
@@ -9186,7 +9185,9 @@ int ProcessManager::OAMParentModuleChange()
} }
//restart DDLProc/DMLProc to perform any rollbacks, if needed //restart DDLProc/DMLProc to perform any rollbacks, if needed
if ( ( config.ServerInstallType() != oam::INSTALL_COMBINE_DM_UM_PM ) ) { //dont rollback in amazon, wait until down pm recovers
if ( ( config.ServerInstallType() != oam::INSTALL_COMBINE_DM_UM_PM )
&& !amazon ) {
processManager.restartProcessType("DDLProc", config.moduleName()); processManager.restartProcessType("DDLProc", config.moduleName());
sleep(1); sleep(1);
processManager.restartProcessType("DMLProc", config.moduleName()); processManager.restartProcessType("DMLProc", config.moduleName());
@@ -10066,20 +10067,7 @@ int ProcessManager::setMySQLReplication(oam::DeviceNetworkList devicenetworklist
if ( moduleType == "pm" && PMwithUM == "n" ) if ( moduleType == "pm" && PMwithUM == "n" )
continue; continue;
} }
//check status, skip if module is offline
int opState = oam::ACTIVE;
bool degraded;
try {
oam.getModuleStatus(remoteModuleName, opState, degraded);
}
catch(...)
{
}
if (opState != oam::ACTIVE)
continue;
ByteStream msg1; ByteStream msg1;
ByteStream::byte requestID = oam::SLAVEREP; ByteStream::byte requestID = oam::SLAVEREP;
if ( !enable ) { if ( !enable ) {