fujin/rtorrent
1
0
Fork 0
mirror of https://github.com/rakshasa/rtorrent.git synced 2026-10-21 00:26:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Stuff.

Browse Source
This commit is contained in:
rakshasa
2026-08-04 10:47:23 +02:00
parent ebe28e07b1
commit 5ab973504a
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/utils/waitpid_queue.cc
+6 -6
View File
@@ -22,7 +22,7 @@ WaitpidQueue::WaitpidQueue() {
if (elapsed >= wait_time) if (elapsed >= wait_time)
break; break;
std::this_thread::sleep_for(100ms); std::this_thread::sleep_for(50ms);
} }
} else { } else {
@@ -49,7 +49,7 @@ WaitpidQueue::WaitpidQueue() {
m_wakeup_worker.store(false, std::memory_order_release); m_wakeup_worker.store(false, std::memory_order_release);
} }
wait_time = std::max(10s, wait_time * 2); wait_time = std::min(10s, wait_time * 2);
for (int pid : queue) { for (int pid : queue) {
if (::waitpid(pid, nullptr, WNOHANG) == 0) if (::waitpid(pid, nullptr, WNOHANG) == 0)
@@ -98,10 +98,10 @@ WaitpidQueue::close_pid(pid_t pid) {
{ {
std::lock_guard<std::mutex> guard(m_mutex); std::lock_guard<std::mutex> guard(m_mutex);
if (!m_queue.empty()) { // if (!m_queue.empty()) {
m_queue.push_back(pid); // m_queue.push_back(pid);
return; // return;
} // }
m_queue.push_back(pid); m_queue.push_back(pid);
} }