move inline

dymensionxyz · May 15, 2024 · 09d08ae · 09d08ae
1 parent a082a5e
commit 09d08ae
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/block/manager.go b/block/manager.go
@@ -12,6 +12,7 @@ import (
 	"github.com/dymensionxyz/dymint/store"
 
 	"code.cloudfoundry.org/go-diodes"
+	uevent "github.com/dymensionxyz/dymint/utils/event"
 
 	"github.com/dymensionxyz/dymint/p2p"
 	"github.com/libp2p/go-libp2p/core/crypto"
@@ -144,7 +145,9 @@ func (m *Manager) Start(ctx context.Context) error {
 
 	//Fullnode loop can start before syncing from DA
 	if !isSequencer {
-		m.startNonSequencerLoop(ctx)
+		go uevent.MustSubscribe(ctx, m.Pubsub, "applyGossipedBlocksLoop", p2p.EventQueryNewNewGossipedBlock, m.onNewGossipedBlock, m.logger)
+		go m.RetrieveLoop(ctx)
+		go m.SyncTargetLoop(ctx)
 	}
 
 	// TODO: populate the accumulatedSize on startup
@@ -158,7 +161,8 @@ func (m *Manager) Start(ctx context.Context) error {
 
 	//Aggregator producer loop is started only when finished syncing from DA
 	if isSequencer {
-		m.startSequencerLoop(ctx)
+		go m.ProduceBlockLoop(ctx)
+		go m.SubmitLoop(ctx)
 	}
 	return nil
 }