package jmri.jmrit.logix;

import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;

import java.util.ArrayList;
import java.util.List;
import java.util.ListIterator;

import javax.annotation.concurrent.GuardedBy;
import javax.annotation.CheckForNull;
import javax.annotation.Nonnull;

import jmri.*;
import jmri.implementation.SignalSpeedMap;
import jmri.util.ThreadingUtil;
import jmri.jmrit.logix.ThrottleSetting.Command;
import jmri.jmrit.logix.ThrottleSetting.CommandValue;
import jmri.jmrit.logix.ThrottleSetting.ValueType;
import jmri.util.swing.JmriJOptionPane;

/**
 * A Warrant contains the operating permissions and directives needed for a
 * train to proceed from an Origin to a Destination.
 * There are three modes that a Warrant may execute;
 * <p>
 * MODE_LEARN - Warrant is created or edited in WarrantFrame and then launched
 * from WarrantFrame who records throttle commands from "_student" throttle.
 * Warrant fires PropertyChanges for WarrantFrame to record when blocks are
 * entered. "_engineer" thread is null.
 * <p>
 * MODE_RUN - Warrant may be launched from several places. An array of
 * BlockOrders, _savedOrders, and corresponding _throttleCommands allow an
 * "_engineer" thread to execute the throttle commands. The blockOrders
 * establish the route for the Warrant to acquire and reserve OBlocks. The
 * Warrant monitors block activity (entrances and exits, signals, rogue
 * occupancy etc) and modifies speed as needed.
 * <p>
 * MODE_MANUAL - Warrant may be launched from several places. The Warrant to
 * acquires and reserves the route from the array of BlockOrders. Throttle
 * commands are done by a human operator. "_engineer" and "_throttleCommands"
 * are not used. Warrant monitors block activity but does not set _stoppingBlock
 * or _protectSignal since it cannot control speed. It does attempt to realign
 * the route as needed, but can be thwarted.
 * <p>
 * Version 1.11 - remove setting of SignalHeads
 *
 * @author Pete Cressman Copyright (C) 2009, 2010, 2022
 */
public class Warrant extends jmri.implementation.AbstractNamedBean implements ThrottleListener, java.beans.PropertyChangeListener {

    public static final String Stop = InstanceManager.getDefault(SignalSpeedMap.class).getNamedSpeed(0.0f); // aspect name
    public static final String EStop = Bundle.getMessage("EStop");
    public static final String Normal ="Normal";    // Cannot determine which SignalSystem(s) and their name(s) for "Clear"

    /**
     * String constant for property warrant start.
     */
    public static final String PROPERTY_WARRANT_START = "WarrantStart";

    /**
     * String constant for property stop warrant.
     */
    public static final String PROPERTY_STOP_WARRANT = "StopWarrant";

    /**
     * String constant for property throttle fail.
     */
    public static final String PROPERTY_THROTTLE_FAIL = "throttleFail";

    /**
     * String constant for property abort learn.
     */
    public static final String PROPERTY_ABORT_LEARN = "abortLearn";

    /**
     * String constant for property control change.
     */
    public static final String PROPERTY_CONTROL_CHANGE = "controlChange";

    /**
     * String constant for property control failed.
     */
    public static final String PROPERTY_CONTROL_FAILED = "controlFailed";

    /**
     * String constant for property ready to run.
     */
    public static final String PROPERTY_READY_TO_RUN = "ReadyToRun";

    /**
     * String constant for property cannot run.
     */
    public static final String PROPERTY_CANNOT_RUN = "cannotRun";

    /**
     * String constant for property block change.
     */
    public static final String PROPERTY_BLOCK_CHANGE = "blockChange";

    /**
     * String constant for property signal overrun.
     */
    public static final String PROPERTY_SIGNAL_OVERRUN = "SignalOverrun";

    /**
     * String constant for property warrant overrun.
     */
    public static final String PROPERTY_WARRANT_OVERRUN = "WarrantOverrun";

    /**
     * String constant for property warrant start.
     */
    public static final String PROPERTY_OCCUPY_OVERRUN = "OccupyOverrun";

    /**
     * String constant for running message.
     */
    public static final String PROPERTY_RUNNING_MESSAGE = "RunningMessage";

    // permanent members.
    private List<BlockOrder> _orders;
    private BlockOrder _viaOrder;
    private BlockOrder _avoidOrder;
    private List<ThrottleSetting> _commands = new ArrayList<>();
    protected String _trainName; // User train name for icon
    private SpeedUtil _speedUtil;
    private boolean _runBlind; // Unable to use block detection, must run on et only
    private boolean _shareRoute;// only allocate one block at a time for sharing route.
    private boolean _addTracker;    // start tracker when warrant ends normally.
    private boolean _haltStart;     // Hold train in Origin block until Resume command
    private boolean _noRamp; // do not ramp speed changes. make immediate speed change when entering approach block.
    private boolean _nxWarrant = false;

    // transient members
    private LearnThrottleFrame _student; // need to callback learning throttle in learn mode
    private boolean _tempRunBlind; // run mode flag to allow running on ET only
    private boolean _delayStart; // allows start block unoccupied and wait for train
    private boolean _lost;      // helps recovery if _idxCurrentOrder block goes inactive
    private boolean _overrun;   // train overran a signal or warrant stop
    private boolean _rampBlkOccupied;  // test for overruns when speed change block occupied by another train
    private int _idxCurrentOrder;
    protected volatile int _runMode = MODE_NONE; // volatile: polled by CheckForTermination from its own thread
    private Engineer _engineer; // thread that runs the train
    @GuardedBy("this")
    private CommandDelay _delayCommand; // thread for delayed ramp down
    private boolean _allocated; // initial Blocks of _orders have been allocated
    private boolean _totalAllocated; // All Blocks of _orders have been allocated
    private boolean _routeSet; // all allocated Blocks of _orders have paths set for route
    protected OBlock _stoppingBlock; // Block occupied by rogue train or halted
    private int _idxStoppingBlock;      // BlockOrder index of _stoppingBlock
    private NamedBean _protectSignal; // Signal stopping train movement
    private int _idxProtectSignal;      // BlockOrder index of _protectSignal

    private boolean _waitForSignal; // train may not move until false
    private boolean _waitForBlock; // train may not move until false
    private boolean _waitForWarrant;
    private String _curSignalAspect;   // speed type to restore when flags are cleared;
    protected String _message; // last message returned from an action
    private final ThrottleManager tm;

    // Running modes
    public static final int MODE_NONE = 0;
    public static final int MODE_LEARN = 1; // Record a command list
    public static final int MODE_RUN = 2;   // Autorun, playback the command list
    public static final int MODE_MANUAL = 3; // block detection of manually run train
    static final String[] MODES = {"none", "LearnMode", "RunAuto", "RunManual", "Abort"};
    public static final int MODE_ABORT = 4; // used to set status string in WarrantTableFrame

    // control states
    public static final int STOP = 0;
    public static final int HALT = 1;
    public static final int RESUME = 2;
    public static final int ABORT = 3;
    public static final int RETRY_FWD = 4;
    public static final int ESTOP = 5;
    protected static final int RAMP_HALT = 6;  // used only to distinguish User halt from speed change halts
    public static final int SPEED_UP = 7;
    public static final int RETRY_BKWD = 8;
    public static final int DEBUG = 9;
    static final String[] CNTRL_CMDS = {"Stop", "Halt", "Resume", "Abort", "MoveToNext",
          "EStop", "ramp", "SpeedUp", "MoveToPrevious","Debug"};  // RAMP_HALT is not a control command

    // engineer running states
    protected static final int RUNNING = 7;
    protected static final int SPEED_RESTRICTED = 8;
    protected static final int WAIT_FOR_CLEAR = 9;
    protected static final int WAIT_FOR_SENSOR = 10;
    protected static final int WAIT_FOR_TRAIN = 11;
    protected static final int WAIT_FOR_DELAYED_START = 12;
    protected static final int LEARNING = 13;
    protected static final int STOP_PENDING = 14;
    static final String[] RUN_STATE = {"HaltStart", "atHalt", "Resumed", "Aborts", "Retried",
            "EStop", "HaltPending", "Running", "changeSpeed", "WaitingForClear", "WaitingForSensor",
            "RunningLate", "WaitingForStart", "RecordingScript", "StopPending"};

    static final float BUFFER_DISTANCE = 50*12*25.4F / WarrantPreferences.getDefault().getLayoutScale(); // 50 scale feet for safety distance
    protected static boolean _trace = WarrantPreferences.getDefault().getTrace();

    // Speed states: steady, increasing, decreasing
    static final int AT_SPEED = 1;
    static final int RAMP_DOWN = 2;
    static final int RAMP_UP = 3;
    public enum SpeedState {
        STEADY_SPEED(AT_SPEED, "SteadySpeed"),
        RAMPING_DOWN(RAMP_DOWN, "RampingDown"),
        RAMPING_UP(RAMP_UP, "RampingUp");

        int _speedStateId;  // state id
        String _bundleKey; // key to get state display name

        SpeedState(int id, String bundleName) {
            _speedStateId = id;
            _bundleKey = bundleName;
        }

        public int getIntId() {
            return _speedStateId;
        }

        @Override
        public String toString() {
            return Bundle.getMessage(_bundleKey);
        }
    }

    /**
     * Create an object with no route defined. The list of BlockOrders is the
     * route from an Origin to a Destination
     *
     * @param sName system name
     * @param uName user name
     */
    public Warrant(String sName, String uName) {
        super(sName, uName);
        _idxCurrentOrder = -1;
        _idxProtectSignal = -1;
        _orders = new ArrayList<>();
        _runBlind = false;
        _speedUtil = new SpeedUtil();
        tm = InstanceManager.getNullableDefault(ThrottleManager.class);
    }

    protected void setNXWarrant(boolean set) {
        _nxWarrant = set;
    }
    protected boolean isNXWarrant() {
        return _nxWarrant;
    }

    @Override
    public int getState() {
        if (_engineer != null) {
            return _engineer.getRunState();
        }
        if (_delayStart) {
            return WAIT_FOR_DELAYED_START;
        }
        if (_runMode == MODE_LEARN) {
            return LEARNING;
        }
        if (_runMode != MODE_NONE) {
            return RUNNING;
        }
        return -1;
    }

    @Override
    public void setState(int state) {
        // warrant state is computed from other values
    }

    public SpeedUtil getSpeedUtil() {
        return _speedUtil;
    }

    public void setSpeedUtil(SpeedUtil su) {
        _speedUtil = su;
    }

    /**
     * Return BlockOrders.
     *
     * @return list of block orders
     */
    public List<BlockOrder> getBlockOrders() {
        return _orders;
    }

    /**
     * Add permanently saved BlockOrder.
     *
     * @param order block order
     */
    public void addBlockOrder(BlockOrder order) {
        _orders.add(order);
    }

    public void setBlockOrders(List<BlockOrder> orders) {
        _orders = orders;
    }

    /**
     * Return permanently saved Origin.
     *
     * @return origin block order
     */
    public BlockOrder getfirstOrder() {
        if (_orders.isEmpty()) {
            return null;
        }
        return new BlockOrder(_orders.get(0));
    }

    /**
     * Return permanently saved Destination.
     *
     * @return destination block order
     */
    public BlockOrder getLastOrder() {
        int size = _orders.size();
        if (size < 2) {
            return null;
        }
        return new BlockOrder(_orders.get(size - 1));
    }

    /**
     * Return permanently saved BlockOrder that must be included in the route.
     *
     * @return via block order
     */
    public BlockOrder getViaOrder() {
        if (_viaOrder == null) {
            return null;
        }
        return new BlockOrder(_viaOrder);
    }

    public void setViaOrder(BlockOrder order) {
        _viaOrder = order;
    }

    public BlockOrder getAvoidOrder() {
        if (_avoidOrder == null) {
            return null;
        }
        return new BlockOrder(_avoidOrder);
    }

    public void setAvoidOrder(BlockOrder order) {
        _avoidOrder = order;
    }

    /**
     * @return block order currently at the train position
     */
    public final BlockOrder getCurrentBlockOrder() {
        return getBlockOrderAt(_idxCurrentOrder);
    }

    /**
     * @return index of block order currently at the train position
     */
    public final int getCurrentOrderIndex() {
        return _idxCurrentOrder;
    }

    protected int getNumOrders() {
        return _orders.size();
    }
    /*
     * Used only by SCWarrant
     * SCWarrant overrides goingActive
     */
    protected void incrementCurrentOrderIndex() {
        _idxCurrentOrder++;
    }

    /**
     * Find index of a block AFTER BlockOrder index.
     *
     * @param block used by the warrant
     * @param idx start index of search
     * @return index of block after of block order index, -1 if not found
     */
    protected int getIndexOfBlockAfter(OBlock block, int idx) {
        for (int i = idx; i < _orders.size(); i++) {
            if (_orders.get(i).getBlock().equals(block)) {
                return i;
            }
        }
        return -1;
    }

    /**
     * Find index of block BEFORE BlockOrder index.
     *
     * @param idx start index of search
     * @param block used by the warrant
     * @return index of block before of block order index, -1 if not found
     */
    protected int getIndexOfBlockBefore(int idx, OBlock block) {
        for (int i = idx; i >= 0; i--) {
            if (_orders.get(i).getBlock().equals(block)) {
                return i;
            }
        }
        return -1;
    }

    /**
     * Call is only valid when in MODE_LEARN and MODE_RUN.
     *
     * @param index index of block order
     * @return block order or null if not found
     */
    protected BlockOrder getBlockOrderAt(int index) {
        if (index >= 0 && index < _orders.size()) {
            return _orders.get(index);
        }
        return null;
    }

    /**
     * Call is only valid when in MODE_LEARN and MODE_RUN.
     *
     * @param idx index of block order
     * @return block of the block order
     */
    protected OBlock getBlockAt(int idx) {

        BlockOrder bo = getBlockOrderAt(idx);
        if (bo != null) {
            return bo.getBlock();
        }
        return null;
    }

    /**
     * Call is only valid when in MODE_LEARN and MODE_RUN.
     *
     * @return Name of OBlock currently occupied
     */
    public String getCurrentBlockName() {
        OBlock block = getBlockAt(_idxCurrentOrder);
        if (block == null || !block.isOccupied()) {
            return Bundle.getMessage("Unknown");
        } else {
            return block.getDisplayName();
        }
    }

    /**
     * @return throttle commands
     */
    public List<ThrottleSetting> getThrottleCommands() {
        return _commands;
    }

    public void setThrottleCommands(List<ThrottleSetting> list) {
        _commands = list;
    }

    public void addThrottleCommand(ThrottleSetting ts) {
        if (ts == null) {
            log.error("warrant {} cannot add null ThrottleSetting", getDisplayName());
        } else {
            _commands.add(ts);
        }
    }

    public void setTrackSpeeds() {
        float speed = 0.0f;
        for (ThrottleSetting ts :_commands) {
            CommandValue cmdVal = ts.getValue();
            ValueType valType = cmdVal.getType();
            switch (valType) {
                case VAL_FLOAT:
                    speed = _speedUtil.getTrackSpeed(cmdVal.getFloat());
                    break;
                case VAL_TRUE:
                    _speedUtil.setIsForward(true);
                    break;
                case VAL_FALSE:
                    _speedUtil.setIsForward(false);
                    break;
                default:
            }
            ts.setTrackSpeed(speed);
        }
    }

