B2BITS FIX Antenna HFT  1.0.16
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | Protected Attributes | Friends | List of all members
Engine::B2B_SEALED< FileT > Class Template Reference

New Incoming Connection. More...

#include <FileMsgStorage.h>

+ Inheritance diagram for Engine::B2B_SEALED< FileT >:
+ Collaboration diagram for Engine::B2B_SEALED< FileT >:

Public Types

typedef std::map< typename
LogFileT< FileT >::MsgHandle,
typename IndexFileT< FileT >
::Data > 
RejectedMapT
 
typedef std::map< typename
LogFileT< FileT >::SeqNum,
typename LogFileT< FileT >
::MsgHandle > 
ToBeResentCollection
 
- Public Types inherited from Engine::MsgStorage
typedef std::vector
< StorableMsg * > 
FixMsgs
 
typedef std::deque< std::string > OutgoingMessages
 
enum  StorageType { PRIMARY_STORAGE = 0, BACKUP_STORAGE }
 Defines type of the storage. More...
 
- Public Types inherited from Engine::Event
enum  Type {
  EVENT, ERROR_EVENT, NOTIFICATION, WARNING,
  SESSION_ERROR, PARSE_ERROR_IN_SESSION, NEW_INCOMING_CONNECTION, SESSION_NOTIFICATION,
  SESSION_WAS_CREATED, SESSION_WAS_CONNECTED, SESSION_WAS_CLOSED, SESSION_WAS_ESTABLISHED,
  SESSION_WAS_RESTORED, SYNCHRONIZATION_COMPLETE, SESSION_WARNING, LINK_ERROR_WAS_DETECTED,
  LINK_WAS_RESTORED, PERSISTENT_DATA_WERE_FOUND, DEBUG_MESSAGE, SESSION_DEBUG_MESSAGE
}
 Event types. More...
 

Public Member Functions

 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)
 Constructor. More...
 
virtual const std::string * getBaseFilePath () const B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual bool getBoolConfigInfo (const std::string &aKey, bool *aValue) const B2B_OVERRIDE
 Retrieves configuration information. More...
 
bool getConfigInfo (const std::string &aKey, std::string *val) const B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
int getInSeqNum () B2B_OVERRIDE
 
virtual bool getIntConfigInfo (const std::string &aKey, int *aValue) const B2B_OVERRIDE
 Retrieves configuration information. More...
 
int getMaxSeqNum () B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
int getMinSeqNum () B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual RejectMsgStoragegetRejectStorage () B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
const std::string * getSenderCompID () const
 Returns session's SenderCompID. More...
 
virtual System::u64 getSessionGlobalID () const
 
virtual System::u64 getSessionInternalState () const
 
int getStoredInSeqNum () const
 Returns current incoming seqNum from config. More...
 
int getStoredOutSeqNum () const
 Returns current outgoing seqNum from config. More...
 
const std::string * getTargetCompID () const
 Returns session's TargetCompID. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual Type getType () const B2B_OVERRIDE
 Returns the event type. More...
 
virtual bool hasRejectedMessage () B2B_OVERRIDE
 Reimplemented from RejectMsgStorage. More...
 
virtual bool isPersistentStorage () const B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual bool isStorageCorrupted () const B2B_OVERRIDE
 Checks if the storage is corrupted. More...
 
 LinkErrorWasDetected (const Session *sn, const char *reason)
 Constructor. More...
 
 LinkWasRestored (const Session *sn, const char *message)
 Constructor. More...
 
int load (FIXVersion preferredVersion=NA)
 Reimplemented from MsgStorage. More...
 
void loadInMemoryCache (ToBeResentCollection &toBeResent, int beginSeqNum, int endSeqNum, int currentOutSeqNum)
 
virtual bool logLocal (StorableMsg const *pMsg, const RawMsg &aRawMsg) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual bool logLocal (StorableMsg const *pMsg, const char *pRawMsg, int size) B2B_OVERRIDE
 Stores the given outgoing message and then destroys it. More...
 
virtual void logRemote (StorableMsg const *pMsg, const RawMsg &rawMsg) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual void logRemote (StorableMsg const *pMsg, const char *pRawMsg, int size) B2B_OVERRIDE
 Logs the message from the remote FIX engine. More...
 
