[CP] fix sql audit bug
This commit is contained in:
@ -86,6 +86,11 @@ void ObConcurrentFIFOAllocator::destroy()
|
|||||||
inner_allocator_.destroy();
|
inner_allocator_.destroy();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void ObConcurrentFIFOAllocator::purge()
|
||||||
|
{
|
||||||
|
inner_allocator_.purge();
|
||||||
|
}
|
||||||
|
|
||||||
void ObConcurrentFIFOAllocator::set_label(const lib::ObLabel &label)
|
void ObConcurrentFIFOAllocator::set_label(const lib::ObLabel &label)
|
||||||
{
|
{
|
||||||
inner_allocator_.set_label(label);
|
inner_allocator_.set_label(label);
|
||||||
|
|||||||
@ -35,6 +35,7 @@ public:
|
|||||||
const lib::ObMemAttr &attr,
|
const lib::ObMemAttr &attr,
|
||||||
const int64_t total_limit);
|
const int64_t total_limit);
|
||||||
void destroy();
|
void destroy();
|
||||||
|
void purge();
|
||||||
public:
|
public:
|
||||||
void set_label(const lib::ObLabel &label);
|
void set_label(const lib::ObLabel &label);
|
||||||
void set_attr(const lib::ObMemAttr &attr);
|
void set_attr(const lib::ObMemAttr &attr);
|
||||||
|
|||||||
@ -103,6 +103,9 @@ public:
|
|||||||
purge_extra_cached_block(0, true);
|
purge_extra_cached_block(0, true);
|
||||||
bsize_ = 0;
|
bsize_ = 0;
|
||||||
}
|
}
|
||||||
|
void purge() {
|
||||||
|
purge_extra_cached_block(0);
|
||||||
|
}
|
||||||
void set_nway(int nway) {
|
void set_nway(int nway) {
|
||||||
if (nway <= 0) {
|
if (nway <= 0) {
|
||||||
nway = 1;
|
nway = 1;
|
||||||
|
|||||||
@ -154,7 +154,7 @@ public:
|
|||||||
void clear_queue()
|
void clear_queue()
|
||||||
{
|
{
|
||||||
(void)release_old(INT64_MAX);
|
(void)release_old(INT64_MAX);
|
||||||
allocator_.destroy();
|
allocator_.purge();
|
||||||
}
|
}
|
||||||
|
|
||||||
uint64_t get_tenant_id() const
|
uint64_t get_tenant_id() const
|
||||||
|
|||||||
Reference in New Issue
Block a user