mirror of
https://github.com/chrislusf/seaweedfs
synced 2024-07-02 23:26:42 +02:00
54 lines
1.2 KiB
Go
54 lines
1.2 KiB
Go
package types
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/chrislusf/seaweedfs/weed/util"
|
|
"math"
|
|
"strconv"
|
|
)
|
|
|
|
type Offset uint32
|
|
type Cookie uint32
|
|
|
|
const (
|
|
OffsetSize = 4
|
|
SizeSize = 4 // uint32 size
|
|
NeedleEntrySize = NeedleIdSize + OffsetSize + SizeSize
|
|
TimestampSize = 8 // int64 size
|
|
NeedlePaddingSize = 8
|
|
MaxPossibleVolumeSize = 4 * 1024 * 1024 * 1024 * 8
|
|
TombstoneFileSize = math.MaxUint32
|
|
CookieSize = 4
|
|
)
|
|
|
|
func CookieToBytes(bytes []byte, cookie Cookie) {
|
|
util.Uint32toBytes(bytes, uint32(cookie))
|
|
}
|
|
func Uint32ToCookie(cookie uint32) Cookie {
|
|
return Cookie(cookie)
|
|
}
|
|
|
|
func BytesToCookie(bytes []byte) Cookie {
|
|
return Cookie(util.BytesToUint32(bytes[0:4]))
|
|
}
|
|
|
|
func ParseCookie(cookieString string) (Cookie, error) {
|
|
cookie, err := strconv.ParseUint(cookieString, 16, 32)
|
|
if err != nil {
|
|
return 0, fmt.Errorf("needle cookie %s format error: %v", cookieString, err)
|
|
}
|
|
return Cookie(cookie), nil
|
|
}
|
|
|
|
func OffsetToBytes(bytes []byte, offset Offset) {
|
|
util.Uint32toBytes(bytes, uint32(offset))
|
|
}
|
|
|
|
func Uint32ToOffset(offset uint32) Offset {
|
|
return Offset(offset)
|
|
}
|
|
|
|
func BytesToOffset(bytes []byte) Offset {
|
|
return Offset(util.BytesToUint32(bytes[0:4]))
|
|
}
|