NS-3 based Named Data Networking (NDN) simulator
ndnSIM 2.5: NDN, CCN, CCNx, content centric networks
API Documentation
echo_client.cpp
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2016, Peter Thorson. All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions are met:
6  * * Redistributions of source code must retain the above copyright
7  * notice, this list of conditions and the following disclaimer.
8  * * Redistributions in binary form must reproduce the above copyright
9  * notice, this list of conditions and the following disclaimer in the
10  * documentation and/or other materials provided with the distribution.
11  * * Neither the name of the WebSocket++ Project nor the
12  * names of its contributors may be used to endorse or promote products
13  * derived from this software without specific prior written permission.
14  *
15  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
16  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18  * ARE DISCLAIMED. IN NO EVENT SHALL PETER THORSON BE LIABLE FOR ANY
19  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
20  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
21  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
22  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
23  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
24  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25  *
26  */
27 
29 #include <websocketpp/client.hpp>
30 
31 #include <iostream>
32 
34 
35 using websocketpp::lib::placeholders::_1;
36 using websocketpp::lib::placeholders::_2;
37 using websocketpp::lib::bind;
38 
39 // pull out the type of messages sent by our config
41 
42 // This message handler will be invoked once for each incoming message. It
43 // prints the message and then sends a copy of the message back to the server.
45  std::cout << "on_message called with hdl: " << hdl.lock().get()
46  << " and message: " << msg->get_payload()
47  << std::endl;
48 
49 
50  websocketpp::lib::error_code ec;
51 
52  c->send(hdl, msg->get_payload(), msg->get_opcode(), ec);
53  if (ec) {
54  std::cout << "Echo failed because: " << ec.message() << std::endl;
55  }
56 }
57 
58 int main(int argc, char* argv[]) {
59  // Create a client endpoint
60  client c;
61 
62  std::string uri = "ws://localhost:9002";
63 
64  if (argc == 2) {
65  uri = argv[1];
66  }
67 
68  try {
69  // Set logging to be pretty verbose (everything except message payloads)
72 
73  // Initialize ASIO
74  c.init_asio();
75 
76  // Register our message handler
77  c.set_message_handler(bind(&on_message,&c,::_1,::_2));
78 
79  websocketpp::lib::error_code ec;
80  client::connection_ptr con = c.get_connection(uri, ec);
81  if (ec) {
82  std::cout << "could not create connection because: " << ec.message() << std::endl;
83  return 0;
84  }
85 
86  // Note that connect here only requests a connection. No network messages are
87  // exchanged until the event loop starts running in the next line.
88  c.connect(con);
89 
90  // Start the ASIO io_service run loop
91  // this will cause a single connection to be made to the server. c.run()
92  // will exit when this connection is closed.
93  c.run();
94  } catch (websocketpp::exception const & e) {
95  std::cout << e.what() << std::endl;
96  }
97 }
static level const all
Special aggregate value representing "all levels".
Definition: levels.hpp:152
connection_type::ptr connection_ptr
Type of a shared pointer to the connections this server will create.
websocketpp::config::asio_tls_client::message_type::ptr message_ptr
void on_message(client *c, websocketpp::connection_hdl hdl, message_ptr msg)
Definition: echo_client.cpp:44
websocketpp::client< websocketpp::config::asio_client > client
Definition: echo_client.cpp:33
static level const frame_payload
One line per frame, includes the full message payload (warning: chatty)
Definition: levels.hpp:129
lib::weak_ptr< void > connection_hdl
A handle to uniquely identify a connection.
connection_ptr connect(connection_ptr con)
Begin the connection process for the given connection.
lib::shared_ptr< message > ptr
Definition: message.hpp:86
websocketpp::config::asio_client::message_type::ptr message_ptr
Definition: echo_client.cpp:40
void set_access_channels(log::level channels)
Set Access logging channel.
Definition: endpoint.hpp:220
int main(int argc, char *argv[])
Definition: echo_client.cpp:58
void clear_access_channels(log::level channels)
Clear Access logging channels.
Definition: endpoint.hpp:231
void set_message_handler(message_handler h)
Definition: endpoint.hpp:322
virtual char const * what() const
Definition: error.hpp:263
void send(connection_hdl hdl, std::string const &payload, frame::opcode::value op, lib::error_code &ec)
Create a message and add it to the outgoing send queue (exception free)
connection_ptr get_connection(uri_ptr location, lib::error_code &ec)
Get a new connection.