mirror of
https://github.com/chrislusf/seaweedfs
synced 2025-06-29 08:12:47 +02:00
16 lines
632 B
Go
16 lines
632 B
Go
package needle
|
|
|
|
import (
|
|
"bytes"
|
|
|
|
. "github.com/seaweedfs/seaweedfs/weed/storage/types"
|
|
"github.com/seaweedfs/seaweedfs/weed/util"
|
|
)
|
|
|
|
func writeNeedleV3(n *Needle, offset uint64, bytesBuffer *bytes.Buffer) (size Size, actualSize int64, err error) {
|
|
return writeNeedleCommon(n, offset, bytesBuffer, Version3, func(n *Needle, header []byte, bytesBuffer *bytes.Buffer, padding int) {
|
|
util.Uint32toBytes(header[0:NeedleChecksumSize], uint32(n.Checksum))
|
|
util.Uint64toBytes(header[NeedleChecksumSize:NeedleChecksumSize+TimestampSize], n.AppendAtNs)
|
|
bytesBuffer.Write(header[0 : NeedleChecksumSize+TimestampSize+padding])
|
|
})
|
|
}
|