void markAsTerminated (bool correctlyTerminated) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual bool markRejected (const RawMsg &msg) B2B_OVERRIDE
 Reimplemented from RejectMsgStorage. More...
 
 NewIncomingConnection (const std::string &remoreAddress, int remotePort, const std::string &localAddress, int localPort)
 Constructor. More...
 
 ParseErrorInSession (const Session *sn, const Utils::Exception &aReason)
 Constructor. More...
 
 PersistentDataWereFound (const Session *session)
 Constructor. More...
 
 PersistentDataWereFound (const std::string &sender, const std::string &target, SessionRole role)
 
CacheHolderBaseprepareLocalRetriving (int beginSeqNum, int endSeqNum, int currentOutSeqNum) B2B_OVERRIDE
 Prepare for cache message walk process like a series of retrieveLocal() calls returns an object whose lifetime is bound to the whole series of retrieveLocal() calls when retrieveLocal() calls are complete, the object should be destroyed by the caller. More...
 
bool retrieveLocal (CacheHolderBase *cacheHolder, ProtocolID protocolID, MsgList *pMsgs, int aBeginSeqNum, int aEndSeqNum=0, FIXVersion preferredVersion=NA) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual bool retrieveLocal (int outSeqNum, std::string *msg, int currentOutSeqNum) B2B_OVERRIDE
 Locates sent message (with seqNum=outSeqNum) and returns it into msg. More...
 
virtual void retrieveRejectedMessages (Utils::Strings *pMessages) B2B_OVERRIDE
 Reimplemented from RejectMsgStorage. More...
 
void retrieveRemote (ProtocolID protocolID, MsgList *pMessages, const MsgTypes &msgTypes, const FixFieldsList &fieldFilter, int beginSeqNum, int endSeqNum=0, FIXVersion fixVersion=NA) B2B_OVERRIDE
 Fills input list with messages that satisfy selection criteria. More...
 
 SessionDebugMessage (const Session *pSn, const std::string &reason)
 Constructor. More...
 
 SessionDebugMessage (const std::string &sender, const std::string &target, const std::string &reason)
 
 SessionDebugMessage (const std::string &sender, const std::string &target, SessionRole role, const std::string &reason)
 
 SessionWasClosed (const Fast2FixSession *sn, const std::string &reason="")
 Constructor. More...
 
 SessionWasClosed (const std::string &sender, const std::string &target, SessionRole role, bool correctlyTerminated, const std::string &reason="")
 
 SessionWasCreated (const Session *sn)
 Constructor. More...
 
 SessionWasEstablished (const Session *sn)
 Constructor. More...
 
 SessionWasEstablished (const std::string &sender, const std::string &target, SessionRole role)
 
 SessionWasRestored (const Session *sn)
 Constructor. More...
 
virtual void setBoolConfigInfo (const std::string &aKey, bool aValue) B2B_OVERRIDE
 Sets the configuration information. More...
 
void setConfigInfo (const std::string &aKey, const std::string &val) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual void setIntConfigInfo (const std::string &aKey, int aValue) B2B_OVERRIDE
 Sets the configuration information. More...
 
virtual void setMaxRemoteSeqNum (int msgSeqNum) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual void setMinSeqNum (int msgSeqNum) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual void setRemoteSeqNum (int msgSeqNum) B2B_OVERRIDE
 Reimplemented from MsgStorage. More...
 
virtual void setSessionInternalState (const System::u64 internalState)
 
virtual void syncMessageStorage ()
 
bool tryMarkRejected (const RawMsg &msg, const ToBeResentCollection &toBeResent)
 
virtual bool unmarkRejected (const RawMsg &msg, const RawMsg &newMsg) B2B_OVERRIDE
 Reimplemented from RejectMsgStorage. More...
 
virtual ~FileMsgStorageT ()
 
virtual ~NewIncomingConnection ()
 Destructor. More...
 
virtual ~SessionDebugMessage ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::MsgStorage
virtual void clear ()
 Clears the storage. More...
 
StorageType currentConnectionType () const
 Returns type of the storage. More...
 
 MsgStorage (StorageType type)
 Constructor. More...
 
virtual bool retrieveLocal (CacheHolderBase *cacheHolder, ProtocolID protocolID, std::vector< FIXMessage * > *apMsgs, int aBeginSeqNum, int aEndSeqNum=0, FIXVersion preferredVersion=NA)=0
 Locates sent messages. More...
 
