1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
/*
* Copyright 2009- ECMWF.
*
* This software is licensed under the terms of the Apache Licence version 2.0
* which can be obtained at http://www.apache.org/licenses/LICENSE-2.0.
* In applying this licence, ECMWF does not waive the privileges and immunities
* granted to it by virtue of its status as an intergovernmental organisation
* nor does it submit to any jurisdiction.
*/
#include <string>
#include <boost/test/unit_test.hpp>
#include "InvokeServer.hpp"
#include "SCPort.hpp"
#include "ecflow/client/ClientInvoker.hpp"
#include "ecflow/core/File.hpp"
#include "ecflow/test/scaffold/Naming.hpp"
using namespace std;
using namespace ecf;
BOOST_AUTO_TEST_SUITE(S_Client)
BOOST_AUTO_TEST_SUITE(T_ServerLoad)
BOOST_AUTO_TEST_CASE(test_server_load) {
ECF_NAME_THIS_TEST();
// Check if gnuplot is found on the path, on the RPM machines gnuplot not always installed
std::string path_to_gnuplot = File::which("gnuplot");
if (path_to_gnuplot.empty()) {
cout << "Ignoring test since GNUplot was not found on $PATH" << endl;
return;
}
// This will remove check pt and backup file before server start, to avoid the server from loading previous test
// data
InvokeServer invokeServer("Client:: ...test_server_load", SCPort::next());
BOOST_REQUIRE_MESSAGE(invokeServer.server_started(),
"Server failed to start on " << invokeServer.host() << ":" << invokeServer.port());
ClientInvoker theClient(invokeServer.host(), invokeServer.port());
// add some text in log file, need at least 4 different time-stamps for plotting
int load = 2;
for (int i = 0; i < load; i++) {
BOOST_REQUIRE_MESSAGE(theClient.delete_all() == 0,
CtsApi::to_string(CtsApi::delete_node()) << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.shutdownServer() == 0,
CtsApi::shutdownServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.haltServer() == 0,
CtsApi::haltServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.restartServer() == 0,
CtsApi::restartServer() << " should return 0\n"
<< theClient.errorMsg());
}
sleep(1); // need a time gap
for (int i = 0; i < load; i++) {
BOOST_REQUIRE_MESSAGE(theClient.delete_all() == 0,
CtsApi::to_string(CtsApi::delete_node()) << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.shutdownServer() == 0,
CtsApi::shutdownServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.haltServer() == 0,
CtsApi::haltServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.restartServer() == 0,
CtsApi::restartServer() << " should return 0\n"
<< theClient.errorMsg());
}
sleep(1); // need a time gap
for (int i = 0; i < load; i++) {
BOOST_REQUIRE_MESSAGE(theClient.delete_all() == 0,
CtsApi::to_string(CtsApi::delete_node()) << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.shutdownServer() == 0,
CtsApi::shutdownServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.haltServer() == 0,
CtsApi::haltServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.restartServer() == 0,
CtsApi::restartServer() << " should return 0\n"
<< theClient.errorMsg());
}
sleep(1); // need a time gap
for (int i = 0; i < load; i++) {
BOOST_REQUIRE_MESSAGE(theClient.delete_all() == 0,
CtsApi::to_string(CtsApi::delete_node()) << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.shutdownServer() == 0,
CtsApi::shutdownServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.haltServer() == 0,
CtsApi::haltServer() << " should return 0\n"
<< theClient.errorMsg());
BOOST_REQUIRE_MESSAGE(theClient.restartServer() == 0,
CtsApi::restartServer() << " should return 0\n"
<< theClient.errorMsg());
}
// Now generate gnuplot files.
BOOST_REQUIRE_MESSAGE(theClient.server_load() == 0,
CtsApi::server_load_arg() << " should return 0 server not started, or connection refused\n"
<< theClient.errorMsg());
// Check files were created
Host the_host(invokeServer.host());
std::string gnuplot_dat_file = the_host.prefix_host_and_port(invokeServer.port(), "gnuplot.dat");
std::string gnuplot_script_file = the_host.prefix_host_and_port(invokeServer.port(), "gnuplot.script");
std::string gnuplot_png_file = the_host.prefix_host_and_port(invokeServer.port(), "png");
BOOST_REQUIRE_MESSAGE(fs::exists(gnuplot_dat_file),
CtsApi::server_load_arg() << " failed file(" << gnuplot_dat_file << ") not generated");
BOOST_REQUIRE_MESSAGE(fs::exists(gnuplot_script_file),
CtsApi::server_load_arg() << " failed file(" << gnuplot_script_file << ") not generated");
BOOST_REQUIRE_MESSAGE(fs::exists(gnuplot_png_file),
CtsApi::server_load_arg() << " failed file(" << gnuplot_png_file << ") not generated");
BOOST_REQUIRE_MESSAGE(fs::file_size(gnuplot_dat_file) != 0,
"Expected file(" << gnuplot_dat_file << ") to have file size > 0 ");
BOOST_REQUIRE_MESSAGE(fs::file_size(gnuplot_script_file) != 0,
"Expected file(" << gnuplot_script_file << ") to have file size > 0 ");
BOOST_REQUIRE_MESSAGE(fs::file_size(gnuplot_png_file) != 0,
"Expected file(" << gnuplot_png_file << ") to have file size > 0 ");
// remove generated gnuplot files.
fs::remove(gnuplot_dat_file);
fs::remove(gnuplot_script_file);
fs::remove(gnuplot_png_file);
}
BOOST_AUTO_TEST_SUITE_END()
BOOST_AUTO_TEST_SUITE_END()
|
