izackp/Apollo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix steam not shutting down

Browse Source
This commit is contained in:
loki
2019-12-15 22:47:55 +01:00
parent b7eab0883c
commit 059adc905d
2 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sunshine/process.cpp
+8 -11
View File
@@ -22,19 +22,16 @@ namespace pt = boost::property_tree;
proc_t proc; proc_t proc;
template<class Rep, class Period> template<class Rep, class Period>
void process_end(bp::child &proc, const std::chrono::duration<Rep, Period>& rel_time) { void process_end(bp::child &proc, bp::group &proc_handle, const std::chrono::duration<Rep, Period>& rel_time) {
if(!proc.running()) { if(!proc.running()) {
return; return;
} }
std::cout << "Interruping Child-Process"sv << std::endl; std::cout << "Force termination Child-Process"sv << std::endl;
platf::terminate_process((std::uint64_t) proc.native_handle()); proc_handle.terminate();
// Force termination if it takes too long // avoid zombie process
if(!proc.wait_for(rel_time)) { proc.wait();
std::cout << "Force termination Child-Process"sv << std::endl;
proc.terminate();
}
} }
int exe(const std::string &cmd, bp::environment &env, file_t &file, std::error_code &ec) { int exe(const std::string &cmd, bp::environment &env, file_t &file, std::error_code &ec) {
@@ -92,10 +89,10 @@ int proc_t::execute(const std::string &name) {
std::cout << "Starting ["sv << proc.cmd << ']' << std::endl; std::cout << "Starting ["sv << proc.cmd << ']' << std::endl;
if(proc.output.empty() || proc.output == "null"sv) { if(proc.output.empty() || proc.output == "null"sv) {
_process = bp::child(proc.cmd, _env, bp::std_out > bp::null, bp::std_err > bp::null, ec); _process = bp::child(_process_handle, proc.cmd, _env, bp::std_out > bp::null, bp::std_err > bp::null, ec);
} }
else { else {
_process = bp::child(proc.cmd, _env, bp::std_out > _pipe.get(), bp::std_err > _pipe.get(), ec); _process = bp::child(_process_handle, proc.cmd, _env, bp::std_out > _pipe.get(), bp::std_err > _pipe.get(), ec);
} }
if(ec) { if(ec) {
@@ -116,7 +113,7 @@ void proc_t::_undo_pre_cmd() {
std::error_code ec; std::error_code ec;
// Ensure child process is terminated // Ensure child process is terminated
process_end(_process, 10s); process_end(_process, _process_handle, 10s);
if(ec) { if(ec) {
std::cout << "FATAL Error: System: "sv << ec.message() << std::endl; std::cout << "FATAL Error: System: "sv << ec.message() << std::endl;
sunshine/process.h
+2
View File
@@ -64,6 +64,8 @@ private:
std::unordered_map<std::string, ctx_t> _name_to_proc; std::unordered_map<std::string, ctx_t> _name_to_proc;
boost::process::child _process; boost::process::child _process;
boost::process::group _process_handle;
file_t _pipe; file_t _pipe;
std::vector<cmd_t>::const_iterator _undo_it; std::vector<cmd_t>::const_iterator _undo_it;
std::vector<cmd_t>::const_iterator _undo_begin; std::vector<cmd_t>::const_iterator _undo_begin;