Skip to content
Snippets Groups Projects
Unverified Commit 3c53c43c authored by fireice-uk's avatar fireice-uk Committed by GitHub
Browse files

Merge pull request #1449 from psychocrypt/fix-wrongUniqueLockUsage

fix wrong unique_lock usage
parents 601d1961 5edfb0da
No related branches found
No related tags found
No related merge requests found
...@@ -229,7 +229,7 @@ void jpsock::jpsock_thread() ...@@ -229,7 +229,7 @@ void jpsock::jpsock_thread()
else else
disconnect_time = 0; disconnect_time = 0;
std::unique_lock<std::mutex>(job_mutex); std::unique_lock<std::mutex> lck(job_mutex);
memset(&oCurrentJob, 0, sizeof(oCurrentJob)); memset(&oCurrentJob, 0, sizeof(oCurrentJob));
bRunning = false; bRunning = false;
} }
...@@ -439,7 +439,7 @@ bool jpsock::process_pool_job(const opq_json_val* params) ...@@ -439,7 +439,7 @@ bool jpsock::process_pool_job(const opq_json_val* params)
if(motd != nullptr && motd->IsString() && (motd->GetStringLength() & 0x01) == 0) if(motd != nullptr && motd->IsString() && (motd->GetStringLength() & 0x01) == 0)
{ {
std::unique_lock<std::mutex>(motd_mutex); std::unique_lock<std::mutex> lck(motd_mutex);
if(motd->GetStringLength() > 0) if(motd->GetStringLength() > 0)
{ {
pool_motd.resize(motd->GetStringLength()/2 + 1); pool_motd.resize(motd->GetStringLength()/2 + 1);
...@@ -454,7 +454,7 @@ bool jpsock::process_pool_job(const opq_json_val* params) ...@@ -454,7 +454,7 @@ bool jpsock::process_pool_job(const opq_json_val* params)
executor::inst()->push_event(ex_event(oPoolJob, pool_id)); executor::inst()->push_event(ex_event(oPoolJob, pool_id));
std::unique_lock<std::mutex>(job_mutex); std::unique_lock<std::mutex> lck(job_mutex);
oCurrentJob = oPoolJob; oCurrentJob = oPoolJob;
return true; return true;
} }
...@@ -679,13 +679,13 @@ bool jpsock::cmd_submit(const char* sJobId, uint32_t iNonce, const uint8_t* bRes ...@@ -679,13 +679,13 @@ bool jpsock::cmd_submit(const char* sJobId, uint32_t iNonce, const uint8_t* bRes
void jpsock::save_nonce(uint32_t nonce) void jpsock::save_nonce(uint32_t nonce)
{ {
std::unique_lock<std::mutex>(job_mutex); std::unique_lock<std::mutex> lck(job_mutex);
oCurrentJob.iSavedNonce = nonce; oCurrentJob.iSavedNonce = nonce;
} }
bool jpsock::get_current_job(pool_job& job) bool jpsock::get_current_job(pool_job& job)
{ {
std::unique_lock<std::mutex>(job_mutex); std::unique_lock<std::mutex> lck(job_mutex);
if(oCurrentJob.iWorkLen == 0) if(oCurrentJob.iWorkLen == 0)
return false; return false;
...@@ -699,7 +699,7 @@ bool jpsock::get_pool_motd(std::string& strin) ...@@ -699,7 +699,7 @@ bool jpsock::get_pool_motd(std::string& strin)
if(!ext_motd) if(!ext_motd)
return false; return false;
std::unique_lock<std::mutex>(motd_mutex); std::unique_lock<std::mutex> lck(motd_mutex);
if(pool_motd.size() > 0) if(pool_motd.size() > 0)
{ {
strin.assign(pool_motd); strin.assign(pool_motd);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment