[#9999] policer: Add EC chunk replication

Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>

@@ -77,3 +77,3 @@
 		Nodes:     nodes,
 	}
-	s.replicator.HandleTask(ctx, task, &res)
+	s.replicator.HandleReplicateTask(ctx, task, &res)

@@ -53,11 +54,6 @@ func (p *Policer) processObject(ctx context.Context, addrWithType objectcore.Add
 
 	c := &placementRequirements{}
 
-	var numOfContainerNodes int

@@ -0,0 +41,4 @@
+	c := &placementRequirements{}
+	checkedNodes := newNodeCache()
+
+	for i := range nn {

@@ -0,0 +48,4 @@
+		default:
+		}
+		rd := policy.ReplicaDescriptor(i)
+		// processNodes replaces rd.GetECDataCount() + rd.GetECParityCount() for len(nn[i]) for valid object type.

@@ -0,0 +96,4 @@
+}
+
+// processECChunk replicates EC chunk if needed.
+// Returns True if current chunk should be stored on current node.

@@ -0,0 +177,4 @@
+	return false
+}
+
+func (p *Policer) collectRequiredECChunks(nodes []netmap.NodeInfo, objInfo objectcore.Info) map[uint32][]netmap.NodeInfo {

@@ -248,2 +247,4 @@
+				return remoteReader.Head(ctx, prm)
 			},
 		),
+		policer.WithLocalObjectHeaderFunc(func(ctx context.Context, a oid.Address) (*objectSDK.Object, error) {

@@ -97,2 +107,4 @@
 	return res.Header(), nil
 }
+
+func (h *RemoteReader) Get(ctx context.Context, prm *RemoteRequestPrm) (*objectSDK.Object, error) {

@@ -0,0 +293,4 @@
+		return
+	}
+	if objInfo.ECInfo.Total-uint32(len(resolved)) > policy.ReplicaDescriptor(0).GetECParityCount() {
+		var founded []uint32

@@ -0,0 +323,4 @@
+		p.log.Error(logs.PolicerFailedToRestoreObject, zap.Stringer("object", parentAddress), zap.Error(err))
+		return
+	}
+	parts, err = c.Split(parentObject, key)

@@ -0,0 +168,4 @@
+		var addr oid.Address
+		addr.SetContainer(objInfo.Address.Container())
+		addr.SetObject(indexToObjectID[index])
+		p.replicator.HandlePullTask(ctx, replicator.Task{

@@ -0,0 +272,4 @@
+					p.log.Error(logs.PolicerFailedToDecodeECChunkID, zap.Error(err), zap.Stringer("object", parentAddress))
+					return
+				}
+				if existed, exist := chunkIDs[ch.Index]; exist && existed != chunkID {

@@ -0,0 +273,4 @@
+					return
+				}
+				if existed, exist := chunkIDs[ch.Index]; exist && existed != chunkID {
+					p.log.Error(logs.PolicerDifferentObjectIDForTheSameECChunk, zap.Stringer("first", existed),