xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

feat: refactor index code

This commit is contained in:
yihaoDeng 2022-06-30 21:08:15 +08:00
parent da93f6c984
commit 3681aacf0e
2 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/index/src/indexFstDfa.c
View File

@ -61,9 +61,10 @@ void dfaBuilderDestroy(FstDfaBuilder *builder) {
pIter = taosHashIterate(builder->cache, pIter); pIter = taosHashIterate(builder->cache, pIter);
} }
taosHashCleanup(builder->cache); taosHashCleanup(builder->cache);
taosMemoryFree(builder);
} }
FstDfa *dfaBuilderBuild(FstDfaBuilder *builder) { FstDfa *dfaBuilder(FstDfaBuilder *builder) {
uint32_t sz = taosArrayGetSize(builder->dfa->insts); uint32_t sz = taosArrayGetSize(builder->dfa->insts);
FstSparseSet *cur = sparSetCreate(sz); FstSparseSet *cur = sparSetCreate(sz);
FstSparseSet *nxt = sparSetCreate(sz); FstSparseSet *nxt = sparSetCreate(sz);

17
source/libs/transport/src/transComm.c
View File

@ -479,6 +479,10 @@ bool transEpSetIsEqual(SEpSet* a, SEpSet* b) {
} }
return true; return true;
} }
static int32_t transGetRefMgt() {
//
return refMgt;
}
static void transInitEnv() { static void transInitEnv() {
refMgt = transOpenExHandleMgt(50000); refMgt = transOpenExHandleMgt(50000);
@ -486,8 +490,9 @@ static void transInitEnv() {
} }
static void transDestroyEnv() { static void transDestroyEnv() {
// close ref // close ref
transCloseExHandleMgt(refMgt); transCloseExHandleMgt();
} }
void transInit() { void transInit() {
// init env // init env
taosThreadOnce(&transModuleInit, transInitEnv); taosThreadOnce(&transModuleInit, transInitEnv);
@ -502,25 +507,25 @@ int32_t transOpenExHandleMgt(int size) {
} }
void transCloseExHandleMgt() { void transCloseExHandleMgt() {
// close ref // close ref
taosCloseRef(refMgt); taosCloseRef(transGetRefMgt());
} }
int64_t transAddExHandle(void* p) { int64_t transAddExHandle(void* p) {
// acquire extern handle // acquire extern handle
return taosAddRef(refMgt, p); return taosAddRef(transGetRefMgt(), p);
} }
int32_t transRemoveExHandle(int64_t refId) { int32_t transRemoveExHandle(int64_t refId) {
// acquire extern handle // acquire extern handle
return taosRemoveRef(refMgt, refId); return taosRemoveRef(transGetRefMgt(), refId);
} }
SExHandle* transAcquireExHandle(int64_t refId) { SExHandle* transAcquireExHandle(int64_t refId) {
// acquire extern handle // acquire extern handle
return (SExHandle*)taosAcquireRef(refMgt, refId); return (SExHandle*)taosAcquireRef(transGetRefMgt(), refId);
} }
int32_t transReleaseExHandle(int64_t refId) { int32_t transReleaseExHandle(int64_t refId) {
// release extern handle // release extern handle
return taosReleaseRef(refMgt, refId); return taosReleaseRef(transGetRefMgt(), refId);
} }
void transDestoryExHandle(void* handle) { void transDestoryExHandle(void* handle) {
if (handle == NULL) { if (handle == NULL) {