aboutsummaryrefslogtreecommitdiff
path: root/weed/storage
diff options
context:
space:
mode:
Diffstat (limited to 'weed/storage')
-rw-r--r--weed/storage/backend/backend.go2
-rw-r--r--weed/storage/backend/s3_backend/s3_backend.go4
-rw-r--r--weed/storage/volume.go8
-rw-r--r--weed/storage/volume_loading.go2
-rw-r--r--weed/storage/volume_tier.go30
5 files changed, 23 insertions, 23 deletions
diff --git a/weed/storage/backend/backend.go b/weed/storage/backend/backend.go
index 58633e76a..6ea850543 100644
--- a/weed/storage/backend/backend.go
+++ b/weed/storage/backend/backend.go
@@ -23,7 +23,7 @@ type BackendStorageFile interface {
type BackendStorage interface {
ToProperties() map[string]string
- NewStorageFile(key string, tierInfo *volume_server_pb.VolumeTierInfo) BackendStorageFile
+ NewStorageFile(key string, tierInfo *volume_server_pb.VolumeInfo) BackendStorageFile
CopyFile(f *os.File, attributes map[string]string, fn func(progressed int64, percentage float32) error) (key string, size int64, err error)
DownloadFile(fileName string, key string, fn func(progressed int64, percentage float32) error) (size int64, err error)
DeleteFile(key string) (err error)
diff --git a/weed/storage/backend/s3_backend/s3_backend.go b/weed/storage/backend/s3_backend/s3_backend.go
index 96a85e504..9f03cfa81 100644
--- a/weed/storage/backend/s3_backend/s3_backend.go
+++ b/weed/storage/backend/s3_backend/s3_backend.go
@@ -61,7 +61,7 @@ func (s *S3BackendStorage) ToProperties() map[string]string {
return m
}
-func (s *S3BackendStorage) NewStorageFile(key string, tierInfo *volume_server_pb.VolumeTierInfo) backend.BackendStorageFile {
+func (s *S3BackendStorage) NewStorageFile(key string, tierInfo *volume_server_pb.VolumeInfo) backend.BackendStorageFile {
if strings.HasPrefix(key, "/") {
key = key[1:]
}
@@ -107,7 +107,7 @@ func (s *S3BackendStorage) DeleteFile(key string) (err error) {
type S3BackendStorageFile struct {
backendStorage *S3BackendStorage
key string
- tierInfo *volume_server_pb.VolumeTierInfo
+ tierInfo *volume_server_pb.VolumeInfo
}
func (s3backendStorageFile S3BackendStorageFile) ReadAt(p []byte, off int64) (n int, err error) {
diff --git a/weed/storage/volume.go b/weed/storage/volume.go
index 139f433c7..9af70c86f 100644
--- a/weed/storage/volume.go
+++ b/weed/storage/volume.go
@@ -40,7 +40,7 @@ type Volume struct {
isCompacting bool
- volumeTierInfo *volume_server_pb.VolumeTierInfo
+ volumeInfo *volume_server_pb.VolumeInfo
}
func NewVolume(dirname string, collection string, id needle.VolumeId, needleMapKind NeedleMapType, replicaPlacement *super_block.ReplicaPlacement, ttl *needle.TTL, preallocate int64, memoryMapMaxSizeMb uint32) (v *Volume, e error) {
@@ -225,11 +225,11 @@ func (v *Volume) ToVolumeInformationMessage() *master_pb.VolumeInformationMessag
}
func (v *Volume) RemoteStorageNameKey() (storageName, storageKey string) {
- if v.volumeTierInfo == nil {
+ if v.volumeInfo == nil {
return
}
- if len(v.volumeTierInfo.GetFiles()) == 0 {
+ if len(v.volumeInfo.GetFiles()) == 0 {
return
}
- return v.volumeTierInfo.GetFiles()[0].BackendName(), v.volumeTierInfo.GetFiles()[0].GetKey()
+ return v.volumeInfo.GetFiles()[0].BackendName(), v.volumeInfo.GetFiles()[0].GetKey()
}
diff --git a/weed/storage/volume_loading.go b/weed/storage/volume_loading.go
index a09939447..42562d233 100644
--- a/weed/storage/volume_loading.go
+++ b/weed/storage/volume_loading.go
@@ -26,7 +26,7 @@ func (v *Volume) load(alsoLoadIndex bool, createDatIfMissing bool, needleMapKind
fileName := v.FileName()
alreadyHasSuperBlock := false
- if v.maybeLoadVolumeTierInfo() {
+ if v.maybeLoadVolumeInfo() {
v.noWriteCanDelete = true
// open remote file
alreadyHasSuperBlock = true
diff --git a/weed/storage/volume_tier.go b/weed/storage/volume_tier.go
index 5e27562f7..82b822393 100644
--- a/weed/storage/volume_tier.go
+++ b/weed/storage/volume_tier.go
@@ -13,13 +13,13 @@ import (
"github.com/golang/protobuf/jsonpb"
)
-func (v *Volume) GetVolumeTierInfo() *volume_server_pb.VolumeTierInfo {
- return v.volumeTierInfo
+func (v *Volume) GetVolumeInfo() *volume_server_pb.VolumeInfo {
+ return v.volumeInfo
}
-func (v *Volume) maybeLoadVolumeTierInfo() bool {
+func (v *Volume) maybeLoadVolumeInfo() bool {
- v.volumeTierInfo = &volume_server_pb.VolumeTierInfo{}
+ v.volumeInfo = &volume_server_pb.VolumeInfo{}
tierFileName := v.FileName() + ".vif"
@@ -33,7 +33,7 @@ func (v *Volume) maybeLoadVolumeTierInfo() bool {
return false
}
- glog.V(0).Infof("maybeLoadVolumeTierInfo loading volume %d check file", v.Id)
+ glog.V(0).Infof("maybeLoadVolumeInfo loading volume %d check file", v.Id)
tierData, readErr := ioutil.ReadFile(tierFileName)
if readErr != nil {
@@ -41,26 +41,26 @@ func (v *Volume) maybeLoadVolumeTierInfo() bool {
return false
}
- glog.V(0).Infof("maybeLoadVolumeTierInfo loading volume %d ReadFile", v.Id)
+ glog.V(0).Infof("maybeLoadVolumeInfo loading volume %d ReadFile", v.Id)
- if err := jsonpb.Unmarshal(bytes.NewReader(tierData), v.volumeTierInfo); err != nil {
+ if err := jsonpb.Unmarshal(bytes.NewReader(tierData), v.volumeInfo); err != nil {
glog.Warningf("unmarshal error: %v", err)
return false
}
- glog.V(0).Infof("maybeLoadVolumeTierInfo loading volume %d Unmarshal tierInfo %v", v.Id, v.volumeTierInfo)
+ glog.V(0).Infof("maybeLoadVolumeInfo loading volume %d Unmarshal tierInfo %v", v.Id, v.volumeInfo)
- if len(v.volumeTierInfo.GetFiles()) == 0 {
+ if len(v.volumeInfo.GetFiles()) == 0 {
return false
}
glog.V(0).Infof("volume %d is tiered to %s as %s and read only", v.Id,
- v.volumeTierInfo.Files[0].BackendName(), v.volumeTierInfo.Files[0].Key)
+ v.volumeInfo.Files[0].BackendName(), v.volumeInfo.Files[0].Key)
v.noWriteCanDelete = true
v.noWriteOrDelete = false
- glog.V(0).Infof("loading volume %d from remote %v", v.Id, v.volumeTierInfo.Files)
+ glog.V(0).Infof("loading volume %d from remote %v", v.Id, v.volumeInfo.Files)
v.LoadRemoteFile()
return true
@@ -75,18 +75,18 @@ func (v *Volume) HasRemoteFile() bool {
}
func (v *Volume) LoadRemoteFile() error {
- tierFile := v.volumeTierInfo.GetFiles()[0]
+ tierFile := v.volumeInfo.GetFiles()[0]
backendStorage := backend.BackendStorages[tierFile.BackendName()]
if v.DataBackend != nil {
v.DataBackend.Close()
}
- v.DataBackend = backendStorage.NewStorageFile(tierFile.Key, v.volumeTierInfo)
+ v.DataBackend = backendStorage.NewStorageFile(tierFile.Key, v.volumeInfo)
return nil
}
-func (v *Volume) SaveVolumeTierInfo() error {
+func (v *Volume) SaveVolumeInfo() error {
tierFileName := v.FileName() + ".vif"
@@ -99,7 +99,7 @@ func (v *Volume) SaveVolumeTierInfo() error {
Indent: " ",
}
- text, marshalErr := m.MarshalToString(v.GetVolumeTierInfo())
+ text, marshalErr := m.MarshalToString(v.GetVolumeInfo())
if marshalErr != nil {
return fmt.Errorf("marshal volume %d tier info: %v", v.Id, marshalErr)
}