    public void setNoRamp(boolean set) {
        _noRamp = set;
    }

    public void setShareRoute(boolean set) {
        _shareRoute = set;
    }

    public void setAddTracker (boolean set) {
        _addTracker = set;
    }

    public void setHaltStart (boolean set) {
        _haltStart = set;
    }

    public boolean getNoRamp() {
        return _noRamp;
    }

    public boolean getShareRoute() {
        return _shareRoute;
    }

    public boolean getAddTracker() {
        return _addTracker;
    }

    public boolean getHaltStart() {
        return _haltStart;
    }

    public String getTrainName() {
        return _trainName;
    }

    public void setTrainName(String name) {
        if (_runMode == MODE_NONE) {
            _trainName = name;
        }
    }

    public boolean getRunBlind() {
        return _runBlind;
    }

    public void setRunBlind(boolean runBlind) {
        _runBlind = runBlind;
    }

    /*
     * Engineer reports its status
     */
    protected void fireRunStatus(String property, Object old, Object status) {
//        jmri.util.ThreadingUtil.runOnLayout(() -> {   // Will hang GUI!
        ThreadingUtil.runOnGUIEventually(() -> { // OK but can be quite late in reporting speed changes
            firePropertyChange(property, old, status);
        });
    }

    /**
     * ****************************** state queries ****************
     */
    /**
     * @return true if listeners are installed enough to run
     */
    public boolean isAllocated() {
        return _allocated;
    }

    /**
     * @return true if listeners are installed for entire route
     */
    public boolean isTotalAllocated() {
        return _totalAllocated;
    }

    /**
     * Turnouts are set for the route
     *
     * @return true if turnouts are set
     */
    public boolean hasRouteSet() {
        return _routeSet;
    }

    /**
     * Test if the permanent saved blocks of this warrant are free (unoccupied
     * and unallocated)
     *
     * @return true if route is free
     */
    public boolean routeIsFree() {
        for (int i = 0; i < _orders.size(); i++) {
            OBlock block = _orders.get(i).getBlock();
            if (!block.isFree()) {
                return false;
            }
        }
        return true;
    }

    /**
     * Test if the permanent saved blocks of this warrant are occupied
     *
     * @return true if any block is occupied
     */
    public boolean routeIsOccupied() {
        for (int i = 1; i < _orders.size(); i++) {
            OBlock block = _orders.get(i).getBlock();
            if ((block.getState() & Block.OCCUPIED) != 0) {
                return true;
            }
        }
        return false;
    }

    public String getMessage() {
        return _message;
    }

    /* ************* Methods for running trains *****************/
/*
    protected void setWaitingForSignal(Boolean set) {
        _waitForSignal = set;
    }
    protected void setWaitingForBlock(Boolean set) {
        _waitForBlock = set;
    }
    protected void setWaitingForWarrant(Boolean set) {
        _waitForWarrant = set;
    }
    */
    protected boolean isWaitingForSignal() {
        return _waitForSignal;
    }
    protected boolean isWaitingForBlock() {
        return _waitForBlock;
    }
    protected boolean isWaitingForWarrant() {
        return _waitForWarrant;
    }
    protected Warrant getBlockingWarrant() {
        if (_stoppingBlock != null && !this.equals(_stoppingBlock.getWarrant())) {
            return _stoppingBlock.getWarrant();
        }
        return null;
    }

    /**
      *  @return ID of run mode
     */
    public int getRunMode() {
        return _runMode;
    }

    protected String getRunModeMessage() {
        String modeDesc = null;
        switch (_runMode) {
            case MODE_NONE:
                return Bundle.getMessage("NotRunning", getDisplayName());
            case MODE_LEARN:
                modeDesc = Bundle.getMessage("Recording");
                break;
            case MODE_RUN:
                modeDesc = Bundle.getMessage("AutoRun");
                break;
            case MODE_MANUAL:
                modeDesc = Bundle.getMessage("ManualRun");
                break;
            default:
        }
        return Bundle.getMessage("WarrantInUse", modeDesc, getDisplayName());

    }

    /**
     * Get the warrant speed message for the current throttle speed setting.
     * This is public to provide access for scripts and LogixNG formulas.
     * @return the current speed message or "Not available".
     */
    public String getWarrantSpeedMessage() {
        var msg = Bundle.getMessage("SpeedNotAvailable");
        if (_runMode == Warrant.MODE_RUN && _engineer != null) {
            msg = getSpeedMessage(_engineer.getSpeedType(true));
        }
        return msg;
    }

    /**
     * Get the running message.
     * It's possible to listen to this message by the property {@link #PROPERTY_RUNNING_MESSAGE}.
     * @return the message
     */
    protected final synchronized String getRunningMessage() {
        // Note that this method is final. To override it, you need
        // to override the method getRunningMessagePrim().
        String msg = getRunningMessagePrim();
        firePropertyChange(PROPERTY_RUNNING_MESSAGE, null, msg);
        return msg;
    }

    /**
     * Get the running message.
     * This is a primitive method for the {@link #getRunningMessage()} method.
     * It creates the message so that the method {@link #getRunningMessage()}
     * can notify its listeners about the message.
     * @return the message
     */
    @SuppressWarnings("fallthrough")
    @SuppressFBWarnings(value = "SF_SWITCH_FALLTHROUGH")
    protected synchronized String getRunningMessagePrim() {
        if (_delayStart) {
            return Bundle.getMessage("waitForDelayStart", _trainName, getBlockAt(0).getDisplayName());
        }
        switch (_runMode) {
            case Warrant.MODE_NONE:
                _message = null;
            case Warrant.MODE_ABORT:
                if (getBlockOrders().isEmpty()) {
                    return Bundle.getMessage("BlankWarrant");
                }
                if (_speedUtil.getAddress() == null) {
                    return Bundle.getMessage("NoLoco");
                }
                if (!(this instanceof SCWarrant) && _commands.size() <= _orders.size()) {
                    return Bundle.getMessage("NoCommands", getDisplayName());
                }
                if (_message != null) {
                    if (_lost) {
                        return Bundle.getMessage("locationUnknown", _trainName, getCurrentBlockName()) + _message;
                    } else {
                        return Bundle.getMessage("Idle", _message);
                    }
                 }
                return Bundle.getMessage("Idle");
            case Warrant.MODE_LEARN:
                return Bundle.getMessage("Learning", getCurrentBlockName());
            case Warrant.MODE_RUN:
                if (_engineer == null) {
                    return Bundle.getMessage("engineerGone", getCurrentBlockName());
                }
                String speedMsg = getSpeedMessage(_engineer.getSpeedType(true)); // current or pending
                int runState = _engineer.getRunState();

                int cmdIdx = _engineer.getCurrentCommandIndex();
                if (cmdIdx >= _commands.size()) {
                    cmdIdx = _commands.size() - 1;
                }
                cmdIdx++;   // display is 1-based
                OBlock block = getBlockAt(_idxCurrentOrder);
                if ((block.getState() & (Block.OCCUPIED | Block.UNDETECTED)) == 0) {
                    return Bundle.getMessage("TrackerNoCurrentBlock", _trainName, block.getDisplayName());
                }
                String blockName = block.getDisplayName();

                switch (runState) {
                    case Warrant.ABORT:
                        if (cmdIdx == _commands.size() - 1) {
                            return Bundle.getMessage("endOfScript", _trainName);
                        }
                        return Bundle.getMessage("Aborted", blockName, cmdIdx);

                    case Warrant.HALT:
                        return Bundle.getMessage("RampHalt", getTrainName(), blockName);
                    case Warrant.WAIT_FOR_CLEAR:
                        SpeedState ss = _engineer.getSpeedState();
                        if (ss.equals(SpeedState.STEADY_SPEED)) {
                            return  makeWaitMessage(blockName, cmdIdx);
                        } else {
                            return Bundle.getMessage("Ramping", ss.toString(), speedMsg, blockName);
                        }
                    case Warrant.WAIT_FOR_TRAIN:
                        if (_engineer.getSpeedSetting() <= 0) {
                            return makeWaitMessage(blockName, cmdIdx);
                        } else {
                            return Bundle.getMessage("WaitForTrain", cmdIdx,
                                    _engineer.getSynchBlock().getDisplayName(), speedMsg);
                        }
                    case Warrant.WAIT_FOR_SENSOR:
                        return Bundle.getMessage("WaitForSensor",
                                cmdIdx, _engineer.getWaitSensor().getDisplayName(),
                                blockName, speedMsg);

                    case Warrant.RUNNING:
                        return Bundle.getMessage("WhereRunning", blockName, cmdIdx, speedMsg);
                    case Warrant.SPEED_RESTRICTED:
                        return Bundle.getMessage("changeSpeed", blockName, cmdIdx, speedMsg);

                    case Warrant.RAMP_HALT:
                        return Bundle.getMessage("HaltPending", speedMsg, blockName);

                    case Warrant.STOP_PENDING:
                        return Bundle.getMessage("StopPending", speedMsg, blockName, (_waitForSignal
                                ? Bundle.getMessage("Signal") : (_waitForWarrant
                                        ? Bundle.getMessage("Warrant") :Bundle.getMessage("Occupancy"))));

                    default:
                        return _message;
                }

            case Warrant.MODE_MANUAL:
                BlockOrder bo = getCurrentBlockOrder();
                if (bo != null) {
                    return Bundle.getMessage("ManualRunning", bo.getBlock().getDisplayName());
                }
                return Bundle.getMessage("ManualRun");

            default:
        }
        return "ERROR mode= " + MODES[_runMode];
    }

    /**
     * Calculates the scale speed of the current throttle setting for display
     * @param speedType name of current speed
     * @return text message
     */
    private String getSpeedMessage(String speedType) {
        float speed = 0;
        String units;
        SignalSpeedMap speedMap = InstanceManager.getDefault(SignalSpeedMap.class);
        switch (speedMap.getInterpretation()) {
            case SignalSpeedMap.PERCENT_NORMAL:
                speed = _engineer.getSpeedSetting() * 100;
                float scriptSpeed = _engineer.getScriptSpeed();
                scriptSpeed = (scriptSpeed > 0 ? (speed/scriptSpeed) : 0);
                units = Bundle.getMessage("percentNormalScript", Math.round(scriptSpeed));
                break;
            case SignalSpeedMap.PERCENT_THROTTLE:
                units = Bundle.getMessage("percentThrottle");
                speed = _engineer.getSpeedSetting() * 100;
                break;
            case SignalSpeedMap.SPEED_MPH:
                units = Bundle.getMessage("mph");
                speed = _speedUtil.getTrackSpeed(_engineer.getSpeedSetting()) * speedMap.getLayoutScale();
                speed *= 2.2369363f;
                break;
            case SignalSpeedMap.SPEED_KMPH:
                units = Bundle.getMessage("kph");
                speed = _speedUtil.getTrackSpeed(_engineer.getSpeedSetting()) * speedMap.getLayoutScale();
                speed *= 3.6f;
                break;
            default:
                log.error("{} Unknown speed interpretation {}", getDisplayName(), speedMap.getInterpretation());
                throw new java.lang.IllegalArgumentException("Unknown speed interpretation " + speedMap.getInterpretation());
        }
        return Bundle.getMessage("atSpeed", speedType, Math.round(speed), units);
    }

    private String makeWaitMessage(String blockName, int cmdIdx) {
        String which = null;
        String where = null;
        if (_waitForSignal) {
            which = Bundle.getMessage("Signal");
            OBlock protectedBlock = getBlockAt(_idxProtectSignal);
            if (protectedBlock != null) {
                where = protectedBlock.getDisplayName();
            }
        } else if (_waitForWarrant) {
            Warrant w = getBlockingWarrant();
            which = Bundle.getMessage("WarrantWait",
                w==null ? "Unknown" : w.getDisplayName());
            if (_stoppingBlock != null) {
                where = _stoppingBlock.getDisplayName();
            }
        } else if (_waitForBlock) {
            which = Bundle.getMessage("Occupancy");
            if (_stoppingBlock != null) {
                where = _stoppingBlock.getDisplayName();
            }
        }
        int runState = _engineer.getRunState();
        if (which == null && (runState == HALT || runState == RAMP_HALT)) {
            which = Bundle.getMessage("Halt");
            where = blockName;
        }
        if (_engineer.isRamping() && runState != RAMP_HALT) {
            String speedMsg = getSpeedMessage(_engineer.getSpeedType(true));
            return Bundle.getMessage("changeSpeed", blockName, cmdIdx, speedMsg);
        }

        if (where == null) {
            // flags can't identify cause.
            if (_message == null) {
                _message = Bundle.getMessage(RUN_STATE[runState], blockName);
            }
            return Bundle.getMessage("trainWaiting", getTrainName(), _message, blockName);
        }
        return Bundle.getMessage("WaitForClear", blockName, which, where);
    }

    @InvokeOnLayoutThread
    private void startTracker() {
        ThreadingUtil.runOnGUIEventually(() -> {
            new Tracker(getCurrentBlockOrder().getBlock(), _trainName,
                    null, InstanceManager.getDefault(TrackerTableAction.class));
        });
    }

    // Get engineer thread to TERMINATED state - didn't answer CI test problem, but let it be.
    private void killEngineer(Engineer engineer, boolean abort, boolean functionFlag) {
        engineer.stopRun(abort, functionFlag); // releases throttle
        engineer.interrupt();
        if (!engineer.getState().equals(Thread.State.TERMINATED)) {
            Thread curThread = Thread.currentThread();
            if (!curThread.equals(_engineer)) {
                kill( engineer, abort, functionFlag);
            } else {   // can't join yourself if called by _engineer
                class Killer implements Runnable {
                    Engineer victim;
                    boolean abortFlag;
                    boolean functionFlag;
                    Killer (Engineer v, boolean a, boolean f) {
                        victim = v;
                        abortFlag = a;
                        functionFlag = f;
                    }
                    @Override
                    public void run() {
                        kill(victim, abortFlag, functionFlag);
                    }
                }
                final Runnable killer = new Killer(engineer, abort, functionFlag);
                synchronized (killer) {
                    Thread hit = ThreadingUtil.newThread(killer,
                            getDisplayName()+" Killer");
                    hit.start();
                }
            }
        }
    }

