#include <XmlRpcDispatch.h>

Classes
struct	MonitoredSource

Public Types
enum	EventType { ReadableEvent = 1 , WritableEvent = 2 , Exception = 4 }
	Values indicating the type of events a source is interested in. More...

Public Member Functions
	XmlRpcDispatch ()
	Constructor.
	~XmlRpcDispatch ()
void	addSource (XmlRpcSource *source, unsigned eventMask)
void	removeSource (XmlRpcSource *source)
void	setSourceEvents (XmlRpcSource *source, unsigned eventMask)
	Modify the types of events to watch for on this source.
void	work (double msTime)
void	exit ()
	Exit from work routine.
void	clear ()
	Clear all sources from the monitored sources list. Sources are closed.

Protected Types
typedef std::list< MonitoredSource >	SourceList

Protected Member Functions
double	getTime ()

Protected Attributes
SourceList	_sources
double	_endTime
bool	_doClear
bool	_inWork

Detailed Description

An object which monitors file descriptors for events and performs callbacks when interesting events happen.

Definition at line 22 of file XmlRpcDispatch.h.

Member Typedef Documentation

◆ SourceList

typedef std::list<MonitoredSource> XmlRpc::XmlRpcDispatch::SourceList

protected

Definition at line 72 of file XmlRpcDispatch.h.

Member Enumeration Documentation

◆ EventType

enum XmlRpc::XmlRpcDispatch::EventType

Values indicating the type of events a source is interested in.

Enumerator
ReadableEvent	data available to read
WritableEvent	connected/data can be written without blocking
Exception	uh oh

Definition at line 29 of file XmlRpcDispatch.h.

                   {
      ReadableEvent = 1, //!< data available to read
      WritableEvent = 2, //!< connected/data can be written without blocking
      Exception     = 4  //!< uh oh
    };

Constructor & Destructor Documentation

◆ XmlRpcDispatch()

XmlRpcDispatch::XmlRpcDispatch ( )

Constructor.

Definition at line 25 of file XmlRpcDispatch.cpp.

                               {
  _endTime = -1.0;
  _doClear = false;
  _inWork  = false;
}

◆ ~XmlRpcDispatch()

XmlRpcDispatch::~XmlRpcDispatch ( )

Definition at line 31 of file XmlRpcDispatch.cpp.

31{}

Member Function Documentation

◆ addSource()

void XmlRpcDispatch::addSource	(	XmlRpcSource *	source,
		unsigned	eventMask )

Monitor this source for the event types specified by the event mask and call its event handler when any of the events occur.

Parameters

source	The source to monitor
eventMask	Which event types to watch for.

See also: EventType

Definition at line 35 of file XmlRpcDispatch.cpp.

                                                                    {
  _sources.push_back( MonitoredSource( source, mask ) );
}

◆ clear()

void XmlRpcDispatch::clear ( )

Clear all sources from the monitored sources list. Sources are closed.

Definition at line 161 of file XmlRpcDispatch.cpp.

                           {
  if ( _inWork ) _doClear = true; // Finish reporting current events before clearing
  else
  {
    SourceList closeList = _sources;
    _sources.clear();
    for ( SourceList::iterator it = closeList.begin(); it != closeList.end(); ++it )
      it->getSource()->close();
  }
}

◆ exit()

void XmlRpcDispatch::exit ( )

Exit from work routine.

Definition at line 156 of file XmlRpcDispatch.cpp.

                          {
  _endTime = 0.0; // Return from work asap
}

◆ getTime()

double XmlRpcDispatch::getTime ( )

protected

Definition at line 172 of file XmlRpcDispatch.cpp.

                               {
#ifdef USE_FTIME
  struct timeb tbuff;
 
  ftime( &tbuff );
  return ( (double)tbuff.time + ( (double)tbuff.millitm / 1000.0 ) +
           ( (double)tbuff.timezone * 60 ) );
#else
  struct timeval  tv;
  struct timezone tz;
 
  gettimeofday( &tv, &tz );
  return ( tv.tv_sec + tv.tv_usec / 1000000.0 );
#endif /* USE_FTIME */
}

Referenced by work().

◆ removeSource()

void XmlRpcDispatch::removeSource ( XmlRpcSource * source )

Stop monitoring this source.

Parameters

source The source to stop monitoring

Definition at line 40 of file XmlRpcDispatch.cpp.

                                                        {
  for ( SourceList::iterator it = _sources.begin(); it != _sources.end(); ++it )
    if ( it->getSource() == source )
    {
      _sources.erase( it );
      break;
    }
}

◆ setSourceEvents()

void XmlRpcDispatch::setSourceEvents	(	XmlRpcSource *	source,
		unsigned	eventMask )

Modify the types of events to watch for on this source.

Definition at line 50 of file XmlRpcDispatch.cpp.

                                                                               {
  for ( SourceList::iterator it = _sources.begin(); it != _sources.end(); ++it )
    if ( it->getSource() == source )
    {
      it->getMask() = eventMask;
      break;
    }
}

