[Boost-commit] svn:boost r63106 - in sandbox/SOC/2010/process: boost boost/process libs/process/example

Subject: [Boost-commit] svn:boost r63106 - in sandbox/SOC/2010/process: boost boost/process libs/process/example
From: boris_at_[hidden]
Date: 2010-06-19 14:19:00

Author: bschaeling
Date: 2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
New Revision: 63106
URL: http://svn.boost.org/trac/boost/changeset/63106

Log:
Added pipe type to support asynchronous read/write operations
Added:
   sandbox/SOC/2010/process/boost/process/pipe.hpp   (contents, props changed)
   sandbox/SOC/2010/process/libs/process/example/wait_sync_child.cpp
      - copied unchanged from r63094, /sandbox/SOC/2010/process/libs/process/example/wait_child.cpp
Removed:
   sandbox/SOC/2010/process/libs/process/example/child_stdin.cpp
   sandbox/SOC/2010/process/libs/process/example/child_stdout.cpp
   sandbox/SOC/2010/process/libs/process/example/wait_child.cpp
Properties modified: 
   sandbox/SOC/2010/process/libs/process/example/   (props changed)
Text files modified: 
   sandbox/SOC/2010/process/boost/process.hpp                              |    34 +-----------------                      
   sandbox/SOC/2010/process/boost/process/all.hpp                          |     1                                         
   sandbox/SOC/2010/process/boost/process/context.hpp                      |    18 +++++-----                              
   sandbox/SOC/2010/process/boost/process/pistream.hpp                     |     2                                         
   sandbox/SOC/2010/process/boost/process/postream.hpp                     |     2                                         
   sandbox/SOC/2010/process/boost/process/stream_behavior.hpp              |    70 ++++++++++++++++++++++++++++----------- 
   sandbox/SOC/2010/process/libs/process/example/create_process.cpp        |    11 ++----                                  
   sandbox/SOC/2010/process/libs/process/example/read_async_from_child.cpp |    25 ++++----------                          
   sandbox/SOC/2010/process/libs/process/example/read_from_child.cpp       |    10 ++++-                                   
   sandbox/SOC/2010/process/libs/process/example/write_async_to_child.cpp  |    13 +++----                                 
   sandbox/SOC/2010/process/libs/process/example/write_to_child.cpp        |     4 +-                                      
   11 files changed, 91 insertions(+), 99 deletions(-)

Modified: sandbox/SOC/2010/process/boost/process.hpp
==============================================================================
--- sandbox/SOC/2010/process/boost/process.hpp	(original)
+++ sandbox/SOC/2010/process/boost/process.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -14,50 +14,22 @@
  * \file boost/process.hpp 
  * 
  * Convenience header that includes all other Boost.Process public header 
- * files. It is important to note that those headers that are specific to 
- * a given platform are only included if the library is being used in that 
- * same platform. 
+ * files. 
  */ 
 
 #ifndef BOOST_PROCESS_HPP 
 #define BOOST_PROCESS_HPP 
 
 #include <boost/process/config.hpp> 
-
-#if defined(BOOST_POSIX_API) 
-/*
-#  include <boost/process/posix_child.hpp> 
-#  include <boost/process/posix_context.hpp> 
-#  include <boost/process/posix_operations.hpp> 
-#  include <boost/process/posix_status.hpp> 
-*/
-#elif defined(BOOST_WINDOWS_API) 
-/*
-#  include <boost/process/win32_child.hpp> 
-#  include <boost/process/win32_context.hpp> 
-#  include <boost/process/win32_operations.hpp> 
-*/
-#else 
-#  error "Unsupported platform." 
-#endif 
-/*
 #include <boost/process/child.hpp> 
 #include <boost/process/context.hpp> 
 #include <boost/process/environment.hpp> 
 #include <boost/process/operations.hpp> 
-#include <boost/process/pistream.hpp> 
-#include <boost/process/postream.hpp> 
-#include <boost/process/process.hpp> 
-#include <boost/process/self.hpp> 
-#include <boost/process/status.hpp> 
-#include <boost/process/stream_behavior.hpp> 
-*/
-#include <boost/process/child.hpp> 
-#include <boost/process/context.hpp> 
-#include <boost/process/operations.hpp> 
+#include <boost/process/pipe.hpp> 
 #include <boost/process/pistream.hpp> 
 #include <boost/process/postream.hpp> 
 #include <boost/process/process.hpp> 
 #include <boost/process/status.hpp> 
 #include <boost/process/stream_behavior.hpp> 
