public class RankingProposer extends Proposer
Proposer.MaxRetriesException, Proposer.Proposal, Proposer.ProposalParser, Proposer.RetryPredicate, Proposer.WinningProposal
elections, formatter, logger, phase1NoNonZeroPrio
Constructor and Description |
---|
RankingProposer(Elections elections,
NameIdPair nameIdPair) |
Modifier and Type | Method and Description |
---|---|
protected Protocol.Value |
choosePhase2Value(java.util.Set<TextProtocol.MessageExchange> exchanges)
Chooses a Value based on the relative ranking of all Promise responses.
|
Proposer.Proposal |
nextProposal()
Returns a proposal number.
|
getProposerStats, issueProposal, shutDown
public RankingProposer(Elections elections, NameIdPair nameIdPair)
protected Protocol.Value choosePhase2Value(java.util.Set<TextProtocol.MessageExchange> exchanges)
choosePhase2Value
in class Proposer
exchanges
- the message exchanges from Phase 1public Proposer.Proposal nextProposal()
nextProposal
in class Proposer
Copyright (c) 2004-2012 Oracle. All rights reserved.