Sirikata
Public Member Functions | Private Attributes | Friends
Sirikata::SpaceContext Class Reference

SpaceContext holds a number of useful items that are effectively global for each space node and used throughout the system -- ServerID, time information, MessageRouter (sending messages), MessageDispatcher (subscribe/unsubscribe from messages), and a Trace object. More...

#include <SpaceContext.hpp>

Inheritance diagram for Sirikata::SpaceContext:
Collaboration diagram for Sirikata::SpaceContext:

List of all members.

Public Member Functions

 SpaceContext (const String &name, ServerID _id, ODPSST::ConnectionManager *sstConnMgr, OHDPSST::ConnectionManager *ohsstConnMgr, Network::IOService *ios, Network::IOStrand *strand, const Time &epoch, Trace::Trace *_trace, const Duration &duration=Duration::zero())
 ~SpaceContext ()
const String & name ()
ServerID id () const
ServerMessageRouter * serverRouter () const
ServerMessageDispatcher * serverDispatcher () const
CoordinateSegmentation * cseg () const
ObjectSessionManager * objectSessionManager () const
ObjectHostSessionManager * ohSessionManager () const
ODPSST::ConnectionManager * sstConnectionManager () const
OHDPSST::ConnectionManager * ohSSTConnectionManager () const
SpaceTrace * spacetrace () const

Private Attributes

const String mName
Sirikata::AtomicValue< ServerID > mID
Sirikata::AtomicValue
< ServerMessageRouter * > 		mServerRouter
Sirikata::AtomicValue
< ServerMessageDispatcher * > 		mServerDispatcher
Sirikata::AtomicValue
< CoordinateSegmentation * > 		mCSeg
Sirikata::AtomicValue
< ObjectHostSessionManager * > 		mObjectHostSessionManager
Sirikata::AtomicValue
< ObjectSessionManager * > 		mObjectSessionManager
Sirikata::AtomicValue
< ODPSST::ConnectionManager * > 		mSSTConnMgr
Sirikata::AtomicValue
< OHDPSST::ConnectionManager * > 		mOHSSTConnMgr
SpaceTrace * mSpaceTrace

Friends

class ServerMessageRouter
class ServerMessageDispatcher
class ObjectSessionManager
class ObjectHostSessionManager
class CoordinateSegmentation

Detailed Description

SpaceContext holds a number of useful items that are effectively global for each space node and used throughout the system -- ServerID, time information, MessageRouter (sending messages), MessageDispatcher (subscribe/unsubscribe from messages), and a Trace object.

Constructor & Destructor Documentation

Sirikata::SpaceContext::SpaceContext ( const String &  name,
ServerID  _id,
ODPSST::ConnectionManager *  sstConnMgr,
OHDPSST::ConnectionManager *  ohsstConnMgr,
Network::IOService *  ios,
Network::IOStrand *  strand,
const Time &  epoch,
Trace::Trace *  _trace,
const Duration &  duration = Duration::zero() 
)
Sirikata::SpaceContext::~SpaceContext ( )

References mSpaceTrace.

Member Function Documentation

CoordinateSegmentation* Sirikata::SpaceContext::cseg ( ) const [inline]

Referenced by Sirikata::CSFQODPFlowScheduler::getObjectWeightRegion(), Sirikata::RegionODPFlowScheduler::totalActiveWeight(), Sirikata::RegionODPFlowScheduler::totalReceiverUsedWeight(), and Sirikata::RegionODPFlowScheduler::totalSenderUsedWeight().

ServerID Sirikata::SpaceContext::id ( ) const [inline]

