diff --git a/api/accounting/grpc/service_frostfs.pb.go b/api/accounting/grpc/service_frostfs.pb.go index 86502ef..f7ac562 100644 --- a/api/accounting/grpc/service_frostfs.pb.go +++ b/api/accounting/grpc/service_frostfs.pb.go @@ -40,7 +40,7 @@ func (x *BalanceRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BalanceRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -201,7 +201,7 @@ func (x *BalanceRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BalanceRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -416,7 +416,7 @@ func (x *BalanceResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BalanceResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -577,7 +577,7 @@ func (x *BalanceResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BalanceResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/accounting/grpc/types_frostfs.pb.go b/api/accounting/grpc/types_frostfs.pb.go index 9d0e9ea..baf5436 100644 --- a/api/accounting/grpc/types_frostfs.pb.go +++ b/api/accounting/grpc/types_frostfs.pb.go @@ -41,7 +41,7 @@ func (x *Decimal) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Decimal) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/acl/grpc/types_frostfs.pb.go b/api/acl/grpc/types_frostfs.pb.go index eed28d6..cdb58a0 100644 --- a/api/acl/grpc/types_frostfs.pb.go +++ b/api/acl/grpc/types_frostfs.pb.go @@ -243,7 +243,7 @@ func (x *EACLRecord_Filter) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *EACLRecord_Filter) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -524,7 +524,7 @@ func (x *EACLRecord_Target) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *EACLRecord_Target) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -748,7 +748,7 @@ func (x *EACLRecord) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *EACLRecord) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1071,7 +1071,7 @@ func (x *EACLTable) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *EACLTable) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1305,7 +1305,7 @@ func (x *BearerToken_Body_TokenLifetime) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BearerToken_Body_TokenLifetime) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1542,7 +1542,7 @@ func (x *BearerToken_Body_APEOverride) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BearerToken_Body_APEOverride) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1742,7 +1742,7 @@ func (x *BearerToken_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BearerToken_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2031,7 +2031,7 @@ func (x *BearerToken) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *BearerToken) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/ape/grpc/types_frostfs.pb.go b/api/ape/grpc/types_frostfs.pb.go index 0e204bd..8321e45 100644 --- a/api/ape/grpc/types_frostfs.pb.go +++ b/api/ape/grpc/types_frostfs.pb.go @@ -82,7 +82,7 @@ func (x *ChainTarget) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ChainTarget) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -274,7 +274,7 @@ func (x *Chain) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Chain) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/apemanager/grpc/service_frostfs.pb.go b/api/apemanager/grpc/service_frostfs.pb.go index 402c908..efbe074 100644 --- a/api/apemanager/grpc/service_frostfs.pb.go +++ b/api/apemanager/grpc/service_frostfs.pb.go @@ -42,7 +42,7 @@ func (x *AddChainRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *AddChainRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -241,7 +241,7 @@ func (x *AddChainRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *AddChainRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -456,7 +456,7 @@ func (x *AddChainResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *AddChainResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -623,7 +623,7 @@ func (x *AddChainResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *AddChainResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -840,7 +840,7 @@ func (x *RemoveChainRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *RemoveChainRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1045,7 +1045,7 @@ func (x *RemoveChainRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *RemoveChainRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1258,7 +1258,7 @@ func (x *RemoveChainResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *RemoveChainResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1377,7 +1377,7 @@ func (x *RemoveChainResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *RemoveChainResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1592,7 +1592,7 @@ func (x *ListChainsRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListChainsRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1753,7 +1753,7 @@ func (x *ListChainsRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListChainsRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1970,7 +1970,7 @@ func (x *ListChainsResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListChainsResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2146,7 +2146,7 @@ func (x *ListChainsResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListChainsResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/container/grpc/service_frostfs.pb.go b/api/container/grpc/service_frostfs.pb.go index 0388293..5071ba3 100644 --- a/api/container/grpc/service_frostfs.pb.go +++ b/api/container/grpc/service_frostfs.pb.go @@ -42,7 +42,7 @@ func (x *PutRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -241,7 +241,7 @@ func (x *PutRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -456,7 +456,7 @@ func (x *PutResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -617,7 +617,7 @@ func (x *PutResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -834,7 +834,7 @@ func (x *DeleteRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1033,7 +1033,7 @@ func (x *DeleteRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1246,7 +1246,7 @@ func (x *DeleteResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1365,7 +1365,7 @@ func (x *DeleteResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1580,7 +1580,7 @@ func (x *GetRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1741,7 +1741,7 @@ func (x *GetRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1960,7 +1960,7 @@ func (x *GetResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2197,7 +2197,7 @@ func (x *GetResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2412,7 +2412,7 @@ func (x *ListRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2573,7 +2573,7 @@ func (x *ListRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2790,7 +2790,7 @@ func (x *ListResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2966,7 +2966,7 @@ func (x *ListResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3181,7 +3181,7 @@ func (x *ListStreamRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListStreamRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3342,7 +3342,7 @@ func (x *ListStreamRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListStreamRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3559,7 +3559,7 @@ func (x *ListStreamResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListStreamResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3735,7 +3735,7 @@ func (x *ListStreamResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ListStreamResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/container/grpc/types_frostfs.pb.go b/api/container/grpc/types_frostfs.pb.go index fa4aead..a4e8dd4 100644 --- a/api/container/grpc/types_frostfs.pb.go +++ b/api/container/grpc/types_frostfs.pb.go @@ -43,7 +43,7 @@ func (x *Container_Attribute) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Container_Attribute) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -224,7 +224,7 @@ func (x *Container) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Container) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/lock/grpc/types_frostfs.pb.go b/api/lock/grpc/types_frostfs.pb.go index 19e45b0..42e08a9 100644 --- a/api/lock/grpc/types_frostfs.pb.go +++ b/api/lock/grpc/types_frostfs.pb.go @@ -41,7 +41,7 @@ func (x *Lock) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Lock) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/netmap/grpc/service_frostfs.pb.go b/api/netmap/grpc/service_frostfs.pb.go index 7e2d7a3..b71f49d 100644 --- a/api/netmap/grpc/service_frostfs.pb.go +++ b/api/netmap/grpc/service_frostfs.pb.go @@ -38,7 +38,7 @@ func (x *LocalNodeInfoRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *LocalNodeInfoRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -157,7 +157,7 @@ func (x *LocalNodeInfoRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *LocalNodeInfoRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -374,7 +374,7 @@ func (x *LocalNodeInfoResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *LocalNodeInfoResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -573,7 +573,7 @@ func (x *LocalNodeInfoResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *LocalNodeInfoResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -786,7 +786,7 @@ func (x *NetworkInfoRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkInfoRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -905,7 +905,7 @@ func (x *NetworkInfoRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkInfoRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1120,7 +1120,7 @@ func (x *NetworkInfoResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkInfoResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1281,7 +1281,7 @@ func (x *NetworkInfoResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkInfoResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1494,7 +1494,7 @@ func (x *NetmapSnapshotRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetmapSnapshotRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1613,7 +1613,7 @@ func (x *NetmapSnapshotRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetmapSnapshotRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1828,7 +1828,7 @@ func (x *NetmapSnapshotResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetmapSnapshotResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1989,7 +1989,7 @@ func (x *NetmapSnapshotResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetmapSnapshotResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/netmap/grpc/types_frostfs.pb.go b/api/netmap/grpc/types_frostfs.pb.go index 15f8959..8266d1a 100644 --- a/api/netmap/grpc/types_frostfs.pb.go +++ b/api/netmap/grpc/types_frostfs.pb.go @@ -143,7 +143,7 @@ func (x *Filter) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Filter) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -462,7 +462,7 @@ func (x *Selector) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Selector) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -768,7 +768,7 @@ func (x *Replica) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Replica) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1043,7 +1043,7 @@ func (x *PlacementPolicy) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PlacementPolicy) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1421,7 +1421,7 @@ func (x *NodeInfo_Attribute) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NodeInfo_Attribute) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1646,7 +1646,7 @@ func (x *NodeInfo) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NodeInfo) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1951,7 +1951,7 @@ func (x *Netmap) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Netmap) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2151,7 +2151,7 @@ func (x *NetworkConfig_Parameter) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkConfig_Parameter) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2342,7 +2342,7 @@ func (x *NetworkConfig) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkConfig) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2502,7 +2502,7 @@ func (x *NetworkInfo) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *NetworkInfo) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/object/grpc/service_frostfs.pb.go b/api/object/grpc/service_frostfs.pb.go index a195f86..d039747 100644 --- a/api/object/grpc/service_frostfs.pb.go +++ b/api/object/grpc/service_frostfs.pb.go @@ -43,7 +43,7 @@ func (x *GetRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -238,7 +238,7 @@ func (x *GetRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -457,7 +457,7 @@ func (x *GetResponse_Body_Init) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetResponse_Body_Init) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -683,7 +683,7 @@ func (x *GetResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1035,7 +1035,7 @@ func (x *GetResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1258,7 +1258,7 @@ func (x *PutRequest_Body_Init) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutRequest_Body_Init) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1534,7 +1534,7 @@ func (x *PutRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1786,7 +1786,7 @@ func (x *PutRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2001,7 +2001,7 @@ func (x *PutResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2162,7 +2162,7 @@ func (x *PutResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2377,7 +2377,7 @@ func (x *DeleteRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2538,7 +2538,7 @@ func (x *DeleteRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2753,7 +2753,7 @@ func (x *DeleteResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2914,7 +2914,7 @@ func (x *DeleteResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *DeleteResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3133,7 +3133,7 @@ func (x *HeadRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *HeadRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3362,7 +3362,7 @@ func (x *HeadRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *HeadRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3579,7 +3579,7 @@ func (x *HeaderWithSignature) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *HeaderWithSignature) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -3767,7 +3767,7 @@ func (x *HeadResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *HeadResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -4105,7 +4105,7 @@ func (x *HeadResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *HeadResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -4324,7 +4324,7 @@ func (x *SearchRequest_Body_Filter) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SearchRequest_Body_Filter) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -4554,7 +4554,7 @@ func (x *SearchRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SearchRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -4810,7 +4810,7 @@ func (x *SearchRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SearchRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -5027,7 +5027,7 @@ func (x *SearchResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SearchResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -5203,7 +5203,7 @@ func (x *SearchResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SearchResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -5420,7 +5420,7 @@ func (x *Range) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Range) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -5613,7 +5613,7 @@ func (x *GetRangeRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -5846,7 +5846,7 @@ func (x *GetRangeRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -6069,7 +6069,7 @@ func (x *GetRangeResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -6371,7 +6371,7 @@ func (x *GetRangeResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -6594,7 +6594,7 @@ func (x *GetRangeHashRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeHashRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -6907,7 +6907,7 @@ func (x *GetRangeHashRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeHashRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -7124,7 +7124,7 @@ func (x *GetRangeHashResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeHashResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -7360,7 +7360,7 @@ func (x *GetRangeHashResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *GetRangeHashResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -7579,7 +7579,7 @@ func (x *PutSingleRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutSingleRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -7796,7 +7796,7 @@ func (x *PutSingleRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutSingleRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -8009,7 +8009,7 @@ func (x *PutSingleResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutSingleResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -8128,7 +8128,7 @@ func (x *PutSingleResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PutSingleResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -8345,7 +8345,7 @@ func (x *PatchRequest_Body_Patch) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PatchRequest_Body_Patch) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -8536,7 +8536,7 @@ func (x *PatchRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PatchRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -8822,7 +8822,7 @@ func (x *PatchRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PatchRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -9037,7 +9037,7 @@ func (x *PatchResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PatchResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -9198,7 +9198,7 @@ func (x *PatchResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *PatchResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/object/grpc/types_frostfs.pb.go b/api/object/grpc/types_frostfs.pb.go index 6c9925c..78d54a4 100644 --- a/api/object/grpc/types_frostfs.pb.go +++ b/api/object/grpc/types_frostfs.pb.go @@ -129,7 +129,7 @@ func (x *ShortHeader) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ShortHeader) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -527,7 +527,7 @@ func (x *Header_Attribute) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Header_Attribute) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -708,7 +708,7 @@ func (x *Header_Split) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Header_Split) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1074,7 +1074,7 @@ func (x *Header_EC) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Header_EC) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1542,7 +1542,7 @@ func (x *Header) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Header) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2149,7 +2149,7 @@ func (x *Object) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Object) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2412,7 +2412,7 @@ func (x *SplitInfo) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SplitInfo) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2637,7 +2637,7 @@ func (x *ECInfo_Chunk) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ECInfo_Chunk) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2862,7 +2862,7 @@ func (x *ECInfo) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ECInfo) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/refs/grpc/types_frostfs.pb.go b/api/refs/grpc/types_frostfs.pb.go index f0a10f3..9aef68d 100644 --- a/api/refs/grpc/types_frostfs.pb.go +++ b/api/refs/grpc/types_frostfs.pb.go @@ -111,7 +111,7 @@ func (x *Address) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Address) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -288,7 +288,7 @@ func (x *ObjectID) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ObjectID) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -433,7 +433,7 @@ func (x *ContainerID) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ContainerID) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -578,7 +578,7 @@ func (x *OwnerID) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *OwnerID) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -725,7 +725,7 @@ func (x *Version) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Version) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -914,7 +914,7 @@ func (x *Signature) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Signature) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1160,7 +1160,7 @@ func (x *SignatureRFC6979) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SignatureRFC6979) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1351,7 +1351,7 @@ func (x *Checksum) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Checksum) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/rpc/client/client.go b/api/rpc/client/client.go index eeac896..6370349 100644 --- a/api/rpc/client/client.go +++ b/api/rpc/client/client.go @@ -4,6 +4,8 @@ import ( "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/api/util/proto/encoding" "google.golang.org/grpc" "google.golang.org/grpc/credentials" + "google.golang.org/grpc/experimental" + "google.golang.org/grpc/mem" ) // Client represents client for exchanging messages @@ -25,6 +27,7 @@ func New(opts ...Option) *Client { if c.tlsCfg != nil { c.grpcDialOpts = append(c.grpcDialOpts, grpc.WithTransportCredentials(credentials.NewTLS(c.tlsCfg))) } + c.grpcDialOpts = append(c.grpcDialOpts, experimental.WithBufferPool(mem.NopBufferPool{})) return &c } diff --git a/api/rpc/client/connect.go b/api/rpc/client/connect.go index e22e0a6..1c85d63 100644 --- a/api/rpc/client/connect.go +++ b/api/rpc/client/connect.go @@ -8,6 +8,8 @@ import ( "net/url" grpcstd "google.golang.org/grpc" + "google.golang.org/grpc/experimental" + "google.golang.org/grpc/mem" ) var errInvalidEndpoint = errors.New("invalid endpoint options") @@ -23,10 +25,16 @@ func (c *Client) openGRPCConn(ctx context.Context, dialer func(ctx context.Conte var err error - c.conn, err = grpcstd.NewClient(c.addr, c.grpcDialOpts...) + //experimental.WithBufferPool() + c.grpcDialOpts = append(c.grpcDialOpts, experimental.WithBufferPool(mem.NopBufferPool{})) + conn, err := grpcstd.NewClient(c.addr, c.grpcDialOpts...) if err != nil { + //spew.Dump("openGRPCConn " + err.Error()) return fmt.Errorf("gRPC new client: %w", err) } + //conn.GetState() + //conn.WaitForStateChange() + c.conn = conn if dialer != nil { ctx, cancel := context.WithTimeout(ctx, c.dialTimeout) diff --git a/api/session/grpc/service_frostfs.pb.go b/api/session/grpc/service_frostfs.pb.go index 1c8e02b..c332525 100644 --- a/api/session/grpc/service_frostfs.pb.go +++ b/api/session/grpc/service_frostfs.pb.go @@ -42,7 +42,7 @@ func (x *CreateRequest_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *CreateRequest_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -247,7 +247,7 @@ func (x *CreateRequest) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *CreateRequest) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -464,7 +464,7 @@ func (x *CreateResponse_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *CreateResponse_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -675,7 +675,7 @@ func (x *CreateResponse) ReadSignedData(buf []byte) ([]byte, error) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *CreateResponse) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/session/grpc/types_frostfs.pb.go b/api/session/grpc/types_frostfs.pb.go index c62c1ff..f74723b 100644 --- a/api/session/grpc/types_frostfs.pb.go +++ b/api/session/grpc/types_frostfs.pb.go @@ -99,7 +99,7 @@ func (x *ObjectSessionContext_Target) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ObjectSessionContext_Target) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -293,7 +293,7 @@ func (x *ObjectSessionContext) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ObjectSessionContext) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -529,7 +529,7 @@ func (x *ContainerSessionContext) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ContainerSessionContext) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -761,7 +761,7 @@ func (x *SessionToken_Body_TokenLifetime) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SessionToken_Body_TokenLifetime) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1007,7 +1007,7 @@ func (x *SessionToken_Body) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SessionToken_Body) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1389,7 +1389,7 @@ func (x *SessionToken) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *SessionToken) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1568,7 +1568,7 @@ func (x *XHeader) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *XHeader) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -1753,7 +1753,7 @@ func (x *RequestMetaHeader) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *RequestMetaHeader) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2201,7 +2201,7 @@ func (x *ResponseMetaHeader) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ResponseMetaHeader) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2561,7 +2561,7 @@ func (x *RequestVerificationHeader) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *RequestVerificationHeader) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -2820,7 +2820,7 @@ func (x *ResponseVerificationHeader) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *ResponseVerificationHeader) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/status/grpc/types_frostfs.pb.go b/api/status/grpc/types_frostfs.pb.go index 35dec11..ab45700 100644 --- a/api/status/grpc/types_frostfs.pb.go +++ b/api/status/grpc/types_frostfs.pb.go @@ -295,7 +295,7 @@ func (x *Status_Detail) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Status_Detail) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst @@ -488,7 +488,7 @@ func (x *Status) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Status) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/tombstone/grpc/types_frostfs.pb.go b/api/tombstone/grpc/types_frostfs.pb.go index df31004..cf6f792 100644 --- a/api/tombstone/grpc/types_frostfs.pb.go +++ b/api/tombstone/grpc/types_frostfs.pb.go @@ -46,7 +46,7 @@ func (x *Tombstone) StableSize() (size int) { // MarshalProtobuf implements the encoding.ProtoMarshaler interface. func (x *Tombstone) MarshalProtobuf(dst []byte) []byte { m := pool.MarshalerPool.Get() - defer pool.MarshalerPool.Put(m) + m = new(easyproto.Marshaler) x.EmitProtobuf(m.MessageMarshaler()) dst = m.Marshal(dst) return dst diff --git a/api/util/proto/test/test.proto b/api/util/proto/test/test.proto deleted file mode 100644 index 58cee2f..0000000 --- a/api/util/proto/test/test.proto +++ /dev/null @@ -1,46 +0,0 @@ -syntax = "proto3"; - -package test; - -option go_package = "util/proto/test"; - -message Primitives { - bytes field_a = 1; - string field_b = 2; - bool field_c = 200; - int32 field_d = 201; - uint32 field_e = 202; - int64 field_f = 203; - uint64 field_g = 204; - fixed64 field_i = 205; - double field_j = 206; - fixed32 field_k = 207; - - enum SomeEnum { - UNKNOWN = 0; - POSITIVE = 1; - NEGATIVE = -1; - } - SomeEnum field_h = 300; - - message Aux { uint32 inner_field = 1; } - - oneof field_m { - bytes field_ma = 401; - uint32 field_me = 402; - Aux field_aux = 403; - } -} - -message RepPrimitives { - repeated bytes field_a = 1; - repeated string field_b = 2; - repeated int32 field_c = 3; - repeated uint32 field_d = 4; - repeated int64 field_e = 5; - repeated uint64 field_f = 6; - repeated uint64 field_fu = 7 [ packed = false ]; - - message Aux { uint32 inner_field = 1; } - repeated Aux field_aux = 8; -} diff --git a/api/util/protogen/internalgengo/proto.go b/api/util/protogen/internalgengo/proto.go index 1467541..a56fdd8 100644 --- a/api/util/protogen/internalgengo/proto.go +++ b/api/util/protogen/internalgengo/proto.go @@ -87,8 +87,16 @@ func emitFieldUnmarshal(g *protogen.GeneratedFile, f *protogen.Field) { func emitMarshalProtobuf(g *protogen.GeneratedFile, msg *protogen.Message) { g.P("// MarshalProtobuf implements the encoding.ProtoMarshaler interface.") g.P("func (x *", msg.GoIdent.GoName, ") MarshalProtobuf(dst []byte) []byte {") + g.P("m := ", mp, ".Get()") - g.P("defer ", mp, ".Put(m)") + // g.P("if size := x.StableSize(); size < 1 << 20 {") + // { + // g.P("m = ", mp, ".Get()") + // g.P("defer ", mp, ".Put(m)") + // } + // g.P("} else { m = new(", easyprotoPackage.Ident("Marshaler"), ") }") + g.P("m = new(", easyprotoPackage.Ident("Marshaler"), ")") + g.P("x.EmitProtobuf(m.MessageMarshaler())") g.P("dst = m.Marshal(dst)") g.P("return dst") diff --git a/go.mod b/go.mod index 9e459f2..3235731 100644 --- a/go.mod +++ b/go.mod @@ -2,6 +2,11 @@ module git.frostfs.info/TrueCloudLab/frostfs-sdk-go go 1.22 +replace ( + google.golang.org/grpc v1.66.2 => /home/annikifa/workspace/grpc-go/ +) + + require ( git.frostfs.info/TrueCloudLab/frostfs-contract v0.19.3-0.20240621131249-49e5270f673e git.frostfs.info/TrueCloudLab/frostfs-crypto v0.6.0 diff --git a/object/transformer/transformer.go b/object/transformer/transformer.go index f7e5cd3..bcfc5ad 100644 --- a/object/transformer/transformer.go +++ b/object/transformer/transformer.go @@ -37,6 +37,7 @@ type payloadSizeLimiter struct { type Params struct { Key *ecdsa.PrivateKey NextTargetInit TargetInitializer + OnClose func() error SessionToken *session.Object NetworkState EpochSource MaxSize uint64 @@ -80,7 +81,17 @@ func (s *payloadSizeLimiter) Write(ctx context.Context, p []byte) (int, error) { } func (s *payloadSizeLimiter) Close(ctx context.Context) (*AccessIdentifiers, error) { - return s.release(ctx, true) + ai, err := s.release(ctx, true) + if err != nil { + return nil, err + } + if s.OnClose != nil { + err = s.OnClose() + if err != nil { + return nil, err + } + } + return ai, err } func (s *payloadSizeLimiter) initialize() {