summaryrefslogtreecommitdiff
path: root/boost/process/detail/windows/group_handle.hpp
diff options
context:
space:
mode:
authorDongHun Kwak <dh0128.kwak@samsung.com>2017-09-13 11:08:07 +0900
committerDongHun Kwak <dh0128.kwak@samsung.com>2017-09-13 11:09:00 +0900
commitb5c87084afaef42b2d058f68091be31988a6a874 (patch)
treeadef9a65870a41181687e11d57fdf98e7629de3c /boost/process/detail/windows/group_handle.hpp
parent34bd32e225e2a8a94104489b31c42e5801cc1f4a (diff)
downloadboost-b5c87084afaef42b2d058f68091be31988a6a874.tar.gz
boost-b5c87084afaef42b2d058f68091be31988a6a874.tar.bz2
boost-b5c87084afaef42b2d058f68091be31988a6a874.zip
Imported Upstream version 1.64.0upstream/1.64.0
Change-Id: Id9212edd016dd55f21172c427aa7894d1d24148b Signed-off-by: DongHun Kwak <dh0128.kwak@samsung.com>
Diffstat (limited to 'boost/process/detail/windows/group_handle.hpp')
-rw-r--r--boost/process/detail/windows/group_handle.hpp191
1 files changed, 191 insertions, 0 deletions
diff --git a/boost/process/detail/windows/group_handle.hpp b/boost/process/detail/windows/group_handle.hpp
new file mode 100644
index 0000000000..e289263cad
--- /dev/null
+++ b/boost/process/detail/windows/group_handle.hpp
@@ -0,0 +1,191 @@
+// 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_WINDOWS_GROUP_HPP_
+#define BOOST_PROCESS_DETAIL_WINDOWS_GROUP_HPP_
+
+#include <boost/process/detail/windows/handler.hpp>
+#include <boost/detail/winapi/jobs.hpp>
+#include <boost/process/detail/windows/child_handle.hpp>
+#include <boost/process/detail/windows/job_workaround.hpp>
+#include <system_error>
+
+namespace boost { namespace process { namespace detail { namespace windows {
+
+inline bool break_away_enabled(::boost::detail::winapi::HANDLE_ h)
+{
+ workaround::JOBOBJECT_EXTENDED_LIMIT_INFORMATION_ info;
+
+ if (!workaround::query_information_job_object(
+ h,
+ workaround::JobObjectExtendedLimitInformation_,
+ static_cast<void*>(&info),
+ sizeof(info),
+ nullptr))
+ throw_last_error("QueryInformationJobObject() failed");
+
+ return (info.BasicLimitInformation.LimitFlags & workaround::JOB_OBJECT_LIMIT_BREAKAWAY_OK_) != 0;
+}
+
+inline void enable_break_away(::boost::detail::winapi::HANDLE_ h)
+{
+ workaround::JOBOBJECT_EXTENDED_LIMIT_INFORMATION_ info;
+
+ if (!workaround::query_information_job_object(
+ h,
+ workaround::JobObjectExtendedLimitInformation_,
+ static_cast<void*>(&info),
+ sizeof(info),
+ nullptr))
+ throw_last_error("QueryInformationJobObject() failed");
+
+ if ((info.BasicLimitInformation.LimitFlags & workaround::JOB_OBJECT_LIMIT_BREAKAWAY_OK_) != 0)
+ return;
+
+ info.BasicLimitInformation.LimitFlags |= workaround::JOB_OBJECT_LIMIT_BREAKAWAY_OK_;
+
+ if (!workaround::set_information_job_object(
+ h,
+ workaround::JobObjectExtendedLimitInformation_,
+ static_cast<void*>(&info),
+ sizeof(info)))
+ throw_last_error("SetInformationJobObject() failed");
+}
+
+inline void enable_break_away(::boost::detail::winapi::HANDLE_ h, std::error_code & ec)
+{
+ workaround::JOBOBJECT_EXTENDED_LIMIT_INFORMATION_ info;
+
+
+ if (!workaround::query_information_job_object(
+ h,
+ workaround::JobObjectExtendedLimitInformation_,
+ static_cast<void*>(&info),
+ sizeof(info),
+ nullptr))
+ {
+ ec = get_last_error();
+ return;
+ }
+
+ if ((info.BasicLimitInformation.LimitFlags & workaround::JOB_OBJECT_LIMIT_BREAKAWAY_OK_) != 0)
+ return;
+
+ info.BasicLimitInformation.LimitFlags |= workaround::JOB_OBJECT_LIMIT_BREAKAWAY_OK_;
+
+ if (!workaround::set_information_job_object(
+ h,
+ workaround::JobObjectExtendedLimitInformation_,
+ static_cast<void*>(&info),
+ sizeof(info)))
+ {
+ ec = get_last_error();
+ return;
+ }
+
+
+}
+
+
+struct group_handle
+{
+ ::boost::detail::winapi::HANDLE_ _job_object;
+
+ typedef ::boost::detail::winapi::HANDLE_ handle_t;
+ handle_t handle() const { return _job_object; }
+
+ explicit group_handle(handle_t h) :
+ _job_object(h)
+ {
+ enable_break_away(_job_object);
+ }
+
+
+ group_handle() : group_handle(::boost::detail::winapi::CreateJobObjectA(nullptr, nullptr))
+ {
+
+ }
+ ~group_handle()
+ {
+ ::boost::detail::winapi::CloseHandle(_job_object);
+ }
+ group_handle(const group_handle & c) = delete;
+ group_handle(group_handle && c) : _job_object(c._job_object)
+ {
+ c._job_object = ::boost::detail::winapi::invalid_handle_value;
+ }
+ group_handle &operator=(const group_handle & c) = delete;
+ group_handle &operator=(group_handle && c)
+ {
+
+ ::boost::detail::winapi::CloseHandle(_job_object);
+ _job_object = c._job_object;
+ c._job_object = ::boost::detail::winapi::invalid_handle_value;
+ return *this;
+ }
+
+ void add(handle_t proc)
+ {
+ if (!::boost::detail::winapi::AssignProcessToJobObject(_job_object, proc))
+ throw_last_error();
+ }
+ void add(handle_t proc, std::error_code & ec) noexcept
+ {
+ if (!::boost::detail::winapi::AssignProcessToJobObject(_job_object, proc))
+ ec = get_last_error();
+ }
+
+ bool has(handle_t proc)
+ {
+ ::boost::detail::winapi::BOOL_ is;
+ if (!::boost::detail::winapi::IsProcessInJob(proc, _job_object, &is))
+ throw_last_error();
+
+ return is!=0;
+ }
+ bool has(handle_t proc, std::error_code & ec) noexcept
+ {
+ ::boost::detail::winapi::BOOL_ is;
+ if (!::boost::detail::winapi::IsProcessInJob(proc, _job_object, &is))
+ ec = get_last_error();
+ return is!=0;
+ }
+
+ bool valid() const
+ {
+ return _job_object != nullptr;
+ }
+
+};
+
+inline void terminate(const group_handle &p)
+{
+ if (!::boost::detail::winapi::TerminateJobObject(p.handle(), EXIT_FAILURE))
+ boost::process::detail::throw_last_error("TerminateJobObject() failed");
+}
+
+inline void terminate(const group_handle &p, std::error_code &ec) noexcept
+{
+ if (!::boost::detail::winapi::TerminateJobObject(p.handle(), EXIT_FAILURE))
+ ec = boost::process::detail::get_last_error();
+ else
+ ec.clear();
+}
+
+inline bool in_group()
+{
+ ::boost::detail::winapi::BOOL_ res;
+ if (!::boost::detail::winapi::IsProcessInJob(boost::detail::winapi::GetCurrentProcess(), nullptr, &res))
+ throw_last_error("IsProcessInJob failed");
+
+ return res!=0;
+}
+
+
+
+}}}}
+
+
+#endif /* BOOST_PROCESS_DETAIL_WINDOWS_GROUP_HPP_ */