FIX::HttpServer Class Reference

Basic HTTP Server. More...

#include <HttpServer.h>

Inheritance diagram for FIX::HttpServer:

Collaboration diagram for FIX::HttpServer:

Public Member Functions
	HttpServer (const SessionSettings &) throw ( ConfigError )
void	start () throw ( ConfigError, RuntimeError )
void	stop ()
Public Member Functions inherited from FIX::SocketServer::Strategy
virtual	~Strategy ()

Static Public Member Functions
static void	startGlobal (const SessionSettings &) throw ( ConfigError, RuntimeError )
static void	stopGlobal ()

Private Member Functions
void	onConfigure (const SessionSettings &) throw ( ConfigError )
void	onInitialize (const SessionSettings &) throw ( RuntimeError )
void	onStart ()
bool	onPoll ()
void	onStop ()
void	onConnect (SocketServer &, int, int)
void	onWrite (SocketServer &, int)
bool	onData (SocketServer &, int)
void	onDisconnect (SocketServer &, int)
void	onError (SocketServer &)
void	onTimeout (SocketServer &)

Static Private Member Functions
static THREAD_PROC	startThread (void *p)

Private Attributes
SocketServer *	m_pServer
SessionSettings	m_settings
thread_id	m_threadid
int	m_port
bool	m_stop

Static Private Attributes
static Mutex	s_mutex
static int	s_count = 0
static HttpServer *	s_pServer = 0

Detailed Description

Basic HTTP Server.

Definition at line 37 of file HttpServer.h.

Constructor & Destructor Documentation

HttpServer()

FIX::HttpServer::HttpServer	(	const SessionSettings &	settings	)
throw	(	ConfigError )

Definition at line 66 of file HttpServer.cpp.

: m_pServer( 0 ), m_settings( settings ), m_threadid( 0 ), m_port( 0 ), m_stop( false ) {}

References m_port, m_pServer, m_settings, m_stop, and m_threadid.

Referenced by startGlobal(), and startThread().

Member Function Documentation

onConfigure()

void FIX::HttpServer::onConfigure ( const SessionSettings & s ) throw ( ConfigError )

private

Definition at line 69 of file HttpServer.cpp.

{  
  m_port = s.get().getInt( HTTP_ACCEPT_PORT );
}

References FIX::HTTP_ACCEPT_PORT, and m_port.

Referenced by start().

onConnect()

void FIX::HttpServer::onConnect ( SocketServer & server, int a, int s )

privatevirtual

Implements FIX::SocketServer::Strategy.

Definition at line 135 of file HttpServer.cpp.

{
  if ( !socket_isValid( s ) ) return;
  HttpConnection connection( s );
  while( connection.read() ) {}
  m_pServer->getMonitor().drop( s );
}

References m_pServer, FIX::HttpConnection::read(), and FIX::socket_isValid().

onData()

bool FIX::HttpServer::onData ( SocketServer & server, int s )

privatevirtual

Implements FIX::SocketServer::Strategy.

Definition at line 147 of file HttpServer.cpp.

{
  return true;
}

onDisconnect()

void FIX::HttpServer::onDisconnect ( SocketServer & , int s )

privatevirtual

Implements FIX::SocketServer::Strategy.

Definition at line 152 of file HttpServer.cpp.

{
}

onError()

void FIX::HttpServer::onError ( SocketServer & )

privatevirtual

Implements FIX::SocketServer::Strategy.

Definition at line 156 of file HttpServer.cpp.

{}

onInitialize()

void FIX::HttpServer::onInitialize ( const SessionSettings & s ) throw ( RuntimeError )

private

Definition at line 75 of file HttpServer.cpp.

{
  try
  {
    m_pServer = new SocketServer( 1 );
    m_pServer->add( m_port, true, false, 0, 0 );
  }
  catch( std::exception& )
  {
    throw RuntimeError( "Unable to create, bind, or listen to port " + IntConvertor::convert( (unsigned short)m_port ) );
  }
}

References FIX::IntConvertor::convert(), m_port, and m_pServer.

Referenced by start().

onPoll()

bool FIX::HttpServer::onPoll ( )

private

Definition at line 122 of file HttpServer.cpp.

{
  if( !m_pServer || m_stop )
    return false;
 
  m_pServer->block( *this, true );
  return true;
}

References m_pServer, and m_stop.

onStart()

void FIX::HttpServer::onStart ( )

private

Definition at line 110 of file HttpServer.cpp.

{
  while ( !m_stop && m_pServer && m_pServer->block( *this ) ) {}
 
  if( !m_pServer )
    return;
 
  m_pServer->close();
  delete m_pServer;
  m_pServer = 0;
}

