TraceWriter.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_core_tracing_TraceWriter_hpp
#define anna_core_tracing_TraceWriter_hpp

#include <vector>

#include <anna/core/mt/NRMutex.hpp>
#include <anna/core/tracing/Logger.hpp>
#include <anna/config/defines.hpp>
#include <anna/core/util/Microsecond.hpp>

namespace anna {

class Configuration;
class TraceWriterObserver;

class TraceWriter : public Logger::Writer {
public:
  static const int DefaultMaxKBSize = 4192 * 1024;

  TraceWriter();

  TraceWriter(const char* fileName, const int maxSize);

  int getMaxSize() const { return a_maxSize; }

  void setup(const char* fileName, const Configuration& configuration) ;

  void setup(const char* fileName, const int maxSize = 0, const bool clean = true) ;

  void printResume() ;

  void attach(TraceWriterObserver* observer) ;

private:
  typedef std::vector <TraceWriterObserver*>::iterator observer_iterator;

  static const int ErrorStream = 2;

  class GuardNoLog {
  public:
    GuardNoLog(NRMutex& mutex) : a_mutex(mutex) { mutex.lock(); }
    ~GuardNoLog() { a_mutex.unlock(); }
  private:
    NRMutex& a_mutex;
  };

  std::string a_outputFile;
  std::string a_outputOldFile;
  int a_maxSize;
  int a_stream;
  Microsecond a_lastTime;
  std::string a_date;
  NRMutex a_mutex;
  std::vector <TraceWriterObserver*> a_observers;
  bool a_observed;

  observer_iterator observer_begin() { return a_observers.begin(); }
  observer_iterator observer_end() { return a_observers.end(); }

  static TraceWriterObserver* observer(observer_iterator& ii) { return *ii; }

  void initialize(const char*) { printResume(); }
  void do_write(int level, const char* text, ...) ;
  const char* getDate() ;
  int prepareOutput(const char* date) ;
};

}

#endif