#include <AggregateManager.hpp>

Inheritance diagram for Sirikata::AggregateManager:

Collaboration diagram for Sirikata::AggregateManager:

Classes
struct	AggregateObject
struct	LocationInfo
class	LocationServiceCache
Public Member Functions
	AggregateManager (LocationService *loc, Transfer::OAuthParamsPtr oauth, const String &username, const String &local_path, const String &local_url_prefix, uint16 n_gen_threads, uint16 n_upload_threads, bool skip_gen, bool skip_upload)
	Create an AggregateManager.
	~AggregateManager ()
void	addAggregate (const UUID &uuid)
void	removeAggregate (const UUID &uuid)
void	addChild (const UUID &uuid, const UUID &child_uuid)
void	removeChild (const UUID &uuid, const UUID &child_uuid)
void	aggregateObserved (const UUID &objid, uint32 nobservers, uint32 nchildren)
void	generateAggregateMesh (const UUID &uuid, const Duration &delayFor=Duration::milliseconds(1.0f))
void	generateAggregateMesh (const UUID &uuid, AggregateObjectPtr aggObject, const Duration &delayFor=Duration::milliseconds(1.0f))
void	metadataFinished (Time t, const UUID uuid, const UUID child_uuid, std::string meshName, uint8 attemptNo, std::tr1::shared_ptr< Transfer::MetadataRequest > request, std::tr1::shared_ptr< Transfer::RemoteFileMetadata > response)
void	chunkFinished (Time t, const UUID uuid, const UUID child_uuid, std::string meshName, std::tr1::shared_ptr< Transfer::ChunkRequest > request, std::tr1::shared_ptr< const Transfer::DenseData > response)
Private Types
enum	{ MAX_NUM_GENERATION_THREADS = 16 }
enum	{ MAX_NUM_UPLOAD_THREADS = 16 }
enum	{ GEN_SUCCESS = 1, CHILDREN_NOT_YET_GEN = 2, NEWER_REQUEST = 3, MISSING_LOC_INFO = 4, MISSING_CHILD_LOC_INFO = 5, MISSING_CHILD_MESHES = 6 }
typedef struct Sirikata::AggregateManager::LocationInfo	LocationInfo
typedef std::tr1::shared_ptr < AggregateObject >	AggregateObjectPtr
typedef std::tr1::unordered_map< UUID, AggregateObjectPtr, UUID::Hasher >	AggregateObjectsMap
Private Member Functions
std::tr1::shared_ptr < LocationInfo >	getCachedLocInfo (const UUID &uuid)
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	localLocationUpdated (const UUID &uuid, bool agg, const TimedMotionVector3f &newval)
virtual void	localOrientationUpdated (const UUID &uuid, bool agg, const TimedMotionQuaternion &newval)
virtual void	localBoundsUpdated (const UUID &uuid, bool agg, const AggregateBoundingInfo &newval)
virtual void	localMeshUpdated (const UUID &uuid, bool agg, const String &newval)
virtual void	replicaObjectAdded (const UUID &uuid, const TimedMotionVector3f &loc, const TimedMotionQuaternion &orient, const AggregateBoundingInfo &bounds, const String &mesh, const String &physics, const String &zernike)
virtual void	replicaObjectRemoved (const UUID &uuid)
virtual void	replicaLocationUpdated (const UUID &uuid, const TimedMotionVector3f &newval)
virtual void	replicaOrientationUpdated (const UUID &uuid, const TimedMotionQuaternion &newval)
virtual void	replicaBoundsUpdated (const UUID &uuid, const AggregateBoundingInfo &newval)
virtual void	replicaMeshUpdated (const UUID &uuid, const String &newval)
void	addToInMemoryCache (const String &meshName, const Mesh::MeshdataPtr mdptr)
void	uploadThreadMain (uint8 i)
bool	findChild (std::vector< AggregateObjectPtr > &v, const UUID &uuid)
void	removeChild (std::vector< AggregateObjectPtr > &v, const UUID &uuid)
void	iRemoveChild (const UUID &uuid, const UUID &child_uuid)
void	getLeaves (const std::vector< UUID > &mIndividualObjects)
void	addLeavesUpTree (UUID leaf_uuid, UUID uuid)
bool	isAggregate (const UUID &uuid)
void	updateChildrenTreeLevel (const UUID &uuid, uint16 treeLevel)
void	addDirtyAggregates (UUID uuid)
void	queueDirtyAggregates (Time postTime)
void	generateMeshesFromQueue (uint8 i)
uint32	generateAggregateMeshAsync (const UUID uuid, Time postTime, bool generateSiblings=true)
void	aggregationThreadMain (uint8 i)
void	updateAggregateLocMesh (UUID uuid, String mesh)
void	uploadAggregateMesh (Mesh::MeshdataPtr agg_mesh, AggregateObjectPtr aggObject, std::tr1::unordered_map< String, String > textureSet, uint32 retryAttempt, Time uploadStartTime)
void	handleUploadFinished (Transfer::UploadRequestPtr request, const Transfer::URI &path, Mesh::MeshdataPtr agg_mesh, AggregateObjectPtr aggObject, std::tr1::unordered_map< String, String > textureSet, uint32 retryAttempt, const Time &uploadStartTime)
void	sendKeepAlives ()
void	handleKeepAliveResponse (const UUID &objid, std::tr1::shared_ptr< Transfer::HttpManager::HttpResponse > response, Transfer::HttpManager::ERR_TYPE error, const boost::system::error_code &boost_error)
bool	cleanUpChild (const UUID &parent_uuid, const UUID &child_id)
void	removeStaleLeaves ()
void	commandStats (const Command::Command &cmd, Command::Commander *cmdr, Command::CommandID cmdid)
Private Attributes
uint16	mNumGenerationThreads
Thread *	mAggregationThreads [MAX_NUM_GENERATION_THREADS]
Network::IOService *	mAggregationServices [MAX_NUM_GENERATION_THREADS]
Network::IOStrand *	mAggregationStrands [MAX_NUM_GENERATION_THREADS]
Network::IOWork *	mIOWorks [MAX_NUM_GENERATION_THREADS]
LocationServiceCache	mLocationServiceCache
boost::mutex	mLocCacheMutex
LocationService *	mLoc
boost::mutex	mModelsSystemMutex
ModelsSystem *	mModelsSystem
Sirikata::Mesh::MeshSimplifier	mMeshSimplifier
Sirikata::Mesh::Filter *	mCenteringFilter
boost::mutex	mAggregateObjectsMutex
AggregateObjectsMap	mAggregateObjects
Time	mAggregateGenerationStartTime
std::tr1::unordered_map< UUID, AggregateObjectPtr, UUID::Hasher >	mDirtyAggregateObjects
boost::mutex	mObjectsByPriorityLocks [MAX_NUM_GENERATION_THREADS]
std::map< float, std::deque < AggregateObjectPtr > >	mObjectsByPriority [MAX_NUM_GENERATION_THREADS]
boost::mutex	mMeshStoreMutex
std::tr1::unordered_map < String, Mesh::MeshdataPtr >	mMeshStore
std::tr1::shared_ptr < Transfer::TransferPool >	mTransferPool
Transfer::TransferMediator *	mTransferMediator
Transfer::OAuthParamsPtr	mOAuth
const String	mCDNUsername
Duration	mModelTTL
Poller *	mCDNKeepAlivePoller
const String	mLocalPath
const String	mLocalURLPrefix
bool	mSkipGenerate
bool	mSkipUpload
uint16	mNumUploadThreads
Thread *	mUploadThreads [MAX_NUM_UPLOAD_THREADS]
Network::IOService *	mUploadServices [MAX_NUM_UPLOAD_THREADS]
Network::IOStrand *	mUploadStrands [MAX_NUM_UPLOAD_THREADS]
Network::IOWork *	mUploadWorks [MAX_NUM_UPLOAD_THREADS]
AtomicValue< uint32 >	mRawAggregateUpdates
AtomicValue< uint32 >	mAggregatesQueued
AtomicValue< uint32 >	mAggregatesGenerated
AtomicValue< uint32 >	mAggregatesFailedToGenerate
AtomicValue< uint32 >	mAggregatesUploaded
AtomicValue< uint32 >	mAggregatesFailedToUpload
boost::mutex	mStatsMutex
Duration	mAggregateCumulativeGenerationTime
Duration	mAggregateCumulativeUploadTime
uint64	mAggregateCumulativeDataSize

