Rename block_producer crate to block_proposer and change references inside it to block_proposer

This commit is contained in:
Feng94 2019-02-19 00:03:35 +11:00
parent a4beb81b83
commit 1bdce182a9
No known key found for this signature in database
GPG Key ID: 023DFB2B75C02282
7 changed files with 7 additions and 7 deletions

View File

@ -1,5 +1,5 @@
[package] [package]
name = "block_producer" name = "block_proposer"
version = "0.1.0" version = "0.1.0"
authors = ["Paul Hauner <paul@paulhauner.com>"] authors = ["Paul Hauner <paul@paulhauner.com>"]
edition = "2018" edition = "2018"

View File

@ -236,7 +236,7 @@ mod tests {
epoch_map.map.insert(produce_epoch, produce_slot); epoch_map.map.insert(produce_epoch, produce_slot);
let epoch_map = Arc::new(epoch_map); let epoch_map = Arc::new(epoch_map);
let mut block_producer = BlockProducer::new( let mut block_proposer = BlockProducer::new(
spec.clone(), spec.clone(),
epoch_map.clone(), epoch_map.clone(),
slot_clock.clone(), slot_clock.clone(),
@ -251,28 +251,28 @@ mod tests {
// One slot before production slot... // One slot before production slot...
slot_clock.set_slot(produce_slot.as_u64() - 1); slot_clock.set_slot(produce_slot.as_u64() - 1);
assert_eq!( assert_eq!(
block_producer.poll(), block_proposer.poll(),
Ok(PollOutcome::BlockProductionNotRequired(produce_slot - 1)) Ok(PollOutcome::BlockProductionNotRequired(produce_slot - 1))
); );
// On the produce slot... // On the produce slot...
slot_clock.set_slot(produce_slot.as_u64()); slot_clock.set_slot(produce_slot.as_u64());
assert_eq!( assert_eq!(
block_producer.poll(), block_proposer.poll(),
Ok(PollOutcome::BlockProduced(produce_slot.into())) Ok(PollOutcome::BlockProduced(produce_slot.into()))
); );
// Trying the same produce slot again... // Trying the same produce slot again...
slot_clock.set_slot(produce_slot.as_u64()); slot_clock.set_slot(produce_slot.as_u64());
assert_eq!( assert_eq!(
block_producer.poll(), block_proposer.poll(),
Ok(PollOutcome::SlotAlreadyProcessed(produce_slot)) Ok(PollOutcome::SlotAlreadyProcessed(produce_slot))
); );
// One slot after the produce slot... // One slot after the produce slot...
slot_clock.set_slot(produce_slot.as_u64() + 1); slot_clock.set_slot(produce_slot.as_u64() + 1);
assert_eq!( assert_eq!(
block_producer.poll(), block_proposer.poll(),
Ok(PollOutcome::BlockProductionNotRequired(produce_slot + 1)) Ok(PollOutcome::BlockProductionNotRequired(produce_slot + 1))
); );
@ -280,7 +280,7 @@ mod tests {
let slot = (produce_epoch.as_u64() + 1) * spec.epoch_length; let slot = (produce_epoch.as_u64() + 1) * spec.epoch_length;
slot_clock.set_slot(slot); slot_clock.set_slot(slot);
assert_eq!( assert_eq!(
block_producer.poll(), block_proposer.poll(),
Ok(PollOutcome::ProducerDutiesUnknown(Slot::new(slot))) Ok(PollOutcome::ProducerDutiesUnknown(Slot::new(slot)))
); );
} }