virtual void retrieveRemote (ProtocolID protocolID, std::vector< FIXMessage * > *pMessages, const MsgTypes &msgTypes, const std::vector< FixField > &fieldFilter, int beginSeqNum, int endSeqNum=0, FIXVersion fixVersion=NA)=0
 Fills input list with messages that satisfy selection criteria. More...
 
virtual void setLastSentSeqNum (int value)
 Updates MsgSeqNum of outgoing messages. More...
 
virtual ~MsgStorage ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::RejectMsgStorage
virtual ~RejectMsgStorage ()
 
- Public Member Functions inherited from Engine::DebugMessage
 DebugMessage (const std::string &msg)
 Constructor. More...
 
virtual const std::string * what () const B2B_OVERRIDE
 Describes the event. More...
 
virtual ~DebugMessage ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::SessionNotification
const std::string * getSenderCompID () const
 Returns session's SenderCompID. More...
 
const std::string * getTargetCompID () const
 Returns session's TargetCompID. More...
 
 SessionNotification (const Session *pSn)
 Constructor. More...
 
 SessionNotification (const Session *pSn, const std::string &reason)
 Constructor. More...
 
 SessionNotification (const std::string &sender, const std::string &target, SessionRole role, const std::string &reason)
 
virtual ~SessionNotification ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::Notification
 Notification (const std::string &msg)
 Constructor. More...
 
virtual const std::string * what () const B2B_OVERRIDE
 Describes the event. More...
 
virtual ~Notification ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::SessionWarning
const std::string * getSenderCompID () const
 Returns session's SenderCompID. More...
 
const std::string * getTargetCompID () const
 Returns session's TargetCompID. More...
 
 SessionWarning (const std::string &sender, const std::string &target, const std::string &reason)
 Constructor. More...
 
 SessionWarning (const Session *pSn, const std::string &reason)
 
virtual ~SessionWarning ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::Warning
 Warning (const std::string &msg)
 Constructor. More...
 
virtual const std::string * what () const B2B_OVERRIDE
 Describes the event. More...
 
virtual ~Warning ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::SessionError
const std::string * getSenderCompID () const
 Returns session's SenderCompID. More...
 
const std::string * getTargetCompID () const
 Returns session's TargetCompID. More...
 
 SessionError (const Session *sn)
 Constructor. More...
 
 SessionError (const std::string &sender, const std::string &target, const std::string &aReason)
 Constructor. More...
 
 SessionError (const Session *sn, const std::string &aReason)
 
virtual const std::string * what () const B2B_OVERRIDE
 Describes the event. More...
 
virtual ~SessionError ()
 Destructor. More...
 
- Public Member Functions inherited from Engine::Error
 Error (const std::string &msg)
 Constructor. More...
 
virtual ~Error ()
 Destructor. More...
 

Static Public Member Functions

static bool rebuildIndexS (const std::string &logPath, const std::string &idxPath, const RestoreOptions &options)
 Store messages in range [aBeginSeqNum, aEndSeqNum] into the pMsgs container. More...
 

Protected Member Functions

virtual bool rebuildIndex (const std::string &logPath, const std::string &idxPath, const RestoreOptions &options) B2B_OVERRIDE
 
- Protected Member Functions inherited from Engine::MsgStorage
void clearFixMsgs (FixMsgs &aMsgs)
 Clears collection (delete all its elements). More...
 
- Protected Member Functions inherited from Engine::Event
virtual ~Event ()
 Destructor. More...
 

Protected Attributes

SessionRole role_
 
std::string sender_
 Sender. More...
 
std::string target_
 Target. More...
 
- Protected Attributes inherited from Engine::MsgStorage
StorageType currentConnectionType_
 
- Protected Attributes inherited from Engine::DebugMessage
std::string m_reason
 Contains std::string that describes the event. More...
 
- Protected Attributes inherited from Engine::SessionNotification
int role_
 Role. More...
 
std::string sender_
 Sender. More...
 
std::string target_
 Target. More...
 
- Protected Attributes inherited from Engine::Notification
std::string m_reason
 Contains std::string that describes the event. More...
 
- Protected Attributes inherited from Engine::Warning
std::string m_reason
 Contains std::string that describes the event. More...
 
- Protected Attributes inherited from Engine::Error
std::string m_reason
 Contains std::string that describes the event. More...
 

