src/main/java/toy/das/bbc/BbcService.java
/**
     * An inner method that supports speculative BBC (used by WrbSerivce)
     * @param b
     */
An inner method that supports speculative BBC (used by WrbSerivce)
@param b
An inner method that supports speculative BBC ( used by WrbSerivce ) @param b
public void updateFastVote(Types.BbcDecision b) {
            Types.Meta key = Types.Meta.newBuilder()
                    .setChannel(b.getM().getChannel())
                    .setCidSeries(b.getM().getCidSeries())
                    .setCid(b.getM().getCid())
                    .build();
            fastVote.computeIfAbsent(key, k -> {
                fastVotePart fv = new fastVotePart();
                fv.d = b;
                fv.done = false;
                rec.computeIfPresent(key, (k1, v1) -> {
                        logger.debug(String.format("[#%d] #2 re-participating in a das " +
                                "[channel=%d ; cidSeries=%d ; cid=%d]", id, b.getM().getChannel(), b.getM().getCidSeries(), b.getM().getCid()));
                        propose(b.getDecosion(), b.getM().getChannel(), b.getM().getCidSeries(), b.getM().getCid());
                        fv.done = true;
                    return v1;
                });
                return fv;
            });
    }
public void updateFastVote ( Types . BbcDecision b ) { Types . Meta key = Types . Meta . newBuilder ( ) . setChannel ( b . getM ( ) . getChannel ( ) ) . setCidSeries ( b . getM ( ) . getCidSeries ( ) ) . setCid ( b . getM ( ) . getCid ( ) ) . build ( ) ; fastVote . computeIfAbsent ( key , k -> { fastVotePart fv = new fastVotePart ( ) ; fv . d = b ; fv . done = false ; rec . computeIfPresent ( key , ( k1 , v1 ) -> { logger . debug ( String . format ( "[#%d] #2 re-participating in a das " + "[channel=%d ; cidSeries=%d ; cid=%d]" , id , b . getM ( ) . getChannel ( ) , b . getM ( ) . getCidSeries ( ) , b . getM ( ) . getCid ( ) ) ) ; propose ( b . getDecosion ( ) , b . getM ( ) . getChannel ( ) , b . getM ( ) . getCidSeries ( ) , b . getM ( ) . getCid ( ) ) ; fv . done = true ; return v1 ; } ) ; return fv ; } ) ; }
An inner method that supports speculative BBC (used by WrbSerivce)
 @param b
An inner method that supports speculative BBC ( used by WrbSerivce ) @param b