package jp.ac.u_ryukyu.ie.cr.jungleNetwork.logupdate;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.ReceiveData;
import alice.datasegment.Receiver;

import java.util.List;

public class LogupdateFinish extends CodeSegment {
    Receiver finish = ids.create(CommandType.TAKE);
    private Receiver clist = ids.create(CommandType.PEEK);

    LogupdateFinish() {
        finish.setKey("jungleControl");
    }

    @Override
    public void run() {
        int command = finish.asInteger();

        @SuppressWarnings("unchecked")
        List<String> list = clist.asClass(List.class);
        for (String node : list) {//他ノードへlogの書き込み
            if (!node.equals(finish.from))
                ods.put(node, "jungleControl", 1);
        }
        if (command == 1) {
            ods.finish("local");
        }
    }
}