wip

Signed-off-by: Pavel Karpy <[email protected]>

object/convert.go

@@ -183,6 +183,7 @@ func (h *SplitHeader) ToGRPCMessage() grpc.Message {
 		m.SetParentSignature(h.parSig.ToGRPCMessage().(*refsGRPC.Signature))
 		m.SetChildren(refs.ObjectIDListToGRPCMessage(h.children))
 		m.SetSplitId(h.splitID)
+		m.SetInit(h.init.ToGRPCMessage().(*refsGRPC.ObjectID))
 	}
 
 	return m
@@ -224,6 +225,20 @@ func (h *SplitHeader) FromGRPCMessage(m grpc.Message) error {
 		}
 	}
 
+	init := v.GetInit()
+	if init == nil {
+		h.init = nil
+	} else {
+		if h.init == nil {
+			h.init = new(refs.ObjectID)
+		}
+
+		err = h.init.FromGRPCMessage(init)
+		if err != nil {
+			return err
+		}
+	}
+
 	parHdr := v.GetParentHeader()
 	if parHdr == nil {
 		h.parHdr = nil
@@ -529,6 +544,7 @@ func (s *SplitInfo) ToGRPCMessage() grpc.Message {
 
 		m.SetLastPart(s.lastPart.ToGRPCMessage().(*refsGRPC.ObjectID))
 		m.SetLink(s.link.ToGRPCMessage().(*refsGRPC.ObjectID))
+		m.SetInitPart(s.initPart.ToGRPCMessage().(*refsGRPC.ObjectID))
 		m.SetSplitId(s.splitID)
 	}
 
@@ -571,6 +587,20 @@ func (s *SplitInfo) FromGRPCMessage(m grpc.Message) error {
 		}
 	}
 
+	init := v.GetInitPart()
+	if init == nil {
+		s.initPart = nil
+	} else {
+		if s.initPart == nil {
+			s.initPart = new(refs.ObjectID)
+		}
+
+		err = s.initPart.FromGRPCMessage(init)
+		if err != nil {
+			return err
+		}
+	}
+
 	s.splitID = v.GetSplitId()
 
 	return nil

object/grpc/types.go

@@ -45,6 +45,10 @@ func (m *Header_Split) SetSplitId(v []byte) {
 	m.SplitId = v
 }
 
+func (m *Header_Split) SetInit(v *refs.ObjectID) {
+	m.Init = v
+}
+
 // SetContainerId sets identifier of the container.
 func (m *Header) SetContainerId(v *refs.ContainerID) {
 	m.ContainerId = v
@@ -170,6 +174,11 @@ func (m *SplitInfo) SetLink(v *refs.ObjectID) {
 	m.Link = v
 }
 
+// SetInitPart sets id of initializing object in split hierarchy.
+func (m *SplitInfo) SetInitPart(v *refs.ObjectID) {
+	m.InitPart = v
+}
+
 // FromString parses ObjectType from a string representation,
 // It is a reverse action to String().
 //

object/marshal.go

@@ -25,6 +25,7 @@ const (
 	splitHdrParentHeaderField    = 4
 	splitHdrChildrenField        = 5
 	splitHdrSplitIDField         = 6
+	splitHdrInitIDField          = 7
 
 	hdrVersionField         = 1
 	hdrContainerIDField     = 2
@@ -49,6 +50,7 @@ const (
 	splitInfoSplitIDField  = 1
 	splitInfoLastPartField = 2
 	splitInfoLinkField     = 3
+	splitInfoInitField     = 4
 
 	getReqBodyAddressField = 1
 	getReqBodyRawFlagField = 2
@@ -202,7 +204,8 @@ func (h *SplitHeader) StableMarshal(buf []byte) []byte {
 	offset += proto.NestedStructureMarshal(splitHdrParentSignatureField, buf[offset:], h.parSig)
 	offset += proto.NestedStructureMarshal(splitHdrParentHeaderField, buf[offset:], h.parHdr)
 	offset += refs.ObjectIDNestedListMarshal(splitHdrChildrenField, buf[offset:], h.children)
-	proto.BytesMarshal(splitHdrSplitIDField, buf[offset:], h.splitID)
+	offset += proto.BytesMarshal(splitHdrSplitIDField, buf[offset:], h.splitID)
+	proto.NestedStructureMarshal(splitHdrInitIDField, buf[offset:], h.init)
 
 	return buf
 }
@@ -218,6 +221,7 @@ func (h *SplitHeader) StableSize() (size int) {
 	size += proto.NestedStructureSize(splitHdrParentHeaderField, h.parHdr)
 	size += refs.ObjectIDNestedListSize(splitHdrChildrenField, h.children)
 	size += proto.BytesSize(splitHdrSplitIDField, h.splitID)
+	size += proto.NestedStructureSize(splitHdrInitIDField, h.init)
 
 	return size
 }
@@ -363,7 +367,8 @@ func (s *SplitInfo) StableMarshal(buf []byte) []byte {
 
 	offset += proto.BytesMarshal(splitInfoSplitIDField, buf[offset:], s.splitID)
 	offset += proto.NestedStructureMarshal(splitInfoLastPartField, buf[offset:], s.lastPart)
-	proto.NestedStructureMarshal(splitInfoLinkField, buf[offset:], s.link)
+	offset += proto.NestedStructureMarshal(splitInfoLinkField, buf[offset:], s.link)
+	proto.NestedStructureMarshal(splitInfoInitField, buf[offset:], s.initPart)
 
 	return buf
 }
@@ -376,6 +381,7 @@ func (s *SplitInfo) StableSize() (size int) {
 	size += proto.BytesSize(splitInfoSplitIDField, s.splitID)
 	size += proto.NestedStructureSize(splitInfoLastPartField, s.lastPart)
 	size += proto.NestedStructureSize(splitInfoLinkField, s.link)
+	size += proto.NestedStructureSize(splitInfoInitField, s.initPart)
 
 	return size
 }