FIX::Session Class Reference

Maintains the state and implements the logic of a FIX session. More...

#include <Session.h>

Collaboration diagram for FIX::Session:

Public Member Functions
	Session (Application &, MessageStoreFactory &, const SessionID &, const DataDictionaryProvider &, const TimeRange &, int heartBtInt, LogFactory *pLogFactory)
virtual	~Session ()
void	logon ()
void	logout (const std::string &reason="")
bool	isEnabled ()
bool	sentLogon ()
bool	sentLogout ()
bool	receivedLogon ()
bool	isLoggedOn ()
void	reset () throw ( IOException )
void	refresh () throw ( IOException )
void	setNextSenderMsgSeqNum (int num) throw ( IOException )
void	setNextTargetMsgSeqNum (int num) throw ( IOException )
const SessionID &	getSessionID () const
void	setDataDictionaryProvider (const DataDictionaryProvider &dataDictionaryProvider)
const DataDictionaryProvider &	getDataDictionaryProvider () const
bool	isSessionTime (const UtcTimeStamp &time)
bool	isLogonTime (const UtcTimeStamp &time)
bool	isInitiator ()
bool	isAcceptor ()
const TimeRange &	getLogonTime ()
void	setLogonTime (const TimeRange &value)
const std::string &	getSenderDefaultApplVerID ()
void	setSenderDefaultApplVerID (const std::string &senderDefaultApplVerID)
const std::string &	getTargetDefaultApplVerID ()
void	setTargetDefaultApplVerID (const std::string &targetDefaultApplVerID)
bool	getSendRedundantResendRequests ()
void	setSendRedundantResendRequests (bool value)
bool	getCheckCompId ()
void	setCheckCompId (bool value)
bool	getCheckLatency ()
void	setCheckLatency (bool value)
int	getMaxLatency ()
void	setMaxLatency (int value)
int	getLogonTimeout ()
void	setLogonTimeout (int value)
int	getLogoutTimeout ()
void	setLogoutTimeout (int value)
bool	getResetOnLogon ()
void	setResetOnLogon (bool value)
bool	getResetOnLogout ()
void	setResetOnLogout (bool value)
bool	getResetOnDisconnect ()
void	setResetOnDisconnect (bool value)
bool	getRefreshOnLogon ()
void	setRefreshOnLogon (bool value)
bool	getMillisecondsInTimeStamp ()
void	setMillisecondsInTimeStamp (bool value)
int	getTimestampPrecision ()
void	setTimestampPrecision (int precision)
bool	getPersistMessages ()
void	setPersistMessages (bool value)
bool	getValidateLengthAndChecksum ()
void	setValidateLengthAndChecksum (bool value)
void	setResponder (Responder *pR)
bool	send (Message &)
void	next ()
void	next (const UtcTimeStamp &timeStamp)
void	next (const std::string &, const UtcTimeStamp &timeStamp, bool queued=false)
void	next (const Message &, const UtcTimeStamp &timeStamp, bool queued=false)
void	disconnect ()
int	getExpectedSenderNum ()
int	getExpectedTargetNum ()
Log *	getLog ()
const MessageStore *	getStore ()
const HeartBtInt &	getHeartBtInt () const

Static Public Member Functions
static bool	sendToTarget (Message &message, const std::string &qualifier="") throw ( SessionNotFound )
static bool	sendToTarget (Message &message, const SessionID &sessionID) throw ( SessionNotFound )
static bool	sendToTarget (Message &, const SenderCompID &senderCompID, const TargetCompID &targetCompID, const std::string &qualifier="") throw ( SessionNotFound )
static bool	sendToTarget (Message &message, const std::string &senderCompID, const std::string &targetCompID, const std::string &qualifier="") throw ( SessionNotFound )
static std::set< SessionID >	getSessions ()
static bool	doesSessionExist (const SessionID &)
static Session *	lookupSession (const SessionID &)
static Session *	lookupSession (const std::string &, bool reverse=false)
static bool	isSessionRegistered (const SessionID &)
static Session *	registerSession (const SessionID &)
static void	unregisterSession (const SessionID &)
static size_t	numSessions ()

Private Types
typedef std::map< SessionID, Session * >	Sessions
typedef std::set< SessionID >	SessionIDs

Private Member Functions
bool	send (const std::string &)
bool	sendRaw (Message &, int msgSeqNum=0)
bool	resend (Message &message)
void	persist (const Message &, const std::string &) throw ( IOException )
void	insertSendingTime (Header &)
void	insertOrigSendingTime (Header &, const UtcTimeStamp &when=UtcTimeStamp())
void	fill (Header &)
bool	isGoodTime (const SendingTime &sendingTime)
bool	checkSessionTime (const UtcTimeStamp &timeStamp)
bool	isTargetTooHigh (const MsgSeqNum &msgSeqNum)
bool	isTargetTooLow (const MsgSeqNum &msgSeqNum)
bool	isCorrectCompID (const SenderCompID &senderCompID, const TargetCompID &targetCompID)
bool	shouldSendReset ()
bool	validLogonState (const MsgType &msgType)
void	fromCallback (const MsgType &msgType, const Message &msg, const SessionID &sessionID)
void	doBadTime (const Message &msg)
void	doBadCompID (const Message &msg)
bool	doPossDup (const Message &msg)
bool	doTargetTooLow (const Message &msg)
void	doTargetTooHigh (const Message &msg)
void	nextQueued (const UtcTimeStamp &timeStamp)
bool	nextQueued (int num, const UtcTimeStamp &timeStamp)
void	nextLogon (const Message &, const UtcTimeStamp &timeStamp)
void	nextHeartbeat (const Message &, const UtcTimeStamp &timeStamp)
void	nextTestRequest (const Message &, const UtcTimeStamp &timeStamp)
void	nextLogout (const Message &, const UtcTimeStamp &timeStamp)
void	nextReject (const Message &, const UtcTimeStamp &timeStamp)
void	nextSequenceReset (const Message &, const UtcTimeStamp &timeStamp)
void	nextResendRequest (const Message &, const UtcTimeStamp &timeStamp)
void	generateLogon ()
void	generateLogon (const Message &)
void	generateResendRequest (const BeginString &, const MsgSeqNum &)
void	generateSequenceReset (int, int)
void	generateHeartbeat ()
void	generateHeartbeat (const Message &)
void	generateTestRequest (const std::string &)
void	generateReject (const Message &, int err, int field=0)
void	generateReject (const Message &, const std::string &)
void	generateBusinessReject (const Message &, int err, int field=0)
void	generateLogout (const std::string &text="")
void	populateRejectReason (Message &, int field, const std::string &)
void	populateRejectReason (Message &, const std::string &)
bool	verify (const Message &msg, bool checkTooHigh=true, bool checkTooLow=true)
bool	set (int s, const Message &m)
bool	get (int s, Message &m) const
Message *	newMessage (const std::string &msgType) const

Static Private Member Functions
static bool	addSession (Session &)
static void	removeSession (Session &)

Private Attributes
Application &	m_application
SessionID	m_sessionID
TimeRange	m_sessionTime
TimeRange	m_logonTime
std::string	m_senderDefaultApplVerID
std::string	m_targetDefaultApplVerID
bool	m_sendRedundantResendRequests
bool	m_checkCompId
bool	m_checkLatency
int	m_maxLatency
bool	m_resetOnLogon
bool	m_resetOnLogout
bool	m_resetOnDisconnect
bool	m_refreshOnLogon
int	m_timestampPrecision
bool	m_persistMessages
bool	m_validateLengthAndChecksum
SessionState	m_state
DataDictionaryProvider	m_dataDictionaryProvider
MessageStoreFactory &	m_messageStoreFactory
LogFactory *	m_pLogFactory
Responder *	m_pResponder
Mutex	m_mutex

Static Private Attributes
static Sessions	s_sessions
static SessionIDs	s_sessionIDs
static Sessions	s_registered
static Mutex	s_mutex

Detailed Description

Maintains the state and implements the logic of a FIX session.

Definition at line 45 of file Session.h.

Member Typedef Documentation

SessionIDs

typedef std::set< SessionID > FIX::Session::SessionIDs

private

Definition at line 234 of file Session.h.

Sessions

typedef std::map< SessionID, Session* > FIX::Session::Sessions

private

Definition at line 233 of file Session.h.

Constructor & Destructor Documentation

Session()

FIX::Session::Session	(	Application &	application,
		MessageStoreFactory &	messageStoreFactory,
		const SessionID &	sessionID,
		const DataDictionaryProvider &	dataDictionaryProvider,
		const TimeRange &	sessionTime,
		int	heartBtInt,
		LogFactory *	pLogFactory )

Definition at line 41 of file Session.cpp.

: m_application( application ),
  m_sessionID( sessionID ),
  m_sessionTime( sessionTime ),
  m_logonTime( sessionTime ),
  m_senderDefaultApplVerID(ApplVerID_FIX50),
  m_targetDefaultApplVerID(ApplVerID_FIX50),
  m_sendRedundantResendRequests( false ),
  m_checkCompId( true ),
  m_checkLatency( true ), 
  m_maxLatency( 120 ),
  m_resetOnLogon( false ),
  m_resetOnLogout( false ), 
  m_resetOnDisconnect( false ),
  m_refreshOnLogon( false ),
  m_timestampPrecision( 3 ),
  m_persistMessages( true ),
  m_validateLengthAndChecksum( true ),
  m_dataDictionaryProvider( dataDictionaryProvider ),
  m_messageStoreFactory( messageStoreFactory ),
  m_pLogFactory( pLogFactory ),
  m_pResponder( 0 )
{
  m_state.heartBtInt( heartBtInt );
  m_state.initiate( heartBtInt != 0 );
  m_state.store( m_messageStoreFactory.create( m_sessionID ) );
  if ( m_pLogFactory )
    m_state.log( m_pLogFactory->create( m_sessionID ) );
 
  if( !checkSessionTime(UtcTimeStamp()) )
    reset();
 
  addSession( *this );
  m_application.onCreate( m_sessionID );
  m_state.onEvent( "Created session" );
}

References addSession(), checkSessionTime(), m_application, m_checkCompId, m_checkLatency, m_dataDictionaryProvider, m_logonTime, m_maxLatency, m_messageStoreFactory, m_persistMessages, m_pLogFactory, m_pResponder, m_refreshOnLogon, m_resetOnDisconnect, m_resetOnLogon, m_resetOnLogout, m_senderDefaultApplVerID, m_sendRedundantResendRequests, m_sessionID, m_sessionTime, m_state, m_targetDefaultApplVerID, m_timestampPrecision, m_validateLengthAndChecksum, and reset().

Referenced by addSession(), lookupSession(), lookupSession(), registerSession(), removeSession(), and sendToTarget().

~Session()

FIX::Session::~Session ( )

virtual

Definition at line 83 of file Session.cpp.

{
  removeSession( *this );
  m_messageStoreFactory.destroy( m_state.store() );
  if ( m_pLogFactory && m_state.log() )
    m_pLogFactory->destroy( m_state.log() );
}

References m_messageStoreFactory, m_pLogFactory, m_state, and removeSession().

Member Function Documentation

addSession()

bool FIX::Session::addSession ( Session & s )

staticprivate

Definition at line 1559 of file Session.cpp.

{
  Locker locker( s_mutex );
  Sessions::iterator it = s_sessions.find( s.m_sessionID );
  if ( it == s_sessions.end() )
  {
    s_sessions[ s.m_sessionID ] = &s;
    s_sessionIDs.insert( s.m_sessionID );
    return true;
  }
  else
    return false;
}

References m_sessionID, s_mutex, s_sessionIDs, s_sessions, and Session().

Referenced by Session().

checkSessionTime()

bool FIX::Session::checkSessionTime ( const UtcTimeStamp & timeStamp )

inlineprivate

Definition at line 255 of file Session.h.

  {
    UtcTimeStamp creationTime = m_state.getCreationTime();
    return m_sessionTime.isInSameRange( timeStamp, creationTime );
  }

References m_sessionTime, and m_state.

Referenced by next(), next(), Session(), and setResponder().

disconnect()

void FIX::Session::disconnect

(

)

Definition at line 613 of file Session.cpp.

{
  Locker l(m_mutex);
 
  if ( m_pResponder )
  {
    m_state.onEvent( "Disconnecting" );
 
    m_pResponder->disconnect();
    m_pResponder = 0;
  }
 
  if ( m_state.receivedLogon() || m_state.sentLogon() )
  {
    m_state.receivedLogon( false );
    m_state.sentLogon( false );
    m_application.onLogout( m_sessionID );
  }
 
  m_state.sentLogout( false );
  m_state.receivedReset( false );
  m_state.sentReset( false );
  m_state.clearQueue();
  m_state.logoutReason();
  if ( m_resetOnDisconnect )
    m_state.reset();
 
  m_state.resendRange( 0, 0 );
}

References m_application, m_mutex, m_pResponder, m_resetOnDisconnect, m_sessionID, and m_state.

Referenced by next(), next(), next(), nextLogon(), nextLogout(), FIX::SocketAcceptor::onDisconnect(), FIX::SocketInitiator::onDisconnect(), reset(), and verify().

doBadCompID()

