Skip to content

Commit

Permalink
adjust log pos
Browse files Browse the repository at this point in the history
  • Loading branch information
guanshengliang committed Dec 31, 2020
1 parent 1170afd commit e49cba7
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/sync/src/syncRetrieve.c
Original file line number Diff line number Diff line change
Expand Up @@ -503,9 +503,10 @@ void *syncRetrieveData(void *param) {
taosClose(pPeer->syncFd);

// The ref is obtained in both the create thread and the current thread, so it is released twice
sInfo("%s, sync retrieve data over, sstatus:%s", pPeer->id, syncStatus[pPeer->sstatus]);

syncReleasePeer(pPeer);
syncReleasePeer(pPeer);

sInfo("%s, sync retrieve data over, sstatus:%s", pPeer->id, syncStatus[pPeer->sstatus]);
return NULL;
}

0 comments on commit e49cba7

Please sign in to comment.