@@ -0,0 +21,4 @@
+	prm.WithShardIDList(s.getShardIDList(req.GetBody().GetShard_ID()))
+	prm.WithIgnoreErrors(req.GetBody().GetIgnoreErrors())
+	prm.WithFaultHandler(s.replicate)
+	prm.WithAsync(true)

@@ -65,2 +117,3 @@
 // The shard being moved must be in read-only mode.
-func (e *StorageEngine) Evacuate(ctx context.Context, prm EvacuateShardPrm) (EvacuateShardRes, error) {
+func (e *StorageEngine) Evacuate(ctx context.Context, prm EvacuateShardPrm) (*EvacuateShardRes, error) {
+	select {

@@ -80,3 +83,3 @@
 	t.Parallel()
 
-	const objPerShard = 3
+	var objPerShard uint32 = 3

@@ -262,0 +316,4 @@
+	prm.shardID = ids[1:2]
+	prm.handler = func(ctx context.Context, a oid.Address, o *objectSDK.Object) error {
+		running.Store(true)
+		for !blocker.Load() {

@@ -0,0 +6,4 @@
+
+To start the evacuation, it is necessary that the shard is in read-only mode (read more [here](./shard-modes.md)).
+
+First of all, by the evacuation the data is transferred to other shards of the same node; if it is not possible, then the data is transferred to other nodes.

@@ -0,0 +135,4 @@
+	const reportIntervalSeconds = 5
+	var resp *control.GetEvacuateShardStatusResponse
+	reportResponse := atomic.NewPointer(resp)
+	poolingCompleted := make(chan interface{})

@@ -86,0 +166,4 @@
+	}
+
+	err = eg.Wait()
+	return res, err

@@ -0,0 +36,4 @@
+		}
+	}
+	var duration *control.GetEvacuateShardStatusResponse_Body_Duration
+	if state.StartedAt() != nil {

@@ -0,0 +135,4 @@
+	const reportIntervalSeconds = 5
+	var resp *control.GetEvacuateShardStatusResponse
+	reportResponse := atomic.NewPointer(resp)
+	poolingCompleted := make(chan interface{})

@@ -0,0 +136,4 @@
+	var resp *control.GetEvacuateShardStatusResponse
+	reportResponse := atomic.NewPointer(resp)
+	poolingCompleted := make(chan interface{})
+	progressReportCompleted := make(chan interface{})

@@ -0,0 +138,4 @@
+	poolingCompleted := make(chan interface{})
+	progressReportCompleted := make(chan interface{})
+
+	go func() {

@@ -0,0 +95,4 @@
+	return s.errMessage
+}
+
+func (s *EvacuationState) NextTryAfterSeconds() int64 {

@@ -0,0 +103,4 @@
+	if s == nil {
+		return nil
+	}
+	shardIDs := make([]string, len(s.shardIDs))

@@ -0,0 +170,4 @@
+	l.guard.RLock()
+	defer l.guard.RUnlock()
+
+	return l.state.DeepCopy()

@@ -30,2 +31,4 @@
     rpc EvacuateShard (EvacuateShardRequest) returns (EvacuateShardResponse);
 
+    // StartEvacuateShard starts moving all data from one shard to the others.
+    rpc StartEvacuateShard (StartEvacuateShardRequest) returns (StartEvacuateShardResponse);