Sirikata::Server Class Reference

Handles all the basic services provided for objects by a server, including routing and message delivery, proximity services, and object -> server mapping. More...

#include <Server.hpp>

Inheritance diagram for Sirikata::Server:

Collaboration diagram for Sirikata::Server:

List of all members.

Classes
struct	ConnectionIDObjectMessagePair
struct	MigratingObjectConnectionsData
struct	StoredConnection
Public Member Functions
	Server (SpaceContext *ctx, Authenticator *auth, Forwarder *forwarder, LocationService *loc_service, CoordinateSegmentation *cseg, Proximity *prox, ObjectSegmentation *oseg, Address4 oh_listen_addr, ObjectHostSessionManager *oh_sess_mgr, ObjectSessionManager *obj_sess_mgr)
	~Server ()
virtual void	receiveMessage (Message *msg)
Private Types
typedef std::tr1::unordered_map< UUID, ObjectConnection *, UUID::Hasher >	ObjectConnectionMap
typedef ObjectConnectionMap	MigrationRequestMap
typedef std::tr1::unordered_map< UUID, Sirikata::Protocol::Migration::MigrationMessage *, UUID::Hasher >	ObjectMigrationMap
typedef std::queue< Message * >	MigrateMessageQueue
typedef std::map< UUID, MigratingObjectConnectionsData >	MigConnectionsMap
typedef std::map< UUID, StoredConnection >	StoredConnectionMap
Private Member Functions
void	start ()
void	stop ()
virtual void	osegMigrationAcknowledged (const UUID &id)
virtual void	osegAddNewFinished (const UUID &id, OSegAddNewStatus status)
ODP::DelegatePort *	createDelegateODPPort (ODP::DelegateService *, const SpaceObjectReference &sor, ODP::PortID port)
bool	delegateODPPortSend (const ODP::Endpoint &source_ep, const ODP::Endpoint &dest_ep, MemoryReference payload)
OHDP::DelegatePort *	createDelegateOHDPPort (OHDP::DelegateService *, const OHDP::Endpoint &ept)
bool	delegateOHDPPortSend (const OHDP::Endpoint &source_ep, const OHDP::Endpoint &dest_ep, MemoryReference payload)
virtual void	onObjectHostConnected (const ObjectHostConnectionID &conn_id, const ShortObjectHostConnectionID short_conn_id, OHDPSST::Stream::Ptr stream)
virtual bool	onObjectHostMessageReceived (const ObjectHostConnectionID &conn_id, const ShortObjectHostConnectionID short_conn_id, Sirikata::Protocol::Object::ObjectMessage *)
virtual void	onObjectHostDisconnected (const ObjectHostConnectionID &conn_id, const ShortObjectHostConnectionID short_conn_id)
void	handleMigrationEvent (const UUID &objid)
void	startSendMigrationMessages ()
void	trySendMigrationMessages ()
void	sendSessionMessageWithRetry (const ObjectHostConnectionID &conn, Sirikata::Protocol::Object::ObjectMessage *msg, const Duration &retry_rate)
bool	isObjectConnected (const UUID &object_id) const
bool	isObjectConnecting (const UUID &object_id) const
void	handleObjectHostConnectionClosed (const ObjectHostConnectionID &conn_id)
void	scheduleObjectHostMessageRouting ()
void	handleObjectHostMessageRouting ()
bool	handleSingleObjectHostMessageRouting ()
void	handleSessionMessage (const ObjectHostConnectionID &oh_conn_id, Sirikata::Protocol::Object::ObjectMessage *msg)
void	handleConnect (const ObjectHostConnectionID &oh_conn_id, const Sirikata::Protocol::Object::ObjectMessage &container, const Sirikata::Protocol::Session::Connect &connect_msg, uint64 seqno)
void	handleConnectAuthResponse (const ObjectHostConnectionID &oh_conn_id, const UUID &obj_id, const Sirikata::Protocol::Session::Connect &connect_msg, uint64 seqno, bool authenticated)
void	sendConnectSuccess (const ObjectHostConnectionID &oh_conn_id, const UUID &obj_id, uint64 session_request_seqno)
void	sendConnectError (const ObjectHostConnectionID &oh_conn_id, const UUID &obj_id, uint64 session_request_seqno)
void	handleConnectAck (const ObjectHostConnectionID &oh_conn_id, const Sirikata::Protocol::Object::ObjectMessage &container, uint64 session_request_seqno)
void	handleMigrate (const ObjectHostConnectionID &oh_conn_id, const Sirikata::Protocol::Object::ObjectMessage &container, const Sirikata::Protocol::Session::Connect &migrate_msg, uint64 seqno)
void	handleMigration (const UUID &obj_id)
void	handleDisconnect (UUID obj_id, ObjectConnection *conn, uint64 session_request_seqno)
void	killObjectConnection (const UUID &obj_id)
void	finishAddObject (const UUID &obj_id, OSegAddNewStatus status)
bool	checkAlreadyMigrating (const UUID &obj_id)
void	processAlreadyMigrating (const UUID &obj_id)
void	newStream (int err, SST::Stream< SpaceObjectReference >::Ptr s)
void	commandObjectsCount (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
void	commandObjectsList (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
void	commandObjectsDisconnect (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
Private Attributes
SpaceContext *	mContext
TimeSyncServer *	mTimeSyncServer
Authenticator *	mAuthenticator
LocationService *	mLocationService
CoordinateSegmentation *	mCSeg
Proximity *	mProximity
ObjectSegmentation *	mOSeg
LocalForwarder *	mLocalForwarder
Forwarder *	mForwarder
MigrationMonitor *	mMigrationMonitor
ObjectHostSessionManager *	mOHSessionManager
ObjectSessionManager *	mObjectSessionManager
Router< Message * > *	mMigrateServerMessageService
bool	mMigrationSendRunning
bool	mShutdownRequested
ObjectHostConnectionManager *	mObjectHostConnectionManager
ObjectConnectionMap	mObjects
MigrationRequestMap	mObjectsAwaitingMigration
ObjectMigrationMap	mObjectMigrations
MigrateMessageQueue	mMigrateMessages
MigConnectionsMap	mMigratingConnections
Timer	mMigrationTimer
StoredConnectionMap	mStoredConnectionData
boost::mutex	mRouteObjectMessageMutex
Sirikata::SizedThreadSafeQueue < ConnectionIDObjectMessagePair >	mRouteObjectMessage
String	mTimeSeriesObjects

---

Detailed Description

Handles all the basic services provided for objects by a server, including routing and message delivery, proximity services, and object -> server mapping.

This is a singleton for each simulated server. Other servers are referenced by their ServerID.

---

Member Typedef Documentation

typedef std::map<UUID,MigratingObjectConnectionsData> Sirikata::Server::MigConnectionsMap [private]

typedef std::queue<Message*> Sirikata::Server::MigrateMessageQueue [private]

typedef ObjectConnectionMap Sirikata::Server::MigrationRequestMap [private]

typedef std::tr1::unordered_map<UUID, ObjectConnection*, UUID::Hasher> Sirikata::Server::ObjectConnectionMap [private]

typedef std::tr1::unordered_map<UUID, Sirikata::Protocol::Migration::MigrationMessage*, UUID::Hasher> Sirikata::Server::ObjectMigrationMap [private]

typedef std::map<UUID, StoredConnection> Sirikata::Server::StoredConnectionMap [private]

---

Constructor & Destructor Documentation

Sirikata::Server::Server	(	SpaceContext *	ctx,
		Authenticator *	auth,
		Forwarder *	forwarder,
		LocationService *	loc_service,
		CoordinateSegmentation *	cseg,
		Proximity *	prox,
		ObjectSegmentation *	oseg,
		Address4	oh_listen_addr,
		ObjectHostSessionManager *	oh_sess_mgr,
		ObjectSessionManager *	obj_sess_mgr
	)

References Sirikata::Context::commander(), commandObjectsCount(), commandObjectsDisconnect(), commandObjectsList(), Sirikata::Forwarder::createServerMessageService(), handleMigrationEvent(), Sirikata::SST::ConnectionManager< EndPointType >::listen(), Sirikata::Context::mainStrand, mContext, mCSeg, mForwarder, mLocalForwarder, mLocationService, mMigrateServerMessageService, mMigrationMonitor, mMigrationTimer, mObjectHostConnectionManager, mOSeg, mTimeSyncServer, newStream(), Sirikata::SpaceID::null(), OBJECT_SPACE_PORT, Sirikata::Command::Commander::registerCommand(), Sirikata::ServerMessageDispatcher::registerMessageRecipient(), SERVER_PORT_MIGRATION, Sirikata::Forwarder::setLocalForwarder(), Sirikata::Forwarder::setODPService(), Sirikata::ObjectSegmentation::setWriteListener(), Sirikata::ObjectReference::spaceServiceID(), Sirikata::SpaceContext::sstConnectionManager(), Sirikata::Timer::start(), and Sirikata::Network::IOStrand::wrap().

Sirikata::Server::~Server

(

)

References Sirikata::Logging::debug, mForwarder, mLocalForwarder, mLocationService, mMigrateServerMessageService, mMigrationMonitor, mObjectHostConnectionManager, mObjects, mProximity, mTimeSyncServer, Sirikata::LocationService::removeLocalObject(), Sirikata::Forwarder::removeObjectConnection(), Sirikata::Proximity::removeQuery(), SERVER_PORT_MIGRATION, SPACE_LOG, and Sirikata::ServerMessageDispatcher::unregisterMessageRecipient().

---

Member Function Documentation

bool Sirikata::Server::checkAlreadyMigrating

(

const UUID &

obj_id

)

[private]

References mMigratingConnections.

Referenced by handleMigration().

void Sirikata::Server::commandObjectsCount	(	const Command::Command &	cmd,
		Command::Commander *	cmdr,
		Command::CommandID	cmdid
	)		[private]

References Sirikata::Command::EmptyResult(), mMigratingConnections, mObjectMigrations, mObjects, mObjectsAwaitingMigration, mStoredConnectionData, and Sirikata::Command::Commander::result().

Referenced by Server().

void Sirikata::Server::commandObjectsDisconnect	(	const Command::Command &	cmd,
		Command::Commander *	cmdr,
		Command::CommandID	cmdid
	)		[private]

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

Referenced by Server().

void Sirikata::Server::commandObjectsList	(	const Command::Command &	cmd,
		Command::Commander *	cmdr,
		Command::CommandID	cmdid
	)		[private]

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

Referenced by Server().

ODP::DelegatePort * Sirikata::Server::createDelegateODPPort	(	ODP::DelegateService *	,
		const SpaceObjectReference &	sor,
		ODP::PortID	port
	)		[private]

References delegateODPPortSend().

OHDP::DelegatePort * Sirikata::Server::createDelegateOHDPPort	(	OHDP::DelegateService *	,
		const OHDP::Endpoint &	ept
	)		[private]

References delegateOHDPPortSend().

bool Sirikata::Server::delegateODPPortSend	(	const ODP::Endpoint &	source_ep,
		const ODP::Endpoint &	dest_ep,
		MemoryReference	payload
	)		[private]

References Sirikata::createObjectMessage(), Sirikata::DataReference< T >::data(), Sirikata::ObjectReference::getAsUUID(), Sirikata::SpaceContext::id(), mContext, mLocalForwarder, Sirikata::ODP::Endpoint::object(), Sirikata::XDP::Endpoint< IdentifierType >::port(), Sirikata::DataReference< T >::size(), and Sirikata::LocalForwarder::tryForward().

Referenced by createDelegateODPPort().

bool Sirikata::Server::delegateOHDPPortSend	(	const OHDP::Endpoint &	source_ep,
		const OHDP::Endpoint &	dest_ep,
		MemoryReference	payload
	)		[private]

References Sirikata::createObjectMessage(), Sirikata::DataReference< T >::data(), Sirikata::SpaceContext::id(), mContext, mObjectHostConnectionManager, Sirikata::OHDP::Endpoint::node(), Sirikata::UUID::null(), Sirikata::XDP::Endpoint< IdentifierType >::port(), Sirikata::ObjectHostConnectionManager::send(), and Sirikata::DataReference< T >::size().

Referenced by createDelegateOHDPPort().

void Sirikata::Server::finishAddObject	(	const UUID &	obj_id,
		OSegAddNewStatus	status
	)		[private]

References Sirikata::LocalForwarder::addActiveConnection(), Sirikata::LocationService::addLocalObject(), Sirikata::Forwarder::addObjectConnection(), Sirikata::Proximity::addQuery(), Sirikata::ObjectSessionManager::addSession(), Sirikata::Server::StoredConnection::conn_id, Sirikata::Server::StoredConnection::conn_msg, Sirikata::ObjectConnection::connID(), Sirikata::Logging::error, Sirikata::SpaceContext::id(), mContext, mCSeg, mForwarder, mLocalForwarder, mLocationService, mObjectHostConnectionManager, mObjects, mObjectSessionManager, mProximity, mStoredConnectionData, mTimeSeriesObjects, Sirikata::Trace::TimeSeries::report(), Sirikata::CoordinateSegmentation::reportLoad(), sendConnectError(), sendConnectSuccess(), Sirikata::CoordinateSegmentation::serverRegion(), Sirikata::Server::StoredConnection::session_seqno, Sirikata::Context::simTime(), SPACE_LOG, Sirikata::OSegWriteListener::SUCCESS, Sirikata::Context::timeSeries, and Sirikata::UUID::toString().

Referenced by osegAddNewFinished().

void Sirikata::Server::handleConnect	(	const ObjectHostConnectionID &	oh_conn_id,
		const Sirikata::Protocol::Object::ObjectMessage &	container,
		const Sirikata::Protocol::Session::Connect &	connect_msg,
		uint64	seqno
	)		[private]

References Sirikata::Authenticator::authenticate(), Sirikata::createObjectMessage(), Sirikata::TemporalValueBase< Value, TimeType >::extrapolate(), handleConnectAuthResponse(), Sirikata::SpaceContext::id(), Sirikata::CoordinateSegmentation::lookup(), mAuthenticator, mContext, mCSeg, mMigrationMonitor, Sirikata::UUID::null(), OBJECT_PORT_SESSION, Sirikata::MigrationMonitor::onThisServer(), position, sendConnectError(), sendSessionMessageWithRetry(), Sirikata::serializePBJMessage(), Sirikata::Context::simTime(), SPACE_LOG, and Sirikata::Logging::warn.

Referenced by handleSessionMessage().

void Sirikata::Server::handleConnectAck	(	const ObjectHostConnectionID &	oh_conn_id,
		const Sirikata::Protocol::Object::ObjectMessage &	container,
		uint64	session_request_seqno
	)		[private]

References Sirikata::Logging::detailed, Sirikata::Forwarder::enableObjectConnection(), mForwarder, mObjects, Sirikata::ObjectConnection::sessionID(), and SPACE_LOG.

Referenced by handleSessionMessage().

void Sirikata::Server::handleConnectAuthResponse	(	const ObjectHostConnectionID &	oh_conn_id,
		const UUID &	obj_id,
		const Sirikata::Protocol::Session::Connect &	connect_msg,
		uint64	seqno,
		bool	authenticated
	)		[private]

References Sirikata::ObjectSegmentation::addNewObject(), Sirikata::Server::StoredConnection::conn_id, Sirikata::Server::StoredConnection::conn_msg, isObjectConnected(), isObjectConnecting(), mObjects, mOSeg, mStoredConnectionData, sendConnectError(), sendConnectSuccess(), and Sirikata::Server::StoredConnection::session_seqno.

Referenced by handleConnect().

void Sirikata::Server::handleDisconnect	(	UUID	obj_id,
		ObjectConnection *	conn,
		uint64	session_request_seqno
	)		[private]

References Sirikata::Logging::detailed, Sirikata::ObjectConnection::id(), mForwarder, mLocalForwarder, mLocationService, mObjects, mObjectSessionManager, mOSeg, mProximity, obj, Sirikata::LocalForwarder::removeActiveConnection(), Sirikata::LocationService::removeLocalObject(), Sirikata::ObjectSegmentation::removeObject(), Sirikata::Forwarder::removeObjectConnection(), Sirikata::Proximity::removeQuery(), Sirikata::ObjectSessionManager::removeSession(), Sirikata::ObjectConnection::sessionID(), and SPACE_LOG.

Referenced by commandObjectsDisconnect(), handleObjectHostConnectionClosed(), and handleSessionMessage().

void Sirikata::Server::handleMigrate	(	const ObjectHostConnectionID &	oh_conn_id,
		const Sirikata::Protocol::Object::ObjectMessage &	container,
		const Sirikata::Protocol::Session::Connect &	migrate_msg,
		uint64	seqno
	)		[private]

References Sirikata::Logging::detailed, handleMigration(), isObjectConnected(), mObjectHostConnectionManager, mObjectsAwaitingMigration, SPACE_LOG, and Sirikata::UUID::toString().

Referenced by handleSessionMessage().

void Sirikata::Server::handleMigration

(

const UUID &

obj_id

)

[private]

References Sirikata::LocalForwarder::addActiveConnection(), Sirikata::LocationService::addLocalObject(), Sirikata::ObjectSegmentation::addMigratedObject(), Sirikata::Forwarder::addObjectConnection(), Sirikata::ObjectSessionManager::addSession(), checkAlreadyMigrating(), Sirikata::ObjectConnection::connID(), Sirikata::createObjectMessage(), Sirikata::Logging::detailed, Sirikata::Logging::error, Sirikata::SpaceContext::id(), mContext, mForwarder, Sirikata::Proximity::migrationClientTag(), mLocalForwarder, mLocationService, mObjectMigrations, mObjects, mObjectsAwaitingMigration, mObjectSessionManager, mOSeg, mProximity, mTimeSeriesObjects, Sirikata::UUID::null(), OBJECT_PORT_SESSION, processAlreadyMigrating(), Sirikata::Proximity::receiveMigrationData(), Sirikata::Trace::TimeSeries::report(), sendSessionMessageWithRetry(), Sirikata::serializePBJMessage(), Sirikata::ObjectConnection::sessionID(), SPACE_LOG, Sirikata::Context::timeSeries, and Sirikata::UUID::toString().

Referenced by handleMigrate(), and receiveMessage().

void Sirikata::Server::handleMigrationEvent

(

const UUID &

objid

)

[private]

References Sirikata::Server::MigratingObjectConnectionsData::bnds, Sirikata::LocationService::bounds(), Sirikata::ObjectSegmentation::clearToMigrate(), Sirikata::ObjectConnection::connID(), Sirikata::createObjectMessage(), Sirikata::LocationService::currentPosition(), Sirikata::Logging::detailed, Sirikata::Timer::elapsed(), Sirikata::Proximity::generateMigrationData(), Sirikata::Forwarder::getObjectConnection(), Sirikata::SpaceContext::id(), Sirikata::Server::MigratingObjectConnectionsData::loc, Sirikata::LocationService::location(), Sirikata::CoordinateSegmentation::lookup(), mContext, mCSeg, Sirikata::LocationService::mesh(), mForwarder, Sirikata::ObjectSegmentation::migrateObject(), Sirikata::Server::MigratingObjectConnectionsData::migratingTo, Sirikata::Proximity::migrationClientTag(), Sirikata::Server::MigratingObjectConnectionsData::milliseconds, mLocalForwarder, mLocationService, mMigrateMessages, mMigratingConnections, mMigrationTimer, mObjects, mObjectSessionManager, mOSeg, mProximity, mTimeSeriesObjects, Sirikata::UUID::null(), obj, Sirikata::Server::MigratingObjectConnectionsData::obj_conner, OBJECT_PORT_SESSION, Sirikata::LocationService::orientation(), Sirikata::TimedMotionQuaternion::position(), Sirikata::TimedMotionVector< MotionVectorType >::position(), Sirikata::LocalForwarder::removeActiveConnection(), Sirikata::LocationService::removeLocalObject(), Sirikata::ObjectSessionManager::removeSession(), Sirikata::Trace::TimeSeries::report(), sendSessionMessageWithRetry(), Sirikata::serializePBJMessage(), SERVER_PORT_MIGRATION, Sirikata::Server::MigratingObjectConnectionsData::serviceConnection, Sirikata::ObjectConnection::sessionID(), SPACE_LOG, startSendMigrationMessages(), Sirikata::Context::timeSeries, Sirikata::UUID::toString(), Sirikata::Server::MigratingObjectConnectionsData::uniqueConnId, Sirikata::TimedMotionQuaternion::updateTime(), Sirikata::TimedMotionVector< MotionVectorType >::updateTime(), Sirikata::TimedMotionQuaternion::velocity(), and Sirikata::TimedMotionVector< MotionVectorType >::velocity().

Referenced by Server().

void Sirikata::Server::handleObjectHostConnectionClosed

(

const ObjectHostConnectionID &

conn_id

)

[private]

References Sirikata::ObjectConnection::connID(), handleDisconnect(), mContext, mObjects, mTimeSeriesObjects, Sirikata::Trace::TimeSeries::report(), Sirikata::ObjectConnection::sessionID(), and Sirikata::Context::timeSeries.

Referenced by onObjectHostDisconnected().

void Sirikata::Server::handleObjectHostMessageRouting

(

)

[private]

References handleSingleObjectHostMessageRouting(), MAX_OH_MESSAGES_HANDLED, mRouteObjectMessage, mRouteObjectMessageMutex, Sirikata::SizedThreadSafeQueue< T, ResourceMonitor, Superclass >::probablyEmpty(), and scheduleObjectHostMessageRouting().

Referenced by scheduleObjectHostMessageRouting().

void Sirikata::Server::handleSessionMessage	(	const ObjectHostConnectionID &	oh_conn_id,
		Sirikata::Protocol::Object::ObjectMessage *	msg
	)		[private]

References Sirikata::Logging::error, handleConnect(), handleConnectAck(), handleDisconnect(), handleMigrate(), LOG_INVALID_MESSAGE, mContext, mObjects, mTimeSeriesObjects, Sirikata::Trace::TimeSeries::report(), SPACE_LOG, and Sirikata::Context::timeSeries.

Referenced by onObjectHostMessageReceived().

bool Sirikata::Server::handleSingleObjectHostMessageRouting

(

)

[private]

References Sirikata::Server::ConnectionIDObjectMessagePair::conn_id, Sirikata::ODP::DelegateService::deliver(), mForwarder, mMigratingConnections, mObjectMigrations, mObjects, mObjectsAwaitingMigration, mRouteObjectMessage, Sirikata::OHDP::NodeID::null(), Sirikata::SpaceID::null(), Sirikata::UUID::null(), Sirikata::Server::ConnectionIDObjectMessagePair::obj_msg, Sirikata::SizedThreadSafeQueue< T, ResourceMonitor, Superclass >::pop(), Sirikata::Forwarder::routeObjectHostMessage(), Sirikata::ObjectHostConnectionID::shortID(), SPACE_LOG, Sirikata::UUID::toString(), and Sirikata::Logging::warn.

Referenced by handleObjectHostMessageRouting().

bool Sirikata::Server::isObjectConnected

(

const UUID &

object_id

)

const [private]

References mObjects.

Referenced by handleConnectAuthResponse(), and handleMigrate().

bool Sirikata::Server::isObjectConnecting

(

const UUID &

object_id

)

const [private]

References mStoredConnectionData.

Referenced by handleConnectAuthResponse().

void Sirikata::Server::killObjectConnection

(

const UUID &

obj_id

)

[private]

References CONTEXT_SPACETRACE, Sirikata::Timer::elapsed(), Sirikata::Logging::error, Sirikata::Forwarder::getObjectConnection(), Sirikata::SpaceContext::id(), mContext, mForwarder, mMigratingConnections, mMigrationTimer, Sirikata::Forwarder::removeObjectConnection(), SPACE_LOG, and Sirikata::UUID::toString().

Referenced by osegMigrationAcknowledged().

void Sirikata::Server::newStream	(	int	err,
		SST::Stream< SpaceObjectReference >::Ptr	s
	)		[private]

References Sirikata::SST::Stream< EndPointType >::close(), Sirikata::ObjectSessionManager::completeSession(), Sirikata::ObjectReference::getAsUUID(), mObjects, mObjectSessionManager, Sirikata::SST::Stream< EndPointType >::remoteEndPoint(), and SST_IMPL_SUCCESS.

Referenced by Server().

void Sirikata::Server::onObjectHostConnected	(	const ObjectHostConnectionID &	conn_id,
		const ShortObjectHostConnectionID	short_conn_id,
		OHDPSST::Stream::Ptr	stream
	)		[private, virtual]

Implements Sirikata::ObjectHostConnectionManager::Listener.

References Sirikata::ObjectHostSessionManager::fireObjectHostSession(), and mOHSessionManager.

void Sirikata::Server::onObjectHostDisconnected	(	const ObjectHostConnectionID &	conn_id,
		const ShortObjectHostConnectionID	short_conn_id
	)		[private, virtual]

Implements Sirikata::ObjectHostConnectionManager::Listener.

References Sirikata::ObjectHostSessionManager::fireObjectHostSessionEnded(), handleObjectHostConnectionClosed(), Sirikata::Context::mainStrand, mContext, mOHSessionManager, and Sirikata::Network::IOStrand::post().

bool Sirikata::Server::onObjectHostMessageReceived	(	const ObjectHostConnectionID &	conn_id,
		const ShortObjectHostConnectionID	short_conn_id,
		Sirikata::Protocol::Object::ObjectMessage *	obj_msg
	)		[private, virtual]

Implements Sirikata::ObjectHostConnectionManager::Listener.

References handleSessionMessage(), Sirikata::Context::mainStrand, mContext, mForwarder, mLocalForwarder, mRouteObjectMessage, mRouteObjectMessageMutex, Sirikata::UUID::null(), OBJECT_PORT_SESSION, Sirikata::Network::IOStrand::post(), Sirikata::SizedThreadSafeQueue< T, ResourceMonitor, Superclass >::probablyEmpty(), Sirikata::SizedThreadSafeQueue< T, ResourceMonitor, Superclass >::push(), scheduleObjectHostMessageRouting(), Sirikata::Trace::SPACE_DROPPED_AT_MAIN_STRAND_CROSSING, TIMESTAMP, TRACE_DROP, Sirikata::Forwarder::tryCacheForward(), and Sirikata::LocalForwarder::tryForward().

void Sirikata::Server::osegAddNewFinished	(	const UUID &	id,
		OSegAddNewStatus	status
	)		[private, virtual]

Implements Sirikata::OSegWriteListener.

References finishAddObject(), Sirikata::Context::mainStrand, mContext, and Sirikata::Network::IOStrand::post().

void Sirikata::Server::osegMigrationAcknowledged

(

const UUID &

id

)

[private, virtual]

Implements Sirikata::OSegWriteListener.

References killObjectConnection(), Sirikata::Context::mainStrand, mContext, and Sirikata::Network::IOStrand::post().

void Sirikata::Server::processAlreadyMigrating

(

const UUID &

obj_id

)

[private]

References Sirikata::LocalForwarder::addActiveConnection(), Sirikata::LocationService::addLocalObject(), Sirikata::ObjectSegmentation::addMigratedObject(), Sirikata::Forwarder::addObjectConnection(), Sirikata::ObjectSessionManager::addSession(), Sirikata::ObjectConnection::connID(), Sirikata::createObjectMessage(), Sirikata::Logging::error, Sirikata::SpaceContext::id(), mContext, mForwarder, Sirikata::Proximity::migrationClientTag(), mLocalForwarder, mLocationService, mMigratingConnections, mObjectMigrations, mObjects, mObjectsAwaitingMigration, mObjectSessionManager, mOSeg, mProximity, mTimeSeriesObjects, Sirikata::UUID::null(), OBJECT_PORT_SESSION, Sirikata::Proximity::receiveMigrationData(), Sirikata::LocalForwarder::removeActiveConnection(), Sirikata::Forwarder::removeObjectConnection(), Sirikata::Trace::TimeSeries::report(), sendSessionMessageWithRetry(), Sirikata::serializePBJMessage(), Sirikata::ObjectConnection::sessionID(), SPACE_LOG, and Sirikata::Context::timeSeries.

Referenced by handleMigration().

void Sirikata::Server::receiveMessage

(

Message *

msg

)

[virtual]

Implements Sirikata::MessageRecipient.

References Sirikata::Message::dest_port(), Sirikata::Logging::detailed, handleMigration(), mObjectMigrations, Sirikata::parsePBJMessage(), Sirikata::Message::payload(), SERVER_PORT_MIGRATION, SPACE_LOG, and Sirikata::UUID::toString().

void Sirikata::Server::scheduleObjectHostMessageRouting

(

)

[private]

References handleObjectHostMessageRouting(), Sirikata::Context::mainStrand, mContext, and Sirikata::Network::IOStrand::post().

Referenced by handleObjectHostMessageRouting(), and onObjectHostMessageReceived().

void Sirikata::Server::sendConnectError	(	const ObjectHostConnectionID &	oh_conn_id,
		const UUID &	obj_id,
		uint64	session_request_seqno
	)		[private]

References Sirikata::createObjectMessage(), Sirikata::SpaceContext::id(), mContext, Sirikata::UUID::null(), OBJECT_PORT_SESSION, sendSessionMessageWithRetry(), and Sirikata::serializePBJMessage().

Referenced by finishAddObject(), handleConnect(), and handleConnectAuthResponse().

void Sirikata::Server::sendConnectSuccess	(	const ObjectHostConnectionID &	oh_conn_id,
		const UUID &	obj_id,
		uint64	session_request_seqno
	)		[private]

References Sirikata::LocationService::bounds(), Sirikata::createObjectMessage(), Sirikata::AggregateBoundingInfo::fullBounds(), Sirikata::SpaceContext::id(), Sirikata::LocationService::location(), mContext, Sirikata::LocationService::mesh(), mLocationService, Sirikata::UUID::null(), OBJECT_PORT_SESSION, Sirikata::LocationService::orientation(), Sirikata::TimedMotionQuaternion::position(), Sirikata::TimedMotionVector< MotionVectorType >::position(), sendSessionMessageWithRetry(), Sirikata::serializePBJMessage(), Sirikata::AggregateBoundingInfo::singleObject(), Sirikata::TimedMotionQuaternion::updateTime(), Sirikata::TimedMotionVector< MotionVectorType >::updateTime(), Sirikata::TimedMotionQuaternion::velocity(), and Sirikata::TimedMotionVector< MotionVectorType >::velocity().

Referenced by finishAddObject(), and handleConnectAuthResponse().

void Sirikata::Server::sendSessionMessageWithRetry	(	const ObjectHostConnectionID &	conn,
		Sirikata::Protocol::Object::ObjectMessage *	msg,
		const Duration &	retry_rate
	)		[private]

References Sirikata::Context::mainStrand, mContext, mObjectHostConnectionManager, Sirikata::Network::IOStrand::post(), Sirikata::ObjectHostConnectionManager::send(), and Sirikata::ObjectHostConnectionManager::validConnection().

Referenced by handleConnect(), handleMigration(), handleMigrationEvent(), processAlreadyMigrating(), sendConnectError(), and sendConnectSuccess().

void Sirikata::Server::start

(

)

[private, virtual]

Implements Sirikata::Service.

References mForwarder, and Sirikata::Forwarder::start().

void Sirikata::Server::startSendMigrationMessages

(

)

[private]

References mMigrationSendRunning, and trySendMigrationMessages().

Referenced by handleMigrationEvent().

void Sirikata::Server::stop

(

)

[private, virtual]

Implements Sirikata::Service.

References mForwarder, mObjectHostConnectionManager, mShutdownRequested, Sirikata::ObjectHostConnectionManager::shutdown(), and Sirikata::Forwarder::stop().

void Sirikata::Server::trySendMigrationMessages

(

)

[private]

References Sirikata::Context::mainStrand, mContext, mMigrateMessages, mMigrateServerMessageService, mMigrationSendRunning, mShutdownRequested, Sirikata::Network::IOStrand::post(), and Sirikata::Router< MessageType >::route().

Referenced by startSendMigrationMessages().

---

Member Data Documentation

Authenticator* Sirikata::Server::mAuthenticator [private]

Referenced by handleConnect().

SpaceContext* Sirikata::Server::mContext [private]

Referenced by delegateODPPortSend(), delegateOHDPPortSend(), finishAddObject(), handleConnect(), handleMigration(), handleMigrationEvent(), handleObjectHostConnectionClosed(), handleSessionMessage(), killObjectConnection(), onObjectHostDisconnected(), onObjectHostMessageReceived(), osegAddNewFinished(), osegMigrationAcknowledged(), processAlreadyMigrating(), scheduleObjectHostMessageRouting(), sendConnectError(), sendConnectSuccess(), sendSessionMessageWithRetry(), Server(), and trySendMigrationMessages().

CoordinateSegmentation* Sirikata::Server::mCSeg [private]

Referenced by finishAddObject(), handleConnect(), handleMigrationEvent(), and Server().

Forwarder* Sirikata::Server::mForwarder [private]

Referenced by finishAddObject(), handleConnectAck(), handleDisconnect(), handleMigration(), handleMigrationEvent(), handleSingleObjectHostMessageRouting(), killObjectConnection(), onObjectHostMessageReceived(), processAlreadyMigrating(), Server(), start(), stop(), and ~Server().

LocalForwarder* Sirikata::Server::mLocalForwarder [private]

Referenced by delegateODPPortSend(), finishAddObject(), handleDisconnect(), handleMigration(), handleMigrationEvent(), onObjectHostMessageReceived(), processAlreadyMigrating(), Server(), and ~Server().

LocationService* Sirikata::Server::mLocationService [private]

Referenced by finishAddObject(), handleDisconnect(), handleMigration(), handleMigrationEvent(), processAlreadyMigrating(), sendConnectSuccess(), Server(), and ~Server().

MigrateMessageQueue Sirikata::Server::mMigrateMessages [private]

Referenced by handleMigrationEvent(), and trySendMigrationMessages().

Router<Message*>* Sirikata::Server::mMigrateServerMessageService [private]

Referenced by Server(), trySendMigrationMessages(), and ~Server().

MigConnectionsMap Sirikata::Server::mMigratingConnections [private]

Referenced by checkAlreadyMigrating(), commandObjectsCount(), handleMigrationEvent(), handleSingleObjectHostMessageRouting(), killObjectConnection(), and processAlreadyMigrating().

MigrationMonitor* Sirikata::Server::mMigrationMonitor [private]

Referenced by handleConnect(), Server(), and ~Server().

bool Sirikata::Server::mMigrationSendRunning [private]

Referenced by startSendMigrationMessages(), and trySendMigrationMessages().

Timer Sirikata::Server::mMigrationTimer [private]

Referenced by handleMigrationEvent(), killObjectConnection(), and Server().

ObjectHostConnectionManager* Sirikata::Server::mObjectHostConnectionManager [private]

Referenced by delegateOHDPPortSend(), finishAddObject(), handleMigrate(), sendSessionMessageWithRetry(), Server(), stop(), and ~Server().

ObjectMigrationMap Sirikata::Server::mObjectMigrations [private]

Referenced by commandObjectsCount(), handleMigration(), handleSingleObjectHostMessageRouting(), processAlreadyMigrating(), and receiveMessage().

ObjectConnectionMap Sirikata::Server::mObjects [private]

Referenced by commandObjectsCount(), commandObjectsDisconnect(), commandObjectsList(), finishAddObject(), handleConnectAck(), handleConnectAuthResponse(), handleDisconnect(), handleMigration(), handleMigrationEvent(), handleObjectHostConnectionClosed(), handleSessionMessage(), handleSingleObjectHostMessageRouting(), isObjectConnected(), newStream(), processAlreadyMigrating(), and ~Server().

MigrationRequestMap Sirikata::Server::mObjectsAwaitingMigration [private]

Referenced by commandObjectsCount(), handleMigrate(), handleMigration(), handleSingleObjectHostMessageRouting(), and processAlreadyMigrating().

ObjectSessionManager* Sirikata::Server::mObjectSessionManager [private]

Referenced by finishAddObject(), handleDisconnect(), handleMigration(), handleMigrationEvent(), newStream(), and processAlreadyMigrating().

ObjectHostSessionManager* Sirikata::Server::mOHSessionManager [private]

Referenced by onObjectHostConnected(), and onObjectHostDisconnected().

ObjectSegmentation* Sirikata::Server::mOSeg [private]

Referenced by handleConnectAuthResponse(), handleDisconnect(), handleMigration(), handleMigrationEvent(), processAlreadyMigrating(), and Server().

Proximity* Sirikata::Server::mProximity [private]

Referenced by finishAddObject(), handleDisconnect(), handleMigration(), handleMigrationEvent(), processAlreadyMigrating(), and ~Server().

Sirikata::SizedThreadSafeQueue<ConnectionIDObjectMessagePair> Sirikata::Server::mRouteObjectMessage [private]

Referenced by handleObjectHostMessageRouting(), handleSingleObjectHostMessageRouting(), and onObjectHostMessageReceived().

boost::mutex Sirikata::Server::mRouteObjectMessageMutex [private]

Referenced by handleObjectHostMessageRouting(), and onObjectHostMessageReceived().

bool Sirikata::Server::mShutdownRequested [private]

Referenced by stop(), and trySendMigrationMessages().

StoredConnectionMap Sirikata::Server::mStoredConnectionData [private]

Referenced by commandObjectsCount(), finishAddObject(), handleConnectAuthResponse(), and isObjectConnecting().

String Sirikata::Server::mTimeSeriesObjects [private]

Referenced by finishAddObject(), handleMigration(), handleMigrationEvent(), handleObjectHostConnectionClosed(), handleSessionMessage(), and processAlreadyMigrating().

TimeSyncServer* Sirikata::Server::mTimeSyncServer [private]

Referenced by Server(), and ~Server().

---

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

• space/src/Server.hpp
• space/src/Server.cpp