void FIX::Session::doBadCompID ( const Message & msg )

private

Definition at line 1152 of file Session.cpp.

{
  generateReject( msg, SessionRejectReason_COMPID_PROBLEM );
  generateLogout();
}

References generateLogout(), and generateReject().

Referenced by verify().

doBadTime()

void FIX::Session::doBadTime ( const Message & msg )

private

Definition at line 1146 of file Session.cpp.

{
  generateReject( msg, SessionRejectReason_SENDINGTIME_ACCURACY_PROBLEM );
  generateLogout();
}

References generateLogout(), and generateReject().

Referenced by verify().

doesSessionExist()

bool FIX::Session::doesSessionExist ( const SessionID & sessionID )

static

Definition at line 1490 of file Session.cpp.

{
  Locker locker( s_mutex );
  return s_sessions.end() != s_sessions.find( sessionID );
}

References s_mutex, and s_sessions.

doPossDup()

bool FIX::Session::doPossDup ( const Message & msg )

private

Definition at line 1158 of file Session.cpp.

{
  const Header & header = msg.getHeader();
  OrigSendingTime origSendingTime;
  SendingTime sendingTime;
  MsgType msgType;
 
  header.getField( msgType );
  header.getField( sendingTime );
 
  if ( msgType != MsgType_SequenceReset )
  {
    if ( !header.getFieldIfSet( origSendingTime ) )
    {
      generateReject( msg, SessionRejectReason_REQUIRED_TAG_MISSING, origSendingTime.getTag() );
      return false;
    }
 
    if ( origSendingTime > sendingTime )
    {
      generateReject( msg, SessionRejectReason_SENDINGTIME_ACCURACY_PROBLEM );
      generateLogout();
      return false;
    }
  }
  return true;
}

References generateLogout(), generateReject(), FIX::FieldMap::getField(), FIX::FieldMap::getFieldIfSet(), and FIX::Message::getHeader().

Referenced by doTargetTooLow().

doTargetTooHigh()

void FIX::Session::doTargetTooHigh ( const Message & msg )

private

Definition at line 1206 of file Session.cpp.

{
  const Header & header = msg.getHeader();
  BeginString beginString;
  MsgSeqNum msgSeqNum;
  header.getField( beginString );
  header.getField( msgSeqNum );
 
  m_state.onEvent( "MsgSeqNum too high, expecting "
                   + IntConvertor::convert( getExpectedTargetNum() )
                   + " but received "
                   + IntConvertor::convert( msgSeqNum ) );
 
  m_state.queue( msgSeqNum, msg );
 
  if( m_state.resendRequested() )
  {
    SessionState::ResendRange range = m_state.resendRange();
 
    if( !m_sendRedundantResendRequests && msgSeqNum >= range.first )
    {
          m_state.onEvent ("Already sent ResendRequest FROM: " +
                           IntConvertor::convert (range.first) + " TO: " +
                           IntConvertor::convert (range.second) +
                           ".  Not sending another.");
          return;
    }
  }
 
  generateResendRequest( beginString, msgSeqNum );
}

References FIX::IntConvertor::convert(), generateResendRequest(), getExpectedTargetNum(), FIX::FieldMap::getField(), FIX::Message::getHeader(), m_sendRedundantResendRequests, and m_state.

Referenced by nextLogon(), and verify().

doTargetTooLow()

bool FIX::Session::doTargetTooLow ( const Message & msg )

private

Definition at line 1186 of file Session.cpp.

{
  const Header & header = msg.getHeader();
  PossDupFlag possDupFlag(false);
  MsgSeqNum msgSeqNum;
  header.getFieldIfSet(possDupFlag);
  header.getField( msgSeqNum );
 
  if ( !possDupFlag )
  {
    std::stringstream stream;
    stream << "MsgSeqNum too low, expecting " << getExpectedTargetNum()
           << " but received " << msgSeqNum;
    generateLogout( stream.str() );
    throw std::logic_error( stream.str() );
  }
 
  return doPossDup( msg );
}

References doPossDup(), generateLogout(), getExpectedTargetNum(), FIX::FieldMap::getField(), FIX::FieldMap::getFieldIfSet(), and FIX::Message::getHeader().

Referenced by verify().

fill()

void FIX::Session::fill ( Header & header )

private

Definition at line 114 of file Session.cpp.

{
  UtcTimeStamp now;
  m_state.lastSentTime( now );
  header.setField( m_sessionID.getBeginString() );
  header.setField( m_sessionID.getSenderCompID() );
  header.setField( m_sessionID.getTargetCompID() );
  header.setField( MsgSeqNum( getExpectedSenderNum() ) );
  insertSendingTime( header );
}

References getExpectedSenderNum(), insertSendingTime(), m_sessionID, m_state, and FIX::FieldMap::setField().

Referenced by generateBusinessReject(), generateHeartbeat(), generateHeartbeat(), generateLogon(), generateLogon(), generateLogout(), generateReject(), generateReject(), generateResendRequest(), generateSequenceReset(), generateTestRequest(), and sendRaw().

fromCallback()

void FIX::Session::fromCallback ( const MsgType & msgType, const Message & msg, const SessionID & sessionID )

private

Definition at line 1137 of file Session.cpp.

{
  if ( Message::isAdminMsgType( msgType ) )
    m_application.fromAdmin( msg, m_sessionID );
  else
    m_application.fromApp( msg, m_sessionID );
}

References FIX::Message::isAdminMsgType(), m_application, and m_sessionID.

Referenced by verify().

generateBusinessReject()

void FIX::Session::generateBusinessReject ( const Message & message, int err, int field = 0 )

private

Definition at line 931 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("j"));
  Message & reject = *pMsg;
 
  reject.getHeader().setField( MsgType( MsgType_BusinessMessageReject ) );
  if( m_sessionID.isFIXT() )
    reject.setField( DefaultApplVerID(m_senderDefaultApplVerID) );  
  fill( reject.getHeader() );
  MsgType msgType;
  MsgSeqNum msgSeqNum;
  message.getHeader().getField( msgType );
  message.getHeader().getField( msgSeqNum );
  reject.setField( RefMsgType( msgType ) );
  reject.setField( RefSeqNum( msgSeqNum ) );
  reject.setField( BusinessRejectReason( err ) );
  m_state.incrNextTargetMsgSeqNum();
 
  const char* reason = 0;
  switch ( err )
  {
    case BusinessRejectReason_OTHER:
    reason = BusinessRejectReason_OTHER_TEXT;
    break;
    case BusinessRejectReason_UNKNOWN_ID:
    reason = BusinessRejectReason_UNKNOWN_ID_TEXT;
    break;
    case BusinessRejectReason_UNKNOWN_SECURITY:
    reason = BusinessRejectReason_UNKNOWN_SECURITY_TEXT;
    break;
    case BusinessRejectReason_UNKNOWN_MESSAGE_TYPE:
    reason = BusinessRejectReason_UNSUPPORTED_MESSAGE_TYPE_TEXT;
    break;
    case BusinessRejectReason_APPLICATION_NOT_AVAILABLE:
    reason = BusinessRejectReason_APPLICATION_NOT_AVAILABLE_TEXT;
    break;
    case BusinessRejectReason_CONDITIONALLY_REQUIRED_FIELD_MISSING:
    reason = BusinessRejectReason_CONDITIONALLY_REQUIRED_FIELD_MISSING_TEXT;
    break;
    case BusinessRejectReason_NOT_AUTHORIZED:
    reason = BusinessRejectReason_NOT_AUTHORIZED_TEXT;
    break;
    case BusinessRejectReason_DELIVERTO_FIRM_NOT_AVAILABLE_AT_THIS_TIME:
    reason = BusinessRejectReason_DELIVERTO_FIRM_NOT_AVAILABLE_AT_THIS_TIME_TEXT;
    break;
  };
 
  if ( reason && field )
  {
    populateRejectReason( reject, field, reason );
    m_state.onEvent( "Message " + msgSeqNum.getString() + " Rejected: "
                     + reason + ":" + IntConvertor::convert( field ) );
  }
  else if ( reason )
  {
    populateRejectReason( reject, reason );
    m_state.onEvent( "Message " + msgSeqNum.getString()
         + " Rejected: " + reason );
  }
  else
    m_state.onEvent( "Message " + msgSeqNum.getString() + " Rejected" );
 
  sendRaw( reject );
}

References FIX::BusinessRejectReason_APPLICATION_NOT_AVAILABLE_TEXT, FIX::BusinessRejectReason_CONDITIONALLY_REQUIRED_FIELD_MISSING_TEXT, FIX::BusinessRejectReason_DELIVERTO_FIRM_NOT_AVAILABLE_AT_THIS_TIME_TEXT, FIX::BusinessRejectReason_NOT_AUTHORIZED_TEXT, FIX::BusinessRejectReason_OTHER_TEXT, FIX::BusinessRejectReason_UNKNOWN_ID_TEXT, FIX::BusinessRejectReason_UNKNOWN_SECURITY_TEXT, FIX::BusinessRejectReason_UNSUPPORTED_MESSAGE_TYPE_TEXT, FIX::IntConvertor::convert(), fill(), FIX::FieldMap::getField(), FIX::Message::getHeader(), m_senderDefaultApplVerID, m_sessionID, m_state, newMessage(), populateRejectReason(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

Referenced by next().

generateHeartbeat() [1/2]

void FIX::Session::generateHeartbeat ( )

private

Definition at line 764 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("0"));
  Message & heartbeat = *pMsg;
 
  heartbeat.getHeader().setField( MsgType( "0" ) );
  fill( heartbeat.getHeader() );
  sendRaw( heartbeat );
}

References fill(), FIX::Message::getHeader(), newMessage(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

Referenced by next(), and nextTestRequest().

generateHeartbeat() [2/2]

void FIX::Session::generateHeartbeat ( const Message & testRequest )

private

Definition at line 774 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("0"));
  Message & heartbeat = *pMsg;
 
  heartbeat.getHeader().setField( MsgType( "0" ) );
  fill( heartbeat.getHeader() );
  try
  {
    TestReqID testReqID;
    testRequest.getField( testReqID );
    heartbeat.setField( testReqID );
  }
  catch ( FieldNotFound& ) {}
 
  sendRaw( heartbeat );
}

References fill(), FIX::FieldMap::getField(), FIX::Message::getHeader(), newMessage(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

generateLogon() [1/2]

void FIX::Session::generateLogon ( )

private

Definition at line 673 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("A"));
  Message & logon = *pMsg;
 
  logon.getHeader().setField( MsgType( "A" ) );
  logon.setField( EncryptMethod( 0 ) );
  logon.setField( m_state.heartBtInt() );
  if( m_sessionID.isFIXT() )
    logon.setField( DefaultApplVerID(m_senderDefaultApplVerID) );  
  if( m_refreshOnLogon )
    refresh();
  if( m_resetOnLogon )
    m_state.reset();
  if( shouldSendReset() )
    logon.setField( ResetSeqNumFlag(true) );
 
  fill( logon.getHeader() );
  UtcTimeStamp now;
  m_state.lastReceivedTime( now );
  m_state.testRequest( 0 );
  m_state.sentLogon( true );
  sendRaw( logon );
}

References fill(), logon(), m_refreshOnLogon, m_resetOnLogon, m_senderDefaultApplVerID, m_sessionID, m_state, newMessage(), refresh(), sendRaw(), shouldSendReset(), and SmartPtr.

Referenced by next(), and nextLogon().

generateLogon() [2/2]

void FIX::Session::generateLogon ( const Message & aLogon )

private

Definition at line 698 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("A"));
  Message & logon = *pMsg;
 
  EncryptMethod encryptMethod;
  HeartBtInt heartBtInt;
  logon.setField( EncryptMethod( 0 ) );
  if( m_sessionID.isFIXT() )
    logon.setField( DefaultApplVerID(m_senderDefaultApplVerID) );  
  if( m_state.receivedReset() )
    logon.setField( ResetSeqNumFlag(true) );
  aLogon.getField( heartBtInt );
  logon.getHeader().setField( MsgType( "A" ) );
  logon.setField( heartBtInt );
  fill( logon.getHeader() );
  sendRaw( logon );
  m_state.sentLogon( true );
}

References fill(), FIX::FieldMap::getField(), logon(), m_senderDefaultApplVerID, m_sessionID, m_state, newMessage(), sendRaw(), and SmartPtr.

generateLogout()

void FIX::Session::generateLogout ( const std::string & text = "" )

private

Definition at line 996 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("5"));
  Message & logout = *pMsg;
 
  logout.getHeader().setField( MsgType( MsgType_Logout ) );
  fill( logout.getHeader() );
  if ( text.length() )
    logout.setField( Text( text ) );
  sendRaw( logout );
  m_state.sentLogout( true );
}

References fill(), logout(), m_state, newMessage(), sendRaw(), and SmartPtr.

Referenced by doBadCompID(), doBadTime(), doPossDup(), doTargetTooLow(), next(), next(), nextLogout(), and reset().

generateReject() [1/2]

void FIX::Session::generateReject ( const Message & message, const std::string & str )

private

Definition at line 902 of file Session.cpp.

