Ecosystem/xmrig
Ecosystem/xmrig
1
0
Fork 0
mirror of https://github.com/xmrig/xmrig.git synced 2025-03-23 23:58:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixed exit condition for RxQueue.

Browse source
This commit is contained in:
XMRig 2019-10-06 11:19:32 +07:00
parent 8af1075c98
commit 0a1836e5a8
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/crypto/rx/RxQueue.cpp
View file

@ -132,15 +132,15 @@ bool xmrig::RxQueue::isReadyUnsafe(const Job &job) const
void xmrig::RxQueue::backgroundInit() void xmrig::RxQueue::backgroundInit()
{ {
while (true) { while (m_state != STATE_SHUTDOWN) {
std::unique_lock<std::mutex> lock(m_mutex); std::unique_lock<std::mutex> lock(m_mutex);
if (m_state == STATE_IDLE) { if (m_state == STATE_IDLE) {
m_cv.wait(lock, [this]{ return m_state != STATE_IDLE; }); m_cv.wait(lock, [this]{ return m_state != STATE_IDLE; });
} }
if (m_state == STATE_SHUTDOWN) { if (m_state != STATE_PENDING) {
break; continue;
} }
const auto item = m_queue.back(); const auto item = m_queue.back();
@ -159,7 +159,8 @@ void xmrig::RxQueue::backgroundInit()
m_storage->init(item.seed, item.threads, item.hugePages); m_storage->init(item.seed, item.threads, item.hugePages);
lock = std::move(std::unique_lock<std::mutex>(m_mutex)); lock = std::move(std::unique_lock<std::mutex>(m_mutex));
if (!m_queue.empty()) {
if (m_state == STATE_SHUTDOWN || !m_queue.empty()) {
continue; continue;
} }