::TestApplication class | Engine::FileMsgStorageT< FileT > | friend |
BACKUP_STORAGE enum value | Engine::MsgStorage | |
clear() | Engine::MsgStorage | virtual |
clearFixMsgs(FixMsgs &aMsgs) | Engine::MsgStorage | protected |
currentConnectionType() const | Engine::MsgStorage | |
currentConnectionType_ | Engine::MsgStorage | protected |
FileMsgStorageT(StorageType type, const std::string &baseName, FileT &outFile, FileT &outIndexFile, FileT &inFile, FileT &inIndexFile, Utils::FilePropertiesT< System::FileEx > *configInfo, bool flushStreams, StorageMgr::PersistentSessionInfo *info) | Engine::FileMsgStorageT< FileT > | |
FixMsgs typedef | Engine::MsgStorage | |
getBaseFilePath() const | Engine::FileMsgStorageT< FileT > | virtual |
getBoolConfigInfo(const std::string &aKey, bool *aValue) const | Engine::FileMsgStorageT< FileT > | virtual |
getConfigInfo(const std::string &aKey, std::string *val) const | Engine::FileMsgStorageT< FileT > | virtual |
getInSeqNum() | Engine::FileMsgStorageT< FileT > | virtual |
getIntConfigInfo(const std::string &aKey, int *aValue) const | Engine::FileMsgStorageT< FileT > | virtual |
getMaxSeqNum() | Engine::FileMsgStorageT< FileT > | virtual |
getMinSeqNum() | Engine::FileMsgStorageT< FileT > | virtual |
getRejectStorage() | Engine::FileMsgStorageT< FileT > | virtual |
getSessionGlobalID() const | Engine::FileMsgStorageT< FileT > | virtual |
getSessionInternalState() const | Engine::FileMsgStorageT< FileT > | virtual |
getStoredInSeqNum() const | Engine::FileMsgStorageT< FileT > | |
getStoredOutSeqNum() const | Engine::FileMsgStorageT< FileT > | |
hasRejectedMessage() | Engine::FileMsgStorageT< FileT > | virtual |
isPersistentStorage() const | Engine::FileMsgStorageT< FileT > | virtual |
isStorageCorrupted() const | Engine::FileMsgStorageT< FileT > | virtual |
load(FIXVersion preferredVersion=NA) | Engine::FileMsgStorageT< FileT > | |
loadInMemoryCache(ToBeResentCollection &toBeResent, int beginSeqNum, int endSeqNum, int currentOutSeqNum) | Engine::FileMsgStorageT< FileT > | |
logLocal(StorableMsg const *pMsg, const RawMsg &aRawMsg) | Engine::FileMsgStorageT< FileT > | virtual |
logLocal(StorableMsg const *pMsg, const char *pRawMsg, int size) | Engine::FileMsgStorageT< FileT > | virtual |
logRemote(StorableMsg const *pMsg, const RawMsg &rawMsg) | Engine::FileMsgStorageT< FileT > | virtual |
logRemote(StorableMsg const *pMsg, const char *pRawMsg, int size) | Engine::FileMsgStorageT< FileT > | virtual |
markAsTerminated(bool correctlyTerminated) | Engine::FileMsgStorageT< FileT > | virtual |
markRejected(const RawMsg &msg) | Engine::FileMsgStorageT< FileT > | virtual |
MsgStorage(StorageType type) | Engine::MsgStorage | |
OutgoingMessages typedef | Engine::MsgStorage | |
prepareLocalRetriving(int beginSeqNum, int endSeqNum, int currentOutSeqNum) | Engine::FileMsgStorageT< FileT > | virtual |
PRIMARY_STORAGE enum value | Engine::MsgStorage | |
rebuildIndex(const std::string &logPath, const std::string &idxPath, const RestoreOptions &options) | Engine::FileMsgStorageT< FileT > | protectedvirtual |
rebuildIndexS(const std::string &logPath, const std::string &idxPath, const RestoreOptions &options) | Engine::FileMsgStorageT< FileT > | static |
RejectedMapT typedef | Engine::FileMsgStorageT< FileT > | |
retrieveLocal(CacheHolderBase *cacheHolder, ProtocolID protocolID, MsgList *pMsgs, int aBeginSeqNum, int aEndSeqNum=0, FIXVersion preferredVersion=NA) | Engine::FileMsgStorageT< FileT > | |
retrieveLocal(int outSeqNum, std::string *msg, int currentOutSeqNum) | Engine::FileMsgStorageT< FileT > | virtual |
Engine::MsgStorage::retrieveLocal(CacheHolderBase *cacheHolder, ProtocolID protocolID, std::vector< FIXMessage * > *apMsgs, int aBeginSeqNum, int aEndSeqNum=0, FIXVersion preferredVersion=NA)=0 | Engine::MsgStorage | pure virtual |
retrieveRejectedMessages(Utils::Strings *pMessages) | Engine::FileMsgStorageT< FileT > | virtual |
retrieveRemote(ProtocolID protocolID, MsgList *pMessages, const MsgTypes &msgTypes, const FixFieldsList &fieldFilter, int beginSeqNum, int endSeqNum=0, FIXVersion fixVersion=NA) | Engine::FileMsgStorageT< FileT > | |
Engine::MsgStorage::retrieveRemote(ProtocolID protocolID, std::vector< FIXMessage * > *pMessages, const MsgTypes &msgTypes, const std::vector< FixField > &fieldFilter, int beginSeqNum, int endSeqNum=0, FIXVersion fixVersion=NA)=0 | Engine::MsgStorage | pure virtual |
SessionInternalStateNA | Engine::MsgStorage | static |
setBoolConfigInfo(const std::string &aKey, bool aValue) | Engine::FileMsgStorageT< FileT > | virtual |
setConfigInfo(const std::string &aKey, const std::string &val) | Engine::FileMsgStorageT< FileT > | virtual |
setIntConfigInfo(const std::string &aKey, int aValue) | Engine::FileMsgStorageT< FileT > | virtual |
setLastSentSeqNum(int value) | Engine::MsgStorage | virtual |
setMaxRemoteSeqNum(int msgSeqNum) | Engine::FileMsgStorageT< FileT > | virtual |
setMinSeqNum(int msgSeqNum) | Engine::FileMsgStorageT< FileT > | virtual |
setRemoteSeqNum(int msgSeqNum) | Engine::FileMsgStorageT< FileT > | virtual |
setSessionGlobalID(const System::u64 globalID) | Engine::FileMsgStorageT< FileT > | virtual |
setSessionInternalState(const System::u64 internalState) | Engine::FileMsgStorageT< FileT > | virtual |
StorageType enum name | Engine::MsgStorage | |
syncMessageStorage() | Engine::FileMsgStorageT< FileT > | virtual |
TestSeqNo class | Engine::FileMsgStorageT< FileT > | friend |
ToBeResentCollection typedef | Engine::FileMsgStorageT< FileT > | |
tryMarkRejected(const RawMsg &msg, const ToBeResentCollection &toBeResent) | Engine::FileMsgStorageT< FileT > | |
unmarkRejected(const RawMsg &msg, const RawMsg &newMsg) | Engine::FileMsgStorageT< FileT > | virtual |
~FileMsgStorageT() | Engine::FileMsgStorageT< FileT > | virtual |
~MsgStorage() | Engine::MsgStorage | virtual |
~RejectMsgStorage() | Engine::RejectMsgStorage | inlinevirtual |