diff options
| -rw-r--r-- | weed/storage/volume_write.go | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/weed/storage/volume_write.go b/weed/storage/volume_write.go index 223e19577..2dc813216 100644 --- a/weed/storage/volume_write.go +++ b/weed/storage/volume_write.go @@ -157,7 +157,7 @@ func (v *Volume) doWriteRequest(n *needle.Needle, checkCookie bool) (offset uint } // append to dat file - n.AppendAtNs = uint64(time.Now().UnixNano()) + n.AppendAtNs = max(uint64(time.Now().UnixNano()), v.lastAppendAtNs+1) offset, size, _, err = n.Append(v.DataBackend, v.Version()) v.checkReadWriteError(err) if err != nil { @@ -330,3 +330,10 @@ func (v *Volume) WriteNeedleBlob(needleId NeedleId, needleBlob []byte, size Size return err } + +func max(x, y uint64) uint64 { + if x <= y { + return y + } + return x +} |