Sirikata
Classes | Public Member Functions | Protected Types | Protected Member Functions | Static Protected Member Functions | Protected Attributes | Private Types | Private Attributes
Sirikata::LibproxProximityBase Class Reference

Base class for Libprox-based Proximity implementations, providing a bit of utility code that gets reused across different implementations. More...

#include <LibproxProximityBase.hpp>

Inheritance diagram for Sirikata::LibproxProximityBase:
Collaboration diagram for Sirikata::LibproxProximityBase:

List of all members.

Classes

struct  expires_tag
struct  objid_tag
struct  ProxStreamInfo
struct  StaticObjectTimeout
struct  Stats

Public Member Functions

 LibproxProximityBase (SpaceContext *ctx, LocationService *locservice, CoordinateSegmentation *cseg, SpaceNetwork *net, AggregateManager *aggmgr)
 ~LibproxProximityBase ()
virtual void start ()
 Start polling this service on this strand at the given maximum rate.
virtual void stop ()
 Stop scheduling this service.
virtual void localObjectAdded (const UUID &uuid, bool agg, const TimedMotionVector3f &loc, const TimedMotionQuaternion &orient, const AggregateBoundingInfo &bounds, const String &mesh, const String &physics, const String &zernike)
virtual void localObjectRemoved (const UUID &uuid, bool agg)
virtual void localBoundsUpdated (const UUID &uuid, bool agg, const AggregateBoundingInfo &newval)

Protected Types

enum  ObjectClass { OBJECT_CLASS_STATIC = 0, OBJECT_CLASS_DYNAMIC = 1, NUM_OBJECT_CLASSES = 2 }
typedef Prox::QueryEvent
< ObjectProxSimulationTraits > 		QueryEvent
typedef std::deque< QueryEvent > QueryEventList
typedef ODPSST::Stream::Ptr ProxObjectStreamPtr
typedef ProxStreamInfo
< ObjectReference,
ODPSST::Stream > 		ProxObjectStreamInfo
typedef std::tr1::shared_ptr
< ProxObjectStreamInfo > 		ProxObjectStreamInfoPtr
typedef OHDPSST::Stream::Ptr ProxObjectHostStreamPtr
typedef ProxStreamInfo
< OHDP::NodeID,
OHDPSST::Stream > 		ProxObjectHostStreamInfo
typedef std::tr1::shared_ptr
< ProxObjectHostStreamInfo > 		ProxObjectHostStreamInfoPtr
typedef
std::tr1::unordered_map< UUID,
ProxObjectStreamInfoPtr,
UUID::Hasher > 		ObjectProxStreamMap
typedef
std::tr1::unordered_map
< OHDP::NodeID,
ProxObjectHostStreamInfoPtr,
OHDP::NodeID::Hasher > 		ObjectHostProxStreamMap
typedef
boost::multi_index_container
< StaticObjectTimeout,
boost::multi_index::indexed_by
< boost::multi_index::ordered_unique
< boost::multi_index::tag
< objid_tag >
, BOOST_MULTI_INDEX_MEMBER(StaticObjectTimeout,
ObjectReference, objid) >
, boost::multi_index::ordered_non_unique
< boost::multi_index::tag
< expires_tag >
, BOOST_MULTI_INDEX_MEMBER(StaticObjectTimeout,
Time, expires) > > > 		StaticObjectTimeouts
typedef
StaticObjectTimeouts::index
< objid_tag >::type 		StaticObjectsByID
typedef
StaticObjectTimeouts::index
< expires_tag >::type 		StaticObjectsByExpiration

Protected Member Functions

