B2BITS FIX Antenna HFT  1.0.17
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Engine::FileMsgStorageT< FileT > Member List

This is the complete list of members for Engine::FileMsgStorageT< FileT >, including all inherited members.

::TestApplication classEngine::FileMsgStorageT< FileT >friend
BACKUP_STORAGE enum valueEngine::MsgStorage
clear()Engine::MsgStoragevirtual
clearFixMsgs(FixMsgs &aMsgs)Engine::MsgStorageprotected
currentConnectionType() const Engine::MsgStorage
currentConnectionType_Engine::MsgStorageprotected
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 typedefEngine::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 typedefEngine::MsgStorage
prepareLocalRetriving(int beginSeqNum, int endSeqNum, int currentOutSeqNum)Engine::FileMsgStorageT< FileT >virtual
PRIMARY_STORAGE enum valueEngine::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 typedefEngine::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)=0Engine::MsgStoragepure 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)=0Engine::MsgStoragepure virtual
SessionInternalStateNAEngine::MsgStoragestatic
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::MsgStoragevirtual
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 nameEngine::MsgStorage
syncMessageStorage()Engine::FileMsgStorageT< FileT >virtual
TestSeqNo classEngine::FileMsgStorageT< FileT >friend
ToBeResentCollection typedefEngine::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::MsgStoragevirtual
~RejectMsgStorage()Engine::RejectMsgStorageinlinevirtual