Friends

class ::TestApplication
 
class TestSeqNo
 

Additional Inherited Members

- Static Public Attributes inherited from Engine::MsgStorage
static const System::u64 SessionInternalStateNA = 0
 

Detailed Description

template<typename FileT>
class Engine::B2B_SEALED< FileT >

New Incoming Connection.

FileT message storage.

Represents debug message related to Session.

Session was established.

Session was restored from Persistent Message Storage.

A telecommunication link error was detected.

A telecommunication link was restored.

Session was closed.

Session was created.

Parse error was detected.

This event is fired when the persistent information about session is found.

Member Typedef Documentation

template<typename FileT >
typedef std::map<typename LogFileT<FileT>::MsgHandle, typename IndexFileT<FileT>::Data> Engine::B2B_SEALED< FileT >::RejectedMapT
template<typename FileT >
typedef std::map<typename LogFileT<FileT>::SeqNum, typename LogFileT<FileT>::MsgHandle> Engine::B2B_SEALED< FileT >::ToBeResentCollection

Constructor & Destructor Documentation

template<typename FileT >
virtual Engine::B2B_SEALED< FileT >::~NewIncomingConnection ( )
inlinevirtual

Destructor.

template<typename FileT >
virtual Engine::B2B_SEALED< FileT >::~SessionDebugMessage ( )
inlinevirtual

Destructor.

template<typename FileT >
virtual Engine::B2B_SEALED< FileT >::~FileMsgStorageT ( )
virtual

Member Function Documentation

template<typename FileT >
Engine::B2B_SEALED< FileT >::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 
)

Constructor.

Parameters
baseNameBase file name.
outFile- file to store outgoing messages.
outIndexFile- index file.
inFile- file to store incoming messages.
inIndexFile- index file.
flushStreams- if true then all input/output will be flushed after each operation.
template<typename FileT >
virtual const std::string* Engine::B2B_SEALED< FileT >::getBaseFilePath ( ) const
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::getBoolConfigInfo ( const std::string &  aKey,
bool *  aValue 
) const
virtual

Retrieves configuration information.

Parameters
aKey- parameter key
aValue- parameter result value
Returns
true if parameter is enabled

Implements Engine::MsgStorage.

template<typename FileT >
bool Engine::B2B_SEALED< FileT >::getConfigInfo ( const std::string &  aKey,
std::string *  val 
) const
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
int Engine::B2B_SEALED< FileT >::getInSeqNum ( )
virtual

Reimplemented from Engine::MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::getIntConfigInfo ( const std::string &  aKey,
int *  aValue 
) const
virtual

Retrieves configuration information.

Parameters
aKey- parameter key
aValue- parameter result value
Returns
true if parameter is enabled

Implements Engine::MsgStorage.

template<typename FileT >
int Engine::B2B_SEALED< FileT >::getMaxSeqNum ( )
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
int Engine::B2B_SEALED< FileT >::getMinSeqNum ( )
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual RejectMsgStorage* Engine::B2B_SEALED< FileT >::getRejectStorage ( )
virtual

Reimplemented from MsgStorage.

Reimplemented from Engine::MsgStorage.

template<typename FileT >
const std::string* Engine::B2B_SEALED< FileT >::getSenderCompID ( ) const
inline

Returns session's SenderCompID.

template<typename FileT >
virtual System::u64 Engine::B2B_SEALED< FileT >::getSessionGlobalID ( ) const
virtual

Reimplemented from Engine::MsgStorage.

template<typename FileT >
virtual System::u64 Engine::B2B_SEALED< FileT >::getSessionInternalState ( ) const
virtual

Reimplemented from Engine::MsgStorage.

template<typename FileT >
int Engine::B2B_SEALED< FileT >::getStoredInSeqNum ( ) const

Returns current incoming seqNum from config.

template<typename FileT >
int Engine::B2B_SEALED< FileT >::getStoredOutSeqNum ( ) const

Returns current outgoing seqNum from config.

template<typename FileT >
const std::string* Engine::B2B_SEALED< FileT >::getTargetCompID ( ) const
inline

Returns session's TargetCompID.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual Type Engine::B2B_SEALED< FileT >::getType ( ) const
inlinevirtual

Returns the event type.

Can be used instead of C++ RTTI.

Reimplemented from Engine::Notification.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::hasRejectedMessage ( )
virtual

