package christie.test.topology.paxos.proposer;

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

import java.util.List;

public class SendPrepareRequestCodeGear extends CodeGear{

    @Take
    Proposal sendProposal;

    @Peek
    TopologyDataGear topoDG;

    @Override
    protected void run(CodeGearManager cgm) {
        List<String> _CLIST = topoDG.getConnectionList();
        for(String acceptorName: _CLIST)
            put(acceptorName, "prepareProposal", sendProposal);

        put("sendedProposal", sendProposal);
        cgm.setup(new ReceivePromiseCodeGear());
    }
}