fipa::acl::StateMachineFactory Class Reference

#include <statemachine_factory.h>

Static Public Member Functions
static void	setProtocolResourceDir (const std::string &resourceDir)
static void	addProtocolResourceDir (const std::string &resourceDir)
static StateMachine	getStateMachine (const std::string &protocol)
static void	prepareProtocolsFromResourceDir (const std::string &directory)

Detailed Description

Definition at line 14 of file statemachine_factory.h.

Member Function Documentation

addProtocolResourceDir()

void fipa::acl::StateMachineFactory::addProtocolResourceDir ( const std::string &  resourceDir )

static

Add the resource dir where to search for the protocol definitions

Exceptions

std::runtime_error

if resource directory does not exist

Definition at line 24 of file statemachine_factory.cpp.

{
    fs::path protocolDir = fs::path(resourceDir);
    if(fs::is_directory(protocolDir))
    {
        std::vector<std::string>::iterator resourcesIt = std::find(msResourceDirs.begin(), msResourceDirs.end(), protocolDir.string());
        if(resourcesIt == msResourceDirs.end())
        {
            msResourceDirs.push_back(protocolDir.string());
            msPreparedResourceDir = false;
            LOG_INFO("Add protocol resource dir: '%s'", protocolDir.string().c_str());
        } else {
            LOG_WARN("Protocol resource dir '%s' already added", protocolDir.string().c_str());
        }
    } else {
        std::string msg = "Could not add resource dir: '" + resourceDir + "', since it does not exist";
        throw std::runtime_error(msg);
    }
}

getStateMachine()

StateMachine fipa::acl::StateMachineFactory::getStateMachine ( const std::string &  protocol )

static

Create a statemachine for a given protocol

Exceptions

runtime_error

if statem machine

Definition at line 93 of file statemachine_factory.cpp.

{
    if(!msPreparedResourceDir)
    {
        StateMachineFactory::prepareProtocolsFromResourceDirs();
    }

    std::map<std::string, StateMachine>::iterator it = msStateMachines.find(protocol);

    if(it != msStateMachines.end())
    {
        return it->second;
    }

    LOG_WARN("StateMachine for protocol '%s' not found", protocol.c_str());
    throw std::runtime_error("State machine for requested protocol does not exist");
}

prepareProtocolsFromResourceDir()

void fipa::acl::StateMachineFactory::prepareProtocolsFromResourceDir ( const std::string &  directory )

static

Instanciates all available machines a resource directory

Definition at line 53 of file statemachine_factory.cpp.

{
    fs::path protocolDir = fs::path(resourceDir);
    LOG_INFO("Prepare protocols from: '%s'", protocolDir.string().c_str());
    if(fs::is_directory(protocolDir))
    {
        std::vector<fs::path> files;
        std::copy(fs::directory_iterator(protocolDir), fs::directory_iterator(), std::back_inserter(files));

        std::vector<fs::path>::iterator it = files.begin();
        for(;it != files.end(); ++it)
        {
            if(fs::is_regular_file(*it))
            {
                // Extract protocol name
                std::string protocolName = it->string();
                size_t pos = protocolName.find_last_of("/");
                protocolName.erase(0, pos+1);

                try {
                    // Loading the state machine from the given spec
                    StateMachine statemachine = msStateMachineReader.loadSpecification(it->string()); 
                    LOG_INFO("Register protocol %s", protocolName.c_str());
                    std::map<std::string, StateMachine>::const_iterator statemachinesIt = msStateMachines.find(protocolName);
                    if( statemachinesIt != msStateMachines.end())
                    {
                        LOG_WARN("Protocol '%s' already registered - will use statemachine specification from '%s'", protocolName.c_str(), it->string().c_str());
                    }
                    msStateMachines[protocolName] = statemachine;
                } catch(const std::runtime_error& e)
                {
                    LOG_ERROR("Error loading specification for: '%s' - %s", protocolName.c_str(), e.what());
                }
            }
        }
    }

    msPreparedResourceDir = true;
}

setProtocolResourceDir()

void fipa::acl::StateMachineFactory::setProtocolResourceDir ( const std::string &  resourceDir )

static

Set the resource dir where to search for the protocol definitions (implies a clearing of all previous entries)

Exceptions

std::runtime_error

if resource directory does not exist

Definition at line 18 of file statemachine_factory.cpp.

{
    msResourceDirs.clear();
    addProtocolResourceDir(resourceDir);
}

---

The documentation for this class was generated from the following files:

• /build/rock-master-18.09-multiagent-fipa-acl-0.20180914/src/conversation_monitor/statemachine_factory.h
• /build/rock-master-18.09-multiagent-fipa-acl-0.20180914/src/conversation_monitor/statemachine_factory.cpp