void coalesceEvents (QueryEventList &evts, uint32 per_event)
virtual void onPintoServerResult (const Sirikata::Protocol::Prox::ProximityUpdate &update)=0
virtual void onPintoServerLocUpdate (const LocUpdate &update)=0
virtual void onSpaceNetworkConnected (ServerID sid)
virtual void onSpaceNetworkDisconnected (ServerID sid)
virtual void updatedSegmentation (CoordinateSegmentation *cseg, const std::vector< SegmentationInfo > &new_seg)
void updateObjectSize (const UUID &obj, float rad)
void removeObjectSize (const UUID &obj)
bool sendServerMessage (Message *msg)
void serverMessageReceived (Message *msg)
void readFramesFromObjectStream (const ObjectReference &oref, ProxObjectStreamInfo::FrameReceivedCallback cb)
void readFramesFromObjectHostStream (const OHDP::NodeID &node, ProxObjectHostStreamInfo::FrameReceivedCallback cb)
void readObjectStreamFrame (String &payload, ProxObjectStreamInfo::FrameReceivedCallback cb)
void readObjectHostStreamFrame (String &payload, ProxObjectStreamInfo::FrameReceivedCallback cb)
void sendObjectResult (Sirikata::Protocol::Object::ObjectMessage *)
void sendObjectHostResult (const OHDP::NodeID &node, Sirikata::Protocol::Object::ObjectMessage *)
bool validSession (const ObjectReference &oref) const
bool validSession (const OHDP::NodeID &node) const
ProxObjectStreamPtr getBaseStream (const ObjectReference &oref) const
ProxObjectHostStreamPtr getBaseStream (const OHDP::NodeID &node) const
void addObjectProxStreamInfo (ODPSST::Stream::Ptr)
void addObjectHostProxStreamInfo (OHDPSST::Stream::Ptr)
void handleAddObjectLocSubscription (const UUID &subscriber, const UUID &observed)
void handleAddObjectLocSubscriptionWithID (const UUID &subscriber, const UUID &observed, ProxIndexID index_id)
void handleRemoveObjectLocSubscription (const UUID &subscriber, const UUID &observed)
void handleRemoveObjectLocSubscriptionWithID (const UUID &subscriber, const UUID &observed, ProxIndexID index_id)
void handleRemoveAllObjectLocSubscription (const UUID &subscriber)
void handleAddOHLocSubscription (const OHDP::NodeID &subscriber, const UUID &observed)
void handleAddOHLocSubscriptionWithID (const OHDP::NodeID &subscriber, const UUID &observed, ProxIndexID index_id)
void handleRemoveOHLocSubscription (const OHDP::NodeID &subscriber, const UUID &observed)
void handleRemoveOHLocSubscriptionWithID (const OHDP::NodeID &subscriber, const UUID &observed, ProxIndexID index_id)
void handleRemoveAllOHLocSubscription (const OHDP::NodeID &subscriber)
void handleAddServerLocSubscription (const ServerID &subscriber, const UUID &observed, SeqNoPtr seqPtr)
void handleAddServerLocSubscriptionWithID (const ServerID &subscriber, const UUID &observed, ProxIndexID index_id, SeqNoPtr seqPtr)
void handleRemoveServerLocSubscription (const ServerID &subscriber, const UUID &observed)
void handleRemoveServerLocSubscriptionWithID (const ServerID &subscriber, const UUID &observed, ProxIndexID index_id)
void handleRemoveAllServerLocSubscription (const ServerID &subscriber)
void checkObjectClass (bool is_local, const UUID &objid, const TimedMotionVector3f &newval)
virtual void handleConnectedServer (ServerID sid)
virtual void handleDisconnectedServer (ServerID sid)
void removeStaticObjectTimeout (const ObjectReference &objid)
virtual void trySwapHandlers (bool is_local, const ObjectReference &objid, bool is_static)=0
void handleCheckObjectClass (bool is_local, const ObjectReference &objid, const TimedMotionVector3f &newval)
void processExpiredStaticObjectTimeouts ()
virtual void aggregateCreated (const ObjectReference &objid)
virtual void aggregateChildAdded (const ObjectReference &objid, const ObjectReference &child, const Vector3f &pos, const AggregateBoundingInfo &bnds)
virtual void aggregateChildRemoved (const ObjectReference &objid, const ObjectReference &child, const Vector3f &pos, const AggregateBoundingInfo &bnds)
virtual void aggregateBoundsUpdated (const ObjectReference &objid, const Vector3f &pos, const AggregateBoundingInfo &bnds)
virtual void aggregateDestroyed (const ObjectReference &objid)
virtual void aggregateObserved (const ObjectReference &objid, uint32 nobservers, uint32 nchildren)
void updateAggregateLoc (const ObjectReference &objid, const Vector3f &pos, const AggregateBoundingInfo &bnds)
virtual void commandProperties (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)=0
virtual void commandListHandlers (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)=0
virtual void commandForceRebuild (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)=0
virtual void commandListNodes (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)=0
virtual void commandStats (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)

Static Protected Member Functions

static const std::string & ObjectClassToString (ObjectClass c)
static BoundingBox3f aggregateBBoxes (const BoundingBoxList &bboxes)
static bool velocityIsStatic (const Vector3f &vel)

Protected Attributes

Stats mStats
bool mSeparateDynamicObjects
int mNumQueryHandlers
Duration mMoveToStaticDelay
PintoServerQuerier * mServerQuerier
float32 mMaxObject
ObjectProxStreamMap mObjectProxStreams
ObjectHostProxStreamMap mObjectHostProxStreams
CBRLocationServiceCache * mLocCache
StaticObjectTimeouts mStaticObjectTimeouts
InstanceMethodNotReentrant mQueryHasEventsNotRentrant

Private Types

typedef
std::tr1::unordered_map< UUID,
float32, UUID::Hasher > 		ObjectSizeMap

Private Attributes

ObjectSizeMap mObjectSizes
Router< Message * > * mProxServerMessageService

Detailed Description

Base class for Libprox-based Proximity implementations, providing a bit of utility code that gets reused across different implementations.

Member Typedef Documentation

