broadcast_server Class Reference

Public Member Functions
	broadcast_server ()
void	on_open (connection_hdl hdl)
void	on_close (connection_hdl hdl)
void	on_message (connection_hdl hdl, server::message_ptr msg)
void	run (uint16_t port)
	broadcast_server ()
void	run (uint16_t port)
void	on_open (connection_hdl hdl)
void	on_close (connection_hdl hdl)
void	on_message (connection_hdl hdl, server::message_ptr msg)
void	process_messages ()
	broadcast_server ()
void	on_open (connection_hdl hdl)
void	on_close (connection_hdl hdl)
void	on_message (connection_hdl hdl, server::message_ptr msg)
void	run (uint16_t port)

Detailed Description

Definition at line 13 of file simple_broadcast_server.cpp.

Constructor & Destructor Documentation

broadcast_server() [1/3]

broadcast_server::broadcast_server ( )

inline

Definition at line 15 of file simple_broadcast_server.cpp.

                       {
        m_server.init_asio();
                
        m_server.set_open_handler(bind(&broadcast_server::on_open,this,::_1));
        m_server.set_close_handler(bind(&broadcast_server::on_close,this,::_1));
        m_server.set_message_handler(bind(&broadcast_server::on_message,this,::_1,::_2));
    }

Here is the call graph for this function:

broadcast_server() [2/3]

broadcast_server::broadcast_server ( )

inline

Definition at line 49 of file broadcast_server.cpp.

                       {
        // Initialize Asio Transport
        m_server.init_asio();
 
        // Register handler callbacks
        m_server.set_open_handler(bind(&broadcast_server::on_open,this,::_1));
        m_server.set_close_handler(bind(&broadcast_server::on_close,this,::_1));
        m_server.set_message_handler(bind(&broadcast_server::on_message,this,::_1,::_2));
    }

Here is the call graph for this function:

broadcast_server() [3/3]

broadcast_server::broadcast_server ( )

inline

Definition at line 14 of file simple_broadcast_server.cpp.

                       {
        m_server.init_asio();
 
        m_server.set_open_handler(bind(&broadcast_server::on_open,this,::_1));
        m_server.set_close_handler(bind(&broadcast_server::on_close,this,::_1));
        m_server.set_message_handler(bind(&broadcast_server::on_message,this,::_1,::_2));
    }

Here is the call graph for this function:

Member Function Documentation

on_close() [1/3]

void broadcast_server::on_close ( connection_hdl hdl )

inline

Definition at line 27 of file simple_broadcast_server.cpp.

                                      {
        m_connections.erase(hdl);
    }

Here is the caller graph for this function:

on_close() [2/3]

void broadcast_server::on_close ( connection_hdl hdl )

inline

Definition at line 83 of file broadcast_server.cpp.

                                      {
        {
            lock_guard<mutex> guard(m_action_lock);
            //std::cout << "on_close" << std::endl;
            m_actions.push(action(UNSUBSCRIBE,hdl));
        }
        m_action_cond.notify_one();
    }

on_close() [3/3]

void broadcast_server::on_close ( connection_hdl hdl )

inline

Definition at line 26 of file simple_broadcast_server.cpp.

                                      {
        m_connections.erase(hdl);
    }

on_message() [1/3]

void broadcast_server::on_message ( connection_hdl hdl, server::message_ptr msg )

inline

Definition at line 31 of file simple_broadcast_server.cpp.

                                                               {
        for (auto it : m_connections) {
            m_server.send(it,msg);
        }
    }

Here is the call graph for this function:

Here is the caller graph for this function:

on_message() [2/3]

void broadcast_server::on_message ( connection_hdl hdl, server::message_ptr msg )

inline

Definition at line 92 of file broadcast_server.cpp.

                                                               {
        // queue message up for sending by processing thread
        {
            lock_guard<mutex> guard(m_action_lock);
            //std::cout << "on_message" << std::endl;
            m_actions.push(action(MESSAGE,hdl,msg));
        }
        m_action_cond.notify_one();
    }

on_message() [3/3]

void broadcast_server::on_message ( connection_hdl hdl, server::message_ptr msg )

inline

Definition at line 30 of file simple_broadcast_server.cpp.

                                                               {
        for (auto it : m_connections) {
            m_server.send(it,msg);
        }
    }

Here is the call graph for this function:

on_open() [1/3]

void broadcast_server::on_open ( connection_hdl hdl )

inline

Definition at line 23 of file simple_broadcast_server.cpp.

                                     {
        m_connections.insert(hdl);
    }

Here is the caller graph for this function:

on_open() [2/3]

void broadcast_server::on_open ( connection_hdl hdl )

inline

Definition at line 74 of file broadcast_server.cpp.

                                     {
        {
            lock_guard<mutex> guard(m_action_lock);
            //std::cout << "on_open" << std::endl;
            m_actions.push(action(SUBSCRIBE,hdl));
        }
        m_action_cond.notify_one();
    }

on_open() [3/3]

void broadcast_server::on_open ( connection_hdl hdl )

inline

Definition at line 22 of file simple_broadcast_server.cpp.

                                     {
        m_connections.insert(hdl);
    }

process_messages()

void broadcast_server::process_messages ( )

inline

Definition at line 102 of file broadcast_server.cpp.

                            {
        while(1) {
            unique_lock<mutex> lock(m_action_lock);
 
            while(m_actions.empty()) {
                m_action_cond.wait(lock);
            }
 
            action a = m_actions.front();
            m_actions.pop();
 
            lock.unlock();
 
            if (a.type == SUBSCRIBE) {
                lock_guard<mutex> guard(m_connection_lock);
                m_connections.insert(a.hdl);
            } else if (a.type == UNSUBSCRIBE) {
                lock_guard<mutex> guard(m_connection_lock);
                m_connections.erase(a.hdl);
            } else if (a.type == MESSAGE) {
                lock_guard<mutex> guard(m_connection_lock);
 
                con_list::iterator it;
                for (it = m_connections.begin(); it != m_connections.end(); ++it) {
                    m_server.send(*it,a.msg);
                }
            } else {
                // undefined.
            }
        }
    }

Here is the call graph for this function:

Here is the caller graph for this function:

run() [1/3]

void broadcast_server::run ( uint16_t port )

inline

Definition at line 37 of file simple_broadcast_server.cpp.

                            {
        m_server.listen(port);
        m_server.start_accept();
        m_server.run();
    }

Here is the call graph for this function:

Here is the caller graph for this function:

run() [2/3]

void broadcast_server::run ( uint16_t port )

inline

Definition at line 59 of file broadcast_server.cpp.

                            {
        // listen on specified port
        m_server.listen(port);
 
        // Start the server accept loop
        m_server.start_accept();
 
        // Start the ASIO io_service run loop
        try {
            m_server.run();
        } catch (const std::exception & e) {
            std::cout << e.what() << std::endl;
        }
    }

Here is the call graph for this function:

run() [3/3]

void broadcast_server::run ( uint16_t port )

inline

Definition at line 36 of file simple_broadcast_server.cpp.

                            {
        m_server.listen(port);
        m_server.start_accept();
        m_server.run();
    }

Here is the call graph for this function:

---

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

• libraries/fc/vendor/websocketpp/docs/simple_broadcast_server.cpp
• libraries/fc/vendor/websocketpp/examples/broadcast_server/broadcast_server.cpp
• libraries/fc/vendor/websocketpp/examples/simple_broadcast_server/simple_broadcast_server.cpp