Member Typedef Documentation

typedef std::tr1::shared_ptr<AggregateObject> Sirikata::AggregateManager::AggregateObjectPtr [private]

typedef std::tr1::unordered_map<UUID, AggregateObjectPtr, UUID::Hasher > Sirikata::AggregateManager::AggregateObjectsMap [private]

typedef struct Sirikata::AggregateManager::LocationInfo Sirikata::AggregateManager::LocationInfo [private]

Member Enumeration Documentation

anonymous enum [private]

Enumerator:

MAX_NUM_GENERATION_THREADS

anonymous enum [private]

Enumerator:

MAX_NUM_UPLOAD_THREADS

anonymous enum [private]

Enumerator:

GEN_SUCCESS
CHILDREN_NOT_YET_GEN
NEWER_REQUEST
MISSING_LOC_INFO
MISSING_CHILD_LOC_INFO
MISSING_CHILD_MESHES

Constructor & Destructor Documentation

Sirikata::AggregateManager::AggregateManager	(	LocationService *	loc,
		Transfer::OAuthParamsPtr	oauth,
		const String &	username,
		const String &	local_path,
		const String &	local_url_prefix,
		uint16	n_gen_threads,
		uint16	n_upload_threads,
		bool	skip_gen,
		bool	skip_upload
	)