    private void kill(Engineer eng, boolean a, boolean f) {
        long time = 0;
        while (!eng.getState().equals(Thread.State.TERMINATED) && time < 100) {
            try {
                eng.stopRun(a, f); // releases throttle
                eng.join(10);
            } catch (InterruptedException ex) {
                log.info("victim.join() interrupted. warrant {}", getDisplayName());
            }
            time += 10;
        }
        _engineer = null;
        log.debug("{}: engineer state {} after {}ms", getDisplayName(), eng.getState().toString(), time);
    }

    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    public void stopWarrant(boolean abort, boolean turnOffFunctions) {
        _delayStart = false;
        clearWaitFlags(true);
        if (_student != null) {
            _student.dispose(); // releases throttle
            _student = null;
        }
        _curSignalAspect = null;
        cancelDelayRamp();

        if (_engineer != null) {
            if (!_engineer.getState().equals(Thread.State.TERMINATED)) {
                killEngineer(_engineer, abort, turnOffFunctions);
            }
            if (_trace || log.isDebugEnabled()) {
                if (abort) {
                    log.info("{} at block {}", Bundle.getMessage("warrantAbort", getTrainName(), getDisplayName()),
                            getBlockAt(_idxCurrentOrder).getDisplayName());
                } else {
                    log.info(Bundle.getMessage("warrantComplete",
                            getTrainName(), getDisplayName(), getBlockAt(_idxCurrentOrder).getDisplayName()));
                }
            }
        } else {
            _runMode = MODE_NONE;
        }

        if (_addTracker && _idxCurrentOrder == _orders.size()-1) { // run was complete to end
            startTracker();
        }
        _addTracker = false;

        // capture before runOnGUI — deAllocate is async; CheckForTermination may reset _idxCurrentOrder on the GUI thread
        final int capturedIdx = _idxCurrentOrder;
        final String capturedBlockName = abort ? null : getCurrentBlockName();

        // insulate possible non-GUI thread making this call (e.g. Engineer)
        ThreadingUtil.runOnGUI(this::deAllocate);

        String bundleKey;
        if (abort) {
            bundleKey = capturedIdx <= 0 ? "warrantAnnull" : "warrantAbort";
        } else {
            bundleKey = (capturedIdx == _orders.size() - 1) ? "warrantComplete" : "warrantEnd";
        }
        fireRunStatus(PROPERTY_STOP_WARRANT, capturedBlockName, bundleKey);
    }

    /**
     * Sets up recording and playing back throttle commands - also cleans up
     * afterwards. MODE_LEARN and MODE_RUN sessions must end by calling again
     * with MODE_NONE. It is important that the route be deAllocated (remove
     * listeners).
     * <p>
     * Rule for (auto) MODE_RUN: 1. At least the Origin block must be owned
     * (allocated) by this warrant. (block._warrant == this) and path set for
     * Run Mode Rule for (auto) LEARN_RUN: 2. Entire Route must be allocated and
     * Route Set for Learn Mode. i.e. this warrant has listeners on all block
     * sensors in the route. Rule for MODE_MANUAL The Origin block must be
     * allocated to this warrant and path set for the route
     *
     * @param mode run mode
     * @param address DCC loco address
     * @param student throttle frame for learn mode parameters
     * @param commands list of throttle commands
     * @param runBlind true if occupancy should be ignored
     * @return error message, if any
     */
    public String setRunMode(int mode, DccLocoAddress address,
            LearnThrottleFrame student,
            List<ThrottleSetting> commands, boolean runBlind) {
        if (log.isDebugEnabled()) {
            log.debug("{}: setRunMode({}) ({}) called with _runMode= {}.",
                  getDisplayName(), mode, MODES[mode], MODES[_runMode]);
        }
        _message = null;
        if (_runMode != MODE_NONE) {
            _message = getRunModeMessage();
            log.error("{} called setRunMode when mode= {}. {}", getDisplayName(), MODES[_runMode],  _message);
            return _message;
        }
        _delayStart = false;
        _lost = false;
        _overrun = false;
        clearWaitFlags(true);
        if (address != null) {
            _speedUtil.setDccAddress(address);
        }
        _message = setPathAt(0);
        if (_message != null) {
            return _message;
        }

        if (mode == MODE_LEARN) {
            // Cannot record if block 0 is not occupied or not dark. If dark, user is responsible for occupation
            if (student == null) {
                _message = Bundle.getMessage("noLearnThrottle", getDisplayName());
                log.error("{} called setRunMode for mode= {}. {}", getDisplayName(), MODES[mode],  _message);
                return _message;
            }
            synchronized (this) {
                _student = student;
            }
            // set mode before notifyThrottleFound is called
            _runMode = mode;
        } else if (mode == MODE_RUN) {
            if (commands != null && commands.size() > 1) {
                _commands = commands;
            }
            // set mode before setStoppingBlock and callback to notifyThrottleFound are called
            _idxCurrentOrder = 0;
            _runMode = mode;
            OBlock b = getBlockAt(0);
            if (b.isDark()) {
                _haltStart = true;
            } else if (!b.isOccupied()) {
                // continuing with no occupation of starting block
                _idxCurrentOrder = -1;
                setStoppingBlock(0);
                _delayStart = true;
            }
        } else if (mode == MODE_MANUAL) {
            if (commands != null) {
                _commands = commands;
            }
        } else {
            deAllocate();
            return _message;
        }
        getBlockAt(0)._entryTime = System.currentTimeMillis();
        _tempRunBlind = runBlind;
        if (!_delayStart) {
            if (mode != MODE_MANUAL) {
                _message = acquireThrottle();
            } else {
                startupWarrant(); // assuming manual operator will go to start block
            }
        }
        return _message;
    } // end setRunMode

    /////////////// start warrant run - end of create/edit/setup methods //////////////////

    /**
     * @return error message if any
     */
    @CheckForNull
    protected String acquireThrottle() {
        String msg = null;
        DccLocoAddress dccAddress = _speedUtil.getDccAddress();
        if (log.isDebugEnabled()) {
            log.debug("{}: acquireThrottle request at {}",
                    getDisplayName(), dccAddress);
        }
        if (dccAddress == null) {
            msg = Bundle.getMessage("NoAddress", getDisplayName());
        } else {
            if (tm == null) {
                msg = Bundle.getMessage("noThrottle", _speedUtil.getDccAddress().getNumber());
            } else {
                if (!tm.requestThrottle(dccAddress, this, false)) {
                    msg = Bundle.getMessage("trainInUse", dccAddress.getNumber());
                }
            }
        }
        if (msg != null) {
            fireRunStatus(PROPERTY_THROTTLE_FAIL, null, msg);
            abortWarrant(msg);
            return msg;
        }
        return null;
    }

    @Override
    public void notifyThrottleFound(DccThrottle throttle) {
        if (throttle == null) {
            _message = Bundle.getMessage("noThrottle", getDisplayName());
            fireRunStatus(PROPERTY_THROTTLE_FAIL, null, _message);
            abortWarrant(_message);
            return;
        }
        if (log.isDebugEnabled()) {
            log.debug("{}: notifyThrottleFound for address= {}, class= {},",
                  getDisplayName(), throttle.getLocoAddress(), throttle.getClass().getName());
        }
        _speedUtil.setThrottle(throttle);
        startupWarrant();
        runWarrant(throttle);
    } //end notifyThrottleFound

    @Override
    public void notifyFailedThrottleRequest(LocoAddress address, String reason) {
        _message = Bundle.getMessage("noThrottle",
                (reason + " " + (address != null ? address.getNumber() : getDisplayName())));
        fireRunStatus(PROPERTY_THROTTLE_FAIL, null, reason);
        abortWarrant(_message);
    }

    /**
     * No steal or share decisions made locally
     * <p>
     * {@inheritDoc}
     */
    @Override
    public void notifyDecisionRequired(LocoAddress address, DecisionType question) {
    }

    protected void releaseThrottle(DccThrottle throttle) {
        if (throttle != null) {
            if (tm != null) {
                tm.releaseThrottle(throttle, this);
            } else {
                log.error("{} releaseThrottle. {} on thread {}",
                        getDisplayName(), Bundle.getMessage("noThrottle", throttle.getLocoAddress()),
                        Thread.currentThread().getName());
            }
            _runMode = MODE_NONE;
        }
    }

    protected void abortWarrant(String msg) {
        log.error("Abort warrant \"{}\" - {} ", getDisplayName(), msg);
        stopWarrant(true, true);
    }

    /**
     * Pause and resume auto-running train or abort any allocation state User
     * issued overriding commands during run time of warrant _engineer.abort()
     * calls setRunMode(MODE_NONE,...) which calls deallocate all.
     *
     * @param idx index of control command
     * @return false if command cannot be given
     */
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    public boolean controlRunTrain(int idx) {
        if (idx < 0) {
            return false;
        }
        boolean ret = false;
        if (_engineer == null) {
            if (log.isDebugEnabled()) {
                log.debug("{}: controlRunTrain({})= \"{}\" for train {} runMode= {}",
                      getDisplayName(), idx, CNTRL_CMDS[idx], getTrainName(), MODES[_runMode]);
            }
            switch (idx) {
                case HALT:
                case RESUME:
                case RETRY_FWD:
                case RETRY_BKWD:
                case SPEED_UP:
                    break;
                case STOP:
                case ABORT:
                    if (_runMode == Warrant.MODE_LEARN) {
                        // let WarrantFrame do the abort. (WarrantFrame listens for "abortLearn")
                        fireRunStatus(PROPERTY_ABORT_LEARN, -MODE_LEARN, _idxCurrentOrder);
                    } else {
                        stopWarrant(true, true);
                    }
                    break;
                case DEBUG:
                    debugInfo();
                    break;
                default:
            }
            return true;
        }
        int runState = _engineer.getRunState();
        if (_trace || log.isDebugEnabled()) {
            log.info(Bundle.getMessage("controlChange",
                    getTrainName(), Bundle.getMessage(Warrant.CNTRL_CMDS[idx]),
                    getCurrentBlockName()));
        }
        synchronized (this) {
            switch (idx) {
                case HALT:
                    rampSpeedTo(Warrant.Stop, -1);  // ramp down
                    _engineer.setHalt(true);
                    ret = true;
                    break;
                case RESUME:
                    BlockOrder bo = getBlockOrderAt(_idxCurrentOrder);
                    OBlock block = bo.getBlock();
                    String msg = null;
                    if (checkBlockForRunning(_idxCurrentOrder)) {
                        if (_waitForSignal || _waitForBlock || _waitForWarrant) {
                            msg = makeWaitMessage(block.getDisplayName(), _idxCurrentOrder);
                        } else {
                            if (runState == WAIT_FOR_CLEAR) {
                                TrainOrder to = bo.allocatePaths(this, true);
                                if (to._cause == null) {
                                       _engineer.setWaitforClear(false);
                                } else {
                                    msg = to._message;
                                }
                            }
                            String train = (String)block.getValue();
                            if (train == null) {
                                train = Bundle.getMessage("unknownTrain");
                            }
                            if (block.isOccupied() && !_trainName.equals(train)) {
                                msg = Bundle.getMessage("blockInUse", train, block.getDisplayName());
                            }
                        }
                    }
                    if (msg != null) {
                        ret = askResumeQuestion(block, msg);
                        if (ret) {
                            ret = reStartTrain();
                        }
                    } else {
                        ret = reStartTrain();
                    }
                    if (!ret) {
//                        _engineer.setHalt(true);
                        if (_message.equals(Bundle.getMessage("blockUnoccupied", block.getDisplayName()))) {
                            ret = askResumeQuestion(block, _message);
                            if (ret) {
                                ret = reStartTrain();
                            }
                        }
                    }
                    break;
                case SPEED_UP:
                    // user wants to increase throttle of stalled train slowly
                    if (checkBlockForRunning(_idxCurrentOrder)) {
                        if ((_waitForSignal || _waitForBlock || _waitForWarrant) ||
                                (runState != RUNNING && runState != SPEED_RESTRICTED)) {
                            block = getBlockAt(_idxCurrentOrder);
                            msg = makeWaitMessage(block.getDisplayName(), _idxCurrentOrder);
                            ret = askResumeQuestion(block, msg);
                            if (ret) {
                                ret = bumpSpeed();
                            }
                        } else {
                            ret = bumpSpeed();
                        }
                    }
                    break;
                case RETRY_FWD: // Force move into next block
                    if (checkBlockForRunning(_idxCurrentOrder + 1)) {
                        bo = getBlockOrderAt(_idxCurrentOrder + 1);
                        block = bo.getBlock();
                        if ((_waitForSignal || _waitForBlock || _waitForWarrant) ||
                                (runState != RUNNING && runState != SPEED_RESTRICTED)) {
                            msg = makeWaitMessage(block.getDisplayName(), _idxCurrentOrder);
                            ret = askResumeQuestion(block, msg);
                            if (ret) {
                                ret = moveToBlock(bo, _idxCurrentOrder + 1);
                            }
                        } else {
                            ret = moveToBlock(bo, _idxCurrentOrder + 1);
                        }
                    }
                    break;
                case RETRY_BKWD: // Force move into previous block - Not enabled.
                    if (checkBlockForRunning(_idxCurrentOrder - 1)) {
                        bo = getBlockOrderAt(_idxCurrentOrder - 1);
                        block = bo.getBlock();
                        if ((_waitForSignal || _waitForBlock || _waitForWarrant) ||
                                (runState != RUNNING && runState != SPEED_RESTRICTED)) {
                            msg = makeWaitMessage(block.getDisplayName(), _idxCurrentOrder);
                            ret = askResumeQuestion(block, msg);
                            if (ret) {
                                ret = moveToBlock(bo, _idxCurrentOrder - 1);
                            }
                        } else {
                            ret = moveToBlock(bo, _idxCurrentOrder - 1);
                        }
                    }
                    break;
                case ABORT:
                    stopWarrant(true, true);
                    ret = true;
                    break;
//                case HALT:
                case STOP:
                    setSpeedToType(Stop); // sets _halt
                    _engineer.setHalt(true);
                    ret = true;
                    break;
                case ESTOP:
                    setSpeedToType(EStop); // E-stop & halt
                    _engineer.setHalt(true);
                    ret = true;
                    break;
                case DEBUG:
                    ret = debugInfo();
                    break;
                default:
            }
        }
        if (ret) {
            fireRunStatus(PROPERTY_CONTROL_CHANGE, runState, idx);
        } else {
            if (_trace || log.isDebugEnabled()) {
                log.info(Bundle.getMessage("controlFailed",
                        getTrainName(), _message,
                        Bundle.getMessage(Warrant.CNTRL_CMDS[idx])));
            }
            fireRunStatus(PROPERTY_CONTROL_FAILED, _message, idx);
        }
        return ret;
    }

    private boolean askResumeQuestion(OBlock block, String reason) {
        String msg = Bundle.getMessage("ResumeQuestion", reason);
        return ThreadingUtil.runOnGUIwithReturn(() -> {
            int result = JmriJOptionPane.showConfirmDialog(WarrantTableFrame.getDefault(),
                msg, Bundle.getMessage("ResumeTitle"),
                JmriJOptionPane.YES_NO_OPTION, JmriJOptionPane.QUESTION_MESSAGE);
            return result==JmriJOptionPane.YES_OPTION;
        });
    }

    // User insists to run train
    private boolean reStartTrain() {
        BlockOrder bo = getBlockOrderAt(_idxCurrentOrder);
        OBlock block = bo.getBlock();
        if (!block.isOccupied() && !block.isDark()) {
            _message = Bundle.getMessage("blockUnoccupied", block.getDisplayName());
            return false;
        }
        // OK, will do it as it long as you own it, and you are where you think you are there.
        block.setValue(_trainName); // indicate position
        block.setState(block.getState());
        _engineer.setHalt(false);
        _engineer.releaseSensorWait();
        clearWaitFlags(false);
        _overrun = true;    // allows doRestoreRunning to run at an OCCUPY state
        return restoreRunning(_engineer.getSpeedType(false));
    }

    // returns true if block is owned and occupied by this warrant
    private boolean checkBlockForRunning(int idxBlockOrder) {
        BlockOrder bo = getBlockOrderAt(idxBlockOrder);
        if (bo == null) {
            _message = Bundle.getMessage("BlockNotInRoute", "?");
            return false;
        }
        OBlock block = bo.getBlock();
        if (!block.isOccupied()) {
            _message = Bundle.getMessage("blockUnoccupied", block.getDisplayName());
            return false;
        }
        return true;
    }

