|
|
|
@ -610,6 +610,7 @@ func (h *serverHandler) handleMsg(p *clientPeer, wg *sync.WaitGroup) error { |
|
|
|
|
var ( |
|
|
|
|
lastBHash common.Hash |
|
|
|
|
root common.Hash |
|
|
|
|
header *types.Header |
|
|
|
|
) |
|
|
|
|
reqCnt := len(req.Reqs) |
|
|
|
|
if accept(req.ReqID, uint64(reqCnt), MaxProofsFetch) { |
|
|
|
@ -624,10 +625,6 @@ func (h *serverHandler) handleMsg(p *clientPeer, wg *sync.WaitGroup) error { |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
|
// Look up the root hash belonging to the request
|
|
|
|
|
var ( |
|
|
|
|
header *types.Header |
|
|
|
|
trie state.Trie |
|
|
|
|
) |
|
|
|
|
if request.BHash != lastBHash { |
|
|
|
|
root, lastBHash = common.Hash{}, request.BHash |
|
|
|
|
|
|
|
|
@ -654,6 +651,7 @@ func (h *serverHandler) handleMsg(p *clientPeer, wg *sync.WaitGroup) error { |
|
|
|
|
// Open the account or storage trie for the request
|
|
|
|
|
statedb := h.blockchain.StateCache() |
|
|
|
|
|
|
|
|
|
var trie state.Trie |
|
|
|
|
switch len(request.AccKey) { |
|
|
|
|
case 0: |
|
|
|
|
// No account key specified, open an account trie
|
|
|
|
|