testee_server.cpp File Reference

#include <websocketpp/config/asio_no_tls.hpp>
#include <websocketpp/server.hpp>
#include <websocketpp/extensions/permessage_deflate/enabled.hpp>
#include <iostream>

Include dependency graph for testee_server.cpp:

Go to the source code of this file.

Classes
struct	testee_config
struct	testee_config::transport_config
struct	testee_config::permessage_deflate_config
	permessage_compress extension More...

Typedefs
typedef websocketpp::server< testee_config >	server

Functions
void	on_message (server *s, websocketpp::connection_hdl hdl, message_ptr msg)
void	on_socket_init (websocketpp::connection_hdl, boost::asio::ip::tcp::socket &s)
int	main (int argc, char *argv[])

Typedef Documentation

server

typedef websocketpp::server<testee_config> server

Definition at line 76 of file testee_server.cpp.

Function Documentation

main()

int main	(	int	argc,
		char *	argv[] )

Definition at line 95 of file testee_server.cpp.

                                  {
    // Create a server endpoint
    server testee_server;
 
    short port = 9002;
    size_t num_threads = 1;
 
    if (argc == 3) {
        port = atoi(argv[1]);
        num_threads = atoi(argv[2]);
    }
 
    try {
        // Total silence
        testee_server.clear_access_channels(websocketpp::log::alevel::all);
        testee_server.clear_error_channels(websocketpp::log::alevel::all);
 
        // Initialize ASIO
        testee_server.init_asio();
        testee_server.set_reuse_addr(true);
 
        // Register our message handler
        testee_server.set_message_handler(bind(&on_message,&testee_server,::_1,::_2));
        testee_server.set_socket_init_handler(bind(&on_socket_init,::_1,::_2));
 
        // Listen on specified port with extended listen backlog
        testee_server.set_listen_backlog(8192);
        testee_server.listen(port);
 
        // Start the server accept loop
        testee_server.start_accept();
 
        // Start the ASIO io_service run loop
        if (num_threads == 1) {
            testee_server.run();
        } else {
            typedef websocketpp::lib::shared_ptr<websocketpp::lib::thread> thread_ptr;
            std::vector<thread_ptr> ts;
            for (size_t i = 0; i < num_threads; i++) {
                ts.push_back(websocketpp::lib::make_shared<websocketpp::lib::thread>(&server::run, &testee_server));
            }
 
            for (size_t i = 0; i < num_threads; i++) {
                ts[i]->join();
            }
        }
 
    } catch (websocketpp::exception const & e) {
        std::cout << "exception: " << e.what() << std::endl;
    }
}

Here is the call graph for this function:

on_message()

void on_message	(	server *	s,
		websocketpp::connection_hdl	hdl,
		message_ptr	msg )

Definition at line 86 of file testee_server.cpp.

                                                                           {
    s->send(hdl, msg->get_payload(), msg->get_opcode());
}

Here is the caller graph for this function:

on_socket_init()

void on_socket_init	(	websocketpp::connection_hdl	,
		boost::asio::ip::tcp::socket &	s )

Definition at line 90 of file testee_server.cpp.

                                                                         {
    boost::asio::ip::tcp::no_delay option(true);
    s.set_option(option);
}

Here is the caller graph for this function: