|
@@ -27,6 +27,7 @@ char *cfg_OpcUa_ServerEndpoint;
|
|
using namespace std;
|
|
using namespace std;
|
|
|
|
|
|
bool stop = false; // when set to true, the client threads terminate
|
|
bool stop = false; // when set to true, the client threads terminate
|
|
|
|
+int overallRequests = 0;
|
|
|
|
|
|
void workerThread()
|
|
void workerThread()
|
|
{
|
|
{
|
|
@@ -71,12 +72,14 @@ void workerThread()
|
|
chrono::system_clock::time_point endTime = chrono::system_clock::now();
|
|
chrono::system_clock::time_point endTime = chrono::system_clock::now();
|
|
UA_Client_disconnect(client);
|
|
UA_Client_disconnect(client);
|
|
UA_Client_delete(client);
|
|
UA_Client_delete(client);
|
|
|
|
+ overallRequests += i;
|
|
|
|
|
|
cout << "Thread " << threadId << " terminating. ";
|
|
cout << "Thread " << threadId << " terminating. ";
|
|
cout << "Statistics: " << endl;
|
|
cout << "Statistics: " << endl;
|
|
cout << "\tRequests sent: " << i << endl;
|
|
cout << "\tRequests sent: " << i << endl;
|
|
cout << "\tRuntime(ms): " << (std::chrono::duration_cast<std::chrono::milliseconds>(endTime-startTime)).count() << endl;
|
|
cout << "\tRuntime(ms): " << (std::chrono::duration_cast<std::chrono::milliseconds>(endTime-startTime)).count() << endl;
|
|
- cout << "\tRequests sent per s: " << ((double)i) / (std::chrono::duration_cast<std::chrono::milliseconds>(endTime-startTime)).count() * 1000.0 << endl;}
|
|
|
|
|
|
+ cout << "\tRequests sent per s: " << ((double)i) / (std::chrono::duration_cast<std::chrono::milliseconds>(endTime-startTime)).count() * 1000.0 << endl;
|
|
|
|
+}
|
|
|
|
|
|
int main(int argc, char **argv) {
|
|
int main(int argc, char **argv) {
|
|
printf("This is the ua-stress-test\n");
|
|
printf("This is the ua-stress-test\n");
|
|
@@ -114,6 +117,7 @@ int main(int argc, char **argv) {
|
|
return EXIT_FAILURE;
|
|
return EXIT_FAILURE;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ chrono::system_clock::time_point startTime = chrono::system_clock::now();
|
|
// start a thread for each connection
|
|
// start a thread for each connection
|
|
list<thread> threadList;
|
|
list<thread> threadList;
|
|
for (int i = 0; i < cfg_NumberOfConnections; i++) { // loop repeats every intervalUs microseconds
|
|
for (int i = 0; i < cfg_NumberOfConnections; i++) { // loop repeats every intervalUs microseconds
|
|
@@ -130,6 +134,13 @@ int main(int argc, char **argv) {
|
|
for (it = threadList.begin(); it != threadList.end(); ++it){
|
|
for (it = threadList.begin(); it != threadList.end(); ++it){
|
|
it->join();
|
|
it->join();
|
|
}
|
|
}
|
|
|
|
+ chrono::system_clock::time_point endTime = chrono::system_clock::now();
|
|
|
|
+
|
|
|
|
+ cout << "Overall Statistics: " << endl;
|
|
|
|
+ cout << "\tRequests sent: " << overallRequests << endl;
|
|
|
|
+ cout << "\tRuntime(ms): " << (std::chrono::duration_cast<std::chrono::milliseconds>(endTime-startTime)).count() << endl;
|
|
|
|
+ cout << "\tRequests sent per s: " << ((double)overallRequests) / (std::chrono::duration_cast<std::chrono::milliseconds>(endTime-startTime)).count() * 1000.0 << endl;
|
|
|
|
+
|
|
|
|
|
|
return EXIT_SUCCESS;
|
|
return EXIT_SUCCESS;
|
|
}
|
|
}
|