Name	Size	Mode	Actions
asio_fwd.hpp	1342	0644	editdlrm
async_handler.hpp	1187	0644	editdlrm
async_in.hpp	3541	0644	editdlrm
async_out.hpp	5794	0644	editdlrm
async_pipe.hpp	11386	0644	editdlrm
basic_cmd.hpp	4551	0644	editdlrm
basic_pipe.hpp	5660	0644	editdlrm
child_handle.hpp	1432	0644	editdlrm
close_in.hpp	1053	0644	editdlrm
close_out.hpp	1735	0644	editdlrm
cmd.hpp	2531	0644	editdlrm
compare_handles.hpp	1029	0644	editdlrm
environment.hpp	9960	0644	editdlrm
env_init.hpp	979	0644	editdlrm
exe.hpp	569	0644	editdlrm
executor.hpp	15541	0644	editdlrm
fd.hpp	2621	0644	editdlrm
file_descriptor.hpp	1884	0644	editdlrm
file_in.hpp	1407	0644	editdlrm
file_out.hpp	2198	0644	editdlrm
group_handle.hpp	2068	0644	editdlrm
group_ref.hpp	1088	0644	editdlrm
handler.hpp	1739	0644	editdlrm
handles.hpp	3945	0644	editdlrm
io_context_ref.hpp	4036	0644	editdlrm
is_running.hpp	2304	0644	editdlrm
null_in.hpp	1305	0644	editdlrm
null_out.hpp	2089	0644	editdlrm
on_exit.hpp	1001	0644	editdlrm
pipe_in.hpp	2375	0644	editdlrm
pipe_out.hpp	3091	0644	editdlrm
search_path.hpp	1218	0644	editdlrm
shell_path.hpp	878	0644	editdlrm
sigchld_service.hpp	4102	0644	editdlrm
signal.hpp	1898	0644	editdlrm
start_dir.hpp	1093	0644	editdlrm
terminate.hpp	1199	0644	editdlrm
use_vfork.hpp	781	0644	editdlrm
wait_for_exit.hpp	6689	0644	editdlrm
wait_group.hpp	3423	0644	editdlrm

// Copyright (c) 2006, 2007 Julio M. Merino Vidal // Copyright (c) 2008 Ilya Sokolov, Boris Schaeling // Copyright (c) 2009 Boris Schaeling // Copyright (c) 2010 Felipe Tanus, Boris Schaeling // Copyright (c) 2011, 2012 Jeff Flinn, 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) #ifndef BOOST_PROCESS_POSIX_PIPE_HPP #define BOOST_PROCESS_POSIX_PIPE_HPP #include #include #include #include #include #include #include namespace boost { namespace process { namespace detail { namespace posix { template> class basic_pipe { int _source = -1; int _sink = -1; public: explicit basic_pipe(int source, int sink) : _source(source), _sink(sink) {} explicit basic_pipe(int source, int sink, const std::string&) : _source(source), _sink(sink) {} typedef CharT char_type ; typedef Traits traits_type; typedef typename Traits::int_type int_type ; typedef typename Traits::pos_type pos_type ; typedef typename Traits::off_type off_type ; typedef int native_handle_type; basic_pipe() { int fds[2]; if (::pipe(fds) == -1) boost::process::detail::throw_last_error("pipe(2) failed"); _source = fds[0]; _sink = fds[1]; } inline basic_pipe(const basic_pipe& rhs); explicit inline basic_pipe(const std::string& name); basic_pipe(basic_pipe&& lhs) : _source(lhs._source), _sink(lhs._sink) { lhs._source = -1; lhs._sink = -1; } inline basic_pipe& operator=(const basic_pipe& ); basic_pipe& operator=(basic_pipe&& lhs) { _source = lhs._source; _sink = lhs._sink ; lhs._source = -1; lhs._sink = -1; return *this; } ~basic_pipe() { if (_sink != -1) ::close(_sink); if (_source != -1) ::close(_source); } native_handle_type native_source() const {return _source;} native_handle_type native_sink () const {return _sink;} void assign_source(native_handle_type h) { _source = h;} void assign_sink (native_handle_type h) { _sink = h;} int_type write(const char_type * data, int_type count) { int_type write_len; while ((write_len = ::write(_sink, data, count * sizeof(char_type))) == -1) { //Try again if interrupted auto err = errno; if (err != EINTR) ::boost::process::detail::throw_last_error(); } return write_len; } int_type read(char_type * data, int_type count) { int_type read_len; while ((read_len = ::read(_source, data, count * sizeof(char_type))) == -1) { //Try again if interrupted auto err = errno; if (err != EINTR) ::boost::process::detail::throw_last_error(); } return read_len; } bool is_open() const { return (_source != -1) || (_sink != -1); } void close() { if (_source != -1) ::close(_source); if (_sink != -1) ::close(_sink); _source = -1; _sink = -1; } }; template basic_pipe::basic_pipe(const basic_pipe & rhs) { if (rhs._source != -1) { _source = ::dup(rhs._source); if (_source == -1) ::boost::process::detail::throw_last_error("dup() failed"); } if (rhs._sink != -1) { _sink = ::dup(rhs._sink); if (_sink == -1) ::boost::process::detail::throw_last_error("dup() failed"); } } template basic_pipe &basic_pipe::operator=(const basic_pipe & rhs) { if (rhs._source != -1) { _source = ::dup(rhs._source); if (_source == -1) ::boost::process::detail::throw_last_error("dup() failed"); } if (rhs._sink != -1) { _sink = ::dup(rhs._sink); if (_sink == -1) ::boost::process::detail::throw_last_error("dup() failed"); } return *this; } template basic_pipe::basic_pipe(const std::string & name) { auto fifo = mkfifo(name.c_str(), 0666 ); if (fifo != 0) boost::process::detail::throw_last_error("mkfifo() failed"); int read_fd = open(name.c_str(), O_RDWR); if (read_fd == -1) boost::process::detail::throw_last_error(); int write_fd = dup(read_fd); if (write_fd == -1) boost::process::detail::throw_last_error(); _sink = write_fd; _source = read_fd; ::unlink(name.c_str()); } template inline bool operator==(const basic_pipe & lhs, const basic_pipe & rhs) { return compare_handles(lhs.native_source(), rhs.native_source()) && compare_handles(lhs.native_sink(), rhs.native_sink()); } template inline bool operator!=(const basic_pipe & lhs, const basic_pipe & rhs) { return !compare_handles(lhs.native_source(), rhs.native_source()) || !compare_handles(lhs.native_sink(), rhs.native_sink()); } }}}} #endif