/*
 * The MIT License
 *
 * Copyright (c) 2010, InfraDNA, Inc.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */
package hudson.model.queue;

/**
 * A concurrency primitive that waits for N number of threads to synchronize.
 * If any of the threads are interrupted while waiting for the completion of the condition,
 * then all the involved threads get interrupted.
 *
 * @author Kohsuke Kawaguchi
 */
class Latch {
    private final int n;
    private int i=0;
    private boolean interrupted;

    public Latch(int n) {
        this.n = n;
    }

    public synchronized void abort() {
        interrupted = true;
        notifyAll();
    }


    public synchronized void synchronize() throws InterruptedException {
        check(n);

        boolean success=false;
        try {
            onCriteriaMet();
            success=true;
        } finally {
            if (!success)
                abort();
        }

        check(n*2);
    }

    private void check(int threshold) throws InterruptedException {
        i++;
        if (i==threshold) {
            notifyAll();
        } else {
            while (i<threshold && !interrupted) {
                try {
                    wait();
                } catch (InterruptedException e) {
                    interrupted = true;
                    notifyAll();
                    throw e;
                }
            }
        }

        // all of us either leave normally or get interrupted
        if (interrupted)
            throw new InterruptedException();
    }

    protected void onCriteriaMet() throws InterruptedException {}
}

@@ -1164,16 +1164,47 @@
 queue;%0A%0A
+import hudson.AbortException;%0A%0A
 /**%0A * A
@@ -1523,22 +1523,202 @@
     
-private boolea
+/**%0A     * If the synchronization on the latch is aborted/interrupted,%0A     * point to the stack trace where that happened. If null,%0A     * no interruption happened.%0A     */%0A    private Exceptio
 n in
@@ -1835,36 +1835,52 @@
   interrupted = 
-true
+new AbortException()
 ;%0A        notify
@@ -2380,17 +2380,16 @@
 hold && 
-!
 interrup
@@ -2391,16 +2391,22 @@
 errupted
+==null
 ) %7B%0A    
@@ -2536,19 +2536,16 @@
 upted = 
-tru
 e;%0A     
@@ -2729,16 +2729,22 @@
 errupted
+!=null
 )%0A      
@@ -2755,16 +2755,38 @@
   throw 
+(InterruptedException)
 new Inte
@@ -2799,24 +2799,47 @@
 dException()
+.initCause(interrupted)
 ;%0A    %7D%0A%0A   

use Exception instead of boolean to capture more information about how the latch was aborted.