Run.java 60.0 KB
Newer Older
K
kohsuke 已提交
1 2 3
/*
 * The MIT License
 * 
4 5
 * Copyright (c) 2004-2010, Sun Microsystems, Inc., Kohsuke Kawaguchi,
 * Daniel Dyer, Red Hat, Inc., Tom Huybrechts
K
kohsuke 已提交
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
 * 
 * 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.
 */
K
kohsuke 已提交
25 26
package hudson.model;

27 28
import hudson.AbortException;
import hudson.BulkChange;
K
kohsuke 已提交
29
import hudson.EnvVars;
K
kohsuke 已提交
30
import hudson.ExtensionPoint;
K
kohsuke 已提交
31
import hudson.FeedAdapter;
32
import hudson.FilePath;
K
kohsuke 已提交
33 34
import hudson.Util;
import hudson.XmlFile;
35
import hudson.cli.declarative.CLIMethod;
K
kohsuke 已提交
36
import hudson.console.AnnotatedLargeText;
37
import hudson.console.ConsoleNote;
38 39
import hudson.matrix.MatrixBuild;
import hudson.matrix.MatrixRun;
40
import hudson.model.listeners.RunListener;
41
import hudson.model.listeners.SaveableListener;
K
kohsuke 已提交
42
import hudson.search.SearchIndexBuilder;
43 44 45 46 47
import hudson.security.ACL;
import hudson.security.AccessControlled;
import hudson.security.Permission;
import hudson.security.PermissionGroup;
import hudson.tasks.LogRotator;
48
import hudson.tasks.Mailer;
K
kohsuke 已提交
49 50
import hudson.tasks.BuildWrapper;
import hudson.tasks.BuildStep;
K
kohsuke 已提交
51
import hudson.tasks.test.AbstractTestResultAction;
K
kohsuke 已提交
52
import hudson.util.FlushProofOutputStream;
K
kohsuke 已提交
53
import hudson.util.IOException2;
K
kohsuke 已提交
54
import hudson.util.LogTaskListener;
55
import hudson.util.XStream2;
56
import hudson.util.ProcessTree;
K
kohsuke 已提交
57

58
import java.io.BufferedReader;
K
kohsuke 已提交
59
import java.io.File;
60
import java.io.FileInputStream;
K
kohsuke 已提交
61
import java.io.IOException;
K
kohsuke 已提交
62
import java.io.InputStream;
63
import java.io.InputStreamReader;
K
kohsuke 已提交
64
import java.io.PrintWriter;
65
import java.io.Reader;
K
kohsuke 已提交
66
import java.io.Writer;
67
import java.nio.charset.Charset;
68
import java.text.DateFormat;
K
kohsuke 已提交
69 70 71
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
72
import java.util.Arrays;
K
kohsuke 已提交
73
import java.util.Calendar;
74
import java.util.Collections;
K
kohsuke 已提交
75
import java.util.Comparator;
76
import java.util.Date;
K
kohsuke 已提交
77
import java.util.GregorianCalendar;
78
import java.util.HashMap;
79
import java.util.LinkedHashMap;
80
import java.util.LinkedList;
K
kohsuke 已提交
81
import java.util.List;
82
import java.util.Locale;
K
kohsuke 已提交
83
import java.util.Map;
K
kohsuke 已提交
84 85
import java.util.Set;
import java.util.HashSet;
86
import java.util.logging.Level;
K
kohsuke 已提交
87
import java.util.logging.Logger;
88 89 90 91 92
import java.util.zip.GZIPInputStream;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletResponse;

K
kohsuke 已提交
93 94
import org.apache.commons.io.input.NullInputStream;
import org.apache.commons.jelly.XMLOutput;
95 96 97 98 99 100 101
import org.kohsuke.stapler.QueryParameter;
import org.kohsuke.stapler.StaplerRequest;
import org.kohsuke.stapler.StaplerResponse;
import org.kohsuke.stapler.export.Exported;
import org.kohsuke.stapler.export.ExportedBean;

import com.thoughtworks.xstream.XStream;
K
kohsuke 已提交
102 103 104 105 106 107 108 109 110 111

/**
 * A particular execution of {@link Job}.
 *
 * <p>
 * Custom {@link Run} type is always used in conjunction with
 * a custom {@link Job} type, so there's no separate registration
 * mechanism for custom {@link Run} types.
 *
 * @author Kohsuke Kawaguchi
K
kohsuke 已提交
112
 * @see RunListener
K
kohsuke 已提交
113
 */
