XmlRpc::XmlRpcServer Class Reference

A class to handle XML RPC requests. More...

#include <XmlRpcServer.h>

Inheritance diagram for XmlRpc::XmlRpcServer:

List of all members.

Public Member Functions
	XmlRpcServer ()
	Create a server object.
virtual	~XmlRpcServer ()
	Destructor.
void	enableIntrospection (bool enabled=true)
	Specify whether introspection is enabled or not. Default is not enabled.
void	addMethod (XmlRpcServerMethod *method)
	Add a command to the RPC server.
void	removeMethod (XmlRpcServerMethod *method)
	Remove a command from the RPC server.
void	removeMethod (const std::string &methodName)
	Remove a command from the RPC server by name.
XmlRpcServerMethod *	findMethod (const std::string &name) const
	Look up a method by name.
bool	bindAndListen (int port, int backlog=5)
void	work (double msTime)
	Process client requests for the specified time.
void	exit ()
	Temporarily stop processing client requests and exit the work() method.
void	shutdown ()
	Close all connections with clients and the socket file descriptor.
void	listMethods (XmlRpcValue &result)
	Introspection support.
virtual unsigned	handleEvent (unsigned eventType)
	Handle client connection requests.
virtual void	removeConnection (XmlRpcServerConnection *)
	Remove a connection from the dispatcher.
int	getfd () const
	Return the file descriptor being monitored.
void	setfd (int fd)
	Specify the file descriptor to monitor.
bool	getKeepOpen () const
	Return whether the file descriptor should be kept open if it is no longer monitored.
void	setKeepOpen (bool b=true)
	Specify whether the file descriptor should be kept open if it is no longer monitored.
virtual void	close ()
	Close the owned fd. If deleteOnClose was specified at construction, the object is deleted.
Protected Types
typedef std::map< std::string, XmlRpcServerMethod * >	MethodMap
Protected Member Functions
virtual void	acceptConnection ()
	Accept a client connection request.
virtual XmlRpcServerConnection *	createConnection (int socket)
	Create a new connection object for processing requests from a specific client.
Protected Attributes
bool	_introspectionEnabled
XmlRpcDispatch	_disp
MethodMap	_methods
XmlRpcServerMethod *	_listMethods
XmlRpcServerMethod *	_methodHelp

---

Detailed Description

A class to handle XML RPC requests.

Definition at line 33 of file XmlRpcServer.h.

---

Member Typedef Documentation

typedef std::map< std::string, XmlRpcServerMethod* > XmlRpc::XmlRpcServer::MethodMap [protected]

Definition at line 94 of file XmlRpcServer.h.

---

Constructor & Destructor Documentation

XmlRpcServer::XmlRpcServer

(

)

Create a server object.

Definition at line 13 of file XmlRpcServer.cpp.

References _introspectionEnabled, _listMethods, and _methodHelp.

{
  _introspectionEnabled = false;
  _listMethods = 0;
  _methodHelp = 0;
}

XmlRpcServer::~XmlRpcServer

(

)

[virtual]

Destructor.

Definition at line 21 of file XmlRpcServer.cpp.

References _listMethods, _methodHelp, _methods, and shutdown().

{
  this->shutdown();
  _methods.clear();
  delete _listMethods;
  delete _methodHelp;
}

---

Member Function Documentation

void XmlRpcServer::acceptConnection

(

)

[protected, virtual]

Accept a client connection request.

Definition at line 145 of file XmlRpcServer.cpp.

References _disp, XmlRpc::XmlRpcSocket::accept(), XmlRpc::XmlRpcDispatch::addSource(), EvtCyclic3::c_str(), XmlRpc::XmlRpcSocket::close(), ers::error, XmlRpc::XmlRpcSocket::getErrorMsg(), XmlRpc::XmlRpcUtil::log(), XmlRpc::XmlRpcDispatch::ReadableEvent, s, and XmlRpc::XmlRpcSocket::setNonBlocking().

Referenced by handleEvent().

