Run.java 41.0 KB
Newer Older
K
kohsuke 已提交
1 2 3 4
package hudson.model;

import com.thoughtworks.xstream.XStream;
import hudson.CloseProofOutputStream;
K
kohsuke 已提交
5
import hudson.EnvVars;
K
kohsuke 已提交
6
import hudson.ExtensionPoint;
K
kohsuke 已提交
7
import hudson.FeedAdapter;
8
import hudson.FilePath;
K
kohsuke 已提交
9
import hudson.Util;
K
kohsuke 已提交
10
import static hudson.Util.combine;
K
kohsuke 已提交
11
import hudson.XmlFile;
12
import hudson.AbortException;
13
import hudson.BulkChange;
14 15
import hudson.matrix.MatrixBuild;
import hudson.matrix.MatrixRun;
16
import hudson.model.listeners.RunListener;
K
kohsuke 已提交
17
import hudson.search.SearchIndexBuilder;
18 19 20 21
import hudson.security.ACL;
import hudson.security.AccessControlled;
import hudson.security.Permission;
import hudson.security.PermissionGroup;
K
kohsuke 已提交
22
import hudson.tasks.BuildStep;
K
kohsuke 已提交
23
import hudson.tasks.BuildWrapper;
24
import hudson.tasks.LogRotator;
25
import hudson.tasks.Mailer;
K
kohsuke 已提交
26 27 28
import hudson.tasks.test.AbstractTestResultAction;
import hudson.util.IOException2;
import hudson.util.XStream2;
29
import org.kohsuke.stapler.QueryParameter;
K
kohsuke 已提交
30 31
import org.kohsuke.stapler.StaplerRequest;
import org.kohsuke.stapler.StaplerResponse;
K
kohsuke 已提交
32 33
import org.kohsuke.stapler.export.Exported;
import org.kohsuke.stapler.export.ExportedBean;
34
import org.kohsuke.stapler.framework.io.LargeText;
K
kohsuke 已提交
35 36 37

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletResponse;
38
import java.io.BufferedReader;
K
kohsuke 已提交
39 40 41 42 43 44
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.io.Writer;
45 46
import java.io.InputStreamReader;
import java.io.FileInputStream;
47
import java.text.DateFormat;
K
kohsuke 已提交
48 49 50 51
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
52
import java.util.Collections;
K
kohsuke 已提交
53
import java.util.Comparator;
54
import java.util.Date;
K
kohsuke 已提交
55
import java.util.GregorianCalendar;
56
import java.util.HashMap;
57
import java.util.LinkedList;
K
kohsuke 已提交
58
import java.util.List;
59
import java.util.Locale;
K
kohsuke 已提交
60
import java.util.Map;
61
import java.util.TreeMap;
62
import java.util.logging.Level;
K
kohsuke 已提交
63
import java.util.logging.Logger;
64
import java.nio.charset.Charset;
K
kohsuke 已提交
65 66 67 68 69 70 71 72 73 74

/**
 * 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 已提交
75
 * @see RunListener
K
kohsuke 已提交
76
 */
