Struct blockgen::BlockGenerator

pub struct BlockGenerator {
    pub pow_config: ProofOfWorkConfig,
    pub stratum: RwLock<Option<Stratum>>,
    /* private fields */
}

The interface for a conflux block generator

Fields

pow_config: ProofOfWorkConfig

stratum: RwLock<Option<Stratum>>

Implementations

impl BlockGenerator

pub fn new( graph: SharedSynchronizationGraph, txpool: SharedTransactionPool, sync: SharedSynchronizationService, maybe_txgen: Option<SharedTransactionGenerator>, pow_config: ProofOfWorkConfig, pow: Arc<PowComputer>, mining_author: Address, pos_verifier: Arc<PosVerifier> ) -> Self

pub fn stop(&self)

Stop mining

pub fn send_problem(bg: Arc<BlockGenerator>, problem: ProofOfWorkProblem)

Send new PoW problem to workers

pub fn assemble_new_fixed_block( &self, parent_hash: H256, referee: Vec<H256>, num_txs: usize, difficulty: u64, adaptive: bool, block_gas_target: u64, pos_reference: Option<PosBlockId> ) -> Result<Block, String>

Assemble a new block with specified parent and referee, this is for test only

pub fn assemble_new_block( &self, num_txs: usize, block_size_limit: usize, additional_transactions: Vec<Arc<SignedTransaction>> ) -> Block

Assemble a new block without nonce

pub fn assemble_new_block_with_blame_info( &self, num_txs: usize, block_size_limit: usize, additional_transactions: Vec<Arc<SignedTransaction>>, blame_override: Option<u32>, state_root_override: Option<H256>, receipt_root_override: Option<H256>, logs_bloom_hash_override: Option<H256> ) -> Block

Assemble a new block without nonce and with options to override the states/blame. This function is used for testing only to generate incorrect blocks

pub fn on_mined_block(&self, block: Block)

Update and sync a new block

pub fn is_mining_block_outdated( &self, block: Option<&Block>, last_assemble: &SystemTime ) -> bool

Check if we need to mine on a new block

pub fn generate_fixed_block( &self, parent_hash: H256, referee: Vec<H256>, num_txs: usize, difficulty: u64, adaptive: bool, pos_reference: Option<H256> ) -> Result<H256, String>

pub fn generate_block( &self, num_txs: usize, block_size_limit: usize, additional_transactions: Vec<Arc<SignedTransaction>> ) -> H256

Generate a block with transactions in the pool

pub fn generate_block_with_blame_info( &self, num_txs: usize, block_size_limit: usize, additional_transactions: Vec<Arc<SignedTransaction>>, blame: Option<u32>, state_root: Option<H256>, receipts_root: Option<H256>, logs_bloom_hash: Option<H256> ) -> H256

Generate a block with transactions in the pool. This is used for testing only

pub fn generate_custom_block( &self, transactions: Vec<Arc<SignedTransaction>>, adaptive: Option<bool> ) -> H256

pub fn generate_custom_block_with_parent( &self, parent_hash: H256, referee: Vec<H256>, transactions: Vec<Arc<SignedTransaction>>, adaptive: bool, maybe_custom: Option<Vec<Vec<u8>>> ) -> Result<H256, String>

pub fn generate_block_with_nonce_and_timestamp( &self, parent_hash: H256, referee: Vec<H256>, transactions: Vec<Arc<SignedTransaction>>, nonce: U256, timestamp: u64, adaptive: bool ) -> Result<H256, String>

pub fn pow_config(&self) -> ProofOfWorkConfig

pub fn start_new_worker( num_worker: u32, bg: Arc<BlockGenerator> ) -> Receiver<ProofOfWorkSolution>

Start num_worker new workers

pub fn start_new_stratum_worker( bg: Arc<BlockGenerator> ) -> Receiver<ProofOfWorkSolution>

pub fn start_mining(bg: Arc<BlockGenerator>, _payload_len: u32)

pub fn auto_block_generation(&self, interval_ms: u64)

Trait Implementations

impl Stopable for BlockGenerator

fn stop(&self)