This commit is contained in:
Chris Lu 2019-12-23 12:48:53 -08:00
parent 09ca936c78
commit 8a2d529759
4 changed files with 5 additions and 6 deletions

View file

@ -168,7 +168,7 @@ func (vs *VolumeServer) VolumeEcShardsDelete(ctx context.Context, req *volume_se
continue continue
} }
for _, fileInfo := range fileInfos { for _, fileInfo := range fileInfos {
if fileInfo.Name() == bName+".ecx" || fileInfo.Name() == bName+".ecj"{ if fileInfo.Name() == bName+".ecx" || fileInfo.Name() == bName+".ecj" {
hasEcxFile = true hasEcxFile = true
continue continue
} }

View file

@ -45,7 +45,6 @@ func (c *commandFsDu) Do(args []string, commandEnv *CommandEnv, writer io.Writer
path = path + "/" path = path + "/"
} }
var blockCount, byteCount uint64 var blockCount, byteCount uint64
dir, name := filer2.FullPath(path).DirAndName() dir, name := filer2.FullPath(path).DirAndName()
blockCount, byteCount, err = duTraverseDirectory(ctx, writer, commandEnv.getFilerClient(filerServer, filerPort), dir, name) blockCount, byteCount, err = duTraverseDirectory(ctx, writer, commandEnv.getFilerClient(filerServer, filerPort), dir, name)

View file

@ -19,7 +19,7 @@ type SortedFileNeedleMap struct {
func NewSortedFileNeedleMap(baseFileName string, indexFile *os.File) (m *SortedFileNeedleMap, err error) { func NewSortedFileNeedleMap(baseFileName string, indexFile *os.File) (m *SortedFileNeedleMap, err error) {
m = &SortedFileNeedleMap{baseFileName: baseFileName} m = &SortedFileNeedleMap{baseFileName: baseFileName}
m.indexFile = indexFile m.indexFile = indexFile
fileName := baseFileName+".sdb" fileName := baseFileName + ".sdb"
if !isSortedFileFresh(fileName, indexFile) { if !isSortedFileFresh(fileName, indexFile) {
glog.V(0).Infof("Start to Generate %s from %s", fileName, indexFile.Name()) glog.V(0).Infof("Start to Generate %s from %s", fileName, indexFile.Name())
erasure_coding.WriteSortedFileFromIdx(baseFileName, ".sdb") erasure_coding.WriteSortedFileFromIdx(baseFileName, ".sdb")