Sirikata::OH::Manual::ObjectQueryHandler Class Reference

#include <ObjectQueryHandler.hpp>

Inheritance diagram for Sirikata::OH::Manual::ObjectQueryHandler:

Collaboration diagram for Sirikata::OH::Manual::ObjectQueryHandler:

List of all members.

Classes
struct	ObjectQueryData
struct	ProximityResultInfo
struct	ReplicatedIndexQueryHandler
Public Types
typedef Prox::Query < ObjectProxSimulationTraits >	Query
typedef Prox::QueryEvent < ObjectProxSimulationTraits >	QueryEvent
Public Member Functions
	ObjectQueryHandler (ObjectHostContext *ctx, ManualObjectQueryProcessor *parent, const OHDP::SpaceNodeID &space, Network::IOStrandPtr prox_strand)
	~ObjectQueryHandler ()
virtual void	start ()
virtual void	stop ()
void	createdReplicatedIndex (ProxIndexID iid, ReplicatedLocationServiceCachePtr loc_cache, ServerID objects_from_server, bool dynamic_objects)
void	removedReplicatedIndex (ProxIndexID iid)
void	updateQuery (HostedObjectPtr ho, const SpaceObjectReference &sporef, const String &params)
void	removeQuery (HostedObjectPtr ho, const SpaceObjectReference &sporef)
void	presenceConnected (const ObjectReference &sporef)
void	presenceDisconnected (const ObjectReference &sporef)
virtual void	onObjectAdded (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onObjectRemoved (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onParentUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onEpochUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onLocationUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onOrientationUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onBoundsUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onMeshUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
virtual void	onPhysicsUpdated (ReplicatedLocationServiceCache *loccache, const ObjectReference &obj)
void	handleCreatedReplicatedIndex (Liveness::Token alive, ProxIndexID iid, ReplicatedLocationServiceCachePtr loc_cache, ServerID objects_from_server, bool dynamic_objects)
void	handleRemovedReplicatedIndex (Liveness::Token alive, ProxIndexID iid)
void	queryHasEvents (Query *query)
virtual void	aggregateCreated (ProxAggregator *handler, const ObjectReference &objid)
virtual void	aggregateChildAdded (ProxAggregator *handler, const ObjectReference &objid, const ObjectReference &child, const Vector3f &bnds_center, const float32 bnds_center_radius, const float32 max_obj_size)
virtual void	aggregateChildRemoved (ProxAggregator *handler, const ObjectReference &objid, const ObjectReference &child, const Vector3f &bnds_center, const float32 bnds_center_radius, const float32 max_obj_size)
virtual void	aggregateBoundsUpdated (ProxAggregator *handler, const ObjectReference &objid, const Vector3f &bnds_center, const float32 bnds_center_radius, const float32 max_obj_size)
virtual void	aggregateDestroyed (ProxAggregator *handler, const ObjectReference &objid)
virtual void	aggregateObserved (ProxAggregator *handler, const ObjectReference &objid, uint32 nobservers, uint32 nchildren)
ProxQueryHandler *	getQueryHandler (const String &handler_name)
void	commandListInfo (const OHDP::SpaceNodeID &snid, Command::Result &result)
void	commandListNodes (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
void	commandListQueriers (const OHDP::SpaceNodeID &snid, Command::Result &result)
void	commandForceRebuild (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
Private Types
typedef Prox::QueryHandler < ObjectProxSimulationTraits >	ProxQueryHandler
typedef Prox::Aggregator < ObjectProxSimulationTraits >	ProxAggregator
typedef std::set< ObjectReference >	ObjectSet
typedef std::tr1::unordered_map < ProxIndexID, Query * >	IndexQueryMap
typedef std::tr1::unordered_set < ServerID >	ServerIDSet
typedef std::tr1::shared_ptr < ObjectQueryData >	ObjectQueryDataPtr
typedef std::tr1::unordered_map < ObjectReference, ObjectQueryDataPtr, ObjectReference::Hasher >	ObjectQueryMap
typedef std::pair < ObjectReference, ProxIndexID >	ObjectIndexQueryKey
typedef std::tr1::unordered_map< Query *, ObjectIndexQueryKey >	InvertedObjectQueryMap
typedef std::tr1::unordered_map < ProxIndexID, ReplicatedIndexQueryHandler >	ReplicatedIndexQueryHandlerMap
typedef std::tr1::unordered_map < ProxAggregator *, ProxIndexID >	InverseReplicatedIndexQueryHandlerMap
typedef std::tr1::shared_ptr < ObjectSet >	ObjectSetPtr
typedef std::tr1::unordered_set < ObjectReference, ObjectReference::Hasher >	SubscriberSet
typedef std::tr1::shared_ptr < SubscriberSet >	SubscriberSetPtr
typedef std::tr1::unordered_map < ObjectReference, SubscriberSetPtr, ObjectReference::Hasher >	SubscribersMap
Private Member Functions
int32	objectQueries () const
void	handleDeliverEvents ()
void	handleNotifySubscribersLocUpdate (Liveness::Token alive, ReplicatedLocationServiceCache *loccache, const ObjectReference &oref)
void	updateQuery (HostedObjectPtr ho, const SpaceObjectReference &sporef, SolidAngle sa, uint32 max_results)
void	updateQuery (const ObjectReference &obj, const TimedMotionVector3f &loc, const BoundingSphere3f &bounds, SolidAngle sa, uint32 max_results)
void	registerObjectQueryWithIndex (const ObjectReference &object, ProxIndexID index_id, ProxQueryHandler *handler, const TimedMotionVector3f &loc, const BoundingSphere3f &bounds, const SolidAngle &angle, uint32 max_results)
void	registerObjectQueryWithServer (const ObjectReference &object, ServerID sid, const TimedMotionVector3f &loc, const BoundingSphere3f &bounds, const SolidAngle &angle, uint32 max_results)
void	unregisterObjectQueryWithIndex (const ObjectReference &object, ProxIndexID index_id)
void	unregisterObjectQueryWithServer (const ObjectReference &object, ServerID sid)
void	handleUpdateObjectQuery (Liveness::Token alive, const ObjectReference &object, const TimedMotionVector3f &loc, const BoundingSphere3f &bounds, const SolidAngle &angle, uint32 max_results)
void	handleRemoveObjectQuery (Liveness::Token alive, const ObjectReference &object, bool notify_main_thread)
void	handleDisconnectedObject (Liveness::Token alive, const ObjectReference &object)
void	generateObjectQueryEvents (Query *query)
void	tickQueryHandler ()
Private Attributes
SubscribersMap	mSubscribers
InstanceMethodNotReentrant	mQueryHasEventsNotRentrant
ObjectQueryMap	mObjectQueries
InvertedObjectQueryMap	mInvertedObjectQueries
ReplicatedIndexQueryHandlerMap	mObjectQueryHandlers
InverseReplicatedIndexQueryHandlerMap	mInverseObjectQueryHandlers
bool	mObjectDistance
PollerService	mObjectHandlerPoller
Sirikata::ThreadSafeQueueWithNotification < ProximityResultInfo >	mObjectResults

---

Member Typedef Documentation

typedef std::tr1::unordered_map<ProxIndexID, Query*> Sirikata::OH::Manual::ObjectQueryHandler::IndexQueryMap [private]

typedef std::tr1::unordered_map<ProxAggregator*, ProxIndexID> Sirikata::OH::Manual::ObjectQueryHandler::InverseReplicatedIndexQueryHandlerMap [private]

typedef std::tr1::unordered_map<Query*, ObjectIndexQueryKey> Sirikata::OH::Manual::ObjectQueryHandler::InvertedObjectQueryMap [private]

typedef std::pair<ObjectReference, ProxIndexID> Sirikata::OH::Manual::ObjectQueryHandler::ObjectIndexQueryKey [private]

typedef std::tr1::shared_ptr<ObjectQueryData> Sirikata::OH::Manual::ObjectQueryHandler::ObjectQueryDataPtr [private]

typedef std::tr1::unordered_map<ObjectReference, ObjectQueryDataPtr, ObjectReference::Hasher> Sirikata::OH::Manual::ObjectQueryHandler::ObjectQueryMap [private]

typedef std::set<ObjectReference> Sirikata::OH::Manual::ObjectQueryHandler::ObjectSet [private]

typedef std::tr1::shared_ptr<ObjectSet> Sirikata::OH::Manual::ObjectQueryHandler::ObjectSetPtr [private]

typedef Prox::Aggregator<ObjectProxSimulationTraits> Sirikata::OH::Manual::ObjectQueryHandler::ProxAggregator [private]

typedef Prox::QueryHandler<ObjectProxSimulationTraits> Sirikata::OH::Manual::ObjectQueryHandler::ProxQueryHandler [private]

typedef Prox::Query<ObjectProxSimulationTraits> Sirikata::OH::Manual::ObjectQueryHandler::Query

typedef Prox::QueryEvent<ObjectProxSimulationTraits> Sirikata::OH::Manual::ObjectQueryHandler::QueryEvent

typedef std::tr1::unordered_map<ProxIndexID, ReplicatedIndexQueryHandler> Sirikata::OH::Manual::ObjectQueryHandler::ReplicatedIndexQueryHandlerMap [private]

typedef std::tr1::unordered_set<ServerID> Sirikata::OH::Manual::ObjectQueryHandler::ServerIDSet [private]

typedef std::tr1::unordered_set<ObjectReference, ObjectReference::Hasher> Sirikata::OH::Manual::ObjectQueryHandler::SubscriberSet [private]

typedef std::tr1::shared_ptr<SubscriberSet> Sirikata::OH::Manual::ObjectQueryHandler::SubscriberSetPtr [private]

typedef std::tr1::unordered_map<ObjectReference, SubscriberSetPtr, ObjectReference::Hasher> Sirikata::OH::Manual::ObjectQueryHandler::SubscribersMap [private]

---

Constructor & Destructor Documentation

Sirikata::OH::Manual::ObjectQueryHandler::ObjectQueryHandler	(	ObjectHostContext *	ctx,
		ManualObjectQueryProcessor *	parent,
		const OHDP::SpaceNodeID &	space,
		Network::IOStrandPtr	prox_strand
	)

References Sirikata::GetOptionValue< String >(), mObjectDistance, and OPT_MANUAL_QUERY_HANDLER_TYPE.

Sirikata::OH::Manual::ObjectQueryHandler::~ObjectQueryHandler

(

)

References Sirikata::Liveness::letDie(), mInverseObjectQueryHandlers, and mObjectQueryHandlers.

---

Member Function Documentation

void Sirikata::OH::Manual::ObjectQueryHandler::aggregateBoundsUpdated	(	ProxAggregator *	handler,
		const ObjectReference &	objid,
		const Vector3f &	bnds_center,
		const float32	bnds_center_radius,
		const float32	max_obj_size
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::aggregateChildAdded	(	ProxAggregator *	handler,
		const ObjectReference &	objid,
		const ObjectReference &	child,
		const Vector3f &	bnds_center,
		const float32	bnds_center_radius,
		const float32	max_obj_size
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::aggregateChildRemoved	(	ProxAggregator *	handler,
		const ObjectReference &	objid,
		const ObjectReference &	child,
		const Vector3f &	bnds_center,
		const float32	bnds_center_radius,
		const float32	max_obj_size
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::aggregateCreated	(	ProxAggregator *	handler,
		const ObjectReference &	objid
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::aggregateDestroyed	(	ProxAggregator *	handler,
		const ObjectReference &	objid
	)		[virtual]

References indexid, mInverseObjectQueryHandlers, Sirikata::OH::Manual::ObjectQueryHandlerBase::mParent, Sirikata::OH::Manual::ObjectQueryHandlerBase::mSpaceNodeID, and Sirikata::OH::Manual::ManualObjectQueryProcessor::replicatedNodeRemoved().

void Sirikata::OH::Manual::ObjectQueryHandler::aggregateObserved	(	ProxAggregator *	handler,
		const ObjectReference &	objid,
		uint32	nobservers,
		uint32	nchildren
	)		[virtual]

References indexid, mInverseObjectQueryHandlers, Sirikata::OH::Manual::ObjectQueryHandlerBase::mParent, Sirikata::OH::Manual::ObjectQueryHandlerBase::mSpaceNodeID, Sirikata::OH::Manual::ManualObjectQueryProcessor::queriersAreObserving(), and Sirikata::OH::Manual::ManualObjectQueryProcessor::queriersStoppedObserving().

void Sirikata::OH::Manual::ObjectQueryHandler::commandForceRebuild	(	const Command::Command &	cmd,
		Command::Commander *	cmdr,
		Command::CommandID	cmdid
	)

References Sirikata::Command::EmptyResult(), and Sirikata::Command::Commander::result().

void Sirikata::OH::Manual::ObjectQueryHandler::commandListInfo	(	const OHDP::SpaceNodeID &	snid,
		Command::Result &	result
	)

References mObjectQueryHandlers, and Sirikata::OHDP::SpaceNodeID::toString().

void Sirikata::OH::Manual::ObjectQueryHandler::commandListNodes	(	const Command::Command &	cmd,
		Command::Commander *	cmdr,
		Command::CommandID	cmdid
	)

References Sirikata::Command::EmptyResult(), getQueryHandler(), Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, Sirikata::Command::Commander::result(), and Sirikata::Context::simTime().

void Sirikata::OH::Manual::ObjectQueryHandler::commandListQueriers	(	const OHDP::SpaceNodeID &	snid,
		Command::Result &	result
	)

References Sirikata::Command::EmptyResult(), mObjectQueries, mObjectQueryHandlers, and Sirikata::OHDP::SpaceNodeID::toString().

void Sirikata::OH::Manual::ObjectQueryHandler::createdReplicatedIndex	(	ProxIndexID	iid,
		ReplicatedLocationServiceCachePtr	loc_cache,
		ServerID	objects_from_server,
		bool	dynamic_objects
	)

References handleCreatedReplicatedIndex(), Sirikata::Liveness::livenessToken(), and Sirikata::OH::Manual::ObjectQueryHandlerBase::mProxStrand.

void Sirikata::OH::Manual::ObjectQueryHandler::generateObjectQueryEvents

(

Query *

query

)

[private]

References Sirikata::UUID::asUInt32(), Sirikata::AggregateBoundingInfo::centerBoundsRadius, Sirikata::AggregateBoundingInfo::centerOffset, Sirikata::Transfer::URI::empty(), Sirikata::ObjectReference::getAsUUID(), Sirikata::OH::Manual::ObjectQueryHandlerBase::handleAddObjectLocSubscription(), Sirikata::OH::Manual::ObjectQueryHandlerBase::handleRemoveObjectLocSubscription(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::AggregateBoundingInfo::maxObjectRadius, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, mInvertedObjectQueries, mObjectQueries, mObjectQueryHandlers, mObjectResults, Sirikata::TimedMotionQuaternion::position(), Sirikata::TimedMotionVector< MotionVectorType >::position(), Sirikata::Network::IOStrand::post(), Sirikata::ThreadSafeQueueWithNotification< T >::push(), registerObjectQueryWithServer(), Sirikata::Transfer::URI::toString(), unregisterObjectQueryWithServer(), Sirikata::TimedMotionQuaternion::updateTime(), Sirikata::TimedMotionVector< MotionVectorType >::updateTime(), Sirikata::TimedMotionQuaternion::velocity(), and Sirikata::TimedMotionVector< MotionVectorType >::velocity().

Referenced by queryHasEvents().

ObjectQueryHandler::ProxQueryHandler * Sirikata::OH::Manual::ObjectQueryHandler::getQueryHandler

(

const String &

handler_name

)

References mObjectQueryHandlers.

Referenced by commandListNodes().

void Sirikata::OH::Manual::ObjectQueryHandler::handleCreatedReplicatedIndex	(	Liveness::Token	alive,
		ProxIndexID	iid,
		ReplicatedLocationServiceCachePtr	loc_cache,
		ServerID	objects_from_server,
		bool	dynamic_objects
	)

References Sirikata::GetOptionValue< String >(), mInverseObjectQueryHandlers, mObjectQueries, mObjectQueryHandlers, OPT_MANUAL_QUERY_HANDLER_OPTIONS, OPT_MANUAL_QUERY_HANDLER_TYPE, and registerObjectQueryWithIndex().

Referenced by createdReplicatedIndex().

void Sirikata::OH::Manual::ObjectQueryHandler::handleDeliverEvents

(

)

[private]

References Sirikata::OH::Manual::ManualObjectQueryProcessor::deliverProximityResult(), Sirikata::Logging::info, mObjectResults, Sirikata::OH::Manual::ObjectQueryHandlerBase::mParent, Sirikata::OH::Manual::ObjectQueryHandlerBase::mSpaceNodeID, mSubscribers, Sirikata::OH::Manual::ObjectQueryHandler::ProximityResultInfo::querier, Sirikata::OH::Manual::ObjectQueryHandler::ProximityResultInfo::results, Sirikata::OHDP::SpaceNodeID::space(), and Sirikata::ThreadSafeQueueWithNotification< T >::swap().

void Sirikata::OH::Manual::ObjectQueryHandler::handleDisconnectedObject	(	Liveness::Token	alive,
		const ObjectReference &	object
	)		[private]

References handleRemoveObjectQuery().

Referenced by presenceDisconnected().

void Sirikata::OH::Manual::ObjectQueryHandler::handleNotifySubscribersLocUpdate	(	Liveness::Token	alive,
		ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	oref
	)		[private]

References Sirikata::OH::Manual::ManualObjectQueryProcessor::deliverLocationResult(), Sirikata::OH::Manual::ObjectQueryHandlerBase::mParent, Sirikata::OH::Manual::ObjectQueryHandlerBase::mSpaceNodeID, mSubscribers, and Sirikata::OHDP::SpaceNodeID::space().

Referenced by onBoundsUpdated(), onEpochUpdated(), onLocationUpdated(), onMeshUpdated(), onOrientationUpdated(), and onPhysicsUpdated().

void Sirikata::OH::Manual::ObjectQueryHandler::handleRemovedReplicatedIndex	(	Liveness::Token	alive,
		ProxIndexID	iid
	)

References mInverseObjectQueryHandlers, and mObjectQueryHandlers.

Referenced by removedReplicatedIndex().

void Sirikata::OH::Manual::ObjectQueryHandler::handleRemoveObjectQuery	(	Liveness::Token	alive,
		const ObjectReference &	object,
		bool	notify_main_thread
	)		[private]

References Sirikata::OH::Manual::ObjectQueryHandlerBase::handleRemoveAllObjectLocSubscription(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, mInvertedObjectQueries, mObjectQueries, and Sirikata::Network::IOStrand::post().

Referenced by handleDisconnectedObject(), and removeQuery().

void Sirikata::OH::Manual::ObjectQueryHandler::handleUpdateObjectQuery	(	Liveness::Token	alive,
		const ObjectReference &	object,
		const TimedMotionVector3f &	loc,
		const BoundingSphere3f &	bounds,
		const SolidAngle &	angle,
		uint32	max_results
	)		[private]

References Sirikata::SolidAngle::asFloat(), Sirikata::Logging::detailed, mObjectQueries, QPLOG, registerObjectQueryWithServer(), and Sirikata::JS::JSPresence::toString().

Referenced by updateQuery().

int32 Sirikata::OH::Manual::ObjectQueryHandler::objectQueries

(

)

const [private]

References mObjectQueries.

void Sirikata::OH::Manual::ObjectQueryHandler::onBoundsUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

References handleNotifySubscribersLocUpdate(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, Sirikata::Network::IOStrand::post(), and updateQuery().

void Sirikata::OH::Manual::ObjectQueryHandler::onEpochUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

References handleNotifySubscribersLocUpdate(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, and Sirikata::Network::IOStrand::post().

void Sirikata::OH::Manual::ObjectQueryHandler::onLocationUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

References handleNotifySubscribersLocUpdate(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, Sirikata::Network::IOStrand::post(), and updateQuery().

void Sirikata::OH::Manual::ObjectQueryHandler::onMeshUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

References handleNotifySubscribersLocUpdate(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, and Sirikata::Network::IOStrand::post().

void Sirikata::OH::Manual::ObjectQueryHandler::onObjectAdded	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::onObjectRemoved	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::onOrientationUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

References handleNotifySubscribersLocUpdate(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, and Sirikata::Network::IOStrand::post().

void Sirikata::OH::Manual::ObjectQueryHandler::onParentUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

void Sirikata::OH::Manual::ObjectQueryHandler::onPhysicsUpdated	(	ReplicatedLocationServiceCache *	loccache,
		const ObjectReference &	obj
	)		[virtual]

References handleNotifySubscribersLocUpdate(), Sirikata::Liveness::livenessToken(), Sirikata::Context::mainStrand, Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, and Sirikata::Network::IOStrand::post().

void Sirikata::OH::Manual::ObjectQueryHandler::presenceConnected

(

const ObjectReference &

sporef

)

void Sirikata::OH::Manual::ObjectQueryHandler::presenceDisconnected

(

const ObjectReference &

sporef

)

References handleDisconnectedObject(), Sirikata::Liveness::livenessToken(), and Sirikata::OH::Manual::ObjectQueryHandlerBase::mProxStrand.

void Sirikata::OH::Manual::ObjectQueryHandler::queryHasEvents

(

Query *

query

)

References generateObjectQueryEvents(), and mQueryHasEventsNotRentrant.

void Sirikata::OH::Manual::ObjectQueryHandler::registerObjectQueryWithIndex	(	const ObjectReference &	object,
		ProxIndexID	index_id,
		ProxQueryHandler *	handler,
		const TimedMotionVector3f &	loc,
		const BoundingSphere3f &	bounds,
		const SolidAngle &	angle,
		uint32	max_results
	)		[private]

References Sirikata::SolidAngle::Min, mInvertedObjectQueries, mObjectDistance, and mObjectQueries.

Referenced by handleCreatedReplicatedIndex(), and registerObjectQueryWithServer().

void Sirikata::OH::Manual::ObjectQueryHandler::registerObjectQueryWithServer	(	const ObjectReference &	object,
		ServerID	sid,
		const TimedMotionVector3f &	loc,
		const BoundingSphere3f &	bounds,
		const SolidAngle &	angle,
		uint32	max_results
	)		[private]

References Sirikata::OH::Manual::ObjectQueryHandler::ReplicatedIndexQueryHandler::from, Sirikata::OH::Manual::ObjectQueryHandler::ReplicatedIndexQueryHandler::handler, mObjectQueries, mObjectQueryHandlers, and registerObjectQueryWithIndex().

Referenced by generateObjectQueryEvents(), and handleUpdateObjectQuery().

void Sirikata::OH::Manual::ObjectQueryHandler::removedReplicatedIndex

(

ProxIndexID

iid

)

References handleRemovedReplicatedIndex(), Sirikata::Liveness::livenessToken(), and Sirikata::OH::Manual::ObjectQueryHandlerBase::mProxStrand.

void Sirikata::OH::Manual::ObjectQueryHandler::removeQuery	(	HostedObjectPtr	ho,
		const SpaceObjectReference &	sporef
	)

References handleRemoveObjectQuery(), Sirikata::Liveness::livenessToken(), Sirikata::OH::Manual::ObjectQueryHandlerBase::mProxStrand, and Sirikata::SpaceObjectReference::object().

void Sirikata::OH::Manual::ObjectQueryHandler::start

(

)

[virtual]

Implements Sirikata::Service.

References mObjectHandlerPoller, and Sirikata::PollerService::start().

void Sirikata::OH::Manual::ObjectQueryHandler::stop

(

)

[virtual]

Implements Sirikata::Service.

References mObjectHandlerPoller, and Sirikata::PollerService::stop().

void Sirikata::OH::Manual::ObjectQueryHandler::tickQueryHandler

(

)

[private]

References Sirikata::OH::Manual::ObjectQueryHandlerBase::mContext, mObjectQueryHandlers, and Sirikata::Context::simTime().

void Sirikata::OH::Manual::ObjectQueryHandler::unregisterObjectQueryWithIndex	(	const ObjectReference &	object,
		ProxIndexID	index_id
	)		[private]

References mInvertedObjectQueries, and mObjectQueries.

Referenced by unregisterObjectQueryWithServer().

void Sirikata::OH::Manual::ObjectQueryHandler::unregisterObjectQueryWithServer	(	const ObjectReference &	object,
		ServerID	sid
	)		[private]

References Sirikata::OH::Manual::ObjectQueryHandler::ReplicatedIndexQueryHandler::from, mObjectQueries, mObjectQueryHandlers, and unregisterObjectQueryWithIndex().

Referenced by generateObjectQueryEvents().

void Sirikata::OH::Manual::ObjectQueryHandler::updateQuery	(	const ObjectReference &	obj,
		const TimedMotionVector3f &	loc,
		const BoundingSphere3f &	bounds,
		SolidAngle	sa,
		uint32	max_results
	)		[private]

References handleUpdateObjectQuery(), Sirikata::Liveness::livenessToken(), and Sirikata::OH::Manual::ObjectQueryHandlerBase::mProxStrand.

void Sirikata::OH::Manual::ObjectQueryHandler::updateQuery	(	HostedObjectPtr	ho,
		const SpaceObjectReference &	sporef,
		const String &	params
	)

Referenced by onBoundsUpdated(), onLocationUpdated(), and updateQuery().

void Sirikata::OH::Manual::ObjectQueryHandler::updateQuery	(	HostedObjectPtr	ho,
		const SpaceObjectReference &	sporef,
		SolidAngle	sa,
		uint32	max_results
	)		[private]

References Sirikata::AggregateBoundingInfo::fullBounds(), Sirikata::SpaceObjectReference::object(), Sirikata::AggregateBoundingInfo::singleObject(), and updateQuery().

---

Member Data Documentation

InverseReplicatedIndexQueryHandlerMap Sirikata::OH::Manual::ObjectQueryHandler::mInverseObjectQueryHandlers [private]

Referenced by aggregateDestroyed(), aggregateObserved(), handleCreatedReplicatedIndex(), handleRemovedReplicatedIndex(), and ~ObjectQueryHandler().

InvertedObjectQueryMap Sirikata::OH::Manual::ObjectQueryHandler::mInvertedObjectQueries [private]

Referenced by generateObjectQueryEvents(), handleRemoveObjectQuery(), registerObjectQueryWithIndex(), and unregisterObjectQueryWithIndex().

bool Sirikata::OH::Manual::ObjectQueryHandler::mObjectDistance [private]

Referenced by ObjectQueryHandler(), and registerObjectQueryWithIndex().

PollerService Sirikata::OH::Manual::ObjectQueryHandler::mObjectHandlerPoller [private]

Referenced by start(), and stop().

ObjectQueryMap Sirikata::OH::Manual::ObjectQueryHandler::mObjectQueries [private]

Referenced by commandListQueriers(), generateObjectQueryEvents(), handleCreatedReplicatedIndex(), handleRemoveObjectQuery(), handleUpdateObjectQuery(), objectQueries(), registerObjectQueryWithIndex(), registerObjectQueryWithServer(), unregisterObjectQueryWithIndex(), and unregisterObjectQueryWithServer().

ReplicatedIndexQueryHandlerMap Sirikata::OH::Manual::ObjectQueryHandler::mObjectQueryHandlers [private]

Referenced by commandListInfo(), commandListQueriers(), generateObjectQueryEvents(), getQueryHandler(), handleCreatedReplicatedIndex(), handleRemovedReplicatedIndex(), registerObjectQueryWithServer(), tickQueryHandler(), unregisterObjectQueryWithServer(), and ~ObjectQueryHandler().

Sirikata::ThreadSafeQueueWithNotification<ProximityResultInfo> Sirikata::OH::Manual::ObjectQueryHandler::mObjectResults [private]

Referenced by generateObjectQueryEvents(), and handleDeliverEvents().

InstanceMethodNotReentrant Sirikata::OH::Manual::ObjectQueryHandler::mQueryHasEventsNotRentrant [private]

Referenced by queryHasEvents().

SubscribersMap Sirikata::OH::Manual::ObjectQueryHandler::mSubscribers [private]

Referenced by handleDeliverEvents(), and handleNotifySubscribersLocUpdate().

---

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

• liboh/plugins/manual_query/ObjectQueryHandler.hpp
• liboh/plugins/manual_query/ObjectQueryHandler.cpp