1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
// (c) 2019-2020, Ava Labs, Inc. All rights reserved.
// See the file LICENSE for licensing terms.
package evm
import (
"errors"
"fmt"
"github.com/ava-labs/coreth/core/types"
"github.com/ava-labs/go-ethereum/rlp"
"github.com/ava-labs/gecko/ids"
"github.com/ava-labs/gecko/snow/choices"
"github.com/ava-labs/gecko/snow/consensus/snowman"
)
// Block implements the snowman.Block interface
type Block struct {
id ids.ID
ethBlock *types.Block
vm *VM
}
// ID implements the snowman.Block interface
func (b *Block) ID() ids.ID { return b.id }
// Accept implements the snowman.Block interface
func (b *Block) Accept() error {
b.vm.ctx.Log.Verbo("Block %s is accepted", b.ID())
b.vm.updateStatus(b.ID(), choices.Accepted)
return nil
}
// Reject implements the snowman.Block interface
func (b *Block) Reject() error {
b.vm.ctx.Log.Verbo("Block %s is rejected", b.ID())
b.vm.updateStatus(b.ID(), choices.Rejected)
return nil
}
// Status implements the snowman.Block interface
func (b *Block) Status() choices.Status {
status := b.vm.getCachedStatus(b.ID())
if status == choices.Unknown && b.ethBlock != nil {
return choices.Processing
}
return status
}
// Parent implements the snowman.Block interface
func (b *Block) Parent() snowman.Block {
parentID := ids.NewID(b.ethBlock.ParentHash())
block := &Block{
id: parentID,
ethBlock: b.vm.getCachedBlock(parentID),
vm: b.vm,
}
b.vm.ctx.Log.Verbo("Parent(%s) has status: %s", block.ID(), block.Status())
return block
}
// Verify implements the snowman.Block interface
func (b *Block) Verify() error {
vm := b.vm
tx := vm.getAtomicTx(b.ethBlock)
switch atx := tx.UnsignedTx.(type) {
case *UnsignedImportTx:
if b.ethBlock.Hash() == vm.genesisHash {
return nil
}
p := b.Parent()
path := []*Block{}
inputs := new(ids.Set)
for {
if p.Status() == choices.Accepted || p.(*Block).ethBlock.Hash() == vm.genesisHash {
break
}
if ret, hit := vm.blockAtomicInputCache.Get(p.ID()); hit {
inputs = ret.(*ids.Set)
break
}
path = append(path, p.(*Block))
p = p.Parent().(*Block)
}
for i := len(path) - 1; i >= 0; i-- {
inputsCopy := new(ids.Set)
p := path[i]
atx := vm.getAtomicTx(p.ethBlock)
inputs.Union(atx.UnsignedTx.(UnsignedAtomicTx).InputUTXOs())
inputsCopy.Union(*inputs)
vm.blockAtomicInputCache.Put(p.ID(), inputsCopy)
}
for _, in := range atx.InputUTXOs().List() {
if inputs.Contains(in) {
return errInvalidBlock
}
}
case *UnsignedExportTx:
default:
return errors.New("unknown atomic tx type")
}
if tx.UnsignedTx.(UnsignedAtomicTx).SemanticVerify(vm, tx) != nil {
return errInvalidBlock
}
_, err := b.vm.chain.InsertChain([]*types.Block{b.ethBlock})
return err
}
// Bytes implements the snowman.Block interface
func (b *Block) Bytes() []byte {
res, err := rlp.EncodeToBytes(b.ethBlock)
if err != nil {
panic(err)
}
return res
}
func (b *Block) String() string { return fmt.Sprintf("EVM block, ID = %s", b.ID()) }
|