typedef std::tr1::unordered_map<OHDP::NodeID, ProxObjectHostStreamInfoPtr, OHDP::NodeID::Hasher> Sirikata::LibproxProximityBase::ObjectHostProxStreamMap [protected]
typedef std::tr1::unordered_map<UUID, ProxObjectStreamInfoPtr, UUID::Hasher> Sirikata::LibproxProximityBase::ObjectProxStreamMap [protected]
typedef std::tr1::unordered_map<UUID, float32, UUID::Hasher> Sirikata::LibproxProximityBase::ObjectSizeMap [private]
typedef ProxStreamInfo<OHDP::NodeID, OHDPSST::Stream> Sirikata::LibproxProximityBase::ProxObjectHostStreamInfo [protected]
typedef std::tr1::shared_ptr<ProxObjectHostStreamInfo> Sirikata::LibproxProximityBase::ProxObjectHostStreamInfoPtr [protected]
typedef OHDPSST::Stream::Ptr Sirikata::LibproxProximityBase::ProxObjectHostStreamPtr [protected]
typedef ProxStreamInfo<ObjectReference, ODPSST::Stream> Sirikata::LibproxProximityBase::ProxObjectStreamInfo [protected]
typedef std::tr1::shared_ptr<ProxObjectStreamInfo> Sirikata::LibproxProximityBase::ProxObjectStreamInfoPtr [protected]
typedef ODPSST::Stream::Ptr Sirikata::LibproxProximityBase::ProxObjectStreamPtr [protected]
typedef Prox::QueryEvent<ObjectProxSimulationTraits> Sirikata::LibproxProximityBase::QueryEvent [protected]

Reimplemented in Sirikata::LibproxProximity.

typedef std::deque<QueryEvent> Sirikata::LibproxProximityBase::QueryEventList [protected]
typedef StaticObjectTimeouts::index<expires_tag>::type Sirikata::LibproxProximityBase::StaticObjectsByExpiration [protected]
typedef StaticObjectTimeouts::index<objid_tag>::type Sirikata::LibproxProximityBase::StaticObjectsByID [protected]
typedef boost::multi_index_container< StaticObjectTimeout, boost::multi_index::indexed_by< boost::multi_index::ordered_unique< boost::multi_index::tag<objid_tag>, BOOST_MULTI_INDEX_MEMBER(StaticObjectTimeout,ObjectReference,objid) >, boost::multi_index::ordered_non_unique< boost::multi_index::tag<expires_tag>, BOOST_MULTI_INDEX_MEMBER(StaticObjectTimeout,Time,expires) > > > Sirikata::LibproxProximityBase::StaticObjectTimeouts [protected]

Member Enumeration Documentation

enum Sirikata::LibproxProximityBase::ObjectClass [protected]
Enumerator:
OBJECT_CLASS_STATIC 
OBJECT_CLASS_DYNAMIC 
NUM_OBJECT_CLASSES 

Constructor & Destructor Documentation

Sirikata::LibproxProximityBase::LibproxProximityBase ( SpaceContext *  ctx,
LocationService *  locservice,
CoordinateSegmentation *  cseg,
SpaceNetwork *  net,
AggregateManager *  aggmgr 
)

References Sirikata::Context::add(), Sirikata::ServerMessageRouter::createServerMessageService(), Sirikata::FactoryImpl< T, Ftype >::getConstructor(), Sirikata::GetOptionValue< bool >(), Sirikata::GetOptionValue< String >(), Sirikata::PintoServerQuerierFactory::getSingleton(), Sirikata::Proximity::mContext, mLocCache, mMoveToStaticDelay, mNumQueryHandlers, mProxServerMessageService, Sirikata::Proximity::mProxStrand, mSeparateDynamicObjects, mServerQuerier, OPT_PINTO, OPT_PINTO_OPTIONS, OPT_PROX_SPLIT_DYNAMIC, and Sirikata::SpaceContext::serverRouter().

Sirikata::LibproxProximityBase::~LibproxProximityBase ( )

References mLocCache, mProxServerMessageService, and mServerQuerier.

Member Function Documentation

void Sirikata::LibproxProximityBase::addObjectHostProxStreamInfo ( OHDPSST::Stream::Ptr  strm) [protected]

References Sirikata::Proximity::mContext, mObjectHostProxStreams, and Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::writeSomeObjectResults().

Referenced by Sirikata::LibproxManualProximity::handleObjectHostSubstream().

void Sirikata::LibproxProximityBase::addObjectProxStreamInfo ( ODPSST::Stream::Ptr  strm) [protected]

References Sirikata::Proximity::mContext, mObjectProxStreams, and Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::writeSomeObjectResults().

BoundingBox3f Sirikata::LibproxProximityBase::aggregateBBoxes ( const BoundingBoxList &  bboxes) [static, protected]

Referenced by Sirikata::LibproxProximity::recomputeAggregateQueryBounds(), start(), and updatedSegmentation().

void Sirikata::LibproxProximityBase::aggregateBoundsUpdated ( const ObjectReference &  objid,
const Vector3f &  pos,
const AggregateBoundingInfo &  bnds 
) [protected, virtual]

References Sirikata::AggregateManager::generateAggregateMesh(), Sirikata::ObjectReference::getAsUUID(), Sirikata::Proximity::mAggregateManager, Sirikata::Context::mainStrand, Sirikata::Proximity::mContext, Sirikata::Network::IOStrand::post(), and updateAggregateLoc().

void Sirikata::LibproxProximityBase::aggregateChildAdded ( const ObjectReference &  objid,
const ObjectReference &  child,
const Vector3f &  pos,
const AggregateBoundingInfo &  bnds 
) [protected, virtual]

