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

add assert for Illegal path

Browse Source
This commit is contained in:
jinjunzh 2022-07-09 17:29:47 -04:00
parent 044c14745e
commit bc775ecc5b
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Compression/CompressionCodecDeflateQpl.cpp
View File

@ -89,6 +89,7 @@ qpl_job * DeflateQplJobHWPool::acquireJob(uint32_t * job_id)
}
}
*job_id = JOB_NUMBER - index;
assert(index < JOB_NUMBER);
return hw_job_ptr_pool[index];
}
else
@ -100,6 +101,7 @@ qpl_job * DeflateQplJobHWPool::releaseJob(uint32_t job_id)
if (jobPoolReady())
{
uint32_t index = JOB_NUMBER - job_id;
assert(index < JOB_NUMBER);
ReleaseJobObjectGuard _(index);
return hw_job_ptr_pool[index];
}
@ -122,6 +124,9 @@ HardwareCodecDeflateQpl::HardwareCodecDeflateQpl():
HardwareCodecDeflateQpl::~HardwareCodecDeflateQpl()
{
#ifndef NDEBUG
assert(decomp_async_job_map.empty());
#else
if (!decomp_async_job_map.empty())
{
LOG_WARNING(log, "Find un-released job when HardwareCodecDeflateQpl destroy");
@ -131,6 +136,7 @@ HardwareCodecDeflateQpl::~HardwareCodecDeflateQpl()
}
decomp_async_job_map.clear();
}
#endif
}
int32_t HardwareCodecDeflateQpl::doCompressData(const char * source, uint32_t source_size, char * dest, uint32_t dest_size) const