[Boost-commit] svn:boost r47261 - trunk/libs/asio/example/local

From: chris_at_[hidden]
Date: 2008-07-09 08:00:57

Author: chris_kohlhoff
Date: 2008-07-09 08:00:56 EDT (Wed, 09 Jul 2008)
New Revision: 47261
URL: http://svn.boost.org/trac/boost/changeset/47261

Log:
Add more UNIX domain socket examples.

Added:
   trunk/libs/asio/example/local/stream_client.cpp   (contents, props changed)
   trunk/libs/asio/example/local/stream_server.cpp   (contents, props changed)
Text files modified: 
   trunk/libs/asio/example/local/Jamfile          |    24 ++++++++++++++++++++++++                
   trunk/libs/asio/example/local/Jamfile.v2       |    30 ++++++++++++++++++++++++++++++          
   trunk/libs/asio/example/local/connect_pair.cpp |     2 ++                                      
   3 files changed, 56 insertions(+), 0 deletions(-)

Modified: trunk/libs/asio/example/local/Jamfile
==============================================================================
--- trunk/libs/asio/example/local/Jamfile	(original)
+++ trunk/libs/asio/example/local/Jamfile	2008-07-09 08:00:56 EDT (Wed, 09 Jul 2008)
@@ -32,3 +32,27 @@
     <mingw><*><find-library>mswsock
     $(SOCKET_LIBS)
   ;
+
+exe stream_client
+  : <lib>@boost/libs/system/build/boost_system
+    stream_client.cpp
+  : <include>$(BOOST_ROOT)
+    <include>../../../..
+    <define>BOOST_ALL_NO_LIB=1
+    <threading>multi
+    <mingw><*><find-library>ws2_32
+    <mingw><*><find-library>mswsock
+    $(SOCKET_LIBS)
+  ;
+
+exe stream_server
+  : <lib>@boost/libs/system/build/boost_system
+    stream_server.cpp
+  : <include>$(BOOST_ROOT)
+    <include>../../../..
+    <define>BOOST_ALL_NO_LIB=1
+    <threading>multi
+    <mingw><*><find-library>ws2_32
+    <mingw><*><find-library>mswsock
+    $(SOCKET_LIBS)
+  ;

Modified: trunk/libs/asio/example/local/Jamfile.v2
==============================================================================
--- trunk/libs/asio/example/local/Jamfile.v2	(original)
+++ trunk/libs/asio/example/local/Jamfile.v2	2008-07-09 08:00:56 EDT (Wed, 09 Jul 2008)
@@ -37,3 +37,33 @@
     <os>HPUX,<toolset>gcc:<define>_XOPEN_SOURCE_EXTENDED
     <os>HPUX:<library>ipv6
   ;
+
+exe stream_client
+  : stream_client.cpp
+    /boost/system//boost_system
+  : <define>BOOST_ALL_NO_LIB=1
+    <threading>multi
+    <os>SOLARIS:<library>socket
+    <os>SOLARIS:<library>nsl
+    <os>NT:<define>_WIN32_WINNT=0x0501
+    <os>NT,<toolset>gcc:<library>ws2_32
+    <os>NT,<toolset>gcc:<library>mswsock
+    <os>NT,<toolset>gcc-cygwin:<define>__USE_W32_SOCKETS
+    <os>HPUX,<toolset>gcc:<define>_XOPEN_SOURCE_EXTENDED
+    <os>HPUX:<library>ipv6
+  ;
+
+exe stream_server
+  : stream_server.cpp
+    /boost/system//boost_system
+  : <define>BOOST_ALL_NO_LIB=1
+    <threading>multi
+    <os>SOLARIS:<library>socket
+    <os>SOLARIS:<library>nsl
+    <os>NT:<define>_WIN32_WINNT=0x0501
+    <os>NT,<toolset>gcc:<library>ws2_32
+    <os>NT,<toolset>gcc:<library>mswsock
+    <os>NT,<toolset>gcc-cygwin:<define>__USE_W32_SOCKETS
+    <os>HPUX,<toolset>gcc:<define>_XOPEN_SOURCE_EXTENDED
+    <os>HPUX:<library>ipv6
+  ;

Modified: trunk/libs/asio/example/local/connect_pair.cpp
==============================================================================
--- trunk/libs/asio/example/local/connect_pair.cpp	(original)
+++ trunk/libs/asio/example/local/connect_pair.cpp	2008-07-09 08:00:56 EDT (Wed, 09 Jul 2008)
@@ -137,4 +137,6 @@
   }
 }
 
+#else // defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)
+# error Local sockets not available on this platform.
 #endif // defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)

