added 1 second delay in thread for peer announcement

bluzelle · Aug 12, 2021 · 438f31b · 438f31b
1 parent 787ec44
commit 438f31b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/x/nft/module.go b/x/nft/module.go
@@ -8,6 +8,7 @@ import (
 	"github.com/bluzelle/curium/x/torrentClient"
 	"github.com/cosmos/cosmos-sdk/x/auth"
 	"sync"
+	"time"
 
 	"github.com/gorilla/mux"
 	"github.com/spf13/cobra"
@@ -174,6 +175,7 @@ func (am AppModule) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.Val
 
 			defer func() {
 				go func() {
+					time.Sleep(time.Second)
 					err := am.keeper.BroadcastRegisterBtPeer(ctx)
 					if err != nil {
 						am.keeper.Logger(ctx).Error("Broadcast Register Bt Peer failed", "error", err)