package christie.test.topology.paxos.learner;

import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.test.topology.paxos.Proposal;

import java.util.HashMap;

public class RecieveAcceptProposalCodeGear extends CodeGear{

    @Take
    Proposal acceptedProposal;

    @Take
    HashMap<String, Proposal> acceptedMap;


    @Override
    protected void run(CodeGearManager cgm) {
        System.out.println("accepted : " + acceptedProposal);
        acceptedMap.put(acceptedProposal.getAcceptorName(),
                        acceptedProposal);
        put("acceptedMap", acceptedMap);
        if(acceptedMap.size() > acceptedProposal.getAcceptorNum()/2) cgm.setup(new AggregateProposalCodeGear());
        else cgm.setup(new RecieveAcceptProposalCodeGear());
    }
}