Create an AggregateManager.

OAuth upload parameters for the CDN. If omitted, uploads will not be attempted User name for account your OAuth params let you upload to on the the CDN

Parameters:

local_path	if non-empty and OAuth values are not specified, generate local meshes that create file:/// URLs. Useful to avoid uploading to the CDN, but in distributed systems will obviously cause failures to download meshes on other nodes.
local_url_prefix	used in conjunction with local_path. If provided, specifies the URL prefix to prepend to the filename to get the full mesh URL, allowing you to publicize the meshes by using something other than a file:// URL, e.g. if you run a web server on your host.
n_gen_threads	number of threads to use for creating aggregate meshes
n_upload_threads	number of threads to use for uploading
skip_gen	if true, skip the generation phase, but pretend it was successful. Useful for testing without spending CPU on generating meshes. Forces skip_upload to be true
skip_upload	if true, skip the upload phase, but pretend it was successful. Useful for testing, but since the mesh cache is limited, this will eventually cause later aggregates to fail to be generated

References Sirikata::LocationService::addListener(), aggregationThreadMain(), Sirikata::Context::commander(), commandStats(), Sirikata::LocationService::context(), Sirikata::Network::IOService::createStrand(), Sirikata::FactoryImpl< T, Ftype >::getConstructor(), Sirikata::Transfer::TransferMediator::getSingleton(), Sirikata::ModelsSystemFactory::getSingleton(), mAggregationServices, mAggregationStrands, mAggregationThreads, mCDNKeepAlivePoller, mCenteringFilter, mIOWorks, mLoc, mModelsSystem, mNumGenerationThreads, mNumUploadThreads, mTransferMediator, mTransferPool, mUploadServices, mUploadStrands, mUploadThreads, mUploadWorks, Sirikata::Transfer::TransferMediator::registerClient(), Sirikata::Command::Commander::registerCommand(), removeStaleLeaves(), sendKeepAlives(), Sirikata::Poller::start(), and uploadThreadMain().

Sirikata::AggregateManager::~AggregateManager ( )

References Sirikata::Thread::join(), mAggregationServices, mAggregationStrands, mAggregationThreads, mCDNKeepAlivePoller, mCenteringFilter, mIOWorks, mModelsSystem, mNumGenerationThreads, mNumUploadThreads, mUploadServices, mUploadStrands, mUploadThreads, mUploadWorks, Sirikata::Network::IOService::stop(), and Sirikata::Poller::stop().

Member Function Documentation

void Sirikata::AggregateManager::addAggregate ( const UUID & uuid )

