view src/main/java/christie/test/Paxos/ProposerCodeGear.java @ 107:825e01825ad3

update java11
author akahori
date Wed, 31 Oct 2018 11:04:55 +0900
parents b9dd655a54b9
children e1e919f12ed9
line wrap: on
line source

package christie.test.Paxos;


import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.datagear.DataGearManager;
import java.util.concurrent.ConcurrentHashMap;

public class ProposerCodeGear extends CodeGear {

    ConcurrentHashMap<String, DataGearManager> acceptors;

    @Override
    protected void run(CodeGearManager cgm) {

        cgm.setup(new SendPrepareRequestCodeGear());
        //put("acceptors", cgm.getRemoteDgmList());
        put("sendProposal", new Proposal(cgm,cgm.cgmID));
        put("promiseCount", 0);

    }
}