/usr/include/quickfix/Acceptor.h is in libquickfix-dev 1.14.4+dfsg-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 | /* -*- C++ -*- */
/****************************************************************************
** Copyright (c) 2001-2014
**
** This file is part of the QuickFIX FIX Engine
**
** This file may be distributed under the terms of the quickfixengine.org
** license as defined by quickfixengine.org and appearing in the file
** LICENSE included in the packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.quickfixengine.org/LICENSE for licensing information.
**
** Contact ask@quickfixengine.org if any conditions of this licensing are
** not clear to you.
**
****************************************************************************/
#ifndef FIX_ACCEPTOR_H
#define FIX_ACCEPTOR_H
#ifdef _MSC_VER
#pragma warning( disable : 4503 4355 4786 4290 )
#endif
#include "Application.h"
#include "MessageStore.h"
#include "Log.h"
#include "Responder.h"
#include "SessionSettings.h"
#include "Exceptions.h"
#include <map>
#include <string>
namespace FIX
{
class Client;
class Session;
/**
* Base for classes which act as an acceptor for incoming connections.
*
* Most users will not need to implement one of these. The default
* SocketAcceptor implementation will be used in most cases.
*/
class Acceptor
{
public:
Acceptor( Application&, MessageStoreFactory&,
const SessionSettings& ) throw( ConfigError );
Acceptor( Application&, MessageStoreFactory&,
const SessionSettings&, LogFactory& ) throw( ConfigError );
virtual ~Acceptor();
Log* getLog()
{
if( m_pLog ) return m_pLog;
return &m_nullLog;
}
/// Start acceptor.
void start() throw ( ConfigError, RuntimeError );
/// Block on the acceptor
void block() throw ( ConfigError, RuntimeError );
/// Poll the acceptor
bool poll( double timeout = 0.0 ) throw ( ConfigError, RuntimeError );
/// Stop acceptor.
void stop( bool force = false );
/// Check to see if any sessions are currently logged on
bool isLoggedOn();
Session* getSession( const std::string& msg, Responder& );
const std::set<SessionID>& getSessions() const { return m_sessionIDs; }
Session* getSession( const SessionID& sessionID ) const;
const Dictionary* const getSessionSettings( const SessionID& sessionID ) const;
bool has( const SessionID& id )
{ return m_sessions.find( id ) != m_sessions.end(); }
bool isStopped() { return m_stop; }
Application& getApplication() { return m_application; }
MessageStoreFactory& getMessageStoreFactory()
{ return m_messageStoreFactory; }
private:
void initialize() throw ( ConfigError );
/// Implemented to configure acceptor
virtual void onConfigure( const SessionSettings& ) throw ( ConfigError ) {};
/// Implemented to initialize acceptor
virtual void onInitialize( const SessionSettings& ) throw ( RuntimeError ) {};
/// Implemented to start listening for connections.
virtual void onStart() = 0;
/// Implemented to connect and poll for events.
virtual bool onPoll( double second ) = 0;
/// Implemented to stop a running acceptor.
virtual void onStop() = 0;
static THREAD_PROC startThread( void* p );
typedef std::set < SessionID > SessionIDs;
typedef std::map < SessionID, Session* > Sessions;
thread_id m_threadid;
Sessions m_sessions;
SessionIDs m_sessionIDs;
Application& m_application;
MessageStoreFactory& m_messageStoreFactory;
SessionSettings m_settings;
LogFactory* m_pLogFactory;
Log* m_pLog;
NullLog m_nullLog;
bool m_firstPoll;
bool m_stop;
};
/*! @} */
}
#endif // FIX_ACCEPTOR_H
|