Inheritance diagram for cmlabs::TestRequestExecutor:

Public Member Functions
	TestRequestExecutor (uint32 id)

Public Member Functions inherited from cmlabs::RequestExecutor
	RequestExecutor (uint32 id=0, const char *name=NULL)

bool	shutdownNetwork ()

bool	addLongRequestName (const char *name)

bool	addGateway (uint32 id, std::string addr, uint16 port, uint8 encryption=NOENC)

bool	setLongRequestLimit (uint32 limit)

bool	receiveNetworkEvent (NetworkEvent evt, NetworkChannel channel, uint64 conid)

bool	receiveMessage (DataMessage msg, NetworkChannel channel, uint64 conid)

bool	receiveHTTPRequest (HTTPRequest req, NetworkChannel channel, uint64 conid)

DataMessage *	waitForLongRequest (uint32 timeoutMS)

DataMessage *	waitForShortRequest (uint32 timeoutMS)

bool	replyToQuery (DataMessage *msg)

Public Member Functions inherited from cmlabs::Runnable
virtual bool	stop (uint32 timeout=200)

Public Member Functions inherited from cmlabs::NetworkReceiver
virtual bool	receiveTelnetLine (TelnetLine line, NetworkChannel channel, uint64 conid)

virtual bool	receiveHTTPReply (HTTPReply reply, HTTPRequest req, NetworkChannel *channel, uint64 conid)

Protected Member Functions
bool	shortRequestRun ()

bool	longRequestRun ()

Protected Member Functions inherited from cmlabs::RequestExecutor
bool	run ()

uint32	sendStatusNow ()

bool	sendMessageToGateway (DataMessage *msg, RequestGatewayConnection &con)

bool	replyToGateway (DataMessage *msg)

Protected Attributes
uint32	id

Protected Attributes inherited from cmlabs::RequestExecutor
std::list< RequestGatewayConnection >	connections

uint32	executorID

std::string	executorName

NetworkManager *	manager

NetworkChannel *	channel

utils::WaitQueuePointer< DataMessage * >	shortExecQ

utils::WaitQueuePointer< DataMessage * >	longExecQ

utils::WaitQueuePointer< DataMessage * >	replyQ

std::map< uint64, RequestReply * >	requestMap

std::vector< std::string >	longReqNames

utils::Mutex	mutex

utils::Mutex	conMutex

utils::Semaphore	shortExecQSemaphore

utils::Semaphore	longExecQSemaphore

uint32	threadID

uint64	lastRefID

uint64	repliedCount

uint64	sentCount

uint64	shortReceivedCount

uint64	longReceivedCount

int32	heartbeatIntervalMS

uint64	lastHeartbeat

uint32	longReqLimit

Protected Attributes inherited from cmlabs::Runnable
uint32	threadID

bool	shouldContinue

bool	isRunning

Friends
THREAD_RET THREAD_FUNCTION_CALL	ShortExecutorRun (THREAD_ARG arg)

THREAD_RET THREAD_FUNCTION_CALL	LongExecutorRun (THREAD_ARG arg)

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

Public Member Functions

Protected Member Functions