taosdata / TDengine / #3565

coverage: 51.098% (-11.1%) from 62.21%
#3565

push

travis-ci

web-flow 
Merge pull request #29316 from taosdata/enh/3.0/TD-33266

enh(ut):Add wal & config UT.

111558 of 284773 branches covered (39.17%)

Branch coverage included in aggregate %.

1 of 2 new or added lines in 2 files covered. (50.0%)

39015 existing lines in 102 files now uncovered.

177882 of 281666 relevant lines covered (63.15%)

15090998.35 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0
/source/dnode/vnode/src/vnd/vnodeInitApi.c
1 
/*
2 
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
3 
 *
4 
 * This program is free software: you can use, redistribute, and/or modify
5 
 * it under the terms of the GNU Affero General Public License, version 3
6 
 * or later ("AGPL"), as published by the Free Software Foundation.
7 
 *
8 
 * This program is distributed in the hope that it will be useful, but WITHOUT
9 
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10 
 * FITNESS FOR A PARTICULAR PURPOSE.
11 
 *
12 
 * You should have received a copy of the GNU Affero General Public License
13 
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
14 
 */
15 









16



#include "meta.h"










17



#include "storageapi.h"










18



#include "tstreamUpdate.h"










19



#include "vnodeInt.h"










20












21



static void initTsdbReaderAPI(TsdReader* pReader);










22



static void initMetadataAPI(SStoreMeta* pMeta);










23



static void initTqAPI(SStoreTqReader* pTq);










24



static void initStateStoreAPI(SStateStore* pStore);










25



static void initMetaReaderAPI(SStoreMetaReader* pMetaReader);










26



static void initMetaFilterAPI(SMetaDataFilterAPI* pFilter);










27



static void initFunctionStateStore(SFunctionStateStore* pStore);










28



static void initCacheFn(SStoreCacheReader* pCache);










29



static void initSnapshotFn(SStoreSnapshotFn* pSnapshot);










30













UNCOV

31



void initStorageAPI(SStorageAPI* pAPI) {




×








UNCOV

32



  initTsdbReaderAPI(&pAPI->tsdReader);




×








UNCOV

33



  initMetadataAPI(&pAPI->metaFn);




×








UNCOV

34



  initStateStoreAPI(&pAPI->stateStore);




×








UNCOV

35



  initMetaReaderAPI(&pAPI->metaReaderFn);




×








UNCOV

36



  initMetaFilterAPI(&pAPI->metaFilter);




×








UNCOV

37



  initTqAPI(&pAPI->tqReaderFn);




×








UNCOV

38



  initFunctionStateStore(&pAPI->functionStore);




×








UNCOV

39



  initCacheFn(&pAPI->cacheFn);




×








UNCOV

40



  initSnapshotFn(&pAPI->snapshotFn);




×








UNCOV

41



}




×







42













UNCOV

43



void initTsdbReaderAPI(TsdReader* pReader) {




×








UNCOV

44



  pReader->tsdReaderOpen = (int32_t(*)(void*, SQueryTableDataCond*, void*, int32_t, SSDataBlock*, void**, const char*,




×







45



                                       SHashObj**))tsdbReaderOpen2;











UNCOV

46



  pReader->tsdReaderClose = tsdbReaderClose2;




×







47













UNCOV

48



  pReader->tsdNextDataBlock = tsdbNextDataBlock2;




×







49













UNCOV

50



  pReader->tsdReaderRetrieveDataBlock = tsdbRetrieveDataBlock2;




×








UNCOV

51



  pReader->tsdReaderReleaseDataBlock = tsdbReleaseDataBlock2;




×







52













UNCOV

53



  pReader->tsdReaderRetrieveBlockSMAInfo = tsdbRetrieveDatablockSMA2;




×







54













UNCOV

55



  pReader->tsdReaderNotifyClosing = tsdbReaderSetCloseFlag;




×








UNCOV

56



  pReader->tsdReaderResetStatus = tsdbReaderReset2;




×







57













UNCOV

58



  pReader->tsdReaderGetDataBlockDistInfo = tsdbGetFileBlocksDistInfo2;




×








UNCOV

59



  pReader->tsdReaderGetNumOfInMemRows = tsdbGetNumOfRowsInMemTable2;  // todo this function should be moved away




×







60













UNCOV

61



  pReader->tsdSetQueryTableList = tsdbSetTableList2;




×








UNCOV

62



  pReader->tsdSetReaderTaskId = tsdbReaderSetId;




×







63













UNCOV

64



  pReader->tsdSetFilesetDelimited = (void (*)(void*))tsdbSetFilesetDelimited;




×








UNCOV

65



  pReader->tsdSetSetNotifyCb = (void (*)(void*, TsdReaderNotifyCbFn, void*))tsdbReaderSetNotifyCb;




×







66












67



  // file set iterate











UNCOV

68



  pReader->fileSetReaderOpen = tsdbFileSetReaderOpen;




×








UNCOV

69



  pReader->fileSetReadNext = tsdbFileSetReaderNext;




×








UNCOV

70



  pReader->fileSetGetEntryField = tsdbFileSetGetEntryField;




×








UNCOV

71



  pReader->fileSetReaderClose = tsdbFileSetReaderClose;




×








UNCOV

72



}