K
kohsuke 已提交
114
@ExportedBean
K
kohsuke 已提交
115
public abstract class Run <JobT extends Job<JobT,RunT>,RunT extends Run<JobT,RunT>>
116
        extends Actionable implements ExtensionPoint, Comparable<RunT>, AccessControlled, PersistenceRoot, DescriptorByNameOwner {
K
kohsuke 已提交
117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133

    protected transient final JobT project;

    /**
     * Build number.
     *
     * <p>
     * In earlier versions &lt; 1.24, this number is not unique nor continuous,
     * but going forward, it will, and this really replaces the build id.
     */
    public /*final*/ int number;

    /**
     * Previous build. Can be null.
     * These two fields are maintained and updated by {@link RunMap}.
     */
    protected volatile transient RunT previousBuild;
K
kohsuke 已提交
134

K
kohsuke 已提交
135 136 137 138 139
    /**
     * Next build. Can be null.
     */
    protected volatile transient RunT nextBuild;

K
kohsuke 已提交
140 141 142 143 144
    /**
     * Pointer to the next younger build in progress. This data structure is lazily updated,
     * so it may point to the build that's already completed. This pointer is set to 'this'
     * if the computation determines that everything earlier than this build is already completed.
     */
145
    /* does not compile on JDK 7: private*/ volatile transient RunT previousBuildInProgress;
K
kohsuke 已提交
146

K
kohsuke 已提交
147 148 149
    /**
     * When the build is scheduled.
     */
150
    protected transient final long timestamp;
K
kohsuke 已提交
151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168

    /**
     * The build result.
     * This value may change while the state is in {@link State#BUILDING}.
     */
    protected volatile Result result;

    /**
     * Human-readable description. Can be null.
     */
    protected volatile String description;

    /**
     * The current build state.
     */
    protected volatile transient State state;

    private static enum State {
169 170 171
        /**
         * Build is created/queued but we haven't started building it.
         */
K
kohsuke 已提交
172
        NOT_STARTED,
173 174 175
        /**
         * Build is in progress.
         */
K
kohsuke 已提交
176
        BUILDING,
177 178 179 180 181 182 183 184
        /**
         * Build is completed now, and the status is determined,
         * but log files are still being updated.
         */
        POST_PRODUCTION,
        /**
         * Build is completed now, and log file is closed.
         */
K
kohsuke 已提交
185 186 187 188 189 190 191 192
        COMPLETED
    }

    /**
     * Number of milli-seconds it took to run this build.
     */
    protected long duration;

193 194 195 196 197 198 199 200
    /**
     * Charset in which the log file is written.
     * For compatibility reason, this field may be null.
     * For persistence, this field is string and not {@link Charset}.
     *
     * @see #getCharset()
     * @since 1.257
     */
201
    protected String charset;
202

K
kohsuke 已提交
203 204 205 206 207
    /**
     * Keeps this log entries.
     */
    private boolean keepLog;

K
kohsuke 已提交
208 209 210 211 212 213
    /**
     * If the build is in progress, remember {@link Runner} that's running it.
     * This field is not persisted.
     */
    private volatile transient Runner runner;

214 215 216 217 218 219 220
    protected static final ThreadLocal<SimpleDateFormat> ID_FORMATTER =
            new ThreadLocal<SimpleDateFormat>() {
                @Override
                protected SimpleDateFormat initialValue() {
                    return new SimpleDateFormat("yyyy-MM-dd_HH-mm-ss");
                }
            };
K
kohsuke 已提交
221 222 223 224 225 226 227 228 229 230 231 232 233 234

    /**
     * Creates a new {@link Run}.
     */
    protected Run(JobT job) throws IOException {
        this(job, new GregorianCalendar());
        this.number = project.assignBuildNumber();
    }

    /**
     * Constructor for creating a {@link Run} object in
     * an arbitrary state.
     */
    protected Run(JobT job, Calendar timestamp) {
235 236 237 238
        this(job,timestamp.getTimeInMillis());
    }

    protected Run(JobT job, long timestamp) {
K
kohsuke 已提交
239 240 241 242 243 244 245 246 247
        this.project = job;
        this.timestamp = timestamp;
        this.state = State.NOT_STARTED;
    }

    /**
     * Loads a run from a log file.
     */
    protected Run(JobT project, File buildDir) throws IOException {
248
        this(project, parseTimestampFromBuildDir(buildDir));
K
kohsuke 已提交
249
        this.previousBuildInProgress = _this(); // loaded builds are always completed
250 251 252 253 254
        this.state = State.COMPLETED;
        this.result = Result.FAILURE;  // defensive measure. value should be overwritten by unmarshal, but just in case the saved data is inconsistent
        getDataFile().unmarshal(this); // load the rest of the data
    }

255
    /*package*/ static long parseTimestampFromBuildDir(File buildDir) throws IOException {
K
kohsuke 已提交
256
        try {
257
            return ID_FORMATTER.get().parse(buildDir.getName()).getTime();
K
kohsuke 已提交
258 259 260 261 262 263 264
        } catch (ParseException e) {
            throw new IOException2("Invalid directory name "+buildDir,e);
        } catch (NumberFormatException e) {
            throw new IOException2("Invalid directory name "+buildDir,e);
        }
    }

K
kohsuke 已提交
265 266 267 268 269 270 271 272
    /**
     * Obtains 'this' in a more type safe signature.
     */
    @SuppressWarnings({"unchecked"})
    private RunT _this() {
        return (RunT)this;
    }

273 274 275 276 277 278 279
    /**
     * Ordering based on build numbers.
     */
    public int compareTo(RunT that) {
        return this.number - that.number;
    }

K
kohsuke 已提交
280 281 282 283 284
    /**
     * Returns the build result.
     *
     * <p>
     * When a build is {@link #isBuilding() in progress}, this method
285
     * returns an intermediate result.
K
kohsuke 已提交
286
     */
K
kohsuke 已提交
287
    @Exported
K
kohsuke 已提交
288
    public Result getResult() {
K
kohsuke 已提交
289 290 291 292 293 294 295 296 297 298 299 300 301
        return result;
    }

    public void setResult(Result r) {
        // state can change only when we are building
        assert state==State.BUILDING;

        StackTraceElement caller = findCaller(Thread.currentThread().getStackTrace(),"setResult");


        // result can only get worse
        if(result==null) {
            result = r;
302
            LOGGER.fine(toString()+" : result is set to "+r+" by "+caller);
K
kohsuke 已提交
303 304
        } else {
            if(r.isWorseThan(result)) {
305
                LOGGER.fine(toString()+" : result is set to "+r+" by "+caller);
K
kohsuke 已提交
306 307 308 309 310
                result = r;
            }
        }
    }

311
    /**
312
     * Gets the subset of {@link #getActions()} that consists of {@link BuildBadgeAction}s.
313 314 315 316 317 318 319 320 321 322
     */
    public List<BuildBadgeAction> getBadgeActions() {
        List<BuildBadgeAction> r = null;
        for (Action a : getActions()) {
            if(a instanceof BuildBadgeAction) {
                if(r==null)
                    r = new ArrayList<BuildBadgeAction>();
                r.add((BuildBadgeAction)a);
            }
        }
323 324 325 326 327
        if(isKeepLog()) {
            if(r==null)
                r = new ArrayList<BuildBadgeAction>();
            r.add(new KeepLogBuildBadge());
        }
328 329 330 331
        if(r==null)     return Collections.emptyList();
        else            return r;
    }

K
kohsuke 已提交
332 333 334 335 336 337 338 339 340 341 342
    private StackTraceElement findCaller(StackTraceElement[] stackTrace, String callee) {
        for(int i=0; i<stackTrace.length-1; i++) {
            StackTraceElement e = stackTrace[i];
            if(e.getMethodName().equals(callee))
                return stackTrace[i+1];
        }
        return null; // not found
    }

    /**
     * Returns true if the build is not completed yet.
343
     * This includes "not started yet" state.
K
kohsuke 已提交
344
     */
K
kohsuke 已提交
345
    @Exported
K
kohsuke 已提交
346
    public boolean isBuilding() {
347 348 349 350 351 352 353 354
        return state.compareTo(State.POST_PRODUCTION) < 0;
    }

    /**
     * Returns true if the log file is still being updated.
     */
    public boolean isLogUpdated() {
        return state.compareTo(State.COMPLETED) < 0;
K
kohsuke 已提交
355 356 357 358 359 360 361 362 363
    }

    /**
     * Gets the {@link Executor} building this job, if it's being built.
     * Otherwise null.
     */
    public Executor getExecutor() {
        for( Computer c : Hudson.getInstance().getComputers() ) {
            for (Executor e : c.getExecutors()) {
364
                if(e.getCurrentExecutable()==this)
K
kohsuke 已提交
365 366 367 368 369 370
                    return e;
            }
        }
        return null;
    }

371 372 373 374 375 376 377 378 379 380
    /**
     * Gets the charset in which the log file is written.
     * @return never null.
     * @since 1.257
     */
    public final Charset getCharset() {
        if(charset==null)   return Charset.defaultCharset();
        return Charset.forName(charset);
    }

K
kohsuke 已提交
381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397
    /**
     * Returns the {@link Cause}s that tirggered a build.
     *
     * <p>
     * If a build sits in the queue for a long time, multiple build requests made during this period
     * are all rolled up into one build, hence this method may return a list.
     *
     * @return
     *      can be empty but never null. read-only.
     * @since 1.321
     */
    public List<Cause> getCauses() {
        CauseAction a = getAction(CauseAction.class);
        if (a==null)    return Collections.emptyList();
        return Collections.unmodifiableList(a.getCauses());
    }

K
kohsuke 已提交
398 399 400 401 402 403 404 405 406 407 408 409
    /**
     * Returns a {@link Cause} of a particular type.
     *
     * @since 1.362
     */
    public <T extends Cause> T getCause(Class<T> type) {
        for (Cause c : getCauses())
            if (type.isInstance(c))
                return type.cast(c);
        return null;
    }

K
kohsuke 已提交
410 411 412 413 414
    /**
     * Returns true if this log file should be kept and not deleted.
     *
     * This is used as a signal to the {@link LogRotator}.
     */
K
kohsuke 已提交
415
    @Exported
416 417 418 419 420 421 422 423 424 425
    public final boolean isKeepLog() {
        return getWhyKeepLog()!=null;
    }

    /**
     * If {@link #isKeepLog()} returns true, returns a human readable
     * one-line string that explains why it's being kept.
     */
    public String getWhyKeepLog() {
        if(keepLog)
K
i18n  
kohsuke 已提交
426
            return Messages.Run_MarkedExplicitly();
427
        return null;    // not marked at all
K
kohsuke 已提交
428 429 430 431 432 433 434 435 436 437 438 439
    }

    /**
     * The project this build is for.
     */
    public JobT getParent() {
        return project;
    }

    /**
     * When the build is scheduled.
     */
K
kohsuke 已提交
440
    @Exported
K
kohsuke 已提交
441
    public Calendar getTimestamp() {
442 443 444
        GregorianCalendar c = new GregorianCalendar();
        c.setTimeInMillis(timestamp);
        return c;
K
kohsuke 已提交
445 446
    }

K
kohsuke 已提交
447 448 449 450 451 452 453 454 455 456 457 458 459 460
    /**
     * Same as {@link #getTimestamp()} but in a different type.
     */
    public final Date getTime() {
        return new Date(timestamp);
    }

    /**
     * Same as {@link #getTimestamp()} but in a different type, that is since the time of the epoc.
     */
    public final long getTimeInMillis() {
        return timestamp;
    }

K
kohsuke 已提交
461
    @Exported
K
kohsuke 已提交
462 463 464 465
    public String getDescription() {
        return description;
    }

466

467 468 469 470 471 472 473 474 475 476 477
    /**
     * Returns the length-limited description.
     * @return The length-limited description.
     */
    public String getTruncatedDescription() {
        final int maxDescrLength = 100;
        if (description == null || description.length() < maxDescrLength) {
            return description;
        }

        final String ending = "...";
478
        final int sz = description.length(), maxTruncLength = maxDescrLength - ending.length();
479 480 481 482

        boolean inTag = false;
        int displayChars = 0;
        int lastTruncatablePoint = -1;
483

484 485 486 487 488 489
        for (int i=0; i<sz; i++) {
            char ch = description.charAt(i);
            if(ch == '<') {
                inTag = true;
            } else if (ch == '>') {
                inTag = false;
490
                if (displayChars <= maxTruncLength) {
491 492 493 494 495
                    lastTruncatablePoint = i + 1;
                }
            }
            if (!inTag) {
                displayChars++;
496 497
                if (displayChars <= maxTruncLength && ch == ' ') {
                    lastTruncatablePoint = i;
498 499
                }
            }
500 501
        }

502
        String truncDesc = description;
503 504 505 506 507

        // Could not find a preferred truncable index, force a trunc at maxTruncLength
        if (lastTruncatablePoint == -1)
            lastTruncatablePoint = maxTruncLength;

508
        if (displayChars >= maxDescrLength) {
509
            truncDesc = truncDesc.substring(0, lastTruncatablePoint) + ending;
510 511
        }
        
512
        return truncDesc;
513
        
514 515
    }

K
kohsuke 已提交
516
    /**
517
     * Gets the string that says how long since this build has started.
K
kohsuke 已提交
518 519 520 521 522
     *
     * @return
     *      string like "3 minutes" "1 day" etc.
     */
    public String getTimestampString() {
523
        long duration = new GregorianCalendar().getTimeInMillis()-timestamp;
K
i18n  
kohsuke 已提交
524
        return Util.getPastTimeString(duration);
K
kohsuke 已提交
525 526 527 528 529 530
    }

    /**
     * Returns the timestamp formatted in xs:dateTime.
     */
    public String getTimestampString2() {
531
        return Util.XS_DATETIME_FORMATTER.format(new Date(timestamp));
K
kohsuke 已提交
532 533 534 535 536 537
    }

    /**
     * Gets the string that says how long the build took to run.
     */
    public String getDurationString() {
538
        if(isBuilding())
539 540
            return Messages.Run_InProgressDuration(
                    Util.getTimeSpanString(System.currentTimeMillis()-timestamp));
K
kohsuke 已提交
541 542 543 544 545 546
        return Util.getTimeSpanString(duration);
    }

    /**
     * Gets the millisecond it took to build.
     */
K
kohsuke 已提交
547
    @Exported
K
kohsuke 已提交
548 549 550 551 552 553 554
    public long getDuration() {
        return duration;
    }

    /**
     * Gets the icon color for display.
     */
555
    public BallColor getIconColor() {
K
kohsuke 已提交
556 557
        if(!isBuilding()) {
            // already built
K
kohsuke 已提交
558
            return getResult().color;
K
kohsuke 已提交
559 560 561
        }

        // a new build is in progress
562
        BallColor baseColor;
K
kohsuke 已提交
563
        if(previousBuild==null)
564
            baseColor = BallColor.GREY;
K
kohsuke 已提交
565 566 567
        else
            baseColor = previousBuild.getIconColor();

568
        return baseColor.anime();
K
kohsuke 已提交
569 570 571 572 573 574 575 576 577
    }

    /**
     * Returns true if the build is still queued and hasn't started yet.
     */
    public boolean hasntStartedYet() {
        return state ==State.NOT_STARTED;
    }

578
    @Override
K
kohsuke 已提交
579
    public String toString() {
K
kohsuke 已提交
580 581 582
        return getFullDisplayName();
    }

583
    @Exported
K
kohsuke 已提交
584
    public String getFullDisplayName() {
585
        return project.getFullDisplayName()+" #"+number;
K
kohsuke 已提交
586 587 588 589 590 591
    }

    public String getDisplayName() {
        return "#"+number;
    }

K
kohsuke 已提交
592
    @Exported(visibility=2)
K
kohsuke 已提交
593 594 595 596 597 598 599 600
    public int getNumber() {
        return number;
    }

    public RunT getPreviousBuild() {
        return previousBuild;
    }

601 602 603 604 605 606 607 608 609 610
    /**
     * Gets the most recent {@linkplain #isBuilding() completed} build excluding 'this' Run itself.
     */
    public final RunT getPreviousCompletedBuild() {
        RunT r=getPreviousBuild();
        while (r!=null && r.isBuilding())
            r=r.getPreviousBuild();
        return r;
    }

K
kohsuke 已提交
611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651
    /**
     * Obtains the next younger build in progress. It uses a skip-pointer so that we can compute this without
     * O(n) computation time. This method also fixes up the skip list as we go, in a way that's concurrency safe.
     *
     * <p>
     * We basically follow the existing skip list, and wherever we find a non-optimal pointer, we remember them
     * in 'fixUp' and update them later.
     */
    public final RunT getPreviousBuildInProgress() {
        if(previousBuildInProgress==this)   return null;    // the most common case

        List<RunT> fixUp = new ArrayList<RunT>();
        RunT r = _this(); // 'r' is the source of the pointer (so that we can add it to fix up if we find that the target of the pointer is inefficient.)
        RunT answer;
        while (true) {
            RunT n = r.previousBuildInProgress;
            if (n==null) {// no field computed yet.
                n=r.getPreviousBuild();
                fixUp.add(r);
            }
            if (r==n || n==null) {
                // this indicates that we know there's no build in progress beyond this point
                answer = null;
                break;
            }
            if (n.isBuilding()) {
                // we now know 'n' is the target we wanted
                answer = n;
                break;
            }

            fixUp.add(r);   // r contains the stale 'previousBuildInProgress' back pointer
            r = n;
        }

        // fix up so that the next look up will run faster
        for (RunT f : fixUp)
            f.previousBuildInProgress = answer==null ? f : answer;
        return answer;
    }

652 653 654 655 656
    /**
     * Returns the last build that was actually built - i.e., skipping any with Result.NOT_BUILT
     */
    public RunT getPreviousBuiltBuild() {
        RunT r=previousBuild;
657 658
        // in certain situations (aborted m2 builds) r.getResult() can still be null, although it should theoretically never happen
        while( r!=null && (r.getResult() == null || r.getResult()==Result.NOT_BUILT) )
659 660 661 662
            r=r.previousBuild;
        return r;
    }

K
kohsuke 已提交
663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686
    /**
     * Returns the last build that didn't fail before this build.
     */
    public RunT getPreviousNotFailedBuild() {
        RunT r=previousBuild;
        while( r!=null && r.getResult()==Result.FAILURE )
            r=r.previousBuild;
        return r;
    }

    /**
     * Returns the last failed build before this build.
     */
    public RunT getPreviousFailedBuild() {
        RunT r=previousBuild;
        while( r!=null && r.getResult()!=Result.FAILURE )
            r=r.previousBuild;
        return r;
    }

    public RunT getNextBuild() {
        return nextBuild;
    }

K
kohsuke 已提交
687 688 689 690 691 692
    /**
     * Returns the URL of this {@link Run}, relative to the context root of Hudson.
     *
     * @return
     *      String like "job/foo/32/" with trailing slash but no leading slash. 
     */
K
kohsuke 已提交
693 694 695 696 697 698
    // I really messed this up. I'm hoping to fix this some time
    // it shouldn't have trailing '/', and instead it should have leading '/'
    public String getUrl() {
        return project.getUrl()+getNumber()+'/';
    }

699 700 701 702 703 704 705 706 707
    /**
     * Obtains the absolute URL to this build.
     *
     * @deprecated
     *      This method shall <b>NEVER</b> be used during HTML page rendering, as it won't work with
     *      network set up like Apache reverse proxy.
     *      This method is only intended for the remote API clients who cannot resolve relative references
     *      (even this won't work for the same reason, which should be fixed.)
     */
K
kohsuke 已提交
708
    @Exported(visibility=2,name="url")
709 710 711 712
    public final String getAbsoluteUrl() {
        return project.getAbsoluteUrl()+getNumber()+'/';
    }

713 714 715 716
    public final String getSearchUrl() {
        return getNumber()+"/";
    }

K
kohsuke 已提交
717 718 719
    /**
     * Unique ID of this build.
     */
K
kohsuke 已提交
720
    @Exported
K
kohsuke 已提交
721
    public String getId() {
722
        return ID_FORMATTER.get().format(new Date(timestamp));
K
kohsuke 已提交
723
    }
K
kohsuke 已提交
724 725 726 727 728 729 730 731 732
    
    /**
     * Get the date formatter used to convert the directory name in to a timestamp
     * This is nasty exposure of private data, but needed all the time the directory
     * containing the build is used as it's timestamp.
     */
    public static DateFormat getIDFormatter() {
    	return ID_FORMATTER.get();
    }
K
kohsuke 已提交
733

734 735 736 737
    public Descriptor getDescriptorByName(String className) {
        return Hudson.getInstance().getDescriptorByName(className);
    }

K
kohsuke 已提交
738 739 740 741 742
    /**
     * Root directory of this {@link Run} on the master.
     *
     * Files related to this {@link Run} should be stored below this directory.
     */
K
kohsuke 已提交
743 744 745 746 747 748 749 750 751 752 753 754 755 756
    public File getRootDir() {
        File f = new File(project.getBuildDir(),getId());
        f.mkdirs();
        return f;
    }

    /**
     * Gets the directory where the artifacts are archived.
     */
    public File getArtifactsDir() {
        return new File(getRootDir(),"archive");
    }

    /**
757
     * Gets the artifacts (relative to {@link #getArtifactsDir()}.
K
kohsuke 已提交
758
     */
759
    @Exported
K
kohsuke 已提交
760
    public List<Artifact> getArtifacts() {
761 762 763 764 765 766 767
        return getArtifactsUpTo(Integer.MAX_VALUE);
    }

    /**
     * Gets the first N artifacts.
     */
    public List<Artifact> getArtifactsUpTo(int n) {
768
        ArtifactList r = new ArtifactList();
769
        addArtifacts(getArtifactsDir(),"","",r,null,n);
770
        r.computeDisplayName();
K
kohsuke 已提交
771 772 773 774 775 776 777 778 779 780
        return r;
    }

    /**
     * Returns true if this run has any artifacts.
     *
     * <p>
     * The strange method name is so that we can access it from EL.
     */
    public boolean getHasArtifacts() {
781
        return !getArtifactsUpTo(1).isEmpty();
K
kohsuke 已提交
782 783
    }

784
    private int addArtifacts( File dir, String path, String pathHref, ArtifactList r, Artifact parent, int upTo ) {
K
kohsuke 已提交
785
        String[] children = dir.list();
786
        if(children==null)  return 0;
787
        Arrays.sort(children, String.CASE_INSENSITIVE_ORDER);
788 789

        int n = 0;
790
        for (String child : children) {
791 792
            String childPath = path + child;
            String childHref = pathHref + Util.rawEncode(child);
K
kohsuke 已提交
793
            File sub = new File(dir, child);
794 795
            boolean collapsed = (children.length==1 && parent!=null);
            Artifact a;
796 797 798 799 800 801 802 803 804 805 806
            if (collapsed) {
                // Collapse single items into parent node where possible:
                a = new Artifact(parent.getFileName() + '/' + child, childPath,
                                 sub.isDirectory() ? null : childHref, parent.getTreeNodeId());
                r.tree.put(a, r.tree.remove(parent));
            } else {
                // Use null href for a directory:
                a = new Artifact(child, childPath,
                                 sub.isDirectory() ? null : childHref, "n" + ++r.idSeq);
                r.tree.put(a, parent!=null ? parent.getTreeNodeId() : null);
            }
K
kohsuke 已提交
807
            if (sub.isDirectory()) {
808
                n += addArtifacts(sub, childPath + '/', childHref + '/', r, a, upTo-n);
809
                if (n>=upTo) break;
K
kohsuke 已提交
810
            } else {
811 812
                // Don't store collapsed path in ArrayList (for correct data in external API)
                r.add(collapsed ? new Artifact(child, a.relativePath, a.href, a.treeNodeId) : a);
813
                if (++n>=upTo) break;;
K
kohsuke 已提交
814
            }
815
        }
816
        return n;
K
kohsuke 已提交
817 818
    }

819 820 821 822 823 824 825 826 827 828 829
    /**
     * Maximum number of artifacts to list before using switching to the tree view.
     */
    public static final int LIST_CUTOFF = Integer.parseInt(System.getProperty("hudson.model.Run.ArtifactList.listCutoff", "16"));

    /**
     * Maximum number of artifacts to show in tree view before just showing a link.
     */
    public static final int TREE_CUTOFF = Integer.parseInt(System.getProperty("hudson.model.Run.ArtifactList.treeCutoff", "40"));

    // ..and then "too many"
K
kohsuke 已提交
830

831
    public final class ArtifactList extends ArrayList<Artifact> {
832 833 834 835 836 837 838 839 840 841 842
        /**
         * Map of Artifact to treeNodeId of parent node in tree view.
         * Contains Artifact objects for directories and files (the ArrayList contains only files).
         */
        private LinkedHashMap<Artifact,String> tree = new LinkedHashMap<Artifact,String>();
        private int idSeq = 0;

        public Map<Artifact,String> getTree() {
            return tree;
        }

843
        public void computeDisplayName() {
844
            if(size()>LIST_CUTOFF)   return; // we are not going to display file names, so no point in computing this
845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903

            int maxDepth = 0;
            int[] len = new int[size()];
            String[][] tokens = new String[size()][];
            for( int i=0; i<tokens.length; i++ ) {
                tokens[i] = get(i).relativePath.split("[\\\\/]+");
                maxDepth = Math.max(maxDepth,tokens[i].length);
                len[i] = 1;
            }

            boolean collision;
            int depth=0;
            do {
                collision = false;
                Map<String,Integer/*index*/> names = new HashMap<String,Integer>();
                for (int i = 0; i < tokens.length; i++) {
                    String[] token = tokens[i];
                    String displayName = combineLast(token,len[i]);
                    Integer j = names.put(displayName, i);
                    if(j!=null) {
                        collision = true;
                        if(j>=0)
                            len[j]++;
                        len[i]++;
                        names.put(displayName,-1);  // occupy this name but don't let len[i] incremented with additional collisions
                    }
                }
            } while(collision && depth++<maxDepth);

            for (int i = 0; i < tokens.length; i++)
                get(i).displayPath = combineLast(tokens[i],len[i]);

//            OUTER:
//            for( int n=1; n<maxLen; n++ ) {
//                // if we just display the last n token, would it be suffice for disambiguation?
//                Set<String> names = new HashSet<String>();
//                for (String[] token : tokens) {
//                    if(!names.add(combineLast(token,n)))
//                        continue OUTER; // collision. Increase n and try again
//                }
//
//                // this n successfully diambiguates
//                for (int i = 0; i < tokens.length; i++) {
//                    String[] token = tokens[i];
//                    get(i).displayPath = combineLast(token,n);
//                }
//                return;
//            }

//            // it's impossible to get here, as that means
//            // we have the same artifacts archived twice, but be defensive
//            for (Artifact a : this)
//                a.displayPath = a.relativePath;
        }

        /**
         * Combines last N token into the "a/b/c" form.
         */
        private String combineLast(String[] token, int n) {
K
kohsuke 已提交
904
            StringBuilder buf = new StringBuilder();
905 906 907 908 909 910 911 912
            for( int i=Math.max(0,token.length-n); i<token.length; i++ ) {
                if(buf.length()>0)  buf.append('/');
                buf.append(token[i]);
            }
            return buf.toString();
        }
    }

K
kohsuke 已提交
913 914 915
    /**
     * A build artifact.
     */
916
    @ExportedBean
K
kohsuke 已提交
917 918 919 920
    public class Artifact {
        /**
         * Relative path name from {@link Run#getArtifactsDir()}
         */
921
    	@Exported(visibility=3)
922
        public final String relativePath;
K
kohsuke 已提交
923

924 925 926 927 928 929
        /**
         * Truncated form of {@link #relativePath} just enough
         * to disambiguate {@link Artifact}s.
         */
        /*package*/ String displayPath;

930 931 932 933 934 935 936 937 938 939
        /**
         * The filename of the artifact.
         * (though when directories with single items are collapsed for tree view, name may
         *  include multiple path components, like "dist/pkg/mypkg")
         */
        private String name;

        /**
         * Properly encoded relativePath for use in URLs.  This field is null for directories.
         */
940 941
        private String href;

942 943 944 945 946 947 948
        /**
         * Id of this node for use in tree view.
         */
        private String treeNodeId;

        /*package for test*/ Artifact(String name, String relativePath, String href, String treeNodeId) {
            this.name = name;
K
kohsuke 已提交
949
            this.relativePath = relativePath;
950
            this.href = href;
951
            this.treeNodeId = treeNodeId;
K
kohsuke 已提交
952 953 954 955 956 957 958 959 960 961 962 963
        }

        /**
         * Gets the artifact file.
         */
        public File getFile() {
            return new File(getArtifactsDir(),relativePath);
        }

        /**
         * Returns just the file name portion, without the path.
         */
964
    	@Exported(visibility=3)
K
kohsuke 已提交
965
        public String getFileName() {
966
            return name;
K
kohsuke 已提交
967 968
        }

969
    	@Exported(visibility=3)
970 971 972 973
        public String getDisplayPath() {
            return displayPath;
        }

974 975 976 977
        public String getHref() {
            return href;
        }

978 979 980 981
        public String getTreeNodeId() {
            return treeNodeId;
        }

982
        @Override
K
kohsuke 已提交
983 984 985 986 987 988 989 990 991 992 993 994
        public String toString() {
            return relativePath;
        }
    }

    /**
     * Returns the log file.
     */
    public File getLogFile() {
        return new File(getRootDir(),"log");
    }

995
    /**
K
kohsuke 已提交
996
     * Returns an input stream that reads from the log file.
997
     * It will use a gzip-compressed log file (log.gz) if that exists.
K
kohsuke 已提交
998
     *
999
     * @throws IOException 
K
kohsuke 已提交
1000 1001
     * @return an input stream from the log file, or null if none exists
     * @since 1.349
1002
     */
K
kohsuke 已提交
1003
    public InputStream getLogInputStream() throws IOException {
1004 1005
    	File logFile = getLogFile();
    	if (logFile.exists() ) {
K
kohsuke 已提交
1006 1007
            return new FileInputStream(logFile);
    	}
1008 1009 1010

    	File compressedLogFile = new File(logFile.getParentFile(), logFile.getName()+ ".gz");
    	if (compressedLogFile.exists()) {
K
kohsuke 已提交
1011 1012
            return new GZIPInputStream(new FileInputStream(compressedLogFile));
    	}
1013
    	
K
kohsuke 已提交
1014
    	return new NullInputStream(0);
1015
    }
K
kohsuke 已提交
1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028

    public Reader getLogReader() throws IOException {
        if (charset==null)  return new InputStreamReader(getLogInputStream());
        else                return new InputStreamReader(getLogInputStream(),charset);
    }

    /**
     * Used from <tt>console.jelly</tt> to write annotated log to the given output.
     *
     * @since 1.349
     */
    public void writeLogTo(long offset, XMLOutput out) throws IOException {
        // TODO: resurrect compressed log file support
1029
        getLogText().writeHtmlTo(offset,out.asWriter());
K
kohsuke 已提交
1030 1031
    }

1032 1033 1034 1035
    /**
     * Used to URL-bind {@link AnnotatedLargeText}.
     */
    public AnnotatedLargeText getLogText() {
K
kohsuke 已提交
1036 1037 1038
        return new AnnotatedLargeText(getLogFile(),getCharset(),!isLogUpdated(),this);
    }

1039
    @Override
1040
    protected SearchIndexBuilder makeSearchIndex() {
1041 1042 1043 1044 1045 1046 1047 1048
        SearchIndexBuilder builder = super.makeSearchIndex()
                .add("console")
                .add("changes");
        for (Action a : getActions()) {
            if(a.getIconFileName()!=null)
                builder.add(a.getUrlName());
        }
        return builder;
1049 1050
    }

1051
    public Api getApi() {
1052 1053 1054
        return new Api(this);
    }

1055
    public void checkPermission(Permission p) {
1056 1057 1058
        getACL().checkPermission(p);
    }

1059 1060 1061 1062
    public boolean hasPermission(Permission p) {
        return getACL().hasPermission(p);
    }

1063
    public ACL getACL() {
1064
        // for now, don't maintain ACL per run, and do it at project level
1065
        return getParent().getACL();
1066 1067
    }

1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081
    /**
     * Deletes this build's artifacts. 
     *
     * @throws IOException
     *      if we fail to delete.
     *
     * @since 1.350
     */
    public synchronized void deleteArtifacts() throws IOException {
        File artifactsDir = getArtifactsDir();

        Util.deleteContentsRecursive(artifactsDir);
    }

K
kohsuke 已提交
1082 1083 1084 1085 1086 1087 1088
    /**
     * Deletes this build and its entire log
     *
     * @throws IOException
     *      if we fail to delete.
     */
    public synchronized void delete() throws IOException {
1089 1090
        RunListener.fireDeleted(this);

1091 1092 1093 1094
        // if we have a symlink, delete it, too
        File link = new File(project.getBuildDir(), String.valueOf(getNumber()));
        link.delete();

K
kohsuke 已提交
1095 1096
        File rootDir = getRootDir();
        File tmp = new File(rootDir.getParentFile(),'.'+rootDir.getName());
1097 1098 1099
        
        boolean renamingSucceeded = rootDir.renameTo(tmp);
        Util.deleteRecursive(tmp);
1100 1101 1102 1103
        // some user reported that they see some left-over .xyz files in the workspace,
        // so just to make sure we've really deleted it, schedule the deletion on VM exit, too.
        if(tmp.exists())
            tmp.deleteOnExit();
K
kohsuke 已提交
1104

1105
        if(!renamingSucceeded)
K
kohsuke 已提交
1106 1107
            throw new IOException(rootDir+" is in use");

J
jglick 已提交
1108 1109
        removeRunFromParent();
    }
1110

J
jglick 已提交
1111 1112
    @SuppressWarnings("unchecked") // seems this is too clever for Java's type system?
    private void removeRunFromParent() {
K
kohsuke 已提交
1113 1114 1115
        getParent().removeRun((RunT)this);
    }

K
kohsuke 已提交
1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186

    /**
     * @see CheckPoint#report()
     */
    /*package*/ static void reportCheckpoint(CheckPoint id) {
        RunnerStack.INSTANCE.peek().checkpoints.report(id);
    }

    /**
     * @see CheckPoint#block()
     */
    /*package*/ static void waitForCheckpoint(CheckPoint id) throws InterruptedException {
        while(true) {
            Run b = RunnerStack.INSTANCE.peek().getBuild().getPreviousBuildInProgress();
            if(b==null)     return; // no pending earlier build
            Run.Runner runner = b.runner;
            if(runner==null) {
                // polled at the wrong moment. try again.
                Thread.sleep(0);
                continue;
            }
            if(runner.checkpoints.waitForCheckPoint(id))
                return; // confirmed that the previous build reached the check point

            // the previous build finished without ever reaching the check point. try again.
        }
    }

    protected abstract class Runner {
        /**
         * Keeps track of the check points attained by a build, and abstracts away the synchronization needed to 
         * maintain this data structure.
         */
        private final class CheckpointSet {
            /**
             * Stages of the builds that this runner has completed. This is used for concurrent {@link Runner}s to
             * coordinate and serialize their executions where necessary.
             */
            private final Set<CheckPoint> checkpoints = new HashSet<CheckPoint>();

            private boolean allDone;

            protected synchronized void report(CheckPoint identifier) {
                checkpoints.add(identifier);
                notifyAll();
            }

            protected synchronized boolean waitForCheckPoint(CheckPoint identifier) throws InterruptedException {
                final Thread t = Thread.currentThread();
                final String oldName = t.getName();
                t.setName(oldName+" : waiting for "+identifier+" on "+getFullDisplayName());
                try {
                    while(!allDone && !checkpoints.contains(identifier))
                        wait();
                    return checkpoints.contains(identifier);
                } finally {
                    t.setName(oldName);
                }
            }

            /**
             * Notifies that the build is fully completed and all the checkpoint locks be released.
             */
            private synchronized void allDone() {
                allDone = true;
                notifyAll();
            }
        }

        private final CheckpointSet checkpoints = new CheckpointSet();

1187 1188 1189 1190 1191 1192
        /**
         * Performs the main build and returns the status code.
         *
         * @throws Exception
         *      exception will be recorded and the build will be considered a failure.
         */
K
kohsuke 已提交
1193
        public abstract Result run( BuildListener listener ) throws Exception, RunnerAbortedException;
K
kohsuke 已提交
1194

1195 1196
        /**
         * Performs the post-build action.
1197
         * <p>
1198
         * This method is called after {@linkplain #run(BuildListener) the main portion of the build is completed.}
K
kohsuke 已提交
1199 1200 1201 1202
         * This is a good opportunity to do notifications based on the result
         * of the build. When this method is called, the build is not really
         * finalized yet, and the build is still considered in progress --- for example,
         * even if the build is successful, this build still won't be picked up
1203
         * by {@link Job#getLastSuccessfulBuild()}.
1204
         */
K
kohsuke 已提交
1205
        public abstract void post( BuildListener listener ) throws Exception;
1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216

        /**
         * Performs final clean up action.
         * <p>
         * This method is called after {@link #post(BuildListener)},
         * after the build result is fully finalized. This is the point
         * where the build is already considered completed.
         * <p>
         * Among other things, this is often a necessary pre-condition
         * before invoking other builds that depend on this build.
         */
K
kohsuke 已提交
1217 1218 1219 1220 1221
        public abstract void cleanUp(BuildListener listener) throws Exception;

        protected final RunT getBuild() {
            return _this();
        }
K
kohsuke 已提交
1222 1223
    }

1224 1225 1226 1227 1228 1229 1230
    /**
     * Used in {@link Runner#run} to indicates that a fatal error in a build
     * is reported to {@link BuildListener} and the build should be simply aborted
     * without further recording a stack trace.
     */
    public static final class RunnerAbortedException extends RuntimeException {}

K
kohsuke 已提交
1231 1232 1233 1234
    protected final void run(Runner job) {
        if(result!=null)
            return;     // already built.

K
kohsuke 已提交
1235
        StreamBuildListener listener=null;
1236

K
kohsuke 已提交
1237
        runner = job;
K
kohsuke 已提交
1238 1239 1240 1241 1242 1243 1244 1245 1246
        onStartBuilding();
        try {
            // to set the state to COMPLETE in the end, even if the thread dies abnormally.
            // otherwise the queue state becomes inconsistent

            long start = System.currentTimeMillis();

            try {
                try {
1247 1248
                    Charset charset = Computer.currentComputer().getDefaultCharset();
                    this.charset = charset.name();
K
kohsuke 已提交
1249
                    listener = new StreamBuildListener(getLogFile(),charset);
K
kohsuke 已提交
1250

K
kohsuke 已提交
1251
                    listener.started(getCauses());
K
kohsuke 已提交
1252

K
kohsuke 已提交
1253 1254
                    RunListener.fireStarted(this,listener);

1255 1256 1257
                    // create a symlink from build number to ID.
                    Util.createSymlink(getParent().getBuildDir(),getId(),String.valueOf(getNumber()),listener);

K
kohsuke 已提交
1258
                    setResult(job.run(listener));
K
kohsuke 已提交
1259 1260

                    LOGGER.info(toString()+" main build action completed: "+result);
K
kohsuke 已提交
1261
                    CheckPoint.MAIN_COMPLETED.report();
K
kohsuke 已提交
1262 1263
                } catch (ThreadDeath t) {
                    throw t;
1264
                } catch( AbortException e ) {// orderly abortion.
1265
                    result = Result.FAILURE;
1266
                    LOGGER.log(Level.FINE, "Build "+this+" aborted",e);
K
kohsuke 已提交
1267
                } catch( RunnerAbortedException e ) {// orderly abortion.
1268
                    result = Result.FAILURE;
1269
                    LOGGER.log(Level.FINE, "Build "+this+" aborted",e);
1270 1271 1272
                } catch( InterruptedException e) {
                    // aborted
                    result = Result.ABORTED;
K
i18n  
kohsuke 已提交
1273
                    listener.getLogger().println(Messages.Run_BuildAborted());
1274
                    LOGGER.log(Level.INFO,toString()+" aborted",e);
K
kohsuke 已提交
1275 1276 1277 1278 1279
                } catch( Throwable e ) {
                    handleFatalBuildProblem(listener,e);
                    result = Result.FAILURE;
                }

K
kohsuke 已提交
1280
                // even if the main build fails fatally, try to run post build processing
K
kohsuke 已提交
1281 1282 1283 1284 1285 1286 1287
                job.post(listener);

            } catch (ThreadDeath t) {
                throw t;
            } catch( Throwable e ) {
                handleFatalBuildProblem(listener,e);
                result = Result.FAILURE;
K
kohsuke 已提交
1288
            } finally {
1289
                long end = System.currentTimeMillis();
1290
                duration = Math.max(end - start, 0);  // @see HUDSON-5844
1291

1292
                // advance the state.
1293 1294 1295 1296
                // the significance of doing this is that Hudson
                // will now see this build as completed.
                // things like triggering other builds requires this as pre-condition.
                // see issue #980.
1297
                state = State.POST_PRODUCTION;
1298 1299 1300 1301 1302 1303 1304

                try {
                    job.cleanUp(listener);
                } catch (Exception e) {
                    handleFatalBuildProblem(listener,e);
                    // too late to update the result now
                }
K
kohsuke 已提交
1305

1306
                RunListener.fireCompleted(this,listener);
K
kohsuke 已提交
1307

1308 1309
                if(listener!=null)
                    listener.finished(result);
K
kohsuke 已提交
1310 1311
                if(listener!=null)
                    listener.closeQuietly();
K
kohsuke 已提交
1312

1313 1314 1315
                try {
                    save();
                } catch (IOException e) {
K
kohsuke 已提交
1316
                    LOGGER.log(Level.SEVERE, "Failed to save build record",e);
1317
                }
K
kohsuke 已提交
1318 1319 1320
            }

            try {
1321
                getParent().logRotate();
K
kohsuke 已提交
1322
            } catch (IOException e) {
K
kohsuke 已提交
1323
                LOGGER.log(Level.SEVERE, "Failed to rotate log",e);
1324 1325
            } catch (InterruptedException e) {
                LOGGER.log(Level.SEVERE, "Failed to rotate log",e);
K
kohsuke 已提交
1326 1327 1328 1329 1330 1331 1332
            }
        } finally {
            onEndBuilding();
        }
    }

    /**
K
kohsuke 已提交
1333
     * Handles a fatal build problem (exception) that occurred during the build.
K
kohsuke 已提交
1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356
     */
    private void handleFatalBuildProblem(BuildListener listener, Throwable e) {
        if(listener!=null) {
            if(e instanceof IOException)
                Util.displayIOException((IOException)e,listener);

            Writer w = listener.fatalError(e.getMessage());
            if(w!=null) {
                try {
                    e.printStackTrace(new PrintWriter(w));
                    w.close();
                } catch (IOException e1) {
                    // ignore
                }
            }
        }
    }

    /**
     * Called when a job started building.
     */
    protected void onStartBuilding() {
        state = State.BUILDING;
K
kohsuke 已提交
1357 1358
        if (runner!=null)
            RunnerStack.INSTANCE.push(runner);
K
kohsuke 已提交
1359 1360 1361 1362 1363 1364
    }

    /**
     * Called when a job finished building normally or abnormally.
     */
    protected void onEndBuilding() {
K
kohsuke 已提交
1365 1366 1367 1368 1369
        // signal that we've finished building.
        if (runner!=null) {
            // MavenBuilds may be created without their corresponding runners.
            state = State.COMPLETED;
            runner.checkpoints.allDone();
K
kohsuke 已提交
1370 1371
            runner = null;
            RunnerStack.INSTANCE.pop();
K
kohsuke 已提交
1372 1373 1374
        } else {
            state = State.COMPLETED;
        }
K
kohsuke 已提交
1375 1376 1377
        if (result == null) {
            result = Result.FAILURE;
            LOGGER.warning(toString() + ": No build result is set, so marking as failure. This shouldn't happen.");
1378 1379
        }

1380
        RunListener.fireFinalized(this);
K
kohsuke 已提交
1381 1382 1383 1384 1385 1386
    }

    /**
     * Save the settings to a file.
     */
    public synchronized void save() throws IOException {
1387
        if(BulkChange.contains(this))   return;
K
kohsuke 已提交
1388
        getDataFile().write(this);
1389
        SaveableListener.fireOnChange(this, getDataFile());
K
kohsuke 已提交
1390 1391 1392 1393 1394 1395 1396 1397 1398
    }

    private XmlFile getDataFile() {
        return new XmlFile(XSTREAM,new File(getRootDir(),"build.xml"));
    }

    /**
     * Gets the log of the build as a string.
     *
M
mindless 已提交
1399 1400 1401
     * @deprecated since 2007-11-11.
     *     Use {@link #getLog(int)} instead as it avoids loading
     *     the whole log into memory unnecessarily.
K
kohsuke 已提交
1402
     */
1403
    @Deprecated
K
kohsuke 已提交
1404
    public String getLog() throws IOException {
1405
        return Util.loadFile(getLogFile(),getCharset());
K
kohsuke 已提交
1406 1407
    }

1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419
    /**
     * Gets the log of the build as a list of strings (one per log line).
     * The number of lines returned is constrained by the maxLines parameter.
     *
     * @param maxLines The maximum number of log lines to return.  If the log
     * is bigger than this, only the most recent lines are returned.
     * @return A list of log lines.  Will have no more than maxLines elements.
     * @throws IOException If there is a problem reading the log file.
     */
    public List<String> getLog(int maxLines) throws IOException {
        int lineCount = 0;
        List<String> logLines = new LinkedList<String>();
1420
        BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(getLogFile()),getCharset()));