{
  int s = XmlRpcSocket::accept(this->getfd());
  XmlRpcUtil::log(2, "XmlRpcServer::acceptConnection: socket %d", s);
  if (s < 0)
  {
    //this->close();
    XmlRpcUtil::error("XmlRpcServer::acceptConnection: Could not accept connection (%s).", XmlRpcSocket::getErrorMsg().c_str());
  }
  else if ( ! XmlRpcSocket::setNonBlocking(s))
  {
    XmlRpcSocket::close(s);
    XmlRpcUtil::error("XmlRpcServer::acceptConnection: Could not set socket to non-blocking input mode (%s).", XmlRpcSocket::getErrorMsg().c_str());
  }
  else  // Notify the dispatcher to listen for input on this source when we are in work()
  {
    XmlRpcUtil::log(2, "XmlRpcServer::acceptConnection: creating a connection");
    _disp.addSource(this->createConnection(s), XmlRpcDispatch::ReadableEvent);
  }
}

void XmlRpcServer::addMethod

(

XmlRpcServerMethod *

method

)

Add a command to the RPC server.

Definition at line 32 of file XmlRpcServer.cpp.

References _methods, and XmlRpc::XmlRpcServerMethod::name().

Referenced by enableIntrospection(), and XmlRpc::XmlRpcServerMethod::XmlRpcServerMethod().

{
  _methods[method->name()] = method;
}

bool XmlRpcServer::bindAndListen	(	int	port,
		int	backlog = 5
	)

Create a socket, bind to the specified port, and set it in listen mode to make it available for clients.

Definition at line 70 of file XmlRpcServer.cpp.

References _disp, XmlRpc::XmlRpcDispatch::addSource(), XmlRpc::XmlRpcSocket::bind(), EvtCyclic3::c_str(), XmlRpc::XmlRpcSource::close(), ers::error, XmlRpc::XmlRpcSocket::getErrorMsg(), XmlRpc::XmlRpcSocket::listen(), XmlRpc::XmlRpcUtil::log(), XmlRpc::XmlRpcDispatch::ReadableEvent, XmlRpc::XmlRpcSource::setfd(), XmlRpc::XmlRpcSocket::setNonBlocking(), XmlRpc::XmlRpcSocket::setReuseAddr(), and XmlRpc::XmlRpcSocket::socket().

Referenced by main().

{
  int fd = XmlRpcSocket::socket();
  if (fd < 0)
  {
    XmlRpcUtil::error("XmlRpcServer::bindAndListen: Could not create socket (%s).", XmlRpcSocket::getErrorMsg().c_str());
    return false;
  }

  this->setfd(fd);

  // Don't block on reads/writes
  if ( ! XmlRpcSocket::setNonBlocking(fd))
  {
    this->close();
    XmlRpcUtil::error("XmlRpcServer::bindAndListen: Could not set socket to non-blocking input mode (%s).", XmlRpcSocket::getErrorMsg().c_str());
    return false;
  }

  // Allow this port to be re-bound immediately so server re-starts are not delayed
  if ( ! XmlRpcSocket::setReuseAddr(fd))
  {
    this->close();
    XmlRpcUtil::error("XmlRpcServer::bindAndListen: Could not set SO_REUSEADDR socket option (%s).", XmlRpcSocket::getErrorMsg().c_str());
    return false;
  }

  // Bind to the specified port on the default interface
  if ( ! XmlRpcSocket::bind(fd, port))
  {
    this->close();
    XmlRpcUtil::error("XmlRpcServer::bindAndListen: Could not bind to specified port (%s).", XmlRpcSocket::getErrorMsg().c_str());
    return false;
  }

  // Set in listening mode
  if ( ! XmlRpcSocket::listen(fd, backlog))
  {
    this->close();
    XmlRpcUtil::error("XmlRpcServer::bindAndListen: Could not set socket in listening mode (%s).", XmlRpcSocket::getErrorMsg().c_str());
    return false;
  }

  XmlRpcUtil::log(2, "XmlRpcServer::bindAndListen: server listening on port %d fd %d", port, fd);

  // Notify the dispatcher to listen on this source when we are in work()
  _disp.addSource(this, XmlRpcDispatch::ReadableEvent);

  return true;
}

void XmlRpc::XmlRpcSource::close

(

)

[virtual, inherited]

Close the owned fd. If deleteOnClose was specified at construction, the object is deleted.

Reimplemented in XmlRpc::XmlRpcClient.

Definition at line 20 of file XmlRpcSource.cpp.

