Commit e3f33325 authored by szh's avatar szh

update mysql

parent 28512777
...@@ -68,7 +68,7 @@ func SyncBlock() { ...@@ -68,7 +68,7 @@ func SyncBlock() {
var wg sync.WaitGroup var wg sync.WaitGroup
for height := processHeight ;height < processHeight + maxDownload;height ++ { for height := processHeight ;height < processHeight + maxDownload;height ++ {
wg.Add(1) wg.Add(1)
go func(height int64) { go func(height int64,statList []*models.RaspMinerStat,txsList []*models.RaspMinerTxs) {
defer wg.Done() defer wg.Done()
stat,txs,err := DealBlock(height) stat,txs,err := DealBlock(height)
if err != nil { if err != nil {
...@@ -81,7 +81,7 @@ func SyncBlock() { ...@@ -81,7 +81,7 @@ func SyncBlock() {
logging.Info("DealBlock stat",*stat) logging.Info("DealBlock stat",*stat)
logging.Info("DealBlock txs",*txs) logging.Info("DealBlock txs",*txs)
checkList[height] = height checkList[height] = height
}(height) }(height,statList,txsList)
} }
//db.SetMainNetHeight(int(processHeight + types.MaxProcessBlocks + 1)) //db.SetMainNetHeight(int(processHeight + types.MaxProcessBlocks + 1))
wg.Wait() wg.Wait()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment