CMSDK
2.0.1
|
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) |