package christie.topology.manager.keepalive;


import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;

public class RemoveTask extends CodeGear {

    @Take
    ListManager _SCHEDULER;

    @Take
    TaskInfo _REMOVETASK;

    public RemoveTask(){
    }

    @Override
    protected void run(CodeGearManager cgm) {
        TaskExecuter exec = TaskExecuter.getInstance();
        if (!exec.compareAndSkip(_REMOVETASK)){
            // case: remove _REMOVETASK is still in the waiting queue.
            boolean removeFlag = _SCHEDULER.deleteTask(_REMOVETASK);
            if (!removeFlag){
                getLocalDGM().put("_REMOVETASK", _REMOVETASK);
                return;
            }
        }
        getLocalDGM().put("_SCHEDULER", _SCHEDULER);
    }
}