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

tabs to spaces

Browse Source
This commit is contained in:
Peter Thorson
2013-04-23 12:35:05 -05:00
parent f51960e8ff
commit 72b3def6d6
1 changed files with 85 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files

170
examples/telemetry_client/telemetry_client.cpp
View File

@@ -8,11 +8,11 @@
class telemetry_client {
public:
typedef websocketpp::client<websocketpp::config::asio_client> client;
typedef websocketpp::lib::lock_guard<websocketpp::lib::mutex> scoped_lock;
telemetry_client() : m_open(false),m_done(false) {
// set up access channels to only log interesting things
typedef websocketpp::client<websocketpp::config::asio_client> client;
typedef websocketpp::lib::lock_guard<websocketpp::lib::mutex> scoped_lock;
telemetry_client() : m_open(false),m_done(false) {
// set up access channels to only log interesting things
m_client.clear_access_channels(websocketpp::log::alevel::all);
m_client.set_access_channels(websocketpp::log::alevel::connect);
m_client.set_access_channels(websocketpp::log::alevel::disconnect);
@@ -21,13 +21,13 @@ public:
m_client.init_asio();
using websocketpp::lib::placeholders::_1;
using websocketpp::lib::bind;
using websocketpp::lib::bind;
m_client.set_open_handler(bind(&telemetry_client::on_open,this,::_1));
m_client.set_close_handler(bind(&telemetry_client::on_close,this,::_1));
}
void connect(const std::string & uri) {
websocketpp::lib::error_code ec;
}
void connect(const std::string & uri) {
websocketpp::lib::error_code ec;
client::connection_ptr con = m_client.get_connection(uri, ec);
// Grab a handle for this connection so we can talk to it in a thread
@@ -36,10 +36,10 @@ public:
// Queue the connection
m_client.connect(con);
}
void run() {
// Create a thread to run the ASIO io_service event loop
}
void run() {
// Create a thread to run the ASIO io_service event loop
websocketpp::lib::thread asio_thread(&client::run, &m_client);
// Create a thread to run the telemetry loop
@@ -47,80 +47,80 @@ public:
asio_thread.join();
telemetry_thread.join();
}
void on_open(websocketpp::connection_hdl hdl) {
m_client.get_alog().write(websocketpp::log::alevel::app,
"Connection opened, starting telemetry!");
scoped_lock guard(m_lock);
m_open = true;
}
void on_close(websocketpp::connection_hdl hdl) {
m_client.get_alog().write(websocketpp::log::alevel::app,
"Connection closed, stopping telemetry!");
scoped_lock guard(m_lock);
m_done = true;
}
void telemetry_loop() {
uint64_t count = 0;
std::stringstream val;
websocketpp::lib::error_code ec;
while(1) {
{
scoped_lock guard(m_lock);
// If the connection hasn't been opened yet wait a bit and try
// again
if (!m_open) {
sleep(1);
continue;
}
// If the connection has been closed, stop generating telemetry
// and exit.
if (m_done) {
break;
}
}
val.str("");
val << "count is " << count++;
m_client.get_alog().write(websocketpp::log::alevel::app, val.str());
m_client.send(m_hdl,val.str(),websocketpp::frame::opcode::text,ec);
if (ec) {
val.str("");
val << "Error: " << ec.message();
m_client.get_alog().write(websocketpp::log::alevel::app, val.str());
break;
}
sleep(1);
}
}
}
void on_open(websocketpp::connection_hdl hdl) {
m_client.get_alog().write(websocketpp::log::alevel::app,
"Connection opened, starting telemetry!");
scoped_lock guard(m_lock);
m_open = true;
}
void on_close(websocketpp::connection_hdl hdl) {
m_client.get_alog().write(websocketpp::log::alevel::app,
"Connection closed, stopping telemetry!");
scoped_lock guard(m_lock);
m_done = true;
}
void telemetry_loop() {
uint64_t count = 0;
std::stringstream val;
websocketpp::lib::error_code ec;
while(1) {
{
scoped_lock guard(m_lock);
// If the connection hasn't been opened yet wait a bit and try
// again
if (!m_open) {
sleep(1);
continue;
}
// If the connection has been closed, stop generating telemetry
// and exit.
if (m_done) {
break;
}
}
val.str("");
val << "count is " << count++;
m_client.get_alog().write(websocketpp::log::alevel::app, val.str());
m_client.send(m_hdl,val.str(),websocketpp::frame::opcode::text,ec);
if (ec) {
val.str("");
val << "Error: " << ec.message();
m_client.get_alog().write(websocketpp::log::alevel::app, val.str());
break;
}
sleep(1);
}
}
private:
client m_client;
websocketpp::connection_hdl m_hdl;
websocketpp::lib::mutex m_lock;
bool m_open;
bool m_done;
client m_client;
websocketpp::connection_hdl m_hdl;
websocketpp::lib::mutex m_lock;
bool m_open;
bool m_done;
};
int main(int argc, char* argv[]) {
telemetry_client c;
std::string uri = "ws://localhost:9002";
if (argc == 2) {
uri = argv[1];
}
c.connect(uri);
c.run();
std::string uri = "ws://localhost:9002";
if (argc == 2) {
uri = argv[1];
}
c.connect(uri);
c.run();
}