    // User increases speed
    private boolean bumpSpeed() {
        // OK, will do as it long as you own it, and you are where you think you are.
        _engineer.setHalt(false);
        _engineer.releaseSensorWait();
        clearWaitFlags(false);
        float speedSetting = _engineer.getSpeedSetting();
        if (speedSetting < 0) { // may have done E-Stop
            speedSetting = 0.0f;
        }
        float bumpSpeed = Math.max(WarrantPreferences.getDefault().getSpeedAssistance(), _speedUtil.getRampThrottleIncrement());
        _engineer.setSpeed(speedSetting + bumpSpeed);
        return true;
    }

    private boolean moveToBlock(BlockOrder bo, int idx) {
        _idxCurrentOrder = idx;
        _message = setPathAt(idx);    // no checks. Force path set and allocation
        if (_message != null) {
            return false;
        }
        OBlock block = bo.getBlock();
        if (block.equals(_stoppingBlock)) {
            clearStoppingBlock();
            _engineer.setHalt(false);
            _engineer.releaseSensorWait();
        }
        goingActive(block);
        return true;
    }

    protected boolean debugInfo() {
        if ( !log.isInfoEnabled() ) {
            return true;
        }
        StringBuilder info = new StringBuilder("\""); info.append(getDisplayName());
        info.append("\" Train \""); info.append(getTrainName()); info.append("\" - Current Block \"");
        info.append(getBlockAt(_idxCurrentOrder).getDisplayName());
        info.append("\" BlockOrder idx= "); info.append(_idxCurrentOrder);
        info.append("\n\tWait flags: _waitForSignal= "); info.append(_waitForSignal);
        info.append(", _waitForBlock= "); info.append(_waitForBlock);
        info.append(", _waitForWarrant= "); info.append(_waitForWarrant);
        info.append("\n\tStatus flags: _overrun= "); info.append(_overrun); info.append(", _rampBlkOccupied= ");
        info.append(_rampBlkOccupied);info.append(", _lost= "); info.append(_lost);
        if (_protectSignal != null) {
            info.append("\n\tWait for Signal \"");info.append(_protectSignal.getDisplayName());info.append("\" protects block ");
            info.append(getBlockAt(_idxProtectSignal).getDisplayName()); info.append("\" from approch block \"");
            info.append(getBlockAt(_idxProtectSignal - 1).getDisplayName()); info.append("\". Shows aspect \"");
            info.append(getSignalSpeedType(_protectSignal)); info.append("\".");
        } else {
            info.append("\n\tNo signals ahead with speed restrictions");
        }
        if(_stoppingBlock != null) {
            if (_waitForWarrant) {
                info.append("\n\tWait for Warrant \"");
                Warrant w = getBlockingWarrant(); info.append((w != null?w.getDisplayName():"Unknown"));
                info.append("\" owns block \"");info.append(_stoppingBlock.getDisplayName()); info.append("\"");
            } else {
                Object what = _stoppingBlock.getValue();
                String who;
                if (what != null) {
                    who = what.toString();
                } else {
                    who = "Unknown Train";
                }
                info.append("\n\tWait for \""); info.append(who); info.append("\" occupying Block \"");
                info.append(_stoppingBlock.getDisplayName()); info.append("\"");
            }
        } else {
            info.append("\n\tNo occupied blocks ahead");
        }
        if (_message != null) {
            info.append("\n\tLast message = ");info.append(_message);
        } else {
            info.append("\n\tNo messages.");
        }

        if (_engineer != null) {
            info.append("\""); info.append("\n\tEngineer Stack trace:");
            for (StackTraceElement elem : _engineer.getStackTrace()) {
                info.append("\n\t\t");
                info.append(elem.getClassName()); info.append("."); info.append(elem.getMethodName());
                info.append(", line "); info.append(elem.getLineNumber());
            }
            info.append(_engineer.debugInfo());
         } else {
            info.append("No engineer.");
        }
        log.info("\n Warrant: {}", info.toString());
        return true;
    }

    protected void startupWarrant() {
        _idxCurrentOrder = 0;
        // set block state to show our train occupies the block
        BlockOrder bo = getBlockOrderAt(0);
        OBlock b = bo.getBlock();
        b.setValue(_trainName);
        b.setState(b.getState() | OBlock.RUNNING);
        firePropertyChange(PROPERTY_WARRANT_START, MODE_NONE, _runMode);
    }

    private void runWarrant(DccThrottle throttle) {
        if (_runMode == MODE_LEARN) {
            synchronized (this) {
                // No Engineer. LearnControlPanel does throttle settings
                _student.notifyThrottleFound(throttle);
            }
        } else {
            if (_engineer != null) {    // should not happen
                killEngineer(_engineer, true, true);
            }
            _engineer = new Engineer(this, throttle);

            _speedUtil.getBlockSpeedTimes(_commands, _orders);   // initialize SpeedUtil
            if (_tempRunBlind) {
                _engineer.setRunOnET(true);
            }
            if (_delayStart || _haltStart) {
                _engineer.setHalt(true);    // throttle already at 0
                // user must explicitly start train (resume) in a dark block
                fireRunStatus(PROPERTY_READY_TO_RUN, -1, 0);   // ready to start msg
            }
            _delayStart = false;
            _engineer.start();

            int runState = _engineer.getRunState();
            if (_trace || log.isDebugEnabled()) {
                log.info("Train \"{}\" on warrant \"{}\" launched. runState= {}", getTrainName(), getDisplayName(), RUN_STATE[runState]);
            }
            if (runState != HALT && runState != RAMP_HALT) {
                setMovement();
            }
        }
    }

    private String setPathAt(int idx) {
        BlockOrder bo = _orders.get(idx);
        OBlock b = bo.getBlock();
        String msg = b.allocate(this);
        if (msg == null) {
            OPath path1 = bo.getPath();
            Portal exit = bo.getExitPortal();
            OBlock block = getBlockAt(idx+1);
            if (block != null) {
                Warrant w = block.getWarrant();
                if ((w != null && !w.equals(this)) || (w == null && block.isOccupied())) {
                    msg =  bo.pathsConnect(path1, exit, block);
                    if (msg == null) {
                        msg = bo.setPath(this);
                    }
                }
            }
            b.showAllocated(this, bo.getPathName());
        }
        return msg;
    }

    /**
     * Allocate as many blocks as possible from the start of the warrant.
     * The first block must be allocated and all blocks of the route must
     * be in service. Otherwise partial success is OK.
     * Installs listeners for the entire route.
     * If occupation by another train is detected, a message will be
     * posted to the Warrant List Window. Note that warrants sharing their
     * clearance only allocate and set paths one block in advance.
     *
     * @param orders list of block orders
     * @param show _message for use ONLY to display a temporary route) continues to
     *  allocate skipping over blocks occupied or owned by another warrant.
     * @return error message, if unable to allocate first block or if any block
     *         is OUT_OF_SERVICE
     */
    public String allocateRoute(boolean show, List<BlockOrder> orders) {
        if (_totalAllocated && _runMode != MODE_NONE && _runMode != MODE_ABORT) {
            return null;
        }
        if (orders != null) {
            _orders = orders;
        }
        _allocated = false;
        _message = null;

        int idxSpeedChange = 0;  // idxBlockOrder where speed changes
        do {
            TrainOrder to = getBlockOrderAt(idxSpeedChange).allocatePaths(this, true);
            switch (to._cause) {
                case NONE:
                    break;
               case WARRANT:
                   _waitForWarrant = true;
                   if (_message == null) {
                       _message = to._message;
                   }
                   if (!show && to._idxContrlBlock == 0) {
                       return _message;
                   }
                   break;
                case OCCUPY:
                    _waitForBlock = true;
                    if (_message == null) {
                        _message = to._message;
                    }
                    break;
                case SIGNAL:
                    if (Stop.equals(to._speedType)) {
                        _waitForSignal = true;
                        if (_message == null) {
                            _message = to._message;
                        }
                    }
                    break;
                default:
                    log.error("{}: allocateRoute at block \"{}\" setPath returns: {}",
                            getDisplayName(), getBlockAt(idxSpeedChange).getDisplayName(), to.toString());
                    if (_message == null) {
                        _message = to._message;
                    }
            }
            if (!show) {
                if (_message != null || (_shareRoute && idxSpeedChange > 1)) {
                    break;
                }
            }
            idxSpeedChange++;
        } while (idxSpeedChange < _orders.size());

        if (log.isDebugEnabled()) {
            log.debug("{}: allocateRoute() _shareRoute= {} show= {}. Break at {} of {}. msg= {}",
                getDisplayName(), _shareRoute, show, idxSpeedChange, _orders.size(), _message);
        }
        _allocated = true; // start block allocated
        if (_message == null) {
            _totalAllocated = true;
            if (show && _shareRoute) {
                _message = Bundle.getMessage("sharedRoute");
            }
        }
        if (show) {
            return _message;
        }
        return null;
    }

    /**
     * Deallocates blocks from the current BlockOrder list
     */
    public void deAllocate() {
        if (_runMode == MODE_NONE || _runMode == MODE_ABORT) {
            _allocated = false;
            _totalAllocated = false;
            _routeSet = false;
            for (int i = 0; i < _orders.size(); i++) {
                deAllocateBlock(_orders.get(i).getBlock());
            }
        }
    }

    private boolean deAllocateBlock(OBlock block) {
        if (block.isAllocatedTo(this)) {
            block.deAllocate(this);
            if (block.equals(_stoppingBlock)){
                doStoppingBlockClear();
            }
            return true;
        }
        return false;
    }

    /**
     * Convenience routine to use from Python to start a warrant.
     *
     * @param mode run mode
     */
    public void runWarrant(int mode) {
        setRunMode(mode, null, null, null, false);
    }

    /**
     * Set the route paths and turnouts for the warrant. Only the first block
     * must be allocated and have its path set. Partial success is OK.
     * A message of the first subsequent block that fails allocation
     * or path setting is written to a field that is
     * displayed in the Warrant List window. When running with block
     * detection, occupation by another train or block 'not in use' or
     * Signals denying movement are reasons
     * for such a message, otherwise only allocation to another warrant
     * prevents total success. Note that warrants sharing their clearance
     * only allocate and set paths one block in advance.
     *
     * @param show If true allocateRoute returns messages for display.
     * @param orders  BlockOrder list of route. If null, use permanent warrant
     *            copy.
     * @return message if the first block fails allocation, otherwise null
     */
    public String setRoute(boolean show, List<BlockOrder> orders) {
        if (_shareRoute) { // full route of a shared warrant may be displayed
            deAllocate();   // clear route to allow sharing with another warrant
        }

        // allocateRoute may set _message for status info, but return null msg
        _message = allocateRoute(show, orders);
        if (_message != null) {
            log.debug("{}: setRoute: {}", getDisplayName(), _message);
            return _message;
        }
        _routeSet = true;
        return null;
    } // setRoute

    /**
     * Check start block for occupied for start of run
     *
     * @return error message, if any
     */
    public String checkStartBlock() {
        log.debug("{}: checkStartBlock.", getDisplayName());
        BlockOrder bo = _orders.get(0);
        OBlock block = bo.getBlock();
        String msg = block.allocate(this);
        if (msg != null) {
            return msg;
        }
        if (block.isDark() || _tempRunBlind) {
            msg = "BlockDark";
        } else if (!block.isOccupied()) {
            msg = "warnStart";
        }
        return msg;
    }

    protected String checkforTrackers() {
        BlockOrder bo = _orders.get(0);
        OBlock block = bo.getBlock();
        log.debug("{}: checkforTrackers at block {}", getDisplayName(), block.getDisplayName());
        Tracker t = InstanceManager.getDefault(TrackerTableAction.class).findTrackerIn(block);
        if (t != null) {
            return Bundle.getMessage("blockInUse", t.getTrainName(), block.getDisplayName());
        }
        return null;
    }

    /**
     * Report any occupied blocks in the route
     *
     * @return String
     */
    public String checkRoute() {
        log.debug("{}: checkRoute.", getDisplayName());
        if (_orders==null || _orders.isEmpty()) {
            return Bundle.getMessage("noBlockOrders");
        }
        OBlock startBlock = _orders.get(0).getBlock();
        for (int i = 1; i < _orders.size(); i++) {
            OBlock block = _orders.get(i).getBlock();
            if (block.isOccupied() && !startBlock.equals(block)) {
                return Bundle.getMessage("BlockRougeOccupied", block.getDisplayName());
            }
            Warrant w = block.getWarrant();
            if (w !=null && !this.equals(w)) {
                return Bundle.getMessage("AllocatedToWarrant",
                        w.getDisplayName(), block.getDisplayName(), w.getTrainName());
            }
        }
        return null;
    }

    @Override
    public void propertyChange(java.beans.PropertyChangeEvent evt) {
        if (!(evt.getSource() instanceof NamedBean)) {
            return;
        }
        String property = evt.getPropertyName();
        if (log.isDebugEnabled()) {
            log.debug("{}: propertyChange \"{}\" new= {} source= {}", getDisplayName(),
                    property, evt.getNewValue(), ((NamedBean) evt.getSource()).getDisplayName());
        }

        if (_protectSignal != null && _protectSignal == evt.getSource()) {
            if (property.equals("Aspect") || property.equals("Appearance")) {
                // signal controlling warrant has changed.
                readStoppingSignal();
            }
        } else if (property.equals("state")) {
            if (_stoppingBlock != null && _stoppingBlock.equals(evt.getSource())) {
                // starting block is allocated but not occupied
                int newState = ((Number) evt.getNewValue()).intValue();
                if ((newState & OBlock.OCCUPIED) != 0) {
                    if (_delayStart) { // wait for arrival of train to begin the run
                        // train arrived at starting block or last known block of lost train is found
                        clearStoppingBlock();
                        OBlock block = getBlockAt(0);
                        _idxCurrentOrder = 0;
                        if (_runMode == MODE_RUN && _engineer == null) {
                            _message = acquireThrottle();
                        } else if (_runMode == MODE_MANUAL) {
                            fireRunStatus(PROPERTY_READY_TO_RUN, -1, 0);   // ready to start msg
                            _delayStart = false;
                        }
                        block._entryTime = System.currentTimeMillis();
                        block.setValue(_trainName);
                        block.setState(block.getState() | OBlock.RUNNING);
                    } else if ((((Number) evt.getNewValue()).intValue() & OBlock.ALLOCATED) == 0) {
                        // blocking warrant has released allocation but train still occupies the block
                        clearStoppingBlock();
                        log.debug("\"{}\" cleared its wait. but block \"{}\" remains occupied", getDisplayName(),
                                (((Block)evt.getSource()).getDisplayName()));
                    }
                } else if ((((Number) evt.getNewValue()).intValue() & OBlock.UNOCCUPIED) != 0) {
                    //  blocking occupation has left the stopping block
                    clearStoppingBlock();
                }
            }
        }
    } //end propertyChange

