|
CMSDK 2.0.1
Cross-platform C++ base library and SDK for the Psyclone AIOS platform
|
Load-test client driving a RequestGateway over WebSocket connections. More...
#include <RequestClient.h>
Public Member Functions | |
| TestWebSocketRequestClient (uint32 id) | |
| bool | init (uint16 port, uint32 gatewayCount, double sendfreq, int32 reconnectMS, uint32 payload, const char *longTestName) |
| bool | finishUp () |
| bool | isStillRunning () |
Protected Member Functions | |
| bool | run () |
Protected Attributes | |
| uint32 | id |
| uint16 | port |
| uint32 | gatewayCount |
| double | sendfreq |
| int32 | reconnectMS |
| uint32 | payload |
| std::string | longTestName |
| bool | shouldContinue |
| bool | shouldFinishUp |
| bool | isRunning |
Friends | |
| THREAD_RET THREAD_FUNCTION_CALL | TestWebSocketRequestClientRun (THREAD_ARG arg) |
Load-test client driving a RequestGateway over WebSocket connections.
Definition at line 557 of file RequestClient.h.
| cmlabs::TestWebSocketRequestClient::TestWebSocketRequestClient | ( | uint32 | id | ) |
Definition at line 1273 of file RequestClient.cpp.
References gatewayCount, isRunning, payload, port, reconnectMS, sendfreq, shouldContinue, and shouldFinishUp.
Referenced by TestWebSocketRequestClientRun.
| bool cmlabs::TestWebSocketRequestClient::finishUp | ( | ) |
Definition at line 1299 of file RequestClient.cpp.
References LOG_SYSTEM, LogPrint, and shouldFinishUp.
| bool cmlabs::TestWebSocketRequestClient::init | ( | uint16 | port, |
| uint32 | gatewayCount, | ||
| double | sendfreq, | ||
| int32 | reconnectMS, | ||
| uint32 | payload, | ||
| const char * | longTestName ) |
Definition at line 1285 of file RequestClient.cpp.
References cmlabs::ThreadManager::CreateThread(), gatewayCount, longTestName, payload, port, reconnectMS, sendfreq, and TestWebSocketRequestClientRun.
Referenced by cmlabs::RequestGateway::UnitTest().
|
inline |
Definition at line 563 of file RequestClient.h.
References isRunning.
|
protected |
Definition at line 1305 of file RequestClient.cpp.
References cmlabs::JSONM::addData(), cmlabs::WebsocketData::BINARY, cmlabs::NetworkChannel::createWebsocketConnection(), cmlabs::NetworkManager::createWebsocketConnection(), cmlabs::WebsocketData::data, cmlabs::NetworkChannel::endConnection(), cmlabs::WebsocketData::getPayloadSize(), cmlabs::JSONM::getSize(), cmlabs::GetTimeAgeMS(), cmlabs::GetTimeNow(), isRunning, cmlabs::JSONM::isValid(), cmlabs::JSONM::jmData, LOG_SYSTEM, LogPrint, NOENC, payload, port, sendfreq, cmlabs::NetworkChannel::sendWebsocketData(), cmlabs::WebsocketData::setData(), cmlabs::JSONM::setJSON(), shouldContinue, shouldFinishUp, cmlabs::utils::Sleep(), cmlabs::utils::StringFormat(), and cmlabs::NetworkChannel::waitForWebsocketData().
Referenced by TestWebSocketRequestClientRun.
|
friend |
Definition at line 1416 of file RequestClient.cpp.
References run(), TestWebSocketRequestClient(), THREAD_ARG, THREAD_FUNCTION_CALL, THREAD_RET, and thread_ret_val.
Referenced by init().
|
protected |
Definition at line 569 of file RequestClient.h.
Referenced by init(), and TestWebSocketRequestClient().
|
protected |
Definition at line 567 of file RequestClient.h.
|
protected |
Definition at line 576 of file RequestClient.h.
Referenced by isStillRunning(), run(), and TestWebSocketRequestClient().
|
protected |
Definition at line 573 of file RequestClient.h.
Referenced by init().
|
protected |
Definition at line 572 of file RequestClient.h.
Referenced by init(), run(), and TestWebSocketRequestClient().
|
protected |
Definition at line 568 of file RequestClient.h.
Referenced by init(), run(), and TestWebSocketRequestClient().
|
protected |
Definition at line 571 of file RequestClient.h.
Referenced by init(), and TestWebSocketRequestClient().
|
protected |
Definition at line 570 of file RequestClient.h.
Referenced by init(), run(), and TestWebSocketRequestClient().
|
protected |
Definition at line 574 of file RequestClient.h.
Referenced by run(), and TestWebSocketRequestClient().
|
protected |
Definition at line 575 of file RequestClient.h.
Referenced by finishUp(), run(), and TestWebSocketRequestClient().