diff options
| author | Chris Lu <chris.lu@gmail.com> | 2012-11-12 01:26:18 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2012-11-12 01:26:18 -0800 |
| commit | ecd0399f8d3e60b6f065258b92901e5b06faffe9 (patch) | |
| tree | ba3d1d45d75901cd5b56f156ffbb7613af62fb18 /weed-fs/src/pkg | |
| parent | ccab4217e4aea86d5db02606f62437783c0c1cec (diff) | |
| download | seaweedfs-ecd0399f8d3e60b6f065258b92901e5b06faffe9.tar.xz seaweedfs-ecd0399f8d3e60b6f065258b92901e5b06faffe9.zip | |
Issue 11: Failed to write to replicas for volumen 3
Avoid unnecessary master lookup
Diffstat (limited to 'weed-fs/src/pkg')
| -rw-r--r-- | weed-fs/src/pkg/storage/volume.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed-fs/src/pkg/storage/volume.go b/weed-fs/src/pkg/storage/volume.go index ee1d98b6a..3bc979251 100644 --- a/weed-fs/src/pkg/storage/volume.go +++ b/weed-fs/src/pkg/storage/volume.go @@ -73,6 +73,9 @@ func (v *Volume) readSuperBlock() { v.replicaType, _ = NewReplicationTypeFromByte(header[1]) } } +func (v *Volume) NeedToReplicate() bool{ + return v.replicaType.GetCopyCount()>1 +} func (v *Volume) write(n *Needle) uint32 { v.accessLock.Lock() |