Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix the wrong 'Identifier' and 'Synchronizer' usage #7252

Merged
merged 5 commits into from
Jun 24, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -41,9 +41,9 @@ public BftEvents.Type getType() {
/**
* Gets round identifier.
*
* @return the round indentifier
* @return the round Identifier
*/
public ConsensusRoundIdentifier getRoundIndentifier() {
public ConsensusRoundIdentifier getRoundIdentifier() {
return roundIdentifier;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ public abstract class BaseBftController implements BftEventHandler {
private final FutureMessageBuffer futureMessageBuffer;
private final Gossiper gossiper;
private final MessageTracker duplicateMessageTracker;
private final SynchronizerUpdater sychronizerUpdater;
private final SynchronizerUpdater synchronizerUpdater;

private final AtomicBoolean started = new AtomicBoolean(false);

Expand All @@ -56,21 +56,21 @@ public abstract class BaseBftController implements BftEventHandler {
* @param gossiper the gossiper
* @param duplicateMessageTracker the duplicate message tracker
* @param futureMessageBuffer the future message buffer
* @param sychronizerUpdater the synchronizer updater
* @param synchronizerUpdater the synchronizer updater
*/
protected BaseBftController(
final Blockchain blockchain,
final BftFinalState bftFinalState,
final Gossiper gossiper,
final MessageTracker duplicateMessageTracker,
final FutureMessageBuffer futureMessageBuffer,
final SynchronizerUpdater sychronizerUpdater) {
final SynchronizerUpdater synchronizerUpdater) {
this.blockchain = blockchain;
this.bftFinalState = bftFinalState;
this.futureMessageBuffer = futureMessageBuffer;
this.gossiper = gossiper;
this.duplicateMessageTracker = duplicateMessageTracker;
this.sychronizerUpdater = sychronizerUpdater;
this.synchronizerUpdater = synchronizerUpdater;
}

@Override
Expand Down Expand Up @@ -162,14 +162,14 @@ public void handleNewBlockEvent(final NewChainHead newChainHead) {

@Override
public void handleBlockTimerExpiry(final BlockTimerExpiry blockTimerExpiry) {
final ConsensusRoundIdentifier roundIndentifier = blockTimerExpiry.getRoundIndentifier();
if (isMsgForCurrentHeight(roundIndentifier)) {
getCurrentHeightManager().handleBlockTimerExpiry(roundIndentifier);
final ConsensusRoundIdentifier roundIdentifier = blockTimerExpiry.getRoundIdentifier();
if (isMsgForCurrentHeight(roundIdentifier)) {
getCurrentHeightManager().handleBlockTimerExpiry(roundIdentifier);
} else {
LOG.trace(
"Block timer event discarded as it is not for current block height chainHeight={} eventHeight={}",
getCurrentHeightManager().getChainHeight(),
roundIndentifier.getSequenceNumber());
roundIdentifier.getSequenceNumber());
}
}

Expand Down Expand Up @@ -221,7 +221,7 @@ private boolean processMessage(final BftMessage<?> msg, final Message rawMsg) {
futureMessageBuffer.addMessage(msgRoundIdentifier.getSequenceNumber(), rawMsg);
// Notify the synchronizer the transmitting peer must have the parent block to the received
// message's target height.
sychronizerUpdater.updatePeerChainState(
synchronizerUpdater.updatePeerChainState(
msgRoundIdentifier.getSequenceNumber() - 1L, rawMsg.getConnection());
} else {
LOG.trace(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ public void aBlockTimerExpiryEventIsAddedToTheQueueOnExpiry() throws Interrupted
assertThat(eventQueue.size()).isEqualTo(1);
final BftEvent queuedEvent = eventQueue.poll(0, TimeUnit.SECONDS);
assertThat(queuedEvent).isInstanceOf(BlockTimerExpiry.class);
assertThat(((BlockTimerExpiry) queuedEvent).getRoundIndentifier())
assertThat(((BlockTimerExpiry) queuedEvent).getRoundIdentifier())
.usingRecursiveComparison()
.isEqualTo(round);
}
Expand Down Expand Up @@ -171,7 +171,7 @@ public void eventIsImmediatelyAddedToTheQueueIfAbsoluteExpiryIsEqualToNow() {
verify(mockQueue).add(bftEventCaptor.capture());

assertThat(bftEventCaptor.getValue() instanceof BlockTimerExpiry).isTrue();
assertThat(((BlockTimerExpiry) bftEventCaptor.getValue()).getRoundIndentifier())
assertThat(((BlockTimerExpiry) bftEventCaptor.getValue()).getRoundIdentifier())
.usingRecursiveComparison()
.isEqualTo(round);
}
Expand Down Expand Up @@ -201,7 +201,7 @@ public void eventIsImmediatelyAddedToTheQueueIfAbsoluteExpiryIsInThePast() {
verify(mockQueue).add(bftEventCaptor.capture());

assertThat(bftEventCaptor.getValue() instanceof BlockTimerExpiry).isTrue();
assertThat(((BlockTimerExpiry) bftEventCaptor.getValue()).getRoundIndentifier())
assertThat(((BlockTimerExpiry) bftEventCaptor.getValue()).getRoundIdentifier())
.usingRecursiveComparison()
.isEqualTo(round);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ public class IbftController extends BaseBftController {
* @param gossiper the gossiper
* @param duplicateMessageTracker the duplicate message tracker
* @param futureMessageBuffer the future message buffer
* @param sychronizerUpdater the synchronizer updater
* @param synchronizerUpdater the synchronizer updater
*/
public IbftController(
final Blockchain blockchain,
Expand All @@ -55,15 +55,15 @@ public IbftController(
final Gossiper gossiper,
final MessageTracker duplicateMessageTracker,
final FutureMessageBuffer futureMessageBuffer,
final SynchronizerUpdater sychronizerUpdater) {
final SynchronizerUpdater synchronizerUpdater) {

super(
blockchain,
bftFinalState,
gossiper,
duplicateMessageTracker,
futureMessageBuffer,
sychronizerUpdater);
synchronizerUpdater);
this.ibftBlockHeightManagerFactory = ibftBlockHeightManagerFactory;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public class QbftController extends BaseBftController {
* @param gossiper the gossiper
* @param duplicateMessageTracker the duplicate message tracker
* @param futureMessageBuffer the future message buffer
* @param sychronizerUpdater the synchronizer updater
* @param synchronizerUpdater the synchronizer updater
* @param bftExtraDataCodec the bft extra data codec
*/
public QbftController(
Expand All @@ -58,7 +58,7 @@ public QbftController(
final Gossiper gossiper,
final MessageTracker duplicateMessageTracker,
final FutureMessageBuffer futureMessageBuffer,
final SynchronizerUpdater sychronizerUpdater,
final SynchronizerUpdater synchronizerUpdater,
final BftExtraDataCodec bftExtraDataCodec) {

super(
Expand All @@ -67,7 +67,7 @@ public QbftController(
gossiper,
duplicateMessageTracker,
futureMessageBuffer,
sychronizerUpdater);
synchronizerUpdater);
this.qbftBlockHeightManagerFactory = qbftBlockHeightManagerFactory;
this.bftExtraDataCodec = bftExtraDataCodec;
}
Expand Down
Loading