Update examples to remove use of now deprecated functionality references #896

Author: Peter Thorson

examples/associative_storage/associative_storage.cpp

@@ -10,6 +10,7 @@ using websocketpp::connection_hdl;
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 struct connection_data {
     int sessionid;
@@ -44,6 +45,11 @@ class print_server {
         m_connections.erase(hdl);
     }
 
+    void on_end_accept(error_code lib_ec, error_code trans_ec) {
+        std::cout << "Accept loop ended "
+                  << lib_ec.message() << "/" << trans_ec.message() << std::endl;
+    }
+
     void on_message(connection_hdl hdl, server::message_ptr msg) {
         connection_data& data = get_data_from_hdl(hdl);
 
@@ -71,7 +77,7 @@ class print_server {
 
     void run(uint16_t port) {
         m_server.listen(port);
-        m_server.start_accept();
+        m_server.start_accept(bind(&print_server::on_end_accept,this,::_1,::_2));
         m_server.run();
     }
 private:

examples/broadcast_server/broadcast_server.cpp

@@ -47,8 +47,12 @@ struct action {
 class broadcast_server {
 public:
     broadcast_server() {
+        websocketpp::lib::error_code ec;
         // Initialize Asio Transport
-        m_server.init_asio();
+        m_server.init_asio(ec);
+        if (!ec) {
+            return;
+        }
 
         // Register handler callbacks
         m_server.set_open_handler(bind(&broadcast_server::on_open,this,::_1));
@@ -57,18 +61,26 @@ class broadcast_server {
     }
 
     void run(uint16_t port) {
+        websocketpp::lib::error_code ec;
+
         // listen on specified port
-        m_server.listen(port);
+        m_server.listen(port,ec);
+        if (!ec) {
+            return;
+        }
 
         // Start the server accept loop
-        m_server.start_accept();
+        m_server.start_accept(ec);
+        if (!ec) {
+            return;
+        }
 
         // Start the ASIO io_service run loop
-        try {
+        //try {
             m_server.run();
-        } catch (const std::exception & e) {
-            std::cout << e.what() << std::endl;
-        }
+        //} catch (const std::exception & e) {
+        //    std::cout << e.what() << std::endl;
+        //}
     }
 
     void on_open(connection_hdl hdl) {
@@ -100,6 +112,7 @@ class broadcast_server {
     }
 
     void process_messages() {
+        websocketpp::lib::error_code ec;
         while(1) {
             unique_lock<mutex> lock(m_action_lock);
 
@@ -123,7 +136,10 @@ class broadcast_server {
 
                 con_list::iterator it;
                 for (it = m_connections.begin(); it != m_connections.end(); ++it) {
-                    m_server.send(*it,a.msg);
+                    m_server.send(*it,a.msg,ec);
+                    if (ec) {
+                        return;
+                    }
                 }
             } else {
                 // undefined.
@@ -143,7 +159,7 @@ class broadcast_server {
 };
 
 int main() {
-    try {
+    //try {
     broadcast_server server_instance;
 
     // Start a thread to run the processing loop
@@ -154,7 +170,7 @@ int main() {
 
     t.join();
 
-    } catch (websocketpp::exception const & e) {
-        std::cout << e.what() << std::endl;
-    }
+    //} catch (websocketpp::exception const & e) {
+    //    std::cout << e.what() << std::endl;
+    //}
 }

examples/debug_client/debug_client.cpp

@@ -30,13 +30,12 @@
  */
 
 #include <websocketpp/config/asio_client.hpp>
-
 #include <websocketpp/client.hpp>
 
 #include <iostream>
 #include <chrono>
 
-typedef websocketpp::client<websocketpp::config::asio_client> client;
+typedef websocketpp::client<websocketpp::config::asio_tls_client> client;
 
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
@@ -63,7 +62,7 @@ class perftest {
 
         // Register our handlers
         m_endpoint.set_socket_init_handler(bind(&type::on_socket_init,this,::_1));
-        //m_endpoint.set_tls_init_handler(bind(&type::on_tls_init,this,::_1));
+        m_endpoint.set_tls_init_handler(bind(&type::on_tls_init,this,::_1));
         m_endpoint.set_message_handler(bind(&type::on_message,this,::_1,::_2));
         m_endpoint.set_open_handler(bind(&type::on_open,this,::_1));
         m_endpoint.set_close_handler(bind(&type::on_close,this,::_1));

examples/echo_server/echo_server.cpp

@@ -9,6 +9,7 @@ typedef websocketpp::server<websocketpp::config::asio> server;
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 // pull out the type of messages sent by our config
 typedef server::message_ptr message_ptr;
@@ -34,6 +35,12 @@ void on_message(server* s, websocketpp::connection_hdl hdl, message_ptr msg) {
     }
 }
 
+// Define a callback to handle failures accepting connections
+void on_end_accept(error_code lib_ec, error_code trans_ec) {
+    std::cout << "Accept loop ended "
+                << lib_ec.message() << "/" << trans_ec.message() << std::endl;
+}
+
 int main() {
     // Create a server endpoint
     server echo_server;
@@ -53,7 +60,7 @@ int main() {
         echo_server.listen(9002);
 
         // Start the server accept loop
-        echo_server.start_accept();
+        echo_server.start_accept(&on_end_accept);
 
         // Start the ASIO io_service run loop
         echo_server.run();

examples/echo_server_both/echo_server_both.cpp

@@ -12,6 +12,7 @@ typedef websocketpp::server<websocketpp::config::asio_tls> server_tls;
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 // type of the ssl context pointer is long so alias it
 typedef websocketpp::lib::shared_ptr<boost::asio::ssl::context> context_ptr;
@@ -34,6 +35,12 @@ void on_message(EndpointType* s, websocketpp::connection_hdl hdl,
     }
 }
 
+// Define a callback to handle failures accepting connections
+void on_end_accept(error_code lib_ec, error_code trans_ec) {
+    std::cout << "Accept loop ended "
+                << lib_ec.message() << "/" << trans_ec.message() << std::endl;
+}
+
 // No change to TLS init methods from echo_server_tls
 std::string get_password() {
     return "test";
@@ -69,7 +76,7 @@ int main() {
     endpoint_plain.set_message_handler(
         bind(&on_message<server_plain>,&endpoint_plain,::_1,::_2));
     endpoint_plain.listen(80);
-    endpoint_plain.start_accept();
+    endpoint_plain.start_accept(&on_end_accept);
 
     // set up tls endpoint
     server_tls endpoint_tls;
@@ -80,7 +87,7 @@ int main() {
     endpoint_tls.set_tls_init_handler(bind(&on_tls_init,::_1));
     // tls endpoint listens on a different port
     endpoint_tls.listen(443);
-    endpoint_tls.start_accept();
+    endpoint_tls.start_accept(&on_end_accept);
 
     // Start the ASIO io_service run loop running both endpoints
     ios.run();

examples/echo_server_tls/echo_server_tls.cpp

@@ -45,6 +45,7 @@ typedef websocketpp::server<websocketpp::config::asio_tls> server;
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 // pull out the type of messages sent by our config
 typedef websocketpp::config::asio::message_type::ptr message_ptr;
@@ -63,6 +64,12 @@ void on_message(server* s, websocketpp::connection_hdl hdl, message_ptr msg) {
     }
 }
 
+// Define a callback to handle failures accepting connections
+void on_end_accept(error_code lib_ec, error_code trans_ec) {
+    std::cout << "Accept loop ended "
+                << lib_ec.message() << "/" << trans_ec.message() << std::endl;
+}
+
 void on_http(server* s, websocketpp::connection_hdl hdl) {
     server::connection_ptr con = s->get_con_from_hdl(hdl);
 
@@ -146,7 +153,7 @@ int main() {
     echo_server.listen(9002);
 
     // Start the server accept loop
-    echo_server.start_accept();
+    echo_server.start_accept(&on_end_accept);
 
     // Start the ASIO io_service run loop
     echo_server.run();

examples/enriched_storage/enriched_storage.cpp

@@ -34,6 +34,7 @@ using websocketpp::connection_hdl;
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 class print_server {
 public:
@@ -57,6 +58,11 @@ class print_server {
         std::cout << "Closing connection " << con->name 
                   << " with sessionid " << con->sessionid << std::endl;
     }
+
+    void on_end_accept(error_code lib_ec, error_code trans_ec) {
+        std::cout << "Accept loop ended "
+                  << lib_ec.message() << "/" << trans_ec.message() << std::endl;
+    }
 
     void on_message(connection_hdl hdl, server::message_ptr msg) {
         connection_ptr con = m_server.get_con_from_hdl(hdl);
@@ -73,7 +79,7 @@ class print_server {
 
     void run(uint16_t port) {
         m_server.listen(port);
-        m_server.start_accept();
+        m_server.start_accept(bind(&print_server::on_end_accept,this,::_1,::_2));
         m_server.run();
     }
 private:

examples/external_io_service/external_io_service.cpp

@@ -34,6 +34,7 @@
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 typedef websocketpp::server<websocketpp::config::asio> ws_echo_server;
 
@@ -58,6 +59,12 @@ void on_message(ws_echo_server* s, websocketpp::connection_hdl hdl, ws_echo_serv
     }
 }
 
+// Define a callback to handle failures accepting connections
+void on_end_accept(error_code lib_ec, error_code trans_ec) {
+    std::cout << "Accept loop ended "
+                << lib_ec.message() << "/" << trans_ec.message() << std::endl;
+}
+
 int main() {
     asio::io_service service;
 
@@ -76,7 +83,7 @@ int main() {
     // Register our message handler
     ws_server.set_message_handler(bind(&on_message,&ws_server,::_1,::_2));
     ws_server.listen(9002);
-    ws_server.start_accept();
+    ws_server.start_accept(&on_end_accept);
 
     // TODO: add a timer?
 

examples/handler_switch/handler_switch.cpp

@@ -36,7 +36,7 @@ int main() {
 
     s.init_asio();
     s.listen(9002);
-    s.start_accept();
+    s.start_accept(NULL); // ignore errors to keep example code consise
 
     s.run();
 }

examples/iostream_server/iostream_server.cpp

@@ -10,6 +10,7 @@ typedef websocketpp::server<websocketpp::config::core> server;
 using websocketpp::lib::placeholders::_1;
 using websocketpp::lib::placeholders::_2;
 using websocketpp::lib::bind;
+using websocketpp::lib::error_code;
 
 // pull out the type of messages sent by our config
 typedef server::message_ptr message_ptr;
@@ -55,7 +56,12 @@ int main() {
         // Register our message handler
         s.set_message_handler(bind(&on_message,&s,::_1,::_2));
 
-        server::connection_ptr con = s.get_connection();
+        error_code ec;
+        server::connection_ptr con = s.get_connection(ec);
+        if (ec) {
+            std::cout << "Failed to generate new connection because " << ec.message() << std::endl;
+            return 1;
+        }
 
         con->start();