import quincy beta 17.1.0

[ceph.git] / ceph / src / boost / libs / fiber / examples / asio / ps / subscriber.cpp

diff --git a/ceph/src/boost/libs/fiber/examples/asio/ps/subscriber.cpp b/ceph/src/boost/libs/fiber/examples/asio/ps/subscriber.cpp
index 7acabe7087eaa119c5b0ba19c81a95cf05f99555..83b5e8b34c443daba8ece7a43ea43404d2770e03 100644 (file)
--- a/ceph/src/boost/libs/fiber/examples/asio/ps/subscriber.cpp
+++ b/ceph/src/boost/libs/fiber/examples/asio/ps/subscriber.cpp
@@ -23,19 +23,19 @@ enum {
 int main( int argc, char* argv[]) {
     try {
         if ( 3 != argc) {
-            std::cerr << "Usage: subscriber <host> <channel>\n";
+            std::cerr << "Usage: subscriber <host> <queue>\n";
             return EXIT_FAILURE;
         }
-        boost::asio::io_service io_service;
-        tcp::resolver resolver( io_service);
+        boost::asio::io_context io_context;
+        tcp::resolver resolver( io_context);
         tcp::resolver::query query( tcp::v4(), argv[1], "9998");
         tcp::resolver::iterator iterator = resolver.resolve( query);
-        tcp::socket s( io_service);
+        tcp::socket s( io_context);
         boost::asio::connect( s, iterator);
         char msg[max_length];
-        std::string channel( argv[2]);
+        std::string queue( argv[2]);
         std::memset( msg, '\0', max_length);
-        std::memcpy( msg, channel.c_str(), channel.size() );
+        std::memcpy( msg, queue.c_str(), queue.size() );
         boost::asio::write( s, boost::asio::buffer( msg, max_length) );
         for (;;) {
             char reply[max_length];