aboutsummaryrefslogtreecommitdiff
path: root/go
diff options
context:
space:
mode:
authorchrislusf <chris.lu@gmail.com>2015-07-10 09:43:49 -0700
committerchrislusf <chris.lu@gmail.com>2015-07-10 09:43:49 -0700
commit2c595d2d16629f7163587e1a08f2419c3df78ecc (patch)
treee86adb663d08ce282eeb2153ccecb8ad99b247fb /go
parenta4d3f2da3d0c5bf19b6bd924df72d7b2484b9f79 (diff)
downloadseaweedfs-2c595d2d16629f7163587e1a08f2419c3df78ecc.tar.xz
seaweedfs-2c595d2d16629f7163587e1a08f2419c3df78ecc.zip
skip isFileUnchanged checking since ttl always change
skip checking since ttl always change. Fixing https://github.com/chrislusf/seaweedfs/issues/166
Diffstat (limited to 'go')
-rw-r--r--go/storage/volume.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/go/storage/volume.go b/go/storage/volume.go
index 0e6cadecc..998b0dd64 100644
--- a/go/storage/volume.go
+++ b/go/storage/volume.go
@@ -152,6 +152,9 @@ func (v *Volume) NeedToReplicate() bool {
// isFileUnchanged checks whether this needle to write is same as last one.
// It requires serialized access in the same volume.
func (v *Volume) isFileUnchanged(n *Needle) bool {
+ if v.Ttl == EMPTY_TTL || v.Ttl.String() == "" {
+ return true
+ }
nv, ok := v.nm.Get(n.Id)
if ok && nv.Offset > 0 {
oldNeedle := new(Needle)