Page MenuHomePhorge

No OneTemporary

Size
23 KB
Referenced Files
None
Subscribers
None
diff --git a/examples/agent-functionalities/agent-functionalities.cpp b/examples/agent-functionalities/agent-functionalities.cpp
index 7e4cf9b..d956c54 100644
--- a/examples/agent-functionalities/agent-functionalities.cpp
+++ b/examples/agent-functionalities/agent-functionalities.cpp
@@ -1,109 +1,169 @@
//===-- examples/agent-functionalities/agent-functionalities.cpp *-- C++-*-===//
//
// The RoSA Framework
//
//===----------------------------------------------------------------------===//
///
/// \file examples/agent-functionalities/agent-functionalities.cpp
///
/// \author David Juhasz (david.juhasz@tuwien.ac.at)
///
/// \date 2017
///
/// \brief A simple example on defining \c rosa::Agent instances using
/// \c rosa::agent::Functionality object as components.
///
//===----------------------------------------------------------------------===//
#include "rosa/agent/Abstraction.hpp"
+#include "rosa/agent/LinearFunctions.hpp"
#include "rosa/agent/Confidence.hpp"
#include "rosa/config/version.h"
#include "rosa/core/Agent.hpp"
#include "rosa/core/MessagingSystem.hpp"
#include "rosa/support/log.h"
#include "rosa/support/terminal_colors.h"
#include <vector>
using namespace rosa;
using namespace rosa::agent;
using namespace rosa::terminal;
/// A dummy wrapper for testing \c rosa::MessagingSystem.
///
/// \note Since we test \c rosa::MessagingSystem directly here, we need to get
/// access to its protected members. That we do by imitating to be a decent
/// subclass of \c rosa::MessagingSystem, while calling protected member
/// functions on an object of a type from which we actually don't inherit.
struct SystemTester : protected MessagingSystem {
template <typename T, typename... Funs>
static AgentHandle createMyAgent(MessagingSystem *S, const std::string &Name,
Funs &&... Fs) {
return ((SystemTester *)S)->createAgent<T>(Name, std::move(Fs)...);
}
static void destroyMyAgent(MessagingSystem *S, const AgentHandle &H) {
((SystemTester *)S)->destroyUnit(unwrapAgent(H));
}
};
/// A special \c rosa::Agent with its own state.
class MyAgent : public Agent {
public:
using Tick = AtomConstant<atom("tick")>;
private:
enum class Categories { Bad, Normal, Good };
static const std::map<Categories, const char *> CategoryNames;
History<uint8_t, 10, HistoryPolicy::FIFO> H;
Confidence<uint8_t> C;
RangeAbstraction<uint8_t, Categories> A;
+ PartialFunction<int, int> L;
+ RangeConfidence<float, float> RCL;
+ RangeConfidence<float, float> RCS;
public:
void handler(Tick, uint8_t V) noexcept {
// Record \p V to the \c rosa::agent::History, then print state info.
H << V;
ASSERT(H.entry() == V); // Sanity check.
- LOG_INFO_STREAM << "\nNext value: " << PRINTABLE(V)
+ LOG_INFO_STREAM << "\nNext value: " << PRINTABLE(V)
<< ", confidence: " << C(H)
- << ", category: " << CategoryNames.at(A(H.entry())) << '\n';
+ << ", category: " << CategoryNames.at(A(H.entry()))
+ << ", partial: " << int(L(H.entry()))
+ << ", range-confidence-linear: ";
+ std::vector<float> res_lin = RCL(H.entry());
+ for(auto i : res_lin){
+ LOG_INFO_STREAM << " " << i;
+ }
+ LOG_INFO_STREAM << ", range-confidence-sine: ";
+ std::vector<float> res_sine = RCS(H.entry());
+ for(auto i : res_sine){
+ LOG_INFO_STREAM << " " << i;
+ }
+ LOG_INFO_STREAM << '\n';
}
MyAgent(const AtomValue Kind, const rosa::id_t Id, const std::string &Name,
MessagingSystem &S)
: Agent(Kind, Id, Name, S, THISMEMBER(handler)), H(), C(5, 20, 1),
A({{{(uint8_t)10, (uint8_t)14}, Categories::Normal},
{{(uint8_t)15, (uint8_t)17}, Categories::Good},
{{(uint8_t)18, (uint8_t)19}, Categories::Normal}},
- Categories::Bad) {}
+ Categories::Bad),
+ L({{{0, 2}, new LinearFunction<int,int>(0, 1)},
+ {{2, 4}, new LinearFunction<int,int>(2, 0)},
+ {{4, 6}, new LinearFunction<int,int>(6, -1)}},
+ 0),
+ RCL({
+ PartialFunction<float, float>({
+ {{0, 3}, new LinearFunction<float, float>(0, 1.0/3)},
+ {{3, 6}, new LinearFunction<float, float>(1, 0)},
+ {{6, 9}, new LinearFunction<float, float>(3.0, -1.0/3)},
+ },0),
+ PartialFunction<float, float>({
+ {{6, 9}, new LinearFunction<float, float>(-2, 1.0/3)},
+ {{9, 12}, new LinearFunction<float, float>(1, 0)},
+ {{12, 15}, new LinearFunction<float, float>(5, -1.0/3)},
+ },0),
+ PartialFunction<float, float>({
+ {{12, 15}, new LinearFunction<float, float>(-4, 1.0/3)},
+ {{15, 18}, new LinearFunction<float, float>(1, 0)},
+ {{18, 21}, new LinearFunction<float, float>(7, -1.0/3)},
+ },0)
+ }),
+ RCS({
+ PartialFunction<float, float>({
+ {{0, 3}, new SineFunction<float, float>
+ (M_PI/3, 0.5, -M_PI/2, 0.5)},
+ {{3, 6}, new LinearFunction<float, float>(1, 0)},
+ {{6, 9}, new SineFunction<float, float>
+ (M_PI/3, 0.5, -M_PI/2 + 3, 0.5)},
+ },0),
+ PartialFunction<float, float>({
+ {{6, 9}, new SineFunction<float, float>
+ (M_PI/3, 0.5, -M_PI/2, 0.5)},
+ {{9, 12}, new LinearFunction<float, float>(1, 0)},
+ {{12, 15}, new SineFunction<float, float>
+ (M_PI/3, 0.5, -M_PI/2 + 3, 0.5)},
+ },0),
+ PartialFunction<float, float>({
+ {{12, 15}, new SineFunction<float, float>
+ (M_PI/3, 0.5, -M_PI/2, 0.5)},
+ {{15, 18}, new LinearFunction<float, float>(1, 0)},
+ {{18, 21}, new SineFunction<float, float>
+ (M_PI/3, 0.5, -M_PI/2 + 3, 0.5)},
+ },0)
+ }){}
};
const std::map<MyAgent::Categories, const char *> MyAgent::CategoryNames{
{Categories::Bad, "Bad"},
{Categories::Normal, "Normal"},
{Categories::Good, "Good"}};
int main(void) {
- LOG_INFO_STREAM << library_string() << " -- " << Color::Red
+ LOG_INFO_STREAM << library_string() << " -- " << Color::Red
<< "agent-functionalities example" << Color::Default
<< '\n';
std::unique_ptr<MessagingSystem> S = MessagingSystem::createSystem("Sys");
MessagingSystem *SP = S.get();
AgentHandle A = SystemTester::createMyAgent<MyAgent>(SP, "MyAgent");
- std::vector<uint8_t> Vs{4, 5, 6, 7, 9, 10, 11, 13,
+ std::vector<uint8_t> Vs{0, 1, 2, 3, 4, 5, 6, 7, 9, 10, 11, 13,
15, 14, 15, 16, 19, 20, 21};
for (auto I = Vs.begin(); I != Vs.end(); ++I) {
A.send<MyAgent::Tick, uint8_t>(MyAgent::Tick::Value, *I);
}
SystemTester::destroyMyAgent(SP, A);
return 0;
}
diff --git a/include/rosa/agent/Abstraction.hpp b/include/rosa/agent/Abstraction.hpp
index c9c4fa2..fa9e03e 100644
--- a/include/rosa/agent/Abstraction.hpp
+++ b/include/rosa/agent/Abstraction.hpp
@@ -1,191 +1,193 @@
//===-- rosa/agent/Abstraction.hpp ------------------------------*- C++ -*-===//
//
// The RoSA Framework
//
//===----------------------------------------------------------------------===//
///
/// \file rosa/agent/Abstraction.hpp
///
/// \author David Juhasz (david.juhasz@tuwien.ac.at)
///
/// \date 2017
///
/// \brief Definition of *abstraction* *functionality*.
///
//===----------------------------------------------------------------------===//
#ifndef ROSA_AGENT_ABSTRACTION_HPP
#define ROSA_AGENT_ABSTRACTION_HPP
#include "rosa/agent/Functionality.h"
#include "rosa/support/debug.hpp"
#include <algorithm>
#include <map>
namespace rosa {
namespace agent {
/// Abstracts values from a type to another one.
///
/// \tparam T type to abstract from
/// \tparam A type to abstract to
template <typename T, typename A> class Abstraction : public Functionality {
protected:
/// Value to abstract to by default.
const A Default;
public:
/// Creates an instance.
///
/// \param Default value to abstract to by default
Abstraction(const A Default) noexcept : Default(Default) {}
/// Destroys \p this object.
~Abstraction(void) = default;
/// Abstracts a value from type \p T to type \p A.
///
/// \note The default implementation always returns
/// \c rosa::agent::Abstraction::Default, hence the actual argument is
/// ignored.
///
/// \return the abstracted value
virtual A operator()(const T &) const noexcept { return Default; }
};
/// Implements \c rosa::agent::Abstraction as a \c std::map from a type to
/// another one.
///
/// \note This implementation is supposed to be used to abstract between
/// enumeration types, which is statically enforced.
///
/// \tparam T type to abstract from
/// \tparam A type to abstract to
template <typename T, typename A>
class MapAbstraction : public Abstraction<T, A>, private std::map<T, A> {
// Make sure the actual type arguments are enumerations.
STATIC_ASSERT((std::is_enum<T>::value && std::is_enum<A>::value),
"mapping not enumerations");
// Bringing into scope inherited members.
using Abstraction<T, A>::Default;
using std::map<T, A>::end;
using std::map<T, A>::find;
public:
/// Creates an instance by initializing the underlying \c std::map.
///
/// \param Map the mapping to do abstraction according to
/// \param Default value to abstract to by default
MapAbstraction(const std::map<T, A> &Map, const A Default) noexcept
: Abstraction<T, A>(Default),
std::map<T, A>(Map) {}
/// Destroys \p this object.
~MapAbstraction(void) = default;
/// Abstracts a value from type \p T to type \p A based on the set mapping.
///
/// Results in the value associated by the set mapping to the argument, or
/// \c rosa::agent::MapAbstraction::Default if the actual argument is not
/// associated with anything by the set mapping.
///
/// \param V value to abstract
///
/// \return the abstracted value based on the set mapping
A operator()(const T &V) const noexcept override {
const auto I = find(V);
return I == end() ? Default : *I;
}
};
/// Implements \c rosa::agent::Abstraction as a \c std::map from ranges of a
/// type to values of another type.
///
/// \note This implementation is supposed to be used to abstract ranges of
/// arithmetic types into enumerations, which is statically enforced.
///
/// \invariant The keys in the underlying \c std::map define valid ranges
/// such that `first <= second` and there are no overlapping ranges defined by
/// the keys.
///
/// \tparam T type to abstract from
/// \tparam A type to abstract to
template <typename T, typename A>
class RangeAbstraction : public Abstraction<T, A>,
private std::map<std::pair<T, T>, A> {
// Make sure the actual type arguments are matching our expectations.
STATIC_ASSERT((std::is_arithmetic<T>::value), "abstracting not arithmetic");
- STATIC_ASSERT((std::is_enum<A>::value), "abstracting not to enumeration");
+ /// \todo check if this compiles with the definition of abstractions as
+ /// self-aware properties
+ //STATIC_ASSERT((std::is_enum<A>::value), "abstracting not to enumeration");
// Bringing into scope inherited members.
using Abstraction<T, A>::Default;
using std::map<std::pair<T, T>, A>::begin;
using std::map<std::pair<T, T>, A>::end;
using std::map<std::pair<T, T>, A>::find;
public:
/// Creates an instance by Initializing the unserlying \c std::map.
///
/// \param Map the mapping to do abstraction according to
/// \param Default value to abstract to by default
///
/// \pre Each key defines a valid range such that `first <= second` and
/// there are no overlapping ranges defined by the keys.
RangeAbstraction(const std::map<std::pair<T, T>, A> &Map, const A &Default)
: Abstraction<T, A>(Default), std::map<std::pair<T, T>, A>(Map) {
// Sanity check.
ASSERT(std::all_of(
begin(), end(), [this](const std::pair<std::pair<T, T>, A> &P) {
return P.first.first <= P.first.second &&
std::all_of(++find(P.first), end(),
[&P](const std::pair<std::pair<T, T>, A> &R) {
// \note Values in \c Map are sorted.
return P.first.first < P.first.second &&
P.first.second <= R.first.first ||
P.first.first == P.first.second &&
P.first.second < R.first.first;
});
}));
}
/// Destroys \p this object.
~RangeAbstraction(void) = default;
/// Abstracts a value from type \p T to type \p A based on the set mapping.
///
/// Results in the value associated by the set mapping to the argument, or
/// \c rosa::agent::RangeAbstraction::Default if the actual argument is not
/// included in any of the ranges in the set mapping.
///
/// \param V value to abstract
///
/// \return the abstracted value based on the set mapping
A operator()(const T &V) const noexcept override {
auto I = begin();
bool Found = false; // Indicates if \c I refers to a matching range.
bool Failed = false; // Indicates if it is pointless to continue searching.
while (!Found && !Failed && I != end()) {
if (V < I->first.first) {
// No match so far and \p V is below the next range, never will match.
// \note Keys are sorted in the map.
Failed = true;
} else if (I->first.first <= V && V < I->first.second) {
// Matching range found.
Found = true;
} else {
// Cannot conclude in this step, move to the next range.
++I;
}
}
ASSERT(!Found || I != end());
return Found ? I->second : Default;
}
};
} // End namespace agent
} // End namespace rosa
#endif // ROSA_AGENT_ABSTRACTION_HPP
diff --git a/include/rosa/agent/LinearFunctions.hpp b/include/rosa/agent/LinearFunctions.hpp
new file mode 100644
index 0000000..cbc901d
--- /dev/null
+++ b/include/rosa/agent/LinearFunctions.hpp
@@ -0,0 +1,224 @@
+//===-- rosa/agent/LinearAbstractions.hpp --------------------------*- C++ -*-===//
+//
+// The RoSA Framework
+//
+//===----------------------------------------------------------------------===//
+///
+/// \file rosa/agent/LinearAbstractions.hpp
+///
+/// \author Benedikt Tutzer (benedikt.tutzer@tuwien.ac.at)
+///
+/// \date 2019
+///
+/// \brief Definition of *LinearFunction* *functionality*.
+///
+//===----------------------------------------------------------------------===//
+
+#ifndef ROSA_AGENT_LINEARFUNCTIONS_HPP
+#define ROSA_AGENT_LINEARFUNCTIONS_HPP
+
+#include "rosa/agent/Functionality.h"
+#include "rosa/agent/Abstraction.hpp"
+
+#include "rosa/support/debug.hpp"
+
+#include <algorithm>
+#include <vector>
+#include <cmath>
+
+namespace rosa {
+namespace agent {
+
+/// Evaluates a linear function at a given value.
+///
+/// \tparam T type of the functions domain
+/// \tparam A type of the functions range
+template <typename T, typename A> class LinearFunction :
+ public Abstraction<T, A>{
+ // Make sure the actual type arguments are matching our expectations.
+ STATIC_ASSERT((std::is_arithmetic<T>::value),
+ "LinearFunction not arithmetic T");
+ STATIC_ASSERT((std::is_arithmetic<A>::value),
+ "LinearFunction not to arithmetic");
+protected:
+ const T Intercept;
+ const T Coefficient;
+
+public:
+ /// Creates an instance.
+ ///
+ /// \param Intercept the intercept of the linear function
+ /// \param Coefficient the coefficient of the linear function
+ /// domain
+ LinearFunction(T Intercept, T Coefficient) noexcept
+ : Abstraction<T, A>(Intercept),
+ Intercept(Intercept),
+ Coefficient(Coefficient) {}
+
+ /// Destroys \p this object.
+ ~LinearFunction(void) = default;
+
+ /// Evaluates the linear function
+ ///
+ /// \param X the value at which to evaluate the function
+ /// \return the result
+ virtual A operator()(const T &X) const noexcept override {
+ return Intercept + X*Coefficient;
+ }
+};
+
+/// Evaluates a sine function at a given value.
+///
+/// \tparam T type of the functions domain
+/// \tparam A type of the functions range
+template <typename T, typename A> class SineFunction :
+ public Abstraction<T, A>{
+ // Make sure the actual type arguments are matching our expectations.
+ STATIC_ASSERT((std::is_arithmetic<T>::value),
+ "SineFunction not arithmetic T");
+ STATIC_ASSERT((std::is_arithmetic<A>::value),
+ "SineFunction not to arithmetic");
+protected:
+ const T Frequency;
+ const T Amplitude;
+ const T Phase;
+ const T Average;
+
+public:
+ /// Creates an instance.
+ ///
+ /// \param Frequency the frequency of the sine wave
+ /// \param Amplitude the amplitude of the sine wave
+ /// \param Phase the phase of the sine wave
+ /// \param Average the average of the sine wave
+ /// domain
+ SineFunction(T Frequency, T Amplitude, T Phase, T Average) noexcept
+ : Abstraction<T, A>(Average),
+ Frequency(Frequency),
+ Amplitude(Amplitude),
+ Phase(Phase),
+ Average(Average) {}
+
+ /// Destroys \p this object.
+ ~SineFunction(void) = default;
+
+ /// Evaluates the linear function
+ ///
+ /// \param X the value at which to evaluate the function
+ /// \return the result
+ virtual A operator()(const T &X) const noexcept override {
+ return Amplitude*sin(Frequency * X + Phase) + Average;
+ }
+};
+
+/// Implements \c rosa::agent::RangeAbstraction as an abstraction from
+/// \c std::map from ranges of a type to abstractions of that type to another
+/// type. The resulting abstractions are evaluated for the given values.
+///
+/// \note This implementation is supposed to be used to abstract ranges of
+/// arithmetic types into abstractions from that type to another arithmetic
+/// type, which is statically enforced.
+///
+/// \invariant The keys in the underlying \c std::map define valid ranges
+/// such that `first <= second` and there are no overlapping ranges defined by
+/// the keys.
+///
+/// \tparam T type to abstract from
+/// \tparam A type to abstract to
+template <typename T, typename A>
+class PartialFunction : private Abstraction<T, A> {
+ // Make sure the actual type arguments are matching our expectations.
+ STATIC_ASSERT((std::is_arithmetic<T>::value), "abstracting not arithmetic");
+ STATIC_ASSERT((std::is_arithmetic<A>::value),
+ "abstracting not to arithmetic");
+
+private:
+ RangeAbstraction<T, Abstraction<T, A>*> RA;
+
+public:
+ /// Creates an instance by Initializing the underlying \c RangeAbstraction.
+ ///
+ /// \param Map the mapping to do abstraction according to
+ /// \param Default abstraction to abstract to by default
+ ///
+ /// \pre Each key defines a valid range such that `first <= second` and
+ /// there are no overlapping ranges defined by the keys.
+ PartialFunction(const std::map<std::pair<T, T>, Abstraction<T, A>*> &Map,
+ const A Default)
+ : Abstraction<T, A>(Default), RA(Map, new Abstraction<T, A>(Default)) {
+ }
+
+ /// Destroys \p this object.
+ ~PartialFunction(void) = default;
+
+ /// Evaluates an Abstraction from type \p T to type \p A based on the set
+ /// mapping.
+ ///
+ /// Results in the value associated by the set mapping to the argument, or
+ /// \c rosa::agent::RangeAbstraction::Default if the actual argument is not
+ /// included in any of the ranges in the set mapping.
+ ///
+ /// \param V value to abstract
+ ///
+ /// \return the abstracted value based on the set mapping
+ A operator()(const T &V) const noexcept override {
+ return (*RA(V))(V);
+ }
+};
+
+/// Evaluates a vector of Abstractions at a given value and returns the results
+/// as a vector
+///
+/// \note This implementation is supposed to be used to abstract ranges of
+/// arithmetic types into vectors of another arithmetic type, which is
+/// statically enforced.
+///
+/// \tparam T type to abstract from
+/// \tparam A type to abstract a vector of to
+template <typename T, typename A>
+class RangeConfidence : public Abstraction<T, std::vector<A>>,
+ private std::vector<PartialFunction<T, A>>{
+ // Make sure the actual type arguments are matching our expectations.
+ STATIC_ASSERT((std::is_arithmetic<T>::value), "abstracting not arithmetic");
+ STATIC_ASSERT((std::is_arithmetic<A>::value),
+ "abstracting not to arithmetic");
+
+ // Bringing into scope inherited members.
+ using std::vector<PartialFunction<T, A>>::size;
+ using std::vector<PartialFunction<T, A>>::begin;
+ using std::vector<PartialFunction<T, A>>::end;
+
+public:
+ /// Creates an instance by Initializing the underlying \c RangeAbstraction.
+ ///
+ /// \param Abstractions the Abstractions to be evaluated
+ RangeConfidence(const std::vector<PartialFunction<T, A>> &Abstractions)
+ : Abstraction<T, std::vector<A>>({}),
+ std::vector<PartialFunction<T, A>>(Abstractions) {
+ }
+
+ /// Destroys \p this object.
+ ~RangeConfidence(void) = default;
+
+ /// Evaluates an Abstraction from type \p T to type \p A based on the set
+ /// mapping.
+ ///
+ /// Results in the value associated by the set mapping to the argument, or
+ /// \c rosa::agent::RangeAbstraction::Default if the actual argument is not
+ /// included in any of the ranges in the set mapping.
+ ///
+ /// \param V value to abstract
+ ///
+ /// \return the abstracted value based on the set mapping
+ std::vector<A> operator()(const T &V) const noexcept override {
+ std::vector<A> ret;
+ for(auto const& func : ((std::vector<PartialFunction<T, A>>)*this)){
+ ret.push_back(func(V));
+ }
+ return ret;
+ }
+};
+} // End namespace agent
+} // End namespace rosa
+
+#endif // ROSA_AGENT_ABSTRACTION_HPP
diff --git a/lib/agent/CMakeLists.txt b/lib/agent/CMakeLists.txt
index 81a33f5..3d6e5ab 100644
--- a/lib/agent/CMakeLists.txt
+++ b/lib/agent/CMakeLists.txt
@@ -1,14 +1,16 @@
set(LIB_INCLUDE_DIR ${ROSA_MAIN_INCLUDE_DIR}/rosa/agent)
add_library(ROSAAgent
${LIB_INCLUDE_DIR}/namespace.h
namespace.cpp
${LIB_INCLUDE_DIR}/Functionality.h
Functionality.cpp
${LIB_INCLUDE_DIR}/Abstraction.hpp
Abstraction.cpp
+ ${LIB_INCLUDE_DIR}/LinearFunctions.hpp
+ LinearFunctions.cpp
${LIB_INCLUDE_DIR}/History.hpp
History.cpp
${LIB_INCLUDE_DIR}/Confidence.hpp
Confidence.cpp
)
diff --git a/lib/agent/LinearFunctions.cpp b/lib/agent/LinearFunctions.cpp
new file mode 100644
index 0000000..0b43abe
--- /dev/null
+++ b/lib/agent/LinearFunctions.cpp
@@ -0,0 +1,20 @@
+//===-- agent/LinearFunctions.cpp -------------------------------*- C++ -*-===//
+//
+// The RoSA Framework
+//
+//===----------------------------------------------------------------------===//
+///
+/// \file agent/LinearFunctions.cpp
+///
+/// \author Benedikt Tutzer (benedikt.tutzer@tuwien.ac.at)
+///
+/// \date 2019
+///
+/// \brief Implementation for rosa/agent/LinearFunctions.hpp.
+///
+/// \note Empty implementation, source file here to have a compile database
+/// entry for rosa/agent/LinearFunctions.hpp.
+///
+//===----------------------------------------------------------------------===//
+
+#include "rosa/agent/LinearFunctions.hpp"

File Metadata

Mime Type
text/x-diff
Expires
Sun, Apr 27, 2:06 PM (1 d, 6 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
134514
Default Alt Text
(23 KB)

Event Timeline