MasterPintoServerQuerierBase uses a single, centralized master Pinto query server to discover which other space servers must be queried. More...

#include <MasterPintoServerQuerierBase.hpp>

Inheritance diagram for Sirikata::MasterPintoServerQuerierBase:

Collaboration diagram for Sirikata::MasterPintoServerQuerierBase:

List of all members.

Public Member Functions
	MasterPintoServerQuerierBase (SpaceContext *ctx, const String &params)
virtual	~MasterPintoServerQuerierBase ()
virtual void	start ()
virtual void	stop ()
virtual void	updateRegion (const BoundingBox3f &region)
	Update this server's parameters.
virtual void	updateLargestObject (float max_radius)
	Update this server's parameters.
virtual void	updateQuery (const String &update)=0
	Update query parameters with the server.
Protected Types
enum	QueueUpdateType { QueueUpdate, DoNotQueueUpdate }
Protected Member Functions
virtual void	onConnected ()
virtual void	onDisconnected ()
virtual void	onPintoData (const String &data)=0
void	sendQueryUpdate (const String &data, QueueUpdateType queue=QueueUpdate)
Protected Attributes
SpaceContext *	mContext
Network::IOStrand *	mIOStrand
Network::Stream *	mServerStream
Private Member Functions
void	connect ()
bool	connected ()
void	handleServerConnection (Network::Stream::ConnectionStatus status, const std::string &reason)
void	handleServerReceived (Network::Chunk &data, const Network::Stream::PauseReceiveCallback &pause)
void	handleServerReadySend ()
void	tryServerUpdate ()
Private Attributes
String	mHost
String	mPort
bool	mConnecting
bool	mConnected
bool	mGaveID
BoundingBox3f	mRegion
bool	mRegionDirty
float32	mMaxRadius
bool	mMaxRadiusDirty
std::vector< String >	mQueuedQueryUpdates

Detailed Description

MasterPintoServerQuerierBase uses a single, centralized master Pinto query server to discover which other space servers must be queried.

Base class for specific implementation, e.g. using aggregated queries, or replicated top-level trees. It handles setting up the connection and managing updates for the required properties. Implementations need to handle query update requests from Proximity and deal with interaction over the connection generated by this class.

Member Enumeration Documentation

enum Sirikata::MasterPintoServerQuerierBase::QueueUpdateType [protected]

Enumerator:

QueueUpdate
DoNotQueueUpdate

Constructor & Destructor Documentation

Sirikata::MasterPintoServerQuerierBase::MasterPintoServerQuerierBase	(	SpaceContext *	ctx,
		const String &	params
	)

References Sirikata::OptionValue::as(), Sirikata::OptionSet::getOptions(), mHost, mPort, OPT_MASTER_PINTO_HOST, OPT_MASTER_PINTO_PORT, Sirikata::OptionSet::parse(), and Sirikata::OptionSet::referenceOption().

Sirikata::MasterPintoServerQuerierBase::~MasterPintoServerQuerierBase ( ) [virtual]

References mIOStrand, and mServerStream.

Member Function Documentation

void Sirikata::MasterPintoServerQuerierBase::connect ( ) [private]

bool Sirikata::MasterPintoServerQuerierBase::connected ( ) [inline, private]

References mConnected.

Referenced by sendQueryUpdate().

void Sirikata::MasterPintoServerQuerierBase::handleServerConnection	(	Network::Stream::ConnectionStatus	status,
		const std::string &	reason
	)		`[private]`

References Sirikata::Network::Stream::Connected, Sirikata::Network::Stream::ConnectionFailed, Sirikata::Logging::debug, Sirikata::Network::Stream::Disconnected, mConnected, mConnecting, mGaveID, MP_LOG, mQueuedQueryUpdates, onConnected(), onDisconnected(), sendQueryUpdate(), and tryServerUpdate().

Referenced by connect().

void Sirikata::MasterPintoServerQuerierBase::handleServerReadySend ( ) [private]

Referenced by connect().

void Sirikata::MasterPintoServerQuerierBase::handleServerReceived	(	Network::Chunk &	data,
		const Network::Stream::PauseReceiveCallback &	pause
	)		`[private]`