References Sirikata::AggregateManager::addChild(), Sirikata::ObjectReference::getAsUUID(), Sirikata::Proximity::mAggregateManager, Sirikata::Context::mainStrand, Sirikata::Proximity::mContext, Sirikata::Network::IOStrand::post(), and updateAggregateLoc().

void Sirikata::LibproxProximityBase::aggregateChildRemoved ( const ObjectReference &  objid,
const ObjectReference &  child,
const Vector3f &  pos,
const AggregateBoundingInfo &  bnds 
) [protected, virtual]

References Sirikata::ObjectReference::getAsUUID(), Sirikata::Proximity::mAggregateManager, Sirikata::Context::mainStrand, Sirikata::Proximity::mContext, Sirikata::Network::IOStrand::post(), Sirikata::AggregateManager::removeChild(), and updateAggregateLoc().

void Sirikata::LibproxProximityBase::aggregateCreated ( const ObjectReference &  objid) [protected, virtual]

References Sirikata::AggregateManager::addAggregate(), Sirikata::LocationService::addLocalAggregateObject(), Sirikata::ObjectReference::getAsUUID(), Sirikata::Proximity::mAggregateManager, Sirikata::Context::mainStrand, Sirikata::Proximity::mContext, Sirikata::Proximity::mLocService, Sirikata::Network::IOStrand::post(), and Sirikata::Context::simTime().

void Sirikata::LibproxProximityBase::aggregateDestroyed ( const ObjectReference &  objid) [protected, virtual]

References Sirikata::ObjectReference::getAsUUID(), Sirikata::Proximity::mAggregateManager, Sirikata::Context::mainStrand, Sirikata::Proximity::mContext, Sirikata::Proximity::mLocService, Sirikata::Network::IOStrand::post(), Sirikata::AggregateManager::removeAggregate(), and Sirikata::LocationService::removeLocalAggregateObject().

void Sirikata::LibproxProximityBase::aggregateObserved ( const ObjectReference &  objid,
uint32  nobservers,
uint32  nchildren 
) [protected, virtual]

References Sirikata::AggregateManager::aggregateObserved(), Sirikata::ObjectReference::getAsUUID(), and Sirikata::Proximity::mAggregateManager.

void Sirikata::LibproxProximityBase::checkObjectClass ( bool  is_local,
const UUID &  objid,
const TimedMotionVector3f &  newval 
) [protected]

References handleCheckObjectClass(), Sirikata::Proximity::mProxStrand, and Sirikata::Network::IOStrand::post().

Referenced by Sirikata::LibproxProximity::localLocationUpdated(), Sirikata::LibproxManualProximity::localLocationUpdated(), and Sirikata::LibproxProximity::replicaLocationUpdated().

void Sirikata::LibproxProximityBase::coalesceEvents ( QueryEventList &  evts,
uint32  per_event 
) [protected]

References mLocCache.

Referenced by Sirikata::LibproxProximity::generateObjectQueryEvents().

virtual void Sirikata::LibproxProximityBase::commandForceRebuild ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [protected, pure virtual]

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

virtual void Sirikata::LibproxProximityBase::commandListHandlers ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [protected, pure virtual]

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

virtual void Sirikata::LibproxProximityBase::commandListNodes ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [protected, pure virtual]

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

virtual void Sirikata::LibproxProximityBase::commandProperties ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [protected, pure virtual]

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

void Sirikata::LibproxProximityBase::commandStats ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [protected, virtual]

References Sirikata::Command::EmptyResult(), mStats, Sirikata::LibproxProximityBase::Stats::objectHostReceivedBytes, Sirikata::LibproxProximityBase::Stats::objectHostReceivedMessages, Sirikata::LibproxProximityBase::Stats::objectHostSentBytes, Sirikata::LibproxProximityBase::Stats::objectHostSentMessages, Sirikata::LibproxProximityBase::Stats::objectReceivedBytes, Sirikata::LibproxProximityBase::Stats::objectReceivedMessages, Sirikata::LibproxProximityBase::Stats::objectSentBytes, Sirikata::LibproxProximityBase::Stats::objectSentMessages, Sirikata::AtomicValue< T >::read(), Sirikata::Command::Commander::result(), Sirikata::LibproxProximityBase::Stats::spaceReceivedBytes, Sirikata::LibproxProximityBase::Stats::spaceReceivedMessages, Sirikata::LibproxProximityBase::Stats::spaceSentBytes, and Sirikata::LibproxProximityBase::Stats::spaceSentMessages.

LibproxProximityBase::ProxObjectStreamPtr Sirikata::LibproxProximityBase::getBaseStream ( const ObjectReference &  oref) const [protected]

References Sirikata::ObjectSessionManager::getSession(), Sirikata::ObjectSession::getStream(), Sirikata::Proximity::mContext, and Sirikata::SpaceContext::objectSessionManager().

Referenced by Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::requestProxSubstream().

LibproxProximityBase::ProxObjectHostStreamPtr Sirikata::LibproxProximityBase::getBaseStream ( const OHDP::NodeID &  node) const [protected]

References Sirikata::ObjectHostSessionManager::getSession(), Sirikata::Proximity::mContext, and Sirikata::SpaceContext::ohSessionManager().