{
  std::string beginString = m_sessionID.getBeginString();
 
  SmartPtr<Message> pMsg(newMessage("3"));
  Message & reject = *pMsg;
 
  reject.getHeader().setField( MsgType( "3" ) );
  reject.reverseRoute( message.getHeader() );
  fill( reject.getHeader() );
 
  MsgType msgType;
  MsgSeqNum msgSeqNum;
 
  message.getHeader().getField( msgType );
  message.getHeader().getField( msgSeqNum );
  if ( beginString >= FIX::BeginString_FIX42 )
    reject.setField( RefMsgType( msgType ) );
  reject.setField( RefSeqNum( msgSeqNum ) );
 
  if ( msgType != MsgType_Logon && msgType != MsgType_SequenceReset )
    m_state.incrNextTargetMsgSeqNum();
 
  reject.setField( Text( str ) );
  sendRaw( reject );
  m_state.onEvent( "Message " + msgSeqNum.getString()
                   + " Rejected: " + str );
}

References FIX::BeginString_FIX42, fill(), FIX::FieldMap::getField(), FIX::Message::getHeader(), m_sessionID, m_state, newMessage(), FIX::Message::reverseRoute(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

generateReject() [2/2]

void FIX::Session::generateReject ( const Message & message, int err, int field = 0 )

private

Definition at line 805 of file Session.cpp.

{
  std::string beginString = m_sessionID.getBeginString();
 
  SmartPtr<Message> pMsg(newMessage("3"));
  Message & reject = *pMsg;
 
  reject.getHeader().setField( MsgType( "3" ) );
  reject.reverseRoute( message.getHeader() );
  fill( reject.getHeader() );
 
  MsgSeqNum msgSeqNum;
  MsgType msgType;
 
  message.getHeader().getField( msgType );
  if( message.getHeader().getFieldIfSet( msgSeqNum ) )
  {
    if( msgSeqNum.getString() != "" )
      reject.setField( RefSeqNum( msgSeqNum ) );
  }
 
  if ( beginString >= FIX::BeginString_FIX42 )
  {
    if( msgType.getString() != "" )
      reject.setField( RefMsgType( msgType ) );
    if ( (beginString == FIX::BeginString_FIX42
          && err <= SessionRejectReason_INVALID_MSGTYPE)
          || beginString > FIX::BeginString_FIX42 )
    {
      reject.setField( SessionRejectReason( err ) );
    }
  }
  if ( msgType != MsgType_Logon && msgType != MsgType_SequenceReset
       && msgSeqNum == getExpectedTargetNum() )
  { m_state.incrNextTargetMsgSeqNum(); }
 
  const char* reason = 0;
  switch ( err )
  {
    case SessionRejectReason_INVALID_TAG_NUMBER:
    reason = SessionRejectReason_INVALID_TAG_NUMBER_TEXT;
    break;
    case SessionRejectReason_REQUIRED_TAG_MISSING:
    reason = SessionRejectReason_REQUIRED_TAG_MISSING_TEXT;
    break;
    case SessionRejectReason_TAG_NOT_DEFINED_FOR_THIS_MESSAGE_TYPE:
    reason = SessionRejectReason_TAG_NOT_DEFINED_FOR_THIS_MESSAGE_TYPE_TEXT;
    break;
    case SessionRejectReason_TAG_SPECIFIED_WITHOUT_A_VALUE:
    reason = SessionRejectReason_TAG_SPECIFIED_WITHOUT_A_VALUE_TEXT;
    break;
    case SessionRejectReason_VALUE_IS_INCORRECT:
    reason = SessionRejectReason_VALUE_IS_INCORRECT_TEXT;
    break;
    case SessionRejectReason_INCORRECT_DATA_FORMAT_FOR_VALUE:
    reason = SessionRejectReason_INCORRECT_DATA_FORMAT_FOR_VALUE_TEXT;
    break;
    case SessionRejectReason_COMPID_PROBLEM:
    reason = SessionRejectReason_COMPID_PROBLEM_TEXT;
    break;
    case SessionRejectReason_SENDINGTIME_ACCURACY_PROBLEM:
    reason = SessionRejectReason_SENDINGTIME_ACCURACY_PROBLEM_TEXT;
    break;
    case SessionRejectReason_INVALID_MSGTYPE:
    reason = SessionRejectReason_INVALID_MSGTYPE_TEXT;
    break;
    case SessionRejectReason_TAG_APPEARS_MORE_THAN_ONCE:
    reason = SessionRejectReason_TAG_APPEARS_MORE_THAN_ONCE_TEXT;
    break;
    case SessionRejectReason_TAG_SPECIFIED_OUT_OF_REQUIRED_ORDER:
    reason = SessionRejectReason_TAG_SPECIFIED_OUT_OF_REQUIRED_ORDER_TEXT;
    break;
    case SessionRejectReason_INCORRECT_NUMINGROUP_COUNT_FOR_REPEATING_GROUP:
    reason = SessionRejectReason_INCORRECT_NUMINGROUP_COUNT_FOR_REPEATING_GROUP_TEXT;
  };
 
  if ( reason && ( field || err == SessionRejectReason_INVALID_TAG_NUMBER ) )
  {
    populateRejectReason( reject, field, reason );
    m_state.onEvent( "Message " + msgSeqNum.getString() + " Rejected: "
                     + reason + ":" + IntConvertor::convert( field ) );
  }
  else if ( reason )
  {
    populateRejectReason( reject, reason );
    m_state.onEvent( "Message " + msgSeqNum.getString()
         + " Rejected: " + reason );
  }
  else
    m_state.onEvent( "Message " + msgSeqNum.getString() + " Rejected" );
 
  if ( !m_state.receivedLogon() )
    throw std::runtime_error( "Tried to send a reject while not logged on" );
 
  sendRaw( reject );
}

References FIX::BeginString_FIX42, FIX::IntConvertor::convert(), fill(), getExpectedTargetNum(), FIX::FieldMap::getField(), FIX::FieldMap::getFieldIfSet(), FIX::Message::getHeader(), m_sessionID, m_state, newMessage(), populateRejectReason(), FIX::Message::reverseRoute(), sendRaw(), FIX::SessionRejectReason_COMPID_PROBLEM_TEXT, FIX::SessionRejectReason_INCORRECT_DATA_FORMAT_FOR_VALUE_TEXT, FIX::SessionRejectReason_INCORRECT_NUMINGROUP_COUNT_FOR_REPEATING_GROUP_TEXT, FIX::SessionRejectReason_INVALID_MSGTYPE_TEXT, FIX::SessionRejectReason_INVALID_TAG_NUMBER_TEXT, FIX::SessionRejectReason_REQUIRED_TAG_MISSING_TEXT, FIX::SessionRejectReason_SENDINGTIME_ACCURACY_PROBLEM_TEXT, FIX::SessionRejectReason_TAG_APPEARS_MORE_THAN_ONCE_TEXT, FIX::SessionRejectReason_TAG_NOT_DEFINED_FOR_THIS_MESSAGE_TYPE_TEXT, FIX::SessionRejectReason_TAG_SPECIFIED_OUT_OF_REQUIRED_ORDER_TEXT, FIX::SessionRejectReason_TAG_SPECIFIED_WITHOUT_A_VALUE_TEXT, FIX::SessionRejectReason_VALUE_IS_INCORRECT_TEXT, FIX::FieldMap::setField(), and SmartPtr.

Referenced by doBadCompID(), doBadTime(), doPossDup(), next(), and nextSequenceReset().

generateResendRequest()

void FIX::Session::generateResendRequest ( const BeginString & beginString, const MsgSeqNum & msgSeqNum )

private

Definition at line 718 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("2"));
  Message & resendRequest = *pMsg;
 
  BeginSeqNo beginSeqNo( ( int ) getExpectedTargetNum() );
  EndSeqNo endSeqNo( msgSeqNum - 1 );
  if ( beginString >= FIX::BeginString_FIX42 )
    endSeqNo = 0;
  else if( beginString <= FIX::BeginString_FIX41 )
    endSeqNo = 999999;
  resendRequest.getHeader().setField( MsgType( "2" ) );
  resendRequest.setField( beginSeqNo );
  resendRequest.setField( endSeqNo );
  fill( resendRequest.getHeader() );
  sendRaw( resendRequest );
 
  m_state.onEvent( "Sent ResendRequest FROM: "
                   + IntConvertor::convert( beginSeqNo ) +
                   " TO: " + IntConvertor::convert( endSeqNo ) );
 
  m_state.resendRange( beginSeqNo, msgSeqNum - 1 );
}

References FIX::BeginString_FIX41, FIX::BeginString_FIX42, FIX::IntConvertor::convert(), fill(), getExpectedTargetNum(), FIX::Message::getHeader(), m_state, newMessage(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

Referenced by doTargetTooHigh().

generateSequenceReset()

void FIX::Session::generateSequenceReset ( int beginSeqNo, int endSeqNo )

private

Definition at line 742 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("4"));
  Message & sequenceReset = *pMsg;
 
  NewSeqNo newSeqNo( endSeqNo );
  sequenceReset.getHeader().setField( MsgType( "4" ) );
  sequenceReset.getHeader().setField( PossDupFlag( true ) );
  sequenceReset.setField( newSeqNo );
  fill( sequenceReset.getHeader() );
 
  SendingTime sendingTime;
  sequenceReset.getHeader().getField( sendingTime );
  insertOrigSendingTime( sequenceReset.getHeader(), sendingTime );
  sequenceReset.getHeader().setField( MsgSeqNum( beginSeqNo ) );
  sequenceReset.setField( GapFillFlag( true ) );
  sendRaw( sequenceReset, beginSeqNo );
  m_state.onEvent( "Sent SequenceReset TO: "
                   + IntConvertor::convert( newSeqNo ) );
}