References m_pServer, and m_stop.

Referenced by startThread().

onStop()

void FIX::HttpServer::onStop ( )

private

Definition at line 131 of file HttpServer.cpp.

{
}

Referenced by stop().

onTimeout()

void FIX::HttpServer::onTimeout ( SocketServer & )

privatevirtual

Reimplemented from FIX::SocketServer::Strategy.

Definition at line 158 of file HttpServer.cpp.

{
}

onWrite()

void FIX::HttpServer::onWrite ( SocketServer & server, int s )

privatevirtual

Implements FIX::SocketServer::Strategy.

Definition at line 143 of file HttpServer.cpp.

{
}

start()

void FIX::HttpServer::start	(		)
throw	(	ConfigError,
		RuntimeError )

Definition at line 89 of file HttpServer.cpp.

{
  m_stop = false;
  onConfigure( m_settings );
  onInitialize( m_settings );
 
  if( !thread_spawn( &startThread, this, m_threadid ) )
    throw RuntimeError("Unable to spawn thread");
}

References m_settings, m_stop, m_threadid, onConfigure(), onInitialize(), startThread(), and FIX::thread_spawn().

startGlobal()

void FIX::HttpServer::startGlobal ( const SessionSettings & s ) throw ( ConfigError, RuntimeError )

static

Definition at line 37 of file HttpServer.cpp.

{
  Locker l( s_mutex );
 
  if( !s.get().has(HTTP_ACCEPT_PORT) )
    return;
 
  s_count += 1;
  if( !s_pServer )
  {
    s_pServer = new HttpServer( s );
    s_pServer->start();
  }
}

References FIX::HTTP_ACCEPT_PORT, HttpServer(), s_count, s_mutex, and s_pServer.

Referenced by FIX::Acceptor::start(), and FIX::Initiator::start().

startThread()

THREAD_PROC FIX::HttpServer::startThread ( void * p )

staticprivate

Definition at line 162 of file HttpServer.cpp.

{
  HttpServer * pServer = static_cast < HttpServer* > ( p );
  pServer->onStart();
  return 0;
}

References HttpServer(), onStart(), and THREAD_PROC.

Referenced by start().

stop()

void FIX::HttpServer::stop

(

)

Definition at line 99 of file HttpServer.cpp.

{
  if( m_stop ) return;
  m_stop = true;
  onStop();
 
  if( m_threadid )
    thread_join( m_threadid );
  m_threadid = 0;
}

References m_stop, m_threadid, onStop(), and FIX::thread_join().

stopGlobal()

void FIX::HttpServer::stopGlobal ( )

static

Definition at line 53 of file HttpServer.cpp.

{
  Locker l( s_mutex );
 
  s_count -= 1;
  if( !s_count && s_pServer )
  {
    s_pServer->stop();
    delete s_pServer;
    s_pServer = 0;
  }  
}

References s_count, s_mutex, and s_pServer.

Referenced by FIX::Acceptor::stop(), and FIX::Initiator::stop().

Member Data Documentation

m_port

int FIX::HttpServer::m_port

private

Definition at line 68 of file HttpServer.h.

Referenced by HttpServer(), onConfigure(), and onInitialize().

m_pServer

SocketServer* FIX::HttpServer::m_pServer

private

Definition at line 65 of file HttpServer.h.

Referenced by HttpServer(), onConnect(), onInitialize(), onPoll(), and onStart().

m_settings

SessionSettings FIX::HttpServer::m_settings

private

Definition at line 66 of file HttpServer.h.

Referenced by HttpServer(), and start().

m_stop

bool FIX::HttpServer::m_stop

private

Definition at line 69 of file HttpServer.h.

Referenced by HttpServer(), onPoll(), onStart(), start(), and stop().

m_threadid

thread_id FIX::HttpServer::m_threadid

private

Definition at line 67 of file HttpServer.h.

Referenced by HttpServer(), start(), and stop().

s_count

int FIX::HttpServer::s_count = 0

staticprivate

Definition at line 72 of file HttpServer.h.

Referenced by startGlobal(), and stopGlobal().

s_mutex

Mutex FIX::HttpServer::s_mutex

staticprivate

Definition at line 71 of file HttpServer.h.

Referenced by startGlobal(), and stopGlobal().

s_pServer

HttpServer * FIX::HttpServer::s_pServer = 0

staticprivate

Definition at line 73 of file HttpServer.h.

Referenced by startGlobal(), and stopGlobal().

---

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

• HttpServer.h
• HttpServer.cpp