void Sirikata::LibproxProximityBase::handleAddObjectLocSubscription ( const UUID &  subscriber,
const UUID &  observed 
) [protected]

References Sirikata::LocationService::contains(), Sirikata::Proximity::mLocService, and Sirikata::LocationService::subscribe().

Referenced by Sirikata::LibproxProximity::generateObjectQueryEvents().

void Sirikata::LibproxProximityBase::handleAddObjectLocSubscriptionWithID ( const UUID &  subscriber,
const UUID &  observed,
ProxIndexID  index_id 
) [protected]

References Sirikata::LocationService::contains(), Sirikata::Proximity::mLocService, and Sirikata::LocationService::subscribe().

void Sirikata::LibproxProximityBase::handleAddOHLocSubscription ( const OHDP::NodeID &  subscriber,
const UUID &  observed 
) [protected]

References Sirikata::LocationService::contains(), Sirikata::Proximity::mLocService, and Sirikata::LocationService::subscribe().

void Sirikata::LibproxProximityBase::handleAddOHLocSubscriptionWithID ( const OHDP::NodeID &  subscriber,
const UUID &  observed,
ProxIndexID  index_id 
) [protected]

References Sirikata::LocationService::contains(), Sirikata::Proximity::mLocService, and Sirikata::LocationService::subscribe().

Referenced by Sirikata::LibproxManualProximity::queryHasEvents().

void Sirikata::LibproxProximityBase::handleAddServerLocSubscription ( const ServerID &  subscriber,
const UUID &  observed,
SeqNoPtr  seqPtr 
) [protected]

References Sirikata::LocationService::contains(), Sirikata::Proximity::mLocService, and Sirikata::LocationService::subscribe().

Referenced by Sirikata::LibproxProximity::generateServerQueryEvents().

void Sirikata::LibproxProximityBase::handleAddServerLocSubscriptionWithID ( const ServerID &  subscriber,
const UUID &  observed,
ProxIndexID  index_id,
SeqNoPtr  seqPtr 
) [protected]

References Sirikata::LocationService::contains(), Sirikata::Proximity::mLocService, and Sirikata::LocationService::subscribe().

Referenced by Sirikata::LibproxManualProximity::queryHasEvents().

void Sirikata::LibproxProximityBase::handleCheckObjectClass ( bool  is_local,
const ObjectReference &  objid,
const TimedMotionVector3f &  newval 
) [protected]

References Sirikata::Proximity::mContext, mMoveToStaticDelay, mSeparateDynamicObjects, mStaticObjectTimeouts, Sirikata::Context::recentSimTime(), removeStaticObjectTimeout(), trySwapHandlers(), Sirikata::TimedMotionVector< MotionVectorType >::velocity(), and velocityIsStatic().

Referenced by checkObjectClass().

void Sirikata::LibproxProximityBase::handleConnectedServer ( ServerID  sid) [protected, virtual]

Reimplemented in Sirikata::LibproxProximity.

Referenced by onSpaceNetworkConnected().

void Sirikata::LibproxProximityBase::handleDisconnectedServer ( ServerID  sid) [protected, virtual]

Reimplemented in Sirikata::LibproxProximity.

Referenced by onSpaceNetworkDisconnected().

void Sirikata::LibproxProximityBase::handleRemoveAllObjectLocSubscription ( const UUID &  subscriber) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxProximity::handleRemoveObjectQuery().

void Sirikata::LibproxProximityBase::handleRemoveAllOHLocSubscription ( const OHDP::NodeID &  subscriber) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxManualProximity::destroyQuery().

void Sirikata::LibproxProximityBase::handleRemoveAllServerLocSubscription ( const ServerID &  subscriber) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxProximity::handleRemoveServerQuery().

void Sirikata::LibproxProximityBase::handleRemoveObjectLocSubscription ( const UUID &  subscriber,
const UUID &  observed 
) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxProximity::generateObjectQueryEvents().

void Sirikata::LibproxProximityBase::handleRemoveObjectLocSubscriptionWithID ( const UUID &  subscriber,
const UUID &  observed,
ProxIndexID  index_id 
) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

void Sirikata::LibproxProximityBase::handleRemoveOHLocSubscription ( const OHDP::NodeID &  subscriber,
const UUID &  observed 
) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

void Sirikata::LibproxProximityBase::handleRemoveOHLocSubscriptionWithID ( const OHDP::NodeID &  subscriber,
const UUID &  observed,
ProxIndexID  index_id 
) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxManualProximity::queryHasEvents().

void Sirikata::LibproxProximityBase::handleRemoveServerLocSubscription ( const ServerID &  subscriber,
const UUID &  observed 
) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxProximity::generateServerQueryEvents().

void Sirikata::LibproxProximityBase::handleRemoveServerLocSubscriptionWithID ( const ServerID &  subscriber,
const UUID &  observed,
ProxIndexID  index_id 
) [protected]

References Sirikata::Proximity::mLocService, and Sirikata::LocationService::unsubscribe().

Referenced by Sirikata::LibproxManualProximity::queryHasEvents().

void Sirikata::LibproxProximityBase::localBoundsUpdated ( const UUID &  uuid,
bool  agg,
const AggregateBoundingInfo &  newval 
) [virtual]

