Sirikata::AsyncCraqSet Class Reference

#include <asyncCraqSet.hpp>

Inheritance diagram for Sirikata::AsyncCraqSet:

Collaboration diagram for Sirikata::AsyncCraqSet:

List of all members.

Public Member Functions
	AsyncCraqSet (SpaceContext *con, Network::IOStrand *strand_this_runs_on, Network::IOStrand *strand_to_post_results_to, CraqObjectSegmentation *parent_oseg_called)
	~AsyncCraqSet ()
void	initialize (std::vector< CraqInitializeArgs >)
void	set (CraqDataSetGet cdSet, uint64 tracking_number=0)
int	queueSize ()
int	numStillProcessing ()
virtual void	erroredGetValue (CraqOperationResult *cor)
virtual void	erroredSetValue (CraqOperationResult *cor)
virtual void	stop ()
Private Member Functions
void	reInitializeNode (int s)
bool	checkConnections (int s)
	return false if the connection is not indeed ready
void	readyStateChanged (int s)
void	pushQueue (const CraqDataSetGet &dataToSet)
Private Attributes
std::vector< CraqInitializeArgs >	mIpAddPort
std::vector< AsyncConnectionSet * >	mConnections
std::vector< Network::IOStrand * >	mConnectionsStrands
bool	connected
std::queue< CraqDataSetGet >	mQueue
std::vector< int >	mReadyConnections
SpaceContext *	ctx
Network::IOStrand *	mStrand
Network::IOStrand *	mResultsStrand
CraqObjectSegmentation *	mOSeg

---

Constructor & Destructor Documentation

Sirikata::AsyncCraqSet::AsyncCraqSet	(	SpaceContext *	con,
		Network::IOStrand *	strand_this_runs_on,
		Network::IOStrand *	strand_to_post_results_to,
		CraqObjectSegmentation *	parent_oseg_called
	)

Sirikata::AsyncCraqSet::~AsyncCraqSet

(

)

References mConnections, and mConnectionsStrands.

---

Member Function Documentation

bool Sirikata::AsyncCraqSet::checkConnections

(

int

s

)

[private]

return false if the connection is not indeed ready

References Sirikata::CraqObjectID::cdk, Sirikata::CRAQ_DATA_KEY_SIZE, Sirikata::CraqDataSetGet::dataKey, Sirikata::CraqDataSetGet::dataKeyValue, Sirikata::CraqDataSetGet::GET, mConnections, mConnectionsStrands, Sirikata::CraqDataSetGet::messageType, mQueue, Sirikata::AsyncConnectionSet::NEED_NEW_SOCKET, Sirikata::AsyncConnectionSet::READY, reInitializeNode(), Sirikata::CraqDataSetGet::SET, Sirikata::AsyncConnectionSet::setBound(), Sirikata::CraqDataSetGet::trackingID, and Sirikata::CraqDataSetGet::trackMessage.

Referenced by pushQueue(), readyStateChanged(), and set().

void Sirikata::AsyncCraqSet::erroredGetValue

(

CraqOperationResult *

cor

)

[virtual]

Implements Sirikata::AsyncCraqScheduler.

void Sirikata::AsyncCraqSet::erroredSetValue

(

CraqOperationResult *

cor

)

[virtual]

Implements Sirikata::AsyncCraqScheduler.

References Sirikata::CraqOperationResult::GET, Sirikata::CraqOperationResult::objID, pushQueue(), Sirikata::CraqOperationResult::servID, Sirikata::CraqDataSetGet::SET, Sirikata::CraqOperationResult::tracking, and Sirikata::CraqOperationResult::whichOperation.

void Sirikata::AsyncCraqSet::initialize

(

std::vector< CraqInitializeArgs >

ipAddPort

)

