mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
66 lines
1.6 KiB
Go
66 lines
1.6 KiB
Go
![]() |
package storage
|
||
|
|
||
|
import (
|
||
|
"code.google.com/p/weed-fs/go/glog"
|
||
|
"fmt"
|
||
|
"os"
|
||
|
)
|
||
|
|
||
|
const (
|
||
|
SuperBlockSize = 8
|
||
|
)
|
||
|
|
||
|
type SuperBlock struct {
|
||
|
version Version
|
||
|
ReplicaPlacement *ReplicaPlacement
|
||
|
}
|
||
|
|
||
|
func (s *SuperBlock) Version() Version {
|
||
|
return s.version
|
||
|
}
|
||
|
func (s *SuperBlock) Bytes() []byte {
|
||
|
header := make([]byte, SuperBlockSize)
|
||
|
header[0] = byte(s.version)
|
||
|
header[1] = s.ReplicaPlacement.Byte()
|
||
|
return header
|
||
|
}
|
||
|
|
||
|
func (v *Volume) maybeWriteSuperBlock() error {
|
||
|
stat, e := v.dataFile.Stat()
|
||
|
if e != nil {
|
||
|
glog.V(0).Infof("failed to stat datafile %s: %s", v.dataFile, e.Error())
|
||
|
return e
|
||
|
}
|
||
|
if stat.Size() == 0 {
|
||
|
v.SuperBlock.version = CurrentVersion
|
||
|
_, e = v.dataFile.Write(v.SuperBlock.Bytes())
|
||
|
if e != nil && os.IsPermission(e) {
|
||
|
//read-only, but zero length - recreate it!
|
||
|
if v.dataFile, e = os.Create(v.dataFile.Name()); e == nil {
|
||
|
if _, e = v.dataFile.Write(v.SuperBlock.Bytes()); e == nil {
|
||
|
v.readOnly = false
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
return e
|
||
|
}
|
||
|
func (v *Volume) readSuperBlock() (err error) {
|
||
|
if _, err = v.dataFile.Seek(0, 0); err != nil {
|
||
|
return fmt.Errorf("cannot seek to the beginning of %s: %s", v.dataFile.Name(), err.Error())
|
||
|
}
|
||
|
header := make([]byte, SuperBlockSize)
|
||
|
if _, e := v.dataFile.Read(header); e != nil {
|
||
|
return fmt.Errorf("cannot read superblock: %s", e.Error())
|
||
|
}
|
||
|
v.SuperBlock, err = ParseSuperBlock(header)
|
||
|
return err
|
||
|
}
|
||
|
func ParseSuperBlock(header []byte) (superBlock SuperBlock, err error) {
|
||
|
superBlock.version = Version(header[0])
|
||
|
if superBlock.ReplicaPlacement, err = NewReplicaPlacementFromByte(header[1]); err != nil {
|
||
|
err = fmt.Errorf("cannot read replica type: %s", err.Error())
|
||
|
}
|
||
|
return
|
||
|
}
|