References AGG_LOG, Sirikata::Logging::detailed, mAggregateObjects, mAggregateObjectsMutex, mRawAggregateUpdates, Sirikata::UUID::null(), and Sirikata::UUID::toString().

Referenced by Sirikata::LibproxProximityBase::aggregateCreated().

void Sirikata::AggregateManager::addChild	(	const UUID &	uuid,
		const UUID &	child_uuid
	)

References addDirtyAggregates(), AGG_LOG, Sirikata::Logging::detailed, mAggregateGenerationStartTime, mAggregateObjects, mAggregateObjectsMutex, mAggregationStrands, mRawAggregateUpdates, Sirikata::Timer::now(), Sirikata::Network::IOStrand::post(), queueDirtyAggregates(), Sirikata::UUID::toString(), and updateChildrenTreeLevel().

Referenced by Sirikata::LibproxProximityBase::aggregateChildAdded().

void Sirikata::AggregateManager::addDirtyAggregates ( UUID uuid ) [private]

References mAggregateObjects, mDirtyAggregateObjects, and Sirikata::UUID::null().

Referenced by addChild(), generateAggregateMesh(), and iRemoveChild().

void Sirikata::AggregateManager::addLeavesUpTree	(	UUID	leaf_uuid,
		UUID	uuid
	)		`[private]`

References getCachedLocInfo(), mAggregateObjects, mDirtyAggregateObjects, Sirikata::UUID::null(), obj, ONE_PIXEL_SOLID_ANGLE, and TWO_PI.

Referenced by getLeaves().

void Sirikata::AggregateManager::addToInMemoryCache	(	const String &	meshName,
		const Mesh::MeshdataPtr	mdptr
	)		`[private]`

References mMeshStore, and mMeshStoreMutex.

Referenced by handleUploadFinished(), metadataFinished(), and uploadAggregateMesh().

void Sirikata::AggregateManager::aggregateObserved	(	const UUID &	objid,
		uint32	nobservers,
		uint32	nchildren
	)

References mAggregateObjects, and mAggregateObjectsMutex.

Referenced by Sirikata::LibproxProximityBase::aggregateObserved().

void Sirikata::AggregateManager::aggregationThreadMain ( uint8 i ) [private]

References mAggregationServices, and Sirikata::Network::IOService::run().

Referenced by AggregateManager().

void Sirikata::AggregateManager::chunkFinished	(	Time	t,
		const UUID	uuid,
		const UUID	child_uuid,
		std::string	meshName,
		std::tr1::shared_ptr< Transfer::ChunkRequest >	request,
		std::tr1::shared_ptr< const Transfer::DenseData >	response
	)

References Sirikata::Transfer::ResourceDownloadTask::cb, Sirikata::SelfWeakPtr< ResourceDownloadTask >::getSharedPtr(), and Sirikata::Transfer::ResourceDownloadTask::mCurrentRequest.

Referenced by metadataFinished().

bool Sirikata::AggregateManager::cleanUpChild	(	const UUID &	parent_uuid,
		const UUID &	child_id
	)		`[private]`

References mAggregateObjects.

Referenced by iRemoveChild(), and removeAggregate().

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

References Sirikata::Command::EmptyResult(), mAggregateCumulativeDataSize, mAggregateCumulativeGenerationTime, mAggregateCumulativeUploadTime, mAggregatesFailedToGenerate, mAggregatesFailedToUpload, mAggregatesGenerated, mAggregatesQueued, mAggregatesUploaded, mDirtyAggregateObjects, mNumGenerationThreads, mObjectsByPriority, mObjectsByPriorityLocks, mRawAggregateUpdates, mStatsMutex, Sirikata::AtomicValue< T >::read(), and Sirikata::Command::Commander::result().

Referenced by AggregateManager().

bool Sirikata::AggregateManager::findChild	(	std::vector< AggregateObjectPtr > &	v,
		const UUID &	uuid
	)		`[private]`

void Sirikata::AggregateManager::generateAggregateMesh	(	const UUID &	uuid,
		const Duration &	delayFor = `Duration::milliseconds(1.0f)`
	)

References mAggregateObjects, mAggregateObjectsMutex, and mRawAggregateUpdates.

Referenced by Sirikata::LibproxProximityBase::aggregateBoundsUpdated().

