diff options
| author | zhengchao <[email protected]> | 2021-06-18 15:11:52 +0800 |
|---|---|---|
| committer | zhengchao <[email protected]> | 2021-06-18 15:11:52 +0800 |
| commit | 00f782b0cf1d6325c8deef68c338ebd99a258c47 (patch) | |
| tree | 260cd0cb77ff64a75967e9df6970f77442180c5e /src/entry/Maat_api.cpp | |
| parent | 8bf48ba1f309012877d79cc790040a1d6701389c (diff) | |
修复配置数量为0时,流式扫描句柄计数错误。
Diffstat (limited to 'src/entry/Maat_api.cpp')
| -rw-r--r-- | src/entry/Maat_api.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/entry/Maat_api.cpp b/src/entry/Maat_api.cpp index 43eb761..cfc9161 100644 --- a/src/entry/Maat_api.cpp +++ b/src/entry/Maat_api.cpp @@ -1961,11 +1961,11 @@ stream_para_t Maat_stream_scan_string_start(Maat_feather_t feather,int table_id, } struct Maat_table_runtime* table_rt=Maat_table_runtime_get(scanner->table_rt_mgr, sp->p_real_table->table_id); + INC_SCANNER_REF(scanner, thread_num); if(table_rt->origin_rule_num==0) { return sp; } - INC_SCANNER_REF(scanner, thread_num); sp->thread_num=thread_num; sp->max_cross_size=expr_desc->cross_cache_size; @@ -2243,6 +2243,7 @@ stream_para_t Maat_stream_scan_digest_start(Maat_feather_t feather,int table_id, sp->virtual_table_id=virtual_table_id; sp->last_full_version=_feather->last_full_version; sp->process_offset=0; + INC_SCANNER_REF(scanner, thread_num); if(scanner==NULL) { return sp; @@ -2254,7 +2255,6 @@ stream_para_t Maat_stream_scan_digest_start(Maat_feather_t feather,int table_id, _feather->scan_err_cnt++; return NULL; } - INC_SCANNER_REF(scanner, thread_num); sp->thread_num=thread_num; sp->total_len=total_len; |