+
 #endif 

Modified: sandbox/SOC/2010/process/boost/process/all.hpp
==============================================================================
--- sandbox/SOC/2010/process/boost/process/all.hpp	(original)
+++ sandbox/SOC/2010/process/boost/process/all.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -25,6 +25,7 @@
 #include <boost/process/context.hpp> 
 #include <boost/process/environment.hpp> 
 #include <boost/process/operations.hpp> 
+#include <boost/process/pipe.hpp> 
 #include <boost/process/pistream.hpp> 
 #include <boost/process/postream.hpp> 
 #include <boost/process/process.hpp> 

Modified: sandbox/SOC/2010/process/boost/process/context.hpp
==============================================================================
--- sandbox/SOC/2010/process/boost/process/context.hpp	(original)
+++ sandbox/SOC/2010/process/boost/process/context.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -33,9 +33,9 @@
  */
 struct context
 {
-    boost::shared_ptr<stream_behavior> stdin_behavior;
-    boost::shared_ptr<stream_behavior> stdout_behavior;
-    boost::shared_ptr<stream_behavior> stderr_behavior;
+    boost::shared_ptr<behavior::stream> stdin_behavior;
+    boost::shared_ptr<behavior::stream> stdout_behavior;
+    boost::shared_ptr<behavior::stream> stderr_behavior;
     std::string process_name;
     std::string work_dir;
     environment environment;
@@ -48,13 +48,13 @@
      */ 
     context() 
 #if defined(BOOST_POSIX_API) 
-        : stdin_behavior(boost::make_shared<inherit>(inherit(STDIN_FILENO))), 
-        stdout_behavior(boost::make_shared<inherit>(inherit(STDOUT_FILENO))), 
-        stderr_behavior(boost::make_shared<inherit>(inherit(STDERR_FILENO))), 
+        : stdin_behavior(behavior::inherit::def(behavior::inherit(STDIN_FILENO))), 
+        stdout_behavior(behavior::inherit::def(behavior::inherit(STDOUT_FILENO))), 
+        stderr_behavior(behavior::inherit::def(behavior::inherit(STDERR_FILENO))), 
 #elif defined(BOOST_WINDOWS_API) 
-        : stdin_behavior(boost::make_shared<inherit>(inherit(::GetStdHandle(STD_INPUT_HANDLE)))), 
-        stdout_behavior(boost::make_shared<inherit>(inherit(::GetStdHandle(STD_OUTPUT_HANDLE)))), 
-        stderr_behavior(boost::make_shared<inherit>(inherit(::GetStdHandle(STD_ERROR_HANDLE)))), 
+        : stdin_behavior(behavior::inherit::def(::GetStdHandle(STD_INPUT_HANDLE))), 
+        stdout_behavior(behavior::inherit::def(::GetStdHandle(STD_OUTPUT_HANDLE))), 
+        stderr_behavior(behavior::inherit::def(::GetStdHandle(STD_ERROR_HANDLE))), 
 #endif 
         work_dir(self::get_work_dir()), 
         environment(self::get_environment()) 

Added: sandbox/SOC/2010/process/boost/process/pipe.hpp
==============================================================================
--- (empty file)
+++ sandbox/SOC/2010/process/boost/process/pipe.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -0,0 +1,43 @@
+//
+// Boost.Process
+// ~~~~~~~~~~~~~
+//
+// Copyright (c) 2006, 2007 Julio M. Merino Vidal
+// Copyright (c) 2008, 2009 Boris Schaeling
+// Copyright (c) 2010 Felipe Tanus, Boris Schaeling
+//
+// 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)
+//
+
+/**
+ * \file boost/process/pipe.hpp
+ *
+ * Includes the declaration of the pipe class.
+ */
+
+#ifndef BOOST_PROCESS_PIPE_HPP
+#define BOOST_PROCESS_PIPE_HPP
+
+#include <boost/process/config.hpp>
+#include <boost/asio.hpp>
+
+namespace boost {
+namespace process {
+
+/**
+ * The pipe class is a type definition for stream-based classes
+ * defined by Boost.Asio.
+ */
+#if defined(BOOST_POSIX_API)
+typedef boost::asio::posix::stream_descriptor pipe;
+#elif defined(BOOST_WINDOWS_API)
+typedef boost::asio::windows::stream_handle pipe;
+#else
+#   error "Unsupported platform."
+#endif
+
+}
+}
+
+#endif

Modified: sandbox/SOC/2010/process/boost/process/pistream.hpp
==============================================================================
--- sandbox/SOC/2010/process/boost/process/pistream.hpp	(original)
+++ sandbox/SOC/2010/process/boost/process/pistream.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -82,7 +82,7 @@
      * The file handle must not be copied. Copying invalidates
      * the source file handle making the pistream unusable.
      */
-    detail::file_handle &handle()
+    detail::file_handle &native()
     {
         return handle_;
     }

Modified: sandbox/SOC/2010/process/boost/process/postream.hpp
==============================================================================
--- sandbox/SOC/2010/process/boost/process/postream.hpp	(original)
+++ sandbox/SOC/2010/process/boost/process/postream.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -82,7 +82,7 @@
      * The file handle must not be copied. Copying invalidates
      * the source file handle making the postream unusable.
      */
-    detail::file_handle &handle()
+    detail::file_handle &native()
     {
         return handle_;
     }

Modified: sandbox/SOC/2010/process/boost/process/stream_behavior.hpp
==============================================================================
--- sandbox/SOC/2010/process/boost/process/stream_behavior.hpp	(original)
+++ sandbox/SOC/2010/process/boost/process/stream_behavior.hpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -13,7 +13,7 @@
 /**
  * \file boost/process/stream_behavior.hpp
  *
- * Includes the declaration of the stream_behavior classes.
+ * Includes the declaration of stream behavior classes.
  *
  */
 
@@ -32,8 +32,12 @@
 #   include <windows.h> 
 #endif 
 
+#include <boost/shared_ptr.hpp> 
+#include <boost/make_shared.hpp> 
+
 namespace boost {
 namespace process {
+namespace behavior {
 
 /*
  * BEHAVIOR | BEFORE fork/CreateProcess        | AFTER fork/CreateProcess 
@@ -52,10 +56,10 @@
 /**
  * Stream behaviors are used to configure streams of a child process.
  *
- * The class stream_behavior is the base class all other stream behavior
- * classes must be derived from.
+ * The class stream is the base class all other stream behavior classes
+ * must be derived from.
  */
-class stream_behavior 
+class stream 
 { 
 public: 
 #if defined(BOOST_POSIX_API) 
@@ -64,7 +68,12 @@
     typedef HANDLE native_type; 
 #endif 
 
-    virtual native_type get_child_end() const 
+    static boost::shared_ptr<stream> def() 
+    { 
+        return boost::make_shared<stream>(stream()); 
+    } 
+
+    virtual native_type get_child_end() 
     { 
 #if defined(BOOST_POSIX_API) 
         return -1; 
@@ -73,7 +82,7 @@
 #endif 
     } 
 
-    virtual native_type get_parent_end() const 
+    virtual native_type get_parent_end() 
     { 
 #if defined(BOOST_POSIX_API) 
         return -1; 
@@ -88,7 +97,7 @@
  *
  * A child process will not be able to use its streams.
  */
-typedef stream_behavior close; 
+typedef stream close; 
 
 /**
  * Stream behavior to make a child process inherit streams.
@@ -96,7 +105,7 @@
  * A child process will use the very same streams the current
  * process uses.
  */
-class inherit : public stream_behavior 
+class inherit : public stream 
 { 
 public: 
     inherit(native_type child_end) 
@@ -108,7 +117,12 @@
 #endif 
     } 
 
-    native_type get_child_end() const 
+    static boost::shared_ptr<inherit> def(native_type child_end) 
+    { 
+        return boost::make_shared<inherit>(inherit(child_end)); 
+    } 
+
+    native_type get_child_end() 
     { 
         return child_end_; 
     } 
@@ -123,12 +137,12 @@
  * A child process will be able to communicate with the current
  * process.
  */
-class capture : public stream_behavior 
+class pipe : public stream 
 { 
 public: 
     enum stream_type { input_stream, output_stream }; 
 
-    capture(stream_type stream) 
+    pipe(stream_type stream) 
     { 
         native_type natives[2]; 
 #if defined(BOOST_POSIX_API) 
@@ -151,12 +165,17 @@
 #endif 
     } 
 
-    native_type get_child_end() const 
+    static boost::shared_ptr<pipe> def(stream_type stream) 
+    { 
+        return boost::make_shared<pipe>(pipe(stream)); 
+    } 
+
+    native_type get_child_end() 
     { 
         return child_end_; 
     } 
 
-    native_type get_parent_end() const 
+    native_type get_parent_end() 
     { 
         return parent_end_; 
     } 
@@ -174,12 +193,12 @@
  * asynchronous I/O (as only named pipes support asynchronous I/O
  * on Windows).
  */
-class capture_with_named_pipe : public stream_behavior 
+class named_pipe : public stream 
 { 
 public: 
     enum stream_type { input_stream, output_stream }; 
 
-    capture_with_named_pipe(stream_type stream, std::string name = "") 
+    named_pipe(stream_type stream, std::string name = "") 
     { 
         native_type natives[2]; 
 #if defined(BOOST_POSIX_API) 
@@ -261,12 +280,17 @@
 #endif 
     } 
 
-    native_type get_child_end() const 
+    static boost::shared_ptr<named_pipe> def(stream_type stream) 
+    { 
+        return boost::make_shared<named_pipe>(named_pipe(stream)); 
+    } 
+
+    native_type get_child_end() 
     { 
         return child_end_; 
     } 
 
-    native_type get_parent_end() const 
+    native_type get_parent_end() 
     { 
         return parent_end_; 
     } 
@@ -282,12 +306,12 @@
  * A child process will be able to use streams. But data written to an 
  * output stream is discarded and data read from an input stream is 0.
  */
-class mute : public stream_behavior 
+class dummy : public stream 
 { 
 public: 
     enum stream_type { input_stream, output_stream }; 
 
-    mute(stream_type stream) 
+    dummy(stream_type stream) 
     { 
 #if defined(BOOST_POSIX_API) 
         std::string filename = (stream == input_stream) ? "/dev/zero" : "/dev/null"; 
@@ -301,7 +325,12 @@
 #endif 
     } 
 
-    native_type get_child_end() const 
+    static boost::shared_ptr<dummy> def(stream_type stream) 
+    { 
+        return boost::make_shared<dummy>(dummy(stream)); 
+    } 
+
+    native_type get_child_end() 
     { 
         return child_end_; 
     } 
@@ -312,5 +341,6 @@
 
 }
 }
+}
 
 #endif

Deleted: sandbox/SOC/2010/process/libs/process/example/child_stdin.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/child_stdin.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
+++ (empty file)
@@ -1,27 +0,0 @@
-//
-// Boost.Process
-// ~~~~~~~~~~~~~
-//
-// Copyright (c) 2006, 2007 Julio M. Merino Vidal
-// Copyright (c) 2008, 2009 Boris Schaeling
-// Copyright (c) 2010 Felipe Tanus, Boris Schaeling
-//
-// 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 <boost/process/all.hpp> 
-#include <string> 
-#include <iostream> 
-
-using namespace boost::process; 
-
-int main() 
-{ 
-    std::string exe = find_executable_in_path("ftp"); 
-    context ctx; 
-    ctx.stdin_behavior = boost::make_shared<capture>(capture(capture::input_stream)); 
-    child c = create_child(exe, ctx); 
-    postream &os = c.get_stdin(); 
-    os << "quit" << std::endl; 
-} 

Deleted: sandbox/SOC/2010/process/libs/process/example/child_stdout.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/child_stdout.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
+++ (empty file)
@@ -1,30 +0,0 @@
-//
-// Boost.Process
-// ~~~~~~~~~~~~~
-//
-// Copyright (c) 2006, 2007 Julio M. Merino Vidal
-// Copyright (c) 2008, 2009 Boris Schaeling
-// Copyright (c) 2010 Felipe Tanus, Boris Schaeling
-//
-// 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 <boost/process/all.hpp> 
-#include <boost/make_shared.hpp> 
-#include <string> 
-#include <iostream> 
-
-using namespace boost::process; 
-
-int main() 
-{ 
-    std::string exe = find_executable_in_path("hostname"); 
-    context ctx; 
-    ctx.stdout_behavior = boost::make_shared<capture>(capture(capture::output_stream)); 
-    child c = create_child(exe, ctx); 
-    pistream &is = c.get_stdout(); 
-    std::string hostname; 
-    is >> hostname; 
-    std::cout << hostname << std::endl; 
-} 

Modified: sandbox/SOC/2010/process/libs/process/example/create_process.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/create_process.cpp	(original)
+++ sandbox/SOC/2010/process/libs/process/example/create_process.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -1,4 +1,4 @@
-/
+//
 // Boost.Process
 // ~~~~~~~~~~~~~
 //
@@ -11,6 +11,7 @@
 //
 
 #include <boost/process/all.hpp> 
+#include <boost/make_shared.hpp> 
 #include <boost/assign/list_of.hpp> 
 #include <vector> 
 #include <string> 
@@ -27,11 +28,7 @@
 
     context ctx; 
     ctx.environment.insert(std::make_pair("NEW_ENV_VARIABLE", "VALUE")); 
-    
-    ctx.stdin_behavior = boost::make_shared<close>(close());
-    ctx.stdout_behavior = boost::make_shared<close>(close()); 
+    ctx.stdin_behavior = behavior::close::def();
+    ctx.stdout_behavior = behavior::close::def(); 
     child c3 = create_child(find_executable_in_path("hostname"), args, ctx); 
-
-    int x;
-    std::cin >> x;
 } 

Modified: sandbox/SOC/2010/process/libs/process/example/read_async_from_child.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/read_async_from_child.cpp	(original)
+++ sandbox/SOC/2010/process/libs/process/example/read_async_from_child.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -10,10 +10,9 @@
 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
 //
 
-#include <boost/all/process.hpp> 
 #include <boost/asio.hpp> 
+#include <boost/process/all.hpp> 
 #include <boost/array.hpp> 
-#include <boost/bind.hpp> 
 #include <string> 
 #include <iostream> 
 
@@ -23,31 +22,21 @@
 io_service ioservice; 
 boost::array<char, 4096> buf; 
 
-void begin_read(pipe &read_end); 
-void end_read(const boost::system::error_code &ec, std::size_t bytes_transferred, pipe &read_end); 
+void handler(const boost::system::error_code &ec, std::size_t bytes_transferred); 
 
 int main() 
 { 
     std::string exe = find_executable_in_path("hostname"); 
     context ctx; 
-    ctx.stdout_behavior = boost::make_shared<capture>(capture(capture::output_stream)); ; 
+    ctx.stdout_behavior = behavior::named_pipe::def(behavior::named_pipe::output_stream); 
     child c = create_child(exe, ctx); 
     pistream &is = c.get_stdout(); 
-    pipe read_end(ioservice, is.native()); 
-    begin_read(read_end); 
+    pipe read_end(ioservice, is.native().release()); 
+    read_end.async_read_some(buffer(buf), handler); 
     ioservice.run(); 
 } 
 
-void begin_read(pipe &read_end) 
+void handler(const boost::system::error_code &ec, std::size_t bytes_transferred) 
 { 
-    read_end.async_read_some(buffer(buf), boost::bind(&end_read, placeholders::error, placeholders::bytes_transferred, read_end)); 
-} 
-
-void end_read(const boost::system::error_code &ec, std::size_t bytes_transferred, pipe &read_end) 
-{ 
-    if (!ec) 
-    { 
-      std::cout << std::string(buf.data(), bytes_transferred) << std::flush; 
-      begin_read(read_end); 
-    } 
+    std::cout << std::string(buf.data(), bytes_transferred) << std::flush; 
 } 

Modified: sandbox/SOC/2010/process/libs/process/example/read_from_child.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/read_from_child.cpp	(original)
+++ sandbox/SOC/2010/process/libs/process/example/read_from_child.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -10,7 +10,7 @@
 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
 //
 
-#include <boost/all/process.hpp> 
+#include <boost/process/all.hpp> 
 #include <string> 
 #include <iostream> 
 
@@ -19,7 +19,11 @@
 int main() 
 { 
     std::string exe = find_executable_in_path("hostname"); 
-    child c = create_child(exe); 
+    context ctx; 
+    ctx.stdout_behavior = behavior::pipe::def(behavior::pipe::output_stream); 
+    child c = create_child(exe, ctx); 
     pistream &is = c.get_stdout(); 
-    std::cout << is.rdbuf(); 
+    std::string hostname; 
+    is >> hostname; 
+    std::cout << hostname << std::endl; 
 } 

Deleted: sandbox/SOC/2010/process/libs/process/example/wait_child.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/wait_child.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
+++ (empty file)
@@ -1,26 +0,0 @@
-//
-// Boost.Process
-// ~~~~~~~~~~~~~
-//
-// Copyright (c) 2006, 2007 Julio M. Merino Vidal
-// Copyright (c) 2008, 2009 Boris Schaeling
-// Copyright (c) 2010 Felipe Tanus, Boris Schaeling
-//
-// 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 <boost/process/all.hpp> 
-#include <string> 
-#include <iostream> 
-
-using namespace boost::process; 
-
-int main() 
-{ 
-    std::string exe = find_executable_in_path("hostname"); 
-    child c = create_child(exe); 
-    status s = c.wait(); 
-    if (s.exited()) 
-        std::cout << s.exit_code() << std::endl; 
-} 

Modified: sandbox/SOC/2010/process/libs/process/example/write_async_to_child.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/write_async_to_child.cpp	(original)
+++ sandbox/SOC/2010/process/libs/process/example/write_async_to_child.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -10,31 +10,30 @@
 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
 //
 
-#include <boost/all/process.hpp> 
 #include <boost/asio.hpp> 
+#include <boost/process/all.hpp> 
 #include <boost/bind.hpp> 
 #include <string> 
-#include <iostream> 
 
 using namespace boost::process; 
 using namespace boost::asio; 
 
 io_service ioservice; 
 
-void end_write(const boost::system::error_code &ec); 
+void handler(const boost::system::error_code &ec, std::size_t bytes_transferred); 
 
 int main() 
 { 
     std::string exe = find_executable_in_path("ftp"); 
     context ctx; 
-    ctx.stdin_behavior = boost::make_shared<capture>(capture(capture::input_stream)); ; 
+    ctx.stdin_behavior = behavior::named_pipe::def(behavior::named_pipe::input_stream); 
     child c = create_child(exe, ctx); 
     postream &os = c.get_stdin(); 
-    pipe write_end(ioservice, os.native()); 
-    async_write(write_end, buffer("quit\n"), boost::bind(&end_write, placeholders::error)); 
+    pipe write_end(ioservice, os.native().release()); 
+    async_write(write_end, buffer("quit\n"), handler); 
     ioservice.run(); 
 } 
 
-void end_write(const boost::system::error_code &ec) 
+void handler(const boost::system::error_code &ec, std::size_t bytes_transferred) 
 { 
 } 

Modified: sandbox/SOC/2010/process/libs/process/example/write_to_child.cpp
==============================================================================
--- sandbox/SOC/2010/process/libs/process/example/write_to_child.cpp	(original)
+++ sandbox/SOC/2010/process/libs/process/example/write_to_child.cpp	2010-06-19 14:18:59 EDT (Sat, 19 Jun 2010)
@@ -10,7 +10,7 @@
 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
 //
 
-#include <boost/all/process.hpp> 
+#include <boost/process/all.hpp> 
 #include <string> 
 #include <iostream> 
 
@@ -20,7 +20,7 @@
 { 
     std::string exe = find_executable_in_path("ftp"); 
     context ctx; 
-    ctx.stdin_behavior = boost::make_shared<capture>(capture(capture::input_stream));  
+    ctx.stdin_behavior = behavior::pipe::def(behavior::pipe::input_stream); 
     child c = create_child(exe, ctx); 
     postream &os = c.get_stdin(); 
     os << "quit" << std::endl;