Referenced by Sirikata::LoadMonitor::addLoadReading(), Sirikata::StandardLocationService::addLocalObject(), Sirikata::BulletPhysicsService::addLocalObject(), Sirikata::RedisObjectSegmentation::addMigratedObject(), Sirikata::LocalObjectSegmentation::addMigratedObject(), Sirikata::CraqObjectSegmentation::addMigratedObject(), Sirikata::RedisObjectSegmentation::addNewObject(), Sirikata::LocalObjectSegmentation::addNewObject(), Sirikata::CraqObjectSegmentation::addNewObject(), Sirikata::StandardLocationService::addReplicaObject(), Sirikata::BulletPhysicsService::addReplicaObject(), Sirikata::CraqObjectSegmentation::beginCraqLookup(), Sirikata::CraqObjectSegmentation::cacheLookup(), Sirikata::CommunicationCache::CommunicationCache(), Sirikata::CoordinateSegmentationClient::CoordinateSegmentationClient(), Sirikata::CraqObjectSegmentation::craqSetResult(), Sirikata::ODPFlowScheduler::createMessageFromODP(), Sirikata::Server::delegateODPPortSend(), Sirikata::Server::delegateOHDPPortSend(), Sirikata::LibproxManualProximity::destroyQuery(), Sirikata::Server::finishAddObject(), Sirikata::RedisObjectSegmentation::finishWriteMigratedObject(), Sirikata::Forwarder::Forwarder(), Sirikata::CraqObjectSegmentation::generateAcknowledgeMessage(), Sirikata::LibproxProximity::generateObjectQueryEvents(), Sirikata::LibproxProximity::generateServerQueryEvents(), Sirikata::CSFQODPFlowScheduler::getObjectWeightRegion(), Sirikata::Server::handleConnect(), Sirikata::TCPSpaceNetwork::handleConnectedStream(), Sirikata::Server::handleMigration(), Sirikata::Server::handleMigrationEvent(), Sirikata::LibproxManualProximity::handleOnPintoServerResult(), Sirikata::LoadMonitor::handlesAdjacentRegion(), Sirikata::CoordinateSegmentationClient::handleSelfLookup(), Sirikata::MigrationMonitor::handleUpdatedSegmentation(), Sirikata::Server::killObjectConnection(), Sirikata::StandardLocationService::locationUpdate(), Sirikata::BulletPhysicsService::locationUpdate(), Sirikata::CraqObjectSegmentation::lookup(), Sirikata::CraqObjectSegmentation::migrateObject(), Sirikata::MigrationMonitor::MigrationMonitor(), Sirikata::LocalPintoServerQuerier::notifyLocUpdate(), Sirikata::LocalPintoServerQuerier::notifyResult(), Sirikata::LibproxProximity::onPintoServerResult(), Sirikata::Server::processAlreadyMigrating(), Sirikata::CraqObjectSegmentation::processMigrateMessageAcknowledge(), Sirikata::LibproxManualProximity::queryHasEvents(), Sirikata::ObjectSegmentation::queueMigAck(), Sirikata::StandardLocationService::receiveMessage(), Sirikata::BulletPhysicsService::receiveMessage(), Sirikata::Forwarder::receiveWeightUpdateMessage(), Sirikata::LibproxProximity::recomputeAggregateQueryBounds(), Sirikata::RedisObjectSegmentation::refreshObjectTimeout(), Sirikata::LibproxManualProximity::registerOHQueryWithServerHandlers(), Sirikata::LibproxManualProximity::registerOHQueryWithServerIndexHandler(), Sirikata::StandardLocationService::removeLocalObject(), Sirikata::BulletPhysicsService::removeLocalObject(), Sirikata::StandardLocationService::removeReplicaObject(), Sirikata::BulletPhysicsService::removeReplicaObject(), Sirikata::Forwarder::routeObjectMessageToServer(), Sirikata::Server::sendConnectError(), Sirikata::Server::sendConnectSuccess(), Sirikata::LoadMonitor::sendLoadReadings(), Sirikata::LibproxProximity::sendQueryRequests(), Sirikata::LibproxManualProximity::sendReplicatedClientProxMessage(), Sirikata::TCPSpaceNetwork::sendServerIntro(), Sirikata::ServerMessageReceiver::ServerMessageReceiver(), Sirikata::LibproxProximityBase::start(), Sirikata::RegionODPFlowScheduler::totalActiveWeight(), Sirikata::RegionODPFlowScheduler::totalReceiverUsedWeight(), Sirikata::RegionODPFlowScheduler::totalSenderUsedWeight(), Sirikata::Forwarder::tryCacheForward(), Sirikata::AlwaysLocationUpdatePolicy::trySend(), Sirikata::MasterPintoServerQuerierBase::tryServerUpdate(), Sirikata::LibproxManualProximity::unregisterOHQueryWithServerHandlers(), Sirikata::LibproxManualProximity::unregisterOHQueryWithServerIndexHandler(), Sirikata::LibproxProximityBase::updatedSegmentation(), Sirikata::Forwarder::updateServerWeights(), and Sirikata::CraqObjectSegmentation::~CraqObjectSegmentation().

const String& Sirikata::SpaceContext::name ( ) [inline]
ObjectSessionManager* Sirikata::SpaceContext::objectSessionManager ( ) const [inline]