Added: trunk/libs/asio/example/local/stream_client.cpp
==============================================================================
--- (empty file)
+++ trunk/libs/asio/example/local/stream_client.cpp	2008-07-09 08:00:56 EDT (Wed, 09 Jul 2008)
@@ -0,0 +1,61 @@
+//
+// stream_client.cpp
+// ~~~~~~~~~~~~~~~~~
+//
+// Copyright (c) 2003-2008 Christopher M. Kohlhoff (chris at kohlhoff dot com)
+//
+// Distributed under the Boost Software License, Version 1.0. (See accompanying
+// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+
+#include <cstdlib>
+#include <cstring>
+#include <iostream>
+#include <boost/asio.hpp>
+
+#if defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)
+
+using boost::asio::local::stream_protocol;
+
+enum { max_length = 1024 };
+
+int main(int argc, char* argv[])
+{
+  try
+  {
+    if (argc != 2)
+    {
+      std::cerr << "Usage: stream_client <file>\n";
+      return 1;
+    }
+
+    boost::asio::io_service io_service;
+
+    stream_protocol::socket s(io_service);
+    s.connect(stream_protocol::endpoint(argv[1]));
+
+    using namespace std; // For strlen.
+    std::cout << "Enter message: ";
+    char request[max_length];
+    std::cin.getline(request, max_length);
+    size_t request_length = strlen(request);
+    boost::asio::write(s, boost::asio::buffer(request, request_length));
+
+    char reply[max_length];
+    size_t reply_length = boost::asio::read(s,
+        boost::asio::buffer(reply, request_length));
+    std::cout << "Reply is: ";
+    std::cout.write(reply, reply_length);
+    std::cout << "\n";
+  }
+  catch (std::exception& e)
+  {
+    std::cerr << "Exception: " << e.what() << "\n";
+  }
+
+  return 0;
+}
+
+#else // defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)
+# error Local sockets not available on this platform.
+#endif // defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)

Added: trunk/libs/asio/example/local/stream_server.cpp
==============================================================================
--- (empty file)
+++ trunk/libs/asio/example/local/stream_server.cpp	2008-07-09 08:00:56 EDT (Wed, 09 Jul 2008)
@@ -0,0 +1,140 @@
+//
+// stream_server.cpp
+// ~~~~~~~~~~~~~~~~~
+//
+// Copyright (c) 2003-2008 Christopher M. Kohlhoff (chris at kohlhoff dot com)
+//
+// Distributed under the Boost Software License, Version 1.0. (See accompanying
+// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+
+#include <cstdio>
+#include <iostream>
+#include <boost/array.hpp>
+#include <boost/bind.hpp>
+#include <boost/enable_shared_from_this.hpp>
+#include <boost/shared_ptr.hpp>
+#include <boost/asio.hpp>
+
+#if defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)
+
+using boost::asio::local::stream_protocol;
+
+class session
+  : public boost::enable_shared_from_this<session>
+{
+public:
+  session(boost::asio::io_service& io_service)
+    : socket_(io_service)
+  {
+  }
+
+  stream_protocol::socket& socket()
+  {
+    return socket_;
+  }
+
+  void start()
+  {
+    socket_.async_read_some(boost::asio::buffer(data_),
+        boost::bind(&session::handle_read,
+          shared_from_this(),
+          boost::asio::placeholders::error,
+          boost::asio::placeholders::bytes_transferred));
+  }
+
+  void handle_read(const boost::system::error_code& error,
+      size_t bytes_transferred)
+  {
+    if (!error)
+    {
+      boost::asio::async_write(socket_,
+          boost::asio::buffer(data_, bytes_transferred),
+          boost::bind(&session::handle_write,
+            shared_from_this(),
+            boost::asio::placeholders::error));
+    }
+  }
+
+  void handle_write(const boost::system::error_code& error)
+  {
+    if (!error)
+    {
+      socket_.async_read_some(boost::asio::buffer(data_),
+          boost::bind(&session::handle_read,
+            shared_from_this(),
+            boost::asio::placeholders::error,
+            boost::asio::placeholders::bytes_transferred));
+    }
+  }
+
+private:
+  // The socket used to communicate with the client.
+  stream_protocol::socket socket_;
+
+  // Buffer used to store data received from the client.
+  boost::array<char, 1024> data_;
+};
+
+typedef boost::shared_ptr<session> session_ptr;
+
+class server
+{
+public:
+  server(boost::asio::io_service& io_service, const std::string& file)
+    : io_service_(io_service),
+      acceptor_(io_service, stream_protocol::endpoint(file))
+  {
+    session_ptr new_session(new session(io_service_));
+    acceptor_.async_accept(new_session->socket(),
+        boost::bind(&server::handle_accept, this, new_session,
+          boost::asio::placeholders::error));
+  }
+
+  void handle_accept(session_ptr new_session,
+      const boost::system::error_code& error)
+  {
+    if (!error)
+    {
+      new_session->start();
+      new_session.reset(new session(io_service_));
+      acceptor_.async_accept(new_session->socket(),
+          boost::bind(&server::handle_accept, this, new_session,
+            boost::asio::placeholders::error));
+    }
+  }
+
+private:
+  boost::asio::io_service& io_service_;
+  stream_protocol::acceptor acceptor_;
+};
+
+int main(int argc, char* argv[])
+{
+  try
+  {
+    if (argc != 2)
+    {
+      std::cerr << "Usage: stream_server <file>\n";
+      std::cerr << "*** WARNING: existing file is removed ***\n";
+      return 1;
+    }
+
+    boost::asio::io_service io_service;
+
+    std::remove(argv[1]);
+    server s(io_service, argv[1]);
+
+    io_service.run();
+  }
+  catch (std::exception& e)
+  {
+    std::cerr << "Exception: " << e.what() << "\n";
+  }
+
+  return 0;
+}
+
+#else // defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)
+# error Local sockets not available on this platform.
+#endif // defined(BOOST_ASIO_HAS_LOCAL_SOCKETS)