K
kohsuke 已提交
1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433
        try {
            for (String line = reader.readLine(); line != null; line = reader.readLine()) {
                logLines.add(line);
                ++lineCount;
                // If we have too many lines, remove the oldest line.  This way we
                // never have to hold the full contents of a huge log file in memory.
                // Adding to and removing from the ends of a linked list are cheap
                // operations.
                if (lineCount > maxLines)
                    logLines.remove(0);
            }
        } finally {
            reader.close();
1434 1435 1436 1437 1438 1439 1440 1441
        }

        // If the log has been truncated, include that information.
        // Use set (replaces the first element) rather than add so that
        // the list doesn't grow beyond the specified maximum number of lines.
        if (lineCount > maxLines)
            logLines.set(0, "[...truncated " + (lineCount - (maxLines - 1)) + " lines...]");

1442
        return ConsoleNote.removeNotes(logLines);
1443 1444
    }

K
kohsuke 已提交
1445
    public void doBuildStatus( StaplerRequest req, StaplerResponse rsp ) throws IOException {
1446
        rsp.sendRedirect2(req.getContextPath()+"/images/48x48/"+getBuildStatusUrl());
K
kohsuke 已提交
1447 1448 1449
    }

    public String getBuildStatusUrl() {
1450
        return getIconColor().getImage();
K
kohsuke 已提交
1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473
    }

    public static class Summary {
        /**
         * Is this build worse or better, compared to the previous build?
         */
        public boolean isWorse;
        public String message;

        public Summary(boolean worse, String message) {
            this.isWorse = worse;
            this.message = message;
        }
    }

    /**
     * Gets an object that computes the single line summary of this build.
     */
    public Summary getBuildStatusSummary() {
        Run prev = getPreviousBuild();

        if(getResult()==Result.SUCCESS) {
            if(prev==null || prev.getResult()== Result.SUCCESS)
1474
                return new Summary(false, Messages.Run_Summary_Stable());
K
kohsuke 已提交
1475
            else
1476
                return new Summary(false, Messages.Run_Summary_BackToNormal());
K
kohsuke 已提交
1477 1478 1479 1480 1481
        }

        if(getResult()==Result.FAILURE) {
            RunT since = getPreviousNotFailedBuild();
            if(since==null)
1482
                return new Summary(false, Messages.Run_Summary_BrokenForALongTime());
K
kohsuke 已提交
1483
            if(since==prev)
1484 1485
                return new Summary(true, Messages.Run_Summary_BrokenSinceThisBuild());
            return new Summary(false, Messages.Run_Summary_BrokenSince(since.getDisplayName()));
K
kohsuke 已提交
1486 1487 1488
        }

        if(getResult()==Result.ABORTED)
1489
            return new Summary(false, Messages.Run_Summary_Aborted());
K
kohsuke 已提交
1490 1491

        if(getResult()==Result.UNSTABLE) {
1492 1493 1494
            if(((Run)this) instanceof AbstractBuild) {
                AbstractTestResultAction trN = ((AbstractBuild)(Run)this).getTestResultAction();
                AbstractTestResultAction trP = prev==null ? null : ((AbstractBuild) prev).getTestResultAction();
K
kohsuke 已提交
1495 1496
                if(trP==null) {
                    if(trN!=null && trN.getFailCount()>0)
1497
                        return new Summary(false, Messages.Run_Summary_TestFailures(trN.getFailCount()));
K
kohsuke 已提交
1498
                    else // ???
1499
                        return new Summary(false, Messages.Run_Summary_Unstable());
K
kohsuke 已提交
1500 1501
                }
                if(trP.getFailCount()==0)
1502
                    return new Summary(true, Messages.Run_Summary_TestsStartedToFail(trN.getFailCount()));
K
kohsuke 已提交
1503
                if(trP.getFailCount() < trN.getFailCount())
1504
                    return new Summary(true, Messages.Run_Summary_MoreTestsFailing(trN.getFailCount()-trP.getFailCount(), trN.getFailCount()));
K
kohsuke 已提交
1505
                if(trP.getFailCount() > trN.getFailCount())
1506
                    return new Summary(false, Messages.Run_Summary_LessTestsFailing(trP.getFailCount()-trN.getFailCount(), trN.getFailCount()));
K
kohsuke 已提交
1507

1508
                return new Summary(false, Messages.Run_Summary_TestsStillFailing(trN.getFailCount()));
K
kohsuke 已提交
1509 1510 1511
            }
        }

1512
        return new Summary(false, Messages.Run_Summary_Unknown());
K
kohsuke 已提交
1513 1514 1515 1516 1517
    }

    /**
     * Serves the artifacts.
     */