void Sirikata::AggregateManager::generateAggregateMesh	(	const UUID &	uuid,
		AggregateObjectPtr	aggObject,
		const Duration &	delayFor = `Duration::milliseconds(1.0f)`
	)

References addDirtyAggregates(), AGG_LOG, Sirikata::Logging::detailed, mAggregateGenerationStartTime, mAggregationStrands, mDirtyAggregateObjects, mModelsSystem, Sirikata::Timer::now(), Sirikata::Network::IOStrand::post(), and queueDirtyAggregates().

uint32 Sirikata::AggregateManager::generateAggregateMeshAsync	(	const UUID	uuid,
		Time	postTime,
		bool	generateSiblings = `true`
	)		`[private]`

References AGG_LOG, CHILDREN_NOT_YET_GEN, Sirikata::Mesh::ComputeBounds(), Sirikata::LocationService::context(), Sirikata::Transfer::URL::context(), Sirikata::Logging::detailed, Sirikata::Transfer::URI::empty(), Sirikata::Transfer::URL::empty(), GEN_SUCCESS, Sirikata::Mesh::GeometryInstance::geometryIndex, getCachedLocInfo(), Sirikata::Matrix4x4< float32 >::identity(), Sirikata::Logging::info, Sirikata::Logging::insane, isAggregate(), Sirikata::Mesh::LightInstance::lightIndex, mAggregateCumulativeGenerationTime, mAggregateGenerationStartTime, mAggregateObjects, mAggregateObjectsMutex, mAggregatesGenerated, Sirikata::Context::mainStrand, Sirikata::Mesh::GeometryInstance::materialBindingMap, metadataFinished(), MISSING_CHILD_LOC_INFO, MISSING_CHILD_MESHES, MISSING_LOC_INFO, mLoc, mMeshSimplifier, mMeshStore, mMeshStoreMutex, mNumUploadThreads, mSkipGenerate, mStatsMutex, mTransferPool, mUploadStrands, NEWER_REQUEST, Sirikata::Mesh::Meshdata::GeometryInstanceIterator::next(), Sirikata::Quaternion::normal(), Sirikata::Timer::now(), Sirikata::Time::null(), Sirikata::Mesh::GeometryInstance::parentNode, Sirikata::Network::IOStrand::post(), Sirikata::Matrix4x4< float32 >::scale(), Sirikata::Mesh::MeshSimplifier::simplify(), Sirikata::texfilename(), Sirikata::Transfer::URI::toString(), Sirikata::UUID::toString(), updateAggregateLocMesh(), uploadAggregateMesh(), url, Sirikata::Vector4< scalar >::w, Sirikata::Vector4< scalar >::x, Sirikata::Vector4< scalar >::y, and Sirikata::Vector4< scalar >::z.

Referenced by generateMeshesFromQueue().

void Sirikata::AggregateManager::generateMeshesFromQueue ( uint8 i ) [private]

References AGG_LOG, CHILDREN_NOT_YET_GEN, Sirikata::Logging::error, GEN_SUCCESS, generateAggregateMeshAsync(), mAggregatesFailedToGenerate, mAggregationStrands, mObjectsByPriority, mObjectsByPriorityLocks, Sirikata::Timer::now(), Sirikata::Time::null(), and Sirikata::Network::IOStrand::post().

Referenced by queueDirtyAggregates().

std::tr1::shared_ptr< AggregateManager::LocationInfo > Sirikata::AggregateManager::getCachedLocInfo ( const UUID & uuid ) [private]

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, and mLocCacheMutex.

Referenced by addLeavesUpTree(), generateAggregateMeshAsync(), handleUploadFinished(), and queueDirtyAggregates().

void Sirikata::AggregateManager::getLeaves ( const std::vector< UUID > & mIndividualObjects ) [private]

References addLeavesUpTree().

Referenced by queueDirtyAggregates().

void Sirikata::AggregateManager::handleKeepAliveResponse	(	const UUID &	objid,
		std::tr1::shared_ptr< Transfer::HttpManager::HttpResponse >	response,
		Transfer::HttpManager::ERR_TYPE	error,
		const boost::system::error_code &	boost_error
	)		`[private]`