K
kohsuke 已提交
77
@ExportedBean
K
kohsuke 已提交
78
public abstract class Run <JobT extends Job<JobT,RunT>,RunT extends Run<JobT,RunT>>
K
kohsuke 已提交
79
        extends Actionable implements ExtensionPoint, Comparable<RunT>, AccessControlled, PersistenceRoot {
K
kohsuke 已提交
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104

    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;
    /**
     * Next build. Can be null.
     */
    protected volatile transient RunT nextBuild;

    /**
     * When the build is scheduled.
     */
105
    protected transient final long timestamp;
K
kohsuke 已提交
106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123

    /**
     * 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 {
124 125 126
        /**
         * Build is created/queued but we haven't started building it.
         */
K
kohsuke 已提交
127
        NOT_STARTED,
128 129 130
        /**
         * Build is in progress.
         */
K
kohsuke 已提交
131
        BUILDING,
132 133 134 135 136 137 138 139
        /**
         * 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 已提交
140 141 142 143 144 145 146 147
        COMPLETED
    }

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

148 149 150 151 152 153 154 155 156 157
    /**
     * 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
     */
    private String charset;

K
kohsuke 已提交
158 159 160 161 162
    /**
     * Keeps this log entries.
     */
    private boolean keepLog;

163 164 165 166 167 168 169
    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 已提交
170 171 172 173 174 175 176 177 178 179 180 181 182 183

    /**
     * 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) {
184 185 186 187
        this(job,timestamp.getTimeInMillis());
    }

    protected Run(JobT job, long timestamp) {
K
kohsuke 已提交
188 189 190 191 192 193 194 195 196
        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 {
197 198 199 200 201 202
        this(project, parseTimestampFromBuildDir(buildDir));
        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
    }

203
    /*package*/ static long parseTimestampFromBuildDir(File buildDir) throws IOException {
K
kohsuke 已提交
204
        try {
205
            return ID_FORMATTER.get().parse(buildDir.getName()).getTime();
K
kohsuke 已提交
206 207 208 209 210 211 212
        } catch (ParseException e) {
            throw new IOException2("Invalid directory name "+buildDir,e);
        } catch (NumberFormatException e) {
            throw new IOException2("Invalid directory name "+buildDir,e);
        }
    }

213 214 215 216 217 218 219
    /**
     * Ordering based on build numbers.
     */
    public int compareTo(RunT that) {
        return this.number - that.number;
    }

K
kohsuke 已提交
220 221 222 223 224 225 226
    /**
     * Returns the build result.
     *
     * <p>
     * When a build is {@link #isBuilding() in progress}, this method
     * may return null or a temporary intermediate result.
     */
K
kohsuke 已提交
227
    @Exported
K
kohsuke 已提交
228
    public Result getResult() {
K
kohsuke 已提交
229 230 231 232 233 234 235 236 237 238 239 240 241
        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;
242
            LOGGER.fine(toString()+" : result is set to "+r+" by "+caller);
K
kohsuke 已提交
243 244
        } else {
            if(r.isWorseThan(result)) {
245
                LOGGER.fine(toString()+" : result is set to "+r+" by "+caller);
K
kohsuke 已提交
246 247 248 249 250
                result = r;
            }
        }
    }

251
    /**
252
     * Gets the subset of {@link #getActions()} that consists of {@link BuildBadgeAction}s.
253 254 255 256 257 258 259 260 261 262
     */
    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);
            }
        }
263 264 265 266 267
        if(isKeepLog()) {
            if(r==null)
                r = new ArrayList<BuildBadgeAction>();
            r.add(new KeepLogBuildBadge());
        }
268 269 270 271
        if(r==null)     return Collections.emptyList();
        else            return r;
    }

K
kohsuke 已提交
272 273 274 275 276 277 278 279 280 281 282
    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.
283
     * This includes "not started yet" state.
K
kohsuke 已提交
284
     */
K
kohsuke 已提交
285
    @Exported
K
kohsuke 已提交
286
    public boolean isBuilding() {
287 288 289 290 291 292 293 294
        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 已提交
295 296 297 298 299 300 301 302 303
    }

    /**
     * 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()) {
304
                if(e.getCurrentExecutable()==this)
K
kohsuke 已提交
305 306 307 308 309 310
                    return e;
            }
        }
        return null;
    }

311 312 313 314 315 316 317 318 319 320
    /**
     * 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 已提交
321 322 323 324 325
    /**
     * Returns true if this log file should be kept and not deleted.
     *
     * This is used as a signal to the {@link LogRotator}.
     */
K
kohsuke 已提交
326
    @Exported
327 328 329 330 331 332 333 334 335 336
    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 已提交
337
            return Messages.Run_MarkedExplicitly();
338
        return null;    // not marked at all
K
kohsuke 已提交
339 340 341 342 343 344 345 346 347 348 349 350
    }

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

    /**
     * When the build is scheduled.
     */
K
kohsuke 已提交
351
    @Exported