References XmlRpc::XmlRpcSource::_deleteOnClose, XmlRpc::XmlRpcSource::_fd, XmlRpc::XmlRpcSocket::close(), and XmlRpc::XmlRpcUtil::log().

Referenced by bindAndListen(), XmlRpc::XmlRpcClient::close(), XmlRpc::XmlRpcClient::readHeader(), and XmlRpc::XmlRpcDispatch::work().

  {
    if (_fd != -1) {
      XmlRpcUtil::log(2,"XmlRpcSource::close: closing socket %d.", _fd);
      XmlRpcSocket::close(_fd);
      XmlRpcUtil::log(2,"XmlRpcSource::close: done closing socket %d.", _fd);
      _fd = -1;
    }
    if (_deleteOnClose) {
      XmlRpcUtil::log(2,"XmlRpcSource::close: deleting this");
      _deleteOnClose = false;
      delete this;
    }
  }

XmlRpcServerConnection * XmlRpcServer::createConnection

(

int

socket

)

[protected, virtual]

Create a new connection object for processing requests from a specific client.

Definition at line 169 of file XmlRpcServer.cpp.

{
  // Specify that the connection object be deleted when it is closed
  return new XmlRpcServerConnection(s, this, true);
}

void XmlRpcServer::enableIntrospection

(

bool

enabled = true

)

Specify whether introspection is enabled or not. Default is not enabled.

Definition at line 245 of file XmlRpcServer.cpp.

References _introspectionEnabled, _listMethods, _methodHelp, addMethod(), LIST_METHODS(), METHOD_HELP(), and removeMethod().

Referenced by main().

{
  if (_introspectionEnabled == enabled)
    return;

  _introspectionEnabled = enabled;

  if (enabled)
  {
    if ( ! _listMethods)
    {
      _listMethods = new ListMethods(this);
      _methodHelp = new MethodHelp(this);
    } else {
      addMethod(_listMethods);
      addMethod(_methodHelp);
    }
  }
  else
  {
    removeMethod(LIST_METHODS);
    removeMethod(METHOD_HELP);
  }
}

void XmlRpcServer::exit

(

)

Temporarily stop processing client requests and exit the work() method.

Definition at line 185 of file XmlRpcServer.cpp.

References _disp, and XmlRpc::XmlRpcDispatch::exit().

{
  _disp.exit();
}

XmlRpcServerMethod * XmlRpcServer::findMethod

(

const std::string &

name

)

const

Look up a method by name.

Definition at line 58 of file XmlRpcServer.cpp.

References _methods, and genRecEmupikp::i.

Referenced by XmlRpc::XmlRpcServerConnection::executeMethod().

{
  MethodMap::const_iterator i = _methods.find(name);
  if (i == _methods.end())
    return 0;
  return i->second;
}

int XmlRpc::XmlRpcSource::getfd

(

)

const [inline, inherited]

Return the file descriptor being monitored.

Definition at line 25 of file XmlRpcSource.h.

References XmlRpc::XmlRpcSource::_fd.

Referenced by XmlRpc::XmlRpcClient::close(), XmlRpc::XmlRpcClient::readHeader(), and XmlRpc::XmlRpcDispatch::work().

{ return _fd; }

bool XmlRpc::XmlRpcSource::getKeepOpen

(

)

const [inline, inherited]

Return whether the file descriptor should be kept open if it is no longer monitored.

Definition at line 30 of file XmlRpcSource.h.

References XmlRpc::XmlRpcSource::_keepOpen.

Referenced by XmlRpc::XmlRpcClient::readHeader(), and XmlRpc::XmlRpcDispatch::work().

{ return _keepOpen; }

unsigned XmlRpcServer::handleEvent

(

unsigned

eventType

)

[virtual]

Handle client connection requests.

Implements XmlRpc::XmlRpcSource.

Definition at line 135 of file XmlRpcServer.cpp.

References acceptConnection(), and XmlRpc::XmlRpcDispatch::ReadableEvent.

{
  acceptConnection();
  return XmlRpcDispatch::ReadableEvent;         // Continue to monitor this fd
}

void XmlRpcServer::listMethods

(

XmlRpcValue &

result

)

Introspection support.

Definition at line 272 of file XmlRpcServer.cpp.

References _methods, genRecEmupikp::i, MULTICALL(), and XmlRpc::XmlRpcValue::setSize().