Reimplemented from RejectMsgStorage.

Implements Engine::RejectMsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::isPersistentStorage ( ) const
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::isStorageCorrupted ( ) const
virtual

Checks if the storage is corrupted.

Returns
true if the storage contains corrupted messages, false otherwise

Implements Engine::MsgStorage.

template<typename FileT >
Engine::B2B_SEALED< FileT >::LinkErrorWasDetected ( const Session sn,
const char *  reason 
)

Constructor.

Parameters
snInstance of Session assigned with event
reasonMessage that describes event. Can be NULL;
template<typename FileT >
Engine::B2B_SEALED< FileT >::LinkWasRestored ( const Session sn,
const char *  message 
)

Constructor.

Parameters
snSession.
messagestd::string that describes this event.
template<typename FileT >
int Engine::B2B_SEALED< FileT >::load ( FIXVersion  preferredVersion = NA)

Reimplemented from MsgStorage.

Reimplemented from MsgStorage. Reads the messages from the message log.

Returns
the MsgSeq of the message that was read last; otherwise -1
template<typename FileT >
void Engine::B2B_SEALED< FileT >::loadInMemoryCache ( ToBeResentCollection toBeResent,
int  beginSeqNum,
int  endSeqNum,
int  currentOutSeqNum 
)
template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::logLocal ( StorableMsg const *  pMsg,
const RawMsg aRawMsg 
)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::logLocal ( StorableMsg const *  pMsg,
const char *  pRawMsg,
int  size 
)
virtual

Stores the given outgoing message and then destroys it.

Returns
false if the message with such sequence number already exists in the storage; otherwise true.
Parameters
apMsg- storage message
nSeqNum- message number
pRawMsg- message buffer pointer
size- message buffer size

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::logRemote ( StorableMsg const *  pMsg,
const RawMsg rawMsg 
)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::logRemote ( StorableMsg const *  pMsg,
const char *  pRawMsg,
int  size 
)
virtual

Logs the message from the remote FIX engine.

Parameters
msgSeqNum- message number
pRawMsg- message buffer pointer
size- message buffer size

Implements Engine::MsgStorage.

template<typename FileT >
void Engine::B2B_SEALED< FileT >::markAsTerminated ( bool  correctlyTerminated)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::markRejected ( const RawMsg msg)
virtual

Reimplemented from RejectMsgStorage.

Implements Engine::RejectMsgStorage.

template<typename FileT >
Engine::B2B_SEALED< FileT >::NewIncomingConnection ( const std::string &  remoreAddress,
int  remotePort,
const std::string &  localAddress,
int  localPort 
)

Constructor.

Parameters
remoreAddressRemote host address.
remotePortRemote port.
localAddressLocal host address.
localPortLocal port.
template<typename FileT >
Engine::B2B_SEALED< FileT >::ParseErrorInSession ( const Session sn,
const Utils::Exception aReason 
)

Constructor.

template<typename FileT >
Engine::B2B_SEALED< FileT >::PersistentDataWereFound ( const Session session)

Constructor.

Parameters
sessionInstance of Session assigned event with.
template<typename FileT >
Engine::B2B_SEALED< FileT >::PersistentDataWereFound ( const std::string &  sender,
const std::string &  target,
SessionRole  role 
)
template<typename FileT >
CacheHolderBase* Engine::B2B_SEALED< FileT >::prepareLocalRetriving ( int  beginSeqNum,
int  endSeqNum,
int  currentOutSeqNum 
)
virtual

Prepare for cache message walk process like a series of retrieveLocal() calls returns an object whose lifetime is bound to the whole series of retrieveLocal() calls when retrieveLocal() calls are complete, the object should be destroyed by the caller.

Returned pointer can have NULL value. To control the lifetime, should be used in conjunction with std::auto_ptr<> The implementaion would typically load the messages from an external storage to memory to prepare for a series of retrieveLocal() calls

Implements Engine::MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::rebuildIndex ( const std::string &  logPath,
const std::string &  idxPath,
const RestoreOptions options 
)
protectedvirtual

Implements Engine::MsgStorage.

template<typename FileT >
static bool Engine::B2B_SEALED< FileT >::rebuildIndexS ( const std::string &  logPath,
const std::string &  idxPath,
const RestoreOptions options 
)
static

