OSDN Git Service

fix
authorHAOYUatHZ <haoyu@protonmail.com>
Thu, 6 Jun 2019 01:19:34 +0000 (09:19 +0800)
committerHAOYUatHZ <haoyu@protonmail.com>
Thu, 6 Jun 2019 01:19:34 +0000 (09:19 +0800)
federation/synchron/block_keeper.go
federation/synchron/db_keeper.go
federation/synchron/unconfirmed_tx_keeper.go

index 31b84b3..aa80b7f 100644 (file)
@@ -9,17 +9,17 @@ import (
        "github.com/jinzhu/gorm"
        // log "github.com/sirupsen/logrus"
 
-       // "github.com/vapor/federation/config"
+       "github.com/vapor/federation/config"
        // "github.com/blockcenter/database"
        // "github.com/blockcenter/database/orm"
        "github.com/vapor/federation/service"
 )
 
 type blockKeeper struct {
-       // cfg      *config.Config
-       db *gorm.DB
-       // cache    *database.RedisDB
+       cfg  *config.Chain
+       db   *gorm.DB
        node *service.Node
+       // cache    *database.RedisDB
        // coinName string
 }
 
index e94628d..2f631ed 100644 (file)
@@ -16,19 +16,19 @@ import (
 )
 
 type DbKeeper struct {
-       // db   *gorm.DB
-       // node *service.Node
        blockKeeper         *blockKeeper
        unconfirmedTxKeeper *unconfirmedTxKeeper
 }
 
 func NewDbKeeper(db *gorm.DB, chainCfg *config.Chain) *DbKeeper {
        blockKeeper := &blockKeeper{
+               cfg:  chainCfg,
                db:   db,
                node: service.NewNode(chainCfg.Upstream.RPC),
        }
 
        unconfirmedTxKeeper := &unconfirmedTxKeeper{
+               cfg:         chainCfg,
                db:          db,
                processTxCh: make(chan *service.WSResponse, maxRawTxSize),
        }
index b9c875d..29b1b1e 100644 (file)
@@ -9,7 +9,7 @@ import (
        "github.com/jinzhu/gorm"
        // log "github.com/sirupsen/logrus"
 
-       // "github.com/vapor/federation/config"
+       "github.com/vapor/federation/config"
        // "github.com/blockcenter/database"
        // "github.com/blockcenter/database/orm"
        "github.com/vapor/federation/service"
@@ -18,10 +18,10 @@ import (
 const maxRawTxSize = 1 << 16
 
 type unconfirmedTxKeeper struct {
-       // cfg         *config.Config
-       db *gorm.DB
-       // coinName    string
+       cfg         *config.Chain
+       db          *gorm.DB
        processTxCh chan *service.WSResponse
+       // coinName    string
 }
 
 func (u *unconfirmedTxKeeper) Run() {