fix issue #659
This commit is contained in:
parent
d4bcce0d8f
commit
dea69ae5d2
|
@ -770,7 +770,10 @@ _again:
|
|||
if (pMeter->finalNumOfBlocks > 0) {
|
||||
pHeader->compInfoOffset = pMeter->compInfoOffset;
|
||||
compInfoOffset += sizeof(SCompInfo) + pMeter->finalNumOfBlocks * sizeof(SCompBlock) + sizeof(TSCKSUM);
|
||||
} else {
|
||||
pHeader->compInfoOffset = 0;
|
||||
}
|
||||
|
||||
dTrace("vid:%d sid:%d id:%s, oldBlocks:%d numOfBlocks:%d compInfoOffset:%d", pObj->vnode, pObj->sid, pObj->meterId,
|
||||
pMeter->oldNumOfBlocks, pMeter->finalNumOfBlocks, compInfoOffset);
|
||||
}
|
||||
|
@ -1890,4 +1893,4 @@ _broken_exit:
|
|||
tfree(pBlocks);
|
||||
tfree(pHeader);
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -203,9 +203,15 @@ int vnodeOpenFileForImport(SImportInfo *pImport, char *payload, SHeadInfo *pHinf
|
|||
return -1;
|
||||
}
|
||||
|
||||
pHinfo->compInfoOffset = pHinfo->headList[pObj->sid].compInfoOffset;
|
||||
pHinfo->leftOffset = pHinfo->headList[pObj->sid].compInfoOffset + sizeof(SCompInfo);
|
||||
} else {
|
||||
if (pHinfo->compInfo.uid == pObj->uid) {
|
||||
pHinfo->compInfoOffset = pHinfo->headList[pObj->sid].compInfoOffset;
|
||||
pHinfo->leftOffset = pHinfo->headList[pObj->sid].compInfoOffset + sizeof(SCompInfo);
|
||||
} else {
|
||||
pHinfo->headList[pObj->sid].compInfoOffset = 0;
|
||||
}
|
||||
}
|
||||
|
||||
if ( pHinfo->headList[pObj->sid].compInfoOffset == 0 ) {
|
||||
memset(&pHinfo->compInfo, 0, sizeof(SCompInfo));
|
||||
pHinfo->compInfo.uid = pObj->uid;
|
||||
|
||||
|
|
Loading…
Reference in New Issue