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

fix compile error

This commit is contained in:
yihaoDeng 2022-07-04 18:57:06 +08:00
parent 37b303f531
commit f213212faf
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -480,10 +480,6 @@ bool transEpSetIsEqual(SEpSet* a, SEpSet* b) {
} }
return true; return true;
} }
static int32_t transGetRefMgt() {
//
return refMgt;
}
static void transInitEnv() { static void transInitEnv() {
refMgt = transOpenRefMgt(50000, transDestoryExHandle); refMgt = transOpenRefMgt(50000, transDestoryExHandle);
@ -517,11 +513,11 @@ void transCloseRefMgt(int32_t mgt) {
} }
int64_t transAddExHandle(int32_t refMgt, void* p) { int64_t transAddExHandle(int32_t refMgt, void* p) {
// acquire extern handle // acquire extern handle
return taosAddRef(transGetRefMgt(), p); return taosAddRef(refMgt, p);
} }
int32_t transRemoveExHandle(int32_t refMgt, int64_t refId) { int32_t transRemoveExHandle(int32_t refMgt, int64_t refId) {
// acquire extern handle // acquire extern handle
return taosRemoveRef(transGetRefMgt(), refId); return taosRemoveRef(refMgt, refId);
} }
void* transAcquireExHandle(int32_t refMgt, int64_t refId) { void* transAcquireExHandle(int32_t refMgt, int64_t refId) {
@ -531,7 +527,7 @@ void* transAcquireExHandle(int32_t refMgt, int64_t refId) {
int32_t transReleaseExHandle(int32_t refMgt, int64_t refId) { int32_t transReleaseExHandle(int32_t refMgt, int64_t refId) {
// release extern handle // release extern handle
return taosReleaseRef(transGetRefMgt(), refId); return taosReleaseRef(refMgt, refId);
} }
void transDestoryExHandle(void* handle) { void transDestoryExHandle(void* handle) {
if (handle == NULL) { if (handle == NULL) {