◆ work()

void XmlRpcDispatch::work ( double msTime )

Watch current set of sources and process events for the specified duration (in ms, -1 implies wait forever, or until exit is called)

Definition at line 60 of file XmlRpcDispatch.cpp.

                                          {
  // Compute end time
  _endTime = ( timeout < 0.0 ) ? -1.0 : ( getTime() + timeout );
  _doClear = false;
  _inWork  = true;
 
  // Only work while there is something to monitor
  while ( _sources.size() > 0 )
  {
 
    // Construct the sets of descriptors we are interested in
    fd_set inFd, outFd, excFd;
    FD_ZERO( &inFd );
    FD_ZERO( &outFd );
    FD_ZERO( &excFd );
 
    int                  maxFd = -1; // Not used on windows
    SourceList::iterator it;
    for ( it = _sources.begin(); it != _sources.end(); ++it )
    {
      int fd = it->getSource()->getfd();
      if ( it->getMask() & ReadableEvent ) FD_SET( fd, &inFd );
      if ( it->getMask() & WritableEvent ) FD_SET( fd, &outFd );
      if ( it->getMask() & Exception ) FD_SET( fd, &excFd );
      if ( it->getMask() && fd > maxFd ) maxFd = fd;
    }
 
    // Check for events
    int nEvents;
    if ( timeout < 0.0 ) nEvents = select( maxFd + 1, &inFd, &outFd, &excFd, NULL );
    else
    {
      struct timeval tv;
      tv.tv_sec  = (int)floor( timeout );
      tv.tv_usec = ( (int)floor( 1000000.0 * ( timeout - floor( timeout ) ) ) ) % 1000000;
      nEvents    = select( maxFd + 1, &inFd, &outFd, &excFd, &tv );
    }
 
    if ( nEvents < 0 )
    {
      XmlRpcUtil::error( "Error in XmlRpcDispatch::work: error in select (%d).", nEvents );
      _inWork = false;
      return;
    }
 
    // Process events
    for ( it = _sources.begin(); it != _sources.end(); )
    {
      SourceList::iterator thisIt  = it++;
      XmlRpcSource*        src     = thisIt->getSource();
      int                  fd      = src->getfd();
      unsigned             newMask = (unsigned)-1;
      if ( fd <= maxFd )
      {
        // If you select on multiple event types this could be ambiguous
        if ( FD_ISSET( fd, &inFd ) ) newMask &= src->handleEvent( ReadableEvent );
        if ( FD_ISSET( fd, &outFd ) ) newMask &= src->handleEvent( WritableEvent );
        if ( FD_ISSET( fd, &excFd ) ) newMask &= src->handleEvent( Exception );
 
        if ( !newMask )
        {
          _sources.erase( thisIt ); // Stop monitoring this one
          if ( !src->getKeepOpen() ) src->close();
        }
        else if ( newMask != (unsigned)-1 ) { thisIt->getMask() = newMask; }
      }
    }
 
    // Check whether to clear all sources
    if ( _doClear )
    {
      SourceList closeList = _sources;
      _sources.clear();
      for ( SourceList::iterator it = closeList.begin(); it != closeList.end(); ++it )
      {
        XmlRpcSource* src = it->getSource();
        src->close();
      }
 
      _doClear = false;
    }
 
    // Check whether end time has passed
    if ( 0 <= _endTime && getTime() > _endTime )
    {
      std::cout << "XmlRpc :  time out when connect to database  " << std::endl; // yzhang
                                                                                 // debug
      break;
    }
  }
 
  _inWork = false;
}

Member Data Documentation

◆ _doClear

bool XmlRpc::XmlRpcDispatch::_doClear

protected

Definition at line 80 of file XmlRpcDispatch.h.

Referenced by clear(), work(), and XmlRpcDispatch().

◆ _endTime

double XmlRpc::XmlRpcDispatch::_endTime

protected

Definition at line 78 of file XmlRpcDispatch.h.

Referenced by exit(), work(), and XmlRpcDispatch().

◆ _inWork

bool XmlRpc::XmlRpcDispatch::_inWork

protected

Definition at line 81 of file XmlRpcDispatch.h.

Referenced by clear(), work(), and XmlRpcDispatch().

◆ _sources

SourceList XmlRpc::XmlRpcDispatch::_sources

protected

Definition at line 75 of file XmlRpcDispatch.h.

Referenced by addSource(), clear(), removeSource(), setSourceEvents(), and work().

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

Classes

Public Types

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Detailed Description

Member Typedef Documentation

◆ SourceList

Member Enumeration Documentation

◆ EventType

Constructor & Destructor Documentation

◆ XmlRpcDispatch()

◆ ~XmlRpcDispatch()

Member Function Documentation

◆ addSource()

◆ clear()

◆ exit()

◆ getTime()

◆ removeSource()

◆ setSourceEvents()

◆ work()

Member Data Documentation

◆ _doClear

◆ _endTime

◆ _inWork

◆ _sources