Sirikata::AsyncCraqGet Class Reference

#include <asyncCraqGet.hpp>

Inheritance diagram for Sirikata::AsyncCraqGet:

Collaboration diagram for Sirikata::AsyncCraqGet:

List of all members.

Classes
struct	QueueValue
Public Member Functions
	AsyncCraqGet (SpaceContext *con, Network::IOStrand *strand_this_runs_on, Network::IOStrand *strand_to_post_results_to, CraqObjectSegmentation *parent_oseg_called)
	~AsyncCraqGet ()
int	runReQuery ()
void	initialize (std::vector< CraqInitializeArgs >)
virtual void	erroredGetValue (CraqOperationResult *cor)
virtual void	erroredSetValue (CraqOperationResult *cor)
void	get (const CraqDataSetGet &cdGet, OSegLookupTraceToken *traceToken)
int	queueSize ()
int	numStillProcessing ()
int	getRespCount ()
virtual void	stop ()
Private Member Functions
void	straightPoll ()
void	reInitializeNode (int s)
void	readyStateChanged (int s)
bool	checkConnections (int s)
void	pushQueue (QueueValue *qv)
Private Attributes
std::vector< CraqInitializeArgs >	mIpAddPort
std::vector< AsyncConnectionGet * >	mConnections
std::vector< Network::IOStrand * >	mConnectionsStrands
std::queue< QueueValue * >	mQueue
std::vector< int >	mReadyConnections
SpaceContext *	ctx
Network::IOStrand *	mStrand
Network::IOStrand *	mResultsStrand
CraqObjectSegmentation *	mOSeg

---

Constructor & Destructor Documentation

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

Sirikata::AsyncCraqGet::~AsyncCraqGet

(

)

References mConnections, and mConnectionsStrands.

---

Member Function Documentation

bool Sirikata::AsyncCraqGet::checkConnections

(

int

s

)

[private]

References Sirikata::CraqObjectID::cdk, Sirikata::AsyncCraqGet::QueueValue::cdQuery, Sirikata::CRAQ_DATA_KEY_SIZE, Sirikata::CraqDataSetGet::dataKey, Sirikata::CraqDataSetGet::GET, Sirikata::AsyncConnectionGet::getBound(), mConnections, mConnectionsStrands, Sirikata::CraqDataSetGet::messageType, mQueue, Sirikata::AsyncConnectionGet::NEED_NEW_SOCKET, Sirikata::OSegLookupTraceToken::OSEG_TRACE_GET_MANAGER_DEQUEUED, Sirikata::AsyncConnectionGet::READY, reInitializeNode(), Sirikata::CraqDataSetGet::SET, Sirikata::OSegLookupTraceToken::stamp(), and Sirikata::AsyncCraqGet::QueueValue::traceToken.

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

void Sirikata::AsyncCraqGet::erroredGetValue

(

CraqOperationResult *

cor

)

[virtual]

Implements Sirikata::AsyncCraqScheduler.

References Sirikata::AsyncCraqGet::QueueValue::cdQuery, Sirikata::CraqDataSetGet::GET, Sirikata::CraqOperationResult::GET, Sirikata::CraqOperationResult::objID, pushQueue(), Sirikata::CraqOperationResult::servID, Sirikata::CraqOperationResult::traceToken, Sirikata::AsyncCraqGet::QueueValue::traceToken, Sirikata::CraqOperationResult::tracking, and Sirikata::CraqOperationResult::whichOperation.

void Sirikata::AsyncCraqGet::erroredSetValue

(

CraqOperationResult *

cor

)

[virtual]

Implements Sirikata::AsyncCraqScheduler.

void Sirikata::AsyncCraqGet::get	(	const CraqDataSetGet &	cdGet,
		OSegLookupTraceToken *	traceToken
	)

