Sirikata
Classes | Public Member Functions | Private Types | Private Member Functions | Private Attributes
Sirikata::ManualPintoManager Class Reference

ManualPintoManager responds to queries from space servers for a top-level tree, representing the highest-level aggregates. More...

#include <ManualPintoManager.hpp>

Inheritance diagram for Sirikata::ManualPintoManager:
Collaboration diagram for Sirikata::ManualPintoManager:

List of all members.

Classes

struct  ClientData

Public Member Functions

 ManualPintoManager (PintoContext *ctx)
virtual ~ManualPintoManager ()

Private Types

typedef
Prox::ManualQueryHandler
< ServerProxSimulationTraits > 		ProxQueryHandler
typedef Prox::ManualQuery
< ServerProxSimulationTraits > 		Query
typedef Prox::QueryEvent
< ServerProxSimulationTraits > 		QueryEvent
typedef
std::tr1::unordered_set
< ServerID > 		ServerSet
typedef
std::tr1::unordered_map
< Sirikata::Network::Stream
*, ClientData > 		ClientDataMap
typedef
std::tr1::unordered_map< Query
*, Sirikata::Network::Stream * > 		ClientsByQuery
typedef
std::tr1::unordered_set
< Sirikata::Network::Stream * > 		ClientStreamSet
typedef
std::tr1::unordered_map
< ServerID, ClientStreamSet > 		ServerSubscriberMap
typedef
std::tr1::unordered_set
< ProxIndexID > 		ProxIndexIDSet

Private Member Functions