1518 1519
    public DirectoryBrowserSupport doArtifact() {
        return new DirectoryBrowserSupport(this,new FilePath(getArtifactsDir()), project.getDisplayName()+' '+getDisplayName(), "package.gif", true);
K
kohsuke 已提交
1520 1521 1522 1523 1524
    }

    /**
     * Returns the build number in the body.
     */
1525
    public void doBuildNumber(StaplerResponse rsp) throws IOException {
K
kohsuke 已提交
1526 1527 1528 1529 1530 1531
        rsp.setContentType("text/plain");
        rsp.setCharacterEncoding("US-ASCII");
        rsp.setStatus(HttpServletResponse.SC_OK);
        rsp.getWriter().print(number);
    }

K
kohsuke 已提交
1532 1533 1534
    /**
     * Returns the build time stamp in the body.
     */
1535
    public void doBuildTimestamp( StaplerRequest req, StaplerResponse rsp, @QueryParameter String format) throws IOException {
K
kohsuke 已提交
1536 1537 1538
        rsp.setContentType("text/plain");
        rsp.setCharacterEncoding("US-ASCII");
        rsp.setStatus(HttpServletResponse.SC_OK);
K
kohsuke 已提交
1539 1540 1541
        DateFormat df = format==null ?
                DateFormat.getDateTimeInstance(DateFormat.SHORT,DateFormat.SHORT, Locale.ENGLISH) :
                new SimpleDateFormat(format,req.getLocale());
K
kohsuke 已提交
1542
        rsp.getWriter().print(df.format(getTime()));
K
kohsuke 已提交
1543 1544
    }