References Sirikata::AsyncCraqGet::QueueValue::cdQuery, checkConnections(), CRAQ_MAX_PUSH_GET, Sirikata::CraqDataSetGet::dataKey, Sirikata::CraqDataSetGet::dataKeyValue, Sirikata::CraqDataSetGet::GET, mQueue, Sirikata::OSegLookupTraceToken::OSEG_TRACE_GET_MANAGER_ENQUEUE_BEGIN, Sirikata::OSegLookupTraceToken::OSEG_TRACE_GET_MANAGER_ENQUEUE_END, pushQueue(), Sirikata::OSegLookupTraceToken::stamp(), Sirikata::STREAM_CRAQ_NUM_CONNECTIONS_GET, Sirikata::AsyncCraqGet::QueueValue::traceToken, and Sirikata::CraqDataSetGet::trackMessage.

Referenced by Sirikata::AsyncCraqHybrid::get(), Sirikata::runMultiUnLoad(), Sirikata::runMultiUnLoadSpeed(), and Sirikata::runUnLoad().

int Sirikata::AsyncCraqGet::getRespCount

(

)

References mConnections.

Referenced by Sirikata::runMultiUnLoad(), and Sirikata::runMultiUnLoadSpeedMulti().

void Sirikata::AsyncCraqGet::initialize

(

std::vector< CraqInitializeArgs >

ipAddPort

)

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

Referenced by Sirikata::AsyncCraqHybrid::initialize(), Sirikata::runLoad(), Sirikata::runMultiUnLoad(), Sirikata::runMultiUnLoadSpeed(), Sirikata::runMultiUnLoadSpeedMulti(), and Sirikata::runUnLoad().

int Sirikata::AsyncCraqGet::numStillProcessing

(

)

References mConnections.

Referenced by Sirikata::AsyncCraqHybrid::numStillProcessing(), Sirikata::runLoad(), Sirikata::runMultiUnLoad(), Sirikata::runMultiUnLoadSpeed(), and Sirikata::runMultiUnLoadSpeedMulti().

void Sirikata::AsyncCraqGet::pushQueue

(

QueueValue *

qv

)

[private]

References checkConnections(), mQueue, and mReadyConnections.

Referenced by erroredGetValue(), and get().

int Sirikata::AsyncCraqGet::queueSize

(

)

References mQueue.

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

void Sirikata::AsyncCraqGet::readyStateChanged

(

int

s

)

[private]

References checkConnections(), mQueue, and mReadyConnections.

Referenced by initialize().

void Sirikata::AsyncCraqGet::reInitializeNode

(

int

s

)

[private]

References ctx, Sirikata::AsyncConnectionGet::initialize(), Sirikata::Context::ioService, mConnections, mConnectionsStrands, mIpAddPort, and Sirikata::STREAM_CRAQ_NUM_CONNECTIONS_GET.

Referenced by checkConnections().

int Sirikata::AsyncCraqGet::runReQuery

(

)

References mConnections, and Sirikata::AsyncConnectionGet::READY.

void Sirikata::AsyncCraqGet::stop

(

)

[virtual]

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

void Sirikata::AsyncCraqGet::straightPoll

(

)

[private]

---

Member Data Documentation

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

Referenced by initialize(), and reInitializeNode().

std::vector<AsyncConnectionGet*> Sirikata::AsyncCraqGet::mConnections [private]

Referenced by checkConnections(), getRespCount(), initialize(), numStillProcessing(), reInitializeNode(), runReQuery(), stop(), and ~AsyncCraqGet().

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

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

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

Referenced by initialize(), and reInitializeNode().

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

Referenced by initialize().

std::queue<QueueValue*> Sirikata::AsyncCraqGet::mQueue [private]

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

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

Referenced by pushQueue(), and readyStateChanged().

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

Referenced by initialize().

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

Referenced by initialize().

---

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

• libspace/plugins/craq/craq_hybrid/craq_gets/asyncCraqGet.hpp
• libspace/plugins/craq/craq_hybrid/craq_gets/asyncCraqGet.cpp