Reimplemented from Sirikata::LocationServiceListener.

Reimplemented in Sirikata::LibproxProximity.

References Sirikata::AggregateBoundingInfo::fullRadius(), and updateObjectSize().

void Sirikata::LibproxProximityBase::localObjectAdded ( const UUID &  uuid,
bool  agg,
const TimedMotionVector3f &  loc,
const TimedMotionQuaternion &  orient,
const AggregateBoundingInfo &  bounds,
const String &  mesh,
const String &  physics,
const String &  zernike 
) [virtual]

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateBoundingInfo::fullRadius(), and updateObjectSize().

void Sirikata::LibproxProximityBase::localObjectRemoved ( const UUID &  uuid,
bool  agg 
) [virtual]

Reimplemented from Sirikata::LocationServiceListener.

Reimplemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

References removeObjectSize().

const String & Sirikata::LibproxProximityBase::ObjectClassToString ( ObjectClass  c) [static, protected]

References OBJECT_CLASS_DYNAMIC, and OBJECT_CLASS_STATIC.

Referenced by Sirikata::LibproxProximity::commandListHandlers(), Sirikata::LibproxManualProximity::commandListHandlers(), Sirikata::LibproxProximity::commandListQueriers(), Sirikata::LibproxManualProximity::commandListQueriers(), Sirikata::LibproxProximity::handleCheckObjectClassForHandlers(), Sirikata::LibproxManualProximity::handleCheckObjectClassForHandlers(), Sirikata::LibproxProximity::handleUpdateServerQuery(), and Sirikata::LibproxManualProximity::handleUpdateServerQuery().

virtual void Sirikata::LibproxProximityBase::onPintoServerLocUpdate ( const LocUpdate &  update) [protected, pure virtual]

Implements Sirikata::PintoServerQuerierListener.

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

virtual void Sirikata::LibproxProximityBase::onPintoServerResult ( const Sirikata::Protocol::Prox::ProximityUpdate &  update) [protected, pure virtual]

Implements Sirikata::PintoServerQuerierListener.

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

void Sirikata::LibproxProximityBase::onSpaceNetworkConnected ( ServerID  sid) [protected, virtual]

Reimplemented from Sirikata::Proximity.

References handleConnectedServer(), Sirikata::Proximity::mProxStrand, and Sirikata::Network::IOStrand::post().

void Sirikata::LibproxProximityBase::onSpaceNetworkDisconnected ( ServerID  sid) [protected, virtual]

Reimplemented from Sirikata::Proximity.

References handleDisconnectedServer(), Sirikata::Proximity::mProxStrand, and Sirikata::Network::IOStrand::post().

void Sirikata::LibproxProximityBase::processExpiredStaticObjectTimeouts ( ) [protected]

References Sirikata::LocationService::context(), Sirikata::Proximity::mLocService, mStaticObjectTimeouts, Sirikata::Context::recentSimTime(), and trySwapHandlers().

Referenced by Sirikata::LibproxProximity::tickQueryHandler(), and Sirikata::LibproxManualProximity::tickQueryHandlers().

void Sirikata::LibproxProximityBase::readFramesFromObjectHostStream ( const OHDP::NodeID &  node,
ProxObjectHostStreamInfo::FrameReceivedCallback  cb 
) [protected]

References mObjectHostProxStreams, and readObjectHostStreamFrame().

Referenced by Sirikata::LibproxManualProximity::handleObjectHostSubstream().

void Sirikata::LibproxProximityBase::readFramesFromObjectStream ( const ObjectReference &  oref,
ProxObjectStreamInfo::FrameReceivedCallback  cb 
) [protected]

References Sirikata::ObjectReference::getAsUUID(), mObjectProxStreams, and readObjectStreamFrame().

void Sirikata::LibproxProximityBase::readObjectHostStreamFrame ( String &  payload,
ProxObjectStreamInfo::FrameReceivedCallback  cb 
) [protected]

References mStats, Sirikata::LibproxProximityBase::Stats::objectHostReceivedBytes, and Sirikata::LibproxProximityBase::Stats::objectHostReceivedMessages.

Referenced by readFramesFromObjectHostStream().

void Sirikata::LibproxProximityBase::readObjectStreamFrame ( String &  payload,
ProxObjectStreamInfo::FrameReceivedCallback  cb 
) [protected]

References mStats, Sirikata::LibproxProximityBase::Stats::objectReceivedBytes, and Sirikata::LibproxProximityBase::Stats::objectReceivedMessages.

Referenced by readFramesFromObjectStream().

void Sirikata::LibproxProximityBase::removeObjectSize ( const UUID &  obj) [protected]

References mMaxObject, mObjectSizes, mServerQuerier, and Sirikata::PintoServerQuerier::updateLargestObject().

Referenced by localObjectRemoved().

void Sirikata::LibproxProximityBase::removeStaticObjectTimeout ( const ObjectReference &  objid) [protected]

References mStaticObjectTimeouts.

Referenced by handleCheckObjectClass(), Sirikata::LibproxProximity::localObjectRemoved(), Sirikata::LibproxManualProximity::localObjectRemoved(), Sirikata::LibproxProximity::replicaObjectRemoved(), and Sirikata::LibproxManualProximity::replicaObjectRemoved().

