summaryrefslogtreecommitdiff
path: root/boost/process/detail/posix/group_handle.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'boost/process/detail/posix/group_handle.hpp')
-rw-r--r--boost/process/detail/posix/group_handle.hpp103
1 files changed, 103 insertions, 0 deletions
diff --git a/boost/process/detail/posix/group_handle.hpp b/boost/process/detail/posix/group_handle.hpp
new file mode 100644
index 0000000000..856b36a6b0
--- /dev/null
+++ b/boost/process/detail/posix/group_handle.hpp
@@ -0,0 +1,103 @@
+// Copyright (c) 2016 Klemens D. Morgenstern
+//
+// 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_DETAIL_POSIX_GROUP_HPP_
+#define BOOST_PROCESS_DETAIL_POSIX_GROUP_HPP_
+
+#include <boost/process/detail/posix/child_handle.hpp>
+#include <system_error>
+#include <unistd.h>
+
+namespace boost { namespace process { namespace detail { namespace posix {
+
+
+
+struct group_handle
+{
+ pid_t grp = -1;
+
+ typedef pid_t handle_t;
+ handle_t handle() const { return grp; }
+
+ explicit group_handle(handle_t h) :
+ grp(h)
+ {
+ }
+
+
+ group_handle() = default;
+
+ ~group_handle() = default;
+ group_handle(const group_handle & c) = delete;
+ group_handle(group_handle && c) : grp(c.grp)
+ {
+ c.grp = -1;
+ }
+ group_handle &operator=(const group_handle & c) = delete;
+ group_handle &operator=(group_handle && c)
+ {
+
+ grp = c.grp;
+ c.grp = -1;
+ return *this;
+ }
+
+ void add(handle_t proc)
+ {
+ if (::setpgid(proc, grp))
+ throw_last_error();
+ }
+ void add(handle_t proc, std::error_code & ec) noexcept
+ {
+ if (::setpgid(proc, grp))
+ ec = get_last_error();
+ }
+
+ bool has(handle_t proc)
+ {
+ return ::getpgid(proc) == grp;
+ }
+ bool has(handle_t proc, std::error_code & ec) noexcept
+ {
+ return ::getpgid(proc) == grp;
+
+ }
+
+ bool valid() const
+ {
+ return grp != -1;
+ }
+
+};
+
+inline void terminate(group_handle &p)
+{
+ if (::killpg(p.grp, SIGKILL) == -1)
+ boost::process::detail::throw_last_error("killpg(2) failed");
+ p.grp = -1;
+}
+
+inline void terminate(group_handle &p, std::error_code &ec) noexcept
+{
+ if (::killpg(p.grp, SIGKILL) == -1)
+ ec = boost::process::detail::get_last_error();
+ else
+ ec.clear();
+
+ p.grp = -1;
+}
+
+
+inline bool in_group()
+{
+ return true;
+}
+
+
+
+}}}}
+
+
+#endif /* BOOST_PROCESS_DETAIL_WINDOWS_GROUP_HPP_ */