diff --git a/source/libs/sync/src/syncEnv.c b/source/libs/sync/src/syncEnv.c index 8f7a717e00dc2ec4546445b8077da0e3dc75f531..ff2d4d4d27f691fe09240b473f3b8ed159ca6f87 100644 --- a/source/libs/sync/src/syncEnv.c +++ b/source/libs/sync/src/syncEnv.c @@ -29,7 +29,8 @@ static void syncEnvTick(void *param, void *tmrId); int32_t syncEnvStart() { int32_t ret = 0; taosSeedRand(taosGetTimestampSec()); - gSyncEnv = doSyncEnvStart(gSyncEnv); + //gSyncEnv = doSyncEnvStart(gSyncEnv); + gSyncEnv = doSyncEnvStart(); assert(gSyncEnv != NULL); sTrace("syncEnvStart ok!"); return ret; @@ -91,10 +92,12 @@ static SSyncEnv *doSyncEnvStart() { } static int32_t doSyncEnvStop(SSyncEnv *pSyncEnv) { + assert(pSyncEnv == gSyncEnv); if (pSyncEnv != NULL) { taosTmrCleanUp(pSyncEnv->pTimerManager); taosMemoryFree(pSyncEnv); } + gSyncEnv = NULL; return 0; }