×







73













UNCOV

74



void initMetadataAPI(SStoreMeta* pMeta) {




×








UNCOV

75



  pMeta->isTableExisted = metaIsTableExist;




×







76













UNCOV

77



  pMeta->openTableMetaCursor = metaOpenTbCursor;




×








UNCOV

78



  pMeta->closeTableMetaCursor = metaCloseTbCursor;




×








UNCOV

79



  pMeta->pauseTableMetaCursor = metaPauseTbCursor;




×








UNCOV

80



  pMeta->resumeTableMetaCursor = metaResumeTbCursor;




×








UNCOV

81



  pMeta->cursorNext = metaTbCursorNext;




×








UNCOV

82



  pMeta->cursorPrev = metaTbCursorPrev;




×







83













UNCOV

84



  pMeta->getBasicInfo = vnodeGetInfo;




×








UNCOV

85



  pMeta->getNumOfChildTables = metaGetStbStats;




×







86













UNCOV

87



  pMeta->getChildTableList = vnodeGetCtbIdList;




×







88













UNCOV

89



  pMeta->storeGetIndexInfo = vnodeGetIdx;




×








UNCOV

90



  pMeta->getInvertIndex = vnodeGetIvtIdx;




×







91













UNCOV

92



  pMeta->extractTagVal = (const void* (*)(const void*, int16_t, STagVal*))metaGetTableTagVal;




×








UNCOV

93



  pMeta->getTableTags = metaGetTableTags;




×








UNCOV

94



  pMeta->getTableTagsByUid = metaGetTableTagsByUids;




×







95













UNCOV

96



  pMeta->getTableUidByName = metaGetTableUidByName;




×








UNCOV

97



  pMeta->getTableTypeByName = metaGetTableTypeByName;




×








UNCOV

98



  pMeta->getTableNameByUid = metaGetTableNameByUid;




×







99













UNCOV

100



  pMeta->getTableSchema = vnodeGetTableSchema;




×








UNCOV

101



  pMeta->storeGetTableList = vnodeGetTableList;




×







102













UNCOV

103



  pMeta->getCachedTableList = metaGetCachedTableUidList;




×








UNCOV

104



  pMeta->putCachedTableList = metaUidFilterCachePut;




×







105













UNCOV

106



  pMeta->metaGetCachedTbGroup = metaGetCachedTbGroup;




×








UNCOV

107



  pMeta->metaPutTbGroupToCache = metaPutTbGroupToCache;




×







108













UNCOV

109



  pMeta->openCtbCursor = metaOpenCtbCursor;




×








UNCOV

110



  pMeta->resumeCtbCursor = metaResumeCtbCursor;




×








UNCOV

111



  pMeta->pauseCtbCursor = metaPauseCtbCursor;




×








UNCOV

112



  pMeta->closeCtbCursor = metaCloseCtbCursor;




×








UNCOV

113



  pMeta->ctbCursorNext = metaCtbCursorNext;




×








UNCOV

114



  pMeta->getDBSize = vnodeGetDBSize;




×








UNCOV

115



}




×







116













UNCOV

117