1545 1546 1547 1548 1549
    /**
     * Sends out the raw console output.
     */
    public void doConsoleText(StaplerRequest req, StaplerResponse rsp) throws IOException {
        rsp.setContentType("text/plain;charset=UTF-8");
1550
        // Prevent jelly from flushing stream so Content-Length header can be added afterwards
K
kohsuke 已提交
1551 1552
        FlushProofOutputStream out = new FlushProofOutputStream(rsp.getCompressedOutputStream(req));
        getLogText().writeLogTo(0,out);
1553
        out.close();
1554 1555
    }

K
kohsuke 已提交
1556 1557
    /**
     * Handles incremental log output.
1558 1559
     * @deprecated as of 1.352
     *      Use {@code getLogText().doProgressiveText(req,rsp)}
K
kohsuke 已提交
1560 1561
     */
    public void doProgressiveLog( StaplerRequest req, StaplerResponse rsp) throws IOException {
1562
        getLogText().doProgressText(req,rsp);
K
kohsuke 已提交
1563 1564 1565
    }

    public void doToggleLogKeep( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1566
        checkPermission(UPDATE);
K
kohsuke 已提交
1567

K
kohsuke 已提交
1568
        keepLog(!keepLog);
K
kohsuke 已提交
1569 1570
        rsp.forwardToPreviousPage(req);
    }
