Skip to content

Commit

Permalink
finish sync txn coding
Browse files Browse the repository at this point in the history
Signed-off-by: billfort <[email protected]>
  • Loading branch information
billfort committed Nov 11, 2022
1 parent c68b56f commit 8db7e02
Show file tree
Hide file tree
Showing 13 changed files with 1,090 additions and 296 deletions.
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ cscope*
/ChainDB.config
/Log/
/vendor/
/test/

/nknd
/nknc
Expand Down
28 changes: 10 additions & 18 deletions dashboard/web/yarn.lock
Original file line number Diff line number Diff line change
Expand Up @@ -3137,9 +3137,9 @@ [email protected]:
node-int64 "^0.4.0"

buffer-from@^1.0.0:
version "1.1.1"
resolved "https://registry.npm.taobao.org/buffer-from/download/buffer-from-1.1.1.tgz#32713bc028f75c02fdb710d7c7bcec1f2c6070ef"
integrity sha1-MnE7wCj3XAL9txDXx7zsHyxgcO8=
version "1.1.2"
resolved "https://registry.yarnpkg.com/buffer-from/-/buffer-from-1.1.2.tgz#2b146a6fd72e80b4f55d255f35ed59a3a9a41bd5"
integrity sha512-E+XQCRwSbaaiChtv6k6Dwgc+bx+Bs6vuKJHHl5kox/BaKbhiXzqQOwK4cO22yElGp2OCmjwVhT3HmxgyPGnJfQ==

buffer-json@^2.0.0:
version "2.0.0"
Expand Down Expand Up @@ -10178,15 +10178,7 @@ source-map-resolve@^0.6.0:
atob "^2.1.2"
decode-uri-component "^0.2.0"

source-map-support@^0.5.6, source-map-support@~0.5.12:
version "0.5.19"
resolved "https://registry.npm.taobao.org/source-map-support/download/source-map-support-0.5.19.tgz#a98b62f86dcaf4f67399648c085291ab9e8fed61"
integrity sha1-qYti+G3K9PZzmWSMCFKRq56P7WE=
dependencies:
buffer-from "^1.0.0"
source-map "^0.6.0"

source-map-support@~0.5.20:
source-map-support@^0.5.6, source-map-support@~0.5.12, source-map-support@~0.5.20:
version "0.5.21"
resolved "https://registry.npmjs.org/source-map-support/-/source-map-support-0.5.21.tgz#04fe7c7f9e1ed2d662233c28cb2b35b9f63f6e4f"
integrity sha512-uBHU3L3czsIyYXKX88fdrGovxdSCoTGDRZ6SYXtSRxLZUzHg5P/66Ht6uoUlHu9EZod+inXhKo3qQgwXUT/y1w==
Expand Down Expand Up @@ -10675,9 +10667,9 @@ terser-webpack-plugin@^4.2.3:
webpack-sources "^1.4.3"

terser@^4.1.2, terser@^4.6.3:
version "4.8.0"
resolved "https://registry.npm.taobao.org/terser/download/terser-4.8.0.tgz?cache=0&sync_timestamp=1592448394415&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fterser%2Fdownload%2Fterser-4.8.0.tgz#63056343d7c70bb29f3af665865a46fe03a0df17"
integrity sha1-YwVjQ9fHC7KfOvZlhlpG/gOg3xc=
version "4.8.1"
resolved "https://registry.yarnpkg.com/terser/-/terser-4.8.1.tgz#a00e5634562de2239fd404c649051bf6fc21144f"
integrity sha512-4GnLC0x667eJG0ewJTa6z/yXrbLGv80D9Ru6HIpCQmO+Q4PfEtBFi0ObSckqwL6VyQv/7ENJieXHo2ANmdQwgw==
dependencies:
commander "^2.20.0"
source-map "~0.6.1"
Expand Down Expand Up @@ -11410,9 +11402,9 @@ vuetify-loader@^1.7.3:
loader-utils "^2.0.0"

vuetify@^2.6:
version "2.6.4"
resolved "https://registry.npmjs.org/vuetify/-/vuetify-2.6.4.tgz#18052f77492d32856fea35c910755075ff32acc9"
integrity sha512-2wEzU/Gz39gQCxK93xoiWPKCHQUnyUKWd81wB7Q7hfYJWu5QOWQXYlF0X/BgUZzf8IOyHWKiSNEAfEe9OE3b4w==
version "2.6.10"
resolved "https://registry.yarnpkg.com/vuetify/-/vuetify-2.6.10.tgz#b86cd7a97bf8cd3828a72c349795b5b3c539ebc2"
integrity sha512-fgUeRDDCwYkwu6WGEEKGe7IdfzOsXJCZGrqkn1pcS2ycuoDL8mR2/dejH5iFNnBY6MnsT365PAGn0J+9otjfQg==

vuex@^3.6.2:
version "3.6.2"
Expand Down
6 changes: 6 additions & 0 deletions lnode/syncblock.go
Original file line number Diff line number Diff line change
Expand Up @@ -403,7 +403,13 @@ func (localNode *LocalNode) initSyncing() {
localNode.AddMessageHandler(pb.MessageType_GET_BLOCK_HEADERS, localNode.getBlockHeadersMessageHandler)
localNode.AddMessageHandler(pb.MessageType_GET_BLOCKS, localNode.getBlocksMessageHandler)
localNode.AddMessageHandler(pb.MessageType_GET_STATES, localNode.getStatesMessageHandler)

localNode.ResetSyncing()

// start sync txn pool routine
localNode.AddMessageHandler(pb.MessageType_GET_TXN_POOL_HASH, localNode.getTxnPoolHashHandler)
localNode.AddMessageHandler(pb.MessageType_GET_TXN_POOL_SYNC, localNode.getTxnPoolSyncHandler)
go localNode.StartSyncTxnPool()
}

func removeStoppedNeighbors(neighbors []*node.RemoteNode) []*node.RemoteNode {
Expand Down
Loading

0 comments on commit 8db7e02

Please sign in to comment.