void Sirikata::LibproxProximityBase::sendObjectHostResult ( const OHDP::NodeID &  node,
Sirikata::Protocol::Object::ObjectMessage *  msg 
) [protected]

References Sirikata::Proximity::mContext, mObjectHostProxStreams, mStats, Sirikata::LibproxProximityBase::Stats::objectHostSentBytes, Sirikata::LibproxProximityBase::Stats::objectHostSentMessages, Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::requestProxSubstream(), Sirikata::Network::Frame::write(), and Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::writeSomeObjectResults().

Referenced by Sirikata::LibproxManualProximity::poll().

void Sirikata::LibproxProximityBase::sendObjectResult ( Sirikata::Protocol::Object::ObjectMessage *  msg) [protected]

References Sirikata::Proximity::mContext, mObjectProxStreams, mStats, Sirikata::LibproxProximityBase::Stats::objectSentBytes, Sirikata::LibproxProximityBase::Stats::objectSentMessages, Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::requestProxSubstream(), Sirikata::Network::Frame::write(), and Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::writeSomeObjectResults().

Referenced by Sirikata::LibproxProximity::poll().

bool Sirikata::LibproxProximityBase::sendServerMessage ( Message *  msg) [protected]

References mProxServerMessageService, mStats, Sirikata::Message::payload(), Sirikata::Router< MessageType >::route(), Sirikata::LibproxProximityBase::Stats::spaceSentBytes, and Sirikata::LibproxProximityBase::Stats::spaceSentMessages.

Referenced by Sirikata::LibproxProximity::poll(), Sirikata::LibproxManualProximity::poll(), and Sirikata::LibproxProximity::sendQueryRequests().

void Sirikata::LibproxProximityBase::serverMessageReceived ( Message *  msg) [protected]

References mStats, Sirikata::Message::payload(), Sirikata::LibproxProximityBase::Stats::spaceReceivedBytes, and Sirikata::LibproxProximityBase::Stats::spaceReceivedMessages.

Referenced by Sirikata::LibproxProximity::receiveMessage(), and Sirikata::LibproxManualProximity::receiveMessage().

void Sirikata::LibproxProximityBase::start ( ) [virtual]

Start polling this service on this strand at the given maximum rate.

Reimplemented from Sirikata::Proximity.

Reimplemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

References aggregateBBoxes(), Sirikata::SpaceContext::id(), Sirikata::Proximity::mContext, Sirikata::Proximity::mCSeg, mServerQuerier, Sirikata::CoordinateSegmentation::serverRegion(), and Sirikata::PintoServerQuerier::updateRegion().

void Sirikata::LibproxProximityBase::stop ( ) [virtual]

Stop scheduling this service.

Note that this does not immediately stop the service, it simply guarantees the service will not be scheduled again. This allows outstanding events to be handled properly.

Reimplemented from Sirikata::Proximity.

Reimplemented in Sirikata::LibproxManualProximity.

virtual void Sirikata::LibproxProximityBase::trySwapHandlers ( bool  is_local,
const ObjectReference &  objid,
bool  is_static 
) [protected, pure virtual]

Implemented in Sirikata::LibproxManualProximity, and Sirikata::LibproxProximity.

Referenced by handleCheckObjectClass(), and processExpiredStaticObjectTimeouts().

void Sirikata::LibproxProximityBase::updateAggregateLoc ( const ObjectReference &  objid,
const Vector3f &  pos,
const AggregateBoundingInfo &  bnds 
) [protected]

References Sirikata::LocationService::bounds(), Sirikata::LocationService::contains(), Sirikata::ObjectReference::getAsUUID(), Sirikata::LocationService::location(), Sirikata::Proximity::mContext, Sirikata::Proximity::mLocService, Sirikata::TimedMotionVector< MotionVectorType >::position(), Sirikata::Context::simTime(), Sirikata::LocationService::updateLocalAggregateBounds(), and Sirikata::LocationService::updateLocalAggregateLocation().

Referenced by aggregateBoundsUpdated(), aggregateChildAdded(), and aggregateChildRemoved().

void Sirikata::LibproxProximityBase::updatedSegmentation ( CoordinateSegmentation *  cseg,
const std::vector< SegmentationInfo > &  new_seg 
) [protected, virtual]

Reimplemented from Sirikata::Proximity.

References aggregateBBoxes(), Sirikata::SpaceContext::id(), Sirikata::Proximity::mContext, Sirikata::Proximity::mCSeg, mServerQuerier, Sirikata::CoordinateSegmentation::serverRegion(), and Sirikata::PintoServerQuerier::updateRegion().

void Sirikata::LibproxProximityBase::updateObjectSize ( const UUID &  obj,
float  rad 
) [protected]

References mMaxObject, mObjectSizes, mServerQuerier, obj, and Sirikata::PintoServerQuerier::updateLargestObject().

Referenced by localBoundsUpdated(), and localObjectAdded().

bool Sirikata::LibproxProximityBase::validSession ( const OHDP::NodeID &  node) const [protected]

References Sirikata::ObjectHostSessionManager::getSession(), Sirikata::Proximity::mContext, and Sirikata::SpaceContext::ohSessionManager().

