Sirikata
|
#include <Trace.hpp>
Public Member Functions | |
~Trace () | |
Trace (const String &filename) | |
CREATE_TRACE_DECL (timestampMessageCreation, const Time &t, uint64 packetId, MessagePath path, ObjectMessagePort optionalMessageSourcePort=0, ObjectMessagePort optionalMessageDestPort=0) | |
CREATE_TRACE_DECL (timestampMessage, const Time &t, uint64 packetId, MessagePath path) | |
void | writeRecord (uint16 type_hint, BatchedBuffer::IOVec *data, uint32 iovcnt) |
template<typename T > | |
void | writeRecord (uint16 type_hint, const T &pl) |
void | prepareShutdown () |
void | shutdown () |
Static Public Member Functions | |
static void | InitOptions () |
Public Attributes | |
Drops | drops |
Private Member Functions | |
void | storageThread (const String &filename) |
Private Attributes | |
BatchedBuffer | data |
bool | mShuttingDown |
Thread * | mStorageThread |
Sirikata::AtomicValue< bool > | mFinishStorage |
Static Private Attributes | |
static OptionValue * | mLogMessage |
Sirikata::Trace::Trace::~Trace | ( | ) |
References drops, and Sirikata::Trace::Drops::output().
Sirikata::Trace::Trace::Trace | ( | const String & | filename | ) |
References mStorageThread, and storageThread().
Sirikata::Trace::Trace::CREATE_TRACE_DECL | ( | timestampMessageCreation | , |
const Time & | t, | ||
uint64 | packetId, | ||
MessagePath | path, | ||
ObjectMessagePort | optionalMessageSourcePort = 0 , |
||
ObjectMessagePort | optionalMessageDestPort = 0 |
||
) |
Sirikata::Trace::Trace::CREATE_TRACE_DECL | ( | timestampMessage | , |
const Time & | t, | ||
uint64 | packetId, | ||
MessagePath | path | ||
) |
void Sirikata::Trace::Trace::InitOptions | ( | ) | [static] |
References Sirikata::InitializeClassOptions::addOption(), mLogMessage, Sirikata::InitializeClassOptions::module(), SIRIKATA_OPTIONS_MODULE, and TRACE_MESSAGE_NAME.
Referenced by main().
void Sirikata::Trace::Trace::prepareShutdown | ( | ) |
References mShuttingDown.
void Sirikata::Trace::Trace::shutdown | ( | ) |
References data, Sirikata::BatchedBuffer::flush(), Sirikata::Thread::join(), mFinishStorage, and mStorageThread.
void Sirikata::Trace::Trace::storageThread | ( | const String & | filename | ) | [private] |
References data, Sirikata::BatchedBuffer::empty(), mFinishStorage, Sirikata::AtomicValue< T >::read(), Sirikata::Timer::sleep(), and Sirikata::BatchedBuffer::store().
Referenced by Trace().
void Sirikata::Trace::Trace::writeRecord | ( | uint16 | type_hint, |
BatchedBuffer::IOVec * | data, | ||
uint32 | iovcnt | ||
) |
References data, and Sirikata::BatchedBuffer::write().
void Sirikata::Trace::Trace::writeRecord | ( | uint16 | type_hint, |
const T & | pl | ||
) | [inline] |
BatchedBuffer Sirikata::Trace::Trace::data [private] |
Referenced by shutdown(), storageThread(), and writeRecord().
Referenced by ~Trace().
Sirikata::AtomicValue<bool> Sirikata::Trace::Trace::mFinishStorage [private] |
Referenced by shutdown(), and storageThread().
OptionValue * Sirikata::Trace::Trace::mLogMessage [static, private] |
Referenced by InitOptions().
bool Sirikata::Trace::Trace::mShuttingDown [private] |
Referenced by prepareShutdown().
Thread* Sirikata::Trace::Trace::mStorageThread [private] |
Referenced by shutdown(), and Trace().