K
kohsuke 已提交
1571 1572 1573 1574

    /**
     * Marks this build to keep the log.
     */
1575
    @CLIMethod(name="keep-build")
K
kohsuke 已提交
1576 1577 1578 1579 1580 1581
    public final void keepLog() throws IOException {
        keepLog(true);
    }

    public void keepLog(boolean newValue) throws IOException {
        keepLog = newValue;
K
kohsuke 已提交
1582 1583
        save();
    }
K
kohsuke 已提交
1584

1585 1586 1587 1588
    /**
     * Deletes the build when the button is pressed.
     */
    public void doDoDelete( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1589
        requirePOST();
1590 1591
        checkPermission(DELETE);

1592 1593 1594
        // We should not simply delete the build if it has been explicitly
        // marked to be preserved, or if the build should not be deleted
        // due to dependencies!
1595 1596
        String why = getWhyKeepLog();
        if (why!=null) {
K
i18n  
kohsuke 已提交
1597
            sendError(Messages.Run_UnableToDelete(toString(),why),req,rsp);
1598 1599 1600 1601 1602 1603
            return;
        }

        delete();
        rsp.sendRedirect2(req.getContextPath()+'/' + getParent().getUrl());
    }
K
kohsuke 已提交
1604

K
kohsuke 已提交
1605
    public void setDescription(String description) throws IOException {
1606 1607
        checkPermission(UPDATE);
        this.description = description;
K
kohsuke 已提交
1608
        save();
1609 1610
    }
    
