ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-04-29 15:37:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix stress_client warning and compile error

Browse Source
This commit is contained in:
Jonathan Rosser
2012-07-31 10:06:00 +01:00
parent a0040da1d7
commit 3ecec05364
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
examples/stress_client/stress_client.cpp
View File

@@ -138,8 +138,8 @@ private:
m_msg_stats.clear();
}
int m_connections_max;
int m_connections_cur;
unsigned int m_connections_max;
unsigned int m_connections_cur;
std::map<std::string,size_t> m_msg_stats;
boost::shared_ptr<boost::asio::deadline_timer> m_timer;
};
@@ -150,14 +150,16 @@ int main(int argc, char* argv[]) {
int num_connections = 100;
int batch_size = 25;
int delay_ms = 16;
if (argc != 5) {
std::cout << "Usage: `echo_client test_url num_connections batch_size delay_ms`" << std::endl;
} else {
uri = argv[1];
num_connections = atoi(argv[2]);
batch_size = atoi(argv[3]);
delay_ms = atoi(argv[4]);
if (argc > 1) {
if (argc != 5) {
std::cout << "Usage: `echo_client test_url num_connections batch_size delay_ms`" << std::endl;
} else {
uri = argv[1];
num_connections = atoi(argv[2]);
batch_size = atoi(argv[3]);
delay_ms = atoi(argv[4]);
}
}
// 12288 is max OS X limit without changing kernal settings
@@ -209,7 +211,7 @@ int main(int argc, char* argv[]) {
connections.insert(endpoint.connect(uri));
boost::thread t(boost::bind(&plain_endpoint_type::run, &endpoint));
boost::thread t(boost::bind(&plain_endpoint_type::run, &endpoint, false));
std::cout << "launching " << num_connections << " connections to " << uri << " in batches of " << batch_size << std::endl;