Case 3 and case 4

code/go/0chain.net/blobbercore/allocation/renamefilechange.go

@@ -24,7 +24,7 @@ func (rf *RenameFileChange) DeleteTempFile() error {
 	return nil
 }
 
-func (rf *RenameFileChange) ApplyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
+func (rf *RenameFileChange) applyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
 	allocationRoot string, ts common.Timestamp, _ map[string]string) (*reference.Ref, error) {
 
 	if rf.Path == "/" {

code/go/0chain.net/blobbercore/allocation/renamefilechange_integration.go

@@ -0,0 +1,28 @@
+//go:build integration_tests
+// +build integration_tests
+
+package allocation
+
+import (
+	"context"
+	"errors"
+
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/reference"
+	"github.com/0chain/blobber/code/go/0chain.net/conductor/conductrpc"
+	"github.com/0chain/blobber/code/go/0chain.net/core/common"
+	"github.com/0chain/blobber/code/go/0chain.net/core/node"
+)
+
+func (rf *RenameFileChange) ApplyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
+	allocationRoot string, ts common.Timestamp, _ map[string]string) (*reference.Ref, error) {
+
+	state := conductrpc.Client().State()
+	if state.FailRenameCommit != nil {
+		for _, nodeId := range state.FailRenameCommit {
+			if nodeId == node.Self.ID {
+				return nil, errors.New("error directed by conductor")
+			}
+		}
+	}
+	return rf.applyChange(ctx, rootRef, change, allocationRoot, ts, nil)
+}

code/go/0chain.net/blobbercore/allocation/renamefilechange_main.go

@@ -0,0 +1,17 @@
+//go:build !integration_tests
+// +build !integration_tests
+
+package allocation
+
+import (
+	"context"
+
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/reference"
+	"github.com/0chain/blobber/code/go/0chain.net/core/common"
+)
+
+func (rf *RenameFileChange) ApplyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
+	allocationRoot string, ts common.Timestamp, _ map[string]string) (*reference.Ref, error) {
+
+	return rf.applyChange(ctx, rootRef, change, allocationRoot, ts, nil)
+}

code/go/0chain.net/conductor/conductrpc/client.go

@@ -52,3 +52,8 @@ func (c *client) blobberCommitted(blobberID string) (err error) {
 	err = c.client.Call("Server.BlobberCommitted", blobberID, nil)
 	return
 }
+
+func (c *client) sendFileMetaRoot(m map[string]string) (err error) {
+	err = c.client.Call("Server.GetFileMetaRoot", m, nil)
+	return
+}

code/go/0chain.net/conductor/conductrpc/entity.go

@@ -1,6 +1,7 @@
 package conductrpc
 
 import (
+	"context"
 	"log"
 	"sync"
 	"sync/atomic"
@@ -31,6 +32,10 @@ func (e *Entity) State() (state *State) {
 // SetState sets current state.
 func (e *Entity) SetState(state *State) {
 	e.state.Store(state) // update
+
+	if state.GetFileMetaRoot {
+		go SendFileMetaRoot()
+	}
 }
 
 // NewEntity creates RPC client for integration tests.
@@ -107,6 +112,19 @@ func (e *Entity) BlobberCommitted(blobberID string) {
 	}
 }
 
+
+func (e *Entity) SendFileMetaRoot(blobberID, fileMetaRoot string, ctxCncl context.CancelFunc) {
+	m := map[string]string{
+		"blobber_id":     blobberID,
+		"file_meta_root": fileMetaRoot,
+	}
+	err := e.client.sendFileMetaRoot(m)
+	if err != nil {
+		return
+	}
+	ctxCncl()
+}
+
 //
 // global
 //

code/go/0chain.net/conductor/conductrpc/file_meta.go

@@ -0,0 +1,64 @@
+package conductrpc
+
+import (
+	"context"
+
+	"log"
+
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/datastore"
+
+	"github.com/0chain/blobber/code/go/0chain.net/core/node"
+)
+
+// alreadyRunning is simple indicator that given function is running
+// no need to acquire mutex lock. It does not matter if at a time it
+// somehow runs the given function multiple times. Since it takes some
+// time to acquire state from rpc server there is no concurrent running
+var alreadyRunning bool
+
+func SendFileMetaRoot() {
+	if alreadyRunning {
+		return
+	}
+	alreadyRunning = true
+	defer func() {
+		alreadyRunning = false
+	}()
+
+	ctx, ctxCncl := context.WithCancel(context.TODO())
+	defer ctxCncl()
+
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		default:
+		}
+
+		s := global.State()
+		if s.GetFileMetaRoot {
+			fmr, err := getFileMetaRoot()
+			if err != nil {
+				log.Printf("Error: %v", err)
+				continue
+			}
+
+			global.SendFileMetaRoot(node.Self.ID, fmr, ctxCncl)
+		}
+	}
+}
+
+func getFileMetaRoot() (string, error) {
+	db := datastore.GetStore().GetDB()
+	var fmr string
+
+	// It will work fine because this blobber will have only single allocation
+	// created by conductor
+	err := db.Raw("SELECT file_meta_root FROM allocations LIMIT 1").Scan(&fmr).Error
+
+	if err != nil {
+		return "", err
+	}
+
+	return fmr, nil
+}

code/go/0chain.net/conductor/conductrpc/state.go

@@ -63,6 +63,8 @@ type State struct {
 	BlobberDelete        BlobberDelete
 	AdversarialValidator AdversarialValidator
 	StopWMCommit         *bool
+	FailRenameCommit     []string
+	GetFileMetaRoot      bool
 }
 
 // Name returns NodeName by given NodeID.