    private String getSignalSpeedType(@Nonnull NamedBean signal) {
        String speedType;
        if (signal instanceof SignalHead) {
            SignalHead head = (SignalHead) signal;
            int appearance = head.getAppearance();
            speedType = InstanceManager.getDefault(SignalSpeedMap.class)
                    .getAppearanceSpeed(head.getAppearanceName(appearance));
            if (log.isDebugEnabled()) {
                log.debug("{}: SignalHead {} sets appearance speed to {}",
                      getDisplayName(), signal.getDisplayName(), speedType);
            }
        } else {
            SignalMast mast = (SignalMast) signal;
            String aspect = mast.getAspect();
            speedType = InstanceManager.getDefault(SignalSpeedMap.class).getAspectSpeed(
                    (aspect== null ? "" : aspect), mast.getSignalSystem());
            if (log.isDebugEnabled()) {
                log.debug("{}: SignalMast {} sets aspect speed to {}",
                      getDisplayName(), signal.getDisplayName(), speedType);
            }
        }
        return speedType;
    }

    /**
     * _protectSignal made an aspect change
     */
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    private void readStoppingSignal() {
        if (_idxProtectSignal < _idxCurrentOrder) { // signal is behind train. ignore
            changeSignalListener(null, _idxCurrentOrder);  // remove signal
            return;
        }
        // Signals may change after entry and while the train in the block.
        // Normally these changes are ignored.
        // However for the case of an overrun stop aspect, the train is waiting.
        if (_idxProtectSignal == _idxCurrentOrder && !_waitForSignal) { // not waiting
            changeSignalListener(null, _idxCurrentOrder);  // remove signal
            return; // normal case
        }// else Train previously overran stop aspect. Continue and respond to signal.

        String speedType = getSignalSpeedType(_protectSignal);
        String curSpeedType;
        if (_waitForSignal) {
            curSpeedType = Stop;
        } else {
            curSpeedType = _engineer.getSpeedType(true);    // current or pending ramp completion
        }
        if (log.isDebugEnabled()) {
            log.debug("{}: Signal \"{}\" changed to aspect \"{}\" {} blocks ahead. curSpeedType= {}",
                    getDisplayName(), _protectSignal.getDisplayName(), speedType, _idxProtectSignal-_idxCurrentOrder, curSpeedType);
        }

        if (curSpeedType.equals(speedType)) {
            return;
        }
        if (_idxProtectSignal > _idxCurrentOrder) {
            if (_speedUtil.secondGreaterThanFirst(speedType, curSpeedType)) {
                // change to slower speed. Check if speed change should occur now
                float availDist = getAvailableDistance(_idxProtectSignal);
                float changeDist = getChangeSpeedDistance(_idxProtectSignal, speedType);
                if (changeDist > availDist) {
                    // Not enough room in blocks ahead. start ramp in current block
                    availDist += getAvailableDistanceAt(_idxCurrentOrder);
                    if (speedType.equals(Warrant.Stop)) {
                        _waitForSignal = true;
                    }
                    int cmdStartIdx = _engineer.getCurrentCommandIndex(); // blkSpeedInfo.getFirstIndex();
                    if (!doDelayRamp(availDist, changeDist, _idxProtectSignal, speedType, cmdStartIdx)) {
                        log.info("No room for train {} to ramp to \"{}\" from \"{}\" for signal \"{}\"!. availDist={}, changeDist={} on warrant {}",
                                getTrainName(), speedType, curSpeedType, _protectSignal.getDisplayName(),
                                availDist,  changeDist, getDisplayName());
                    }   // otherwise will do ramp when entering a block ahead
                }
                return;
            }
        }
        if (!speedType.equals(Warrant.Stop)) {  // a moving aspect clears a signal wait
            if (_waitForSignal) {
                // signal protecting next block just released its hold
                _curSignalAspect = speedType;
                _waitForSignal = false;
                if (_trace || log.isDebugEnabled()) {
                    log.info(Bundle.getMessage("SignalCleared", _protectSignal.getDisplayName(), speedType, _trainName));
                }
                ThreadingUtil.runOnGUIDelayed(() -> {
                    restoreRunning(speedType);
                }, 2000);
            }
        }
    }


    /*
     * return distance from the exit of the current block "_idxCurrentOrder"
     * to the entrance of the "idxChange" block.
     */
    private float getAvailableDistance(int idxChange) {
        float availDist = 0;
        int idxBlockOrder = _idxCurrentOrder + 1;
        if (idxBlockOrder < _orders.size() - 1) {
            while (idxBlockOrder < idxChange) {
                availDist += getAvailableDistanceAt(idxBlockOrder++);   // distance to next block
            }
        }
        return availDist;
    }

    /*
     * Get distance needed to ramp so the speed into the next block satisfies the speedType
     * @param idxBlockOrder blockOrder index of entrance block
     */
    private float getChangeSpeedDistance(int idxBlockOrder, String speedType) {
        float speedSetting = _engineer.getSpeedSetting();       // current speed
        // Estimate speed at start of ramp
        float enterSpeed;   // speed at start of ramp
        if (speedSetting > 0.1f && (_idxCurrentOrder == idxBlockOrder - 1)) {
            // if in the block immediately before the entrance block, use current speed
            enterSpeed = speedSetting;
        } else { // else use entrance speed of previous block
            String currentSpeedType = _engineer.getSpeedType(false); // current speed type
            float scriptSpeed = _speedUtil.getBlockSpeedInfo(idxBlockOrder - 1).getEntranceSpeed();
            enterSpeed = _speedUtil.modifySpeed(scriptSpeed, currentSpeedType);
        }
        float scriptSpeed = _speedUtil.getBlockSpeedInfo(idxBlockOrder).getEntranceSpeed();
        float endSpeed = _speedUtil.modifySpeed(scriptSpeed, speedType);
        // compare distance needed for script throttle at entrance to entrance speed,
        // to the distance needed for current throttle to entrance speed.
        float enterLen = _speedUtil.getRampLengthForEntry(enterSpeed, endSpeed);
        // add buffers for signal and safety clearance
        float bufDist = getEntranceBufferDist(idxBlockOrder);
//        log.debug("{}: getChangeSpeedDistance curSpeed= {} enterSpeed= {} endSpeed= {}", getDisplayName(), speedSetting, enterSpeed, endSpeed);
        return enterLen + bufDist;
    }

    private void doStoppingBlockClear() {
        if (_stoppingBlock == null) {
            return;
        }
        _stoppingBlock.removePropertyChangeListener(this);
        _stoppingBlock = null;
        _idxStoppingBlock = -1;
    }

    /**
     * Called when a rogue or warranted train has left a block.
     * Also called from propertyChange() to allow warrant to acquire a throttle
     * and launch an engineer. Also called by retry control command to help user
     * work out of an error condition.
     */
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    synchronized private void clearStoppingBlock() {
        if (_stoppingBlock == null) {
            return;
        }
        String name = _stoppingBlock.getDisplayName();
        doStoppingBlockClear();

        if (_delayStart) {
            return;    // don't start. Let user resume start
        }
        if (_trace || log.isDebugEnabled()) {
            String reason;
            if (_waitForBlock) {
                reason = Bundle.getMessage("Occupancy");
            } else {
                reason = Bundle.getMessage("Warrant");
            }
            log.info(Bundle.getMessage("StopBlockCleared",
                    getTrainName(), getDisplayName(), reason, name));
        }
        cancelDelayRamp();
        int time = 1000;
        if (_waitForBlock) {
            _waitForBlock = false;
            time = 4000;
        }
        if (_waitForWarrant) {
            _waitForWarrant = false;
            time = 3000;
        }
        String speedType;
        if (_curSignalAspect != null) {
            speedType = _curSignalAspect;
        } else {
            speedType = _engineer.getSpeedType(false); // current speed type
        }
        ThreadingUtil.runOnGUIDelayed(() -> {
            restoreRunning(speedType);
        }, time);
    }

    private String okToRun() {
        boolean cannot = false;
        StringBuilder sb = new StringBuilder();
        if (_waitForSignal) {
            sb.append(Bundle.getMessage("Signal"));
            cannot = true;
        }
        if (_waitForWarrant) {
            if (cannot) {
                sb.append(", ");
            } else {
                cannot = true;
            }
            Warrant w = getBlockingWarrant();
           if (w != null) {
                sb.append(Bundle.getMessage("WarrantWait",  w.getDisplayName()));
            } else {
                sb.append(Bundle.getMessage("WarrantWait", "Unknown"));
            }
        }
        if (_waitForBlock) {
            if (cannot) {
                sb.append(", ");
            } else {
                cannot = true;
            }
            sb.append(Bundle.getMessage("Occupancy"));
        }

        if (_engineer != null) {
            int runState = _engineer.getRunState();
            if (runState == HALT || runState == RAMP_HALT) {
                if (cannot) {
                    sb.append(", ");
                } else {
                    cannot = true;
                }
                sb.append(Bundle.getMessage("userHalt"));
            }
        }
        if (cannot) {
            return sb.toString();
        }
        return null;
    }

    /**
     * A layout condition that has restricted or stopped a train has been cleared.
     * i.e. Signal aspect, rogue occupied block, contesting warrant or user halt.
     * This may or may not be all the conditions restricting speed.
     * @return true if automatic restart is done
     */
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    private boolean restoreRunning(String speedType) {
        _message = okToRun();
        boolean returnOK;
        if (_message == null) {
            BlockOrder bo = getBlockOrderAt(_idxCurrentOrder);
            TrainOrder to = bo.allocatePaths(this, true);
            OBlock block = bo.getBlock();
            if (log.isDebugEnabled()) {
                log.debug("{}: restoreRunning {}", getDisplayName(), to.toString());
            }
            switch (to._cause) {    // to._cause - precedence of checks is WARRANT, OCCUPY, SIGNAL
                case NONE:
                    returnOK = doRestoreRunning(block, speedType);
                    break;
                case WARRANT:
                   _waitForWarrant = true;
                   _message = to._message;
                   setStoppingBlock(to._idxContrlBlock);
                   returnOK = false;
                   break;
                case OCCUPY:
                    if (_overrun || _lost) {
                        _message = setPathAt(_idxCurrentOrder);
                        if (_message == null) {
                            returnOK = doRestoreRunning(block, speedType);
                        } else {
                            returnOK = false;
                        }
                        if (_lost && returnOK) {
                            _lost = false;
                        }
                        break;
                    }
                    returnOK = false;
                    _waitForBlock = true;
                    _message = to._message;
                    setStoppingBlock(to._idxContrlBlock);
                    break;
                case SIGNAL:
                    if (to._idxContrlBlock == _idxCurrentOrder) {
                        returnOK = doRestoreRunning(block, speedType);
                    } else {
                        returnOK = false;
                    }
                    if (returnOK && Stop.equals(to._speedType)) {
                        _waitForSignal = true;
                        _message = to._message;
                        setProtectingSignal(to._idxContrlBlock);
                        returnOK = false;
                        break;
                    }
                    speedType = to._speedType;
                    returnOK = doRestoreRunning(block, speedType);
                    break;
                default:
                    log.error("restoreRunning TrainOrder {}", to.toString());
                    _message = to._message;
                    returnOK = false;
            }
        } else {
            returnOK = false;
        }
        if (!returnOK) {
            String blockName = getBlockAt(_idxCurrentOrder).getDisplayName();
            if (_trace || log.isDebugEnabled()) {
                log.info(Bundle.getMessage("trainWaiting", getTrainName(), _message, blockName));
            }
            fireRunStatus(PROPERTY_CANNOT_RUN, blockName, _message);
        }
        return returnOK;
    }

    private boolean doRestoreRunning(OBlock block, String speedType) {
        _overrun = false;
        _curSignalAspect = null;
        setPathAt(_idxCurrentOrder);    // show ownership and train Id

        // It is highly likely an event to restart a speed increase occurs when the train
        // position is in the middle or end of the block. Since 'lookAheadforSpeedChange'
        // assumes the train is at the start of a block, don't ramp up if the
        // train may not enter the next block. No room for both ramp up and ramp down
        BlockOrder bo = getBlockOrderAt(_idxCurrentOrder+1);
        if (bo != null) {
            TrainOrder to = bo.allocatePaths(this, true);
            if (Warrant.Stop.equals(to._speedType)) {
                _message = to._message;
                switch (to._cause) {
                    case NONE:
                        break;
                   case WARRANT:
                       _waitForWarrant = true;
                       setStoppingBlock(to._idxContrlBlock);
                       break;
                    case OCCUPY:
                        _waitForBlock = true;
                        setStoppingBlock(to._idxContrlBlock);
                        break;
                    case SIGNAL:
                        _waitForSignal = true;
                        setProtectingSignal(to._idxContrlBlock);
                        break;
                    default:
                }
                return false;
            }
        }
        _engineer.clearWaitForSync(block);
        if (log.isDebugEnabled()) {
            log.debug("{}: restoreRunning(): rampSpeedTo to \"{}\"",
                    getDisplayName(), speedType);
        }
        rampSpeedTo(speedType, -1);
        // continue, there may be blocks ahead that need a speed decrease before entering them
        if (!_overrun && _idxCurrentOrder < _orders.size() - 1) {
            lookAheadforSpeedChange(speedType, speedType);
        } // else at last block, forget about speed changes
        return true;
    }

    /**
     * Stopping block only used in MODE_RUN _stoppingBlock is an occupied OBlock
     * preventing the train from continuing the route OR another warrant
     * is preventing this warrant from allocating the block to continue.
     * <p>
     */
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    private void setStoppingBlock(int idxBlock) {
        OBlock block = getBlockAt(idxBlock);
        if (block == null) {
            return;
        }
        // _idxCurrentOrder == 0 may be a delayed start waiting for loco.
        // Otherwise don't set _stoppingBlock for a block occupied by train
        if (idxBlock < 0 || (_idxCurrentOrder == idxBlock && !_lost)) {
            return;
        }
        OBlock prevBlk = _stoppingBlock;
        if (_stoppingBlock != null) {
            if (_stoppingBlock.equals(block)) {
                return;
            }

            int idxStop = getIndexOfBlockAfter(_stoppingBlock, _idxCurrentOrder);
            if ((idxBlock < idxStop) || idxStop < 0) {
                prevBlk.removePropertyChangeListener(this);
            } else {
                if (idxStop < _idxCurrentOrder) {
                    log.error("{}: _stoppingBlock \"{}\" index {} < _idxCurrentOrder {}",
                            getDisplayName(), _stoppingBlock.getDisplayName(), idxStop, _idxCurrentOrder);
                }
                return;
            }
        }
        _stoppingBlock = block;
        _idxStoppingBlock = idxBlock;
        _stoppingBlock.addPropertyChangeListener(this);
        if ((_trace || log.isDebugEnabled()) && (_waitForBlock || _waitForWarrant)) {
            String reason;
            String cause;
            if (_waitForWarrant) {
                reason = Bundle.getMessage("Warrant");
                Warrant w = block.getWarrant();
                if (w != null) {
                    cause = w.getDisplayName();
                } else {
                    cause = Bundle.getMessage("Unknown");
                }
            } else if (_waitForBlock) {
                reason = Bundle.getMessage("Occupancy");
                cause = (String)block.getValue();
                if (cause == null) {
                    cause = Bundle.getMessage("unknownTrain");
                }
            } else if (_lost) {
                reason = Bundle.getMessage("Lost");
                cause = Bundle.getMessage("Occupancy");
            } else {
                reason = Bundle.getMessage("Start");
                cause = "";
            }
            log.info(Bundle.getMessage("StopBlockSet", _stoppingBlock.getDisplayName(), getTrainName(), reason, cause));
        }
    }

