diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-11-09 00:10:59 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-11-09 00:10:59 -0800 |
| commit | 85f8649320033a46e71b20a588930013c00b3fdf (patch) | |
| tree | 3cbcd4988d1327c465896df294141ee52f2b4701 /weed/storage/volume_loading.go | |
| parent | c5c1d83d91e5de51dd51b96cf338b00f38532d6c (diff) | |
| download | seaweedfs-85f8649320033a46e71b20a588930013c00b3fdf.tar.xz seaweedfs-85f8649320033a46e71b20a588930013c00b3fdf.zip | |
refactor memory mapped file into backend storage
Diffstat (limited to 'weed/storage/volume_loading.go')
| -rw-r--r-- | weed/storage/volume_loading.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/storage/volume_loading.go b/weed/storage/volume_loading.go index e769321c4..6f1d8fe40 100644 --- a/weed/storage/volume_loading.go +++ b/weed/storage/volume_loading.go @@ -25,13 +25,13 @@ func (v *Volume) load(alsoLoadIndex bool, createDatIfMissing bool, needleMapKind var e error fileName := v.FileName() alreadyHasSuperBlock := false - var dataFile *os.File // open dat file if exists, canRead, canWrite, modifiedTime, fileSize := checkFile(fileName + ".dat"); exists { if !canRead { return fmt.Errorf("cannot read Volume Data file %s.dat", fileName) } + var dataFile *os.File if canWrite { dataFile, e = os.OpenFile(fileName+".dat", os.O_RDWR|os.O_CREATE, 0644) } else { @@ -43,14 +43,14 @@ func (v *Volume) load(alsoLoadIndex bool, createDatIfMissing bool, needleMapKind if fileSize >= _SuperBlockSize { alreadyHasSuperBlock = true } + v.DataBackend = backend.NewDiskFile(dataFile) } else { if createDatIfMissing { - dataFile, e = createVolumeFile(fileName+".dat", preallocate, v.MemoryMapMaxSizeMb) + v.DataBackend, e = createVolumeFile(fileName+".dat", preallocate, v.MemoryMapMaxSizeMb) } else { return fmt.Errorf("Volume Data file %s.dat does not exist.", fileName) } } - v.DataBackend = backend.NewDiskFile(dataFile) if e != nil { if !os.IsPermission(e) { |