bool Sirikata::LibproxProximityBase::validSession ( const ObjectReference &  oref) const [protected]

References Sirikata::ObjectSessionManager::getSession(), Sirikata::Proximity::mContext, and Sirikata::SpaceContext::objectSessionManager().

Referenced by Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::proxSubstreamCallback(), and Sirikata::LibproxProximityBase::ProxStreamInfo< EndpointType, StreamType >::requestProxSubstream().

bool Sirikata::LibproxProximityBase::velocityIsStatic ( const Vector3f &  vel) [static, protected]

Referenced by handleCheckObjectClass(), Sirikata::LibproxProximity::handlerShouldHandleObject(), and Sirikata::LibproxManualProximity::handlerShouldHandleObject().

Member Data Documentation

CBRLocationServiceCache* Sirikata::LibproxProximityBase::mLocCache [protected]

Referenced by coalesceEvents(), Sirikata::LibproxProximity::generateObjectQueryEvents(), Sirikata::LibproxProximity::generateServerQueryEvents(), Sirikata::LibproxManualProximity::LibproxManualProximity(), Sirikata::LibproxProximity::LibproxProximity(), LibproxProximityBase(), and ~LibproxProximityBase().

float32 Sirikata::LibproxProximityBase::mMaxObject [protected]

Referenced by Sirikata::LibproxProximity::commandProperties(), Sirikata::LibproxManualProximity::commandProperties(), removeObjectSize(), and updateObjectSize().

Duration Sirikata::LibproxProximityBase::mMoveToStaticDelay [protected]

Referenced by Sirikata::LibproxProximity::commandProperties(), Sirikata::LibproxManualProximity::commandProperties(), handleCheckObjectClass(), and LibproxProximityBase().

int Sirikata::LibproxProximityBase::mNumQueryHandlers [protected]

Referenced by Sirikata::LibproxProximity::commandProperties(), Sirikata::LibproxManualProximity::commandProperties(), Sirikata::LibproxManualProximity::LibproxManualProximity(), Sirikata::LibproxProximity::LibproxProximity(), and LibproxProximityBase().

ObjectHostProxStreamMap Sirikata::LibproxProximityBase::mObjectHostProxStreams [protected]

Referenced by addObjectHostProxStreamInfo(), Sirikata::LibproxManualProximity::commandProperties(), readFramesFromObjectHostStream(), and sendObjectHostResult().

ObjectProxStreamMap Sirikata::LibproxProximityBase::mObjectProxStreams [protected]

Referenced by addObjectProxStreamInfo(), Sirikata::LibproxProximity::commandProperties(), readFramesFromObjectStream(), sendObjectResult(), and Sirikata::LibproxProximity::sessionClosed().

ObjectSizeMap Sirikata::LibproxProximityBase::mObjectSizes [private]

Referenced by removeObjectSize(), and updateObjectSize().

Router<Message*>* Sirikata::LibproxProximityBase::mProxServerMessageService [private]

Referenced by LibproxProximityBase(), sendServerMessage(), and ~LibproxProximityBase().

InstanceMethodNotReentrant Sirikata::LibproxProximityBase::mQueryHasEventsNotRentrant [protected]

Referenced by Sirikata::LibproxProximity::queryHasEvents(), and Sirikata::LibproxManualProximity::queryHasEvents().

bool Sirikata::LibproxProximityBase::mSeparateDynamicObjects [protected]

Referenced by Sirikata::LibproxProximity::commandProperties(), Sirikata::LibproxManualProximity::commandProperties(), handleCheckObjectClass(), Sirikata::LibproxProximity::handlerShouldHandleObject(), Sirikata::LibproxManualProximity::handlerShouldHandleObject(), Sirikata::LibproxManualProximity::LibproxManualProximity(), Sirikata::LibproxProximity::LibproxProximity(), LibproxProximityBase(), Sirikata::LibproxProximity::localLocationUpdated(), Sirikata::LibproxManualProximity::localLocationUpdated(), and Sirikata::LibproxProximity::replicaLocationUpdated().

PintoServerQuerier* Sirikata::LibproxProximityBase::mServerQuerier [protected]

Referenced by LibproxProximityBase(), removeObjectSize(), Sirikata::LibproxManualProximity::sendReplicatedClientProxMessage(), start(), Sirikata::LibproxProximity::updateAggregateQuery(), updatedSegmentation(), updateObjectSize(), and ~LibproxProximityBase().

StaticObjectTimeouts Sirikata::LibproxProximityBase::mStaticObjectTimeouts [protected]

Referenced by handleCheckObjectClass(), processExpiredStaticObjectTimeouts(), and removeStaticObjectTimeout().

Stats Sirikata::LibproxProximityBase::mStats [protected]

Referenced by commandStats(), Sirikata::LibproxProximity::handleObjectProximityMessage(), readObjectHostStreamFrame(), readObjectStreamFrame(), sendObjectHostResult(), sendObjectResult(), sendServerMessage(), and serverMessageReceived().

The documentation for this class was generated from the following files:
Generated on Tue Oct 2 2012 00:16:43 for Sirikata by  doxygen 1.7.4