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

enh: refact syncEnv code

This commit is contained in:
Shengliang Guan 2022-11-01 09:02:48 +08:00
parent 91abd170e3
commit fbb1fa5303
3 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/sync/inc/syncEnv.h
View File

@ -54,7 +54,7 @@ typedef struct SSyncEnv {
SSyncEnv* syncEnv(); SSyncEnv* syncEnv();
int64_t syncNodeAdd(SSyncNode* pNode); int64_t syncNodeAdd(SSyncNode* pNode);
void syncNodeRemove(SSyncNode* pNode); void syncNodeRemove(int64_t rid);
SSyncNode* syncNodeAcquire(int64_t rid); SSyncNode* syncNodeAcquire(int64_t rid);
void syncNodeRelease(SSyncNode* pNode); void syncNodeRelease(SSyncNode* pNode);

5
source/libs/sync/src/syncEnv.c
View File

@ -74,10 +74,7 @@ int64_t syncNodeAdd(SSyncNode *pNode) {
return pNode->rid; return pNode->rid;
} }
void syncNodeRemove(SSyncNode *pNode) { void syncNodeRemove(int64_t rid) { taosRemoveRef(gNodeRefId, rid); }
taosRemoveRef(gNodeRefId, pNode->rid);
sDebug("vgId:%d, sync rid:%" PRId64 " is removed from rsetId:%d", pNode->vgId, pNode->rid, gNodeRefId);
}
SSyncNode *syncNodeAcquire(int64_t rid) { SSyncNode *syncNodeAcquire(int64_t rid) {
SSyncNode *pNode = taosAcquireRef(gNodeRefId, rid); SSyncNode *pNode = taosAcquireRef(gNodeRefId, rid);

2
source/libs/sync/src/syncMain.c
View File

@ -76,7 +76,7 @@ void syncStop(int64_t rid) {
SSyncNode* pNode = syncNodeAcquire(rid); SSyncNode* pNode = syncNodeAcquire(rid);
if (pNode != NULL) { if (pNode != NULL) {
syncNodeRelease(pNode); syncNodeRelease(pNode);
syncNodeRemove(pNode); syncNodeRemove(rid);
} }
} }