virtual void onConnected (Sirikata::Network::Stream *newStream)
virtual void onInitialMessage (Sirikata::Network::Stream *stream)
virtual void onRegionUpdate (Sirikata::Network::Stream *stream, BoundingSphere3f bounds)
virtual void onMaxSizeUpdate (Sirikata::Network::Stream *stream, float32 ms)
virtual void onQueryUpdate (Sirikata::Network::Stream *stream, const String &update)
virtual void onDisconnected (Sirikata::Network::Stream *stream)
virtual void queryHasEvents (Query *query)
virtual void aggregateBoundsUpdated (ProxAggregator *handler, const ServerID &objid, const Vector3f &bnds_center, const float32 bnds_center_radius, const float32 max_obj_size)
void sendLocUpdate (ServerID about)
virtual void commandProperties (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
virtual void commandListHandlers (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
virtual void commandForceRebuild (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
virtual void commandListNodes (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
virtual void commandListQueriers (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
virtual void commandStats (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
void tick ()

Private Attributes

ClientDataMap mClients
ClientsByQuery mClientsByQuery
ServerSubscriberMap mServerSubscribers
ProxIndexIDSet mProxIndices
ProxQueryHandler * mQueryHandler
Time mLastTime
Duration mDt

Detailed Description

ManualPintoManager responds to queries from space servers for a top-level tree, representing the highest-level aggregates.

Each query has a cut, ManualPintoManager accepts commands to control it, and replicates data about nodes along and above the cut to the client space server.

Member Typedef Documentation

typedef std::tr1::unordered_map<Sirikata::Network::Stream*, ClientData> Sirikata::ManualPintoManager::ClientDataMap [private]
typedef std::tr1::unordered_map<Query*, Sirikata::Network::Stream*> Sirikata::ManualPintoManager::ClientsByQuery [private]
typedef std::tr1::unordered_set<Sirikata::Network::Stream*> Sirikata::ManualPintoManager::ClientStreamSet [private]
typedef std::tr1::unordered_set<ProxIndexID> Sirikata::ManualPintoManager::ProxIndexIDSet [private]
typedef Prox::ManualQueryHandler<ServerProxSimulationTraits> Sirikata::ManualPintoManager::ProxQueryHandler [private]
typedef Prox::ManualQuery<ServerProxSimulationTraits> Sirikata::ManualPintoManager::Query [private]
typedef Prox::QueryEvent<ServerProxSimulationTraits> Sirikata::ManualPintoManager::QueryEvent [private]
typedef std::tr1::unordered_set<ServerID> Sirikata::ManualPintoManager::ServerSet [private]
typedef std::tr1::unordered_map<ServerID, ClientStreamSet> Sirikata::ManualPintoManager::ServerSubscriberMap [private]

Constructor & Destructor Documentation

Sirikata::ManualPintoManager::ManualPintoManager ( PintoContext *  ctx)

References Sirikata::PintoManagerBase::mLocCache, and mQueryHandler.

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

References mQueryHandler.

Member Function Documentation

void Sirikata::ManualPintoManager::aggregateBoundsUpdated ( ProxAggregator *  handler,
const ServerID &  objid,
const Vector3f &  bnds_center,
const float32  bnds_center_radius,
const float32  max_obj_size 
) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References sendLocUpdate().

void Sirikata::ManualPintoManager::commandForceRebuild ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [private, virtual]

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

void Sirikata::ManualPintoManager::commandListHandlers ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [private, virtual]

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

void Sirikata::ManualPintoManager::commandListNodes ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [private, virtual]

References Sirikata::Command::EmptyResult(), Sirikata::PintoManagerBase::mContext, mQueryHandler, Sirikata::Command::Commander::result(), and Sirikata::Context::simTime().

void Sirikata::ManualPintoManager::commandListQueriers ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [private, virtual]

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

void Sirikata::ManualPintoManager::commandProperties ( const Command::Command &  cmd,
Command::Commander *  cmdr,
Command::CommandID  cmdid 
) [private, virtual]

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

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

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

void Sirikata::ManualPintoManager::onConnected ( Sirikata::Network::Stream *  newStream) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References mClients.

void Sirikata::ManualPintoManager::onDisconnected ( Sirikata::Network::Stream *  stream) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References mClients, mClientsByQuery, mServerSubscribers, and tick().

void Sirikata::ManualPintoManager::onInitialMessage ( Sirikata::Network::Stream *  stream) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References mClients, mClientsByQuery, mQueryHandler, Sirikata::Time::null(), Sirikata::ManualPintoManager::ClientData::query, and tick().

void Sirikata::ManualPintoManager::onMaxSizeUpdate ( Sirikata::Network::Stream *  stream,
float32  ms 
) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References mClients, sendLocUpdate(), Sirikata::PintoManagerBase::streamServerID(), and tick().

void Sirikata::ManualPintoManager::onQueryUpdate ( Sirikata::Network::Stream *  stream,
const String &  update 
) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References Sirikata::Logging::detailed, Sirikata::Logging::error, mClients, PINTO_LOG, Sirikata::PintoManagerBase::streamServerID(), and tick().

void Sirikata::ManualPintoManager::onRegionUpdate ( Sirikata::Network::Stream *  stream,
BoundingSphere3f  bounds 
) [private, virtual]

Reimplemented from Sirikata::PintoManagerBase.

References mClients, sendLocUpdate(), and Sirikata::PintoManagerBase::streamServerID().

void Sirikata::ManualPintoManager::queryHasEvents ( Query *  query) [private, virtual]

References Sirikata::PintoManagerLocationServiceCache::centerBoundsRadius(), Sirikata::PintoManagerLocationServiceCache::centerOffset(), Sirikata::Quaternion::identity(), Sirikata::PintoManagerLocationServiceCache::location(), Sirikata::PintoManagerLocationServiceCache::maxSize(), mClients, mClientsByQuery, Sirikata::PintoManagerLocationServiceCache::mesh(), Sirikata::PintoManagerBase::mLocCache, mProxIndices, mServerSubscribers, Sirikata::Time::null(), Sirikata::TimedMotionVector< MotionVectorType >::position(), Sirikata::Network::ReliableOrdered, Sirikata::ManualPintoManager::ClientData::results, Sirikata::Network::Stream::send(), Sirikata::ManualPintoManager::ClientData::seqno, Sirikata::serializePBJMessage(), Sirikata::PintoManagerLocationServiceCache::startTracking(), Sirikata::PintoManagerLocationServiceCache::stopTracking(), Sirikata::PintoManagerLocationServiceCache::tracking(), Sirikata::TimedMotionVector< MotionVectorType >::updateTime(), and Sirikata::TimedMotionVector< MotionVectorType >::velocity().

void Sirikata::ManualPintoManager::sendLocUpdate ( ServerID  about) [private]

References Sirikata::PintoManagerLocationServiceCache::centerBoundsRadius(), Sirikata::PintoManagerLocationServiceCache::centerOffset(), Sirikata::PintoManagerLocationServiceCache::location(), Sirikata::PintoManagerLocationServiceCache::maxSize(), mClients, Sirikata::PintoManagerBase::mLocCache, mProxIndices, mServerSubscribers, Sirikata::TimedMotionVector< MotionVectorType >::position(), Sirikata::Network::ReliableOrdered, Sirikata::Network::Stream::send(), Sirikata::ManualPintoManager::ClientData::seqno, Sirikata::serializePBJMessage(), Sirikata::PintoManagerLocationServiceCache::startTracking(), Sirikata::PintoManagerLocationServiceCache::stopTracking(), Sirikata::PintoManagerLocationServiceCache::tracking(), Sirikata::TimedMotionVector< MotionVectorType >::updateTime(), and Sirikata::TimedMotionVector< MotionVectorType >::velocity().

Referenced by aggregateBoundsUpdated(), onMaxSizeUpdate(), and onRegionUpdate().

void Sirikata::ManualPintoManager::tick ( ) [private]

References mDt, mLastTime, and mQueryHandler.

Referenced by onDisconnected(), onInitialMessage(), onMaxSizeUpdate(), and onQueryUpdate().

Member Data Documentation

ClientDataMap Sirikata::ManualPintoManager::mClients [private]

Referenced by commandListQueriers(), commandProperties(), onConnected(), onDisconnected(), onInitialMessage(), onMaxSizeUpdate(), onQueryUpdate(), onRegionUpdate(), queryHasEvents(), and sendLocUpdate().

ClientsByQuery Sirikata::ManualPintoManager::mClientsByQuery [private]

Referenced by onDisconnected(), onInitialMessage(), and queryHasEvents().

Duration Sirikata::ManualPintoManager::mDt [private]

Referenced by tick().

Time Sirikata::ManualPintoManager::mLastTime [private]

Referenced by tick().

ProxIndexIDSet Sirikata::ManualPintoManager::mProxIndices [private]

Referenced by queryHasEvents(), and sendLocUpdate().

ProxQueryHandler* Sirikata::ManualPintoManager::mQueryHandler [private]

Referenced by commandListHandlers(), commandListNodes(), ManualPintoManager(), onInitialMessage(), tick(), and ~ManualPintoManager().

ServerSubscriberMap Sirikata::ManualPintoManager::mServerSubscribers [private]

Referenced by onDisconnected(), queryHasEvents(), and sendLocUpdate().

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