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

fix a small bug

This commit is contained in:
Hongze Cheng 2019-11-26 17:47:29 +08:00
parent 178f5771f6
commit ed253f2a2a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/system/detail/src/vnodeImport.c
View File

@ -243,7 +243,7 @@ int vnodeImportPoints(SMeterObj *pObj, char *cont, int contLen, char source, voi
pthread_mutex_unlock(&pPool->vmutex); pthread_mutex_unlock(&pPool->vmutex);
vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING); vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING);
return TSDB_CODE_ACTION_IN_PROGRESS; return TSDB_CODE_ACTION_IN_PROGRESS;
} else { } else {
pPool->commitInProcess = 1; pPool->commitInProcess = 1;
pthread_mutex_unlock(&pPool->vmutex); pthread_mutex_unlock(&pPool->vmutex);
@ -251,9 +251,9 @@ int vnodeImportPoints(SMeterObj *pObj, char *cont, int contLen, char source, voi
*pNumOfPoints = import.importedRows; *pNumOfPoints = import.importedRows;
} }
pVnode->version++; pVnode->version++;
vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING);
} }
vnodeClearMeterState(pObj, TSDB_METER_STATE_IMPORTING);
return code; return code;
} }