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

[jira none]

This commit is contained in:
hjxilinx 2019-11-28 10:56:06 +08:00
parent 14c9d204f9
commit 4466964afc
2 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/system/detail/src/vnodeQueryImpl.c
View File

@ -2919,6 +2919,7 @@ static int file_order_comparator(const void *p1, const void *p2) {
/** /**
* open a data files and header file for metric meta query * open a data files and header file for metric meta query
*
* @param pQInfo * @param pQInfo
* @param pVnodeFiles * @param pVnodeFiles
* @param fid * @param fid
@ -2929,8 +2930,6 @@ static int file_order_comparator(const void *p1, const void *p2) {
*/ */
static int32_t vnodeOpenVnodeDBFiles(SQInfo *pQInfo, SQueryFileInfo *pVnodeFiles, int32_t fid, int32_t vnodeId, static int32_t vnodeOpenVnodeDBFiles(SQInfo *pQInfo, SQueryFileInfo *pVnodeFiles, int32_t fid, int32_t vnodeId,
char *fileName, char *prefix) { char *fileName, char *prefix) {
// __off_t size = 0;
pVnodeFiles->fileID = fid; pVnodeFiles->fileID = fid;
pVnodeFiles->defaultMappingSize = DEFAULT_DATA_FILE_MMAP_WINDOW_SIZE; pVnodeFiles->defaultMappingSize = DEFAULT_DATA_FILE_MMAP_WINDOW_SIZE;

1
src/system/detail/src/vnodeShell.c
View File

@ -569,7 +569,6 @@ int vnodeProcessShellSubmitRequest(char *pMsg, int msgLen, SShellObj *pObj) {
int sversion = htonl(pBlocks->sversion); int sversion = htonl(pBlocks->sversion);
if (pSubmit->import) { if (pSubmit->import) {
dTrace("start to import data");
code = vnodeImportPoints(pMeterObj, (char *) &(pBlocks->numOfRows), subMsgLen, TSDB_DATA_SOURCE_SHELL, pObj, code = vnodeImportPoints(pMeterObj, (char *) &(pBlocks->numOfRows), subMsgLen, TSDB_DATA_SOURCE_SHELL, pObj,
sversion, &numOfPoints, now); sversion, &numOfPoints, now);
} else { } else {