forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-20 13:44:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

block 1 - all masternodes race to create

Browse source
This commit is contained in:
AnilChinchawale 2018-07-10 16:20:55 +05:30
parent 2a878bb7a7
commit 2fb2d7404d
2 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
consensus/clique/clique.go
View file

@ -47,7 +47,8 @@ const (
inmemorySnapshots = 128 // Number of recent vote snapshots to keep in memory
inmemorySignatures = 4096 // Number of recent block signatures to keep in memory
wiggleTime = 500 * time.Millisecond // Random delay (per signer) to allow concurrent signers
wiggleTime = 500 * time.Millisecond // Random delay (per signer) to allow concurrent signers
genesisCoinBase = "0x0000000000000000000000000000000000000000"
)
// Clique proof-of-authority protocol constants.
@ -384,7 +385,10 @@ func position(list []common.Address, x common.Address) int {
}
func YourTurn(snap *Snapshot, pre, cur common.Address) bool {
return (position(snap.signers(), pre)+1) % len(snap.signers()) == position(snap.signers(), cur)
preIndex := position(snap.signers(), pre)
curIndex := position(snap.signers(), cur)
log.Info("Debugging info", "number of masternodes", len(snap.signers()), "previous", pre, "position", preIndex, "current", cur, "position", curIndex)
return (preIndex+1)%len(snap.signers()) == curIndex || pre.String() == genesisCoinBase
}
// snapshot retrieves the authorization snapshot at a given point in time.
@ -526,7 +530,8 @@ func (c *Clique) verifySeal(chain consensus.ChainReader, header *types.Header, p
// header for running the transactions on top.
func (c *Clique) Prepare(chain consensus.ChainReader, header *types.Header) error {
// If the block isn't a checkpoint, cast a random vote (good enough for now)
header.Coinbase = common.Address{}
//FIXME: keep header.Coinbase == miner's address
//header.Coinbase = common.Address{}
header.Nonce = types.BlockNonce{}
number := header.Number.Uint64()

2
miner/worker.go
View file

@ -409,7 +409,7 @@ func (self *worker) commitNewWork() {
return
}
if !clique.YourTurn(snap, parent.Coinbase(), self.coinbase) {
log.Info("Not our turn to commit block", "wait" , nil)
log.Info("Not our turn to commit block. Wait for next time")
return
}
}