K
kohsuke 已提交
1611 1612 1613 1614 1615
    /**
     * Accepts the new description.
     */
    public synchronized void doSubmitDescription( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
        req.setCharacterEncoding("UTF-8");
1616
        setDescription(req.getParameter("description"));
K
kohsuke 已提交
1617 1618 1619 1620
        rsp.sendRedirect(".");  // go to the top page
    }

    /**
1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633
     * @deprecated as of 1.292
     *      Use {@link #getEnvironment()} instead.
     */
    public Map<String,String> getEnvVars() {
        try {
            return getEnvironment();
        } catch (IOException e) {
            return new EnvVars();
        } catch (InterruptedException e) {
            return new EnvVars();
        }
    }

K
kohsuke 已提交
1634
    /**
1635
     * @deprecated as of 1.305 use {@link #getEnvironment(TaskListener)}
K
kohsuke 已提交
1636 1637 1638 1639 1640
     */
    public EnvVars getEnvironment() throws IOException, InterruptedException {
        return getEnvironment(new LogTaskListener(LOGGER, Level.INFO));
    }

1641 1642 1643
    /**
     * Returns the map that contains environmental variables to be used for launching
     * processes for this build.
K
kohsuke 已提交
1644
     *
1645
     * <p>
K
kohsuke 已提交
1646 1647 1648 1649
     * {@link BuildStep}s that invoke external processes should use this.
     * This allows {@link BuildWrapper}s and other project configurations (such as JDK selection)
     * to take effect.
     *
1650
     * <p>
1651 1652
     * Unlike earlier {@link #getEnvVars()}, this map contains the whole environment,
     * not just the overrides, so one can introspect values to change its behavior.
1653
     * @since 1.305
K
kohsuke 已提交
1654
     */
