Trace.hpp 9.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351
  1. /**
  2. * @file utils/Trace.hpp
  3. * @author See the AUTHORS file
  4. */
  5. /*
  6. * Copyright (C) 2012-2017 ULCO http://www.univ-littoral.fr
  7. *
  8. * This program is free software: you can redistribute it and/or modify
  9. * it under the terms of the GNU General Public License as published by
  10. * the Free Software Foundation, either version 3 of the License, or
  11. * (at your option) any later version.
  12. *
  13. * This program is distributed in the hope that it will be useful,
  14. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. * GNU General Public License for more details.
  17. *
  18. * You should have received a copy of the GNU General Public License
  19. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  20. */
  21. #ifndef ARTIS_UTILS_TRACE
  22. #define ARTIS_UTILS_TRACE
  23. #include <algorithm>
  24. #include <iterator>
  25. #include <memory>
  26. #include <mutex>
  27. #include <sstream>
  28. #include <string>
  29. #include <vector>
  30. #include <artis/utils/DateTime.hpp>
  31. #include <artis/kernel/Any.hpp>
  32. #if WIN32
  33. #include <iso646.h>
  34. #endif
  35. namespace artis { namespace utils {
  36. enum TraceType { NONE = 0, CHECK, CONSTRUCT, SUBMODEL_ADD, INTERNAL_DECL,
  37. EXTERNAL_DECL, INTERNAL_LINK, INIT, START, BEFORE_COMPUTE,
  38. COMPUTE, PUT, AFTER_COMPUTE, DESTRUCT, KERNEL};
  39. static const std::vector <std::string> TraceTypesStr = {
  40. "none", "check", "construct", "submodel_add", "internal_decl",
  41. "external_decl", "internal_link", "init", "start", "before_compute",
  42. "compute", "put", "after_compute", "destruct", "kernel"};
  43. class KernelInfo
  44. {
  45. public:
  46. const std::string& var() const {return _var;}
  47. std::string value() const {return _value;}
  48. std::string tgt_model() const {return _tgt_model;}
  49. std::string tgt_internal_var() const {return _tgt_internal_var;}
  50. bool internal_var() const {return _internal_var;}
  51. bool empty() const {return _empty;}
  52. KernelInfo() :
  53. _var(""), _internal_var(false), _value(""),
  54. _tgt_model(""), _tgt_internal_var(""), _empty(true)
  55. { }
  56. KernelInfo(const std::string& var, bool internal_var,
  57. const std::string& value) :
  58. _var(var), _internal_var(internal_var), _value(value),
  59. _tgt_model(""), _tgt_internal_var(""), _empty(false)
  60. { }
  61. KernelInfo(const std::string& var, const std::string& tgt_model,
  62. const std::string& tgt_internal_var) :
  63. _var(var), _internal_var(true), _value(""),
  64. _tgt_model(tgt_model), _tgt_internal_var(tgt_internal_var),
  65. _empty(false)
  66. { }
  67. KernelInfo(const std::string& var, bool internal_var) :
  68. _var(var), _internal_var(internal_var), _value(""),
  69. _tgt_model(""), _tgt_internal_var(""), _empty(false)
  70. { }
  71. KernelInfo(const std::string& tgt_model) :
  72. _var(""), _internal_var(false), _value(""),
  73. _tgt_model(tgt_model), _tgt_internal_var(""),
  74. _empty(false)
  75. { }
  76. std::string to_string() const {
  77. std::ostringstream ss;
  78. if( not _var.empty() ){
  79. ss << ":";
  80. if (not _internal_var)
  81. ss << "*";
  82. ss << _var;
  83. }
  84. if( not _value.empty()) {
  85. ss << "=" << _value;
  86. }
  87. if(not _tgt_model.empty()) {
  88. ss << " -> " << _tgt_model;
  89. if(not _tgt_internal_var.empty()) {
  90. ss << ":" << _tgt_internal_var;
  91. }
  92. }
  93. return ss.str();
  94. }
  95. private:
  96. std::string _var;
  97. bool _internal_var;
  98. std::string _value;
  99. std::string _tgt_model;
  100. std::string _tgt_internal_var;
  101. bool _empty;
  102. };
  103. template < class Time >
  104. class TraceElement
  105. {
  106. public:
  107. TraceElement() : _time(Time::null), _type(NONE)
  108. { }
  109. TraceElement(const std::string& model_name, typename Time::type time,
  110. TraceType type) :
  111. _model_name(model_name), _time(time), _type(type)
  112. { }
  113. virtual ~TraceElement()
  114. { }
  115. const std::string& get_comment() const
  116. { return _comment; }
  117. const std::string& get_model_name() const
  118. { return _model_name; }
  119. typename Time::type get_time() const
  120. { return _time; }
  121. TraceType get_type() const
  122. { return _type; }
  123. const KernelInfo& get_kernel_info() const
  124. { return _kernel_info; }
  125. void set_comment(const std::string& comment)
  126. { _comment = comment; }
  127. void set_kernel_info(const KernelInfo& info)
  128. { _kernel_info = info; }
  129. private:
  130. std::string _model_name;
  131. typename Time::type _time;
  132. TraceType _type;
  133. std::string _comment;
  134. KernelInfo _kernel_info;
  135. };
  136. template < class Time >
  137. class TraceElements : public std::vector < TraceElement < Time > >
  138. {
  139. public:
  140. TraceElements()
  141. { }
  142. virtual ~TraceElements()
  143. { }
  144. TraceElements filter_model_name(
  145. const std::string& model_name) const
  146. {
  147. TraceElements < Time > result;
  148. std::copy_if(TraceElements < Time >::begin(),
  149. TraceElements < Time >::end(), std::back_inserter(result),
  150. [model_name](TraceElement < Time > const & x)
  151. { return x.get_model_name() == model_name; });
  152. return result;
  153. }
  154. TraceElements filter_time(typename Time::type time) const
  155. {
  156. TraceElements result;
  157. std::copy_if(TraceElements < Time >::begin(),
  158. TraceElements < Time >::end(), std::back_inserter(result),
  159. [time](TraceElement < Time > const & x)
  160. { return x.get_time() == time; });
  161. return result;
  162. }
  163. TraceElements filter_type(TraceType type) const
  164. {
  165. TraceElements result;
  166. std::copy_if(TraceElements < Time >::begin(),
  167. TraceElements < Time >::end(), std::back_inserter(result),
  168. [type](TraceElement < Time > const & x)
  169. { return x.get_type() == type; });
  170. return result;
  171. }
  172. std::string to_string(artis::utils::DateFormat date_format = artis::utils::DATE_FORMAT_EXTENDED) const
  173. {
  174. std::ostringstream ss;
  175. for (typename TraceElements < Time >::const_iterator it =
  176. TraceElements < Time >::begin();
  177. it != TraceElements < Time >::end(); ++it) {
  178. ss << "TRACE";
  179. if(it->get_time() != Time::null) {
  180. ss << "(" << utils::DateTime::toJulianDayFmt(it->get_time(), date_format) << ")";
  181. }
  182. ss << ": ";
  183. ss << "<" + TraceTypesStr[it->get_type()] + ">";
  184. ss << " " << it->get_model_name();
  185. if(not it->get_kernel_info().empty()) {
  186. ss << it->get_kernel_info().to_string();
  187. }
  188. if (not it->get_comment().empty()) {
  189. ss << " => " << it->get_comment();
  190. }
  191. ss << std::endl;
  192. }
  193. return ss.str();
  194. }
  195. };
  196. template < class Time >
  197. class Trace
  198. {
  199. public:
  200. virtual ~Trace()
  201. { }
  202. static Trace& trace()
  203. {
  204. std::call_once(_flag, [] ()
  205. { _instance.reset(new Trace()); std::cout << "Trace singleton done" << std::endl;}
  206. );
  207. return *_instance;
  208. }
  209. void clear()
  210. { _trace.clear(); }
  211. const TraceElements < Time >& elements() const
  212. { return _trace; }
  213. void flush()
  214. {
  215. if (_sstream) {
  216. _element.set_comment(_sstream->str());
  217. delete _sstream;
  218. _sstream = 0;
  219. }
  220. _trace.push_back(_element);
  221. }
  222. std::mutex& mutex()
  223. { return _mutex; }
  224. void set_element(const TraceElement < Time >& element)
  225. { _element = element; }
  226. void set_kernel_info(const KernelInfo& info)
  227. { _element.set_kernel_info(info); }
  228. std::ostringstream& sstream()
  229. {
  230. if (_sstream == 0) {
  231. _sstream = new std::ostringstream();
  232. }
  233. return *_sstream;
  234. }
  235. private:
  236. Trace()
  237. { _sstream = 0; }
  238. static std::shared_ptr < Trace < Time > > _instance;
  239. static std::once_flag _flag;
  240. TraceElements < Time > _trace;
  241. TraceElement < Time > _element;
  242. std::ostringstream* _sstream;
  243. std::mutex _mutex;
  244. };
  245. } }
  246. template < class Time >
  247. artis::utils::Trace < Time >& operator<<(
  248. artis::utils::Trace < Time >& trace,
  249. const artis::utils::TraceElement < Time >& e)
  250. {
  251. std::lock_guard < std::mutex > lock(trace.mutex());
  252. trace.set_element(e);
  253. return trace;
  254. }
  255. template < class Time >
  256. artis::utils::Trace < Time >& operator<<(
  257. artis::utils::Trace < Time >& trace,
  258. const artis::utils::KernelInfo& info)
  259. {
  260. std::lock_guard < std::mutex > lock(trace.mutex());
  261. trace.set_kernel_info(info);
  262. return trace;
  263. }
  264. template < class Time >
  265. artis::utils::Trace < Time >& operator<<(
  266. artis::utils::Trace < Time >& trace,
  267. const std::string& str)
  268. {
  269. std::lock_guard < std::mutex > lock(trace.mutex());
  270. trace.sstream() << str;
  271. return trace;
  272. }
  273. template < class Time >
  274. artis::utils::Trace < Time >& operator<<(
  275. artis::utils::Trace < Time >& trace,
  276. typename Time::type t)
  277. {
  278. std::lock_guard < std::mutex > lock(trace.mutex());
  279. trace.sstream() << t;
  280. return trace;
  281. }
  282. template < class Time >
  283. std::shared_ptr < artis::utils::Trace < Time > >
  284. artis::utils::Trace < Time >::_instance;
  285. template < class Time >
  286. std::once_flag artis::utils::Trace < Time >::_flag;
  287. #endif