K
kohsuke 已提交
352
    public Calendar getTimestamp() {
353 354 355
        GregorianCalendar c = new GregorianCalendar();
        c.setTimeInMillis(timestamp);
        return c;
K
kohsuke 已提交
356 357
    }

K
kohsuke 已提交
358
    @Exported
K
kohsuke 已提交
359 360 361 362
    public String getDescription() {
        return description;
    }

363 364 365 366 367 368 369 370 371 372 373
    /**
     * 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 = "...";
374

375 376 377 378 379 380 381 382 383 384 385 386 387
        // limit the description
        String truncDescr = description.substring(
                0, maxDescrLength - ending.length());

        // truncate the description on the space
        int lastSpace = truncDescr.lastIndexOf(" ");
        if (lastSpace != -1) {
            truncDescr = truncDescr.substring(0, lastSpace);
        }

        return truncDescr + ending;
    }

K
kohsuke 已提交
388 389 390 391 392 393 394
    /**
     * Gets the string that says how long since this build has scheduled.
     *
     * @return
     *      string like "3 minutes" "1 day" etc.
     */
    public String getTimestampString() {
395
        long duration = new GregorianCalendar().getTimeInMillis()-timestamp;
K
i18n  
kohsuke 已提交
396
        return Util.getPastTimeString(duration);
K
kohsuke 已提交
397 398 399 400 401 402
    }

    /**
     * Returns the timestamp formatted in xs:dateTime.
     */
    public String getTimestampString2() {
403
        return Util.XS_DATETIME_FORMATTER.format(new Date(timestamp));
K
kohsuke 已提交
404 405 406 407 408 409
    }

    /**
     * Gets the string that says how long the build took to run.
     */
    public String getDurationString() {
410
        if(isBuilding())
411
            return Util.getTimeSpanString(System.currentTimeMillis()-timestamp)+" and counting";
K
kohsuke 已提交
412 413 414 415 416 417
        return Util.getTimeSpanString(duration);
    }

    /**
     * Gets the millisecond it took to build.
     */
K
kohsuke 已提交
418
    @Exported
K
kohsuke 已提交
419 420 421 422 423 424 425
    public long getDuration() {
        return duration;
    }

    /**
     * Gets the icon color for display.
     */
426
    public BallColor getIconColor() {
K
kohsuke 已提交
427 428
        if(!isBuilding()) {
            // already built
K
kohsuke 已提交
429
            return getResult().color;
K
kohsuke 已提交
430 431 432
        }

        // a new build is in progress
433
        BallColor baseColor;
K
kohsuke 已提交
434
        if(previousBuild==null)
435
            baseColor = BallColor.GREY;
K
kohsuke 已提交
436 437 438
        else
            baseColor = previousBuild.getIconColor();

439
        return baseColor.anime();
K
kohsuke 已提交
440 441 442 443 444 445 446 447 448 449
    }

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

    public String toString() {
K
kohsuke 已提交
450 451 452
        return getFullDisplayName();
    }

453
    @Exported
K
kohsuke 已提交
454
    public String getFullDisplayName() {
455
        return project.getFullDisplayName()+" #"+number;
K
kohsuke 已提交
456 457 458 459 460 461
    }

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

K
kohsuke 已提交
462
    @Exported(visibility=2)
K
kohsuke 已提交
463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500
    public int getNumber() {
        return number;
    }

    public RunT getPreviousBuild() {
        return previousBuild;
    }

    /**
     * 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;
    }

    // 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()+'/';
    }

501 502 503 504 505 506 507 508 509
    /**
     * 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 已提交
510
    @Exported(visibility=2,name="url")
511 512 513 514
    public final String getAbsoluteUrl() {
        return project.getAbsoluteUrl()+getNumber()+'/';
    }

515 516 517 518
    public final String getSearchUrl() {
        return getNumber()+"/";
    }

K
kohsuke 已提交
519 520 521 522
    /**
     * Unique ID of this build.
     */
    public String getId() {
523
        return ID_FORMATTER.get().format(new Date(timestamp));
K
kohsuke 已提交
524 525
    }

