From dc06049df934a40dc66edf669f1ea24c7a67d923 Mon Sep 17 00:00:00 2001 From: Peter Thorson Date: Sun, 2 Mar 2014 19:43:11 -0600 Subject: [PATCH] add debug server example --- SConstruct | 3 + examples/debug_server/CMakeLists.txt | 10 +++ examples/debug_server/SConscript | 23 +++++++ examples/debug_server/debug_server.cpp | 92 ++++++++++++++++++++++++++ 4 files changed, 128 insertions(+) create mode 100644 examples/debug_server/CMakeLists.txt create mode 100644 examples/debug_server/SConscript create mode 100644 examples/debug_server/debug_server.cpp diff --git a/SConstruct b/SConstruct index 0c8cfd3d17..fb8df135a0 100644 --- a/SConstruct +++ b/SConstruct @@ -229,6 +229,9 @@ utility_client = SConscript('#/examples/utility_client/SConscript',variant_dir = # debug_client debug_client = SConscript('#/examples/debug_client/SConscript',variant_dir = builddir + 'debug_client',duplicate = 0) +# debug_server +debug_server = SConscript('#/examples/debug_server/SConscript',variant_dir = builddir + 'debug_server',duplicate = 0) + # subprotocol_server subprotocol_server = SConscript('#/examples/subprotocol_server/SConscript',variant_dir = builddir + 'subprotocol_server',duplicate = 0) diff --git a/examples/debug_server/CMakeLists.txt b/examples/debug_server/CMakeLists.txt new file mode 100644 index 0000000000..02f6dcf720 --- /dev/null +++ b/examples/debug_server/CMakeLists.txt @@ -0,0 +1,10 @@ + +file (GLOB SOURCE_FILES *.cpp) +file (GLOB HEADER_FILES *.hpp) + +init_target (debug_server) + +build_executable (${TARGET_NAME} ${SOURCE_FILES} ${HEADER_FILES}) + +link_boost () +final_target () diff --git a/examples/debug_server/SConscript b/examples/debug_server/SConscript new file mode 100644 index 0000000000..4d02261c62 --- /dev/null +++ b/examples/debug_server/SConscript @@ -0,0 +1,23 @@ +## Debug server example +## + +Import('env') +Import('env_cpp11') +Import('boostlibs') +Import('platform_libs') +Import('polyfill_libs') + +env = env.Clone () +env_cpp11 = env_cpp11.Clone () + +prgs = [] + +# if a C++11 environment is available build using that, otherwise use boost +if env_cpp11.has_key('WSPP_CPP11_ENABLED'): + ALL_LIBS = boostlibs(['system'],env_cpp11) + [platform_libs] + [polyfill_libs] + prgs += env_cpp11.Program('debug_server', ["debug_server.cpp"], LIBS = ALL_LIBS) +else: + ALL_LIBS = boostlibs(['system'],env) + [platform_libs] + [polyfill_libs] + prgs += env.Program('debug_server', ["debug_server.cpp"], LIBS = ALL_LIBS) + +Return('prgs') diff --git a/examples/debug_server/debug_server.cpp b/examples/debug_server/debug_server.cpp new file mode 100644 index 0000000000..724ec3c406 --- /dev/null +++ b/examples/debug_server/debug_server.cpp @@ -0,0 +1,92 @@ +/* + * Copyright (c) 2014, Peter Thorson. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are met: + * * Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * * Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * * Neither the name of the WebSocket++ Project nor the + * names of its contributors may be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" + * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL PETER THORSON BE LIABLE FOR ANY + * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES + * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; + * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND + * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS + * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/** ====== WARNING ======== + * This example is presently used as a scratch space. It may or may not be broken + * at any given time. + */ + +#include + +#include + +#include + +typedef websocketpp::server server; + +using websocketpp::lib::placeholders::_1; +using websocketpp::lib::placeholders::_2; +using websocketpp::lib::bind; + +// pull out the type of messages sent by our config +typedef server::message_ptr message_ptr; + +// Define a callback to handle incoming messages +void on_message(server* s, websocketpp::connection_hdl hdl, message_ptr msg) { + std::cout << "on_message called with hdl: " << hdl.lock().get() + << " and message: " << msg->get_payload() + << std::endl; + + try { + s->send(hdl, msg->get_payload(), msg->get_opcode()); + } catch (const websocketpp::lib::error_code& e) { + std::cout << "Echo failed because: " << e + << "(" << e.message() << ")" << std::endl; + } +} + +int main() { + // Create a server endpoint + server echo_server; + + try { + // Set logging settings + echo_server.set_access_channels(websocketpp::log::alevel::all); + echo_server.clear_access_channels(websocketpp::log::alevel::frame_payload); + + // Initialize ASIO + echo_server.init_asio(); + echo_server.set_reuse_addr(true); + + // Register our message handler + echo_server.set_message_handler(bind(&on_message,&echo_server,::_1,::_2)); + + // Listen on port 9012 + echo_server.listen(9012); + + // Start the server accept loop + echo_server.start_accept(); + + // Start the ASIO io_service run loop + echo_server.run(); + } catch (const std::exception & e) { + std::cout << e.what() << std::endl; + } catch (websocketpp::lib::error_code e) { + std::cout << e.message() << std::endl; + } catch (...) { + std::cout << "other exception" << std::endl; + } +}