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;

    //@Peek
    HashMap<String, Proposal> acceptedMap;

    public RecieveAcceptProposalCodeGear(HashMap<String, Proposal> acceptedMap){
        this.acceptedMap=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(acceptedMap));
        else
            cgm.setup(new RecieveAcceptProposalCodeGear(acceptedMap));
    }
}