References AGG_LOG, Sirikata::Transfer::HttpManager::BOOST_ERROR, Sirikata::LocationService::context(), Sirikata::Logging::detailed, mAggregateObjects, mAggregateObjectsMutex, mLoc, mModelTTL, Sirikata::Context::recentSimTime(), Sirikata::Transfer::HttpManager::REQUEST_PARSING_FAILED, Sirikata::Transfer::HttpManager::RESPONSE_PARSING_FAILED, and Sirikata::Transfer::HttpManager::SUCCESS.

Referenced by sendKeepAlives().

void Sirikata::AggregateManager::handleUploadFinished	(	Transfer::UploadRequestPtr	request,
		const Transfer::URI &	path,
		Mesh::MeshdataPtr	agg_mesh,
		AggregateObjectPtr	aggObject,
		std::tr1::unordered_map< String, String >	textureSet,
		uint32	retryAttempt,
		const Time &	uploadStartTime
	)		`[private]`

void Sirikata::AggregateManager::iRemoveChild	(	const UUID &	uuid,
		const UUID &	child_uuid
	)		`[private]`

References addDirtyAggregates(), AGG_LOG, cleanUpChild(), Sirikata::Logging::detailed, mAggregateGenerationStartTime, mAggregateObjects, mAggregationStrands, mRawAggregateUpdates, Sirikata::Timer::now(), Sirikata::Network::IOStrand::post(), queueDirtyAggregates(), and Sirikata::UUID::toString().

Referenced by removeChild().

bool Sirikata::AggregateManager::isAggregate ( const UUID & uuid ) [private]

References mAggregateObjects, and mAggregateObjectsMutex.

Referenced by generateAggregateMeshAsync().

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

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, and mLocCacheMutex.