References Sirikata::Network::IOService::createStrand(), ctx, Sirikata::AsyncConnectionSet::initialize(), Sirikata::Context::ioService, mConnections, mConnectionsStrands, mIpAddPort, mOSeg, mResultsStrand, mStrand, readyStateChanged(), and Sirikata::STREAM_CRAQ_NUM_CONNECTIONS_SET.

Referenced by Sirikata::AsyncCraqHybrid::initialize().

int Sirikata::AsyncCraqSet::numStillProcessing

(

)

References mConnections.

Referenced by Sirikata::AsyncCraqHybrid::numStillProcessing().

void Sirikata::AsyncCraqSet::pushQueue

(

const CraqDataSetGet &

dataToSet

)

[private]

References checkConnections(), mQueue, and mReadyConnections.

Referenced by erroredSetValue(), and set().

int Sirikata::AsyncCraqSet::queueSize

(

)

References mQueue.

Referenced by Sirikata::AsyncCraqHybrid::queueSize().

void Sirikata::AsyncCraqSet::readyStateChanged

(

int

s

)

[private]

References checkConnections(), mQueue, and mReadyConnections.

Referenced by initialize().

void Sirikata::AsyncCraqSet::reInitializeNode

(

int

s

)

[private]

References ctx, Sirikata::AsyncConnectionSet::initialize(), Sirikata::Context::ioService, mConnections, mConnectionsStrands, mIpAddPort, and Sirikata::STREAM_CRAQ_NUM_CONNECTIONS_SET.

Referenced by checkConnections().

void Sirikata::AsyncCraqSet::set	(	CraqDataSetGet	cdSet,
		uint64	tracking_number = 0
	)

References checkConnections(), CRAQ_MAX_PUSH_SET, Sirikata::CraqDataSetGet::messageType, mQueue, pushQueue(), Sirikata::CraqDataSetGet::SET, Sirikata::STREAM_CRAQ_NUM_CONNECTIONS_SET, Sirikata::CraqDataSetGet::trackingID, and Sirikata::CraqDataSetGet::trackMessage.

Referenced by Sirikata::AsyncCraqHybrid::set().

void Sirikata::AsyncCraqSet::stop

(

)

[virtual]

References mConnections, mConnectionsStrands, and Sirikata::AsyncConnectionSet::stop().

---

Member Data Documentation

bool Sirikata::AsyncCraqSet::connected [private]

SpaceContext* Sirikata::AsyncCraqSet::ctx [private]

Referenced by initialize(), and reInitializeNode().

std::vector<AsyncConnectionSet*> Sirikata::AsyncCraqSet::mConnections [private]

Referenced by checkConnections(), initialize(), numStillProcessing(), reInitializeNode(), stop(), and ~AsyncCraqSet().

std::vector<Network::IOStrand*> Sirikata::AsyncCraqSet::mConnectionsStrands [private]

Referenced by checkConnections(), initialize(), reInitializeNode(), stop(), and ~AsyncCraqSet().

std::vector<CraqInitializeArgs> Sirikata::AsyncCraqSet::mIpAddPort [private]

Referenced by initialize(), and reInitializeNode().

CraqObjectSegmentation* Sirikata::AsyncCraqSet::mOSeg [private]

Referenced by initialize().

std::queue<CraqDataSetGet> Sirikata::AsyncCraqSet::mQueue [private]

Referenced by checkConnections(), pushQueue(), queueSize(), readyStateChanged(), and set().

std::vector<int> Sirikata::AsyncCraqSet::mReadyConnections [private]

Referenced by pushQueue(), and readyStateChanged().

Network::IOStrand* Sirikata::AsyncCraqSet::mResultsStrand [private]

Referenced by initialize().

Network::IOStrand* Sirikata::AsyncCraqSet::mStrand [private]

Referenced by initialize().

---

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

• libspace/plugins/craq/craq_hybrid/craq_sets/asyncCraqSet.hpp
• libspace/plugins/craq/craq_hybrid/craq_sets/asyncCraqSet.cpp