void initTqAPI(SStoreTqReader* pTq) {




×








UNCOV

118



  pTq->tqReaderOpen = tqReaderOpen;




×








UNCOV

119



  pTq->tqReaderSetColIdList = tqReaderSetColIdList;




×







120













UNCOV

121



  pTq->tqReaderClose = tqReaderClose;




×








UNCOV

122



  pTq->tqReaderSeek = tqReaderSeek;




×








UNCOV

123



  pTq->tqRetrieveBlock = tqRetrieveDataBlock;




×







124













UNCOV

125



  pTq->tqGetTablePrimaryKey = tqGetTablePrimaryKey;




×








UNCOV

126



  pTq->tqSetTablePrimaryKey = tqSetTablePrimaryKey;




×








UNCOV

127



  pTq->tqReaderNextBlockInWal = tqNextBlockInWal;




×







128













UNCOV

129



  pTq->tqNextBlockImpl = tqNextBlockImpl;  // todo remove it




×







130













UNCOV

131



  pTq->tqReaderAddTables = tqReaderAddTbUidList;




×








UNCOV

132



  pTq->tqReaderSetQueryTableList = tqReaderSetTbUidList;




×







133













UNCOV

134



  pTq->tqReaderRemoveTables = tqReaderRemoveTbUidList;




×







135













UNCOV

136



  pTq->tqReaderIsQueriedTable = tqReaderIsQueriedTable;




×








UNCOV

137



  pTq->tqReaderCurrentBlockConsumed = tqCurrentBlockConsumed;




×







138













UNCOV

139



  pTq->tqReaderGetWalReader = tqGetWalReader;  // todo remove it




×







140



  //  pTq->tqReaderRetrieveTaosXBlock = tqRetrieveTaosxBlock;  // todo remove it










141













UNCOV

142



  pTq->tqReaderSetSubmitMsg = tqReaderSetSubmitMsg;  // todo remove it




×








UNCOV

143



  pTq->tqGetResultBlock = tqGetResultBlock;




×







144












145



  //  pTq->tqReaderNextBlockFilterOut = tqNextDataBlockFilterOut;











UNCOV

146



  pTq->tqGetResultBlockTime = tqGetResultBlockTime;




×







147













UNCOV

148



  pTq->tqGetStreamExecProgress = tqGetStreamExecInfo;




×








UNCOV

149



}




×







150













UNCOV

151