Store messages in range [aBeginSeqNum, aEndSeqNum] into the pMsgs container.

template<typename FileT >
bool Engine::B2B_SEALED< FileT >::retrieveLocal ( CacheHolderBase cacheHolder,
ProtocolID  protocolID,
MsgList pMsgs,
int  aBeginSeqNum,
int  aEndSeqNum = 0,
FIXVersion  preferredVersion = NA 
)

Reimplemented from MsgStorage.

template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::retrieveLocal ( int  outSeqNum,
std::string *  msg,
int  currentOutSeqNum 
)
virtual

Locates sent message (with seqNum=outSeqNum) and returns it into msg.

Returns
true if message was found, false otherwize

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::retrieveRejectedMessages ( Utils::Strings pMessages)
virtual

Reimplemented from RejectMsgStorage.

Implements Engine::RejectMsgStorage.

template<typename FileT >
void Engine::B2B_SEALED< FileT >::retrieveRemote ( ProtocolID  protocolID,
MsgList pMessages,
const MsgTypes msgTypes,
const FixFieldsList fieldFilter,
int  beginSeqNum,
int  endSeqNum = 0,
FIXVersion  fixVersion = NA 
)

Fills input list with messages that satisfy selection criteria.

Warning
It's caller's responsibility to release returned messages.
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionDebugMessage ( const Session pSn,
const std::string &  reason 
)

Constructor.

template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionDebugMessage ( const std::string &  sender,
const std::string &  target,
const std::string &  reason 
)
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionDebugMessage ( const std::string &  sender,
const std::string &  target,
SessionRole  role,
const std::string &  reason 
)
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionWasClosed ( const Fast2FixSession *  sn,
const std::string &  reason = "" 
)

Constructor.

Parameters
snSession.
reasonReason of session closing.
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionWasClosed ( const std::string &  sender,
const std::string &  target,
SessionRole  role,
bool  correctlyTerminated,
const std::string &  reason = "" 
)
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionWasCreated ( const Session sn)

Constructor.

template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionWasEstablished ( const Session sn)

Constructor.

Parameters
snInstance of Session assigned with event
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionWasEstablished ( const std::string &  sender,
const std::string &  target,
SessionRole  role 
)
template<typename FileT >
Engine::B2B_SEALED< FileT >::SessionWasRestored ( const Session sn)

Constructor.

Parameters
snInstance of Session assigned with event
template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::setBoolConfigInfo ( const std::string &  aKey,
bool  aValue 
)
virtual

Sets the configuration information.

Parameters
aKey- parameter key
aValue- parameter value

Implements Engine::MsgStorage.

template<typename FileT >
void Engine::B2B_SEALED< FileT >::setConfigInfo ( const std::string &  aKey,
const std::string &  val 
)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::setIntConfigInfo ( const std::string &  aKey,
int  aValue 
)
virtual

Sets the configuration information.

Parameters
aKey- parameter key
aValue- parameter value

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::setMaxRemoteSeqNum ( int  msgSeqNum)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::setMinSeqNum ( int  msgSeqNum)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::setRemoteSeqNum ( int  msgSeqNum)
virtual

Reimplemented from MsgStorage.

Implements Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::setSessionInternalState ( const System::u64  internalState)
virtual

Reimplemented from Engine::MsgStorage.

template<typename FileT >
virtual void Engine::B2B_SEALED< FileT >::syncMessageStorage ( )
virtual

Implements Engine::MsgStorage.

template<typename FileT >
bool Engine::B2B_SEALED< FileT >::tryMarkRejected ( const RawMsg msg,
const ToBeResentCollection toBeResent 
)
template<typename FileT >
virtual bool Engine::B2B_SEALED< FileT >::unmarkRejected ( const RawMsg msg,
const RawMsg newMsg 
)
virtual

Reimplemented from RejectMsgStorage.

Implements Engine::RejectMsgStorage.

Friends And Related Function Documentation

template<typename FileT >
friend class ::TestApplication
friend
template<typename FileT >
friend class TestSeqNo
friend

Member Data Documentation

template<typename FileT >
SessionRole Engine::B2B_SEALED< FileT >::role_
protected
template<typename FileT >
std::string Engine::B2B_SEALED< FileT >::sender_
protected

Sender.

template<typename FileT >
std::string Engine::B2B_SEALED< FileT >::target_
protected

Target.