K
kohsuke 已提交
526 527 528 529 530
    /**
     * Root directory of this {@link Run} on the master.
     *
     * Files related to this {@link Run} should be stored below this directory.
     */
K
kohsuke 已提交
531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546
    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");
    }

    /**
     * Gets the first {@value #CUTOFF} artifacts (relative to {@link #getArtifactsDir()}.
     */
547
    @Exported
K
kohsuke 已提交
548
    public List<Artifact> getArtifacts() {
549
        ArtifactList r = new ArtifactList();
K
kohsuke 已提交
550
        addArtifacts(getArtifactsDir(),"",r);
551
        r.computeDisplayName();
K
kohsuke 已提交
552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581
        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() {
        return !getArtifacts().isEmpty();
    }

    private void addArtifacts( File dir, String path, List<Artifact> r ) {
        String[] children = dir.list();
        if(children==null)  return;
        for (String child : children) {
            if(r.size()>CUTOFF)
                return;
            File sub = new File(dir, child);
            if (sub.isDirectory()) {
                addArtifacts(sub, path + child + '/', r);
            } else {
                r.add(new Artifact(path + child));
            }
        }
    }

    private static final int CUTOFF = 17;   // 0, 1,... 16, and then "too many"

582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 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 652
    public final class ArtifactList extends ArrayList<Artifact> {
        public void computeDisplayName() {
            if(size()>CUTOFF)   return; // we are not going to display file names, so no point in computing this

            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) {
            StringBuffer buf = new StringBuffer();
            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 已提交
653 654 655
    /**
     * A build artifact.
     */
656
    @ExportedBean
K
kohsuke 已提交
657 658 659 660
    public class Artifact {
        /**
         * Relative path name from {@link Run#getArtifactsDir()}
         */
661
    	@Exported(visibility=3)
662
        public final String relativePath;
K
kohsuke 已提交
663

664 665 666 667 668 669 670
        /**
         * Truncated form of {@link #relativePath} just enough
         * to disambiguate {@link Artifact}s.
         */
        /*package*/ String displayPath;

        /*package for test*/ Artifact(String relativePath) {
K
kohsuke 已提交
671 672 673 674 675 676 677 678 679 680 681 682 683
            this.relativePath = relativePath;
        }

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

        /**
         * Returns just the file name portion, without the path.
         */
684
    	@Exported(visibility=3)
K
kohsuke 已提交
685 686 687 688
        public String getFileName() {
            return getFile().getName();
        }

689
    	@Exported(visibility=3)
690 691 692 693
        public String getDisplayPath() {
            return displayPath;
        }

K
kohsuke 已提交
694 695 696 697 698 699 700 701 702 703 704 705
        public String toString() {
            return relativePath;
        }
    }

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

706
    protected SearchIndexBuilder makeSearchIndex() {
707 708 709 710 711 712 713 714
        SearchIndexBuilder builder = super.makeSearchIndex()
                .add("console")
                .add("changes");
        for (Action a : getActions()) {
            if(a.getIconFileName()!=null)
                builder.add(a.getUrlName());
        }
        return builder;
715 716
    }

717 718 719 720
    public Api getApi(final StaplerRequest req) {
        return new Api(this);
    }

721
    public void checkPermission(Permission p) {
722 723 724
        getACL().checkPermission(p);
    }

725 726 727 728
    public boolean hasPermission(Permission p) {
        return getACL().hasPermission(p);
    }

729
    public ACL getACL() {
730
        // for now, don't maintain ACL per run, and do it at project level
731
        return getParent().getACL();
732 733
    }

K
kohsuke 已提交
734 735 736 737 738 739 740 741 742
    /**
     * Deletes this build and its entire log
     *
     * @throws IOException
     *      if we fail to delete.
     */
    public synchronized void delete() throws IOException {
        File rootDir = getRootDir();
        File tmp = new File(rootDir.getParentFile(),'.'+rootDir.getName());
743 744 745
        
        boolean renamingSucceeded = rootDir.renameTo(tmp);
        Util.deleteRecursive(tmp);
K
kohsuke 已提交
746

747
        if(!renamingSucceeded)
K
kohsuke 已提交
748 749
            throw new IOException(rootDir+" is in use");

J
jglick 已提交
750 751 752 753
        removeRunFromParent();
    }
    @SuppressWarnings("unchecked") // seems this is too clever for Java's type system?
    private void removeRunFromParent() {
K
kohsuke 已提交
754 755 756 757
        getParent().removeRun((RunT)this);
    }

    protected static interface Runner {
758 759 760 761 762 763 764
        /**
         * Performs the main build and returns the status code.
         *
         * @throws Exception
         *      exception will be recorded and the build will be considered a failure.
         */
        Result run( BuildListener listener ) throws Exception, RunnerAbortedException;
K
kohsuke 已提交
765

766 767
        /**
         * Performs the post-build action.
768
         * <p>
K
kohsuke 已提交
769 770 771 772 773
         * This method is called after the status of the build is determined.
         * 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
774
         * by {@link Job#getLastSuccessfulBuild()}.
775
         */
776
        void post( BuildListener listener ) throws Exception;
777 778 779 780 781 782 783 784 785 786 787 788

        /**
         * 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.
         */
        void cleanUp(BuildListener listener) throws Exception;
K
kohsuke 已提交
789 790
    }

791 792 793 794 795 796 797
    /**
     * 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 已提交
798 799 800 801
    protected final void run(Runner job) {
        if(result!=null)
            return;     // already built.

802 803 804
        BuildListener listener=null;
        PrintStream log = null;

K
kohsuke 已提交
805 806 807 808 809 810 811 812 813
        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 {
K
kohsuke 已提交
814
                    log = new PrintStream(new FileOutputStream(getLogFile()));
815 816 817
                    Charset charset = Computer.currentComputer().getDefaultCharset();
                    this.charset = charset.name();
                    listener = new StreamBuildListener(new PrintStream(new CloseProofOutputStream(log)),charset);
K
kohsuke 已提交
818 819 820

                    listener.started();

K
kohsuke 已提交
821 822
                    RunListener.fireStarted(this,listener);

K
kohsuke 已提交
823
                    setResult(job.run(listener));
K
kohsuke 已提交
824 825 826 827

                    LOGGER.info(toString()+" main build action completed: "+result);
                } catch (ThreadDeath t) {
                    throw t;
828 829
                } catch( AbortException e ) {
                    result = Result.FAILURE;
830 831
                } catch( RunnerAbortedException e ) {
                    result = Result.FAILURE;
832 833 834
                } catch( InterruptedException e) {
                    // aborted
                    result = Result.ABORTED;
K
i18n  
kohsuke 已提交
835
                    listener.getLogger().println(Messages.Run_BuildAborted());
836
                    LOGGER.log(Level.INFO,toString()+" aborted",e);
K
kohsuke 已提交
837 838 839 840 841
                } catch( Throwable e ) {
                    handleFatalBuildProblem(listener,e);
                    result = Result.FAILURE;
                }

K
kohsuke 已提交
842
                // even if the main build fails fatally, try to run post build processing
K
kohsuke 已提交
843 844 845 846 847 848 849
                job.post(listener);

            } catch (ThreadDeath t) {
                throw t;
            } catch( Throwable e ) {
                handleFatalBuildProblem(listener,e);
                result = Result.FAILURE;
K
kohsuke 已提交
850
            } finally {
851 852 853
                long end = System.currentTimeMillis();
                duration = end-start;

854
                // advance the state.
855 856 857 858
                // 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.
859
                state = State.POST_PRODUCTION;
860 861 862 863 864 865 866

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

868
                RunListener.fireCompleted(this,listener);
K
kohsuke 已提交
869

870 871 872 873
                if(listener!=null)
                    listener.finished(result);
                if(log!=null)
                    log.close();
K
kohsuke 已提交
874

875 876 877 878 879
                try {
                    save();
                } catch (IOException e) {
                    e.printStackTrace();
                }
K
kohsuke 已提交
880 881 882
            }

            try {
883
                getParent().logRotate();
K
kohsuke 已提交
884 885 886 887 888 889 890 891 892
            } catch (IOException e) {
                e.printStackTrace();
            }
        } finally {
            onEndBuilding();
        }
    }

    /**
K
kohsuke 已提交
893
     * Handles a fatal build problem (exception) that occurred during the build.
K
kohsuke 已提交
894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928
     */
    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;
    }

    /**
     * Called when a job finished building normally or abnormally.
     */
    protected void onEndBuilding() {
        state = State.COMPLETED;
        if(result==null) {
            // shouldn't happen, but be defensive until we figure out why
            result = Result.FAILURE;
            LOGGER.warning(toString()+": No build result is set, so marking as failure. This shouldn't happen");
        }
929
        RunListener.fireFinalized(this);
K
kohsuke 已提交
930 931 932 933 934 935
    }

    /**
     * Save the settings to a file.
     */
    public synchronized void save() throws IOException {
936
        if(BulkChange.contains(this))   return;
K
kohsuke 已提交
937 938 939 940 941 942 943 944 945 946
        getDataFile().write(this);
    }

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

    /**
     * Gets the log of the build as a string.
     *
947 948
     * @deprecated Use {@link #getLog(int)} instead as it avoids loading
     * the whole log into memory unnecessarily.
K
kohsuke 已提交
949
     */
950
    @Deprecated
K
kohsuke 已提交
951
    public String getLog() throws IOException {
952
        return Util.loadFile(getLogFile(),getCharset());
K
kohsuke 已提交
953 954
    }

955 956 957 958 959 960 961 962 963 964 965 966
    /**
     * 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>();
967
        BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(getLogFile()),getCharset()));
K
kohsuke 已提交
968 969 970 971 972 973 974 975 976 977 978 979 980
        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();
981 982 983 984 985 986 987 988 989 990 991
        }

        // 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...]");

        return logLines;
    }

K
kohsuke 已提交
992 993 994 995 996 997
    public void doBuildStatus( StaplerRequest req, StaplerResponse rsp ) throws IOException {
        // see Hudson.doNocacheImages. this is a work around for a bug in Firefox
        rsp.sendRedirect2(req.getContextPath()+"/nocacheImages/48x48/"+getBuildStatusUrl());
    }

    public String getBuildStatusUrl() {
998
        return getIconColor().getImage();
K
kohsuke 已提交
999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032
    }

    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)
                return new Summary(false,"stable");
            else
                return new Summary(false,"back to normal");
        }

        if(getResult()==Result.FAILURE) {
            RunT since = getPreviousNotFailedBuild();
            if(since==null)
                return new Summary(false,"broken for a long time");
            if(since==prev)
                return new Summary(true,"broken since this build");
J
jglick 已提交
1033
            return new Summary(false,"broken since "+since.getDisplayName());
K
kohsuke 已提交
1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044
        }

        if(getResult()==Result.ABORTED)
            return new Summary(false,"aborted");

        if(getResult()==Result.UNSTABLE) {
            if(((Run)this) instanceof Build) {
                AbstractTestResultAction trN = ((Build)(Run)this).getTestResultAction();
                AbstractTestResultAction trP = prev==null ? null : ((Build) prev).getTestResultAction();
                if(trP==null) {
                    if(trN!=null && trN.getFailCount()>0)
K
kohsuke 已提交
1045
                        return new Summary(false,combine(trN.getFailCount(),"test failure"));
K
kohsuke 已提交
1046 1047 1048 1049
                    else // ???
                        return new Summary(false,"unstable");
                }
                if(trP.getFailCount()==0)
K
kohsuke 已提交
1050
                    return new Summary(true,combine(trN.getFailCount(),"test")+" started to fail");
K
kohsuke 已提交
1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067
                if(trP.getFailCount() < trN.getFailCount())
                    return new Summary(true,combine(trN.getFailCount()-trP.getFailCount(),"more test")
                        +" are failing ("+trN.getFailCount()+" total)");
                if(trP.getFailCount() > trN.getFailCount())
                    return new Summary(false,combine(trP.getFailCount()-trN.getFailCount(),"less test")
                        +" are failing ("+trN.getFailCount()+" total)");

                return new Summary(false,combine(trN.getFailCount(),"test")+" are still failing");
            }
        }

        return new Summary(false,"?");
    }

    /**
     * Serves the artifacts.
     */
K
kohsuke 已提交
1068
    public void doArtifact( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException, InterruptedException {
K
kohsuke 已提交
1069 1070
        new DirectoryBrowserSupport(this,project.getDisplayName()+' '+getDisplayName())
            .serveFile(req, rsp, new FilePath(getArtifactsDir()), "package.gif", true);
K
kohsuke 已提交
1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082
    }

    /**
     * Returns the build number in the body.
     */
    public void doBuildNumber( StaplerRequest req, StaplerResponse rsp ) throws IOException {
        rsp.setContentType("text/plain");
        rsp.setCharacterEncoding("US-ASCII");
        rsp.setStatus(HttpServletResponse.SC_OK);
        rsp.getWriter().print(number);
    }

K
kohsuke 已提交
1083 1084 1085
    /**
     * Returns the build time stamp in the body.
     */
1086
    public void doBuildTimestamp( StaplerRequest req, StaplerResponse rsp, @QueryParameter String format) throws IOException {
K
kohsuke 已提交
1087 1088 1089
        rsp.setContentType("text/plain");
        rsp.setCharacterEncoding("US-ASCII");
        rsp.setStatus(HttpServletResponse.SC_OK);
K
kohsuke 已提交
1090 1091 1092
        DateFormat df = format==null ?
                DateFormat.getDateTimeInstance(DateFormat.SHORT,DateFormat.SHORT, Locale.ENGLISH) :
                new SimpleDateFormat(format,req.getLocale());
K
kohsuke 已提交
1093 1094 1095
        rsp.getWriter().print(df.format(getTimestamp().getTime()));
    }

K
kohsuke 已提交
1096 1097 1098 1099
    /**
     * Handles incremental log output.
     */
    public void doProgressiveLog( StaplerRequest req, StaplerResponse rsp) throws IOException {
1100
        new LargeText(getLogFile(),getCharset(),!isLogUpdated()).doProgressText(req,rsp);
K
kohsuke 已提交
1101 1102 1103
    }

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

K
kohsuke 已提交
1106
        keepLog(!keepLog);
K
kohsuke 已提交
1107 1108
        rsp.forwardToPreviousPage(req);
    }
K
kohsuke 已提交
1109 1110 1111 1112

    /**
     * Marks this build to keep the log.
     */
K
kohsuke 已提交
1113 1114 1115 1116 1117 1118
    public final void keepLog() throws IOException {
        keepLog(true);
    }

    public void keepLog(boolean newValue) throws IOException {
        keepLog = newValue;
K
kohsuke 已提交
1119 1120
        save();
    }
K
kohsuke 已提交
1121

1122 1123 1124 1125
    /**
     * Deletes the build when the button is pressed.
     */
    public void doDoDelete( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1126 1127
        checkPermission(DELETE);

1128 1129 1130
        // 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!
1131 1132
        String why = getWhyKeepLog();
        if (why!=null) {
K
i18n  
kohsuke 已提交
1133
            sendError(Messages.Run_UnableToDelete(toString(),why),req,rsp);
1134 1135 1136 1137 1138 1139
            return;
        }

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

K
kohsuke 已提交
1141
    public void setDescription(String description) throws IOException {
1142 1143
        checkPermission(UPDATE);
        this.description = description;
K
kohsuke 已提交
1144
        save();
1145 1146
    }
    
K
kohsuke 已提交
1147 1148 1149 1150 1151
    /**
     * Accepts the new description.
     */
    public synchronized void doSubmitDescription( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
        req.setCharacterEncoding("UTF-8");
1152
        setDescription(req.getParameter("description"));
K
kohsuke 已提交
1153 1154 1155 1156
        rsp.sendRedirect(".");  // go to the top page
    }

    /**
K
kohsuke 已提交
1157 1158
     * Returns the map that contains environmental variable overrides for this build.
     *
1159
     * <p>
K
kohsuke 已提交
1160 1161 1162 1163
     * {@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.
     *
1164 1165 1166 1167 1168 1169
     * <p>
     * On Windows systems, environment variables are case-preserving but
     * comparison/query is case insensitive (IOW, you can set 'Path' to something
     * and you get the same value by doing '%PATH%'.)  So to implement this semantics
     * the map returned from here is a {@link TreeMap} with a special comparator.
     *
K
kohsuke 已提交
1170 1171
     */
    public Map<String,String> getEnvVars() {
K
kohsuke 已提交
1172
        EnvVars env = new EnvVars();
K
kohsuke 已提交
1173 1174 1175
        env.put("BUILD_NUMBER",String.valueOf(number));
        env.put("BUILD_ID",getId());
        env.put("BUILD_TAG","hudson-"+getParent().getName()+"-"+number);
1176
        env.put("JOB_NAME",getParent().getFullName());
1177 1178 1179
        String rootUrl = Hudson.getInstance().getRootUrl();
        if(rootUrl!=null)
            env.put("HUDSON_URL", rootUrl);
K
kohsuke 已提交
1180 1181 1182 1183 1184 1185 1186

        Thread t = Thread.currentThread();
        if (t instanceof Executor) {
            Executor e = (Executor) t;
            env.put("EXECUTOR_NUMBER",String.valueOf(e.getNumber()));
        }

K
kohsuke 已提交
1187 1188 1189
        return env;
    }

H
huybrechts 已提交
1190
    public static final XStream XSTREAM = new XStream2();
K
kohsuke 已提交
1191
    static {
1192 1193 1194
        XSTREAM.alias("build",FreeStyleBuild.class);
        XSTREAM.alias("matrix-build",MatrixBuild.class);
        XSTREAM.alias("matrix-run",MatrixRun.class);
K
kohsuke 已提交
1195 1196 1197 1198 1199 1200 1201 1202 1203 1204
        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 已提交
1205 1206 1207 1208 1209
            long lt = lhs.getTimestamp().getTimeInMillis();
            long rt = rhs.getTimestamp().getTimeInMillis();
            if(lt>rt)   return -1;
            if(lt<rt)   return 1;
            return 0;
K
kohsuke 已提交
1210 1211 1212 1213 1214 1215
        }
    };

    /**
     * {@link FeedAdapter} to produce feed from the summary of this build.
     */
K
kohsuke 已提交
1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242
    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.
         */
        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 已提交
1243 1244
    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 已提交
1245 1246

    private static class DefaultFeedAdapter implements FeedAdapter<Run> {
K
kohsuke 已提交
1247 1248 1249 1250 1251 1252 1253 1254 1255
        public String getEntryTitle(Run entry) {
            return entry+" ("+entry.getResult()+")";
        }

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

        public String getEntryID(Run entry) {
1256 1257 1258
            return "tag:" + "hudson.dev.java.net,"
                + entry.getTimestamp().get(Calendar.YEAR) + ":"
                + entry.getParent().getName()+':'+entry.getId();
K
kohsuke 已提交
1259 1260
        }

1261 1262 1263 1264 1265
        public String getEntryDescription(Run entry) {
            // TODO: this could provide some useful details
            return null;
        }

K
kohsuke 已提交
1266 1267 1268
        public Calendar getEntryTimestamp(Run entry) {
            return entry.getTimestamp();
        }
1269 1270 1271 1272

        public String getEntryAuthor(Run entry) {
            return Mailer.DESCRIPTOR.getAdminAddress();
        }
1273
    }
1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290

    @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
            // may not have the action.. rather than 404, redirect up to the build page.
            result = new RedirectUp();
        return result;
    }

    public static class RedirectUp {
        public void doDynamic(StaplerRequest req, StaplerResponse rsp) throws IOException {
            rsp.sendRedirect("..");
        }
    }
K
kohsuke 已提交
1291
}