diff options
author | Sonic <sonic@dexon.org> | 2019-03-08 14:49:00 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@byzantine-lab.io> | 2019-06-12 17:27:22 +0800 |
commit | a6acc747e603a2f449af075a007a34fc494631e0 (patch) | |
tree | 14715e687337d211ce7526f0ece0d8f3068d38b4 /dex | |
parent | 8e87508f4858fc9dd5836af1f6d09184a4c24ad3 (diff) | |
download | go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.tar go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.tar.gz go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.tar.bz2 go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.tar.lz go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.tar.xz go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.tar.zst go-tangerine-a6acc747e603a2f449af075a007a34fc494631e0.zip |
dex, dex/downloader: remove some TODO comments (#232)
Diffstat (limited to 'dex')
-rw-r--r-- | dex/downloader/downloader.go | 1 | ||||
-rw-r--r-- | dex/downloader/fakepeer.go | 3 | ||||
-rw-r--r-- | dex/downloader/peer.go | 1 | ||||
-rw-r--r-- | dex/handler.go | 3 | ||||
-rw-r--r-- | dex/protocol_test.go | 6 |
5 files changed, 1 insertions, 13 deletions
diff --git a/dex/downloader/downloader.go b/dex/downloader/downloader.go index 3d3a78e18..e3960ea30 100644 --- a/dex/downloader/downloader.go +++ b/dex/downloader/downloader.go @@ -1403,7 +1403,6 @@ func (d *Downloader) processHeaders(origin uint64, pivot uint64, number uint64) // In case of header only syncing, validate the chunk immediately if d.mode == FastSync || d.mode == LightSync { - // TODO(sonic) update the gov state to make TSigVerify correct // Collect the yet unknown headers to mark them as uncertain unknown := make([]*types.Header, 0, len(headersWithGovState)) for _, header := range chunk { diff --git a/dex/downloader/fakepeer.go b/dex/downloader/fakepeer.go index f4ff9b517..e1c3070d2 100644 --- a/dex/downloader/fakepeer.go +++ b/dex/downloader/fakepeer.go @@ -89,7 +89,6 @@ func (p *FakePeer) RequestHeadersByHash(hash common.Hash, amount int, skip int, } } - // TODO(sonic): fix this var headersWithGovState []*types.HeaderWithGovState for _, h := range headers { headersWithGovState = append(headersWithGovState, @@ -122,7 +121,7 @@ func (p *FakePeer) RequestHeadersByNumber(number uint64, amount int, skip int, r } headers = append(headers, origin) } - // TODO(sonic): fix this + var headersWithGovState []*types.HeaderWithGovState for _, h := range headers { headersWithGovState = append(headersWithGovState, diff --git a/dex/downloader/peer.go b/dex/downloader/peer.go index e1c6960f1..df8ef0ee9 100644 --- a/dex/downloader/peer.go +++ b/dex/downloader/peer.go @@ -103,7 +103,6 @@ func (w *lightPeerWrapper) RequestHeadersByNumber(i uint64, amount int, skip int return w.peer.RequestHeadersByNumber(i, amount, skip, reverse, withGov) } func (w *lightPeerWrapper) RequestGovStateByHash(common.Hash) error { - // TODO(sonic): support this panic("RequestGovStateByHash not supported in light client mode sync") } func (w *lightPeerWrapper) DownloadBodies([]common.Hash) error { diff --git a/dex/handler.go b/dex/handler.go index 5bd615c86..efd0538f4 100644 --- a/dex/handler.go +++ b/dex/handler.go @@ -909,7 +909,6 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { } govState, err := pm.blockchain.GetGovStateByHash(hash) if err != nil { - // TODO(sonic): handle this error panic(err) } return p.SendGovState(govState) @@ -1027,7 +1026,6 @@ func (pm *ProtocolManager) BroadcastAgreementResult( } } - // TODO(sonic): send to some of other nodes (gossip) for _, peer := range pm.peers.PeersWithoutAgreement(rlpHash(agreement)) { peer.AsyncSendAgreement(agreement) } @@ -1048,7 +1046,6 @@ func (pm *ProtocolManager) BroadcastRandomnessResult( } } - // TODO(sonic): send to some of other nodes (gossip) for _, peer := range pm.peers.PeersWithoutRandomness(rlpHash(randomness)) { peer.AsyncSendRandomnesses(randomnesses) } diff --git a/dex/protocol_test.go b/dex/protocol_test.go index fb414613e..22281d0f2 100644 --- a/dex/protocol_test.go +++ b/dex/protocol_test.go @@ -569,7 +569,6 @@ func TestRecvDKGPrivateShare(t *testing.T) { defer pm.Stop() defer p.close() - // TODO(sonic): polish this privkey := dkg.NewPrivateKey() privateShare := dkgTypes.PrivateShare{ ProposerID: coreTypes.NodeID{coreCommon.Hash{1, 2, 3}}, @@ -606,7 +605,6 @@ func TestSendDKGPrivateShare(t *testing.T) { defer pm.Stop() defer p1.close() - // TODO(sonic): polish this privkey := dkg.NewPrivateKey() privateShare := dkgTypes.PrivateShare{ ProposerID: coreTypes.NodeID{coreCommon.Hash{1, 2, 3}}, @@ -654,7 +652,6 @@ func TestRecvAgreement(t *testing.T) { defer pm.Stop() defer p.close() - // TODO(sonic): polish this vote := coreTypes.Vote{ VoteHeader: coreTypes.VoteHeader{ ProposerID: coreTypes.NodeID{coreCommon.Hash{1, 2, 3}}, @@ -698,7 +695,6 @@ func TestSendAgreement(t *testing.T) { defer pm.Stop() defer p.close() - // TODO(sonic): polish this vote := coreTypes.Vote{ VoteHeader: coreTypes.VoteHeader{ ProposerID: coreTypes.NodeID{coreCommon.Hash{1, 2, 3}}, @@ -745,7 +741,6 @@ func TestRecvRandomnesses(t *testing.T) { defer pm.Stop() defer p.close() - // TODO(sonic): polish this randomness := coreTypes.BlockRandomnessResult{ BlockHash: coreCommon.Hash{8, 8, 8}, Position: coreTypes.Position{ @@ -777,7 +772,6 @@ func TestSendRandomnesses(t *testing.T) { defer pm.Stop() defer p.close() - // TODO(sonic): polish this randomness := coreTypes.BlockRandomnessResult{ BlockHash: coreCommon.Hash{8, 8, 8}, Position: coreTypes.Position{ |