[41e287] | 1 | /*
|
---|
| 2 | * ObservedValuesContainer.hpp
|
---|
| 3 | *
|
---|
| 4 | * Created on: Oct 29, 2015
|
---|
| 5 | * Author: heber
|
---|
| 6 | */
|
---|
| 7 |
|
---|
| 8 |
|
---|
| 9 | #ifndef OBSERVEDVALUESCONTAINER_HPP_
|
---|
| 10 | #define OBSERVEDVALUESCONTAINER_HPP_
|
---|
| 11 |
|
---|
| 12 | // include config.h
|
---|
| 13 | #ifdef HAVE_CONFIG_H
|
---|
| 14 | #include <config.h>
|
---|
| 15 | #endif
|
---|
| 16 |
|
---|
| 17 | #include "ObservedValue_types.hpp"
|
---|
| 18 |
|
---|
| 19 | #include <map>
|
---|
| 20 | #include <string>
|
---|
| 21 |
|
---|
[90821d] | 22 | #include <boost/function.hpp>
|
---|
| 23 |
|
---|
[41e287] | 24 | class QtObservedInstanceBoard;
|
---|
| 25 |
|
---|
| 26 | /** This class contains ObservedValues of the class \b T each instance identified
|
---|
| 27 | * by the id type \b id.
|
---|
| 28 | *
|
---|
| 29 | * All the reference counting is done inside this container.
|
---|
| 30 | */
|
---|
| 31 | template <class T, typename id>
|
---|
| 32 | class ObservedValuesContainer
|
---|
| 33 | {
|
---|
[68418e] | 34 | public:
|
---|
| 35 |
|
---|
| 36 | //!> typedef for callback functions to be used on last SubjectKilled()
|
---|
| 37 | typedef boost::function<void (const id _id)> onDestroy_t;
|
---|
| 38 |
|
---|
[41e287] | 39 | /** Cstor of class ObservedValuesContainer.
|
---|
| 40 | *
|
---|
| 41 | * \param _name name used in debugging and prints
|
---|
[65c323] | 42 | * \param _board ref to InstanceBoard
|
---|
[68418e] | 43 | * \param _onDestroy function to call when last subjectKilled() was received and
|
---|
| 44 | * ObservedValues are destroyed
|
---|
[41e287] | 45 | */
|
---|
[65c323] | 46 | ObservedValuesContainer(
|
---|
| 47 | const std::string _name,
|
---|
[68418e] | 48 | QtObservedInstanceBoard &_board,
|
---|
| 49 | const onDestroy_t _onDestroy);
|
---|
[41e287] | 50 |
|
---|
| 51 | /** Delivers the set of Observed value for the instance identified by \a _id.
|
---|
| 52 | *
|
---|
| 53 | * \param _id identifier of the instance
|
---|
| 54 | * \return shared ptr to observed instance.
|
---|
| 55 | */
|
---|
| 56 | typename T::ptr get(const id _id);
|
---|
| 57 |
|
---|
[68418e] | 58 | /** Used by QtObserved.. instance to note that signOn() has been called.
|
---|
[41e287] | 59 | *
|
---|
[68418e] | 60 | * \param _id identifier of the instance who called signOn()
|
---|
[41e287] | 61 | */
|
---|
[68418e] | 62 | void markObservedValuesAsConnected(const id _id);
|
---|
[41e287] | 63 |
|
---|
[68418e] | 64 | /** Used by QtObserved.. instance to note that signOff() has been called.
|
---|
| 65 | *
|
---|
| 66 | * \param _id identifier of the instance who called signOff()
|
---|
| 67 | */
|
---|
| 68 | void markObservedValuesAsDisconnected(const id _id);
|
---|
[41e287] | 69 |
|
---|
[90821d] | 70 | /** Inform this container that subjectKilled() was received by one of the ObservedValues.
|
---|
| 71 | *
|
---|
| 72 | * \param _id identifier of the receiving instance
|
---|
| 73 | */
|
---|
[68418e] | 74 | void countsubjectKilled(const id _id);
|
---|
| 75 |
|
---|
| 76 | /** Erases a vector of observed values of an instance identified by \a _id.
|
---|
| 77 | *
|
---|
| 78 | * \param _id identifier of instance
|
---|
| 79 | */
|
---|
| 80 | void removeObservedValues(const id _id);
|
---|
[90821d] | 81 |
|
---|
[41e287] | 82 | private:
|
---|
[68418e] | 83 | typedef std::pair<typename T::ptr, size_t> RefCountedObservedValues_t;
|
---|
[41e287] | 84 | typedef std::map<id, RefCountedObservedValues_t> CountedObservedValues_t;
|
---|
| 85 | //!> internal vector of observed values
|
---|
| 86 | CountedObservedValues_t ObservedValues;
|
---|
| 87 |
|
---|
[90821d] | 88 | //!> typedef for map with subjectKilledCounts for each instance
|
---|
| 89 | typedef std::map<id, size_t> subjectKilledCount_t;
|
---|
| 90 |
|
---|
| 91 | //!> counts how many ObservedValues have already been subjectKilled()
|
---|
| 92 | subjectKilledCount_t subjectKilledCount;
|
---|
| 93 |
|
---|
[41e287] | 94 | //!> name used in describing the instance type
|
---|
| 95 | const std::string NameOfType;
|
---|
| 96 |
|
---|
[65c323] | 97 | //!> reference to InstanceBoard for callbacks on subjectKilled()
|
---|
| 98 | QtObservedInstanceBoard &board;
|
---|
| 99 |
|
---|
[68418e] | 100 | //!> callback function when ObservedValues need to be destroyed
|
---|
| 101 | const onDestroy_t onDestroy;
|
---|
| 102 |
|
---|
| 103 | private:
|
---|
| 104 | /** Internal function to check whether an Observed instance identified by
|
---|
| 105 | * \a _id is still signOn() to its associated World instance.
|
---|
| 106 | *
|
---|
| 107 | * \param _id identifier of instance
|
---|
| 108 | * \return true - no more signOn()s, false - else
|
---|
| 109 | */
|
---|
| 110 | bool checkRefCount(const id _id) const;
|
---|
| 111 |
|
---|
| 112 | /** Internal function to check whether any ObservedValue identified by
|
---|
| 113 | * \a _id is still signOn() to its associated World instance.
|
---|
| 114 | *
|
---|
| 115 | * \param _id identifier of instance
|
---|
| 116 | * \return true - no more signOn()s, false - else
|
---|
| 117 | */
|
---|
| 118 | bool checksubjectKilled(const id _id) const;
|
---|
| 119 |
|
---|
[41e287] | 120 | private:
|
---|
| 121 | //!> QtObservedInstanceBoard may access anything
|
---|
| 122 | friend class QtObservedInstanceBoard;
|
---|
| 123 |
|
---|
| 124 | /** Inserts a new ObservedValue vector into the container.
|
---|
| 125 | *
|
---|
| 126 | * \param _id identifier of instance associated with observed values
|
---|
| 127 | * \param _obsvalues vector of observed values of instance
|
---|
| 128 | * \return true - insertion successful, false - else
|
---|
| 129 | */
|
---|
[68418e] | 130 | bool insert(const id _id, const typename T::ptr &_obsvalues);
|
---|
[41e287] | 131 |
|
---|
| 132 | /** Use to change the identifier associated with a vector of observed values.
|
---|
| 133 | *
|
---|
| 134 | * \param _oldid old identifier
|
---|
| 135 | * \param _newid new identifier
|
---|
| 136 | * \return true - change successful, false - else
|
---|
| 137 | */
|
---|
| 138 | bool changeIdentifier(const id _oldid, const id _newid);
|
---|
| 139 |
|
---|
| 140 | /** Returns the number of reference delivered for this instance identified by \a _id.
|
---|
| 141 | *
|
---|
| 142 | * \param _id identifier of instance
|
---|
| 143 | * \return reference count
|
---|
| 144 | */
|
---|
| 145 | size_t getRefCount(const id _id) const;
|
---|
| 146 |
|
---|
| 147 | /** Checks whether a vector of observed values of an instance identified by \a _id
|
---|
| 148 | * is present.
|
---|
| 149 | *
|
---|
| 150 | * \param _id identifier of instance
|
---|
| 151 | * \return true - present, false - else
|
---|
| 152 | */
|
---|
| 153 | bool isPresent(const id _id) const;
|
---|
| 154 | };
|
---|
| 155 |
|
---|
| 156 | #endif /* OBSERVEDVALUESCONTAINER_HPP_ */
|
---|