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
use ethereum_types::U256;
use engines::Engine;
use engines::block_reward::{self, RewardKind};
use header::BlockNumber;
use machine::WithRewards;
use parity_machine::{Header, LiveBlock, WithBalances, TotalScoredHeader};
#[derive(Clone, Default)]
pub struct NullEngineParams {
	
	pub block_reward: U256,
}
impl From<::ethjson::spec::NullEngineParams> for NullEngineParams {
	fn from(p: ::ethjson::spec::NullEngineParams) -> Self {
		NullEngineParams {
			block_reward: p.block_reward.map_or_else(Default::default, Into::into),
		}
	}
}
pub struct NullEngine<M> {
	params: NullEngineParams,
	machine: M,
}
impl<M> NullEngine<M> {
	
	pub fn new(params: NullEngineParams, machine: M) -> Self {
		NullEngine {
			params: params,
			machine: machine,
		}
	}
}
impl<M: Default> Default for NullEngine<M> {
	fn default() -> Self {
		Self::new(Default::default(), Default::default())
	}
}
impl<M: WithBalances + WithRewards> Engine<M> for NullEngine<M>
  where M::ExtendedHeader: TotalScoredHeader,
        <M::ExtendedHeader as TotalScoredHeader>::Value: Ord
{
	fn name(&self) -> &str {
		"NullEngine"
	}
	fn machine(&self) -> &M { &self.machine }
	fn on_close_block(&self, block: &mut M::LiveBlock) -> Result<(), M::Error> {
		use std::ops::Shr;
		let author = *LiveBlock::header(&*block).author();
		let number = LiveBlock::header(&*block).number();
		let reward = self.params.block_reward;
		if reward == U256::zero() { return Ok(()) }
		let n_uncles = LiveBlock::uncles(&*block).len();
		let mut rewards = Vec::new();
		
		let result_block_reward = reward + reward.shr(5) * U256::from(n_uncles);
		rewards.push((author, RewardKind::Author, result_block_reward));
		
		for u in LiveBlock::uncles(&*block) {
			let uncle_author = u.author();
			let result_uncle_reward = (reward * U256::from(8 + u.number() - number)).shr(3);
			rewards.push((*uncle_author, RewardKind::Uncle, result_uncle_reward));
		}
		block_reward::apply_block_rewards(&rewards, block, &self.machine)
	}
	fn maximum_uncle_count(&self, _block: BlockNumber) -> usize { 2 }
	fn verify_local_seal(&self, _header: &M::Header) -> Result<(), M::Error> {
		Ok(())
	}
	fn snapshot_components(&self) -> Option<Box<::snapshot::SnapshotComponents>> {
		Some(Box::new(::snapshot::PowSnapshot::new(10000, 10000)))
	}
	fn fork_choice(&self, new: &M::ExtendedHeader, current: &M::ExtendedHeader) -> super::ForkChoice {
		super::total_difficulty_fork_choice(new, current)
	}
}