Sirikata::AsyncCraq Class Reference

#include <asyncCraq.hpp>

Collaboration diagram for Sirikata::AsyncCraq:

List of all members.

Public Types
enum	AsyncCraqReqStatus { REQUEST_PROCESSED, REQUEST_NOT_PROCESSED }
Public Member Functions
	AsyncCraq (SpaceContext *spc, Network::IOStrand *)
	~AsyncCraq ()
void	initialize (std::vector< CraqInitializeArgs >)
int	set (const CraqDataSetGet &cdSet)
int	get (const CraqDataSetGet &cdGet)
void	runTestOfConnection ()
void	runTestOfAllConnections ()
void	tick (std::vector< CraqOperationResult * > &getResults, std::vector< CraqOperationResult * > &trackedSetResults)
int	queueSize ()
Public Attributes
Network::IOService *	io_service
Private Member Functions
void	processGetResults (std::vector< CraqOperationResult * > &getRes)
void	processErrorResults (std::vector< CraqOperationResult * > &errorRes)
void	processTrackedSetResults (std::vector< CraqOperationResult * > &trackedSetRes)
void	reInitializeNode (int s)
void	checkConnections (int s)
Private Attributes
std::vector< CraqInitializeArgs >	mIpAddPort
std::vector< AsyncConnection * >	mConnections
int	mCurrentTrackNum
SpaceContext *	ctx
bool	connected
CraqDataResponseBuffer	mReadData
CraqDataGetResp	mReadSomeData
std::queue< CraqDataSetGet * >	mQueue
Timer	mTimer
SpaceContext *	mContext
Network::IOStrand *	mStrand

---

Member Enumeration Documentation

enum Sirikata::AsyncCraq::AsyncCraqReqStatus

Enumerator:

REQUEST_PROCESSED
REQUEST_NOT_PROCESSED

---

Constructor & Destructor Documentation

Sirikata::AsyncCraq::AsyncCraq	(	SpaceContext *	spc,
		Network::IOStrand *	str
	)

References io_service, mContext, mStrand, mTimer, and Sirikata::Timer::start().

Sirikata::AsyncCraq::~AsyncCraq

(

)

References io_service.

---

Member Function Documentation

void Sirikata::AsyncCraq::checkConnections

(

int

s

)

[private]

References Sirikata::CraqDataSetGet::dataKey, Sirikata::CraqDataSetGet::dataKeyValue, Sirikata::CraqDataSetGet::GET, mConnections, Sirikata::CraqDataSetGet::messageType, mQueue, Sirikata::AsyncConnection::NEED_NEW_SOCKET, Sirikata::AsyncConnection::READY, reInitializeNode(), Sirikata::CraqDataSetGet::SET, Sirikata::CraqDataSetGet::trackingID, and Sirikata::CraqDataSetGet::trackMessage.

Referenced by tick().

int Sirikata::AsyncCraq::get

(

const CraqDataSetGet &

cdGet

)

References Sirikata::CraqDataSetGet::dataKey, Sirikata::CraqDataSetGet::dataKeyValue, Sirikata::CraqDataSetGet::GET, mQueue, and Sirikata::CraqDataSetGet::trackMessage.

void Sirikata::AsyncCraq::initialize

(

std::vector< CraqInitializeArgs >

ipAddPort

)

References Sirikata::CRAQ_NUM_CONNECTIONS, ctx, io_service, mConnections, mCurrentTrackNum, mIpAddPort, and mStrand.

void Sirikata::AsyncCraq::processErrorResults

(

std::vector< CraqOperationResult * > &

errorRes

)

[private]

References Sirikata::CraqDataSetGet::GET, Sirikata::CraqOperationResult::GET, mQueue, and Sirikata::CraqDataSetGet::SET.

Referenced by tick().

void Sirikata::AsyncCraq::processGetResults

(

std::vector< CraqOperationResult * > &

getRes

)

[private]

void Sirikata::AsyncCraq::processTrackedSetResults

(

std::vector< CraqOperationResult * > &

trackedSetRes

)

[private]

int Sirikata::AsyncCraq::queueSize

(

)

References mQueue.

void Sirikata::AsyncCraq::reInitializeNode

(

int

s

)

[private]

References Sirikata::CRAQ_NUM_CONNECTIONS, ctx, io_service, mConnections, mIpAddPort, and mStrand.

Referenced by checkConnections().

void Sirikata::AsyncCraq::runTestOfAllConnections

(

)

void Sirikata::AsyncCraq::runTestOfConnection

(

)

int Sirikata::AsyncCraq::set

(

const CraqDataSetGet &

cdSet

)

References Sirikata::CraqDataSetGet::dataKey, Sirikata::CraqDataSetGet::dataKeyValue, mCurrentTrackNum, Sirikata::CraqDataSetGet::messageType, mQueue, Sirikata::CraqDataSetGet::SET, Sirikata::CraqDataSetGet::trackingID, and Sirikata::CraqDataSetGet::trackMessage.

void Sirikata::AsyncCraq::tick	(	std::vector< CraqOperationResult * > &	getResults,
		std::vector< CraqOperationResult * > &	trackedSetResults
	)

References checkConnections(), Sirikata::Timer::elapsed(), io_service, mConnections, mTimer, Sirikata::Network::IOService::poll(), processErrorResults(), and Sirikata::Network::IOService::reset().

---

Member Data Documentation

bool Sirikata::AsyncCraq::connected [private]

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

Referenced by initialize(), and reInitializeNode().

Network::IOService* Sirikata::AsyncCraq::io_service

Referenced by AsyncCraq(), initialize(), reInitializeNode(), tick(), and ~AsyncCraq().

std::vector<AsyncConnection*> Sirikata::AsyncCraq::mConnections [private]

Referenced by checkConnections(), initialize(), reInitializeNode(), and tick().

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

Referenced by AsyncCraq().

int Sirikata::AsyncCraq::mCurrentTrackNum [private]

Referenced by initialize(), and set().

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

Referenced by initialize(), and reInitializeNode().

std::queue<CraqDataSetGet*> Sirikata::AsyncCraq::mQueue [private]

Referenced by checkConnections(), get(), processErrorResults(), queueSize(), and set().

CraqDataResponseBuffer Sirikata::AsyncCraq::mReadData [private]

CraqDataGetResp Sirikata::AsyncCraq::mReadSomeData [private]

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

Referenced by AsyncCraq(), initialize(), and reInitializeNode().

Timer Sirikata::AsyncCraq::mTimer [private]

Referenced by AsyncCraq(), and tick().

---

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

• libspace/plugins/craq/craq_oseg/asyncCraq.hpp
• libspace/plugins/craq/craq_oseg/asyncCraq.cpp