123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233 |
- // Copyright 2016 The go-ethereum Authors
- // This file is part of the go-ethereum library.
- //
- // The go-ethereum library is free software: you can redistribute it and/or modify
- // it under the terms of the GNU Lesser General Public License as published by
- // the Free Software Foundation, either version 3 of the License, or
- // (at your option) any later version.
- //
- // The go-ethereum library is distributed in the hope that it will be useful,
- // but WITHOUT ANY WARRANTY; without even the implied warranty of
- // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- // GNU Lesser General Public License for more details.
- //
- // You should have received a copy of the GNU Lesser General Public License
- // along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
- package params
- import (
- "encoding/binary"
- "errors"
- "fmt"
- "math/big"
- "strings"
- "github.com/ethereum/go-ethereum/common"
- "github.com/ethereum/go-ethereum/common/math"
- "github.com/ethereum/go-ethereum/log"
- "golang.org/x/crypto/sha3"
- )
- // Genesis hashes to enforce below configs on.
- var (
- MainnetGenesisHash = common.HexToHash("0xd4e56740f876aef8c010b86a40d5f56745a118d0906a34e69aec8c0db1cb8fa3")
- RopstenGenesisHash = common.HexToHash("0x41941023680923e0fe4d74a34bdac8141f2540e3ae90623718e47d66d1ca4a2d")
- RinkebyGenesisHash = common.HexToHash("0x6341fd3daf94b748c72ced5a5b26028f2474f5f00d824504e4fa37a75767e177")
- GoerliGenesisHash = common.HexToHash("0xbf7e331f7f7c1dd2e05159666b3bf8bc7a8a3a9eb1d518969eab529dd9b88c1a")
- YoloV3GenesisHash = common.HexToHash("0xf1f2876e8500c77afcc03228757b39477eceffccf645b734967fe3c7e16967b7")
- )
- // TrustedCheckpoints associates each known checkpoint with the genesis hash of
- // the chain it belongs to.
- var TrustedCheckpoints = map[common.Hash]*TrustedCheckpoint{
- MainnetGenesisHash: MainnetTrustedCheckpoint,
- RopstenGenesisHash: RopstenTrustedCheckpoint,
- RinkebyGenesisHash: RinkebyTrustedCheckpoint,
- GoerliGenesisHash: GoerliTrustedCheckpoint,
- }
- // CheckpointOracles associates each known checkpoint oracles with the genesis hash of
- // the chain it belongs to.
- var CheckpointOracles = map[common.Hash]*CheckpointOracleConfig{
- MainnetGenesisHash: MainnetCheckpointOracle,
- RopstenGenesisHash: RopstenCheckpointOracle,
- RinkebyGenesisHash: RinkebyCheckpointOracle,
- GoerliGenesisHash: GoerliCheckpointOracle,
- }
- var (
- // MainnetChainConfig is the chain parameters to run a node on the main network.
- MainnetChainConfig = &ChainConfig{
- ChainID: big.NewInt(1),
- HomesteadBlock: big.NewInt(1_150_000),
- DAOForkBlock: big.NewInt(1_920_000),
- DAOForkSupport: true,
- EIP150Block: big.NewInt(2_463_000),
- EIP150Hash: common.HexToHash("0x2086799aeebeae135c246c65021c82b4e15a2c451340993aacfd2751886514f0"),
- EIP155Block: big.NewInt(2_675_000),
- EIP158Block: big.NewInt(2_675_000),
- ByzantiumBlock: big.NewInt(4_370_000),
- ConstantinopleBlock: big.NewInt(7_280_000),
- PetersburgBlock: big.NewInt(7_280_000),
- IstanbulBlock: big.NewInt(9_069_000),
- MuirGlacierBlock: big.NewInt(9_200_000),
- BerlinBlock: big.NewInt(12_244_000),
- Ethash: new(EthashConfig),
- }
- // MainnetTrustedCheckpoint contains the light client trusted checkpoint for the main network.
- MainnetTrustedCheckpoint = &TrustedCheckpoint{
- SectionIndex: 371,
- SectionHead: common.HexToHash("0x50fd3cec5376ede90ef9129772022690cd1467f22c18abb7faa11e793c51e9c9"),
- CHTRoot: common.HexToHash("0xb57b4b22a77b5930847b1ca9f62daa11eae6578948cb7b18997f2c0fe5757025"),
- BloomRoot: common.HexToHash("0xa338f8a868a194fa90327d0f5877f656a9f3640c618d2a01a01f2e76ef9ef954"),
- }
- // MainnetCheckpointOracle contains a set of configs for the main network oracle.
- MainnetCheckpointOracle = &CheckpointOracleConfig{
- Address: common.HexToAddress("0x9a9070028361F7AAbeB3f2F2Dc07F82C4a98A02a"),
- Signers: []common.Address{
- common.HexToAddress("0x1b2C260efc720BE89101890E4Db589b44E950527"), // Peter
- common.HexToAddress("0x78d1aD571A1A09D60D9BBf25894b44e4C8859595"), // Martin
- common.HexToAddress("0x286834935f4A8Cfb4FF4C77D5770C2775aE2b0E7"), // Zsolt
- common.HexToAddress("0xb86e2B0Ab5A4B1373e40c51A7C712c70Ba2f9f8E"), // Gary
- common.HexToAddress("0x0DF8fa387C602AE62559cC4aFa4972A7045d6707"), // Guillaume
- },
- Threshold: 2,
- }
- // RopstenChainConfig contains the chain parameters to run a node on the Ropsten test network.
- RopstenChainConfig = &ChainConfig{
- ChainID: big.NewInt(3),
- HomesteadBlock: big.NewInt(0),
- DAOForkBlock: nil,
- DAOForkSupport: true,
- EIP150Block: big.NewInt(0),
- EIP150Hash: common.HexToHash("0x41941023680923e0fe4d74a34bdac8141f2540e3ae90623718e47d66d1ca4a2d"),
- EIP155Block: big.NewInt(10),
- EIP158Block: big.NewInt(10),
- ByzantiumBlock: big.NewInt(1_700_000),
- ConstantinopleBlock: big.NewInt(4_230_000),
- PetersburgBlock: big.NewInt(4_939_394),
- IstanbulBlock: big.NewInt(6_485_846),
- MuirGlacierBlock: big.NewInt(7_117_117),
- BerlinBlock: big.NewInt(9_812_189),
- Ethash: new(EthashConfig),
- }
- // RopstenTrustedCheckpoint contains the light client trusted checkpoint for the Ropsten test network.
- RopstenTrustedCheckpoint = &TrustedCheckpoint{
- SectionIndex: 279,
- SectionHead: common.HexToHash("0x4a4912848d4c06090097073357c10015d11c6f4544a0f93cbdd584701c3b7d58"),
- CHTRoot: common.HexToHash("0x9053b7867ae921e80a4e2f5a4b15212e4af3d691ca712fb33dc150e9c6ea221c"),
- BloomRoot: common.HexToHash("0x3dc04cb1be7ddc271f3f83469b47b76184a79d7209ef51d85b1539ea6d25a645"),
- }
- // RopstenCheckpointOracle contains a set of configs for the Ropsten test network oracle.
- RopstenCheckpointOracle = &CheckpointOracleConfig{
- Address: common.HexToAddress("0xEF79475013f154E6A65b54cB2742867791bf0B84"),
- Signers: []common.Address{
- common.HexToAddress("0x32162F3581E88a5f62e8A61892B42C46E2c18f7b"), // Peter
- common.HexToAddress("0x78d1aD571A1A09D60D9BBf25894b44e4C8859595"), // Martin
- common.HexToAddress("0x286834935f4A8Cfb4FF4C77D5770C2775aE2b0E7"), // Zsolt
- common.HexToAddress("0xb86e2B0Ab5A4B1373e40c51A7C712c70Ba2f9f8E"), // Gary
- common.HexToAddress("0x0DF8fa387C602AE62559cC4aFa4972A7045d6707"), // Guillaume
- },
- Threshold: 2,
- }
- // RinkebyChainConfig contains the chain parameters to run a node on the Rinkeby test network.
- RinkebyChainConfig = &ChainConfig{
- ChainID: big.NewInt(4),
- HomesteadBlock: big.NewInt(1),
- DAOForkBlock: nil,
- DAOForkSupport: true,
- EIP150Block: big.NewInt(2),
- EIP150Hash: common.HexToHash("0x9b095b36c15eaf13044373aef8ee0bd3a382a5abb92e402afa44b8249c3a90e9"),
- EIP155Block: big.NewInt(3),
- EIP158Block: big.NewInt(3),
- ByzantiumBlock: big.NewInt(1_035_301),
- ConstantinopleBlock: big.NewInt(3_660_663),
- PetersburgBlock: big.NewInt(4_321_234),
- IstanbulBlock: big.NewInt(5_435_345),
- MuirGlacierBlock: nil,
- BerlinBlock: big.NewInt(8_290_928),
- Clique: &CliqueConfig{
- Period: 15,
- Epoch: 30000,
- },
- }
- // RinkebyTrustedCheckpoint contains the light client trusted checkpoint for the Rinkeby test network.
- RinkebyTrustedCheckpoint = &TrustedCheckpoint{
- SectionIndex: 254,
- SectionHead: common.HexToHash("0x0cba01dd71baa22ac8fa0b105bc908e94f9ecfbc79b4eb97427fe07b5851dd10"),
- CHTRoot: common.HexToHash("0x5673d8fc49c9c7d8729068640e4b392d46952a5a38798973bac1cf1d0d27ad7d"),
- BloomRoot: common.HexToHash("0x70e01232b66df9a7778ae3291c9217afb9a2d9f799f32d7b912bd37e7bce83a8"),
- }
- // RinkebyCheckpointOracle contains a set of configs for the Rinkeby test network oracle.
- RinkebyCheckpointOracle = &CheckpointOracleConfig{
- Address: common.HexToAddress("0xebe8eFA441B9302A0d7eaECc277c09d20D684540"),
- Signers: []common.Address{
- common.HexToAddress("0xd9c9cd5f6779558b6e0ed4e6acf6b1947e7fa1f3"), // Peter
- common.HexToAddress("0x78d1aD571A1A09D60D9BBf25894b44e4C8859595"), // Martin
- common.HexToAddress("0x286834935f4A8Cfb4FF4C77D5770C2775aE2b0E7"), // Zsolt
- common.HexToAddress("0xb86e2B0Ab5A4B1373e40c51A7C712c70Ba2f9f8E"), // Gary
- },
- Threshold: 2,
- }
- // GoerliChainConfig contains the chain parameters to run a node on the Görli test network.
- GoerliChainConfig = &ChainConfig{
- ChainID: big.NewInt(5),
- HomesteadBlock: big.NewInt(0),
- DAOForkBlock: nil,
- DAOForkSupport: true,
- EIP150Block: big.NewInt(0),
- EIP155Block: big.NewInt(0),
- EIP158Block: big.NewInt(0),
- ByzantiumBlock: big.NewInt(0),
- ConstantinopleBlock: big.NewInt(0),
- PetersburgBlock: big.NewInt(0),
- IstanbulBlock: big.NewInt(1_561_651),
- MuirGlacierBlock: nil,
- BerlinBlock: big.NewInt(4_460_644),
- Clique: &CliqueConfig{
- Period: 15,
- Epoch: 30000,
- },
- }
- // GoerliTrustedCheckpoint contains the light client trusted checkpoint for the Görli test network.
- GoerliTrustedCheckpoint = &TrustedCheckpoint{
- SectionIndex: 138,
- SectionHead: common.HexToHash("0xb7ea0566abd7d0def5b3c9afa3431debb7bb30b65af35f106ca93a59e6c859a7"),
- CHTRoot: common.HexToHash("0x378c7ea9081242beb982e2e39567ba12f2ed3e59e5aba3f9db1d595646d7c9f4"),
- BloomRoot: common.HexToHash("0x523c169286cfca52e8a6579d8c35dc8bf093412d8a7478163bfa81ae91c2492d"),
- }
- // GoerliCheckpointOracle contains a set of configs for the Goerli test network oracle.
- GoerliCheckpointOracle = &CheckpointOracleConfig{
- Address: common.HexToAddress("0x18CA0E045F0D772a851BC7e48357Bcaab0a0795D"),
- Signers: []common.Address{
- common.HexToAddress("0x4769bcaD07e3b938B7f43EB7D278Bc7Cb9efFb38"), // Peter
- common.HexToAddress("0x78d1aD571A1A09D60D9BBf25894b44e4C8859595"), // Martin
- common.HexToAddress("0x286834935f4A8Cfb4FF4C77D5770C2775aE2b0E7"), // Zsolt
- common.HexToAddress("0xb86e2B0Ab5A4B1373e40c51A7C712c70Ba2f9f8E"), // Gary
- common.HexToAddress("0x0DF8fa387C602AE62559cC4aFa4972A7045d6707"), // Guillaume
- },
- Threshold: 2,
- }
- // YoloV3ChainConfig contains the chain parameters to run a node on the YOLOv3 test network.
- YoloV3ChainConfig = &ChainConfig{
- ChainID: new(big.Int).SetBytes([]byte("yolov3x")),
- HomesteadBlock: big.NewInt(0),
- DAOForkBlock: nil,
- DAOForkSupport: true,
- EIP150Block: big.NewInt(0),
- EIP155Block: big.NewInt(0),
- EIP158Block: big.NewInt(0),
- ByzantiumBlock: big.NewInt(0),
- ConstantinopleBlock: big.NewInt(0),
- PetersburgBlock: big.NewInt(0),
- IstanbulBlock: big.NewInt(0),
- MuirGlacierBlock: nil,
- BerlinBlock: nil, // Don't enable Berlin directly, we're YOLOing it
- YoloV3Block: big.NewInt(0),
- Clique: &CliqueConfig{
- Period: 15,
- Epoch: 30000,
- },
- }
- // AllEthashProtocolChanges contains every protocol change (EIPs) introduced
- // and accepted by the Ethereum core developers into the Ethash consensus.
- //
- // This configuration is intentionally not using keyed fields to force anyone
- // adding flags to the config to also have to set these fields.
- AllEthashProtocolChanges = &ChainConfig{big.NewInt(1337), big.NewInt(0), nil, false, big.NewInt(0), common.Hash{}, big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), nil, nil, nil, new(EthashConfig), nil, nil, nil, nil, nil, false, 32, 35, big.NewInt(0), big.NewInt(0), nil, nil, false, nil, nil}
- // AllCliqueProtocolChanges contains every protocol change (EIPs) introduced
- // and accepted by the Ethereum core developers into the Clique consensus.
- //
- // This configuration is intentionally not using keyed fields to force anyone
- // adding flags to the config to also have to set these fields.
- AllCliqueProtocolChanges = &ChainConfig{big.NewInt(10), big.NewInt(0), nil, false, big.NewInt(0), common.Hash{}, big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), nil, nil, nil, nil, &CliqueConfig{Period: 0, Epoch: 30000}, nil, nil, nil, nil, false, 32, 32, big.NewInt(0), big.NewInt(0), nil, nil, false, nil, nil}
- // Quorum chainID should 10
- TestChainConfig = &ChainConfig{big.NewInt(10), big.NewInt(0), nil, false, big.NewInt(0), common.Hash{}, big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), nil, nil, nil, new(EthashConfig), nil, nil, nil, nil, nil, false, 32, 32, big.NewInt(0), big.NewInt(0), nil, nil, false, nil, nil}
- TestRules = TestChainConfig.Rules(new(big.Int))
- QuorumTestChainConfig = &ChainConfig{big.NewInt(10), big.NewInt(0), nil, false, big.NewInt(0), common.Hash{}, big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), nil, nil, nil, nil, nil, new(EthashConfig), nil, nil, nil, nil, nil, true, 64, 32, big.NewInt(0), big.NewInt(0), nil, big.NewInt(0), false, nil, nil}
- QuorumMPSTestChainConfig = &ChainConfig{big.NewInt(10), big.NewInt(0), nil, false, big.NewInt(0), common.Hash{}, big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), big.NewInt(0), nil, nil, nil, nil, nil, new(EthashConfig), nil, nil, nil, nil, nil, true, 64, 32, big.NewInt(0), big.NewInt(0), nil, big.NewInt(0), true, nil, nil}
- )
- // TrustedCheckpoint represents a set of post-processed trie roots (CHT and
- // BloomTrie) associated with the appropriate section index and head hash. It is
- // used to start light syncing from this checkpoint and avoid downloading the
- // entire header chain while still being able to securely access old headers/logs.
- type TrustedCheckpoint struct {
- SectionIndex uint64 `json:"sectionIndex"`
- SectionHead common.Hash `json:"sectionHead"`
- CHTRoot common.Hash `json:"chtRoot"`
- BloomRoot common.Hash `json:"bloomRoot"`
- }
- // HashEqual returns an indicator comparing the itself hash with given one.
- func (c *TrustedCheckpoint) HashEqual(hash common.Hash) bool {
- if c.Empty() {
- return hash == common.Hash{}
- }
- return c.Hash() == hash
- }
- // Hash returns the hash of checkpoint's four key fields(index, sectionHead, chtRoot and bloomTrieRoot).
- func (c *TrustedCheckpoint) Hash() common.Hash {
- var sectionIndex [8]byte
- binary.BigEndian.PutUint64(sectionIndex[:], c.SectionIndex)
- w := sha3.NewLegacyKeccak256()
- w.Write(sectionIndex[:])
- w.Write(c.SectionHead[:])
- w.Write(c.CHTRoot[:])
- w.Write(c.BloomRoot[:])
- var h common.Hash
- w.Sum(h[:0])
- return h
- }
- // Empty returns an indicator whether the checkpoint is regarded as empty.
- func (c *TrustedCheckpoint) Empty() bool {
- return c.SectionHead == (common.Hash{}) || c.CHTRoot == (common.Hash{}) || c.BloomRoot == (common.Hash{})
- }
- // CheckpointOracleConfig represents a set of checkpoint contract(which acts as an oracle)
- // config which used for light client checkpoint syncing.
- type CheckpointOracleConfig struct {
- Address common.Address `json:"address"`
- Signers []common.Address `json:"signers"`
- Threshold uint64 `json:"threshold"`
- }
- type MaxCodeConfigStruct struct {
- Block *big.Int `json:"block,omitempty"`
- Size uint64 `json:"size,omitempty"`
- }
- // ChainConfig is the core config which determines the blockchain settings.
- //
- // ChainConfig is stored in the database on a per block basis. This means
- // that any network, identified by its genesis block, can have its own
- // set of configuration options.
- type ChainConfig struct {
- ChainID *big.Int `json:"chainId"` // chainId identifies the current chain and is used for replay protection
- HomesteadBlock *big.Int `json:"homesteadBlock,omitempty"` // Homestead switch block (nil = no fork, 0 = already homestead)
- DAOForkBlock *big.Int `json:"daoForkBlock,omitempty"` // TheDAO hard-fork switch block (nil = no fork)
- DAOForkSupport bool `json:"daoForkSupport,omitempty"` // Whether the nodes supports or opposes the DAO hard-fork
- // EIP150 implements the Gas price changes (https://github.com/ethereum/EIPs/issues/150)
- EIP150Block *big.Int `json:"eip150Block,omitempty"` // EIP150 HF block (nil = no fork)
- EIP150Hash common.Hash `json:"eip150Hash,omitempty"` // EIP150 HF hash (needed for header only clients as only gas pricing changed)
- EIP155Block *big.Int `json:"eip155Block,omitempty"` // EIP155 HF block
- EIP158Block *big.Int `json:"eip158Block,omitempty"` // EIP158 HF block
- ByzantiumBlock *big.Int `json:"byzantiumBlock,omitempty"` // Byzantium switch block (nil = no fork, 0 = already on byzantium)
- ConstantinopleBlock *big.Int `json:"constantinopleBlock,omitempty"` // Constantinople switch block (nil = no fork, 0 = already activated)
- PetersburgBlock *big.Int `json:"petersburgBlock,omitempty"` // Petersburg switch block (nil = same as Constantinople)
- IstanbulBlock *big.Int `json:"istanbulBlock,omitempty"` // Istanbul switch block (nil = no fork, 0 = already on istanbul)
- MuirGlacierBlock *big.Int `json:"muirGlacierBlock,omitempty"` // Eip-2384 (bomb delay) switch block (nil = no fork, 0 = already activated)
- BerlinBlock *big.Int `json:"berlinBlock,omitempty"` // Berlin switch block (nil = no fork, 0 = already on berlin)
- YoloV3Block *big.Int `json:"yoloV3Block,omitempty"` // YOLO v3: Gas repricings TODO @holiman add EIP references
- EWASMBlock *big.Int `json:"ewasmBlock,omitempty"` // EWASM switch block (nil = no fork, 0 = already activated)
- CatalystBlock *big.Int `json:"catalystBlock,omitempty"` // Catalyst switch block (nil = no fork, 0 = already on catalyst)
- // Various consensus engines
- Ethash *EthashConfig `json:"ethash,omitempty"`
- Clique *CliqueConfig `json:"clique,omitempty"`
- Istanbul *IstanbulConfig `json:"istanbul,omitempty"` // Quorum
- IBFT *IBFTConfig `json:"ibft,omitempty"` // Quorum
- QBFT *QBFTConfig `json:"qbft,omitempty"` // Quorum
- // Start of Quorum specific configs
- Transitions []Transition `json:"transitions,omitempty"` // Quorum - transition config based on the block number
- IsQuorum bool `json:"isQuorum"` // Quorum flag
- TransactionSizeLimit uint64 `json:"txnSizeLimit"` // Quorum - transaction size limit
- MaxCodeSize uint64 `json:"maxCodeSize"` // Quorum - maximum CodeSize of contract
- // QIP714Block implements the permissions related changes
- QIP714Block *big.Int `json:"qip714Block,omitempty"`
- MaxCodeSizeChangeBlock *big.Int `json:"maxCodeSizeChangeBlock,omitempty"`
- // to track multiple changes to maxCodeSize
- MaxCodeSizeConfig []MaxCodeConfigStruct `json:"maxCodeSizeConfig,omitempty"`
- PrivacyEnhancementsBlock *big.Int `json:"privacyEnhancementsBlock,omitempty"`
- IsMPS bool `json:"isMPS"` // multiple private states flag
- PrivacyPrecompileBlock *big.Int `json:"privacyPrecompileBlock,omitempty"` // Switch block to enable privacy precompiled contract to process privacy marker transactions
- EnableGasPriceBlock *big.Int `json:"enableGasPriceBlock,omitempty"` // Switch block to enable usage of gas price
- // End of Quorum specific configs
- }
- // EthashConfig is the consensus engine configs for proof-of-work based sealing.
- type EthashConfig struct{}
- // String implements the stringer interface, returning the consensus engine details.
- func (c *EthashConfig) String() string {
- return "ethash"
- }
- // CliqueConfig is the consensus engine configs for proof-of-authority based sealing.
- type CliqueConfig struct {
- Period uint64 `json:"period"` // Number of seconds between blocks to enforce
- Epoch uint64 `json:"epoch"` // Epoch length to reset votes and checkpoint
- AllowedFutureBlockTime uint64 `json:"allowedFutureBlockTime"` // Max time (in seconds) from current time allowed for blocks, before they're considered future blocks
- }
- // String implements the stringer interface, returning the consensus engine details.
- func (c *CliqueConfig) String() string {
- return "clique"
- }
- // IstanbulConfig is the consensus engine configs for Istanbul based sealing.
- type IstanbulConfig struct {
- Epoch uint64 `json:"epoch"` // Epoch length to reset votes and checkpoint
- ProposerPolicy uint64 `json:"policy"` // The policy for proposer selection
- Ceil2Nby3Block *big.Int `json:"ceil2Nby3Block,omitempty"` // Number of confirmations required to move from one state to next [2F + 1 to Ceil(2N/3)]
- TestQBFTBlock *big.Int `json:"testQBFTBlock,omitempty"` // Fork block at which block confirmations are done using qbft consensus instead of ibft
- }
- // String implements the stringer interface, returning the consensus engine details.
- func (c *IstanbulConfig) String() string {
- return "istanbul"
- }
- type BFTConfig struct {
- EpochLength uint64 `json:"epochlength"` // Number of blocks that should pass before pending validator votes are reset
- BlockPeriodSeconds uint64 `json:"blockperiodseconds"` // Minimum time between two consecutive IBFT or QBFT blocks’ timestamps in seconds
- EmptyBlockPeriodSeconds *uint64 `json:"emptyblockperiodseconds,omitempty"` // Minimum time between two consecutive IBFT or QBFT a block and empty block’ timestamps in seconds
- RequestTimeoutSeconds uint64 `json:"requesttimeoutseconds"` // Minimum request timeout for each IBFT or QBFT round in milliseconds
- ProposerPolicy uint64 `json:"policy"` // The policy for proposer selection
- Ceil2Nby3Block *big.Int `json:"ceil2Nby3Block,omitempty"` // Number of confirmations required to move from one state to next [2F + 1 to Ceil(2N/3)]
- ValidatorContractAddress common.Address `json:"validatorcontractaddress"` // Smart contract address for list of validators
- }
- type IBFTConfig struct {
- *BFTConfig
- }
- func (c IBFTConfig) String() string {
- return "istanbul"
- }
- type QBFTConfig struct {
- *BFTConfig
- BlockReward *math.HexOrDecimal256 `json:"blockReward,omitempty"` // Reward from start, works only on QBFT consensus protocol
- BeneficiaryMode *string `json:"beneficiaryMode,omitempty"` // Mode for setting the beneficiary, either: list, besu, validators (beneficiary list is the list of validators)
- MiningBeneficiary *common.Address `json:"miningBeneficiary,omitempty"` // Wallet address that benefits at every new block (besu mode)
- ValidatorSelectionMode *string `json:"validatorselectionmode,omitempty"` // Select model for validators
- Validators []common.Address `json:"validators"` // Validators list
- }
- func (c QBFTConfig) String() string {
- return QBFT
- }
- const (
- IBFT = "ibft"
- QBFT = "qbft"
- ContractMode = "contract"
- BlockHeaderMode = "blockheader"
- )
- type Transition struct {
- Block *big.Int `json:"block"`
- Algorithm string `json:"algorithm,omitempty"`
- EpochLength uint64 `json:"epochlength,omitempty"` // Number of blocks that should pass before pending validator votes are reset
- BlockPeriodSeconds uint64 `json:"blockperiodseconds,omitempty"` // Minimum time between two consecutive IBFT or QBFT blocks’ timestamps in seconds
- EmptyBlockPeriodSeconds *uint64 `json:"emptyblockperiodseconds,omitempty"` // Minimum time between two consecutive IBFT or QBFT a block and empty block’ timestamps in seconds
- RequestTimeoutSeconds uint64 `json:"requesttimeoutseconds,omitempty"` // Minimum request timeout for each IBFT or QBFT round in milliseconds
- ContractSizeLimit uint64 `json:"contractsizelimit,omitempty"` // Maximum smart contract code size
- ValidatorContractAddress common.Address `json:"validatorcontractaddress"` // Smart contract address for list of validators
- Validators []common.Address `json:"validators"` // List of validators
- ValidatorSelectionMode string `json:"validatorselectionmode,omitempty"` // Validator selection mode to switch to
- EnhancedPermissioningEnabled *bool `json:"enhancedPermissioningEnabled,omitempty"` // aka QIP714Block
- PrivacyEnhancementsEnabled *bool `json:"privacyEnhancementsEnabled,omitempty"` // privacy enhancements (mandatory party, private state validation)
- PrivacyPrecompileEnabled *bool `json:"privacyPrecompileEnabled,omitempty"` // enable marker transactions support
- GasPriceEnabled *bool `json:"gasPriceEnabled,omitempty"` // enable gas price
- MinerGasLimit uint64 `json:"miner.gaslimit,omitempty"` // Gas Limit
- TwoFPlusOneEnabled *bool `json:"2FPlus1Enabled,omitempty"` // Ceil(2N/3) is the default you need to explicitly use 2F + 1
- TransactionSizeLimit uint64 `json:"transactionSizeLimit,omitempty"` // Modify TransactionSizeLimit
- BlockReward *math.HexOrDecimal256 `json:"blockReward,omitempty"` // validation rewards
- BeneficiaryMode *string `json:"beneficiaryMode,omitempty"` // Mode for setting the beneficiary, either: list, besu, validators (beneficiary list is the list of validators)
- MiningBeneficiary *common.Address `json:"miningBeneficiary,omitempty"` // Wallet address that benefits at every new block (besu mode)
- }
- // String implements the fmt.Stringer interface.
- func (c *ChainConfig) String() string {
- var engine interface{}
- switch {
- case c.Ethash != nil:
- engine = c.Ethash
- case c.Clique != nil:
- engine = c.Clique
- case c.Istanbul != nil:
- engine = c.Istanbul
- default:
- engine = "unknown"
- }
- return fmt.Sprintf("{ChainID: %v Homestead: %v DAO: %v DAOSupport: %v EIP150: %v EIP155: %v EIP158: %v Byzantium: %v IsQuorum: %v Constantinople: %v TransactionSizeLimit: %v MaxCodeSize: %v Petersburg: %v Istanbul: %v, Muir Glacier: %v, Berlin: %v Catalyst: %v YOLO v3: %v PrivacyEnhancements: %v PrivacyPrecompile: %v EnableGasPriceBlock: %v Engine: %v}",
- c.ChainID,
- c.HomesteadBlock,
- c.DAOForkBlock,
- c.DAOForkSupport,
- c.EIP150Block,
- c.EIP155Block,
- c.EIP158Block,
- c.ByzantiumBlock,
- c.IsQuorum,
- c.ConstantinopleBlock,
- c.TransactionSizeLimit,
- c.MaxCodeSize,
- c.PetersburgBlock,
- c.IstanbulBlock,
- c.MuirGlacierBlock,
- c.BerlinBlock,
- c.CatalystBlock,
- c.YoloV3Block,
- c.PrivacyEnhancementsBlock, //Quorum
- c.PrivacyPrecompileBlock, //Quorum
- c.EnableGasPriceBlock, //Quorum
- engine,
- )
- }
- // Quorum - validate code size and transaction size limit
- func (c *ChainConfig) IsValid() error {
- if c.TransactionSizeLimit < 32 || c.TransactionSizeLimit > 128 {
- return errors.New("Genesis transaction size limit must be between 32 and 128")
- }
- if c.MaxCodeSize != 0 && (c.MaxCodeSize < 24 || c.MaxCodeSize > 128) {
- return errors.New("Genesis max code size must be between 24 and 128")
- }
- return nil
- }
- // IsHomestead returns whether num is either equal to the homestead block or greater.
- func (c *ChainConfig) IsHomestead(num *big.Int) bool {
- return isForked(c.HomesteadBlock, num)
- }
- // IsDAOFork returns whether num is either equal to the DAO fork block or greater.
- func (c *ChainConfig) IsDAOFork(num *big.Int) bool {
- return isForked(c.DAOForkBlock, num)
- }
- // IsEIP150 returns whether num is either equal to the EIP150 fork block or greater.
- func (c *ChainConfig) IsEIP150(num *big.Int) bool {
- return isForked(c.EIP150Block, num)
- }
- // IsEIP155 returns whether num is either equal to the EIP155 fork block or greater.
- func (c *ChainConfig) IsEIP155(num *big.Int) bool {
- return isForked(c.EIP155Block, num)
- }
- // IsEIP158 returns whether num is either equal to the EIP158 fork block or greater.
- func (c *ChainConfig) IsEIP158(num *big.Int) bool {
- return isForked(c.EIP158Block, num)
- }
- // IsByzantium returns whether num is either equal to the Byzantium fork block or greater.
- func (c *ChainConfig) IsByzantium(num *big.Int) bool {
- return isForked(c.ByzantiumBlock, num)
- }
- // IsConstantinople returns whether num is either equal to the Constantinople fork block or greater.
- func (c *ChainConfig) IsConstantinople(num *big.Int) bool {
- return isForked(c.ConstantinopleBlock, num)
- }
- // IsMuirGlacier returns whether num is either equal to the Muir Glacier (EIP-2384) fork block or greater.
- func (c *ChainConfig) IsMuirGlacier(num *big.Int) bool {
- return isForked(c.MuirGlacierBlock, num)
- }
- // IsPetersburg returns whether num is either
- // - equal to or greater than the PetersburgBlock fork block,
- // - OR is nil, and Constantinople is active
- func (c *ChainConfig) IsPetersburg(num *big.Int) bool {
- return isForked(c.PetersburgBlock, num) || c.PetersburgBlock == nil && isForked(c.ConstantinopleBlock, num)
- }
- // IsIstanbul returns whether num is either equal to the Istanbul fork block or greater.
- func (c *ChainConfig) IsIstanbul(num *big.Int) bool {
- return isForked(c.IstanbulBlock, num)
- }
- // IsBerlin returns whether num is either equal to the Berlin fork block or greater.
- func (c *ChainConfig) IsBerlin(num *big.Int) bool {
- return isForked(c.BerlinBlock, num) || isForked(c.YoloV3Block, num)
- }
- // IsCatalyst returns whether num is either equal to the Merge fork block or greater.
- func (c *ChainConfig) IsCatalyst(num *big.Int) bool {
- return isForked(c.CatalystBlock, num)
- }
- // IsEWASM returns whether num represents a block number after the EWASM fork
- func (c *ChainConfig) IsEWASM(num *big.Int) bool {
- return isForked(c.EWASMBlock, num)
- }
- // Quorum
- //
- // IsQIP714 returns whether num represents a block number where permissions is enabled
- func (c *ChainConfig) IsQIP714(num *big.Int) bool {
- enableEnhancedPermissioning := false
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.EnhancedPermissioningEnabled != nil {
- enableEnhancedPermissioning = *transition.EnhancedPermissioningEnabled
- }
- })
- return isForked(c.QIP714Block, num) || enableEnhancedPermissioning
- }
- // Quorum
- //
- // GetMaxCodeSize returns maxCodeSize for the given block number
- func (c *ChainConfig) GetMaxCodeSize(num *big.Int) int {
- maxCodeSize := MaxCodeSize
- if len(c.MaxCodeSizeConfig) > 0 {
- log.Warn("WARNING: The attribute config.maxCodeSizeConfig is deprecated and will be removed in the future, please use config.transitions.contractsizelimit on genesis file")
- for _, data := range c.MaxCodeSizeConfig {
- if data.Block.Cmp(num) > 0 {
- break
- }
- maxCodeSize = int(data.Size) * 1024
- }
- } else if c.MaxCodeSize > 0 {
- if c.MaxCodeSizeChangeBlock != nil && c.MaxCodeSizeChangeBlock.Cmp(big.NewInt(0)) >= 0 {
- if isForked(c.MaxCodeSizeChangeBlock, num) {
- maxCodeSize = int(c.MaxCodeSize) * 1024
- }
- } else {
- maxCodeSize = int(c.MaxCodeSize) * 1024
- }
- }
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.ContractSizeLimit != 0 {
- maxCodeSize = int(transition.ContractSizeLimit) * 1024
- }
- })
- return maxCodeSize
- }
- func (c *ChainConfig) GetRewardAccount(num *big.Int, coinbase common.Address) (common.Address, error) {
- beneficiaryMode := "validator"
- miningBeneficiary := common.Address{}
- if c.QBFT != nil && c.QBFT.MiningBeneficiary != nil {
- miningBeneficiary = *c.QBFT.MiningBeneficiary
- beneficiaryMode = "fixed"
- }
- if c.QBFT != nil && c.QBFT.BeneficiaryMode != nil {
- beneficiaryMode = *c.QBFT.BeneficiaryMode
- }
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.BeneficiaryMode != nil && (*transition.BeneficiaryMode == "validators" || *transition.BeneficiaryMode == "validator") {
- beneficiaryMode = "validator"
- }
- if transition.MiningBeneficiary != nil && (transition.BeneficiaryMode == nil || *transition.BeneficiaryMode == "fixed") {
- miningBeneficiary = *transition.MiningBeneficiary
- beneficiaryMode = "fixed"
- }
- })
- switch strings.ToLower(beneficiaryMode) {
- case "fixed":
- log.Trace("fixed beneficiary mode", "miningBeneficiary", miningBeneficiary)
- return miningBeneficiary, nil
- case "validator":
- log.Trace("validator beneficiary mode", "coinbase", coinbase)
- return coinbase, nil
- }
- return common.Address{}, errors.New("BeneficiaryMode must be coinbase|fixed")
- }
- func (c *ChainConfig) GetBlockReward(num *big.Int) big.Int {
- blockReward := *math.NewHexOrDecimal256(0)
- if c.QBFT != nil && c.QBFT.BlockReward != nil {
- blockReward = *c.QBFT.BlockReward
- }
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.BlockReward != nil {
- blockReward = *transition.BlockReward
- }
- })
- return big.Int(blockReward)
- }
- // Quorum
- // gets value at or after a transition
- func (c *ChainConfig) GetTransitionValue(num *big.Int, callback func(transition Transition)) {
- if c != nil && num != nil && c.Transitions != nil {
- for i := 0; i < len(c.Transitions) && c.Transitions[i].Block.Cmp(num) <= 0; i++ {
- callback(c.Transitions[i])
- }
- }
- }
- // Quorum
- //
- // GetMinerMinGasLimit returns the miners minGasLimit for the given block number
- func (c *ChainConfig) GetMinerMinGasLimit(num *big.Int, defaultValue uint64) uint64 {
- minGasLimit := defaultValue
- if c != nil && num != nil && len(c.Transitions) > 0 {
- for i := 0; i < len(c.Transitions) && c.Transitions[i].Block.Cmp(num) <= 0; i++ {
- if c.Transitions[i].MinerGasLimit != 0 {
- minGasLimit = c.Transitions[i].MinerGasLimit
- }
- }
- }
- return minGasLimit
- }
- // Quorum
- //
- // validates the maxCodeSizeConfig data passed in config
- func (c *ChainConfig) CheckMaxCodeConfigData() error {
- if c.MaxCodeSize != 0 || (c.MaxCodeSizeChangeBlock != nil && c.MaxCodeSizeChangeBlock.Cmp(big.NewInt(0)) >= 0) {
- return errors.New("maxCodeSize & maxCodeSizeChangeBlock deprecated. Consider using maxCodeSizeConfig")
- }
- // validate max code size data
- // 1. Code size should not be less than 24 and greater than 128
- // 2. block entries are in ascending order
- prevBlock := big.NewInt(0)
- for _, data := range c.MaxCodeSizeConfig {
- if data.Size < 24 || data.Size > 128 {
- return errors.New("Genesis max code size must be between 24 and 128")
- }
- if data.Block == nil {
- return errors.New("Block number not given in maxCodeSizeConfig data")
- }
- if data.Block.Cmp(prevBlock) < 0 {
- return errors.New("invalid maxCodeSize detail, block order has to be ascending")
- }
- prevBlock = data.Block
- }
- return nil
- }
- func (c *ChainConfig) CheckTransitionsData() error {
- isQBFT := false
- if c.QBFT != nil {
- isQBFT = true
- }
- prevBlock := big.NewInt(0)
- for _, transition := range c.Transitions {
- if transition.Algorithm != "" && !strings.EqualFold(transition.Algorithm, IBFT) && !strings.EqualFold(transition.Algorithm, QBFT) {
- return ErrTransitionAlgorithm
- }
- if transition.ValidatorSelectionMode != "" && transition.ValidatorSelectionMode != ContractMode && transition.ValidatorSelectionMode != BlockHeaderMode {
- return ErrValidatorSelectionMode
- }
- if c.Istanbul != nil && c.Istanbul.TestQBFTBlock != nil && (strings.EqualFold(transition.Algorithm, IBFT) || strings.EqualFold(transition.Algorithm, QBFT)) {
- return ErrTestQBFTBlockAndTransitions
- }
- if len(c.MaxCodeSizeConfig) > 0 && transition.ContractSizeLimit != 0 {
- return ErrMaxCodeSizeConfigAndTransitions
- }
- if strings.EqualFold(transition.Algorithm, QBFT) {
- isQBFT = true
- }
- if transition.Block == nil {
- return ErrBlockNumberMissing
- }
- if transition.Block.Cmp(prevBlock) < 0 {
- return ErrBlockOrder
- }
- if isQBFT && strings.EqualFold(transition.Algorithm, IBFT) {
- return ErrTransition
- }
- if transition.ContractSizeLimit != 0 && (transition.ContractSizeLimit < 24 || transition.ContractSizeLimit > 128) {
- return ErrContractSizeLimit
- }
- if transition.ValidatorContractAddress != (common.Address{}) && transition.ValidatorSelectionMode != ContractMode {
- return ErrMissingValidatorSelectionMode
- }
- if transition.TransactionSizeLimit != 0 && transition.TransactionSizeLimit < 32 || transition.TransactionSizeLimit > 128 {
- return ErrTransactionSizeLimit
- }
- if transition.BeneficiaryMode != nil && *transition.BeneficiaryMode != "fixed" && *transition.BeneficiaryMode != "validators" && *transition.BeneficiaryMode != "" && *transition.BeneficiaryMode != "list" {
- return ErrBeneficiaryMode
- }
- prevBlock = transition.Block
- }
- return nil
- }
- // Quorum
- //
- // checks if changes to maxCodeSizeConfig proposed are compatible
- // with already existing genesis data
- func isMaxCodeSizeConfigCompatible(c1, c2 *ChainConfig, head *big.Int) (error, *big.Int, *big.Int) {
- if len(c1.MaxCodeSizeConfig) == 0 && len(c2.MaxCodeSizeConfig) == 0 {
- // maxCodeSizeConfig not used. return
- return nil, big.NewInt(0), big.NewInt(0)
- }
- // existing config had maxCodeSizeConfig and new one does not have the same return error
- if len(c1.MaxCodeSizeConfig) > 0 && len(c2.MaxCodeSizeConfig) == 0 {
- return fmt.Errorf("genesis file missing max code size information"), head, head
- }
- if len(c2.MaxCodeSizeConfig) > 0 && len(c1.MaxCodeSizeConfig) == 0 {
- return nil, big.NewInt(0), big.NewInt(0)
- }
- // check the number of records below current head in both configs
- // if they do not match throw an error
- c1RecsBelowHead := 0
- for _, data := range c1.MaxCodeSizeConfig {
- if data.Block.Cmp(head) <= 0 {
- c1RecsBelowHead++
- } else {
- break
- }
- }
- c2RecsBelowHead := 0
- for _, data := range c2.MaxCodeSizeConfig {
- if data.Block.Cmp(head) <= 0 {
- c2RecsBelowHead++
- } else {
- break
- }
- }
- // if the count of past records is not matching return error
- if c1RecsBelowHead != c2RecsBelowHead {
- return errors.New("maxCodeSizeConfig data incompatible. updating maxCodeSize for past"), head, head
- }
- // validate that each past record is matching exactly. if not return error
- for i := 0; i < c1RecsBelowHead; i++ {
- if c1.MaxCodeSizeConfig[i].Block.Cmp(c2.MaxCodeSizeConfig[i].Block) != 0 ||
- c1.MaxCodeSizeConfig[i].Size != c2.MaxCodeSizeConfig[i].Size {
- return errors.New("maxCodeSizeConfig data incompatible. maxCodeSize historical data does not match"), head, head
- }
- }
- return nil, big.NewInt(0), big.NewInt(0)
- }
- // Quorum
- //
- // checks if changes to transitions proposed are compatible
- // with already existing genesis data
- func isTransitionsConfigCompatible(c1, c2 *ChainConfig, head *big.Int) (error, *big.Int, *big.Int) {
- if len(c1.Transitions) == 0 && len(c2.Transitions) == 0 {
- // maxCodeSizeConfig not used. return
- return nil, big.NewInt(0), big.NewInt(0)
- }
- // existing config had Transitions and new one does not have the same return error
- if len(c1.Transitions) > 0 && len(c2.Transitions) == 0 {
- return fmt.Errorf("genesis file missing transitions information"), head, head
- }
- if len(c2.Transitions) > 0 && len(c1.Transitions) == 0 {
- return nil, big.NewInt(0), big.NewInt(0)
- }
- // check the number of records below current head in both configs
- // if they do not match throw an error
- c1RecsBelowHead := 0
- for _, data := range c1.Transitions {
- if data.Block.Cmp(head) <= 0 {
- c1RecsBelowHead++
- } else {
- break
- }
- }
- c2RecsBelowHead := 0
- for _, data := range c2.Transitions {
- if data.Block.Cmp(head) <= 0 {
- c2RecsBelowHead++
- } else {
- break
- }
- }
- // if the count of past records is not matching return error
- if c1RecsBelowHead != c2RecsBelowHead {
- return errors.New("transitions data incompatible. updating transitions for past"), head, head
- }
- // validate that each past record is matching exactly. if not return error
- for i := 0; i < c1RecsBelowHead; i++ {
- isSameBlock := c1.Transitions[i].Block.Cmp(c2.Transitions[i].Block) != 0
- if isSameBlock || c1.Transitions[i].Algorithm != c2.Transitions[i].Algorithm {
- return ErrTransitionIncompatible("Algorithm"), head, head
- }
- if isSameBlock || c1.Transitions[i].BlockPeriodSeconds != c2.Transitions[i].BlockPeriodSeconds {
- return ErrTransitionIncompatible("BlockPeriodSeconds"), head, head
- }
- if isSameBlock || c1.Transitions[i].RequestTimeoutSeconds != c2.Transitions[i].RequestTimeoutSeconds {
- return ErrTransitionIncompatible("RequestTimeoutSeconds"), head, head
- }
- if isSameBlock || c1.Transitions[i].EpochLength != c2.Transitions[i].EpochLength {
- return ErrTransitionIncompatible("EpochLength"), head, head
- }
- if isSameBlock || c1.Transitions[i].ContractSizeLimit != c2.Transitions[i].ContractSizeLimit {
- return ErrTransitionIncompatible("ContractSizeLimit"), head, head
- }
- if isSameBlock || c1.Transitions[i].ValidatorContractAddress != c2.Transitions[i].ValidatorContractAddress {
- return ErrTransitionIncompatible("ValidatorContractAddress"), head, head
- }
- if isSameBlock || c1.Transitions[i].ValidatorSelectionMode != c2.Transitions[i].ValidatorSelectionMode {
- return ErrTransitionIncompatible("ValidatorSelectionMode"), head, head
- }
- if isSameBlock || c1.Transitions[i].MinerGasLimit != c2.Transitions[i].MinerGasLimit {
- return ErrTransitionIncompatible("Miner GasLimit"), head, head
- }
- if isSameBlock || c1.Transitions[i].TwoFPlusOneEnabled != c2.Transitions[i].TwoFPlusOneEnabled {
- return ErrTransitionIncompatible("2FPlus1Enabled"), head, head
- }
- if isSameBlock || c1.Transitions[i].MinerGasLimit != c2.Transitions[i].MinerGasLimit {
- return ErrTransitionIncompatible("TransactionSizeLimit"), head, head
- }
- }
- return nil, big.NewInt(0), big.NewInt(0)
- }
- // Quorum
- //
- // IsPrivacyEnhancementsEnabled returns whether num represents a block number after the PrivacyEnhancementsEnabled fork
- func (c *ChainConfig) IsPrivacyEnhancementsEnabled(num *big.Int) bool {
- isPrivacyEnhancementsEnabled := false
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.PrivacyEnhancementsEnabled != nil {
- isPrivacyEnhancementsEnabled = *transition.PrivacyEnhancementsEnabled
- }
- })
- return isForked(c.PrivacyEnhancementsBlock, num) || isPrivacyEnhancementsEnabled
- }
- // Quorum
- //
- // Check whether num represents a block number after the PrivacyPrecompileBlock
- func (c *ChainConfig) IsPrivacyPrecompileEnabled(num *big.Int) bool {
- isPrivacyPrecompileEnabled := false
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.PrivacyPrecompileEnabled != nil {
- isPrivacyPrecompileEnabled = *transition.PrivacyPrecompileEnabled
- }
- })
- return isForked(c.PrivacyPrecompileBlock, num) || isPrivacyPrecompileEnabled
- }
- // Quorum
- func (c *ChainConfig) GetTransactionSizeLimit(num *big.Int) uint64 {
- transactionSizeLimit := uint64(0)
- c.GetTransitionValue(num, func(transition Transition) {
- transactionSizeLimit = transition.TransactionSizeLimit
- })
- if transactionSizeLimit == 0 {
- transactionSizeLimit = c.TransactionSizeLimit
- }
- if transactionSizeLimit == 0 {
- transactionSizeLimit = 64
- }
- return transactionSizeLimit
- }
- // Quorum
- //
- // Check whether num represents a block number after the EnableGasPriceBlock
- func (c *ChainConfig) IsGasPriceEnabled(num *big.Int) bool {
- isGasEnabled := false
- c.GetTransitionValue(num, func(transition Transition) {
- if transition.GasPriceEnabled != nil {
- isGasEnabled = *transition.GasPriceEnabled
- }
- })
- return isForked(c.EnableGasPriceBlock, num) || isGasEnabled
- }
- // CheckCompatible checks whether scheduled fork transitions have been imported
- // with a mismatching chain configuration.
- func (c *ChainConfig) CheckCompatible(newcfg *ChainConfig, height uint64, isQuorumEIP155Activated bool) *ConfigCompatError {
- bhead := new(big.Int).SetUint64(height)
- // check if the maxCodesize data passed is compatible 1st
- // this is being handled separately as it can have breaks
- // at multiple block heights and cannot be handled with in
- // checkCompatible
- // compare the maxCodeSize data between the old and new config
- err, cBlock, newCfgBlock := isMaxCodeSizeConfigCompatible(c, newcfg, bhead)
- if err != nil {
- return newCompatError(err.Error(), cBlock, newCfgBlock)
- }
- // compare the transitions data between the old and new config
- err, cBlock, newCfgBlock = isTransitionsConfigCompatible(c, newcfg, bhead)
- if err != nil {
- return newCompatError(err.Error(), cBlock, newCfgBlock)
- }
- // Iterate checkCompatible to find the lowest conflict.
- var lasterr *ConfigCompatError
- for {
- err := c.checkCompatible(newcfg, bhead, isQuorumEIP155Activated)
- if err == nil || (lasterr != nil && err.RewindTo == lasterr.RewindTo) {
- break
- }
- lasterr = err
- bhead.SetUint64(err.RewindTo)
- }
- return lasterr
- }
- // CheckConfigForkOrder checks that we don't "skip" any forks, geth isn't pluggable enough
- // to guarantee that forks
- func (c *ChainConfig) CheckConfigForkOrder() error {
- type fork struct {
- name string
- block *big.Int
- optional bool // if true, the fork may be nil and next fork is still allowed
- }
- var lastFork fork
- for _, cur := range []fork{
- {name: "homesteadBlock", block: c.HomesteadBlock},
- {name: "daoForkBlock", block: c.DAOForkBlock, optional: true},
- {name: "eip150Block", block: c.EIP150Block},
- {name: "eip155Block", block: c.EIP155Block},
- {name: "eip158Block", block: c.EIP158Block},
- {name: "byzantiumBlock", block: c.ByzantiumBlock},
- {name: "constantinopleBlock", block: c.ConstantinopleBlock},
- {name: "petersburgBlock", block: c.PetersburgBlock},
- {name: "istanbulBlock", block: c.IstanbulBlock},
- {name: "muirGlacierBlock", block: c.MuirGlacierBlock, optional: true},
- {name: "berlinBlock", block: c.BerlinBlock},
- } {
- if lastFork.name != "" {
- // Next one must be higher number
- if lastFork.block == nil && cur.block != nil {
- return fmt.Errorf("unsupported fork ordering: %v not enabled, but %v enabled at %v",
- lastFork.name, cur.name, cur.block)
- }
- if lastFork.block != nil && cur.block != nil {
- if lastFork.block.Cmp(cur.block) > 0 {
- return fmt.Errorf("unsupported fork ordering: %v enabled at %v, but %v enabled at %v",
- lastFork.name, lastFork.block, cur.name, cur.block)
- }
- }
- }
- // If it was optional and not set, then ignore it
- if !cur.optional || cur.block != nil {
- lastFork = cur
- }
- }
- return nil
- }
- func (c *ChainConfig) checkCompatible(newcfg *ChainConfig, head *big.Int, isQuorumEIP155Activated bool) *ConfigCompatError {
- if isForkIncompatible(c.HomesteadBlock, newcfg.HomesteadBlock, head) {
- return newCompatError("Homestead fork block", c.HomesteadBlock, newcfg.HomesteadBlock)
- }
- if isForkIncompatible(c.DAOForkBlock, newcfg.DAOForkBlock, head) {
- return newCompatError("DAO fork block", c.DAOForkBlock, newcfg.DAOForkBlock)
- }
- if c.IsDAOFork(head) && c.DAOForkSupport != newcfg.DAOForkSupport {
- return newCompatError("DAO fork support flag", c.DAOForkBlock, newcfg.DAOForkBlock)
- }
- if isForkIncompatible(c.EIP150Block, newcfg.EIP150Block, head) {
- return newCompatError("EIP150 fork block", c.EIP150Block, newcfg.EIP150Block)
- }
- if isQuorumEIP155Activated && c.ChainID != nil && isForkIncompatible(c.EIP155Block, newcfg.EIP155Block, head) {
- return newCompatError("EIP155 fork block", c.EIP155Block, newcfg.EIP155Block)
- }
- if isQuorumEIP155Activated && c.ChainID != nil && c.IsEIP155(head) && !configNumEqual(c.ChainID, newcfg.ChainID) {
- return newCompatError("EIP155 chain ID", c.ChainID, newcfg.ChainID)
- }
- if isForkIncompatible(c.EIP158Block, newcfg.EIP158Block, head) {
- return newCompatError("EIP158 fork block", c.EIP158Block, newcfg.EIP158Block)
- }
- if c.IsEIP158(head) && !configNumEqual(c.ChainID, newcfg.ChainID) {
- return newCompatError("EIP158 chain ID", c.EIP158Block, newcfg.EIP158Block)
- }
- if isForkIncompatible(c.ByzantiumBlock, newcfg.ByzantiumBlock, head) {
- return newCompatError("Byzantium fork block", c.ByzantiumBlock, newcfg.ByzantiumBlock)
- }
- if isForkIncompatible(c.ConstantinopleBlock, newcfg.ConstantinopleBlock, head) {
- return newCompatError("Constantinople fork block", c.ConstantinopleBlock, newcfg.ConstantinopleBlock)
- }
- if isForkIncompatible(c.PetersburgBlock, newcfg.PetersburgBlock, head) {
- // the only case where we allow Petersburg to be set in the past is if it is equal to Constantinople
- // mainly to satisfy fork ordering requirements which state that Petersburg fork be set if Constantinople fork is set
- if isForkIncompatible(c.ConstantinopleBlock, newcfg.PetersburgBlock, head) {
- return newCompatError("Petersburg fork block", c.PetersburgBlock, newcfg.PetersburgBlock)
- }
- }
- if isForkIncompatible(c.IstanbulBlock, newcfg.IstanbulBlock, head) {
- return newCompatError("Istanbul fork block", c.IstanbulBlock, newcfg.IstanbulBlock)
- }
- if isForkIncompatible(c.MuirGlacierBlock, newcfg.MuirGlacierBlock, head) {
- return newCompatError("Muir Glacier fork block", c.MuirGlacierBlock, newcfg.MuirGlacierBlock)
- }
- if isForkIncompatible(c.BerlinBlock, newcfg.BerlinBlock, head) {
- return newCompatError("Berlin fork block", c.BerlinBlock, newcfg.BerlinBlock)
- }
- if isForkIncompatible(c.YoloV3Block, newcfg.YoloV3Block, head) {
- return newCompatError("YOLOv3 fork block", c.YoloV3Block, newcfg.YoloV3Block)
- }
- if isForkIncompatible(c.EWASMBlock, newcfg.EWASMBlock, head) {
- return newCompatError("ewasm fork block", c.EWASMBlock, newcfg.EWASMBlock)
- }
- if c.Istanbul != nil && newcfg.Istanbul != nil && isForkIncompatible(c.Istanbul.Ceil2Nby3Block, newcfg.Istanbul.Ceil2Nby3Block, head) {
- return newCompatError("Ceil 2N/3 fork block", c.Istanbul.Ceil2Nby3Block, newcfg.Istanbul.Ceil2Nby3Block)
- }
- if c.Istanbul != nil && newcfg.Istanbul != nil && isForkIncompatible(c.Istanbul.TestQBFTBlock, newcfg.Istanbul.TestQBFTBlock, head) {
- return newCompatError("Test QBFT fork block", c.Istanbul.TestQBFTBlock, newcfg.Istanbul.TestQBFTBlock)
- }
- if isForkIncompatible(c.QIP714Block, newcfg.QIP714Block, head) {
- return newCompatError("permissions fork block", c.QIP714Block, newcfg.QIP714Block)
- }
- if newcfg.MaxCodeSizeChangeBlock != nil && isForkIncompatible(c.MaxCodeSizeChangeBlock, newcfg.MaxCodeSizeChangeBlock, head) {
- return newCompatError("max code size change fork block", c.MaxCodeSizeChangeBlock, newcfg.MaxCodeSizeChangeBlock)
- }
- if isForkIncompatible(c.PrivacyEnhancementsBlock, newcfg.PrivacyEnhancementsBlock, head) {
- return newCompatError("Privacy Enhancements fork block", c.PrivacyEnhancementsBlock, newcfg.PrivacyEnhancementsBlock)
- }
- if isForkIncompatible(c.PrivacyPrecompileBlock, newcfg.PrivacyPrecompileBlock, head) {
- return newCompatError("Privacy Precompile fork block", c.PrivacyPrecompileBlock, newcfg.PrivacyPrecompileBlock)
- }
- return nil
- }
- // isForkIncompatible returns true if a fork scheduled at s1 cannot be rescheduled to
- // block s2 because head is already past the fork.
- func isForkIncompatible(s1, s2, head *big.Int) bool {
- return (isForked(s1, head) || isForked(s2, head)) && !configNumEqual(s1, s2)
- }
- // isForked returns whether a fork scheduled at block s is active at the given head block.
- func isForked(s, head *big.Int) bool {
- if s == nil || head == nil {
- return false
- }
- return s.Cmp(head) <= 0
- }
- func configNumEqual(x, y *big.Int) bool {
- if x == nil {
- return y == nil
- }
- if y == nil {
- return x == nil
- }
- return x.Cmp(y) == 0
- }
- // ConfigCompatError is raised if the locally-stored blockchain is initialised with a
- // ChainConfig that would alter the past.
- type ConfigCompatError struct {
- What string
- // block numbers of the stored and new configurations
- StoredConfig, NewConfig *big.Int
- // the block number to which the local chain must be rewound to correct the error
- RewindTo uint64
- }
- func newCompatError(what string, storedblock, newblock *big.Int) *ConfigCompatError {
- var rew *big.Int
- switch {
- case storedblock == nil:
- rew = newblock
- case newblock == nil || storedblock.Cmp(newblock) < 0:
- rew = storedblock
- default:
- rew = newblock
- }
- err := &ConfigCompatError{what, storedblock, newblock, 0}
- if rew != nil && rew.Sign() > 0 {
- err.RewindTo = rew.Uint64() - 1
- }
- return err
- }
- func (err *ConfigCompatError) Error() string {
- return fmt.Sprintf("mismatching %s in database (have %d, want %d, rewindto %d)", err.What, err.StoredConfig, err.NewConfig, err.RewindTo)
- }
- // Rules wraps ChainConfig and is merely syntactic sugar or can be used for functions
- // that do not have or require information about the block.
- //
- // Rules is a one time interface meaning that it shouldn't be used in between transition
- // phases.
- type Rules struct {
- ChainID *big.Int
- IsHomestead, IsEIP150, IsEIP155, IsEIP158 bool
- IsByzantium, IsConstantinople, IsPetersburg, IsIstanbul bool
- IsBerlin, IsCatalyst bool
- // Quorum
- IsPrivacyEnhancementsEnabled bool
- IsPrivacyPrecompile bool
- IsGasPriceEnabled bool
- }
- // Rules ensures c's ChainID is not nil.
- func (c *ChainConfig) Rules(num *big.Int) Rules {
- chainID := c.ChainID
- if chainID == nil {
- chainID = new(big.Int)
- }
- return Rules{
- ChainID: new(big.Int).Set(chainID),
- IsHomestead: c.IsHomestead(num),
- IsEIP150: c.IsEIP150(num),
- IsEIP155: c.IsEIP155(num),
- IsEIP158: c.IsEIP158(num),
- IsByzantium: c.IsByzantium(num),
- IsConstantinople: c.IsConstantinople(num),
- IsPetersburg: c.IsPetersburg(num),
- IsIstanbul: c.IsIstanbul(num),
- IsBerlin: c.IsBerlin(num),
- IsCatalyst: c.IsCatalyst(num),
- // Quorum
- IsPrivacyEnhancementsEnabled: c.IsPrivacyEnhancementsEnabled(num),
- IsPrivacyPrecompile: c.IsPrivacyPrecompileEnabled(num),
- IsGasPriceEnabled: c.IsGasPriceEnabled(num),
- }
- }
|