StatusManager.cpp

Go to the documentation of this file.

#include "StatusManager.h"
 
#include <filesystem>
#include <fstream>
 
#include <ArmarXCore/core/logging/Logging.h>
#include <ArmarXCore/core/system/ArmarXDataPath.h>
#include <ArmarXCore/util/CPPUtility/filesystem.h>
 
using namespace ScenarioManager;
using namespace Exec;
using namespace armarx;
 
StatusManager::StatusManager()
{
}
 
int
StatusManager::loadPid(Data_Structure::ApplicationInstancePtr app)
{
    std::string cachePath = ArmarXDataPath::GetCachePath();
    if (cachePath.empty())
    {
        return -1;
    }
 
    cachePath.append("/pids/");
    auto dir = remove_trailing_separator(cachePath);
 
    if (!std::filesystem::exists(dir) && !std::filesystem::create_directories(dir))
    {
        ARMARX_WARNING_S << "Unable to create Cache directory for the ScenarioManager plugin at "
                         << cachePath;
    }
 
 
    std::string filename = cachePath + app->getPackageName() + "." + app->getScenario()->getName() +
                           "." + app->getName() + (app->getInstanceName().empty() ? "" : ".") +
                           app->getInstanceName() + ".pids";
 
    if (!std::filesystem::exists(filename))
    {
        return -1;
    }
 
    std::ifstream input(filename);
 
    int pid;
    input >> pid;
 
    return pid;
}
 
void
StatusManager::savePid(Data_Structure::ApplicationInstancePtr app)
{
    std::string cachePath = ArmarXDataPath::GetCachePath();
    if (cachePath.empty())
    {
        // Without a cache path loadPid() can never find anything again, so silently "saving" to a
        // path relative to the filesystem root would just lose every pid across restarts.
        ARMARX_WARNING_S << "No cache path configured - the pid of " << app->getName()
                         << " cannot be persisted, and the application will be reported as "
                            "stopped once its pid is lost.";
        return;
    }
 
    cachePath.append("/pids/");
    auto dir = remove_trailing_separator(cachePath);
 
    if (!std::filesystem::exists(dir) && !std::filesystem::create_directories(dir))
    {
        ARMARX_WARNING_S << "Unable to create Cache directory for the ScenarioManager plugin at "
                         << cachePath;
    }
 
    std::string filename = cachePath + app->getPackageName() + "." + app->getScenario()->getName() +
                           "." + app->getName() + (app->getInstanceName().empty() ? "" : ".") +
                           app->getInstanceName() + ".pids";
 
    if (app->getPid() == -1)
    {
        std::filesystem::remove(std::filesystem::path(filename));
        return;
    }
 
    std::ofstream output(filename);
 
    output << app->getPid();
    output.close();
 
    if (!output)
    {
        ARMARX_WARNING_S << "Failed to write the pid of " << app->getName() << " to " << filename
                         << ". The application will be reported as stopped once its pid is lost.";
    }
}
 
void
StatusManager::clearCache()
{
    std::string cachePath = ArmarXDataPath::GetCachePath();
    cachePath.append("/pids/");
 
    std::filesystem::remove_all(std::filesystem::path(cachePath));
}