Referenced by Sirikata::LibproxProximityBase::getBaseStream(), Sirikata::LocationService::LocationService(), Sirikata::Proximity::Proximity(), Sirikata::Environment::start(), Sirikata::Environment::stop(), Sirikata::AlwaysLocationUpdatePolicy::subscribe(), Sirikata::AlwaysLocationUpdatePolicy::trySend(), Sirikata::LibproxProximity::updateQuery(), Sirikata::LibproxProximityBase::validSession(), Sirikata::AlwaysLocationUpdatePolicy::validSubscriber(), Sirikata::LocationService::~LocationService(), and Sirikata::Proximity::~Proximity().

ObjectHostSessionManager* Sirikata::SpaceContext::ohSessionManager ( ) const [inline]

Referenced by Sirikata::LibproxProximityBase::getBaseStream(), Sirikata::Proximity::Proximity(), Sirikata::AlwaysLocationUpdatePolicy::subscribe(), Sirikata::AlwaysLocationUpdatePolicy::trySend(), Sirikata::LibproxProximityBase::validSession(), Sirikata::AlwaysLocationUpdatePolicy::validSubscriber(), and Sirikata::Proximity::~Proximity().

OHDPSST::ConnectionManager* Sirikata::SpaceContext::ohSSTConnectionManager ( ) const [inline]

Referenced by Sirikata::ObjectHostConnectionManager::ObjectHostConnectionManager().

ServerMessageDispatcher* Sirikata::SpaceContext::serverDispatcher ( ) const [inline]

Referenced by Sirikata::LoadMonitor::LoadMonitor(), Sirikata::LocationService::LocationService(), Sirikata::ObjectSegmentation::ObjectSegmentation(), Sirikata::Proximity::Proximity(), Sirikata::UniformCoordinateSegmentation::UniformCoordinateSegmentation(), Sirikata::LoadMonitor::~LoadMonitor(), Sirikata::LocationService::~LocationService(), Sirikata::ObjectSegmentation::~ObjectSegmentation(), Sirikata::Proximity::~Proximity(), and Sirikata::UniformCoordinateSegmentation::~UniformCoordinateSegmentation().

ServerMessageRouter* Sirikata::SpaceContext::serverRouter ( ) const [inline]

Referenced by Sirikata::LocationUpdatePolicy::initialize(), Sirikata::LibproxProximityBase::LibproxProximityBase(), Sirikata::LoadMonitor::LoadMonitor(), and Sirikata::ObjectSegmentation::ObjectSegmentation().

SpaceTrace* Sirikata::SpaceContext::spacetrace ( ) const [inline]
ODPSST::ConnectionManager* Sirikata::SpaceContext::sstConnectionManager ( ) const [inline]

Referenced by Sirikata::Server::Server(), and Sirikata::Forwarder::setODPService().

Friends And Related Function Documentation

friend class CoordinateSegmentation [friend]
friend class ObjectHostSessionManager [friend]
friend class ObjectSessionManager [friend]
friend class ServerMessageDispatcher [friend]
friend class ServerMessageRouter [friend]

Member Data Documentation

Sirikata::AtomicValue<CoordinateSegmentation*> Sirikata::SpaceContext::mCSeg [private]

Referenced by Sirikata::CoordinateSegmentation::CoordinateSegmentation().

Sirikata::AtomicValue<ServerID> Sirikata::SpaceContext::mID [private]
const String Sirikata::SpaceContext::mName [private]
Sirikata::AtomicValue<ObjectHostSessionManager*> Sirikata::SpaceContext::mObjectHostSessionManager [private]

Referenced by Sirikata::ObjectHostSessionManager::ObjectHostSessionManager().

Sirikata::AtomicValue<ObjectSessionManager*> Sirikata::SpaceContext::mObjectSessionManager [private]

Referenced by Sirikata::ObjectSessionManager::ObjectSessionManager().

Sirikata::AtomicValue<OHDPSST::ConnectionManager*> Sirikata::SpaceContext::mOHSSTConnMgr [private]
Sirikata::AtomicValue<ServerMessageDispatcher*> Sirikata::SpaceContext::mServerDispatcher [private]

Referenced by Sirikata::ServerMessageDispatcher::ServerMessageDispatcher().

Sirikata::AtomicValue<ServerMessageRouter*> Sirikata::SpaceContext::mServerRouter [private]

Referenced by Sirikata::ServerMessageRouter::ServerMessageRouter().

SpaceTrace* Sirikata::SpaceContext::mSpaceTrace [private]

Referenced by ~SpaceContext().

Sirikata::AtomicValue<ODPSST::ConnectionManager*> Sirikata::SpaceContext::mSSTConnMgr [private]
The documentation for this class was generated from the following files:
Generated on Tue Oct 2 2012 00:16:39 for Sirikata by  doxygen 1.7.4