telemetry_client Class Reference

Public Types
typedef websocketpp::client< websocketpp::config::asio_client >	client
typedef websocketpp::lib::lock_guard< websocketpp::lib::mutex >	scoped_lock

Public Member Functions
	telemetry_client ()
void	run (const std::string &uri)
void	on_open (websocketpp::connection_hdl)
void	on_close (websocketpp::connection_hdl)
void	on_fail (websocketpp::connection_hdl)
void	telemetry_loop ()

Detailed Description

The telemetry client connects to a WebSocket server and sends a message every second containing an integer count. This example can be used as the basis for programs where a client connects and pushes data for logging, stress/load testing, etc.

Definition at line 15 of file telemetry_client.cpp.

Member Typedef Documentation

client

websocketpp::client<websocketpp::config::asio_client> telemetry_client::client

Definition at line 17 of file telemetry_client.cpp.

scoped_lock

websocketpp::lib::lock_guard<websocketpp::lib::mutex> telemetry_client::scoped_lock

Definition at line 18 of file telemetry_client.cpp.

Constructor & Destructor Documentation

telemetry_client()

telemetry_client::telemetry_client ( )

inline

Definition at line 20 of file telemetry_client.cpp.

                       : 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);
        m_client.set_access_channels(websocketpp::log::alevel::app);
 
        // Initialize the Asio transport policy
        m_client.init_asio();
 
        // Bind the handlers we are using
        using websocketpp::lib::placeholders::_1;
        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));
        m_client.set_fail_handler(bind(&telemetry_client::on_fail,this,_1));
    }

Here is the call graph for this function:

Member Function Documentation

on_close()

void telemetry_client::on_close ( websocketpp::connection_hdl )

inline

Definition at line 77 of file telemetry_client.cpp.

                                             {
        m_client.get_alog().write(websocketpp::log::alevel::app,
            "Connection closed, stopping telemetry!");
 
        scoped_lock guard(m_lock);
        m_done = true;
    }

Here is the call graph for this function:

Here is the caller graph for this function:

on_fail()

void telemetry_client::on_fail ( websocketpp::connection_hdl )

inline

Definition at line 86 of file telemetry_client.cpp.

                                            {
        m_client.get_alog().write(websocketpp::log::alevel::app,
            "Connection failed, stopping telemetry!");
 
        scoped_lock guard(m_lock);
        m_done = true;
    }

Here is the call graph for this function:

Here is the caller graph for this function:

on_open()

void telemetry_client::on_open ( websocketpp::connection_hdl )

inline

Definition at line 68 of file telemetry_client.cpp.

                                            {
        m_client.get_alog().write(websocketpp::log::alevel::app,
            "Connection opened, starting telemetry!");
 
        scoped_lock guard(m_lock);
        m_open = true;
    }

Here is the call graph for this function:

Here is the caller graph for this function:

run()

void telemetry_client::run ( const std::string & uri )

inline

Definition at line 39 of file telemetry_client.cpp.

                                    {
        // Create a new connection to the given URI
        websocketpp::lib::error_code ec;
        client::connection_ptr con = m_client.get_connection(uri, ec);
        if (ec) {
            m_client.get_alog().write(websocketpp::log::alevel::app,
                    "Get Connection Error: "+ec.message());
            return;
        }
 
        // Grab a handle for this connection so we can talk to it in a thread
        // safe manor after the event loop starts.
        m_hdl = con->get_handle();
 
        // Queue the connection. No DNS queries or network connections will be
        // made until the io_service event loop is run.
        m_client.connect(con);
 
        // 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
        websocketpp::lib::thread telemetry_thread(&telemetry_client::telemetry_loop,this);
 
        asio_thread.join();
        telemetry_thread.join();
    }

Here is the call graph for this function:

Here is the caller graph for this function:

telemetry_loop()

void telemetry_client::telemetry_loop ( )

inline

Definition at line 94 of file telemetry_client.cpp.

                          {
        uint64_t count = 0;
        std::stringstream val;
        websocketpp::lib::error_code ec;
 
        while(1) {
            bool wait = false;
 
            {
                scoped_lock guard(m_lock);
                // If the connection has been closed, stop generating telemetry
                if (m_done) {break;}
 
                // If the connection hasn't been opened yet wait a bit and retry
                if (!m_open) {
                    wait = true;
                }
            }
 
            if (wait) {
                sleep(1);
                continue;
            }
 
            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);
 
            // The most likely error that we will get is that the connection is
            // not in the right state. Usually this means we tried to send a
            // message to a connection that was closed or in the process of
            // closing. While many errors here can be easily recovered from,
            // in this simple example, we'll stop the telemetry loop.
            if (ec) {
                m_client.get_alog().write(websocketpp::log::alevel::app,
                    "Send Error: "+ec.message());
                break;
            }
 
            sleep(1);
        }
    }

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• libraries/fc/vendor/websocketpp/examples/telemetry_client/telemetry_client.cpp