forked from TrueCloudLab/frostfs-api-go
6f4908edc2
The speed of copying (which is done regulary for e.g. subnet changes) is less, however it isn't on the hot path and the absolute time difference is insignificant. ``` name old time/op new time/op delta NodeAttributes-8 96.2ns ± 1% 158.3ns ± 1% +64.61% (p=0.000 n=10+10) name old alloc/op new alloc/op delta NodeAttributes-8 32.0B ± 0% 32.0B ± 0% ~ (all equal) name old allocs/op new allocs/op delta NodeAttributes-8 2.00 ± 0% 2.00 ± 0% ~ (all equal) ``` Signed-off-by: Evgenii Stratonikov <evgeniy@nspcc.ru>
682 lines
13 KiB
Go
682 lines
13 KiB
Go
package netmap
|
|
|
|
import (
|
|
netmap "github.com/nspcc-dev/neofs-api-go/v2/netmap/grpc"
|
|
"github.com/nspcc-dev/neofs-api-go/v2/rpc/message"
|
|
protoutil "github.com/nspcc-dev/neofs-api-go/v2/util/proto"
|
|
)
|
|
|
|
const (
|
|
nameFilterField = 1
|
|
keyFilterField = 2
|
|
opFilterField = 3
|
|
valueFilterField = 4
|
|
filtersFilterField = 5
|
|
|
|
nameSelectorField = 1
|
|
countSelectorField = 2
|
|
clauseSelectorField = 3
|
|
attributeSelectorField = 4
|
|
filterSelectorField = 5
|
|
|
|
countReplicaField = 1
|
|
selectorReplicaField = 2
|
|
|
|
replicasPolicyField = 1
|
|
backupPolicyField = 2
|
|
selectorsPolicyField = 3
|
|
filtersPolicyField = 4
|
|
subnetIDPolicyField = 5
|
|
|
|
keyAttributeField = 1
|
|
valueAttributeField = 2
|
|
parentsAttributeField = 3
|
|
|
|
keyNodeInfoField = 1
|
|
addressNodeInfoField = 2
|
|
attributesNodeInfoField = 3
|
|
stateNodeInfoField = 4
|
|
|
|
versionInfoResponseBodyField = 1
|
|
nodeInfoResponseBodyField = 2
|
|
)
|
|
|
|
func (f *Filter) StableMarshal(buf []byte) ([]byte, error) {
|
|
if f == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, f.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.StringMarshal(nameFilterField, buf[offset:], f.name)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.StringMarshal(keyFilterField, buf[offset:], f.key)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.EnumMarshal(opFilterField, buf[offset:], int32(f.op))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.StringMarshal(valueFilterField, buf[offset:], f.value)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
for i := range f.filters {
|
|
n, err = protoutil.NestedStructureMarshal(filtersFilterField, buf[offset:], &f.filters[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (f *Filter) StableSize() (size int) {
|
|
size += protoutil.StringSize(nameFilterField, f.name)
|
|
size += protoutil.StringSize(keyFilterField, f.key)
|
|
size += protoutil.EnumSize(opFilterField, int32(f.op))
|
|
size += protoutil.StringSize(valueFilterField, f.value)
|
|
for i := range f.filters {
|
|
size += protoutil.NestedStructureSize(filtersFilterField, &f.filters[i])
|
|
}
|
|
|
|
return size
|
|
}
|
|
|
|
func (f *Filter) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(f, data, new(netmap.Filter))
|
|
}
|
|
|
|
func (s *Selector) StableMarshal(buf []byte) ([]byte, error) {
|
|
if s == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, s.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.StringMarshal(nameSelectorField, buf[offset:], s.name)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.UInt32Marshal(countSelectorField, buf[offset:], s.count)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.EnumMarshal(clauseSelectorField, buf[offset:], int32(s.clause))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.StringMarshal(attributeSelectorField, buf[offset:], s.attribute)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
_, err = protoutil.StringMarshal(filterSelectorField, buf[offset:], s.filter)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (s *Selector) StableSize() (size int) {
|
|
size += protoutil.StringSize(nameSelectorField, s.name)
|
|
size += protoutil.UInt32Size(countSelectorField, s.count)
|
|
size += protoutil.EnumSize(countSelectorField, int32(s.clause))
|
|
size += protoutil.StringSize(attributeSelectorField, s.attribute)
|
|
size += protoutil.StringSize(filterSelectorField, s.filter)
|
|
|
|
return size
|
|
}
|
|
|
|
func (s *Selector) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(s, data, new(netmap.Selector))
|
|
}
|
|
|
|
func (r *Replica) StableMarshal(buf []byte) ([]byte, error) {
|
|
if r == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, r.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.UInt32Marshal(countReplicaField, buf[offset:], r.count)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
_, err = protoutil.StringMarshal(selectorReplicaField, buf[offset:], r.selector)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (r *Replica) StableSize() (size int) {
|
|
size += protoutil.UInt32Size(countReplicaField, r.count)
|
|
size += protoutil.StringSize(selectorReplicaField, r.selector)
|
|
|
|
return size
|
|
}
|
|
|
|
func (r *Replica) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(r, data, new(netmap.Replica))
|
|
}
|
|
|
|
func (p *PlacementPolicy) StableMarshal(buf []byte) ([]byte, error) {
|
|
if p == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, p.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
for i := range p.replicas {
|
|
n, err = protoutil.NestedStructureMarshal(replicasPolicyField, buf[offset:], &p.replicas[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
n, err = protoutil.UInt32Marshal(backupPolicyField, buf[offset:], p.backupFactor)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
for i := range p.selectors {
|
|
n, err = protoutil.NestedStructureMarshal(selectorsPolicyField, buf[offset:], &p.selectors[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
for i := range p.filters {
|
|
n, err = protoutil.NestedStructureMarshal(filtersPolicyField, buf[offset:], &p.filters[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
_, err = protoutil.NestedStructureMarshal(subnetIDPolicyField, buf[offset:], p.subnetID)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (p *PlacementPolicy) StableSize() (size int) {
|
|
for i := range p.replicas {
|
|
size += protoutil.NestedStructureSize(replicasPolicyField, &p.replicas[i])
|
|
}
|
|
|
|
size += protoutil.UInt32Size(backupPolicyField, p.backupFactor)
|
|
|
|
for i := range p.selectors {
|
|
size += protoutil.NestedStructureSize(selectorsPolicyField, &p.selectors[i])
|
|
}
|
|
|
|
for i := range p.filters {
|
|
size += protoutil.NestedStructureSize(filtersPolicyField, &p.filters[i])
|
|
}
|
|
|
|
size += protoutil.NestedStructureSize(subnetIDPolicyField, p.subnetID)
|
|
|
|
return size
|
|
}
|
|
|
|
func (p *PlacementPolicy) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(p, data, new(netmap.PlacementPolicy))
|
|
}
|
|
|
|
func (a *Attribute) StableMarshal(buf []byte) ([]byte, error) {
|
|
if a == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, a.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.StringMarshal(keyAttributeField, buf[offset:], a.key)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.StringMarshal(valueAttributeField, buf[offset:], a.value)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
for i := range a.parents {
|
|
n, err = protoutil.StringMarshal(parentsAttributeField, buf[offset:], a.parents[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (a *Attribute) StableSize() (size int) {
|
|
if a == nil {
|
|
return 0
|
|
}
|
|
|
|
size += protoutil.StringSize(keyAttributeField, a.key)
|
|
size += protoutil.StringSize(valueAttributeField, a.value)
|
|
|
|
for i := range a.parents {
|
|
size += protoutil.StringSize(parentsAttributeField, a.parents[i])
|
|
}
|
|
|
|
return size
|
|
}
|
|
|
|
func (a *Attribute) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(a, data, new(netmap.NodeInfo_Attribute))
|
|
}
|
|
|
|
func (ni *NodeInfo) StableMarshal(buf []byte) ([]byte, error) {
|
|
if ni == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, ni.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.BytesMarshal(keyNodeInfoField, buf[offset:], ni.publicKey)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.RepeatedStringMarshal(addressNodeInfoField, buf[offset:], ni.addresses)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
for i := range ni.attributes {
|
|
n, err = protoutil.NestedStructureMarshal(attributesNodeInfoField, buf[offset:], &ni.attributes[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
_, err = protoutil.EnumMarshal(stateNodeInfoField, buf[offset:], int32(ni.state))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (ni *NodeInfo) StableSize() (size int) {
|
|
if ni == nil {
|
|
return 0
|
|
}
|
|
|
|
size += protoutil.BytesSize(keyNodeInfoField, ni.publicKey)
|
|
size += protoutil.RepeatedStringSize(addressNodeInfoField, ni.addresses)
|
|
|
|
for i := range ni.attributes {
|
|
size += protoutil.NestedStructureSize(attributesNodeInfoField, &ni.attributes[i])
|
|
}
|
|
|
|
size += protoutil.EnumSize(stateNodeInfoField, int32(ni.state))
|
|
|
|
return size
|
|
}
|
|
|
|
func (ni *NodeInfo) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(ni, data, new(netmap.NodeInfo))
|
|
}
|
|
|
|
func (l *LocalNodeInfoRequestBody) StableMarshal(buf []byte) ([]byte, error) {
|
|
return nil, nil
|
|
}
|
|
|
|
func (l *LocalNodeInfoRequestBody) StableSize() (size int) {
|
|
return 0
|
|
}
|
|
|
|
func (l *LocalNodeInfoRequestBody) Unmarshal([]byte) error {
|
|
return nil
|
|
}
|
|
|
|
func (l *LocalNodeInfoResponseBody) StableMarshal(buf []byte) ([]byte, error) {
|
|
if l == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, l.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.NestedStructureMarshal(versionInfoResponseBodyField, buf[offset:], l.version)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
_, err = protoutil.NestedStructureMarshal(nodeInfoResponseBodyField, buf[offset:], l.nodeInfo)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (l *LocalNodeInfoResponseBody) StableSize() (size int) {
|
|
if l == nil {
|
|
return 0
|
|
}
|
|
|
|
size += protoutil.NestedStructureSize(versionInfoResponseBodyField, l.version)
|
|
size += protoutil.NestedStructureSize(nodeInfoResponseBodyField, l.nodeInfo)
|
|
|
|
return size
|
|
}
|
|
|
|
func (l *LocalNodeInfoResponseBody) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(l, data, new(netmap.LocalNodeInfoResponse_Body))
|
|
}
|
|
|
|
const (
|
|
_ = iota
|
|
netPrmKeyFNum
|
|
netPrmValFNum
|
|
)
|
|
|
|
func (x *NetworkParameter) StableMarshal(buf []byte) ([]byte, error) {
|
|
if x == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, x.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.BytesMarshal(netPrmKeyFNum, buf[offset:], x.k)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
_, err = protoutil.BytesMarshal(netPrmValFNum, buf[offset:], x.v)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (x *NetworkParameter) StableSize() (size int) {
|
|
if x == nil {
|
|
return 0
|
|
}
|
|
|
|
size += protoutil.BytesSize(netPrmKeyFNum, x.k)
|
|
size += protoutil.BytesSize(netPrmValFNum, x.v)
|
|
|
|
return size
|
|
}
|
|
|
|
const (
|
|
_ = iota
|
|
netCfgPrmsFNum
|
|
)
|
|
|
|
func (x *NetworkConfig) StableMarshal(buf []byte) ([]byte, error) {
|
|
if x == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, x.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
for i := range x.ps {
|
|
n, err = protoutil.NestedStructureMarshal(netCfgPrmsFNum, buf[offset:], &x.ps[i])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (x *NetworkConfig) StableSize() (size int) {
|
|
if x == nil {
|
|
return 0
|
|
}
|
|
|
|
for i := range x.ps {
|
|
size += protoutil.NestedStructureSize(netCfgPrmsFNum, &x.ps[i])
|
|
}
|
|
|
|
return size
|
|
}
|
|
|
|
const (
|
|
_ = iota
|
|
netInfoCurEpochFNum
|
|
netInfoMagicNumFNum
|
|
netInfoMSPerBlockFNum
|
|
netInfoCfgFNum
|
|
)
|
|
|
|
func (i *NetworkInfo) StableMarshal(buf []byte) ([]byte, error) {
|
|
if i == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, i.StableSize())
|
|
}
|
|
|
|
var (
|
|
offset, n int
|
|
err error
|
|
)
|
|
|
|
n, err = protoutil.UInt64Marshal(netInfoCurEpochFNum, buf[offset:], i.curEpoch)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.UInt64Marshal(netInfoMagicNumFNum, buf[offset:], i.magicNum)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
n, err = protoutil.Int64Marshal(netInfoMSPerBlockFNum, buf[offset:], i.msPerBlock)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
offset += n
|
|
|
|
_, err = protoutil.NestedStructureMarshal(netInfoCfgFNum, buf[offset:], i.netCfg)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (i *NetworkInfo) StableSize() (size int) {
|
|
if i == nil {
|
|
return 0
|
|
}
|
|
|
|
size += protoutil.UInt64Size(netInfoCurEpochFNum, i.curEpoch)
|
|
size += protoutil.UInt64Size(netInfoMagicNumFNum, i.magicNum)
|
|
size += protoutil.Int64Size(netInfoMSPerBlockFNum, i.msPerBlock)
|
|
size += protoutil.NestedStructureSize(netInfoCfgFNum, i.netCfg)
|
|
|
|
return size
|
|
}
|
|
|
|
func (i *NetworkInfo) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(i, data, new(netmap.NetworkInfo))
|
|
}
|
|
|
|
func (l *NetworkInfoRequestBody) StableMarshal(buf []byte) ([]byte, error) {
|
|
return nil, nil
|
|
}
|
|
|
|
func (l *NetworkInfoRequestBody) StableSize() (size int) {
|
|
return 0
|
|
}
|
|
|
|
func (l *NetworkInfoRequestBody) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(l, data, new(netmap.NetworkInfoRequest_Body))
|
|
}
|
|
|
|
const (
|
|
_ = iota
|
|
netInfoRespBodyNetInfoFNum
|
|
)
|
|
|
|
func (i *NetworkInfoResponseBody) StableMarshal(buf []byte) ([]byte, error) {
|
|
if i == nil {
|
|
return []byte{}, nil
|
|
}
|
|
|
|
if buf == nil {
|
|
buf = make([]byte, i.StableSize())
|
|
}
|
|
|
|
_, err := protoutil.NestedStructureMarshal(netInfoRespBodyNetInfoFNum, buf, i.netInfo)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
func (i *NetworkInfoResponseBody) StableSize() (size int) {
|
|
if i == nil {
|
|
return 0
|
|
}
|
|
|
|
size += protoutil.NestedStructureSize(netInfoRespBodyNetInfoFNum, i.netInfo)
|
|
|
|
return size
|
|
}
|
|
|
|
func (i *NetworkInfoResponseBody) Unmarshal(data []byte) error {
|
|
return message.Unmarshal(i, data, new(netmap.NetworkInfoResponse_Body))
|
|
}
|