graph_manager.hpp 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318
  1. /**
  2. * @file tests/mixed/graph_manager.hpp
  3. * @author The PARADEVS Development Team
  4. * See the AUTHORS or Authors.txt file
  5. */
  6. /*
  7. * PARADEVS - the multimodeling and simulation environment
  8. * This file is a part of the PARADEVS environment
  9. *
  10. * Copyright (C) 2013 ULCO http://www.univ-litoral.fr
  11. *
  12. * This program is free software: you can redistribute it and/or modify
  13. * it under the terms of the GNU General Public License as published by
  14. * the Free Software Foundation, either version 3 of the License, or
  15. * (at your option) any later version.
  16. *
  17. * This program is distributed in the hope that it will be useful,
  18. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  19. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  20. * GNU General Public License for more details.
  21. *
  22. * You should have received a copy of the GNU General Public License
  23. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  24. */
  25. #ifndef TESTS_MIXED_GRAPH_MANAGER_HPP
  26. #define TESTS_MIXED_GRAPH_MANAGER_HPP 1
  27. #include <common/scheduler/VectorScheduler.hpp>
  28. #include <common/scheduler/HeapScheduler.hpp>
  29. #include <common/Trace.hpp>
  30. #include <dtss/Coordinator.hpp>
  31. #include <dtss/GraphManager.hpp>
  32. #include <dtss/Simulator.hpp>
  33. #include <pdevs/Coordinator.hpp>
  34. #include <pdevs/GraphManager.hpp>
  35. #include <pdevs/Simulator.hpp>
  36. #include <tests/mixed/models.hpp>
  37. namespace paradevs { namespace tests { namespace mixed {
  38. struct LastBagPolicy
  39. {
  40. const common::Bag < MyTime >& bag() const
  41. { return _bag; }
  42. virtual void operator()(typename MyTime::type /* t */,
  43. const common::ExternalEvent < MyTime >& event,
  44. typename MyTime::type /* tl */,
  45. typename MyTime::type /* tn */)
  46. {
  47. _bag.clear();
  48. _bag.push_back(event);
  49. }
  50. private:
  51. common::Bag < MyTime > _bag;
  52. };
  53. struct IgnorePolicy
  54. {
  55. const common::Bag < MyTime >& bag() const
  56. { return _bag; }
  57. virtual void operator()(typename MyTime::type /* t */,
  58. const common::ExternalEvent < MyTime >& /* event */,
  59. typename MyTime::type /* tl */,
  60. typename MyTime::type /* tn */)
  61. { }
  62. private:
  63. common::Bag < MyTime > _bag;
  64. };
  65. class S1GraphManager :
  66. public pdevs::GraphManager < MyTime, paradevs::common::NoParameters >
  67. {
  68. public:
  69. S1GraphManager(common::Coordinator < MyTime >* coordinator,
  70. const paradevs::common::NoParameters& parameters) :
  71. pdevs::GraphManager < MyTime,
  72. paradevs::common::NoParameters >(
  73. coordinator, parameters),
  74. a("a1", NoParameters()), b("b1", NoParameters())
  75. {
  76. add_child(&a);
  77. add_child(&b);
  78. add_link(&a, "out", &b, "in");
  79. add_link(&b, "out", coordinator, "out");
  80. }
  81. virtual ~S1GraphManager()
  82. { }
  83. private:
  84. pdevs::Simulator < MyTime, A1, NoParameters > a;
  85. pdevs::Simulator < MyTime, B1, NoParameters > b;
  86. };
  87. class S2GraphManager :
  88. public dtss::GraphManager < MyTime, paradevs::common::NoParameters >
  89. {
  90. public:
  91. S2GraphManager(common::Coordinator < MyTime >* coordinator,
  92. const paradevs::common::NoParameters& parameters) :
  93. dtss::GraphManager < MyTime,
  94. paradevs::common::NoParameters >(
  95. coordinator, parameters),
  96. a("a2", 20, NoParameters()), b("b2", 20, NoParameters())
  97. {
  98. add_child(&a);
  99. add_child(&b);
  100. add_link(&a, "out", &b, "in");
  101. add_link(coordinator, "in", &a, "in");
  102. }
  103. virtual ~S2GraphManager()
  104. { }
  105. private:
  106. dtss::Simulator < MyTime, A2, NoParameters > a;
  107. dtss::Simulator < MyTime, B2, NoParameters > b;
  108. };
  109. class RootGraphManager :
  110. public pdevs::GraphManager < MyTime, paradevs::common::NoParameters >
  111. {
  112. public:
  113. RootGraphManager(common::Coordinator < MyTime >* coordinator,
  114. const paradevs::common::NoParameters& parameters) :
  115. pdevs::GraphManager < MyTime,
  116. paradevs::common::NoParameters >(
  117. coordinator, parameters),
  118. S1("S1", paradevs::common::NoParameters(),
  119. paradevs::common::NoParameters()),
  120. S2("S2", paradevs::dtss::Parameters < MyTime >(20),
  121. paradevs::common::NoParameters())
  122. {
  123. add_child(&S1);
  124. add_child(&S2);
  125. add_link(&S1, "out", &S2, "in");
  126. }
  127. virtual ~RootGraphManager()
  128. { }
  129. private:
  130. pdevs::Coordinator < MyTime,
  131. paradevs::common::scheduler::VectorScheduler <
  132. MyTime >,
  133. S1GraphManager,
  134. paradevs::common::NoParameters,
  135. paradevs::common::NoParameters > S1;
  136. dtss::Coordinator < MyTime,
  137. LastBagPolicy,
  138. S2GraphManager,
  139. paradevs::dtss::Parameters < MyTime >,
  140. paradevs::common::NoParameters > S2;
  141. };
  142. template < int size >
  143. class LinearGraphManager :
  144. public pdevs::GraphManager < MyTime, paradevs::common::NoParameters >
  145. {
  146. public:
  147. LinearGraphManager(common::Coordinator < MyTime >* coordinator,
  148. const paradevs::common::NoParameters& parameters) :
  149. pdevs::GraphManager < MyTime,
  150. paradevs::common::NoParameters >(
  151. coordinator, parameters)
  152. {
  153. for (unsigned int i = 1; i <= size; ++i) {
  154. std::ostringstream ss;
  155. ss << "a" << i;
  156. _models.push_back(
  157. new pdevs::Simulator < MyTime, Beep, NoParameters >(
  158. ss.str(), NoParameters()));
  159. }
  160. for (unsigned int i = 0; i < size; ++i) {
  161. add_child(_models[i]);
  162. }
  163. for (unsigned int i = 0; i < size - 1; ++i) {
  164. add_link(_models[i], "out", _models[i + 1], "in");
  165. }
  166. }
  167. virtual ~LinearGraphManager()
  168. {
  169. for (unsigned int i = 0; i < size; ++i) {
  170. delete _models[i];
  171. }
  172. }
  173. private:
  174. std::vector < pdevs::Simulator < MyTime, Beep, NoParameters >* > _models;
  175. };
  176. class Linear2GraphManager :
  177. public pdevs::GraphManager < MyTime, paradevs::common::NoParameters >
  178. {
  179. public:
  180. Linear2GraphManager(common::Coordinator < MyTime >* coordinator,
  181. const paradevs::common::NoParameters& parameters) :
  182. pdevs::GraphManager < MyTime,
  183. paradevs::common::NoParameters >(
  184. coordinator, parameters)
  185. {
  186. for (unsigned int i = 1; i <= 100; ++i) {
  187. std::ostringstream ss;
  188. ss << "a" << i;
  189. _models.push_back(
  190. new pdevs::Simulator < MyTime, Beep, NoParameters >(
  191. ss.str(), NoParameters()));
  192. }
  193. for (unsigned int i = 0; i < 100; ++i) {
  194. add_child(_models[i]);
  195. }
  196. for (unsigned int i = 0; i < 99; ++i) {
  197. add_link(_models[i], "out", _models[i + 1], "in");
  198. }
  199. add_link(coordinator, "in", _models[0], "in");
  200. add_link(_models[49], "out", coordinator, "out");
  201. }
  202. virtual ~Linear2GraphManager()
  203. {
  204. for (unsigned int i = 0; i < 100; ++i) {
  205. delete _models[i];
  206. }
  207. }
  208. private:
  209. std::vector < pdevs::Simulator < MyTime, Beep, NoParameters >* > _models;
  210. };
  211. class Root2GraphManager :
  212. public pdevs::GraphManager < MyTime, paradevs::common::NoParameters >
  213. {
  214. public:
  215. Root2GraphManager(common::Coordinator < MyTime >* coordinator,
  216. const paradevs::common::NoParameters& parameters) :
  217. pdevs::GraphManager < MyTime,
  218. paradevs::common::NoParameters >(
  219. coordinator, parameters),
  220. S1("S1", paradevs::common::NoParameters(),
  221. paradevs::common::NoParameters()),
  222. S2("S2", paradevs::common::NoParameters(),
  223. paradevs::common::NoParameters())
  224. {
  225. add_child(&S1);
  226. add_child(&S2);
  227. add_link(&S1, "out", &S2, "in");
  228. }
  229. virtual ~Root2GraphManager()
  230. { }
  231. private:
  232. pdevs::Coordinator < MyTime,
  233. paradevs::common::scheduler::HeapScheduler <
  234. MyTime >,
  235. Linear2GraphManager,
  236. paradevs::common::NoParameters,
  237. paradevs::common::NoParameters > S1;
  238. pdevs::Coordinator < MyTime,
  239. paradevs::common::scheduler::HeapScheduler <
  240. MyTime >,
  241. Linear2GraphManager,
  242. paradevs::common::NoParameters,
  243. paradevs::common::NoParameters > S2;
  244. };
  245. class Root3GraphManager :
  246. public pdevs::GraphManager < MyTime, paradevs::common::NoParameters >
  247. {
  248. public:
  249. Root3GraphManager(common::Coordinator < MyTime >* coordinator,
  250. const paradevs::common::NoParameters& parameters) :
  251. pdevs::GraphManager < MyTime,
  252. paradevs::common::NoParameters >(
  253. coordinator, parameters),
  254. S1("S1", paradevs::common::NoParameters(),
  255. paradevs::common::NoParameters()),
  256. S2("S2", paradevs::common::NoParameters(),
  257. paradevs::common::NoParameters())
  258. {
  259. add_child(&S1);
  260. add_child(&S2);
  261. add_link(&S1, "out", &S2, "in");
  262. }
  263. virtual ~Root3GraphManager()
  264. { }
  265. private:
  266. pdevs::Coordinator < MyTime,
  267. paradevs::common::scheduler::VectorScheduler <
  268. MyTime >,
  269. Linear2GraphManager,
  270. paradevs::common::NoParameters,
  271. paradevs::common::NoParameters > S1;
  272. pdevs::Coordinator < MyTime,
  273. paradevs::common::scheduler::VectorScheduler <
  274. MyTime >,
  275. Linear2GraphManager,
  276. paradevs::common::NoParameters,
  277. paradevs::common::NoParameters > S2;
  278. };
  279. } } } // namespace paradevs tests mixed
  280. #endif