seaweedfs/weed/storage/volume_super_block.go

package storage

import (
	"fmt"
	"os"

	"github.com/seaweedfs/seaweedfs/weed/glog"
	"github.com/seaweedfs/seaweedfs/weed/storage/backend"
	"github.com/seaweedfs/seaweedfs/weed/storage/needle"
	"github.com/seaweedfs/seaweedfs/weed/storage/super_block"
)

func (v *Volume) maybeWriteSuperBlock(ver needle.Version) error {

	datSize, _, e := v.DataBackend.GetStat()
	if e != nil {
		glog.V(0).Infof("failed to stat datafile %s: %v", v.DataBackend.Name(), e)
		return e
	}
	if datSize == 0 {
		v.SuperBlock.Version = ver
		_, e = v.DataBackend.WriteAt(v.SuperBlock.Bytes(), 0)
		if e != nil && os.IsPermission(e) {
			//read-only, but zero length - recreate it!
			var dataFile *os.File
			if dataFile, e = os.Create(v.DataBackend.Name()); e == nil {
				v.DataBackend = backend.NewDiskFile(dataFile)
				if _, e = v.DataBackend.WriteAt(v.SuperBlock.Bytes(), 0); e == nil {
					v.noWriteLock.Lock()
					v.noWriteOrDelete = false
					v.noWriteCanDelete = false
					v.noWriteLock.Unlock()
				}
			}
		}
	}
	return e
}

func (v *Volume) readSuperBlock() (err error) {
	v.SuperBlock, err = super_block.ReadSuperBlock(v.DataBackend)
	if v.volumeInfo != nil && v.volumeInfo.Replication != "" {
		if replication, err := super_block.NewReplicaPlacementFromString(v.volumeInfo.Replication); err != nil {
			return fmt.Errorf("Error parse volume %d replication %s : %v", v.Id, v.volumeInfo.Replication, err)
		} else {
			v.SuperBlock.ReplicaPlacement = replication
		}
	}
	return err
}