tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-24 22:24:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove duplicated validation paths in function signatures

Browse Source
This commit is contained in:
Michael Friedrich 2018-10-24 17:06:17 +02:00
parent 043824a6a9
commit efc2289178
2 changed files with 15 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
lib/remote/apilistener-filesync.cpp
View File

@ -446,7 +446,7 @@ Value ApiListener::ConfigUpdateHandler(const MessageOrigin::Ptr& origin, const D
/* Spawn a validation process. On success, move the staged configuration /* Spawn a validation process. On success, move the staged configuration
* into production and restart. * into production and restart.
*/ */
AsyncTryActivateZonesStage(GetApiZonesStageDir(), GetApiZonesDir(), relativePaths); AsyncTryActivateZonesStage(relativePaths);
} }
return Empty; return Empty;
@ -459,20 +459,20 @@ Value ApiListener::ConfigUpdateHandler(const MessageOrigin::Ptr& origin, const D
* On failure, there's no restart and this is logged. * On failure, there's no restart and this is logged.
* *
* @param pr Result of the validation process. * @param pr Result of the validation process.
* @param stageConfigDir TODO * @param relativePaths Collected paths including the zone name, which are copied from stage to current directories.
* @param currentConfigDir TODO
* @param relativePaths Collected paths which are copied from stage to current.
*/ */
void ApiListener::TryActivateZonesStageCallback(const ProcessResult& pr, void ApiListener::TryActivateZonesStageCallback(const ProcessResult& pr,
const String& stageConfigDir, const String& currentConfigDir,
const std::vector<String>& relativePaths) const std::vector<String>& relativePaths)
{ {
String logFile = GetApiZonesStageDir() + "/startup.log"; String apiZonesDir = GetApiZonesDir();
String apiZonesStageDir = GetApiZonesStageDir();
String logFile = apiZonesStageDir + "/startup.log";
std::ofstream fpLog(logFile.CStr(), std::ofstream::out | std::ostream::binary | std::ostream::trunc); std::ofstream fpLog(logFile.CStr(), std::ofstream::out | std::ostream::binary | std::ostream::trunc);
fpLog << pr.Output; fpLog << pr.Output;
fpLog.close(); fpLog.close();
String statusFile = GetApiZonesStageDir() + "/status"; String statusFile = apiZonesStageDir + "/status";
std::ofstream fpStatus(statusFile.CStr(), std::ofstream::out | std::ostream::binary | std::ostream::trunc); std::ofstream fpStatus(statusFile.CStr(), std::ofstream::out | std::ostream::binary | std::ostream::trunc);
fpStatus << pr.ExitStatus; fpStatus << pr.ExitStatus;
fpStatus.close(); fpStatus.close();
@ -480,9 +480,7 @@ void ApiListener::TryActivateZonesStageCallback(const ProcessResult& pr,
/* validation went fine, copy stage and reload */ /* validation went fine, copy stage and reload */
if (pr.ExitStatus == 0) { if (pr.ExitStatus == 0) {
Log(LogInformation, "ApiListener") Log(LogInformation, "ApiListener")
<< "Config validation for stage '" << GetApiZonesStageDir() << "' was OK, replacing into '" << GetApiZonesDir() << "' and triggering reload."; << "Config validation for stage '" << apiZonesStageDir << "' was OK, replacing into '" << apiZonesDir << "' and triggering reload.";
String apiZonesDir = GetApiZonesDir();
/* Purge production before copying stage. */ /* Purge production before copying stage. */
if (Utility::PathExists(apiZonesDir)) if (Utility::PathExists(apiZonesDir))
@ -495,8 +493,8 @@ void ApiListener::TryActivateZonesStageCallback(const ProcessResult& pr,
Log(LogNotice, "ApiListener") Log(LogNotice, "ApiListener")
<< "Copying file '" << path << "' from config sync staging to production zones directory."; << "Copying file '" << path << "' from config sync staging to production zones directory.";
String stagePath = GetApiZonesStageDir() + path; String stagePath = apiZonesStageDir + path;
String currentPath = GetApiZonesDir() + path; String currentPath = apiZonesDir + path;
Utility::MkDirP(Utility::DirName(currentPath), 0700); Utility::MkDirP(Utility::DirName(currentPath), 0700);
@ -515,7 +513,7 @@ void ApiListener::TryActivateZonesStageCallback(const ProcessResult& pr,
/* Error case. */ /* Error case. */
Log(LogCritical, "ApiListener") Log(LogCritical, "ApiListener")
<< "Config validation failed for staged cluster config sync in '" << GetApiZonesStageDir() << "Config validation failed for staged cluster config sync in '" << apiZonesStageDir
<< "'. Aborting. Logs: '" << logFile << "'"; << "'. Aborting. Logs: '" << logFile << "'";
ApiListener::Ptr listener = ApiListener::GetInstance(); ApiListener::Ptr listener = ApiListener::GetInstance();
@ -528,12 +526,9 @@ void ApiListener::TryActivateZonesStageCallback(const ProcessResult& pr,
* Spawns a new validation process and waits for its output. * Spawns a new validation process and waits for its output.
* Sets 'System.ZonesStageVarDir' to override the config validation zone dirs with our current stage. * Sets 'System.ZonesStageVarDir' to override the config validation zone dirs with our current stage.
* *
* @param stageConfigDir TODO * @param relativePaths Required for later file operations in the callback. Provides the zone name plus path in a list.
* @param currentConfigDir TODO
* @param relativePaths Required for later file operations in the callback.
*/ */
void ApiListener::AsyncTryActivateZonesStage(const String& stageConfigDir, const String& currentConfigDir, void ApiListener::AsyncTryActivateZonesStage(const std::vector<String>& relativePaths)
const std::vector<String>& relativePaths)
{ {
VERIFY(Application::GetArgC() >= 1); VERIFY(Application::GetArgC() >= 1);
@ -559,7 +554,7 @@ void ApiListener::AsyncTryActivateZonesStage(const String& stageConfigDir, const
Process::Ptr process = new Process(Process::PrepareCommand(args)); Process::Ptr process = new Process(Process::PrepareCommand(args));
process->SetTimeout(300); process->SetTimeout(300);
process->Run(std::bind(&TryActivateZonesStageCallback, _1, stageConfigDir, currentConfigDir, relativePaths)); process->Run(std::bind(&TryActivateZonesStageCallback, _1, relativePaths));
} }
/** /**

4
lib/remote/apilistener.hpp
View File

@ -182,10 +182,8 @@ private:
void SendConfigUpdate(const JsonRpcConnection::Ptr& aclient); void SendConfigUpdate(const JsonRpcConnection::Ptr& aclient);
static void TryActivateZonesStageCallback(const ProcessResult& pr, static void TryActivateZonesStageCallback(const ProcessResult& pr,
const String& stageConfigDir, const String& currentConfigDir,
const std::vector<String>& relativePaths);
static void AsyncTryActivateZonesStage(const String& stageConfigDir, const String& currentConfigDir,
const std::vector<String>& relativePaths); const std::vector<String>& relativePaths);
static void AsyncTryActivateZonesStage(const std::vector<String>& relativePaths);
void UpdateLastFailedZonesStageValidation(const String& log); void UpdateLastFailedZonesStageValidation(const String& log);
void ClearLastFailedZonesStageValidation(); void ClearLastFailedZonesStageValidation();