Parallelize chain synchronization in startup

sanjayarun07 · May 13, 2019 · 2cf42e0 · 2cf42e0
1 parent 6af1b83
commit 2cf42e0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 7 deletions.
diff --git a/sqlchain/chain.go b/sqlchain/chain.go
@@ -792,7 +792,7 @@ func (c *Chain) processBlocks(ctx context.Context) {
 }
 
 // Start starts the main process of the sql-chain.
-func (c *Chain) Start() (err error) {
+func (c *Chain) Start() {
 	c.rt.goFunc(c.processBlocks)
 	c.sync()
 	c.rt.goFunc(c.mainCycle)

diff --git a/sqlchain/chain_test.go b/sqlchain/chain_test.go
@@ -275,10 +275,7 @@ func TestMultiChain(t *testing.T) {
 
 	// Start all chain instances
 	for _, v := range chains {
-		if err = v.chain.Start(); err != nil {
-			t.Fatalf("error occurred: %v", err)
-		}
-
+		v.chain.Start()
 		defer func(c *Chain) {
 			// Stop chain main process before exit
 			_ = c.Stop()

diff --git a/worker/db.go b/worker/db.go
@@ -175,9 +175,8 @@ func NewDatabase(cfg *DBConfig, peers *proto.Peers,
 	}
 	if db.chain, err = sqlchain.NewChain(chainCfg); err != nil {
 		return
-	} else if err = db.chain.Start(); err != nil {
-		return
 	}
+	go db.chain.Start()
 
 	// init kayak config
 	kayakWalPath := filepath.Join(cfg.DataDir, KayakWalFileName)