ceph/src/boost/boost/process/detail/posix/pipe_out.hpp

   1 // Copyright (c) 2006, 2007 Julio M. Merino Vidal
   2 // Copyright (c) 2008 Ilya Sokolov, Boris Schaeling
   3 // Copyright (c) 2009 Boris Schaeling
   4 // Copyright (c) 2010 Felipe Tanus, Boris Schaeling
   5 // Copyright (c) 2011, 2012 Jeff Flinn, Boris Schaeling
   6 // Copyright (c) 2016 Klemens D. Morgenstern
   7 //
   8 // Distributed under the Boost Software License, Version 1.0. (See accompanying
   9 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  10
  11 #ifndef BOOST_PROCESS_DETAIL_POSIX_PIPE_OUT_HPP
  12 #define BOOST_PROCESS_DETAIL_POSIX_PIPE_OUT_HPP
  13
  14 #include <boost/process/pipe.hpp>
  15 #include <boost/process/detail/posix/handler.hpp>
  16 #include <unistd.h>
  17
  18 namespace boost { namespace process { namespace detail { namespace posix {
  19
  20 template<int p1, int p2>
  21 struct pipe_out : handler_base_ext
  22 {
  23     int sink;
  24     int source; //opposite end
  25
  26     pipe_out(int sink, int source) : sink(sink), source(source) {}
  27
  28     template<typename T>
  29     pipe_out(T & p) : sink(p.native_sink()), source(p.native_source())
  30     {
  31         p.assign_sink(-1);
  32     }
  33
  34     template<typename Executor>
  35     void on_error(Executor &, const std::error_code &) const
  36     {
  37         ::close(sink);
  38     }
  39
  40     template<typename Executor>
  41     void on_success(Executor &) const
  42     {
  43         ::close(sink);
  44     }
  45
  46     template <typename Executor>
  47     void on_exec_setup(Executor &e) const;
  48 };
  49
  50 template<>
  51 template<typename Executor>
  52 void pipe_out<1,-1>::on_exec_setup(Executor &e) const
  53 {
  54     if (::dup2(sink, STDOUT_FILENO) == -1)
  55          e.set_error(::boost::process::detail::get_last_error(), "dup3() failed");
  56     ::close(sink);
  57     ::close(source);
  58 }
  59
  60 template<>
  61 template<typename Executor>
  62 void pipe_out<2,-1>::on_exec_setup(Executor &e) const
  63 {
  64     if (::dup2(sink, STDERR_FILENO) == -1)
  65          e.set_error(::boost::process::detail::get_last_error(), "dup2() failed");
  66     ::close(sink);
  67     ::close(source);
  68 }
  69
  70 template<>
  71 template<typename Executor>
  72 void pipe_out<1,2>::on_exec_setup(Executor &e) const
  73 {
  74     if (::dup2(sink, STDOUT_FILENO) == -1)
  75          e.set_error(::boost::process::detail::get_last_error(), "dup2() failed");
  76     if (::dup2(sink, STDERR_FILENO) == -1)
  77          e.set_error(::boost::process::detail::get_last_error(), "dup2() failed");
  78     ::close(sink);
  79     ::close(source);
  80 }
  81
  82 class async_pipe;
  83
  84 template<int p1, int p2>
  85 struct async_pipe_out : public pipe_out<p1, p2>
  86 {
  87     async_pipe &pipe;
  88     template<typename AsyncPipe>
  89     async_pipe_out(AsyncPipe & p) : pipe_out<p1, p2>(p.native_sink(), p.native_source()), pipe(p)
  90     {
  91     }
  92
  93     template<typename Pipe, typename Executor>
  94     static void close(Pipe & pipe, Executor &)
  95     {
  96         boost::system::error_code ec;
  97         std::move(pipe).sink().close(ec);
  98     }
  99
 100     template<typename Executor>
 101     void on_error(Executor & exec, const std::error_code &)
 102     {
 103         close(pipe, exec);
 104     }
 105
 106     template<typename Executor>
 107     void on_success(Executor &exec)
 108     {
 109         close(pipe, exec);
 110     }
 111 };
 112
 113
 114 }}}}
 115
 116 #endif