void Sirikata::AggregateManager::localLocationUpdated	(	const UUID &	uuid,
		bool	agg,
		const TimedMotionVector3f &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, mLocCacheMutex, and Sirikata::TimedMotionVector< MotionVectorType >::position().

void Sirikata::AggregateManager::localMeshUpdated	(	const UUID &	uuid,
		bool	agg,
		const String &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, and mLocCacheMutex.

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

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::insertLocationInfo(), mLocationServiceCache, mLocCacheMutex, Sirikata::TimedMotionQuaternion::position(), and Sirikata::TimedMotionVector< MotionVectorType >::position().

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

Reimplemented from Sirikata::LocationServiceListener.

References mLocationServiceCache, mLocCacheMutex, and Sirikata::AggregateManager::LocationServiceCache::removeLocationInfo().

void Sirikata::AggregateManager::localOrientationUpdated	(	const UUID &	uuid,
		bool	agg,
		const TimedMotionQuaternion &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, mLocCacheMutex, and Sirikata::TimedMotionQuaternion::position().

void Sirikata::AggregateManager::metadataFinished	(	Time	t,
		const UUID	uuid,
		const UUID	child_uuid,
		std::string	meshName,
		uint8	attemptNo,
		std::tr1::shared_ptr< Transfer::MetadataRequest >	request,
		std::tr1::shared_ptr< Transfer::RemoteFileMetadata >	response
	)

References addToInMemoryCache(), AGG_LOG, chunkFinished(), Sirikata::Logging::detailed, Sirikata::Transfer::RemoteFileMetadata::getChunkList(), mAggregateObjects, mAggregateObjectsMutex, mTransferPool, Sirikata::Timer::now(), and Sirikata::Logging::warn.

Referenced by generateAggregateMeshAsync().

void Sirikata::AggregateManager::queueDirtyAggregates ( Time postTime ) [private]

References generateMeshesFromQueue(), getCachedLocInfo(), getLeaves(), HUMAN_FOV, mAggregateGenerationStartTime, mAggregateObjects, mAggregatesQueued, mAggregationStrands, MAX_NUM_GENERATION_THREADS, mDirtyAggregateObjects, mNumGenerationThreads, mObjectsByPriority, mObjectsByPriorityLocks, Sirikata::Network::IOStrand::post(), and TWO_PI.

Referenced by addChild(), generateAggregateMesh(), and iRemoveChild().

void Sirikata::AggregateManager::removeAggregate ( const UUID & uuid )

References AGG_LOG, cleanUpChild(), Sirikata::Logging::detailed, mAggregateObjects, mAggregateObjectsMutex, mRawAggregateUpdates, and Sirikata::UUID::toString().

Referenced by Sirikata::LibproxProximityBase::aggregateDestroyed().

void Sirikata::AggregateManager::removeChild	(	std::vector< AggregateObjectPtr > &	v,
		const UUID &	uuid
	)		`[private]`

Referenced by Sirikata::LibproxProximityBase::aggregateChildRemoved().

void Sirikata::AggregateManager::removeChild	(	const UUID &	uuid,
		const UUID &	child_uuid
	)

References iRemoveChild(), and mAggregateObjectsMutex.

void Sirikata::AggregateManager::removeStaleLeaves ( ) [private]

References mAggregateObjects, mAggregateObjectsMutex, mAggregationStrands, and Sirikata::Network::IOStrand::post().

Referenced by AggregateManager().

void Sirikata::AggregateManager::replicaBoundsUpdated	(	const UUID &	uuid,
		const AggregateBoundingInfo &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, and mLocCacheMutex.

void Sirikata::AggregateManager::replicaLocationUpdated	(	const UUID &	uuid,
		const TimedMotionVector3f &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, mLocCacheMutex, and Sirikata::TimedMotionVector< MotionVectorType >::position().

void Sirikata::AggregateManager::replicaMeshUpdated	(	const UUID &	uuid,
		const String &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, and mLocCacheMutex.

void Sirikata::AggregateManager::replicaObjectAdded	(	const UUID &	uuid,
		const TimedMotionVector3f &	loc,
		const TimedMotionQuaternion &	orient,
		const AggregateBoundingInfo &	bounds,
		const String &	mesh,
		const String &	physics,
		const String &	zernike
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::insertLocationInfo(), mLocationServiceCache, mLocCacheMutex, Sirikata::TimedMotionQuaternion::position(), and Sirikata::TimedMotionVector< MotionVectorType >::position().

void Sirikata::AggregateManager::replicaObjectRemoved ( const UUID & uuid ) [private, virtual]

Reimplemented from Sirikata::LocationServiceListener.

References mLocationServiceCache, mLocCacheMutex, and Sirikata::AggregateManager::LocationServiceCache::removeLocationInfo().

void Sirikata::AggregateManager::replicaOrientationUpdated	(	const UUID &	uuid,
		const TimedMotionQuaternion &	newval
	)		`[private, virtual]`

Reimplemented from Sirikata::LocationServiceListener.

References Sirikata::AggregateManager::LocationServiceCache::getLocationInfo(), mLocationServiceCache, mLocCacheMutex, and Sirikata::TimedMotionQuaternion::position().

void Sirikata::AggregateManager::sendKeepAlives ( ) [private]

References AGG_LOG, Sirikata::LocationService::context(), Sirikata::Logging::detailed, Sirikata::Transfer::OAuthHttpManager::get(), handleKeepAliveResponse(), mAggregateObjects, mAggregateObjectsMutex, mCDNUsername, mLoc, mModelTTL, mOAuth, Sirikata::Time::null(), and Sirikata::Context::recentSimTime().

Referenced by AggregateManager().

void Sirikata::AggregateManager::updateAggregateLocMesh	(	UUID	uuid,
		String	mesh
	)		`[private]`

References Sirikata::LocationService::contains(), mLoc, and Sirikata::LocationService::updateLocalAggregateMesh().

Referenced by generateAggregateMeshAsync(), handleUploadFinished(), and uploadAggregateMesh().

void Sirikata::AggregateManager::updateChildrenTreeLevel	(	const UUID &	uuid,
		uint16	treeLevel
	)		`[private]`

References mAggregateObjects.

Referenced by addChild().

void Sirikata::AggregateManager::uploadAggregateMesh	(	Mesh::MeshdataPtr	agg_mesh,
		AggregateObjectPtr	aggObject,
		std::tr1::unordered_map< String, String >	textureSet,
		uint32	retryAttempt,
		Time	uploadStartTime
	)		`[private]`