    /**
     * set signal listening for aspect change for block at index.
     * return true if signal is set.
     */
    private boolean setProtectingSignal(int idx) {
        if (_idxProtectSignal == idx) {
            return true;
        }
        BlockOrder blkOrder = getBlockOrderAt(idx);
        NamedBean signal = blkOrder.getSignal();

        if (_protectSignal != null && _protectSignal.equals(signal)) {
            // Must be the route coming back to the same block. Same signal, move index only.
            if (_idxProtectSignal < idx && idx >= 0) {
                _idxProtectSignal = idx;
            }
            return true;
        }

        if (_protectSignal != null) {
            if (idx > _idxProtectSignal && _idxProtectSignal > _idxCurrentOrder) {
                return true;
            }
        }

        return changeSignalListener(signal, idx);
    }

    /**
     * if current listening signal is not at signalIndex, remove listener and
     * set new listening signal
     */
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    private boolean changeSignalListener(NamedBean  signal,  int signalIndex) {
        if (signalIndex == _idxProtectSignal) {
            return true;
        }
//        StringBuilder sb = new StringBuilder(getDisplayName());
        if (_protectSignal != null) {
            _protectSignal.removePropertyChangeListener(this);
/*            if (log.isDebugEnabled()) {
                sb.append("Removes \"");
                sb.append(_protectSignal.getDisplayName());
                sb.append("\" at \"");
                sb.append(getBlockAt(_idxProtectSignal).getDisplayName());
                sb.append("\"");
            }*/
            _protectSignal = null;
            _idxProtectSignal = -1;
        }
        boolean ret = false;
        if (signal != null) {
            _protectSignal = signal;
            _idxProtectSignal = signalIndex;
            _protectSignal.addPropertyChangeListener(this);
            if (_trace || log.isDebugEnabled()) {
                log.info(Bundle.getMessage("ProtectSignalSet", getTrainName(),
                        _protectSignal.getDisplayName(), getBlockAt(_idxProtectSignal).getDisplayName()));
            }
            ret = true;
        }
        return ret;
    }

    /**
     * Check if this is the next block of the train moving under the warrant
     * Learn mode assumes route is set and clear. Run mode update conditions.
     * <p>
     * Must be called on Layout thread.
     *
     * @param block Block in the route is going active.
     */
    @InvokeOnLayoutThread
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    protected void goingActive(OBlock block) {
        if (log.isDebugEnabled()) {
            if (!ThreadingUtil.isLayoutThread()) {
                log.error("{} invoked on wrong thread", getDisplayName(), new Exception("traceback"));
                stopWarrant(true, true);
                return;
            }
        }

        if (_runMode == MODE_NONE) {
            return;
        }
        int activeIdx = getIndexOfBlockAfter(block, _idxCurrentOrder);
        if (log.isDebugEnabled()) {
            log.debug("{}: **Block \"{}\" goingActive. activeIdx= {}, _idxCurrentOrder= {}.",
                    getDisplayName(), block.getDisplayName(), activeIdx, _idxCurrentOrder);
        }
        Warrant w = block.getWarrant();
        if (w == null || !this.equals(w)) {
            if (log.isDebugEnabled()) {
                log.debug("{}: **Block \"{}\" owned by {}!",
                        getDisplayName(), block.getDisplayName(), (w==null?"NO One":w.getDisplayName()));
            }
            return;
        }
        if (_lost && !getBlockAt(_idxCurrentOrder).isOccupied()) {
            _idxCurrentOrder = activeIdx;
            log.info("Train \"{}\" found at block \"{}\" of warrant {}.",
                       getTrainName(), block.getDisplayName(),  getDisplayName());
            _lost = false;
            rampSpeedTo(_engineer.getSpeedType(false), - 1); // current speed type
            setMovement();
            return;
        }
        if (activeIdx <= 0) {
            // if _idxCurrentOrder == 0, (i.e. starting block) case 0 is handled as the _stoppingBlock
            return;
        }
        if (activeIdx == _idxCurrentOrder) {
            // unusual occurrence.  dirty track? sensor glitch?
            if (_trace || log.isDebugEnabled()) {
                log.info(Bundle.getMessage("RegainDetection", getTrainName(), block.getDisplayName()));
            }
        } else if (activeIdx == _idxCurrentOrder + 1) {
            if (_delayStart) {
                log.warn("{}: Rogue entered Block \"{}\" ahead of {}.",
                        getDisplayName(), block.getDisplayName(), getTrainName());
                _message = Bundle.getMessage("BlockRougeOccupied", block.getDisplayName());
                return;
            }
            // Since we are moving at speed we assume it is our train that entered the block
            // continue on.
            _idxCurrentOrder = activeIdx;
        } else if (activeIdx > _idxCurrentOrder + 1) {
            // if previous blocks are dark, this could be for our train
            // check from current (last known) block to this just activated block
            for (int idx = _idxCurrentOrder + 1; idx < activeIdx; idx++) {
                OBlock preBlock = getBlockAt(idx);
                if (!preBlock.isDark()) {
                    // not dark, therefore not our train
                    if (log.isDebugEnabled()) {
                        OBlock curBlock = getBlockAt(_idxCurrentOrder);
                        log.debug("Rogue train entered block \"{}\" ahead of train {} currently in block \"{}\"!",
                                block.getDisplayName(), _trainName, curBlock.getDisplayName());
                    }
                    return;
                }
            }
            // we assume this is our train entering block
            _idxCurrentOrder = activeIdx;
            // previous blocks were checked as UNDETECTED above
            // Indicate the previous dark block was entered
            OBlock prevBlock = getBlockAt(activeIdx - 1);
            prevBlock._entryTime = System.currentTimeMillis() - 5000; // arbitrary. Just say 5 seconds
            prevBlock.setValue(_trainName);
            prevBlock.setState(prevBlock.getState() | OBlock.RUNNING);
            if (log.isDebugEnabled()) {
                log.debug("{}: Train moving from UNDETECTED block \"{}\" now entering block\"{}\"",
                        getDisplayName(), prevBlock.getDisplayName(), block.getDisplayName());
            }
        } else if (_idxCurrentOrder > activeIdx) {
            // unusual occurrence.  dirty track, sensor glitch, too fast for goingInactive() for complete?
            log.info("Tail of Train {} regained detection behind Block= {} at block= {}",
                    getTrainName(), block.getDisplayName(), getBlockAt(activeIdx).getDisplayName());
            return;
        }
        // Since we are moving we assume it is our train entering the block
        // continue on.
        setHeadOfTrain(block);
        if (_engineer != null) {
            _engineer.clearWaitForSync(block); // Sync commands if train is faster than ET
        }
        if (_trace) {
            log.info(Bundle.getMessage("TrackerBlockEnter", getTrainName(),  block.getDisplayName()));
        }
        fireRunStatus("blockChange", getBlockAt(activeIdx - 1), block);
        if (_runMode == MODE_LEARN) {
            return;
        }
        // _idxCurrentOrder has been incremented. Warranted train has entered this block.
        // Do signals, speed etc.
        if (_idxCurrentOrder < _orders.size() - 1) {
            if (_engineer != null) {
                BlockOrder bo = _orders.get(_idxCurrentOrder + 1);
                if (bo.getBlock().isDark()) {
                    // can't detect next block, use ET
                    _engineer.setRunOnET(true);
                } else if (!_tempRunBlind) {
                    _engineer.setRunOnET(false);
                }
            }
        }
        if (log.isTraceEnabled()) {
            log.debug("{}: end of goingActive. leaving \"{}\" entered \"{}\"",
                    getDisplayName(), getBlockAt(activeIdx - 1).getDisplayName(), block.getDisplayName());
        }
        setMovement();
    } //end goingActive

    private void setHeadOfTrain(OBlock block ) {
        block.setValue(_trainName);
        block.setState(block.getState() | OBlock.RUNNING);
        if (_runMode == MODE_RUN && _idxCurrentOrder > 0 && _idxCurrentOrder < _orders.size()) {
            _speedUtil.leavingBlock(_idxCurrentOrder - 1);
        }
    }

    /**
     * @param block Block in the route is going Inactive
     */
    @InvokeOnLayoutThread
    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    protected void goingInactive(OBlock block) {
        if (log.isDebugEnabled()) {
            if (!ThreadingUtil.isLayoutThread()) {
                log.error("{} invoked on wrong thread", getDisplayName(), new Exception("traceback"));
            }
        }
        if (_runMode == MODE_NONE) {
            return;
        }

        int idx = getIndexOfBlockBefore(_idxCurrentOrder, block); // if idx >= 0, it is in this warrant
        if (log.isDebugEnabled()) {
            log.debug("{}: *Block \"{}\" goingInactive. idx= {}, _idxCurrentOrder= {}.",
                    getDisplayName(), block.getDisplayName(), idx, _idxCurrentOrder);
        }
        if (idx > _idxCurrentOrder) {
            return;
        }
        releaseBlock(block, idx);
        block.setValue(null);
        if (idx == _idxCurrentOrder) {
            // Train not visible if current block goes inactive. This is OK if the next block is Dark.
            if (_idxCurrentOrder + 1 < _orders.size()) {
                OBlock nextBlock = getBlockAt(_idxCurrentOrder + 1);
                if (nextBlock.isDark()) {
                    goingActive(nextBlock); // fake occupancy for dark block
                    return;
                }
                if (checkForOverrun(nextBlock)) {
                    return;
                }
            }
            _lost = true;
            if (_engineer != null) {
                setSpeedToType(Stop);   // set 0 throttle
                setStoppingBlock(_idxCurrentOrder);
            }
            if (_trace) {
                log.info(Bundle.getMessage("ChangedRoute", _trainName, block.getDisplayName(), getDisplayName()));
            }
            fireRunStatus("blockChange", block, null);  // train is lost
        }
    } // end goingInactive

    /**
     * Deallocates all blocks prior to and including block at index idx
     * of _orders, if not needed again.
     * Comes from goingInactive, i.e. warrant has a listener on the block.
     * @param block warrant is releasing
     * @param idx index in BlockOrder list
     */
    private void releaseBlock(OBlock block, int idx) {
        /*
         * Deallocate block if train will not use the block again. Warrant
         * could loop back and re-enter blocks previously traversed. That is,
         * they will need to re-allocation of blocks ahead.
         * Previous Dark blocks also need deallocation and other trains or cars
         * dropped may have prevented previous blocks from going inactive.
         * Thus we must deallocate backward until we reach inactive detectable blocks
         * or blocks we no longer own.
         */
        for (int i = idx; i > -1; i--) {
            boolean neededLater = false;
            OBlock curBlock = getBlockAt(i);
            for (int j = i + 1; j < _orders.size(); j++) {
                if (curBlock.equals(getBlockAt(j))) {
                    neededLater = true;
                }
            }
            if (!neededLater) {
                if (deAllocateBlock(curBlock)) {
                    curBlock.setValue(null);
                    _totalAllocated = false;
                }
            } else {
                if (curBlock.isAllocatedTo(this)) {
                    // Can't deallocate, but must listen for followers
                    // who may be occupying the block
                    if (_idxCurrentOrder != idx + 1) {
                        curBlock.setValue(null);
                    }
                    if (curBlock.equals(_stoppingBlock)){
                        doStoppingBlockClear();
                    }
                }
                if (_shareRoute) { // don't deallocate if closer than 2 blocks, otherwise deallocate
                    int k = Math.min(3, _orders.size());
                    while (k > _idxCurrentOrder) {
                        if (!curBlock.equals(getBlockAt(k))) {
                            if (deAllocateBlock(curBlock)) {
                                curBlock.setValue(null);
                                _totalAllocated = false;
                            }
                        }
                        k--;
                    }
                }
            }
        }
    }

    /*
     * This block is a possible overrun. If permitted, we may claim ownership.
     * BlockOrder index of block is _idxCurrentOrder + 1
     * return true, if warrant can claim occupation and ownership
     */
    private boolean checkForOverrun(OBlock block) {
        if (block.isOccupied() && (System.currentTimeMillis() - block._entryTime < 5000)) {
            // Went active within the last 5 seconds. Likely an overrun
            _overrun = true;
            _message = setPathAt(_idxCurrentOrder + 1);    //  no TrainOrder checks. allocates and sets path
            if (_message == null) {   // OK we own the block now.
                _idxCurrentOrder++;
                // insulate possible non-GUI thread making this call (e.g. Engineer)
                ThreadingUtil.runOnGUI(()-> goingActive(block));
                return true ;
            }
        }
        return false;
    }

    @Override
    public void dispose() {
        if (_runMode != MODE_NONE) {
            stopWarrant(true, true);
        }
        super.dispose();
    }

    @Override
    public String getBeanType() {
        return Bundle.getMessage("BeanNameWarrant");
    }

    private class CommandDelay extends Thread {

        String _speedType;
//        long _startTime = 0;
        long _waitTime = 0;
        float _waitSpeed;
        volatile boolean quit = false;
        int _endBlockIdx;

        CommandDelay(@Nonnull String speedType, long startWait, float waitSpeed, int endBlockIdx) {
            _speedType = speedType;
            _waitTime = startWait;
            _waitSpeed = waitSpeed;
            _endBlockIdx = endBlockIdx;
            setName("CommandDelay(" + getTrainName() + "-" + speedType +")");
        }

        // check if request for a duplicate CommandDelay can be cancelled
        boolean isDuplicate(String speedType, long startWait, int endBlockIdx) {
            if (endBlockIdx == _endBlockIdx && speedType.equals(_speedType) ) { // &&
//                    (_waitTime - (System.currentTimeMillis() - _startTime)) < startWait) {
                return true;    // keeps this thread
            }
            return false;   // not a duplicate or does not shorten time wait. this thread will be cancelled
        }

        @Override
        @SuppressFBWarnings(value = "WA_NOT_IN_LOOP", justification = "notify never called on this thread")
        public void run() {
            synchronized (this) {
//                _startTime = System.currentTimeMillis();
                boolean ramping = _engineer.isRamping();
                if (ramping) {
                    long startTime = System.currentTimeMillis();
                    while (!quit && System.currentTimeMillis() - startTime <= _waitTime) {
                        if (_engineer.getSpeedSetting() >= _waitSpeed) {
                            break; // stop ramping beyond this speed
                        }
                        try {
                            wait(100);
                        } catch (InterruptedException ie) {
                            if (log.isDebugEnabled() && quit) {
                                log.debug("CommandDelay interrupt. Ramp to {} not done. warrant {}",
                                        _speedType, getDisplayName());
                            }
                        }
                    }
                } else {
                    try {
                        wait(_waitTime);
                    } catch (InterruptedException ie) {
                        if (log.isDebugEnabled() && quit) {
                            log.debug("CommandDelay interrupt.  Ramp to {} not done. warrant {}",
                                    _speedType, getDisplayName());
                        }
                    }
                }

                if (!quit && _engineer != null) {
                    if (_noRamp) {
                        setSpeedToType(_speedType);
                    } else {
                        _engineer.rampSpeedTo(_speedType, _endBlockIdx);
                    }
                }
            }
            endDelayCommand(this);
        }
    }

    synchronized private void cancelDelayRamp() {
        if (_delayCommand != null) {
            log.debug("{}: cancelDelayRamp() called. _speedType= {}", getDisplayName(), _delayCommand._speedType);
            _delayCommand.quit = true;
            _delayCommand.interrupt();
            _delayCommand = null;
        }
    }

    synchronized private void endDelayCommand(CommandDelay cd) {
        if (_delayCommand == cd) {  // may have been replaced by a newer one
            _delayCommand = null;
        }
    }