{
  int i = 0;
  result.setSize(_methods.size()+1);
  for (MethodMap::iterator it=_methods.begin(); it != _methods.end(); ++it)
    result[i++] = it->first;

  // Multicall support is built into XmlRpcServerConnection
  result[i] = MULTICALL;
}

void XmlRpcServer::removeConnection

(

XmlRpcServerConnection *

)

[virtual]

Remove a connection from the dispatcher.

Definition at line 177 of file XmlRpcServer.cpp.

References _disp, and XmlRpc::XmlRpcDispatch::removeSource().

Referenced by XmlRpc::XmlRpcServerConnection::~XmlRpcServerConnection().

{
  _disp.removeSource(sc);
}

void XmlRpcServer::removeMethod

(

const std::string &

methodName

)

Remove a command from the RPC server by name.

Definition at line 48 of file XmlRpcServer.cpp.

References _methods, and genRecEmupikp::i.

{
  MethodMap::iterator i = _methods.find(methodName);
  if (i != _methods.end())
    _methods.erase(i);
}

void XmlRpcServer::removeMethod

(

XmlRpcServerMethod *

method

)

Remove a command from the RPC server.

Definition at line 39 of file XmlRpcServer.cpp.

References _methods, genRecEmupikp::i, and XmlRpc::XmlRpcServerMethod::name().

Referenced by enableIntrospection(), and XmlRpc::XmlRpcServerMethod::~XmlRpcServerMethod().

{
  MethodMap::iterator i = _methods.find(method->name());
  if (i != _methods.end())
    _methods.erase(i);
}

void XmlRpc::XmlRpcSource::setfd

(

int

fd

)

[inline, inherited]

Specify the file descriptor to monitor.

Definition at line 27 of file XmlRpcSource.h.

References XmlRpc::XmlRpcSource::_fd.

Referenced by bindAndListen(), and XmlRpc::XmlRpcClient::doConnect().

{ _fd = fd; }

void XmlRpc::XmlRpcSource::setKeepOpen

(

bool

b = true

)

[inline, inherited]

Specify whether the file descriptor should be kept open if it is no longer monitored.

Definition at line 32 of file XmlRpcSource.h.

References XmlRpc::XmlRpcSource::_keepOpen.

Referenced by XmlRpc::XmlRpcClient::XmlRpcClient().

{ _keepOpen = b; }

void XmlRpcServer::shutdown

(

)

Close all connections with clients and the socket file descriptor.

Definition at line 193 of file XmlRpcServer.cpp.

References _disp, and XmlRpc::XmlRpcDispatch::clear().

Referenced by ~XmlRpcServer().

{
  // This closes and destroys all connections as well as closing this socket
  _disp.clear();
}

void XmlRpcServer::work

(

double

msTime

)

Process client requests for the specified time.

Definition at line 124 of file XmlRpcServer.cpp.

References _disp, XmlRpc::XmlRpcUtil::log(), and XmlRpc::XmlRpcDispatch::work().

Referenced by main().

{
  XmlRpcUtil::log(2, "XmlRpcServer::work: waiting for a connection");
  _disp.work(msTime);
}

---

Member Data Documentation

XmlRpcDispatch XmlRpc::XmlRpcServer::_disp [protected]

Definition at line 91 of file XmlRpcServer.h.

Referenced by acceptConnection(), bindAndListen(), exit(), removeConnection(), shutdown(), and work().

bool XmlRpc::XmlRpcServer::_introspectionEnabled [protected]

Definition at line 88 of file XmlRpcServer.h.

Referenced by enableIntrospection(), and XmlRpcServer().

XmlRpcServerMethod* XmlRpc::XmlRpcServer::_listMethods [protected]

Definition at line 98 of file XmlRpcServer.h.

Referenced by enableIntrospection(), XmlRpcServer(), and ~XmlRpcServer().

XmlRpcServerMethod* XmlRpc::XmlRpcServer::_methodHelp [protected]

Definition at line 99 of file XmlRpcServer.h.

Referenced by enableIntrospection(), XmlRpcServer(), and ~XmlRpcServer().

MethodMap XmlRpc::XmlRpcServer::_methods [protected]

Definition at line 95 of file XmlRpcServer.h.

Referenced by addMethod(), findMethod(), listMethods(), removeMethod(), and ~XmlRpcServer().

---