thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 17:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

add a one-line method for resetting a job lock

Browse Source
This commit is contained in:
jinjunzh 2022-07-08 12:09:58 -04:00
parent 7a3c21174d
commit 7eb71143db
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Compression/CompressionCodecDeflate.cpp
View File

@ -40,7 +40,7 @@ DeflateJobHWPool::DeflateJobHWPool():log(&Poco::Logger::get("DeflateJobHWPool"))
if ((nullptr == qpl_job_ptr) || (qpl_init_job(PATH, qpl_job_ptr) != QPL_STS_OK))
break;
jobPool[index] = qpl_job_ptr;
jobLocks[index].store(false);
unLockJob(index);
}
const char * qpl_version = qpl_get_library_version();
@ -66,7 +66,7 @@ DeflateJobHWPool::~DeflateJobHWPool()
qpl_fini_job(jobPool[i]);
}
jobPool[i] = nullptr;
jobLocks[i].store(false);
unLockJob(i);
}
jobPoolReady() = false;
}

2
src/Compression/CompressionCodecDeflate.h
View File

@ -81,6 +81,8 @@ private:
return jobLocks[index].compare_exchange_strong(expected, true);
}
void unLockJob(uint32_t index) { jobLocks[index].store(false); }
class ReleaseJobObjectGuard
{
uint32_t index;