    private void rampSpeedTo(String speedType, int idx) {
        cancelDelayRamp();
        if (_noRamp) {
            _engineer.setSpeedToType(speedType);
            _engineer.setWaitforClear(speedType.equals(Stop) || speedType.equals(EStop));
            if (log.isDebugEnabled()) {
                log.debug("{}: No Ramp to \"{}\" from block \"{}\"", getDisplayName(), speedType, getCurrentBlockName());
            }
            return;
        }
        if (log.isDebugEnabled()) {
            if (idx < 0) {
                log.debug("{}: Ramp up to \"{}\" from block \"{}\"", getDisplayName(), speedType, getCurrentBlockName());
            } else {
                log.debug("{}: Ramp down to \"{}\" before block \"{}\"", getDisplayName(), speedType, getBlockAt(idx).getDisplayName());
            }
        }
        if (_engineer != null) {
            _engineer.rampSpeedTo(speedType, idx);
        } else {
            log.error("{}: No Engineer!", getDisplayName());
        }
    }

    private void setSpeedToType(String speedType) {
        cancelDelayRamp();
        _engineer.setSpeedToType(speedType);
    }

    private void clearWaitFlags(boolean removeListeners) {
        if (log.isTraceEnabled()) {
            log.trace("{}: Flags cleared {}.", getDisplayName(), removeListeners?"and removed Listeners":"only");
        }
        _waitForBlock = false;
        _waitForSignal = false;
        _waitForWarrant = false;
        if (removeListeners) {
            if (_protectSignal != null) {
                _protectSignal.removePropertyChangeListener(this);
                _protectSignal = null;
                _idxProtectSignal = -1;
            }
            if (_stoppingBlock != null) {
                _stoppingBlock.removePropertyChangeListener(this);
                _stoppingBlock = null;
                _idxStoppingBlock = -1;
            }
        }
    }

    /*
     * Return pathLength of the block.
     */
    private float getAvailableDistanceAt(int idxBlockOrder) {
        BlockOrder blkOrder = getBlockOrderAt(idxBlockOrder);
        float pathLength = blkOrder.getPathLength();
        if (idxBlockOrder == 0 || pathLength <= 20.0f) {
            // Position in block is unknown. use calculated distances instead
            float blkDist = _speedUtil.getBlockSpeedInfo(idxBlockOrder).getCalcLen();
            if (log.isDebugEnabled()) {
                log.debug("{}: getAvailableDistanceAt: block \"{}\" using calculated blkDist= {}, pathLength= {}",
                        getDisplayName(), blkOrder.getBlock().getDisplayName(), blkDist, pathLength);
            }
            return blkDist;
        } else {
            return pathLength;
        }
    }

    private float getEntranceBufferDist(int idxBlockOrder) {
        float bufDist = BUFFER_DISTANCE;
        if (_waitForSignal) {        // signal restricting speed
            bufDist+= getBlockOrderAt(idxBlockOrder).getEntranceSpace(); // signal's adjustment
        }
        return bufDist;
    }

    /**
     * Called to set the correct speed for the train when the scripted speed
     * must be modified due to a track condition (signaled speed or rogue
     * occupation). Also called to return to the scripted speed after the
     * condition is cleared. Assumes the train occupies the block of the current
     * block order.
     * <p>
     * Looks for speed requirements of this block and takes immediate action if
     * found. Otherwise looks ahead for future speed change needs. If speed
     * restriction changes are required to begin in this block, but the change
     * is not immediate, then determine the proper time delay to start the speed
     * change.
     */
    private void setMovement() {
        BlockOrder curBlkOrder = getBlockOrderAt(_idxCurrentOrder);
        OBlock curBlock = curBlkOrder.getBlock();
        String currentSpeedType = _engineer.getSpeedType(false); // current speed type
        String entrySpeedType = BlockOrder.getPermissibleSpeedAt(curBlkOrder); // expected speed type for this block
        if (entrySpeedType == null) {
            entrySpeedType = currentSpeedType;
        }
        curBlkOrder.setPath(this);  // restore running

        if (log.isDebugEnabled()) {
            SpeedState speedState = _engineer.getSpeedState();
            int runState = _engineer.getRunState();
            log.debug("{}: SET MOVEMENT Block \"{}\" runState= {}, speedState= {} for currentSpeedType= {}. entrySpeedType= {}.",
                    getDisplayName(), curBlock.getDisplayName(), RUN_STATE[runState], speedState.toString(),
                    currentSpeedType, entrySpeedType);
            log.debug("{}: Flags: _waitForBlock={}, _waitForSignal={}, _waitForWarrant={} curThrottle= {}.",
                    getDisplayName(), _waitForBlock, _waitForSignal, _waitForWarrant, _engineer.getSpeedSetting());
            if (_message != null) {
                log.debug("{}: _message ({}) ", getDisplayName(), _message);
            }
        }

        // Check that flags and states agree with expected speed and position
        // A signal drop down can appear to be a speed violation, but only when a violation when expected
        if (_idxCurrentOrder > 0) {
            if (_waitForSignal) {
                if (_idxProtectSignal == _idxCurrentOrder) {
                    makeOverrunMessage(curBlkOrder);
                    setSpeedToType(Stop); // immediate decrease
                    return;
                }
            }
            if (_idxStoppingBlock == _idxCurrentOrder) {
                if (_waitForBlock || _waitForWarrant) {
                    makeOverrunMessage(curBlkOrder);
                    setSpeedToType(Stop); // immediate decrease
                    return;
                }
            }

            if (_speedUtil.secondGreaterThanFirst(entrySpeedType, currentSpeedType)) {
                // signal or block speed entrySpeedType is less than currentSpeedType.
                // Speed for this block is violated so set end speed immediately
                NamedBean signal = curBlkOrder.getSignal();
                if (signal != null) {
                    log.info("Train {} moved past required {} speed for signal \"{}\" at block \"{}\" on warrant {}!",
                            getTrainName(), entrySpeedType, signal.getDisplayName(), curBlock.getDisplayName(), getDisplayName());
                } else {
                    log.info("Train {} moved past required \"{}\" speed at block \"{}\" on warrant {}!",
                            getTrainName(), entrySpeedType, curBlock.getDisplayName(), getDisplayName());
                }
                fireRunStatus("SignalOverrun", (signal!=null?signal.getDisplayName():curBlock.getDisplayName()),
                        entrySpeedType); // message of speed violation
               setSpeedToType(entrySpeedType); // immediate decrease
               currentSpeedType = entrySpeedType;
            }
        } else {    // at origin block and train has arrived,. ready to move
            if (Stop.equals(currentSpeedType)) {
                currentSpeedType = Normal;
            }
        }

        if (_idxCurrentOrder < _orders.size() - 1) {
            lookAheadforSpeedChange(currentSpeedType, entrySpeedType);
        } // else at last block, forget about speed changes, return;
    }

    /*
     * Looks for the need to reduce speed ahead. If one is found, mkes an estimate of the
     *distance needed to change speeds.  Find the available distance available, including
     * the full length of the current path. If the ramp to reduce speed should begin in the
     * current block, calls methods to calculate the time lapse before the ramp should begin.
     * entrySpeedType (expected type) will be either equal to or greater than currentSpeedType
     * for all blocks except rhe first.
     */
    private void lookAheadforSpeedChange(String currentSpeedType, String entrySpeedType) {
        clearWaitFlags(false);
        // look ahead for speed type slower than current type, refresh flags
        // entrySpeedType is the expected speed to be reached, if no speed change ahead

        String speedType = currentSpeedType;    // first slower speedType ahead
        int idx = _idxCurrentOrder + 1;
        int idxSpeedChange = -1;  // idxBlockOrder where speed changes
        int idxContrlBlock = -1;
        int limit;
        if (_shareRoute) {
            limit = Math.min(_orders.size(), _idxCurrentOrder + 3);
        } else {
            limit = _orders.size();
        }
        boolean allocate = true;
        int numAllocated = 0;
        do {
            TrainOrder to = getBlockOrderAt(idx).allocatePaths(this, allocate);
            if (log.isDebugEnabled()) {
                log.debug("{}: lookAheadforSpeedChange {}", getDisplayName(), to.toString());
            }
            switch (to._cause) {
                case NONE:
                    break;
               case WARRANT:
                   _waitForWarrant = true;
                   _message = to._message;
                   idxContrlBlock = to._idxContrlBlock;
                   idxSpeedChange = to._idxEnterBlock;
                   speedType = Stop;
                   break;
                case OCCUPY:
                    _waitForBlock = true;
                    _message = to._message;
                    idxContrlBlock = to._idxContrlBlock;
                    idxSpeedChange = to._idxEnterBlock;
                    speedType = Stop;
                    break;
                case SIGNAL:
                    speedType = to._speedType;
                    if (Stop.equals(speedType)) {
                        _waitForSignal = true;
                    }
                    idxContrlBlock = to._idxContrlBlock;
                    idxSpeedChange = to._idxEnterBlock;
                    _message = to._message;
                    break;
                default:
                    log.error("{}: lookAheadforSpeedChange at block \"{}\" setPath returns: {}",
                            getDisplayName(), getBlockAt(_idxCurrentOrder).getDisplayName(), to.toString());
                    _message = to._message;
                    setSpeedToType(Stop);
                    return;
            }
            numAllocated++;
            if (Stop.equals(speedType)) {
                break;
            }
            if (_shareRoute && numAllocated > 1 ) {
                allocate = false;
            }
            idx++;

        } while ((idxSpeedChange < 0) && (idx < limit) &&
                !_speedUtil.secondGreaterThanFirst(speedType, currentSpeedType));

        if (!Stop.equals(speedType)) {
            while ((idx < limit)) { // allocate and set paths beyond speed change
                TrainOrder to = getBlockOrderAt(idx).allocatePaths(this, false);
                if (Stop.equals(to._speedType)) {
                    break;
                }
                idx++;
            }
        }
        if (idxSpeedChange < 0) {
            idxSpeedChange = _orders.size() - 1;
        }

        float availDist = getAvailableDistance(idxSpeedChange);  // distance ahead (excluding current block
        float changeDist = getChangeSpeedDistance(idxSpeedChange, speedType);    // distance needed to change speed for speedType

        if (_speedUtil.secondGreaterThanFirst(currentSpeedType, speedType)) {
            // speedType is greater than currentSpeedType. i.e. increase speed.
            rampSpeedTo(speedType, -1);
            return;
        }
        if (!currentSpeedType.equals(entrySpeedType)) {
            // entrySpeedType is greater than currentSpeedType. i.e. increase speed.
            rampSpeedTo(entrySpeedType, -1);
            // continue to interrupt ramp up with ramp down
        }

        // set next signal after current block for aspect speed change
        for (int i = _idxCurrentOrder + 1; i < _orders.size(); i++) {
            if (setProtectingSignal(i)) {
               break;
           }
        }

        OBlock block = getBlockAt(idxSpeedChange);
        if (log.isDebugEnabled()) {
            log.debug("{}: Speed \"{}\" at block \"{}\" until speed \"{}\" at block \"{}\", availDist={}, changeDist={}",
                    getDisplayName(), currentSpeedType, getBlockAt(_idxCurrentOrder).getDisplayName(), speedType,
                    block.getDisplayName(), availDist, changeDist);
        }

        if (changeDist <= availDist) {
            cancelDelayRamp(); // interrupts down ramping
            clearWaitFlags(false);
            return;
        }

        // Now set stopping condition of flags, if any. Not, if current block is also ahead.
        if (_waitForBlock) {
            if (!getBlockAt(_idxCurrentOrder).equals(block)) {
                setStoppingBlock(idxContrlBlock);
            }
        } else if (_waitForWarrant) {
            // if block is allocated and unoccupied, but cannot set path exit.
            if (_stoppingBlock == null) {
                setStoppingBlock(idxContrlBlock);
            }
        }

        // Begin a ramp for speed change in this block. If due to a signal, watch that one
        if(_waitForSignal) {
            // Watch this signal. Should be the previous set signal above.
            // If not, then user has not configured signal system to allow room for speed changes.
            setProtectingSignal(idxContrlBlock);
        }

        // either ramp in progress or no changes needed. Stopping conditions set, so move on.
        if (!_speedUtil.secondGreaterThanFirst(speedType, currentSpeedType)) {
            return;
        }

        availDist += getAvailableDistanceAt(_idxCurrentOrder);   // Add available length in this block

        int cmdStartIdx = _speedUtil.getBlockSpeedInfo(_idxCurrentOrder).getFirstIndex();
        if (!doDelayRamp(availDist, changeDist, idxSpeedChange, speedType, cmdStartIdx)) {
            log.warn("No room for train {} to ramp to \"{}\" from \"{}\" in block \"{}\"!. availDist={}, changeDist={} on warrant {}",
                    getTrainName(), speedType, currentSpeedType, getBlockAt(_idxCurrentOrder).getDisplayName(),
                    availDist,  changeDist, getDisplayName());
        }
    }

    /*
     * if there is sufficient room calculate a wait time, otherwise ramp immediately.
     */
    synchronized private boolean doDelayRamp(float availDist, float changeDist, int idxSpeedChange, String speedType, int cmdStartIdx) {
        String pendingSpeedType = _engineer.getSpeedType(true); // current or pending speed type
        if (pendingSpeedType.equals(speedType)) {
            return true;
        }
        if (availDist < 10) {
            setSpeedToType(speedType);
            return false;
        } else {
            SpeedState speedState = _engineer.getSpeedState();
            switch (speedState) {
                case RAMPING_UP:
                    makeRampWait(availDist, idxSpeedChange, speedType);
                    break;
                case RAMPING_DOWN:
                    log.error("Already ramping to \"{}\" making ramp for \"{}\".", _engineer.getSpeedType(true), speedType);
                //$FALL-THROUGH$
                case STEADY_SPEED:
                //$FALL-THROUGH$
                default:
                    makeScriptWait(availDist, changeDist, idxSpeedChange, speedType, cmdStartIdx);
            }
        }
        return true;
    }