void initStateStoreAPI(SStateStore* pStore) {




×








UNCOV

152



  pStore->streamFileStateInit = streamFileStateInit;




×








UNCOV

153



  pStore->updateInfoDestoryColseWinSBF = updateInfoDestoryColseWinSBF;




×







154













UNCOV

155



  pStore->streamStatePutParName = streamStatePutParName;




×








UNCOV

156



  pStore->streamStateGetParName = streamStateGetParName;




×








UNCOV

157



  pStore->streamStateDeleteParName = streamStateDeleteParName;




×







158













UNCOV

159



  pStore->streamStateAddIfNotExist = streamStateAddIfNotExist;




×








UNCOV

160



  pStore->streamStateReleaseBuf = streamStateReleaseBuf;




×








UNCOV

161



  pStore->streamStateClearBuff = streamStateClearBuff;




×








UNCOV

162



  pStore->streamStateFreeVal = streamStateFreeVal;




×







163













UNCOV

164



  pStore->streamStatePut = streamStatePut;




×








UNCOV

165



  pStore->streamStateGet = streamStateGet;




×








UNCOV

166



  pStore->streamStateCheck = streamStateCheck;




×








UNCOV

167



  pStore->streamStateGetByPos = streamStateGetByPos;




×








UNCOV

168



  pStore->streamStateDel = streamStateDel;




×








UNCOV

169



  pStore->streamStateClear = streamStateClear;




×








UNCOV

170



  pStore->streamStateSaveInfo = streamStateSaveInfo;




×








UNCOV

171



  pStore->streamStateGetInfo = streamStateGetInfo;




×








UNCOV

172



  pStore->streamStateSetNumber = streamStateSetNumber;




×








UNCOV

173



  pStore->streamStateGetPrev = streamStateGetPrev;




×







174













UNCOV

175



  pStore->streamStateFillPut = streamStateFillPut;




×








UNCOV

176



  pStore->streamStateFillGet = streamStateFillGet;




×








UNCOV

177



  pStore->streamStateFillAddIfNotExist = streamStateFillAddIfNotExist;




×








UNCOV

178



  pStore->streamStateFillDel = streamStateFillDel;




×








UNCOV

179



  pStore->streamStateFillGetNext = streamStateFillGetNext;




×








UNCOV

180



  pStore->streamStateFillGetPrev = streamStateFillGetPrev;




×







181













UNCOV

182



  pStore->streamStateCurNext = streamStateCurNext;




×








UNCOV

183



  pStore->streamStateCurPrev = streamStateCurPrev;




×







184













UNCOV

185



  pStore->streamStateGetAndCheckCur = streamStateGetAndCheckCur;




×








UNCOV

186



  pStore->streamStateSeekKeyNext = streamStateSeekKeyNext;




×








UNCOV

187



  pStore->streamStateFillSeekKeyNext = streamStateFillSeekKeyNext;




×








UNCOV

188



  pStore->streamStateFillSeekKeyPrev = streamStateFillSeekKeyPrev;




×








UNCOV

189



  pStore->streamStateFreeCur = streamStateFreeCur;




×







190













UNCOV

191



  pStore->streamStateFillGetGroupKVByCur = streamStateFillGetGroupKVByCur;




×








UNCOV

192



  pStore->streamStateGetKVByCur = streamStateGetKVByCur;




×







193













UNCOV

194



  pStore->streamStateSetFillInfo = streamStateSetFillInfo;




×








UNCOV

195



  pStore->streamStateClearExpiredState = streamStateClearExpiredState;




×







196













UNCOV

197



  pStore->streamStateSessionAddIfNotExist = streamStateSessionAddIfNotExist;




×








UNCOV

198



  pStore->streamStateSessionPut = streamStateSessionPut;




×








UNCOV

199



  pStore->streamStateSessionGet = streamStateSessionGet;




×








UNCOV

200



  pStore->streamStateSessionDel = streamStateSessionDel;




×








UNCOV

201



  pStore->streamStateSessionReset = streamStateSessionReset;




×








UNCOV

202



  pStore->streamStateSessionClear = streamStateSessionClear;




×








UNCOV

203



  pStore->streamStateSessionGetKVByCur = streamStateSessionGetKVByCur;




×








UNCOV

204



  pStore->streamStateStateAddIfNotExist = streamStateStateAddIfNotExist;




×








UNCOV

205



  pStore->streamStateSessionGetKeyByRange = streamStateSessionGetKeyByRange;




×








UNCOV

206



  pStore->streamStateCountGetKeyByRange = streamStateCountGetKeyByRange;




×








UNCOV

207



  pStore->streamStateSessionAllocWinBuffByNextPosition = streamStateSessionAllocWinBuffByNextPosition;




×







208













UNCOV

209



  pStore->streamStateCountWinAddIfNotExist = streamStateCountWinAddIfNotExist;




×








UNCOV

210



  pStore->streamStateCountWinAdd = streamStateCountWinAdd;




×







211













UNCOV

212



  pStore->updateInfoInit = updateInfoInit;




×








UNCOV

213



  pStore->updateInfoFillBlockData = updateInfoFillBlockData;




×








UNCOV

214



  pStore->updateInfoIsUpdated = updateInfoIsUpdated;




×








UNCOV

215



  pStore->updateInfoIsTableInserted = updateInfoIsTableInserted;




×








UNCOV

216



  pStore->updateInfoDestroy = updateInfoDestroy;




×








UNCOV

217



  pStore->windowSBfDelete = windowSBfDelete;




×








UNCOV

218



  pStore->windowSBfAdd = windowSBfAdd;




×








UNCOV

219



  pStore->isIncrementalTimeStamp = isIncrementalTimeStamp;




×







220













UNCOV

221



  pStore->updateInfoInitP = updateInfoInitP;




×








UNCOV

222



  pStore->updateInfoAddCloseWindowSBF = updateInfoAddCloseWindowSBF;




×








UNCOV

223



  pStore->updateInfoDestoryColseWinSBF = updateInfoDestoryColseWinSBF;




×








UNCOV

224



  pStore->updateInfoSerialize = updateInfoSerialize;




×








UNCOV

225



  pStore->updateInfoDeserialize = updateInfoDeserialize;




×







226













UNCOV

227



  pStore->streamStateSessionSeekKeyNext = streamStateSessionSeekKeyNext;




×








UNCOV

228



  pStore->streamStateCountSeekKeyPrev = streamStateCountSeekKeyPrev;




×








UNCOV

229



  pStore->streamStateSessionSeekKeyCurrentPrev = streamStateSessionSeekKeyCurrentPrev;




×








UNCOV

230



  pStore->streamStateSessionSeekKeyCurrentNext = streamStateSessionSeekKeyCurrentNext;




×







231













UNCOV

232



  pStore->streamStateGroupPut = streamStateGroupPut;




×








UNCOV

233



  pStore->streamStateGroupGetCur = streamStateGroupGetCur;




×








UNCOV

234



  pStore->streamStateGroupCurNext = streamStateGroupCurNext;




×








UNCOV

235



  pStore->streamStateGroupGetKVByCur = streamStateGroupGetKVByCur;




×







236













UNCOV

237



  pStore->streamFileStateDestroy = streamFileStateDestroy;




×








UNCOV

238



  pStore->streamFileStateClear = streamFileStateClear;




×








UNCOV

239



  pStore->needClearDiskBuff = needClearDiskBuff;




×







240













UNCOV

241



  pStore->streamStateOpen = streamStateOpen;




×








UNCOV

242



  pStore->streamStateClose = streamStateClose;




×








UNCOV

243



  pStore->streamStateBegin = streamStateBegin;




×








UNCOV

244



  pStore->streamStateCommit = streamStateCommit;




×








UNCOV

245



  pStore->streamStateDestroy = streamStateDestroy;




×








UNCOV

246



  pStore->streamStateDeleteCheckPoint = streamStateDeleteCheckPoint;




×








UNCOV

247



  pStore->streamStateReloadInfo = streamStateReloadInfo;




×








UNCOV

248



  pStore->streamStateCopyBackend = streamStateCopyBackend;




×








UNCOV

249



}