References FIX::IntConvertor::convert(), fill(), FIX::FieldMap::getField(), FIX::Message::getHeader(), insertOrigSendingTime(), m_state, newMessage(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

Referenced by nextResendRequest().

generateTestRequest()

void FIX::Session::generateTestRequest ( const std::string & id )

private

Definition at line 792 of file Session.cpp.

{
  SmartPtr<Message> pMsg(newMessage("1"));
  Message & testRequest = *pMsg;
 
  testRequest.getHeader().setField( MsgType( "1" ) );
  fill( testRequest.getHeader() );
  TestReqID testReqID( id );
  testRequest.setField( testReqID );
 
  sendRaw( testRequest );
}

References fill(), FIX::Message::getHeader(), newMessage(), sendRaw(), FIX::FieldMap::setField(), and SmartPtr.

Referenced by next().

get()

bool FIX::Session::get ( int s, Message & m ) const

private

getCheckCompId()

bool FIX::Session::getCheckCompId ( )

inline

Definition at line 137 of file Session.h.

    { return m_checkCompId; }

References m_checkCompId.

Referenced by FIX::HttpConnection::processSession().

getCheckLatency()

bool FIX::Session::getCheckLatency ( )

inline

Definition at line 142 of file Session.h.

    { return m_checkLatency; }

References m_checkLatency.

Referenced by FIX::HttpConnection::processSession().

getDataDictionaryProvider()

const DataDictionaryProvider & FIX::Session::getDataDictionaryProvider ( ) const

inline

Definition at line 79 of file Session.h.

  { return m_dataDictionaryProvider; }

References m_dataDictionaryProvider.

getExpectedSenderNum()

int FIX::Session::getExpectedSenderNum ( )

inline

Definition at line 224 of file Session.h.

{ return m_state.getNextSenderMsgSeqNum(); }

References m_state.

Referenced by fill(), nextResendRequest(), FIX::HttpConnection::processRoot(), FIX::HttpConnection::processSession(), sendRaw(), and shouldSendReset().

getExpectedTargetNum()

int FIX::Session::getExpectedTargetNum ( )

inline

Definition at line 225 of file Session.h.

{ return m_state.getNextTargetMsgSeqNum(); }

References m_state.

Referenced by doTargetTooHigh(), doTargetTooLow(), generateReject(), generateResendRequest(), nextQueued(), nextSequenceReset(), FIX::HttpConnection::processRoot(), FIX::HttpConnection::processSession(), and shouldSendReset().

getHeartBtInt()

const HeartBtInt & FIX::Session::getHeartBtInt ( ) const

inline

Definition at line 230 of file Session.h.

{ return m_state.heartBtInt(); }

References m_state.

getLog()

Log * FIX::Session::getLog ( )

inline

Definition at line 227 of file Session.h.

{ return &m_state; }

References m_state.

Referenced by FIX::SocketInitiator::doConnect(), and FIX::ThreadedSocketInitiator::doConnect().

getLogonTime()

const TimeRange & FIX::Session::getLogonTime ( )

inline

Definition at line 117 of file Session.h.

    { return m_logonTime; }

References m_logonTime.

getLogonTimeout()

int FIX::Session::getLogonTimeout ( )

inline

Definition at line 152 of file Session.h.

    { return m_state.logonTimeout(); }

References m_state.

Referenced by FIX::HttpConnection::processSession().

getLogoutTimeout()

int FIX::Session::getLogoutTimeout ( )

inline

Definition at line 157 of file Session.h.

    { return m_state.logoutTimeout(); }

References m_state.

Referenced by FIX::HttpConnection::processSession().

getMaxLatency()

int FIX::Session::getMaxLatency ( )

inline

Definition at line 147 of file Session.h.

    { return m_maxLatency; }

References m_maxLatency.

Referenced by FIX::HttpConnection::processSession().

getMillisecondsInTimeStamp()

bool FIX::Session::getMillisecondsInTimeStamp ( )

inline

Definition at line 182 of file Session.h.

    { return (m_timestampPrecision == 3); }

References m_timestampPrecision.

Referenced by FIX::HttpConnection::processSession().

getPersistMessages()

bool FIX::Session::getPersistMessages ( )

inline

Definition at line 200 of file Session.h.

    { return m_persistMessages; }

References m_persistMessages.

Referenced by FIX::HttpConnection::processSession().

getRefreshOnLogon()

bool FIX::Session::getRefreshOnLogon ( )

inline

Definition at line 177 of file Session.h.

    { return m_refreshOnLogon; }

References m_refreshOnLogon.

Referenced by FIX::HttpConnection::processSession().

getResetOnDisconnect()

bool FIX::Session::getResetOnDisconnect ( )

inline

Definition at line 172 of file Session.h.

    { return m_resetOnDisconnect; }

References m_resetOnDisconnect.

Referenced by FIX::HttpConnection::processSession().

getResetOnLogon()

bool FIX::Session::getResetOnLogon ( )

inline

Definition at line 162 of file Session.h.

    { return m_resetOnLogon; }

References m_resetOnLogon.

Referenced by FIX::HttpConnection::processSession().

getResetOnLogout()

bool FIX::Session::getResetOnLogout ( )

inline

Definition at line 167 of file Session.h.

    { return m_resetOnLogout; }

References m_resetOnLogout.

Referenced by FIX::HttpConnection::processSession().

getSenderDefaultApplVerID()

const std::string & FIX::Session::getSenderDefaultApplVerID ( )

inline

Definition at line 122 of file Session.h.

    { return m_senderDefaultApplVerID; }

References m_senderDefaultApplVerID.

Referenced by FIX::MessageCracker::crack(), and FIX::MessageCracker::crack().

getSendRedundantResendRequests()

bool FIX::Session::getSendRedundantResendRequests ( )

inline

Definition at line 132 of file Session.h.

    { return m_sendRedundantResendRequests; }

References m_sendRedundantResendRequests.

Referenced by FIX::HttpConnection::processSession().

getSessionID()

const SessionID & FIX::Session::getSessionID ( ) const

inline

Definition at line 75 of file Session.h.

  { return m_sessionID; }

References m_sessionID.

Referenced by FIX::SocketInitiator::onConnect(), FIX::SocketInitiator::onDisconnect(), FIX::ThreadedSocketInitiator::socketThread(), and FIX::Acceptor::stop().

getSessions()

std::set< SessionID > FIX::Session::getSessions ( )

static

Definition at line 1485 of file Session.cpp.

{
  return s_sessionIDs;
}

References s_sessionIDs.

Referenced by FIX::HttpConnection::processDisableSessions(), FIX::HttpConnection::processEnableSessions(), FIX::HttpConnection::processRefreshSessions(), FIX::HttpConnection::processResetSessions(), and FIX::HttpConnection::processRoot().

getStore()

const MessageStore * FIX::Session::getStore ( )

inline

Definition at line 228 of file Session.h.

{ return &m_state; }

References m_state.

getTargetDefaultApplVerID()

const std::string & FIX::Session::getTargetDefaultApplVerID ( )

inline

Definition at line 127 of file Session.h.

    { return m_targetDefaultApplVerID; }

References m_targetDefaultApplVerID.

getTimestampPrecision()

int FIX::Session::getTimestampPrecision ( )

inline

Definition at line 190 of file Session.h.

    { return m_timestampPrecision; }

References m_timestampPrecision.

getValidateLengthAndChecksum()

bool FIX::Session::getValidateLengthAndChecksum ( )

inline

Definition at line 205 of file Session.h.

    { return m_validateLengthAndChecksum; }

References m_validateLengthAndChecksum.

insertOrigSendingTime()

void FIX::Session::insertOrigSendingTime ( Header & header, const UtcTimeStamp & when = UtcTimeStamp () )

private

Definition at line 103 of file Session.cpp.

{
  bool showMilliseconds = false;
  if( m_sessionID.getBeginString() == BeginString_FIXT11 )
    showMilliseconds = true;
  else
    showMilliseconds = m_sessionID.getBeginString() >= BeginString_FIX42;
 
  header.setField( OrigSendingTime(when, showMilliseconds ? m_timestampPrecision : 0) );
}

References FIX::BeginString_FIX42, FIX::BeginString_FIXT11, m_sessionID, m_timestampPrecision, and FIX::FieldMap::setField().

Referenced by generateSequenceReset(), and resend().

insertSendingTime()

void FIX::Session::insertSendingTime ( Header & header )

private

Definition at line 91 of file Session.cpp.

{
  UtcTimeStamp now;
  bool showMilliseconds = false;
  if( m_sessionID.getBeginString() == BeginString_FIXT11 )
    showMilliseconds = true;
  else
    showMilliseconds = m_sessionID.getBeginString() >= BeginString_FIX42;
 
  header.setField( SendingTime(now, showMilliseconds ? m_timestampPrecision : 0) );
}

References FIX::BeginString_FIX42, FIX::BeginString_FIXT11, m_sessionID, m_timestampPrecision, and FIX::FieldMap::setField().

Referenced by fill(), and resend().

isAcceptor()

bool FIX::Session::isAcceptor ( )

inline

Definition at line 114 of file Session.h.

    { return !m_state.initiate(); }

References m_state.

isCorrectCompID()

bool FIX::Session::isCorrectCompID ( const SenderCompID & senderCompID, const TargetCompID & targetCompID )

inlineprivate

Definition at line 264 of file Session.h.

  {
    if( !m_checkCompId ) return true;
 
    return
      m_sessionID.getSenderCompID().getValue() == targetCompID.getValue()
      && m_sessionID.getTargetCompID().getValue() == senderCompID.getValue();
  }

References m_checkCompId, and m_sessionID.

Referenced by verify().

isEnabled()

bool FIX::Session::isEnabled ( )

inline

Definition at line 59 of file Session.h.

  { return m_state.enabled(); }

References m_state.

Referenced by FIX::Initiator::connect(), next(), nextLogon(), FIX::HttpConnection::processRoot(), FIX::HttpConnection::processSession(), FIX::Acceptor::stop(), and FIX::Initiator::stop().

isGoodTime()

bool FIX::Session::isGoodTime ( const SendingTime & sendingTime )

inlineprivate

Definition at line 249 of file Session.h.

  {
    if ( !m_checkLatency ) return true;
    UtcTimeStamp now;
    return labs( now - sendingTime ) <= m_maxLatency;
  }

References m_checkLatency, and m_maxLatency.

Referenced by verify().

isInitiator()

bool FIX::Session::isInitiator ( )

inline

Definition at line 112 of file Session.h.

    { return m_state.initiate(); }

References m_state.

Referenced by FIX::HttpConnection::processRoot(), and FIX::HttpConnection::processSession().

isLoggedOn()

bool FIX::Session::isLoggedOn ( )

inline

Definition at line 65 of file Session.h.

{ return receivedLogon() && sentLogon(); }

References receivedLogon(), and sentLogon().

Referenced by next(), next(), nextLogon(), FIX::HttpConnection::processRoot(), FIX::HttpConnection::processSession(), and sendRaw().

isLogonTime()

bool FIX::Session::isLogonTime ( const UtcTimeStamp & time )

inline

Definition at line 110 of file Session.h.

    { return m_logonTime.isInRange(time); }

References m_logonTime.

Referenced by next(), and nextLogon().

isSessionRegistered()

bool FIX::Session::isSessionRegistered ( const SessionID & sessionID )

static

Definition at line 1531 of file Session.cpp.

{
  Locker locker( s_mutex );
  return s_registered.end() != s_registered.find( sessionID );
}

References s_mutex, and s_registered.

Referenced by FIX::SocketConnection::isValidSession(), registerSession(), and FIX::ThreadedSocketConnection::setSession().

isSessionTime()

bool FIX::Session::isSessionTime ( const UtcTimeStamp & time )

inline

Definition at line 108 of file Session.h.

    { return m_sessionTime.isInRange(time); }

References isSessionTime(), and m_sessionTime.

Referenced by FIX::Initiator::connect(), FIX::SocketInitiator::doConnect(), FIX::ThreadedSocketInitiator::doConnect(), isSessionTime(), FIX::HttpConnection::processRoot(), and FIX::HttpConnection::processSession().

isTargetTooHigh()

bool FIX::Session::isTargetTooHigh ( const MsgSeqNum & msgSeqNum )

inlineprivate

Definition at line 260 of file Session.h.

  { return msgSeqNum > ( m_state.getNextTargetMsgSeqNum() ); }

References m_state.

Referenced by nextLogon(), nextResendRequest(), and verify().

isTargetTooLow()

bool FIX::Session::isTargetTooLow ( const MsgSeqNum & msgSeqNum )

inlineprivate

Definition at line 262 of file Session.h.

  { return msgSeqNum < ( m_state.getNextTargetMsgSeqNum() ); }

References m_state.

Referenced by nextResendRequest(), and verify().

logon()

void FIX::Session::logon ( )

inline

Definition at line 55 of file Session.h.

  { m_state.enabled( true ); m_state.logoutReason( "" ); }

References m_state.

Referenced by generateLogon(), generateLogon(), nextLogon(), FIX::HttpConnection::processEnableSessions(), and FIX::HttpConnection::processSession().

logout()

void FIX::Session::logout ( const std::string & reason = "" )

inline

Definition at line 57 of file Session.h.

  { m_state.enabled( false ); m_state.logoutReason( reason ); }

References m_state.

Referenced by generateLogout(), nextLogout(), FIX::HttpConnection::processDisableSessions(), FIX::HttpConnection::processSession(), FIX::Acceptor::stop(), and FIX::Initiator::stop().

lookupSession() [1/2]

Session * FIX::Session::lookupSession ( const SessionID & sessionID )

static

Definition at line 1496 of file Session.cpp.

{
  Locker locker( s_mutex );
  Sessions::iterator find = s_sessions.find( sessionID );
  if ( find != s_sessions.end() )
    return find->second;
  else
    return 0;
}

References s_mutex, s_sessions, and Session().

Referenced by FIX::Initiator::connect(), FIX::MessageCracker::crack(), FIX::MessageCracker::crack(), FIX::SocketInitiator::doConnect(), FIX::ThreadedSocketInitiator::doConnect(), FIX::Initiator::isLoggedOn(), lookupSession(), FIX::HttpConnection::processDisableSessions(), FIX::HttpConnection::processEnableSessions(), FIX::HttpConnection::processRefreshSession(), FIX::HttpConnection::processRefreshSessions(), FIX::HttpConnection::processResetSession(), FIX::HttpConnection::processResetSessions(), FIX::HttpConnection::processRoot(), FIX::HttpConnection::processSession(), FIX::SocketConnection::read(), registerSession(), sendToTarget(), FIX::ThreadedSocketConnection::setSession(), FIX::ThreadedSocketInitiator::socketThread(), FIX::Acceptor::stop(), and FIX::Initiator::stop().

lookupSession() [2/2]

Session * FIX::Session::lookupSession ( const std::string & string, bool reverse = false )

static

Definition at line 1506 of file Session.cpp.

{
  Message message;
  if ( !message.setStringHeader( string ) )
    return 0;
 
  try
  {
    const Header& header = message.getHeader();
    const BeginString& beginString = FIELD_GET_REF( header, BeginString );
    const SenderCompID& senderCompID = FIELD_GET_REF( header, SenderCompID );
    const TargetCompID& targetCompID = FIELD_GET_REF( header, TargetCompID );
 
    if ( reverse )
    {
      return lookupSession( SessionID( beginString, SenderCompID( targetCompID ),
                                     TargetCompID( senderCompID ) ) );
    }
 
    return lookupSession( SessionID( beginString, senderCompID,
                          targetCompID ) );
  }
  catch ( FieldNotFound& ) { return 0; }
}

References FIELD_GET_REF, FIX::Message::getHeader(), lookupSession(), reverse(), Session(), and FIX::Message::setStringHeader().

newMessage()

Message * FIX::Session::newMessage ( const std::string & msgType ) const

private

Definition at line 492 of file Session.cpp.

{
  Message * msg = 0;
 
  const DataDictionary& sessionDD =
    m_dataDictionaryProvider.getSessionDataDictionary(m_sessionID.getBeginString());
  if (!sessionDD.isMessageFieldsOrderPreserved())
  {
    msg = new Message();
  }
  else
  {
    const message_order & hdrOrder = sessionDD.getHeaderOrderedFields();
    const message_order & trlOrder = sessionDD.getTrailerOrderedFields();
    if (!m_sessionID.isFIXT() || Message::isAdminMsgType(msgType) )
    {
      const message_order & msgOrder = sessionDD.getMessageOrderedFields(msgType);
      msg = new Message(hdrOrder, trlOrder, msgOrder);
    }
    else
    {
      const DataDictionary& applicationDD =
        m_dataDictionaryProvider.getApplicationDataDictionary(m_senderDefaultApplVerID);
      const message_order & msgOrder = applicationDD.getMessageOrderedFields(msgType);
      msg = new Message(hdrOrder, trlOrder, msgOrder);
    }
  }
 
  return msg;
}

References FIX::DataDictionary::getHeaderOrderedFields(), FIX::DataDictionary::getMessageOrderedFields(), FIX::DataDictionary::getTrailerOrderedFields(), FIX::Message::isAdminMsgType(), FIX::DataDictionary::isMessageFieldsOrderPreserved(), m_dataDictionaryProvider, m_senderDefaultApplVerID, and m_sessionID.

Referenced by generateBusinessReject(), generateHeartbeat(), generateHeartbeat(), generateLogon(), generateLogon(), generateLogout(), generateReject(), generateReject(), generateResendRequest(), generateSequenceReset(), and generateTestRequest().

next() [1/4]

void FIX::Session::next

(

)

Definition at line 125 of file Session.cpp.

{
  next( UtcTimeStamp() );
}

References next().

Referenced by next(), next(), next(), nextQueued(), nextResendRequest(), and FIX::ThreadedSocketInitiator::socketThread().

next() [2/4]

void FIX::Session::next	(	const Message &	message,
		const UtcTimeStamp &	timeStamp,
		bool	queued = false )

Definition at line 1301 of file Session.cpp.

{
  const Header& header = message.getHeader();
 
  try
  {
    if ( !checkSessionTime(timeStamp) )
      { reset(); return; }
 
    const MsgType& msgType = FIELD_GET_REF( header, MsgType );
    const BeginString& beginString = FIELD_GET_REF( header, BeginString );
    // make sure these fields are present
    FIELD_THROW_IF_NOT_FOUND( header, SenderCompID );
    FIELD_THROW_IF_NOT_FOUND( header, TargetCompID );
 
    if ( beginString != m_sessionID.getBeginString() )
      throw UnsupportedVersion();
 
    if( msgType == MsgType_Logon )
    {
      if( m_sessionID.isFIXT() )
      {
        const DefaultApplVerID& applVerID = FIELD_GET_REF( message, DefaultApplVerID );
        setTargetDefaultApplVerID(applVerID);
      }
      else
      {
        setTargetDefaultApplVerID(Message::toApplVerID(beginString));
      }
    }
 
    const DataDictionary& sessionDataDictionary = 
        m_dataDictionaryProvider.getSessionDataDictionary(m_sessionID.getBeginString());
 
    if( m_sessionID.isFIXT() && message.isApp() )
    {
      ApplVerID applVerID = m_targetDefaultApplVerID;
      header.getFieldIfSet(applVerID);
      const DataDictionary& applicationDataDictionary = 
        m_dataDictionaryProvider.getApplicationDataDictionary(applVerID);
      DataDictionary::validate( message, &sessionDataDictionary, &applicationDataDictionary );
    }
    else
    {
      sessionDataDictionary.validate( message );
    }
 
    if ( msgType == MsgType_Logon )
      nextLogon( message, timeStamp );
    else if ( msgType == MsgType_Heartbeat )
      nextHeartbeat( message, timeStamp );
    else if ( msgType == MsgType_TestRequest )
      nextTestRequest( message, timeStamp );
    else if ( msgType == MsgType_SequenceReset )
      nextSequenceReset( message, timeStamp );
    else if ( msgType == MsgType_Logout )
      nextLogout( message, timeStamp );
    else if ( msgType == MsgType_ResendRequest )
      nextResendRequest( message,timeStamp );
    else if ( msgType == MsgType_Reject )
      nextReject( message, timeStamp );
    else
    {
      if ( !verify( message ) ) return ;
      m_state.incrNextTargetMsgSeqNum();
    }
  }
  catch ( MessageParseError& e )
  { m_state.onEvent( e.what() ); }
  catch ( RequiredTagMissing & e )
  { LOGEX( generateReject( message, SessionRejectReason_REQUIRED_TAG_MISSING, e.field ) ); }
  catch ( FieldNotFound & e )
  {
    if( header.getField(FIELD::BeginString) >= FIX::BeginString_FIX42 && message.isApp() )
    {
      LOGEX( generateBusinessReject( message, BusinessRejectReason_CONDITIONALLY_REQUIRED_FIELD_MISSING, e.field ) );
    }
    else
    {
      LOGEX( generateReject( message, SessionRejectReason_REQUIRED_TAG_MISSING, e.field ) );
      if ( header.getField(FIELD::MsgType) == MsgType_Logon )
      {
        m_state.onEvent( "Required field missing from logon" );
        disconnect();
      }
    }
  }
  catch ( InvalidTagNumber & e )
  { LOGEX( generateReject( message, SessionRejectReason_INVALID_TAG_NUMBER, e.field ) ); }
  catch ( NoTagValue & e )
  { LOGEX( generateReject( message, SessionRejectReason_TAG_SPECIFIED_WITHOUT_A_VALUE, e.field ) ); }
  catch ( TagNotDefinedForMessage & e )
  { LOGEX( generateReject( message, SessionRejectReason_TAG_NOT_DEFINED_FOR_THIS_MESSAGE_TYPE, e.field ) ); }
  catch ( InvalidMessageType& )
  { LOGEX( generateReject( message, SessionRejectReason_INVALID_MSGTYPE ) ); }
  catch ( UnsupportedMessageType& )
  {
    if ( header.getField(FIELD::BeginString) >= FIX::BeginString_FIX42 )
      { LOGEX( generateBusinessReject( message, BusinessRejectReason_UNKNOWN_MESSAGE_TYPE ) ); }
    else
      { LOGEX( generateReject( message, "Unsupported message type" ) ); }
  }
  catch ( TagOutOfOrder & e )
  { LOGEX( generateReject( message, SessionRejectReason_TAG_SPECIFIED_OUT_OF_REQUIRED_ORDER, e.field ) ); }
  catch ( IncorrectDataFormat & e )
  { LOGEX( generateReject( message, SessionRejectReason_INCORRECT_DATA_FORMAT_FOR_VALUE, e.field ) ); }
  catch ( IncorrectTagValue & e )
  { LOGEX( generateReject( message, SessionRejectReason_VALUE_IS_INCORRECT, e.field ) ); }
  catch ( RepeatedTag & e )
  { LOGEX( generateReject( message, SessionRejectReason_TAG_APPEARS_MORE_THAN_ONCE, e.field ) ); }
  catch ( RepeatingGroupCountMismatch & e )
  { LOGEX( generateReject( message, SessionRejectReason_INCORRECT_NUMINGROUP_COUNT_FOR_REPEATING_GROUP, e.field ) ); }
  catch ( InvalidMessage& e )
  { m_state.onEvent( e.what() ); }
  catch ( RejectLogon& e )
  {
    m_state.onEvent( e.what() );
    generateLogout( e.what() );
    disconnect();
  }
  catch ( UnsupportedVersion& )
  {
    if ( header.getField(FIELD::MsgType) == MsgType_Logout )
      nextLogout( message, timeStamp );
    else
    {
      generateLogout( "Incorrect BeginString" );
      m_state.incrNextTargetMsgSeqNum();
    }
  }
  catch ( IOException& e )
  {
    m_state.onEvent( e.what() );
    disconnect();
  }
 
  if( !queued )
    nextQueued( timeStamp );
 
  if( isLoggedOn() )
    next();
}

References FIX::BeginString_FIX42, checkSessionTime(), disconnect(), FIELD_GET_REF, FIELD_THROW_IF_NOT_FOUND, generateBusinessReject(), generateLogout(), generateReject(), FIX::FieldMap::getField(), FIX::FieldMap::getFieldIfSet(), FIX::Message::getHeader(), FIX::Message::isApp(), isLoggedOn(), LOGEX, m_dataDictionaryProvider, m_sessionID, m_state, m_targetDefaultApplVerID, next(), nextHeartbeat(), nextLogon(), nextLogout(), nextQueued(), nextReject(), nextResendRequest(), nextSequenceReset(), nextTestRequest(), reset(), setTargetDefaultApplVerID(), FIX::Message::toApplVerID(), FIX::DataDictionary::validate(), and verify().

next() [3/4]

void FIX::Session::next	(	const std::string &	msg,
		const UtcTimeStamp &	timeStamp,
		bool	queued = false )

Definition at line 1267 of file Session.cpp.

{
  try
  {
    m_state.onIncoming( msg );
    const DataDictionary& sessionDD = 
      m_dataDictionaryProvider.getSessionDataDictionary(m_sessionID.getBeginString());
    if( m_sessionID.isFIXT() )
    {
      const DataDictionary& applicationDD =
        m_dataDictionaryProvider.getApplicationDataDictionary(m_senderDefaultApplVerID);
      next( Message( msg, sessionDD, applicationDD, m_validateLengthAndChecksum ), timeStamp, queued );
    }
    else
    {
      next( Message( msg, sessionDD, m_validateLengthAndChecksum ), timeStamp, queued );
    }
  }
  catch( InvalidMessage& e )
  {
    m_state.onEvent( e.what() );
 
    try
    {
      if( identifyType(msg) == MsgType_Logon )
      {
        m_state.onEvent( "Logon message is not valid" );
        disconnect();
      }
    } catch( MessageParseError& ) {}
    throw e;
  }
}

References disconnect(), FIX::identifyType(), m_dataDictionaryProvider, m_senderDefaultApplVerID, m_sessionID, m_state, m_validateLengthAndChecksum, and next().

next() [4/4]

void FIX::Session::next

(

const UtcTimeStamp &

timeStamp

)

Definition at line 130 of file Session.cpp.

{
  try
  {
    if ( !checkSessionTime(timeStamp) )
      { reset(); return; }
 
    if( !isEnabled() || !isLogonTime(timeStamp) )
    {
      if( isLoggedOn() )
      {
        if( !m_state.sentLogout() )
        {
          m_state.onEvent( "Initiated logout request" );
          generateLogout( m_state.logoutReason() );
        }
      }
      else
        return;
    }
 
    if ( !m_state.receivedLogon() )
    {
      if ( m_state.shouldSendLogon() && isLogonTime(timeStamp) )
      {
        generateLogon();
        m_state.onEvent( "Initiated logon request" );
      }
      else if ( m_state.alreadySentLogon() && m_state.logonTimedOut() )
      {
        m_state.onEvent( "Timed out waiting for logon response" );
        disconnect();
      }
      return ;
    }
 
    if ( m_state.heartBtInt() == 0 ) return ;
 
    if ( m_state.logoutTimedOut() )
    {
      m_state.onEvent( "Timed out waiting for logout response" );
      disconnect();
    }
 
    if ( m_state.withinHeartBeat() ) return ;
 
    if ( m_state.timedOut() )
    {
      m_state.onEvent( "Timed out waiting for heartbeat" );
      disconnect();
    }
    else
    {
      if ( m_state.needTestRequest() )
      {
        generateTestRequest( "TEST" );
        m_state.testRequest( m_state.testRequest() + 1 );
        m_state.onEvent( "Sent test request TEST" );
      }
      else if ( m_state.needHeartbeat() )
      {
        generateHeartbeat();
      }
    }
  }
  catch ( FIX::IOException& e )
  {
    m_state.onEvent( e.what() );
    disconnect();
  }
}

References checkSessionTime(), disconnect(), generateHeartbeat(), generateLogon(), generateLogout(), generateTestRequest(), isEnabled(), isLoggedOn(), isLogonTime(), m_state, and reset().

nextHeartbeat()

void FIX::Session::nextHeartbeat ( const Message & heartbeat, const UtcTimeStamp & timeStamp )

private

Definition at line 280 of file Session.cpp.

{
  if ( !verify( heartbeat ) ) return ;
  m_state.incrNextTargetMsgSeqNum();
  nextQueued( timeStamp );
}

References m_state, nextQueued(), and verify().

Referenced by next().

nextLogon()

void FIX::Session::nextLogon ( const Message & logon, const UtcTimeStamp & timeStamp )

private

Definition at line 202 of file Session.cpp.

{
  SenderCompID senderCompID;
  TargetCompID targetCompID;
  logon.getHeader().getField( senderCompID );
  logon.getHeader().getField( targetCompID );
 
  if( m_refreshOnLogon )
    refresh();
 
  if( !isEnabled() )
  {
    m_state.onEvent( "Session is not enabled for logon" );
    disconnect();
    return;
  }
 
  if( !isLogonTime(timeStamp) )
  {
    m_state.onEvent( "Received logon outside of valid logon time" );
    disconnect();
    return;
  }
 
  ResetSeqNumFlag resetSeqNumFlag(false);
  logon.getFieldIfSet(resetSeqNumFlag);
  m_state.receivedReset( resetSeqNumFlag );
 
  if( m_state.receivedReset() )
  {
    m_state.onEvent( "Logon contains ResetSeqNumFlag=Y, reseting sequence numbers to 1" );
    if( !m_state.sentReset() ) m_state.reset();
  }
 
  if( m_state.shouldSendLogon() && !m_state.receivedReset() )
  {
    m_state.onEvent( "Received logon response before sending request" );
    disconnect();
    return;
  }
 
  if( !m_state.initiate() && m_resetOnLogon )
    m_state.reset();
 
  if( !verify( logon, false, true ) )
    return;
  m_state.receivedLogon( true );
 
  if ( !m_state.initiate() 
       || (m_state.receivedReset() && !m_state.sentReset()) )
  {
    logon.getFieldIfSet(m_state.heartBtInt());
    m_state.onEvent( "Received logon request" );
    generateLogon( logon );
    m_state.onEvent( "Responding to logon request" );
  }
  else
    m_state.onEvent( "Received logon response" );
 
  m_state.sentReset( false );
  m_state.receivedReset( false );
 
  MsgSeqNum msgSeqNum;
  logon.getHeader().getField( msgSeqNum );
  if ( isTargetTooHigh( msgSeqNum ) && !resetSeqNumFlag )
  {
    doTargetTooHigh( logon );
  }
  else
  {
    m_state.incrNextTargetMsgSeqNum();
    nextQueued( timeStamp );
  }
 
  if ( isLoggedOn() )
    m_application.onLogon( m_sessionID );
}

References disconnect(), doTargetTooHigh(), generateLogon(), isEnabled(), isLoggedOn(), isLogonTime(), isTargetTooHigh(), logon(), m_application, m_refreshOnLogon, m_resetOnLogon, m_sessionID, m_state, nextQueued(), refresh(), and verify().

Referenced by next().

nextLogout()

void FIX::Session::nextLogout ( const Message & logout, const UtcTimeStamp & timeStamp )

private

Definition at line 295 of file Session.cpp.

{
  if ( !verify( logout, false, false ) ) return ;
  if ( !m_state.sentLogout() )
  {
    m_state.onEvent( "Received logout request" );
    generateLogout();
    m_state.onEvent( "Sending logout response" );
  }
  else
    m_state.onEvent( "Received logout response" );
 
  m_state.incrNextTargetMsgSeqNum();
  if ( m_resetOnLogout ) m_state.reset();
  disconnect();
}

References disconnect(), generateLogout(), logout(), m_resetOnLogout, m_state, and verify().

Referenced by next().

nextQueued() [1/2]

void FIX::Session::nextQueued ( const UtcTimeStamp & timeStamp )

private

Definition at line 1238 of file Session.cpp.

{
  while ( nextQueued( getExpectedTargetNum(), timeStamp ) ) {}
}

References getExpectedTargetNum(), and nextQueued().

Referenced by next(), nextHeartbeat(), nextLogon(), nextQueued(), nextReject(), and nextTestRequest().

nextQueued() [2/2]

bool FIX::Session::nextQueued ( int num, const UtcTimeStamp & timeStamp )

private

Definition at line 1243 of file Session.cpp.

{
  Message msg;
  MsgType msgType;
 
  if( m_state.retrieve( num, msg ) )
  {
    m_state.onEvent( "Processing QUEUED message: "
                     + IntConvertor::convert( num ) );
    msg.getHeader().getField( msgType );
    if( msgType == MsgType_Logon
        || msgType == MsgType_ResendRequest )
    {
      m_state.incrNextTargetMsgSeqNum();
    }
    else
    {
      next( msg, timeStamp, true );
    }
    return true;
  }
  return false;
}

References FIX::IntConvertor::convert(), FIX::FieldMap::getField(), FIX::Message::getHeader(), m_state, and next().

nextReject()

void FIX::Session::nextReject ( const Message & reject, const UtcTimeStamp & timeStamp )

private

Definition at line 312 of file Session.cpp.

{
  if ( !verify( reject, false, true ) ) return ;
  m_state.incrNextTargetMsgSeqNum();
  nextQueued( timeStamp );
}

References m_state, nextQueued(), and verify().

Referenced by next().

nextResendRequest()

void FIX::Session::nextResendRequest ( const Message & resendRequest, const UtcTimeStamp & timeStamp )

private

Definition at line 344 of file Session.cpp.

{
  if ( !verify( resendRequest, false, false ) ) return ;
 
  Locker l( m_mutex );
 
  BeginSeqNo beginSeqNo;
  EndSeqNo endSeqNo;
  resendRequest.getField( beginSeqNo );
  resendRequest.getField( endSeqNo );
 
  m_state.onEvent( "Received ResendRequest FROM: "
       + IntConvertor::convert( beginSeqNo ) +
                   " TO: " + IntConvertor::convert( endSeqNo ) );
 
  std::string beginString = m_sessionID.getBeginString();
  if ( (beginString >= FIX::BeginString_FIX42 && endSeqNo == 0) ||
       (beginString <= FIX::BeginString_FIX42 && endSeqNo == 999999) ||
       (endSeqNo >= getExpectedSenderNum()) )
  { endSeqNo = getExpectedSenderNum() - 1; }
 
  if ( !m_persistMessages )
  {
    endSeqNo = EndSeqNo(endSeqNo + 1);
    int next = m_state.getNextSenderMsgSeqNum();
    if( endSeqNo > next )
      endSeqNo = EndSeqNo(next);
    generateSequenceReset( beginSeqNo, endSeqNo );
    return;
  }
 
  std::vector < std::string > messages;
  m_state.get( beginSeqNo, endSeqNo, messages );
 
  std::vector < std::string > ::iterator i;
  MsgSeqNum msgSeqNum(0);
  MsgType msgType;
  int begin = 0;
  int current = beginSeqNo;
  std::string messageString;
 
  for ( i = messages.begin(); i != messages.end(); ++i )
  {
    SmartPtr<FIX::Message> pMsg;
    std::string strMsgType;
    const DataDictionary& sessionDD =
      m_dataDictionaryProvider.getSessionDataDictionary(m_sessionID.getBeginString());
    if (sessionDD.isMessageFieldsOrderPreserved())
    {
      std::string::size_type equalSign = (*i).find("\00135=");
      equalSign += 4;
      std::string::size_type soh = (*i).find_first_of('\001', equalSign);
      strMsgType = (*i).substr(equalSign, soh - equalSign);
#ifdef HAVE_EMX
      if (FIX::Message::isAdminMsgType(strMsgType) == false)
      {
        equalSign = (*i).find("\0019426=", soh);
        if (equalSign == std::string::npos)
          throw FIX::IOException("EMX message type (9426) not found");
 
        equalSign += 6;
        soh = (*i).find_first_of('\001', equalSign);
        if (soh == std::string::npos)
          throw FIX::IOException("EMX message type (9426) soh char not found");
        strMsgType.assign((*i).substr(equalSign, soh - equalSign));
      }
#endif
    }
 
    if( m_sessionID.isFIXT() )
    {
      Message msg;
      msg.setStringHeader(*i);
      ApplVerID applVerID;
      if( !msg.getHeader().getFieldIfSet(applVerID) )
        applVerID = m_senderDefaultApplVerID;
 
      const DataDictionary& applicationDD =
          m_dataDictionaryProvider.getApplicationDataDictionary(applVerID);
      if (strMsgType.empty())
        pMsg.reset( new Message( *i, sessionDD, applicationDD, m_validateLengthAndChecksum ));
      else
      {
        const message_order & hdrOrder = sessionDD.getHeaderOrderedFields();
        const message_order & trlOrder = sessionDD.getTrailerOrderedFields();
        const message_order & msgOrder = applicationDD.getMessageOrderedFields(strMsgType);
        pMsg.reset( new Message( hdrOrder, trlOrder, msgOrder, *i, sessionDD, applicationDD, m_validateLengthAndChecksum ));
      }
    }
    else
    {
      if (strMsgType.empty())
        pMsg.reset( new Message( *i, sessionDD, m_validateLengthAndChecksum ));
      else
      {
        const message_order & hdrOrder = sessionDD.getHeaderOrderedFields();
        const message_order & trlOrder = sessionDD.getTrailerOrderedFields();
        const message_order & msgOrder = sessionDD.getMessageOrderedFields(strMsgType);
        pMsg.reset(new Message(hdrOrder, trlOrder, msgOrder, *i, sessionDD, m_validateLengthAndChecksum ));
      }
    }
 
    Message & msg = *pMsg;
 
    msg.getHeader().getField( msgSeqNum );
    msg.getHeader().getField( msgType );
 
    if( (current != msgSeqNum) && !begin )
      begin = current;
 
    if ( Message::isAdminMsgType( msgType ) )
    {
      if ( !begin ) begin = msgSeqNum;
    }
    else
    {
      if ( resend( msg ) )
      {
        if ( begin ) generateSequenceReset( begin, msgSeqNum );
        send( msg.toString(messageString) );
        m_state.onEvent( "Resending Message: "
                         + IntConvertor::convert( msgSeqNum ) );
        begin = 0;
      }
      else
      { if ( !begin ) begin = msgSeqNum; }
    }
    current = msgSeqNum + 1;
  }
  if ( begin )
  {
    generateSequenceReset( begin, msgSeqNum + 1 );
  }
 
  if ( endSeqNo > msgSeqNum )
  {
    endSeqNo = EndSeqNo(endSeqNo + 1);
    int next = m_state.getNextSenderMsgSeqNum();
    if( endSeqNo > next )
      endSeqNo = EndSeqNo(next);
    generateSequenceReset( beginSeqNo, endSeqNo );
  }
 
  resendRequest.getHeader().getField( msgSeqNum );
  if( !isTargetTooHigh(msgSeqNum) && !isTargetTooLow(msgSeqNum) )
    m_state.incrNextTargetMsgSeqNum();
}

References FIX::BeginString_FIX42, FIX::IntConvertor::convert(), generateSequenceReset(), getExpectedSenderNum(), FIX::FieldMap::getField(), FIX::FieldMap::getFieldIfSet(), FIX::Message::getHeader(), FIX::DataDictionary::getHeaderOrderedFields(), FIX::DataDictionary::getMessageOrderedFields(), FIX::DataDictionary::getTrailerOrderedFields(), FIX::Message::isAdminMsgType(), FIX::DataDictionary::isMessageFieldsOrderPreserved(), isTargetTooHigh(), isTargetTooLow(), m_dataDictionaryProvider, m_mutex, m_persistMessages, m_senderDefaultApplVerID, m_sessionID, m_state, m_validateLengthAndChecksum, next(), resend(), send(), FIX::Message::setStringHeader(), SmartPtr, FIX::Message::toString(), and verify().

Referenced by next().

nextSequenceReset()

void FIX::Session::nextSequenceReset ( const Message & sequenceReset, const UtcTimeStamp & timeStamp )

private

Definition at line 319 of file Session.cpp.

{
  bool isGapFill = false;
  GapFillFlag gapFillFlag;
  if ( sequenceReset.getFieldIfSet( gapFillFlag ) )
  {
    isGapFill = gapFillFlag;
  }
 
  if ( !verify( sequenceReset, isGapFill, isGapFill ) ) return ;
 
  NewSeqNo newSeqNo;
  if ( sequenceReset.getFieldIfSet( newSeqNo ) )
  {
    m_state.onEvent( "Received SequenceReset FROM: "
                     + IntConvertor::convert( getExpectedTargetNum() ) +
                     " TO: " + IntConvertor::convert( newSeqNo ) );
 
    if ( newSeqNo > getExpectedTargetNum() )
      m_state.setNextTargetMsgSeqNum( MsgSeqNum( newSeqNo ) );
    else if ( newSeqNo < getExpectedTargetNum() )
      generateReject( sequenceReset, SessionRejectReason_VALUE_IS_INCORRECT );
  }
}

References FIX::IntConvertor::convert(), generateReject(), getExpectedTargetNum(), FIX::FieldMap::getFieldIfSet(), m_state, and verify().

Referenced by next().

nextTestRequest()

void FIX::Session::nextTestRequest ( const Message & testRequest, const UtcTimeStamp & timeStamp )

private

Definition at line 287 of file Session.cpp.

{
  if ( !verify( testRequest ) ) return ;
  generateHeartbeat( testRequest );
  m_state.incrNextTargetMsgSeqNum();
  nextQueued( timeStamp );
}

References generateHeartbeat(), m_state, nextQueued(), and verify().

Referenced by next().

numSessions()

size_t FIX::Session::numSessions ( )

static

Definition at line 1553 of file Session.cpp.

{
  Locker locker( s_mutex );
  return s_sessions.size();
}

References s_mutex, and s_sessions.

Referenced by FIX::HttpConnection::processRoot().

persist()

void FIX::Session::persist ( const Message & message, const std::string & messageString ) throw ( IOException )

private

Definition at line 663 of file Session.cpp.

{
  MsgSeqNum msgSeqNum;
  message.getHeader().getField( msgSeqNum );
  if( m_persistMessages )
    m_state.set( msgSeqNum, messageString );
  m_state.incrNextSenderMsgSeqNum();
}

References m_persistMessages, and m_state.

Referenced by sendRaw().

populateRejectReason() [1/2]

void FIX::Session::populateRejectReason ( Message & reject, const std::string & text )

private

Definition at line 1029 of file Session.cpp.

{
  reject.setField( Text( text ) );
}

References FIX::FieldMap::setField().

populateRejectReason() [2/2]

void FIX::Session::populateRejectReason ( Message & reject, int field, const std::string & text )

private

Definition at line 1009 of file Session.cpp.

{
  MsgType msgType;
   reject.getHeader().getField( msgType );
 
  if ( msgType == MsgType_Reject 
       && m_sessionID.getBeginString() >= FIX::BeginString_FIX42 )
  {
    reject.setField( RefTagID( field ) );
    reject.setField( Text( text ) );
  }
  else
  {
    std::stringstream stream;
    stream << text << " (" << field << ")";
    reject.setField( Text( stream.str() ) );
  }
}

References FIX::BeginString_FIX42, FIX::FieldMap::getField(), FIX::Message::getHeader(), m_sessionID, and FIX::FieldMap::setField().

Referenced by generateBusinessReject(), and generateReject().

receivedLogon()

bool FIX::Session::receivedLogon ( )

inline

Definition at line 64 of file Session.h.

{ return m_state.receivedLogon(); }

References m_state.

Referenced by isLoggedOn().

refresh()

void FIX::Session::refresh ( ) throw ( IOException )

inline

Definition at line 68 of file Session.h.

  { m_state.refresh(); }

References m_state.

Referenced by generateLogon(), nextLogon(), FIX::HttpConnection::processRefreshSession(), and FIX::HttpConnection::processRefreshSessions().

registerSession()

Session * FIX::Session::registerSession ( const SessionID & sessionID )

static

Definition at line 1537 of file Session.cpp.

{
  Locker locker( s_mutex );
  Session* pSession = lookupSession( sessionID );
  if ( pSession == 0 ) return 0;
  if ( isSessionRegistered( sessionID ) ) return 0;
  s_registered[ sessionID ] = pSession;
  return pSession;
}

References isSessionRegistered(), lookupSession(), s_mutex, s_registered, and Session().

Referenced by FIX::SocketConnection::read(), and FIX::ThreadedSocketConnection::setSession().

removeSession()

void FIX::Session::removeSession ( Session & s )

staticprivate

Definition at line 1573 of file Session.cpp.

{
  Locker locker( s_mutex );
  s_sessions.erase( s.m_sessionID );
  s_sessionIDs.erase( s.m_sessionID );
  s_registered.erase( s.m_sessionID );
}

References m_sessionID, s_mutex, s_registered, s_sessionIDs, s_sessions, and Session().

Referenced by ~Session().

resend()

bool FIX::Session::resend ( Message & message )

private

Definition at line 643 of file Session.cpp.

{
  SendingTime sendingTime;
  MsgSeqNum msgSeqNum;
  Header& header = message.getHeader();
  header.getField( sendingTime );
  header.getField( msgSeqNum );
  insertOrigSendingTime( header, sendingTime );
  header.setField( PossDupFlag( true ) );
  insertSendingTime( header );
 
  try
  {
    m_application.toApp( message, m_sessionID );
    return true;
  }
  catch ( DoNotSend& )
  { return false; }
}

References FIX::FieldMap::getField(), FIX::Message::getHeader(), insertOrigSendingTime(), insertSendingTime(), m_application, m_sessionID, and FIX::FieldMap::setField().

Referenced by nextResendRequest().

reset()

void FIX::Session::reset ( ) throw ( IOException )

inline

Definition at line 66 of file Session.h.

  { generateLogout(); disconnect(); m_state.reset(); }

References disconnect(), generateLogout(), and m_state.

Referenced by next(), next(), FIX::HttpConnection::processResetSession(), FIX::HttpConnection::processResetSessions(), Session(), and setResponder().

send() [1/2]

bool FIX::Session::send ( const std::string & string )

private

Definition at line 606 of file Session.cpp.

{
  if ( !m_pResponder ) return false;
  m_state.onOutgoing( string );
  return m_pResponder->send( string );
}

References m_pResponder, and m_state.

send() [2/2]

bool FIX::Session::send

(

Message &

message

)

Definition at line 523 of file Session.cpp.

{
  message.getHeader().removeField( FIELD::PossDupFlag );
  message.getHeader().removeField( FIELD::OrigSendingTime );
  return sendRaw( message );
}

References FIX::Message::getHeader(), FIX::FieldMap::removeField(), and sendRaw().

Referenced by nextResendRequest(), sendRaw(), and sendToTarget().

sendRaw()

bool FIX::Session::sendRaw ( Message & message, int msgSeqNum = 0 )

private

Definition at line 530 of file Session.cpp.

{
  Locker l( m_mutex );
 
  try
  {
    Header& header = message.getHeader();
 
    MsgType msgType;
    header.getFieldIfSet(msgType);
 
    fill( header );
    std::string messageString;
 
    if ( num )
      header.setField( MsgSeqNum( num ) );
 
    if ( Message::isAdminMsgType( msgType ) )
    {
      m_application.toAdmin( message, m_sessionID );
 
      if( msgType == "A" && !m_state.receivedReset() )
      {
        ResetSeqNumFlag resetSeqNumFlag( false );
        message.getFieldIfSet(resetSeqNumFlag);
 
        if( resetSeqNumFlag )
        {
          m_state.reset();
          message.getHeader().setField( MsgSeqNum(getExpectedSenderNum()) );
        }
        m_state.sentReset( resetSeqNumFlag );
      }
 
      message.toString( messageString );
 
      if( !num )
        persist( message, messageString );
 
      if (
        msgType == "A" || msgType == "5"
        || msgType == "2" || msgType == "4"
        || isLoggedOn() )
      {
        send( messageString );
      }
    }
    else
    {
      // do not send application messages if they will just be cleared
      if( !isLoggedOn() && shouldSendReset() )
        return false;
 
      try
      {
        m_application.toApp( message, m_sessionID );
        message.toString( messageString );
 
        if( !num )
          persist( message, messageString );
 
        if ( isLoggedOn() )
          send( messageString );
      }
      catch ( DoNotSend& ) { return false; }
    }
 
    return true;
  }
  catch ( IOException& e )
  {
    m_state.onEvent( e.what() );
    return false;
  }
}

References fill(), getExpectedSenderNum(), FIX::FieldMap::getFieldIfSet(), FIX::Message::getHeader(), FIX::Message::isAdminMsgType(), isLoggedOn(), m_application, m_mutex, m_sessionID, m_state, persist(), send(), FIX::FieldMap::setField(), shouldSendReset(), and FIX::Message::toString().

Referenced by generateBusinessReject(), generateHeartbeat(), generateHeartbeat(), generateLogon(), generateLogon(), generateLogout(), generateReject(), generateReject(), generateResendRequest(), generateSequenceReset(), generateTestRequest(), and send().

sendToTarget() [1/4]

bool FIX::Session::sendToTarget ( Message & message, const SenderCompID & senderCompID, const TargetCompID & targetCompID, const std::string & qualifier = "" ) throw ( SessionNotFound )

static

Definition at line 1464 of file Session.cpp.

{
  message.getHeader().setField( senderCompID );
  message.getHeader().setField( targetCompID );
  return sendToTarget( message, qualifier );
}

References sendToTarget().

sendToTarget() [2/4]

bool FIX::Session::sendToTarget ( Message & message, const SessionID & sessionID ) throw ( SessionNotFound )

static

Definition at line 1455 of file Session.cpp.

{
  message.setSessionID( sessionID );
  Session* pSession = lookupSession( sessionID );
  if ( !pSession ) throw SessionNotFound();
  return pSession->send( message );
}

References lookupSession(), send(), and Session().

sendToTarget() [3/4]

bool FIX::Session::sendToTarget ( Message & message, const std::string & qualifier = "" ) throw ( SessionNotFound )

static

Definition at line 1444 of file Session.cpp.

{
  try
  {
    SessionID sessionID = message.getSessionID( qualifier );
    return sendToTarget( message, sessionID );
  }
  catch ( FieldNotFound& ) { throw SessionNotFound(); }
}

References sendToTarget().

Referenced by sendToTarget(), sendToTarget(), and sendToTarget().

sendToTarget() [4/4]

bool FIX::Session::sendToTarget ( Message & message, const std::string & senderCompID, const std::string & targetCompID, const std::string & qualifier = "" ) throw ( SessionNotFound )

static

Definition at line 1476 of file Session.cpp.

{
  return sendToTarget( message, SenderCompID( sender ),
                       TargetCompID( target ), qualifier );
}

References sendToTarget().

sentLogon()

bool FIX::Session::sentLogon ( )

inline

Definition at line 62 of file Session.h.

{ return m_state.sentLogon(); }

References m_state.

Referenced by isLoggedOn().

sentLogout()

bool FIX::Session::sentLogout ( )

inline

Definition at line 63 of file Session.h.

{ return m_state.sentLogout(); }

References m_state.

set()

bool FIX::Session::set ( int s, const Message & m )

private

setCheckCompId()

void FIX::Session::setCheckCompId ( bool value )

inline

Definition at line 139 of file Session.h.

    { m_checkCompId = value; }

References m_checkCompId.

Referenced by FIX::HttpConnection::processSession().

setCheckLatency()

void FIX::Session::setCheckLatency ( bool value )

inline

Definition at line 144 of file Session.h.

    { m_checkLatency = value; }

References m_checkLatency.

Referenced by FIX::HttpConnection::processSession().

setDataDictionaryProvider()

void FIX::Session::setDataDictionaryProvider ( const DataDictionaryProvider & dataDictionaryProvider )

inline

Definition at line 77 of file Session.h.

  { m_dataDictionaryProvider = dataDictionaryProvider; }

References m_dataDictionaryProvider.

setLogonTime()

void FIX::Session::setLogonTime ( const TimeRange & value )

inline

Definition at line 119 of file Session.h.

    { m_logonTime = value; }

References m_logonTime.

setLogonTimeout()

void FIX::Session::setLogonTimeout ( int value )

inline

Definition at line 154 of file Session.h.

    { m_state.logonTimeout( value ); }

References m_state.

Referenced by FIX::HttpConnection::processSession().

setLogoutTimeout()

void FIX::Session::setLogoutTimeout ( int value )

inline

Definition at line 159 of file Session.h.

    { m_state.logoutTimeout( value ); }

References m_state.

Referenced by FIX::HttpConnection::processSession().

setMaxLatency()

void FIX::Session::setMaxLatency ( int value )

inline

Definition at line 149 of file Session.h.

    { m_maxLatency = value; }

References m_maxLatency.

Referenced by FIX::HttpConnection::processSession().

setMillisecondsInTimeStamp()

void FIX::Session::setMillisecondsInTimeStamp ( bool value )

inline

Definition at line 184 of file Session.h.

    { if (value)
        m_timestampPrecision = 3;
      else
        m_timestampPrecision = 0;
    }

References m_timestampPrecision.

Referenced by FIX::HttpConnection::processSession().

setNextSenderMsgSeqNum()

void FIX::Session::setNextSenderMsgSeqNum ( int num ) throw ( IOException )

inline

Definition at line 70 of file Session.h.

  { m_state.setNextSenderMsgSeqNum( num ); }

References m_state.

Referenced by FIX::HttpConnection::processSession().

setNextTargetMsgSeqNum()

void FIX::Session::setNextTargetMsgSeqNum ( int num ) throw ( IOException )

inline

Definition at line 72 of file Session.h.

  { m_state.setNextTargetMsgSeqNum( num ); }

References m_state.

Referenced by FIX::HttpConnection::processSession().

setPersistMessages()

void FIX::Session::setPersistMessages ( bool value )

inline

Definition at line 202 of file Session.h.

    { m_persistMessages = value; }

References m_persistMessages.

Referenced by FIX::HttpConnection::processSession().

setRefreshOnLogon()

void FIX::Session::setRefreshOnLogon ( bool value )

inline

Definition at line 179 of file Session.h.

    { m_refreshOnLogon = value; } 

References m_refreshOnLogon.

Referenced by FIX::HttpConnection::processSession().

setResetOnDisconnect()

void FIX::Session::setResetOnDisconnect ( bool value )

inline

Definition at line 174 of file Session.h.

    { m_resetOnDisconnect = value; }

References m_resetOnDisconnect.

Referenced by FIX::HttpConnection::processSession().

setResetOnLogon()

void FIX::Session::setResetOnLogon ( bool value )

inline

Definition at line 164 of file Session.h.

    { m_resetOnLogon = value; }

References m_resetOnLogon.

Referenced by FIX::HttpConnection::processSession().

setResetOnLogout()

void FIX::Session::setResetOnLogout ( bool value )

inline

Definition at line 169 of file Session.h.

    { m_resetOnLogout = value; }

References m_resetOnLogout.

Referenced by FIX::HttpConnection::processSession().

setResponder()

void FIX::Session::setResponder ( Responder * pR )

inline

Definition at line 210 of file Session.h.

  {
    if( !checkSessionTime(UtcTimeStamp()) )
      reset();
    m_pResponder = pR;
  }

References checkSessionTime(), m_pResponder, and reset().

setSenderDefaultApplVerID()

void FIX::Session::setSenderDefaultApplVerID ( const std::string & senderDefaultApplVerID )

inline

Definition at line 124 of file Session.h.

    { m_senderDefaultApplVerID = senderDefaultApplVerID; }

References m_senderDefaultApplVerID.

setSendRedundantResendRequests()

void FIX::Session::setSendRedundantResendRequests ( bool value )

inline

Definition at line 134 of file Session.h.

    { m_sendRedundantResendRequests = value; } 

References m_sendRedundantResendRequests.

Referenced by FIX::HttpConnection::processSession().

setTargetDefaultApplVerID()

void FIX::Session::setTargetDefaultApplVerID ( const std::string & targetDefaultApplVerID )

inline

Definition at line 129 of file Session.h.

    { m_targetDefaultApplVerID = targetDefaultApplVerID; }

References m_targetDefaultApplVerID.

Referenced by next().

setTimestampPrecision()

void FIX::Session::setTimestampPrecision ( int precision )

inline

Definition at line 192 of file Session.h.

    {
      if (precision < 0 || precision > 9)
        return;
 
      m_timestampPrecision = precision;
    }

References m_timestampPrecision.

setValidateLengthAndChecksum()

void FIX::Session::setValidateLengthAndChecksum ( bool value )

inline

Definition at line 207 of file Session.h.

    { m_validateLengthAndChecksum = value; }

References m_validateLengthAndChecksum.

shouldSendReset()

bool FIX::Session::shouldSendReset ( )

private

Definition at line 1106 of file Session.cpp.

{
  std::string beginString = m_sessionID.getBeginString();
  return beginString >= FIX::BeginString_FIX41
    && ( m_resetOnLogon || 
         m_resetOnLogout || 
         m_resetOnDisconnect )
    && ( getExpectedSenderNum() == 1 )
    && ( getExpectedTargetNum() == 1 );
}

References FIX::BeginString_FIX41, getExpectedSenderNum(), getExpectedTargetNum(), m_resetOnDisconnect, m_resetOnLogon, m_resetOnLogout, and m_sessionID.

Referenced by generateLogon(), and sendRaw().

unregisterSession()

void FIX::Session::unregisterSession ( const SessionID & sessionID )

static

Definition at line 1547 of file Session.cpp.

{
  Locker locker( s_mutex );
  s_registered.erase( sessionID );
}

References s_mutex, and s_registered.

Referenced by FIX::Acceptor::stop(), FIX::SocketConnection::~SocketConnection(), and FIX::ThreadedSocketConnection::~ThreadedSocketConnection().

validLogonState()

bool FIX::Session::validLogonState ( const MsgType & msgType )

private

Definition at line 1117 of file Session.cpp.

{
  if ( (msgType == MsgType_Logon && m_state.sentReset()) 
       || (m_state.receivedReset()) )
    return true;
  if ( (msgType == MsgType_Logon && !m_state.receivedLogon())
       || (msgType != MsgType_Logon && m_state.receivedLogon()) )
    return true;
  if ( msgType == MsgType_Logout && m_state.sentLogon() )
    return true;
  if ( msgType != MsgType_Logout && m_state.sentLogout() )
    return true;
  if ( msgType == MsgType_SequenceReset ) 
    return true;
  if ( msgType == MsgType_Reject )
    return true;
 
  return false;
}

References m_state.

Referenced by verify().

verify()

bool FIX::Session::verify ( const Message & msg, bool checkTooHigh = true, bool checkTooLow = true )

private

Definition at line 1034 of file Session.cpp.

{
  const MsgType* pMsgType = 0;
  const MsgSeqNum* pMsgSeqNum = 0;
 
  try
  {
    const Header& header = msg.getHeader();
 
    pMsgType = FIELD_GET_PTR( header, MsgType );
    const SenderCompID& senderCompID = FIELD_GET_REF( header, SenderCompID );
    const TargetCompID& targetCompID = FIELD_GET_REF( header, TargetCompID );
    const SendingTime& sendingTime = FIELD_GET_REF( header, SendingTime );
 
    if( checkTooHigh || checkTooLow )
      pMsgSeqNum = FIELD_GET_PTR( header, MsgSeqNum );
 
    if ( !validLogonState( *pMsgType ) )
      throw std::logic_error( "Logon state is not valid for message" );
 
    if ( !isGoodTime( sendingTime ) )
    {
      doBadTime( msg );
      return false;
    }
    if ( !isCorrectCompID( senderCompID, targetCompID ) )
    {
      doBadCompID( msg );
      return false;
    }
 
    if ( checkTooHigh && isTargetTooHigh( *pMsgSeqNum ) )
    {
      doTargetTooHigh( msg );
      return false;
    }
    else if ( checkTooLow && isTargetTooLow( *pMsgSeqNum ) )
    {
      doTargetTooLow( msg );
      return false;
    }
 
    if ( (checkTooHigh || checkTooLow) && m_state.resendRequested() )
    {
      SessionState::ResendRange range = m_state.resendRange();
 
      if ( *pMsgSeqNum >= range.second )
      {
        m_state.onEvent ("ResendRequest for messages FROM: " +
                         IntConvertor::convert (range.first) + " TO: " +
                         IntConvertor::convert (range.second) +
                         " has been satisfied.");
        m_state.resendRange (0, 0);
      }
    }
  }
  catch ( std::exception& e )
  {
    m_state.onEvent( e.what() );
    disconnect();
    return false;
  }
 
  UtcTimeStamp now;
  m_state.lastReceivedTime( now );
  m_state.testRequest( 0 );
 
  fromCallback( pMsgType ? *pMsgType : MsgType(), msg, m_sessionID );
  return true;
}

References FIX::IntConvertor::convert(), disconnect(), doBadCompID(), doBadTime(), doTargetTooHigh(), doTargetTooLow(), FIELD_GET_PTR, FIELD_GET_REF, fromCallback(), FIX::Message::getHeader(), isCorrectCompID(), isGoodTime(), isTargetTooHigh(), isTargetTooLow(), m_sessionID, m_state, and validLogonState().

Referenced by next(), nextHeartbeat(), nextLogon(), nextLogout(), nextReject(), nextResendRequest(), nextSequenceReset(), and nextTestRequest().

Member Data Documentation

m_application

Application& FIX::Session::m_application

private

Definition at line 318 of file Session.h.

Referenced by disconnect(), fromCallback(), nextLogon(), resend(), sendRaw(), and Session().

m_checkCompId

bool FIX::Session::m_checkCompId

private

Definition at line 326 of file Session.h.

Referenced by getCheckCompId(), isCorrectCompID(), Session(), and setCheckCompId().

m_checkLatency

bool FIX::Session::m_checkLatency

private

Definition at line 327 of file Session.h.

Referenced by getCheckLatency(), isGoodTime(), Session(), and setCheckLatency().

m_dataDictionaryProvider

DataDictionaryProvider FIX::Session::m_dataDictionaryProvider

private

Definition at line 338 of file Session.h.

Referenced by getDataDictionaryProvider(), newMessage(), next(), next(), nextResendRequest(), Session(), and setDataDictionaryProvider().

m_logonTime

TimeRange FIX::Session::m_logonTime

private

Definition at line 321 of file Session.h.

Referenced by getLogonTime(), isLogonTime(), Session(), and setLogonTime().

m_maxLatency

int FIX::Session::m_maxLatency

private

Definition at line 328 of file Session.h.

Referenced by getMaxLatency(), isGoodTime(), Session(), and setMaxLatency().

m_messageStoreFactory

MessageStoreFactory& FIX::Session::m_messageStoreFactory

private

Definition at line 339 of file Session.h.

Referenced by Session(), and ~Session().

m_mutex

Mutex FIX::Session::m_mutex

private

Definition at line 342 of file Session.h.

Referenced by disconnect(), nextResendRequest(), and sendRaw().

m_persistMessages

bool FIX::Session::m_persistMessages

private

Definition at line 334 of file Session.h.

Referenced by getPersistMessages(), nextResendRequest(), persist(), Session(), and setPersistMessages().

m_pLogFactory

LogFactory* FIX::Session::m_pLogFactory

private

Definition at line 340 of file Session.h.

Referenced by Session(), and ~Session().

m_pResponder

Responder* FIX::Session::m_pResponder

private

Definition at line 341 of file Session.h.

Referenced by disconnect(), send(), Session(), and setResponder().

m_refreshOnLogon

bool FIX::Session::m_refreshOnLogon

private

Definition at line 332 of file Session.h.

Referenced by generateLogon(), getRefreshOnLogon(), nextLogon(), Session(), and setRefreshOnLogon().

m_resetOnDisconnect

bool FIX::Session::m_resetOnDisconnect

private

Definition at line 331 of file Session.h.

Referenced by disconnect(), getResetOnDisconnect(), Session(), setResetOnDisconnect(), and shouldSendReset().

m_resetOnLogon

bool FIX::Session::m_resetOnLogon

private

Definition at line 329 of file Session.h.

Referenced by generateLogon(), getResetOnLogon(), nextLogon(), Session(), setResetOnLogon(), and shouldSendReset().

m_resetOnLogout

bool FIX::Session::m_resetOnLogout

private

Definition at line 330 of file Session.h.

Referenced by getResetOnLogout(), nextLogout(), Session(), setResetOnLogout(), and shouldSendReset().

m_senderDefaultApplVerID

std::string FIX::Session::m_senderDefaultApplVerID

private

Definition at line 323 of file Session.h.

Referenced by generateBusinessReject(), generateLogon(), generateLogon(), getSenderDefaultApplVerID(), newMessage(), next(), nextResendRequest(), Session(), and setSenderDefaultApplVerID().

m_sendRedundantResendRequests

bool FIX::Session::m_sendRedundantResendRequests

private

Definition at line 325 of file Session.h.

Referenced by doTargetTooHigh(), getSendRedundantResendRequests(), Session(), and setSendRedundantResendRequests().

m_sessionID

SessionID FIX::Session::m_sessionID

private

Definition at line 319 of file Session.h.

Referenced by addSession(), disconnect(), fill(), fromCallback(), generateBusinessReject(), generateLogon(), generateLogon(), generateReject(), generateReject(), getSessionID(), insertOrigSendingTime(), insertSendingTime(), isCorrectCompID(), newMessage(), next(), next(), nextLogon(), nextResendRequest(), populateRejectReason(), removeSession(), resend(), sendRaw(), Session(), shouldSendReset(), and verify().

m_sessionTime

TimeRange FIX::Session::m_sessionTime

private

Definition at line 320 of file Session.h.

Referenced by checkSessionTime(), isSessionTime(), and Session().

m_state

SessionState FIX::Session::m_state

private

Definition at line 337 of file Session.h.

Referenced by checkSessionTime(), disconnect(), doTargetTooHigh(), fill(), generateBusinessReject(), generateLogon(), generateLogon(), generateLogout(), generateReject(), generateReject(), generateResendRequest(), generateSequenceReset(), getExpectedSenderNum(), getExpectedTargetNum(), getHeartBtInt(), getLog(), getLogonTimeout(), getLogoutTimeout(), getStore(), isAcceptor(), isEnabled(), isInitiator(), isTargetTooHigh(), isTargetTooLow(), logon(), logout(), next(), next(), next(), nextHeartbeat(), nextLogon(), nextLogout(), nextQueued(), nextReject(), nextResendRequest(), nextSequenceReset(), nextTestRequest(), persist(), receivedLogon(), refresh(), reset(), send(), sendRaw(), sentLogon(), sentLogout(), Session(), setLogonTimeout(), setLogoutTimeout(), setNextSenderMsgSeqNum(), setNextTargetMsgSeqNum(), validLogonState(), verify(), and ~Session().

m_targetDefaultApplVerID

std::string FIX::Session::m_targetDefaultApplVerID

private

Definition at line 324 of file Session.h.

Referenced by getTargetDefaultApplVerID(), next(), Session(), and setTargetDefaultApplVerID().

m_timestampPrecision

int FIX::Session::m_timestampPrecision

private

Definition at line 333 of file Session.h.

Referenced by getMillisecondsInTimeStamp(), getTimestampPrecision(), insertOrigSendingTime(), insertSendingTime(), Session(), setMillisecondsInTimeStamp(), and setTimestampPrecision().

m_validateLengthAndChecksum

bool FIX::Session::m_validateLengthAndChecksum

private

Definition at line 335 of file Session.h.

Referenced by getValidateLengthAndChecksum(), next(), nextResendRequest(), Session(), and setValidateLengthAndChecksum().

s_mutex

Mutex FIX::Session::s_mutex

staticprivate

Definition at line 347 of file Session.h.

Referenced by addSession(), doesSessionExist(), isSessionRegistered(), lookupSession(), numSessions(), registerSession(), removeSession(), and unregisterSession().

s_registered

Session::Sessions FIX::Session::s_registered

staticprivate

Definition at line 346 of file Session.h.

Referenced by isSessionRegistered(), registerSession(), removeSession(), and unregisterSession().

s_sessionIDs

Session::SessionIDs FIX::Session::s_sessionIDs

staticprivate

Definition at line 345 of file Session.h.

Referenced by addSession(), getSessions(), and removeSession().

s_sessions

Session::Sessions FIX::Session::s_sessions

staticprivate

Definition at line 344 of file Session.h.

Referenced by addSession(), doesSessionExist(), lookupSession(), numSessions(), and removeSession().

---

The documentation for this class was generated from the following files:

• Session.h
• Session.cpp