    private void makeRampWait(float availDist, int idxSpeedChange, @Nonnull String speedType) {
        BlockSpeedInfo info = _speedUtil.getBlockSpeedInfo(idxSpeedChange - 1);
        float speedSetting = info.getExitSpeed();
        float endSpeed = _speedUtil.modifySpeed(speedSetting, speedType);

        speedSetting = _engineer.getSpeedSetting();       // current speed
        float prevSetting = speedSetting;
        String currentSpeedType = _engineer.getSpeedType(false); // current speed type

        float changeDist = 0;
        if (log.isDebugEnabled()) {
            log.debug("{}: makeRampWait for speed change \"{}\" to \"{}\". Throttle from={}, to={}, availDist={}",
                    getDisplayName(), currentSpeedType, speedType, speedSetting, endSpeed, availDist);
            // command index numbers biased by 1
        }
        float bufDist = getEntranceBufferDist(idxSpeedChange);
        float accumTime = 0;    // accumulated time of commands up to ramp start
        float accumDist = 0;
        RampData ramp = _speedUtil.getRampForSpeedChange(speedSetting, 1.0f);
        int time = ramp.getRampTimeIncrement();
        ListIterator<Float> iter = ramp.speedIterator(true);

        while (iter.hasNext()) {
            changeDist = _speedUtil.getRampLengthForEntry(speedSetting, endSpeed) + bufDist;
            accumDist += _speedUtil.getDistanceOfSpeedChange(prevSetting, speedSetting, time);
            accumTime += time;
            prevSetting = speedSetting;
            speedSetting = iter.next();

            if (changeDist + accumDist >= availDist) {
                float curTrackSpeed = _speedUtil.getTrackSpeed(speedSetting);
                float remDist = changeDist + accumDist - availDist;
                if (curTrackSpeed > 0) {
                    accumTime -= remDist / curTrackSpeed;
                } else {
                    log.warn("{}: Cannot compute wait time for \"{}\" ramp to block \"{}\". trackSpeed= {}", getDisplayName(),
                            speedType, getBlockAt(idxSpeedChange).getDisplayName(), curTrackSpeed);
                }
                break;
            }
        }
        if (changeDist < accumDist) {
            float curTrackSpeed = _speedUtil.getTrackSpeed(speedSetting);
            if (curTrackSpeed > 0) {
                accumTime += (availDist - changeDist) / curTrackSpeed;
            } else {
                log.warn("{}: Cannot compute wait time for \"{}\" ramp to block \"{}\". trackSpeed= {}", getDisplayName(),
                        speedType, getBlockAt(idxSpeedChange).getDisplayName(), curTrackSpeed);
            }
        }

        int waitTime = Math.round(accumTime);

        if (log.isDebugEnabled()) {
            log.debug("{}: RAMP: Wait {}ms and travel {}mm until {}mm before entering block \"{}\" at throttle= {}. availDist={}mm",
                    getDisplayName(), waitTime, Math.round(accumDist), Math.round(changeDist),
                    getBlockAt(idxSpeedChange).getDisplayName(), speedSetting, Math.round(availDist));
        }
        rampSpeedDelay(waitTime, speedType, speedSetting, idxSpeedChange);
    }

    /**
     *  Must start the ramp in current block. ( at _idxCurrentOrder)
     *  find the time when ramp should start in this block, then use thread CommandDelay to start the ramp.
     *  Train must travel a deltaDist for a deltaTime to the start of the ramp.
     *  It travels at throttle settings of scriptSpeed(s) modified by currentSpeedType.
     *  trackSpeed(s) of these modified scriptSettings are computed from SpeedProfile
     *  waitThrottle is throttleSpeed when ramp is started. This may not be the scriptSpeed now
     *  Start with waitThrottle (modSetting) being at the entrance to the block.
     *  modSetting gives the current trackSpeed.
     *  accumulate the time and distance and determine the distance (changeDist) needed for entrance into
     *  block (at idxSpeedChange) requiring speed change to speedType
     *  final ramp should modify waitSpeed to endSpeed and must end at the exit of end block (endBlockIdx)
     *
     * @param availDist     distance available to make the ramp
     * @param changeDist    distance needed for the rmp
     * @param idxSpeedChange block order index of block to complete change before entry
     * @param speedType     speed aspect of speed change
     * @param cmdStartIdx   command index of delay
     */
    /**
     * Ratio by which scripted times are stretched when the train runs at a
     * modified speed: the scripted track speed over the actual track speed.
     * While the script has the train stopped there is nothing to stretch, so
     * the scripted times are used unchanged (as the Engineer does).
     */
    private float getScriptTimeRatio(float scriptSpeed, float trackSpeed) {
        if (trackSpeed > 0) {
            return _speedUtil.getTrackSpeed(scriptSpeed) / trackSpeed;
        }
        return 1;
    }

    private void makeScriptWait(float availDist, float changeDist, int idxSpeedChange, @Nonnull String speedType, int cmdStartIdx) {
        BlockSpeedInfo info = _speedUtil.getBlockSpeedInfo(idxSpeedChange - 1);
        int cmdEndIdx = info.getLastIndex();
        float scriptSpeed = info.getExitSpeed();
        float endSpeed = _speedUtil.modifySpeed(scriptSpeed, speedType);

        scriptSpeed = _engineer.getScriptSpeed();  // script throttle setting
        float speedSetting = _engineer.getSpeedSetting();       // current speed
        String currentSpeedType = _engineer.getSpeedType(false); // current speed type

        float modSetting = speedSetting;      // _speedUtil.modifySpeed(scriptSpeed, currentSpeedType);
        float beginTrackSpeed = _speedUtil.getTrackSpeed(modSetting);   // mm/sec track speed at modSetting
        float curTrackSpeed = beginTrackSpeed;
        if (_idxCurrentOrder == 0 && availDist > BUFFER_DISTANCE) {
            changeDist = 0;
        }
        if (log.isDebugEnabled()) {
            log.debug("{}: makespeedChange cmdIdx #{} to #{} at speedType \"{}\" to \"{}\". speedSetting={}, changeDist={}, availDist={}",
                    getDisplayName(), cmdStartIdx+1, cmdEndIdx+1, currentSpeedType, speedType, speedSetting, changeDist, availDist);
            // command index numbers biased by 1
        }
        float accumTime = 0;    // accumulated time of commands up to ramp start
        float accumDist = 0;
        Command cmd = _commands.get(cmdStartIdx).getCommand();

        if (cmd.equals(Command.NOOP) && beginTrackSpeed > 0) {
            accumTime = (availDist - changeDist) / beginTrackSpeed;
        } else {
            // time adjustment for current speed type; scripted times are used unchanged while stopped
            float timeRatio = getScriptTimeRatio(scriptSpeed, curTrackSpeed);
            float bufDist = getEntranceBufferDist(idxSpeedChange);
            float prevSetting = modSetting;    // throttle setting at the start of each interval

            // Each command runs its time after the previous one, so the train covers the interval
            // before command i at the setting from the previous speed command.
            for (int i = cmdStartIdx; i <= cmdEndIdx; i++) {
                ThrottleSetting ts = _commands.get(i);
                long time = (long)(ts.getTime() * timeRatio);
                // getDistanceOfSpeedChange takes throttle settings, not track speeds
                float dist = _speedUtil.getDistanceOfSpeedChange(prevSetting, modSetting, time);
                prevSetting = modSetting;
                if (changeDist + accumDist + dist >= availDist) {
                    // the ramp must start within this interval
                    float needDist = Math.max(0, availDist - changeDist - accumDist);
                    if (dist > 0) {
                        accumTime += time * needDist / dist;
                    }
                    break;
                }
                accumDist += dist;
                accumTime += time;
                cmd = ts.getCommand();
                if (cmd.equals(Command.SPEED)) {
                    CommandValue cmdVal = ts.getValue();
                    scriptSpeed = cmdVal.getFloat();
                    modSetting = _speedUtil.modifySpeed(scriptSpeed, currentSpeedType);
                    curTrackSpeed = _speedUtil.getTrackSpeed(modSetting);
                    changeDist = _speedUtil.getRampLengthForEntry(modSetting, endSpeed) + bufDist;
                    timeRatio = getScriptTimeRatio(scriptSpeed, curTrackSpeed);
                }

                if (log.isDebugEnabled()) {
                    log.debug("{}: cmd#{} accumTime= {} accumDist= {} changeDist= {}, throttle= {}",
                            getDisplayName(), i+1, accumTime, accumDist, changeDist, modSetting);
                }
                if (changeDist + accumDist >= availDist) {
                    // the ramp from the new speed needs more distance: start it as this command runs
                    break;
                }
                if (cmd.equals(Command.NOOP)) {
                    // speed change is supposed to start in current block
                    // start ramp in next block?
                    float remDist = availDist - changeDist - accumDist;
                    log.warn("{}: script unfit cmd#{}. Cannot compute wait time for \"{}\" ramp to block \"{}\". remDist= {}",
                            getDisplayName(), i+1, speedType, getBlockAt(idxSpeedChange).getDisplayName(), remDist);
                    accumTime -= _speedUtil.getTimeForDistance(modSetting, bufDist);
                    break;
                }
            }
        }

        int waitTime = Math.round(accumTime);

        if (log.isDebugEnabled()) {
            log.debug("{}: RAMP: Wait {}ms and travel {}mm until {}mm before entering block \"{}\" at throttle= {}. availDist={}mm",
                    getDisplayName(), waitTime, Math.round(accumDist), Math.round(changeDist),
                    getBlockAt(idxSpeedChange).getDisplayName(), modSetting, Math.round(availDist));
        }

        rampSpeedDelay(waitTime, speedType, modSetting, idxSpeedChange);
    }

    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    synchronized private void rampSpeedDelay (long waitTime, String speedType, float waitSpeed, int idxSpeedChange) {
        int endBlockIdx = idxSpeedChange - 1;
        waitTime -= 50;     // Subtract a bit
        if( waitTime < 0) {
            rampSpeedTo(speedType, endBlockIdx);   // do it now on this thread.
            return;
        }
        String reason;
        if(_waitForSignal) {
            reason = Bundle.getMessage("Signal");
        } else if (_waitForWarrant) {
            reason = Bundle.getMessage("Warrant");
        } else if (_waitForBlock) {
            reason = Bundle.getMessage("Occupancy");
        } else {
            reason = Bundle.getMessage("Signal");
        }

        if (_trace || log.isDebugEnabled()) {
            if (log.isDebugEnabled()) {
                log.info("Train \"{}\" needs speed decrease to \"{}\" from \"{}\" for {} before entering block \"{}\"",
                        getTrainName(), speedType, _engineer.getSpeedType(true), reason, getBlockAt(idxSpeedChange).getDisplayName());
           }
        }
        if (_delayCommand != null) {
            if (_delayCommand.isDuplicate(speedType, waitTime, endBlockIdx)) {
                return;
            }
            cancelDelayRamp();
        }
        _delayCommand = new CommandDelay(speedType, waitTime, waitSpeed, endBlockIdx);
        _delayCommand.start();
        if (log.isDebugEnabled()) {
            log.debug("{}: CommandDelay: will wait {}ms, then Ramp to {} in block {}.",
                    getDisplayName(), waitTime, speedType, getBlockAt(endBlockIdx).getDisplayName());
        }
        String blkName = getBlockAt(endBlockIdx).getDisplayName();
        if (_trace || log.isDebugEnabled()) {
            log.info(Bundle.getMessage("RampBegin", getTrainName(), reason, blkName, speedType, waitTime));
        }
    }

    protected void downRampBegun(int endBlockIdx) {
        OBlock block = getBlockAt(endBlockIdx + 1);
        if (block != null) {
            _rampBlkOccupied = block.isOccupied();
        } else {
            _rampBlkOccupied = true;
        }
    }

    protected void downRampDone(boolean stop, boolean halted, String speedType, int endBlockIdx) {
        if (_idxCurrentOrder < endBlockIdx) {
            return;     // overrun not possible.
        }
        // look for overruns
        int nextIdx = endBlockIdx + 1;
        if (nextIdx > 0 && nextIdx < _orders.size()) {
            BlockOrder bo = getBlockOrderAt(nextIdx);
            OBlock block = bo.getBlock();
            if (block.isOccupied() && !_rampBlkOccupied) {
                // Occupied now, but not occupied by another train at start of ramp.
                if (!checkForOverrun(block) ) {    // Not us. check if something should have us wait
                    Warrant w = block.getWarrant();
                    _overrun = true;    // endBlock occupied during ramp down. Speed overrun!
                    if (w != null && !w.equals(this)) { // probably redundant
                        _waitForWarrant = true;
                        setStoppingBlock(nextIdx);
                    } else if (Stop.equals(BlockOrder.getPermissibleSpeedAt(bo))) { // probably redundant
                        _waitForSignal = true;
                        setProtectingSignal(nextIdx);
                    } else {
                        _waitForBlock = true;
                    }
                }
                makeOverrunMessage(bo);
            }   // case where occupied at start of ramp is indeterminate
        }
    }

    @SuppressFBWarnings(value="SLF4J_FORMAT_SHOULD_BE_CONST", justification="False assumption")
    private void makeOverrunMessage(BlockOrder curBlkOrder) {
        OBlock curBlock = curBlkOrder.getBlock();
        String name = null;
        if (_waitForSignal) {
            NamedBean signal = curBlkOrder.getSignal();
            if (signal!=null) {
                name = signal.getDisplayName();
            } else {
                name = curBlock.getDisplayName();
            }
            _overrun = true;
            String entrySpeedType = BlockOrder.getPermissibleSpeedAt(curBlkOrder); // expected speed type for this block
            log.info(Bundle.getMessage("SignalOverrun", getTrainName(), entrySpeedType, name));
            fireRunStatus("SignalOverrun", name, entrySpeedType); // message of speed violation
            return;
        }
        String bundleKey = null;
        if (_waitForWarrant) {
            bundleKey = PROPERTY_WARRANT_OVERRUN;
            Warrant w = curBlock.getWarrant();
            if (w != null) {
                name = w.getDisplayName();
            }
        } else if (_waitForBlock){
            bundleKey = PROPERTY_OCCUPY_OVERRUN;
            name = (String)curBlock.getValue();
        }
        if (name == null) {
            name = Bundle.getMessage("unknownTrain");
        }
        if (bundleKey != null) {
            _overrun = true;
            log.info(Bundle.getMessage(bundleKey, getTrainName(), curBlock.getDisplayName(), name));
            fireRunStatus(bundleKey, curBlock.getDisplayName(), name); // message of speed violation
        } else {
            log.error("Train \"{}\" entered stopping block \"{}\" for unknown reason on warrant {}!",
                getTrainName(), curBlock.getDisplayName(), getDisplayName());
        }
    }

    /**
     * {@inheritDoc}
     * <p>
     * This implementation tests that
     * {@link jmri.NamedBean#getSystemName()}
     * is equal for this and obj.
     * To allow a warrant to run with sections, DccLocoAddress is included to test equality
     *
     * @param obj the reference object with which to compare.
     * @return {@code true} if this object is the same as the obj argument;
     *         {@code false} otherwise.
     */
    @Override
    public boolean equals(Object obj) {
        if (obj == null) return false; // by contract

        if (obj instanceof Warrant) {  // NamedBeans are not equal to things of other types
            Warrant b = (Warrant) obj;
            DccLocoAddress addr = this._speedUtil.getDccAddress();
            if (addr == null) {
                if (b._speedUtil.getDccAddress() != null) {
                    return false;
                }
                return (this.getSystemName().equals(b.getSystemName()));
            }
            return (this.getSystemName().equals(b.getSystemName()) && addr.equals(b._speedUtil.getDccAddress()));
        }
        return false;
    }

    /**
     * {@inheritDoc}
     *
     * @return hash code value is based on the system name and DccLocoAddress.
     */
    @Override
    public int hashCode() {
        return (getSystemName().concat(_speedUtil.getDccAddress().toString())).hashCode();
    }

    @Override
    public List<NamedBeanUsageReport> getUsageReport(NamedBean bean) {
        List<NamedBeanUsageReport> report = new ArrayList<>();
        if (bean != null) {
            if (bean.equals(getBlockingWarrant())) {
                report.add(new NamedBeanUsageReport("WarrantBlocking"));
            }
            getBlockOrders().forEach((blockOrder) -> {
                if (bean.equals(blockOrder.getBlock())) {
                    report.add(new NamedBeanUsageReport("WarrantBlock"));
                }
                if (bean.equals(blockOrder.getSignal())) {
                    report.add(new NamedBeanUsageReport("WarrantSignal"));
                }
            });
        }
        return report;
    }

    private static final org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(Warrant.class);
}