diff options
| author | Chris Lu <chris.lu@gmail.com> | 2012-11-20 00:54:37 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2012-11-20 00:54:37 -0800 |
| commit | e00d8dc536a15de9296f5dc072f49ff91ca835a1 (patch) | |
| tree | e4dd5a85e08dac00fd31a556e6b282df39c55cd6 | |
| parent | 084e0ab7bb7c0425623581787372bfc2cb6edbc4 (diff) | |
| download | seaweedfs-e00d8dc536a15de9296f5dc072f49ff91ca835a1.tar.xz seaweedfs-e00d8dc536a15de9296f5dc072f49ff91ca835a1.zip | |
adjust formatting
| -rw-r--r-- | weed-fs/src/pkg/storage/volume.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/weed-fs/src/pkg/storage/volume.go b/weed-fs/src/pkg/storage/volume.go index 3bc979251..b278cf7d1 100644 --- a/weed-fs/src/pkg/storage/volume.go +++ b/weed-fs/src/pkg/storage/volume.go @@ -73,8 +73,8 @@ func (v *Volume) readSuperBlock() { v.replicaType, _ = NewReplicationTypeFromByte(header[1]) } } -func (v *Volume) NeedToReplicate() bool{ - return v.replicaType.GetCopyCount()>1 +func (v *Volume) NeedToReplicate() bool { + return v.replicaType.GetCopyCount() > 1 } func (v *Volume) write(n *Needle) uint32 { @@ -157,7 +157,7 @@ func (v *Volume) copyDataAndGenerateIndexFile(srcName, dstName, idxName string) n, rest := ReadNeedle(src) nm := NewNeedleMap(idx) old_offset := uint32(SuperBlockSize) - new_offset := uint32(SuperBlockSize) + new_offset := uint32(SuperBlockSize) for n != nil { nv, ok := v.nm.Get(n.Id) //log.Println("file size is", n.Size, "rest", rest) @@ -172,12 +172,12 @@ func (v *Volume) copyDataAndGenerateIndexFile(srcName, dstName, idxName string) n.Data = bytes[:n.Size] n.Checksum = NewCRC(n.Data) n.Append(dst) - new_offset += rest+16 + new_offset += rest + 16 log.Println("saving key", n.Id, "volume offset", old_offset, "=>", new_offset, "data_size", n.Size, "rest", rest) } - src.Seek(int64(rest-n.Size-4), 1) + src.Seek(int64(rest-n.Size-4), 1) } - old_offset += rest+16 + old_offset += rest + 16 n, rest = ReadNeedle(src) } |