×







250













UNCOV

251



void initMetaReaderAPI(SStoreMetaReader* pMetaReader) {




×








UNCOV

252



  pMetaReader->initReader = _metaReaderInit;




×








UNCOV

253



  pMetaReader->clearReader = metaReaderClear;




×







254













UNCOV

255



  pMetaReader->getTableEntryByUid = metaReaderGetTableEntryByUid;




×







256













UNCOV

257



  pMetaReader->getEntryGetUidCache = metaReaderGetTableEntryByUidCache;




×








UNCOV

258



  pMetaReader->getTableEntryByName = metaGetTableEntryByName;




×







259













UNCOV

260



  pMetaReader->readerReleaseLock = metaReaderReleaseLock;




×








UNCOV

261



}




×







262













UNCOV

263



void initMetaFilterAPI(SMetaDataFilterAPI* pFilter) {




×








UNCOV

264



  pFilter->metaFilterCreateTime = metaFilterCreateTime;




×








UNCOV

265



  pFilter->metaFilterTableIds = metaFilterTableIds;




×








UNCOV

266



  pFilter->metaFilterTableName = metaFilterTableName;




×








UNCOV

267



  pFilter->metaFilterTtl = metaFilterTtl;




×








UNCOV

268



}




×







269













UNCOV

270



void initFunctionStateStore(SFunctionStateStore* pStore) {




×








UNCOV

271



  pStore->streamStateFuncPut = streamStateFuncPut;




×








UNCOV

272



  pStore->streamStateFuncGet = streamStateFuncGet;




×








UNCOV

273



}




×







274













UNCOV

275



void initCacheFn(SStoreCacheReader* pCache) {




×








UNCOV

276



  pCache->openReader = tsdbCacherowsReaderOpen;




×








UNCOV

277



  pCache->closeReader = tsdbCacherowsReaderClose;




×








UNCOV

278



  pCache->retrieveRows = tsdbRetrieveCacheRows;




×








UNCOV

279



  pCache->reuseReader = tsdbReuseCacherowsReader;




×








UNCOV

280



}




×







281













UNCOV

282



void initSnapshotFn(SStoreSnapshotFn* pSnapshot) {




×








UNCOV

283



  pSnapshot->taosXGetTablePrimaryKey = taosXGetTablePrimaryKey;




×








UNCOV

284



  pSnapshot->taosXSetTablePrimaryKey = taosXSetTablePrimaryKey;




×








UNCOV

285



  pSnapshot->setForSnapShot = setForSnapShot;




×








UNCOV

286



  pSnapshot->destroySnapshot = destroySnapContext;




×








UNCOV

287



  pSnapshot->getMetaTableInfoFromSnapshot = getMetaTableInfoFromSnapshot;




×








UNCOV

288



  pSnapshot->getTableInfoFromSnapshot = getTableInfoFromSnapshot;




×








UNCOV

289



}




×





















    

  • 

    •