// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.client.widgets.nonpublic;

import org.litesoft.GWT.client.*;
import org.litesoft.commonfoundation.base.*;
import org.litesoft.core.delayed.*;

public class EscalatingProcess implements TimedRunnable {
    private long mDelay = 0;
    private DelayedProcess mProcess;

    public EscalatingProcess( DelayedProcess pProcess ) {
        Confirm.isNotNull( "Process", mProcess = pProcess );
    }

    private synchronized long initDelay() {
        return mDelay = 125;
    }

    private synchronized long escalateDelay() {
        return (1000 <= (mDelay += mDelay)) ? mDelay : (mDelay = 1000);
    }

    public synchronized void cancel() {
        mDelay = 0;
    }

    public synchronized boolean isLive() {
        return (mDelay != 0);
    }

    public void schedule() {
        TimedRunnableManager.INSTANCE.cancel( this );
        TimedRunnableManager.INSTANCE.runIn( this, initDelay() );
    }

    @Override
    public Again runOnce() {
        if ( isLive() ) {
            if ( !mProcess.process() ) {
                return new RunAgainIn( escalateDelay() );
            }
            cancel();
        }
        return null;
    }
}