FM / windows

/usr/include/boost/process/detail/windows/

/usr/include/boost/process/detail/windows

Name	Size	Mode	Actions
asio_fwd.hpp	1354	0644	edit dl rm
async_handler.hpp	1195	0644	edit dl rm
async_in.hpp	3557	0644	edit dl rm
async_out.hpp	6079	0644	edit dl rm
async_pipe.hpp	17611	0644	edit dl rm
basic_cmd.hpp	5072	0644	edit dl rm
basic_pipe.hpp	8451	0644	edit dl rm
child_handle.hpp	3185	0644	edit dl rm
close_in.hpp	1040	0644	edit dl rm
close_out.hpp	1743	0644	edit dl rm
cmd.hpp	993	0644	edit dl rm
compare_handles.hpp	1488	0644	edit dl rm
environment.hpp	10976	0644	edit dl rm
env_init.hpp	1615	0644	edit dl rm
executor.hpp	8045	0644	edit dl rm
file_descriptor.hpp	3747	0644	edit dl rm
file_in.hpp	1735	0644	edit dl rm
file_out.hpp	2691	0644	edit dl rm
group_handle.hpp	6527	0644	edit dl rm
group_ref.hpp	1572	0644	edit dl rm
handler.hpp	566	0644	edit dl rm
handles.hpp	5746	0644	edit dl rm
handle_workaround.hpp	8924	0644	edit dl rm
io_context_ref.hpp	5043	0644	edit dl rm
is_running.hpp	1411	0644	edit dl rm
job_workaround.hpp	9721	0644	edit dl rm
locale.hpp	3154	0644	edit dl rm
null_in.hpp	1559	0644	edit dl rm
null_out.hpp	2576	0644	edit dl rm
on_exit.hpp	1202	0644	edit dl rm
pipe_in.hpp	2571	0644	edit dl rm
pipe_out.hpp	3535	0644	edit dl rm
search_path.hpp	2808	0644	edit dl rm
shell_path.hpp	1568	0644	edit dl rm
show_window.hpp	1308	0644	edit dl rm
start_dir.hpp	1026	0644	edit dl rm
terminate.hpp	1329	0644	edit dl rm
wait_for_exit.hpp	4048	0644	edit dl rm
wait_group.hpp	4337	0644	edit dl rm

Edit: /usr/include/boost/process/detail/windows/wait_group.hpp (4337B)

// 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_WAIT_GROUP_HPP_
#define BOOST_PROCESS_DETAIL_WINDOWS_WAIT_GROUP_HPP_

#include <boost/process/detail/config.hpp>
#include <boost/process/detail/windows/group_handle.hpp>
#include <boost/winapi/jobs.hpp>
#include <boost/winapi/wait.hpp>
#include <chrono>

namespace boost { namespace process { namespace detail { namespace windows {

struct group_handle;

inline bool wait_impl(const group_handle & p, std::error_code & ec, std::chrono::system_clock::rep wait_time)
{
    ::boost::winapi::DWORD_ completion_code;
    ::boost::winapi::ULONG_PTR_ completion_key;
    ::boost::winapi::LPOVERLAPPED_ overlapped;

auto start_time = std::chrono::system_clock::now();

while (workaround::get_queued_completion_status(
                                       p._io_port, &completion_code,
                                       &completion_key, &overlapped, static_cast<::boost::winapi::DWORD_>(wait_time)))
    {
        if (reinterpret_cast<::boost::winapi::HANDLE_>(completion_key) == p._job_object &&
             completion_code == workaround::JOB_OBJECT_MSG_ACTIVE_PROCESS_ZERO_)
        {

//double check, could be a different handle from a child
            workaround::JOBOBJECT_BASIC_ACCOUNTING_INFORMATION_ info;
            if (!workaround::query_information_job_object(
                    p._job_object,
                    workaround::JobObjectBasicAccountingInformation_,
                    static_cast<void *>(&info),
                    sizeof(info), nullptr))
            {
                ec = get_last_error();
                return false;
            }
            else if (info.ActiveProcesses == 0)
                return false; //correct, nothing left.
        }
        //reduce the remaining wait time -> in case interrupted by something else
        if (wait_time != static_cast<int>(::boost::winapi::infinite))
        {
            auto now = std::chrono::system_clock::now();
            auto diff = std::chrono::duration_cast<std::chrono::milliseconds>(now - start_time);
            wait_time -= static_cast<std::chrono::system_clock::rep>(diff.count());
            start_time = now;
            if (wait_time <= 0)
                return true; //timeout with other source
        }

}

auto ec_ = get_last_error();
    if (ec_.value() == ::boost::winapi::wait_timeout)
        return true; //timeout

ec = ec_;
    return false;
}

inline void wait(const group_handle &p, std::error_code &ec)
{
    wait_impl(p, ec, ::boost::winapi::infinite);
}

inline void wait(const group_handle &p)
{
    std::error_code ec;
    wait(p, ec);
    boost::process::detail::throw_error(ec, "wait error");
}

template< class Clock, class Duration >
inline bool wait_until(
        const group_handle &p,
        const std::chrono::time_point<Clock, Duration>& timeout_time,
        std::error_code &ec)
{
    std::chrono::milliseconds ms =
            std::chrono::duration_cast<std::chrono::milliseconds>(
                    timeout_time - Clock::now());

auto timeout = wait_impl(p, ec, ms.count());
    return !ec && !timeout;
}

template< class Clock, class Duration >
inline bool wait_until(
        const group_handle &p,
        const std::chrono::time_point<Clock, Duration>& timeout_time)
{
    std::error_code ec;
    bool b = wait_until(p, timeout_time, ec);
    boost::process::detail::throw_error(ec, "wait_until error");
    return b;
}

template< class Rep, class Period >
inline bool wait_for(
        const group_handle &p,
        const std::chrono::duration<Rep, Period>& rel_time,
        std::error_code &ec)
{
    auto ms = std::chrono::duration_cast<std::chrono::milliseconds>(rel_time);
    auto timeout = wait_impl(p, ec, ms.count());
    return !ec && !timeout;
}

template< class Rep, class Period >
inline bool wait_for(
        const group_handle &p,
        const std::chrono::duration<Rep, Period>& rel_time)
{
    std::error_code ec;
    bool b = wait_for(p, rel_time, ec);
    boost::process::detail::throw_error(ec, "wait_for error");
    return b;
}

}}}}

#endif /* BOOST_PROCESS_DETAIL_WINDOWS_WAIT_GROUP_HPP_ */

cmd: