B2BITS FIX Antenna HFT
1.0.16
|
#include <LogMsgFile.h>
Public Types | |
enum | { INVALID_MSG_HANDLE = -1 } |
typedef IndexFileT< FileT > ::Data::Flags | Flags |
typedef IndexFileT< FileT >::Offset | MsgHandle |
typedef std::map< MsgHandle, typename IndexFileT< FileT > ::Data > | MsgHandle2Data |
typedef FastFileT< FileT >::Offset | Offset |
typedef IndexFileT< FileT > ::Data::SeqNum | SeqNum |
Public Member Functions | |
void | close () |
void | closeHandle (MsgHandle handle) |
MsgHandle | find (SeqNum seqNum) |
MsgHandle | find (const std::string &msg) |
void | flush () |
LogFilePosT< FileT > | getCurrPos () |
IndexFileT< FileT >::Data | getData (MsgHandle handle) |
bool | isRejected (MsgHandle handle) |
void | load (MsgHandle handle, std::string &msg) |
void | load (const typename IndexFileT< FileT >::Data &data, std::string &msg) |
MsgHandle | log (const char *msg, System::u32 size, SeqNum seqNum, Flags flags, const PersistentData &persistentData, bool isTimestampsInLogsMode, bool flush=false, const char *custom_timestamp=0) |
LogFileT (FileT &file, FileT &indx, bool chunkAlloc) | |
void | markRejected (MsgHandle handle) |
void | markToBeResent (MsgHandle handle) |
bool | next (std::string &msg) |
bool | next (typename IndexFileT< FileT >::Data &data) |
bool | next (MsgHandle &handle) |
bool | next (MsgHandle &handle, typename IndexFileT< FileT >::Data &data) |
bool | prev (typename IndexFileT< FileT >::Data &data) |
bool | prev (MsgHandle &handle, typename IndexFileT< FileT >::Data &data) |
void | save (MsgHandle handle, const std::string &msg) |
void | save (const typename IndexFileT< FileT >::Data &data, const std::string &msg) |
void | seekTo (const LogFilePosT< FileT > &) |
void | sync () |
void | toBegin () |
bool | toBeResent (MsgHandle handle) |
void | toEnd () |
void | unmarkRejected (MsgHandle handle) |
void | unmarkToBeResent (MsgHandle handle) |
~LogFileT () | |
Static Public Member Functions | |
static bool | isRejected (typename IndexFileT< FileT >::Data &data) |
static bool | isValid (MsgHandle handle) |
static bool | toBeResent (typename IndexFileT< FileT >::Data &data) |
Protected Attributes | |
FastFileT< FileT > | file_ |
IndexFileT< FileT > | indx_ |
MsgHandle2Data | msgHandleCash_ |
Offset | nextWritePtr_ |
typedef IndexFileT<FileT>::Data::Flags Engine::LogFileT< FileT >::Flags |
typedef IndexFileT<FileT>::Offset Engine::LogFileT< FileT >::MsgHandle |
typedef std::map<MsgHandle, typename IndexFileT<FileT>::Data> Engine::LogFileT< FileT >::MsgHandle2Data |
typedef FastFileT<FileT>::Offset Engine::LogFileT< FileT >::Offset |
typedef IndexFileT<FileT>::Data::SeqNum Engine::LogFileT< FileT >::SeqNum |
Engine::LogFileT< FileT >::LogFileT | ( | FileT & | file, |
FileT & | indx, | ||
bool | chunkAlloc | ||
) |
Engine::LogFileT< FileT >::~LogFileT | ( | ) |
void Engine::LogFileT< FileT >::close | ( | ) |
void Engine::LogFileT< FileT >::closeHandle | ( | MsgHandle | handle | ) |
Engine::LogFileT< FileT >::MsgHandle Engine::LogFileT< FileT >::find | ( | SeqNum | seqNum | ) |
References Engine::IndexFileT< FileT >::Data::getSeqNum().
Engine::LogFileT< FileT >::MsgHandle Engine::LogFileT< FileT >::find | ( | const std::string & | msg | ) |
References Engine::IndexFileT< FileT >::Data::getMsgSize().
void Engine::LogFileT< FileT >::flush | ( | ) |
Engine::LogFilePosT< FileT > Engine::LogFileT< FileT >::getCurrPos | ( | ) |
Engine::IndexFileT< FileT >::Data Engine::LogFileT< FileT >::getData | ( | MsgHandle | handle | ) |
|
static |
References Engine::FLG_MSG_REJECTED, and Engine::IndexFileT< FileT >::Data::getFlags().
bool Engine::LogFileT< FileT >::isRejected | ( | MsgHandle | handle | ) |
|
static |
void Engine::LogFileT< FileT >::load | ( | MsgHandle | handle, |
std::string & | msg | ||
) |
void Engine::LogFileT< FileT >::load | ( | const typename IndexFileT< FileT >::Data & | data, |
std::string & | msg | ||
) |
Engine::LogFileT< FileT >::MsgHandle Engine::LogFileT< FileT >::log | ( | const char * | msg, |
System::u32 | size, | ||
SeqNum | seqNum, | ||
Flags | flags, | ||
const PersistentData & | persistentData, | ||
bool | isTimestampsInLogsMode, | ||
bool | flush = false , |
||
const char * | custom_timestamp = 0 |
||
) |
void Engine::LogFileT< FileT >::markRejected | ( | MsgHandle | handle | ) |
void Engine::LogFileT< FileT >::markToBeResent | ( | MsgHandle | handle | ) |
bool Engine::LogFileT< FileT >::next | ( | std::string & | msg | ) |
bool Engine::LogFileT< FileT >::next | ( | typename IndexFileT< FileT >::Data & | data | ) |
bool Engine::LogFileT< FileT >::next | ( | MsgHandle & | handle | ) |
bool Engine::LogFileT< FileT >::next | ( | MsgHandle & | handle, |
typename IndexFileT< FileT >::Data & | data | ||
) |
bool Engine::LogFileT< FileT >::prev | ( | typename IndexFileT< FileT >::Data & | data | ) |
bool Engine::LogFileT< FileT >::prev | ( | MsgHandle & | handle, |
typename IndexFileT< FileT >::Data & | data | ||
) |
void Engine::LogFileT< FileT >::save | ( | MsgHandle | handle, |
const std::string & | msg | ||
) |
void Engine::LogFileT< FileT >::save | ( | const typename IndexFileT< FileT >::Data & | data, |
const std::string & | msg | ||
) |
void Engine::LogFileT< FileT >::seekTo | ( | const LogFilePosT< FileT > & | pos | ) |
void Engine::LogFileT< FileT >::sync | ( | ) |
void Engine::LogFileT< FileT >::toBegin | ( | ) |
|
static |
bool Engine::LogFileT< FileT >::toBeResent | ( | MsgHandle | handle | ) |
void Engine::LogFileT< FileT >::toEnd | ( | ) |
void Engine::LogFileT< FileT >::unmarkRejected | ( | MsgHandle | handle | ) |
void Engine::LogFileT< FileT >::unmarkToBeResent | ( | MsgHandle | handle | ) |
|
protected |
|
protected |
Referenced by Engine::LogFileT< FileT >::LogFileT().
|
protected |
|
protected |
Referenced by Engine::LogFileT< FileT >::LogFileT().