aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-03-06 14:25:21 -0800
committerChris Lu <chris.lu@gmail.com>2021-03-06 14:26:27 -0800
commite9eddfb8a2bf05fd5770825d54de655914942d4f (patch)
tree395fc2442d3253cf5c0b3e0183e01fc1c2144f8d
parent8363be85486e97053cdac45e9d0a692fe76af02e (diff)
downloadseaweedfs-e9eddfb8a2bf05fd5770825d54de655914942d4f.tar.xz
seaweedfs-e9eddfb8a2bf05fd5770825d54de655914942d4f.zip
remove wrong writes
-rw-r--r--weed/storage/volume_stream_write.go2
1 files changed, 0 insertions, 2 deletions
diff --git a/weed/storage/volume_stream_write.go b/weed/storage/volume_stream_write.go
index f619de30b..955875aa2 100644
--- a/weed/storage/volume_stream_write.go
+++ b/weed/storage/volume_stream_write.go
@@ -48,8 +48,6 @@ func (v *Volume) StreamWrite(n *needle.Needle, data io.Reader, dataSize uint32)
// data checksum
util.Uint32toBytes(header[0:needle.NeedleChecksumSize], crcWriter.Sum())
- df.Write(header[0:needle.NeedleChecksumSize])
-
// write timestamp, padding
n.AppendAtNs = uint64(time.Now().UnixNano())
util.Uint64toBytes(header[needle.NeedleChecksumSize:needle.NeedleChecksumSize+TimestampSize], n.AppendAtNs)