K
kohsuke 已提交
1655
    public EnvVars getEnvironment(TaskListener log) throws IOException, InterruptedException {
1656
        EnvVars env = Computer.currentComputer().getEnvironment().overrideAll(getCharacteristicEnvVars());
1657
        String rootUrl = Hudson.getInstance().getRootUrl();
1658
        if(rootUrl!=null) {
1659
            env.put("HUDSON_URL", rootUrl);
1660 1661 1662
            env.put("BUILD_URL", rootUrl+getUrl());
            env.put("JOB_URL", rootUrl+getParent().getUrl());
        }
1663
        
K
kohsuke 已提交
1664 1665
        if(!env.containsKey("HUDSON_HOME"))
            env.put("HUDSON_HOME", Hudson.getInstance().getRootDir().getPath() );
K
kohsuke 已提交
1666 1667 1668 1669 1670

        Thread t = Thread.currentThread();
        if (t instanceof Executor) {
            Executor e = (Executor) t;
            env.put("EXECUTOR_NUMBER",String.valueOf(e.getNumber()));
1671
            env.put("NODE_NAME",e.getOwner().getName());
K
kohsuke 已提交
1672 1673
        }

K
kohsuke 已提交
1674 1675 1676
        return env;
    }

1677 1678
    /**
     * Builds up the environment variable map that's sufficient to identify a process
1679
     * as ours. This is used to kill run-away processes via {@link ProcessTree#killAll(Map)}.
1680
     */
1681
    public final EnvVars getCharacteristicEnvVars() {
1682 1683 1684 1685 1686 1687 1688 1689
        EnvVars env = new EnvVars();
        env.put("BUILD_NUMBER",String.valueOf(number));
        env.put("BUILD_ID",getId());
        env.put("BUILD_TAG","hudson-"+getParent().getName()+"-"+number);
        env.put("JOB_NAME",getParent().getFullName());
        return env;
    }

H
huybrechts 已提交
1690 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706
    public String getExternalizableId() {
        return project.getName() + "#" + getNumber();
    }

    public static Run<?,?> fromExternalizableId(String id) {
        int hash = id.lastIndexOf('#');
        if (hash <= 0) {
            throw new IllegalArgumentException("Invalid id");
        }
        String jobName = id.substring(0, hash);
        int number = Integer.parseInt(id.substring(hash + 1));

        Job<?,?> job = (Job<?,?>) Hudson.getInstance().getItem(jobName);
        return job.getBuildByNumber(number);
    }


H
huybrechts 已提交
1707
    public static final XStream XSTREAM = new XStream2();
K
kohsuke 已提交
1708
    static {
1709 1710 1711
        XSTREAM.alias("build",FreeStyleBuild.class);
        XSTREAM.alias("matrix-build",MatrixBuild.class);
        XSTREAM.alias("matrix-run",MatrixRun.class);
K
kohsuke 已提交
1712 1713 1714 1715 1716 1717 1718 1719 1720 1721
        XSTREAM.registerConverter(Result.conv);
    }

    private static final Logger LOGGER = Logger.getLogger(Run.class.getName());

    /**
     * Sort by date. Newer ones first. 
     */
    public static final Comparator<Run> ORDER_BY_DATE = new Comparator<Run>() {
        public int compare(Run lhs, Run rhs) {
K
kohsuke 已提交
1722 1723
            long lt = lhs.getTimeInMillis();
            long rt = rhs.getTimeInMillis();
K
kohsuke 已提交
1724 1725 1726
            if(lt>rt)   return -1;
            if(lt<rt)   return 1;
            return 0;
K
kohsuke 已提交
1727 1728 1729 1730 1731 1732
        }
    };

    /**
     * {@link FeedAdapter} to produce feed from the summary of this build.
     */
K
kohsuke 已提交
1733 1734 1735 1736 1737 1738 1739 1740 1741 1742
    public static final FeedAdapter<Run> FEED_ADAPTER = new DefaultFeedAdapter();

    /**
     * {@link FeedAdapter} to produce feeds to show one build per project.
     */
    public static final FeedAdapter<Run> FEED_ADAPTER_LATEST = new DefaultFeedAdapter() {
        /**
         * The entry unique ID needs to be tied to a project, so that
         * new builds will replace the old result.
         */
1743
        @Override
K
kohsuke 已提交
1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760
        public String getEntryID(Run e) {
            // can't use a meaningful year field unless we remember when the job was created.
            return "tag:hudson.dev.java.net,2008:"+e.getParent().getAbsoluteUrl();
        }
    };

    /**
     * {@link BuildBadgeAction} that shows the logs are being kept.
     */
    public final class KeepLogBuildBadge implements BuildBadgeAction {
        public String getIconFileName() { return null; }
        public String getDisplayName() { return null; }
        public String getUrlName() { return null; }
        public String getWhyKeepLog() { return Run.this.getWhyKeepLog(); }
    }

    public static final PermissionGroup PERMISSIONS = new PermissionGroup(Run.class,Messages._Run_Permissions_Title());
K
kohsuke 已提交
1761 1762
    public static final Permission DELETE = new Permission(PERMISSIONS,"Delete",Messages._Run_DeletePermission_Description(),Permission.DELETE);
    public static final Permission UPDATE = new Permission(PERMISSIONS,"Update",Messages._Run_UpdatePermission_Description(),Permission.UPDATE);
K
kohsuke 已提交
1763 1764

    private static class DefaultFeedAdapter implements FeedAdapter<Run> {
K
kohsuke 已提交
1765 1766 1767 1768 1769 1770 1771 1772 1773
        public String getEntryTitle(Run entry) {
            return entry+" ("+entry.getResult()+")";
        }

        public String getEntryUrl(Run entry) {
            return entry.getUrl();
        }

        public String getEntryID(Run entry) {
1774 1775 1776
            return "tag:" + "hudson.dev.java.net,"
                + entry.getTimestamp().get(Calendar.YEAR) + ":"
                + entry.getParent().getName()+':'+entry.getId();
K
kohsuke 已提交
1777 1778
        }

1779 1780 1781 1782 1783
        public String getEntryDescription(Run entry) {
            // TODO: this could provide some useful details
            return null;
        }

K
kohsuke 已提交
1784 1785 1786
        public Calendar getEntryTimestamp(Run entry) {
            return entry.getTimestamp();
        }
1787 1788

        public String getEntryAuthor(Run entry) {
1789
            return Mailer.descriptor().getAdminAddress();
1790
        }
1791
    }
1792 1793 1794 1795 1796 1797 1798

    @Override
    public Object getDynamic(String token, StaplerRequest req, StaplerResponse rsp) {
        Object result = super.getDynamic(token, req, rsp);
        if (result == null)
            // Next/Previous Build links on an action page (like /job/Abc/123/testReport)
            // will also point to same action (/job/Abc/124/testReport), but other builds
M
mindless 已提交
1799
            // may not have the action.. tell browsers to redirect up to the build page.
1800 1801 1802 1803 1804
            result = new RedirectUp();
        return result;
    }

    public static class RedirectUp {
K
kohsuke 已提交
1805
        public void doDynamic(StaplerResponse rsp) throws IOException {
M
mindless 已提交
1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817
            // Compromise to handle both browsers (auto-redirect) and programmatic access
            // (want accurate 404 response).. send 404 with javscript to redirect browsers.
            rsp.setStatus(HttpServletResponse.SC_NOT_FOUND);
            rsp.setContentType("text/html;charset=UTF-8");
            PrintWriter out = rsp.getWriter();
            out.println("<html><head>" +
                "<meta http-equiv='refresh' content='1;url=..'/>" +
                "<script>window.location.replace('..');</script>" +
                "</head>" +
                "<body style='background-color:white; color:white;'>" +
                "Not found</body></html>");
            out.flush();
1818 1819
        }
    }
K
kohsuke 已提交
1820
}