Job.java 34.4 KB
Newer Older
K
kohsuke 已提交
1 2
package hudson.model;

3
import static javax.servlet.http.HttpServletResponse.SC_BAD_REQUEST;
K
kohsuke 已提交
4
import hudson.ExtensionPoint;
5
import hudson.StructuredForm;
6
import hudson.Util;
7
import hudson.XmlFile;
8
import hudson.model.Descriptor.FormException;
9
import hudson.model.listeners.ItemListener;
10
import hudson.search.QuickSilver;
K
kohsuke 已提交
11
import hudson.search.SearchIndex;
12
import hudson.search.SearchIndexBuilder;
K
kohsuke 已提交
13 14
import hudson.search.SearchItem;
import hudson.search.SearchItems;
K
kohsuke 已提交
15
import hudson.tasks.LogRotator;
16
import hudson.util.AtomicFileWriter;
K
kohsuke 已提交
17
import hudson.util.ChartUtil;
K
kohsuke 已提交
18
import hudson.util.ColorPalette;
19
import hudson.util.CopyOnWriteList;
K
kohsuke 已提交
20 21 22 23
import hudson.util.DataSetBuilder;
import hudson.util.IOException2;
import hudson.util.RunList;
import hudson.util.ShiftedCategoryAxis;
K
kohsuke 已提交
24
import hudson.util.StackedAreaRenderer2;
K
kohsuke 已提交
25
import hudson.util.TextFile;
26
import hudson.widgets.HistoryWidget;
27
import hudson.widgets.Widget;
28 29 30 31 32 33
import hudson.widgets.HistoryWidget.Adapter;

import java.awt.Color;
import java.awt.Paint;
import java.io.File;
import java.io.IOException;
34 35
import java.io.StringWriter;
import java.io.PrintWriter;
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.SortedMap;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletResponse;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;

52
import net.sf.json.JSONObject;
53
import net.sf.json.JSONException;
54

K
kohsuke 已提交
55 56 57 58 59 60 61 62 63
import org.apache.tools.ant.taskdefs.Copy;
import org.apache.tools.ant.types.FileSet;
import org.jfree.chart.ChartFactory;
import org.jfree.chart.JFreeChart;
import org.jfree.chart.axis.CategoryAxis;
import org.jfree.chart.axis.CategoryLabelPositions;
import org.jfree.chart.axis.NumberAxis;
import org.jfree.chart.plot.CategoryPlot;
import org.jfree.chart.plot.PlotOrientation;
K
kohsuke 已提交
64
import org.jfree.chart.renderer.category.StackedAreaRenderer;
K
kohsuke 已提交
65 66 67 68
import org.jfree.data.category.CategoryDataset;
import org.jfree.ui.RectangleInsets;
import org.kohsuke.stapler.StaplerRequest;
import org.kohsuke.stapler.StaplerResponse;
69
import org.kohsuke.stapler.WebMethod;
K
kohsuke 已提交
70
import org.kohsuke.stapler.export.Exported;
K
kohsuke 已提交
71 72 73 74 75 76 77 78 79 80

/**
 * A job is an runnable entity under the monitoring of Hudson.
 *
 * <p>
 * Every time it "runs", it will be recorded as a {@link Run} object.
 *
 * @author Kohsuke Kawaguchi
 */
public abstract class Job<JobT extends Job<JobT,RunT>, RunT extends Run<JobT,RunT>>
81
        extends AbstractItem implements ExtensionPoint {
K
kohsuke 已提交
82 83

    /**
K
kohsuke 已提交
84
     * Next build number.
K
kohsuke 已提交
85 86 87 88 89 90 91
     * Kept in a separate file because this is the only information
     * that gets updated often. This allows the rest of the configuration
     * to be in the VCS.
     * <p>
     * In 1.28 and earlier, this field was stored in the project configuration file,
     * so even though this is marked as transient, don't move it around.
     */
K
kohsuke 已提交
92
    protected transient volatile int nextBuildNumber = 1;
K
kohsuke 已提交
93

K
kohsuke 已提交
94
    private volatile LogRotator logRotator;
95 96 97 98 99 100 101
    
    /**
     * Not all plugins are good at calculating their health report quickly.
     * These fields are used to cache the health reports to speed up rendering the main page.
     */
    private transient Integer cachedBuildHealthReportsBuildNumber = null;
    private transient List<HealthReport> cachedBuildHealthReports = null;
K
kohsuke 已提交
102 103 104

    private boolean keepDependencies;

105 106 107
    /**
     * List of {@link UserProperty}s configured for this project.
     */
K
kohsuke 已提交
108
    protected CopyOnWriteList<JobProperty<? super JobT>> properties = new CopyOnWriteList<JobProperty<? super JobT>>();
109

110 111
    protected Job(ItemGroup parent,String name) {
        super(parent,name);
K
kohsuke 已提交
112 113
    }

114 115
    public void onLoad(ItemGroup<? extends Item> parent, String name) throws IOException {
        super.onLoad(parent, name);
K
kohsuke 已提交
116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131

        TextFile f = getNextBuildNumberFile();
        if(f.exists()) {
            // starting 1.28, we store nextBuildNumber in a separate file.
            // but old Hudson didn't do it, so if the file doesn't exist,
            // assume that nextBuildNumber was read from config.xml
            try {
                this.nextBuildNumber = Integer.parseInt(f.readTrim());
            } catch (NumberFormatException e) {
                throw new IOException2(f+" doesn't contain a number",e);
            }
        } else {
            // this must be the old Hudson. create this file now.
            saveNextBuildNumber();
            save(); // and delete it from the config.xml
        }
132 133 134

        if(properties==null) // didn't exist < 1.72
            properties = new CopyOnWriteList<JobProperty<? super JobT>>();
K
kohsuke 已提交
135 136 137

        for (JobProperty p : properties)
            p.setOwner(this);
K
kohsuke 已提交
138 139
    }

140 141 142 143 144 145
    @Override
    public void onCopiedFrom(Item src) {
        super.onCopiedFrom(src);
        this.nextBuildNumber = 1;     // reset the next build number
    }

K
kohsuke 已提交
146 147 148 149 150 151 152 153 154 155 156 157 158
    protected void performDelete() throws IOException {
        // if a build is in progress. Cancel it.
        RunT lb = getLastBuild();
        if(lb!=null) {
            Executor e = lb.getExecutor();
            if(e!=null) {
                e.interrupt();
                // should we block until the build is cancelled?
            }
        }
        super.performDelete();
    }

K
kohsuke 已提交
159
    private TextFile getNextBuildNumberFile() {
160
        return new TextFile(new File(this.getRootDir(),"nextBuildNumber"));
K
kohsuke 已提交
161 162
    }

163
    protected void saveNextBuildNumber() throws IOException {
K
kohsuke 已提交
164 165 166
        getNextBuildNumberFile().write(String.valueOf(nextBuildNumber)+'\n');
    }

K
kohsuke 已提交
167
    @Exported
K
kohsuke 已提交
168 169 170 171
    public boolean isInQueue() {
        return false;
    }

K
kohsuke 已提交
172 173 174
    /**
     * If this job is in the build queue, return its item.
     */
K
kohsuke 已提交
175
    @Exported
K
kohsuke 已提交
176 177 178 179
    public Queue.Item getQueueItem() {
        return null;
    }

180 181 182 183 184
    /**
     * Get the term used in the UI to represent this kind of {@link AbstractProject}.
     * Must start with a capital letter.
     */
    public String getPronoun() {
K
i18n  
kohsuke 已提交
185
        return Messages.Job_Pronoun();
186 187
    }

188 189 190 191 192 193 194
    /**
     * Returns whether the name of this job can be changed by user.
     */
    public boolean isNameEditable() {
        return true;
    }

K
kohsuke 已提交
195 196 197
    /**
     * If true, it will keep all the build logs of dependency components.
     */
K
kohsuke 已提交
198
    @Exported
K
kohsuke 已提交
199 200 201 202 203 204 205 206 207 208 209 210 211
    public boolean isKeepDependencies() {
        return keepDependencies;
    }

    /**
     * Allocates a new buildCommand number.
     */
    public synchronized int assignBuildNumber() throws IOException {
        int r = nextBuildNumber++;
        saveNextBuildNumber();
        return r;
    }

212 213 214
    /**
     * Peeks the next build number.
     */
K
kohsuke 已提交
215
    @Exported
K
kohsuke 已提交
216 217 218 219
    public int getNextBuildNumber() {
        return nextBuildNumber;
    }

220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237
    /**
     * Programatically updates the next build number.
     *
     * <p>
     * Much of Hudson assumes that the build number is unique and monotonic,
     * so this method can only accept a new value that's bigger than
     * {@link #getNextBuildNumber()} returns. Otherwise it'll be no-op.
     *
     * @since 1.199
     *      (before that, this method was package private.)
     */
    public void updateNextBuildNumber(int next) throws IOException {
        if(next>nextBuildNumber) {
            this.nextBuildNumber = next;
            saveNextBuildNumber();
        }
    }

K
kohsuke 已提交
238 239 240 241 242 243 244 245 246 247 248
    /**
     * Returns the log rotator for this job, or null if none.
     */
    public LogRotator getLogRotator() {
        return logRotator;
    }

    public void setLogRotator(LogRotator logRotator) {
        this.logRotator = logRotator;
    }

249 250 251 252 253 254 255 256 257
    /**
     * Perform log rotation.
     */
    public void logRotate() throws IOException {
        LogRotator lr = getLogRotator();
        if(lr!=null)
            lr.perform(this);
    }

K
kohsuke 已提交
258 259 260 261 262 263 264
    /**
     * True if this instance supports log rotation configuration.
     */
    public boolean supportsLogRotator() {
        return true;
    }

K
kohsuke 已提交
265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282
    protected SearchIndexBuilder makeSearchIndex() {
        return super.makeSearchIndex()
            .add(new SearchIndex() {
                public void find(String token, List<SearchItem> result) {
                    try {
                        if(token.startsWith("#"))   token=token.substring(1);   // ignore leading '#'
                        int n = Integer.parseInt(token);
                        Run b = getBuildByNumber(n);
                        if(b==null) return; // no such build
                        result.add(SearchItems.create("#"+n,""+n,b));
                    } catch (NumberFormatException e) {
                        // not a number.
                    }
                }

                public void suggest(String token, List<SearchItem> result) {
                    find(token,result);
                }
K
kohsuke 已提交
283
            }).add("configure","config","configure");
K
kohsuke 已提交
284 285
    }

286
    public Collection<? extends Job> getAllJobs() {
287 288 289
        return Collections.<Job>singleton(this);
    }

290 291 292 293 294 295 296 297
    /**
     * Adds {@link JobProperty}.
     * @since 1.188
     */
    public void addProperty(JobProperty<? super JobT> jobProp) throws IOException {
        properties.add(jobProp);
        save();
    }
298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316
    /**
     * Gets all the job properties configured for this job.
     */
    @SuppressWarnings("unchecked")
    public Map<JobPropertyDescriptor,JobProperty<? super JobT>> getProperties() {
        return Descriptor.toMap((Iterable)properties);
    }

    /**
     * Gets the specific property, or null if the propert is not configured for this job.
     */
    public <T extends JobProperty> T getProperty(Class<T> clazz) {
        for (JobProperty p : properties) {
            if(clazz.isInstance(p))
                return clazz.cast(p);
        }
        return null;
    }

317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344
    public List<Widget> getWidgets() {
        ArrayList<Widget> r = new ArrayList<Widget>();
        r.add(createHistoryWidget());
        return r;
    }

    protected HistoryWidget createHistoryWidget() {
        return new HistoryWidget<Job,RunT>(this,getBuilds(),HISTORY_ADAPTER);
    }

    protected static final HistoryWidget.Adapter<Run> HISTORY_ADAPTER = new Adapter<Run>() {
        public int compare(Run record, String key) {
            return record.getNumber()-Integer.parseInt(key);
        }

        public String getKey(Run record) {
            return String.valueOf(record.getNumber());
        }

        public boolean isBuilding(Run record) {
            return record.isBuilding();
        }

        public String getNextKey(String key) {
            return String.valueOf(Integer.parseInt(key)+1);
        }
    };

K
kohsuke 已提交
345 346
    /**
     * Renames a job.
K
kohsuke 已提交
347 348 349 350
     *
     * <p>
     * This method is defined on {@link Job} but really only applicable
     * for {@link Job}s that are top-level items.
K
kohsuke 已提交
351 352 353
     */
    public void renameTo(String newName) throws IOException {
        // always synchronize from bigger objects first
354
        final Hudson parent = Hudson.getInstance();
K
kohsuke 已提交
355
        assert this instanceof TopLevelItem;
K
kohsuke 已提交
356 357 358 359 360
        synchronized(parent) {
            synchronized(this) {
                // sanity check
                if(newName==null)
                    throw new IllegalArgumentException("New name is not given");
361
                if(parent.getItem(newName)!=null)
K
kohsuke 已提交
362 363 364 365 366 367 368 369
                    throw new IllegalArgumentException("Job "+newName+" already exists");

                // noop?
                if(this.name.equals(newName))
                    return;


                String oldName = this.name;
370
                File oldRoot = this.getRootDir();
K
kohsuke 已提交
371 372

                doSetName(newName);
373
                File newRoot = this.getRootDir();
K
kohsuke 已提交
374

375 376 377
                boolean success = false;

                try {// rename data files
K
kohsuke 已提交
378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423
                    boolean interrupted=false;
                    boolean renamed = false;

                    // try to rename the job directory.
                    // this may fail on Windows due to some other processes accessing a file.
                    // so retry few times before we fall back to copy.
                    for( int retry=0; retry<5; retry++ ) {
                        if(oldRoot.renameTo(newRoot)) {
                            renamed = true;
                            break; // succeeded
                        }
                        try {
                            Thread.sleep(500);
                        } catch (InterruptedException e) {
                            // process the interruption later
                            interrupted = true;
                        }
                    }

                    if(interrupted)
                        Thread.currentThread().interrupt();

                    if(!renamed) {
                        // failed to rename. it must be that some lengthy process is going on
                        // to prevent a rename operation. So do a copy. Ideally we'd like to
                        // later delete the old copy, but we can't reliably do so, as before the VM
                        // shuts down there might be a new job created under the old name.
                        Copy cp = new Copy();
                        cp.setProject(new org.apache.tools.ant.Project());
                        cp.setTodir(newRoot);
                        FileSet src = new FileSet();
                        src.setDir(getRootDir());
                        cp.addFileset(src);
                        cp.setOverwrite(true);
                        cp.setPreserveLastModified(true);
                        cp.setFailOnError(false);   // keep going even if there's an error
                        cp.execute();

                        // try to delete as much as possible
                        try {
                            Util.deleteRecursive(oldRoot);
                        } catch (IOException e) {
                            // but ignore the error, since we expect that
                            e.printStackTrace();
                        }
                    }
424 425 426 427 428 429

                    success = true;
                } finally {
                    // if failed, back out the rename.
                    if(!success)
                        doSetName(oldName);
K
kohsuke 已提交
430 431
                }

K
kohsuke 已提交
432
                parent.onRenamed((TopLevelItem)this,oldName,newName);
K
kohsuke 已提交
433

434 435
                for (ItemListener l : Hudson.getInstance().getJobListeners())
                    l.onRenamed(this,oldName,newName);
K
kohsuke 已提交
436 437 438 439 440 441 442
            }
        }
    }

    /**
     * Returns true if we should display "build now" icon
     */
K
kohsuke 已提交
443
    @Exported
K
kohsuke 已提交
444 445 446 447 448 449
    public abstract boolean isBuildable();

    /**
     * Gets all the builds.
     *
     * @return
K
kohsuke 已提交
450
     *      never null. The first entry is the latest build.
K
kohsuke 已提交
451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467
     */
    public List<RunT> getBuilds() {
        return new ArrayList<RunT>(_getRuns().values());
    }

    /**
     * Gets all the builds in a map.
     */
    public SortedMap<Integer,RunT> getBuildsAsMap() {
        return Collections.unmodifiableSortedMap(_getRuns());
    }

    /**
     * @deprecated
     *      This is only used to support backward compatibility with
     *      old URLs.
     */
J
jglick 已提交
468
    @Deprecated
K
kohsuke 已提交
469 470 471 472 473 474 475 476 477 478 479
    public RunT getBuild(String id) {
        for (RunT r : _getRuns().values()) {
            if(r.getId().equals(id))
                return r;
        }
        return null;
    }

    /**
     * @param n
     *      The build number.
K
kohsuke 已提交
480 481
     * @return
     *      null if no such build exists.
K
kohsuke 已提交
482 483 484 485 486 487
     * @see Run#getNumber()
     */
    public RunT getBuildByNumber(int n) {
        return _getRuns().get(n);
    }

K
kohsuke 已提交
488
    /**
K
kohsuke 已提交
489
     * Gets the youngest build #m that satisfies <tt>n&lt;=m</tt>.
K
kohsuke 已提交
490 491 492 493
     *
     * This is useful when you'd like to fetch a build but the exact build might be already
     * gone (deleted, rotated, etc.)
     */
K
kohsuke 已提交
494
    public final RunT getNearestBuild(int n) {
K
kohsuke 已提交
495
        SortedMap<Integer, ? extends RunT> m = _getRuns().headMap(n-1); // the map should include n, so n-1
K
kohsuke 已提交
496
        if(m.isEmpty()) return null;
497
        return m.get(m.lastKey());
K
kohsuke 已提交
498 499
    }

K
kohsuke 已提交
500 501 502 503 504 505 506 507 508 509 510 511
    /**
     * Gets the latest build #m that satisfies <tt>m&lt;=n</tt>.
     *
     * This is useful when you'd like to fetch a build but the exact build might be already
     * gone (deleted, rotated, etc.)
     */
    public final RunT getNearestOldBuild(int n) {
        SortedMap<Integer, ? extends RunT> m = _getRuns().tailMap(n);
        if(m.isEmpty()) return null;
        return m.get(m.firstKey());
    }

K
kohsuke 已提交
512 513 514 515 516
    public Object getDynamic(String token, StaplerRequest req, StaplerResponse rsp) {
        try {
            // try to interpret the token as build number
            return _getRuns().get(Integer.valueOf(token));
        } catch (NumberFormatException e) {
517 518 519 520 521 522
            // try to map that to widgets
            for (Widget w : getWidgets()) {
                if(w.getUrlName().equals(token))
                    return w;
            }
            
K
kohsuke 已提交
523 524 525 526 527 528 529 530 531 532 533 534 535 536
            return super.getDynamic(token,req,rsp);
        }
    }

    /**
     * Directory for storing {@link Run} records.
     * <p>
     * Some {@link Job}s may not have backing data store for {@link Run}s,
     * but those {@link Job}s that use file system for storing data
     * should use this directory for consistency.
     *
     * @see RunMap
     */
    protected File getBuildDir() {
537
        return new File(getRootDir(),"builds");
K
kohsuke 已提交
538 539 540 541 542 543
    }

    /**
     * Gets all the runs.
     *
     * The resulting map must be immutable (by employing copy-on-write semantics.)
544
     * The map is descending order, with newest builds at the top.
K
kohsuke 已提交
545 546 547 548 549 550 551 552 553 554 555 556 557 558
     */
    protected abstract SortedMap<Integer,? extends RunT> _getRuns();

    /**
     * Called from {@link Run} to remove it from this job.
     *
     * The files are deleted already. So all the callee needs to do
     * is to remove a reference from this {@link Job}.
     */
    protected abstract void removeRun(RunT run);

    /**
     * Returns the last build.
     */
559
    @Exported @QuickSilver
K
kohsuke 已提交
560 561 562 563 564 565 566 567 568 569
    public RunT getLastBuild() {
        SortedMap<Integer,? extends RunT> runs = _getRuns();

        if(runs.isEmpty())    return null;
        return runs.get(runs.firstKey());
    }

    /**
     * Returns the oldest build in the record.
     */
570
    @Exported @QuickSilver
K
kohsuke 已提交
571 572 573 574 575 576 577 578 579
    public RunT getFirstBuild() {
        SortedMap<Integer,? extends RunT> runs = _getRuns();

        if(runs.isEmpty())    return null;
        return runs.get(runs.lastKey());
    }

    /**
     * Returns the last successful build, if any. Otherwise null.
K
kohsuke 已提交
580
     * A stable build would include either {@link Result#SUCCESS} or {@link Result#UNSTABLE}.
581
     * @see #getLastStableBuild()
K
kohsuke 已提交
582
     */
583
    @Exported @QuickSilver
K
kohsuke 已提交
584 585 586 587 588 589 590 591 592 593 594
    public RunT getLastSuccessfulBuild() {
        RunT r = getLastBuild();
        // temporary hack till we figure out what's causing this bug
        while(r!=null && (r.isBuilding() || r.getResult()==null || r.getResult().isWorseThan(Result.UNSTABLE)))
            r=r.getPreviousBuild();
        return r;
    }

    /**
     * Returns the last stable build, if any. Otherwise null.
     */
595
    @Exported @QuickSilver
K
kohsuke 已提交
596 597 598 599 600 601 602 603 604 605
    public RunT getLastStableBuild() {
        RunT r = getLastBuild();
        while(r!=null && (r.isBuilding() || r.getResult().isWorseThan(Result.SUCCESS)))
            r=r.getPreviousBuild();
        return r;
    }

    /**
     * Returns the last failed build, if any. Otherwise null.
     */
606
    @Exported @QuickSilver
K
kohsuke 已提交
607 608 609 610 611 612
    public RunT getLastFailedBuild() {
        RunT r = getLastBuild();
        while(r!=null && (r.isBuilding() || r.getResult()!=Result.FAILURE))
            r=r.getPreviousBuild();
        return r;
    }
613 614 615 616 617 618 619 620 621 622 623
    
    /**
     * Returns the last completed build, if any. Otherwise null.
     */
    @Exported @QuickSilver
    public RunT getLastCompletedBuild() {
       RunT r = getLastBuild();
       while(r!=null && r.isBuilding())
           r=r.getPreviousBuild();
       return r;
    }
K
kohsuke 已提交
624 625 626 627

    /**
     * Used as the color of the status ball for the project.
     */
K
kohsuke 已提交
628
    @Exported(visibility=2,name="color")
629
    public BallColor getIconColor() {
K
kohsuke 已提交
630 631 632 633 634 635 636
        RunT lastBuild = getLastBuild();
        while(lastBuild!=null && lastBuild.hasntStartedYet())
            lastBuild = lastBuild.getPreviousBuild();

        if(lastBuild!=null)
            return lastBuild.getIconColor();
        else
637
            return BallColor.GREY;
K
kohsuke 已提交
638 639
    }

S
stephenconnolly 已提交
640 641 642 643 644
    /**
     * Get the current health report for a job.
     * @return
     *     the health report.  Never returns null
     */
645
    public HealthReport getBuildHealth() {
646 647 648
        List<HealthReport> reports = getBuildHealthReports();
        return reports.isEmpty() ? new HealthReport() : reports.get(0);
    }
S
stephenconnolly 已提交
649

650
    @Exported(name="healthReport")
651 652
    public List<HealthReport> getBuildHealthReports() {
        List<HealthReport> reports = new ArrayList<HealthReport>();
S
stephenconnolly 已提交
653
        RunT lastBuild = getLastBuild();
654 655

        if (lastBuild != null && lastBuild.isBuilding()) {
656
            // show the previous build's report until the current one is finished building.
657 658 659
            lastBuild = lastBuild.getPreviousBuild();
        }

660 661 662 663 664 665 666
        // check the cache
        if (cachedBuildHealthReportsBuildNumber != null && 
                cachedBuildHealthReports != null &&
                lastBuild != null &&
                cachedBuildHealthReportsBuildNumber.intValue() == lastBuild.getNumber()) {
            reports.addAll(cachedBuildHealthReports);
        } else if (lastBuild != null) {
S
stephenconnolly 已提交
667
            for (HealthReportingAction healthReportingAction : lastBuild.getActions(HealthReportingAction.class)) {
668 669
                final HealthReport report = healthReportingAction.getBuildHealth();
                if (report != null) {
670 671 672 673 674
                    if (report.isAggregateReport()) {
                        reports.addAll(report.getAggregatedReports());
                    } else {
                        reports.add(report);
                    }
675 676 677 678
                }
            }
            final HealthReport report = getBuildStabilityHealthReport();
            if (report != null) {
679 680 681 682 683
                if (report.isAggregateReport()) {
                    reports.addAll(report.getAggregatedReports());
                } else {
                    reports.add(report);
                }
684
            }
685 686 687 688 689 690

            Collections.sort(reports);
    
            // store the cache
            cachedBuildHealthReportsBuildNumber = lastBuild.getNumber();
            cachedBuildHealthReports = new ArrayList<HealthReport>(reports);
691
        }
S
stephenconnolly 已提交
692

693
        return reports;
S
stephenconnolly 已提交
694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726
    }

    private HealthReport getBuildStabilityHealthReport() {
        // we can give a simple view of build health from the last five builds
        int failCount = 0;
        int totalCount = 0;
        RunT i = getLastBuild();
        while (totalCount < 5 && i != null) {
            switch (i.getIconColor()) {
                case BLUE:
                case YELLOW:
                    //failCount stays the same
                    totalCount++;
                    break;
                case RED:
                    failCount++;
                    totalCount++;
                    break;

                default:
                    // do nothing as these are inconclusive statuses
                    break;
            }
            i = i.getPreviousBuild();
        }
        if (totalCount > 0) {
            int score = (int) ((100.0 * (totalCount - failCount)) / totalCount);
            if (score < 100 && score > 0) {
                // HACK
                // force e.g. 4/5 to be in the 60-79 range
                score--;
            }

K
i18n  
kohsuke 已提交
727
            String description;
S
stephenconnolly 已提交
728
            if (failCount == 0) {
K
i18n  
kohsuke 已提交
729
                description = Messages.Job_NoRecentBuildFailed();
S
stephenconnolly 已提交
730 731 732 733
            } else if (totalCount == failCount) {
                // this should catch the case where totalCount == 1
                // as failCount must be between 0 and totalCount
                // and we can't get here if failCount == 0
K
i18n  
kohsuke 已提交
734
                description = Messages.Job_AllRecentBuildFailed();
S
stephenconnolly 已提交
735
            } else {
K
i18n  
kohsuke 已提交
736
                description = Messages.Job_NOfMFailed(failCount,totalCount);
S
stephenconnolly 已提交
737
            }
K
i18n  
kohsuke 已提交
738
            return new HealthReport(score, Messages.Job_BuildStability(description));
S
stephenconnolly 已提交
739 740
        }
        return null;
741
    }
K
kohsuke 已提交
742 743 744 745 746 747 748 749 750

//
//
// actions
//
//
    /**
     * Accepts submission from the configuration page.
     */
751
    public synchronized void doConfigSubmit(StaplerRequest req, StaplerResponse rsp) throws IOException, ServletException {
752
        checkPermission(CONFIGURE);
K
kohsuke 已提交
753 754 755 756 757

        req.setCharacterEncoding("UTF-8");

        description = req.getParameter("description");

758
        if (req.getParameter("logrotate") != null)
K
kohsuke 已提交
759 760 761 762
            logRotator = LogRotator.DESCRIPTOR.newInstance(req);
        else
            logRotator = null;

763
        keepDependencies = req.getParameter("keepDependencies") != null;
K
kohsuke 已提交
764

765 766
        try {
            properties.clear();
767 768 769 770

            JSONObject json = StructuredForm.get(req);

            int i=0;
K
kohsuke 已提交
771
            for (JobPropertyDescriptor d : JobPropertyDescriptor.getPropertyDescriptors(Job.this.getClass())) {
772 773
                String name = "jobProperty"+(i++);
                JobProperty prop = d.newInstance(req,json.getJSONObject(name));
K
kohsuke 已提交
774 775
                if (prop != null) {
                    prop.setOwner(this);
776
                    properties.add(prop);
K
kohsuke 已提交
777
                }
778
            }
779 780 781 782 783 784 785

            submit(req,rsp);

            save();

            String newName = req.getParameter("name");
            if(newName!=null && !newName.equals(name)) {
K
kohsuke 已提交
786 787 788 789 790 791 792
                // check this error early to avoid HTTP response splitting.
                try {
                    Hudson.checkGoodName(newName);
                } catch (ParseException e) {
                    sendError(e,req,rsp);
                    return;
                }
793 794 795 796
                rsp.sendRedirect("rename?newName="+newName);
            } else {
                rsp.sendRedirect(".");
            }
797
        } catch (FormException e) {
798
            rsp.setStatus(SC_BAD_REQUEST);
799
            sendError(e,req,rsp);
800 801 802 803 804 805 806 807 808 809
        } catch (JSONException e) {
            StringWriter sw = new StringWriter();
            PrintWriter pw = new PrintWriter(sw);
            pw.println("Failed to parse form data. Please report this probelm as a bug");
            pw.println("JSON="+StructuredForm.get(req));
            pw.println();
            e.printStackTrace(pw);

            rsp.setStatus(SC_BAD_REQUEST);
            sendError(sw.toString(),req,rsp);
810
        }
811
    }
K
kohsuke 已提交
812

813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841
    /**
     * Accepts <tt>config.xml</tt> submission, as well as serve it.
     */
    @WebMethod(name="config.xml")
    public void doConfigDotXml(StaplerRequest req, StaplerResponse rsp) throws IOException {
        checkPermission(CONFIGURE);

        if(req.getMethod().equals("GET")) {
            // read
            rsp.setContentType("application/xml;charset=UTF-8");
            getConfigFile().writeRawTo(rsp.getWriter());
            return;
        }
        if(req.getMethod().equals("POST")) {
            // submission
            XmlFile configXmlFile = getConfigFile();
            AtomicFileWriter out = new AtomicFileWriter(configXmlFile.getFile());

            try {
                // this allows us to use UTF-8 for storing data,
                // plus it checks any well-formedness issue in the submitted data
                Transformer t = TransformerFactory.newInstance().newTransformer();
                t.transform(new StreamSource(req.getReader()),new StreamResult(out));
                out.close();
            } catch (TransformerException e) {
                throw new IOException2("Failed to persist configuration.xml",e);
            }

            // try to reflect the changes by reloading
842
            new XmlFile(Items.XSTREAM, out.getTemporaryFile()).unmarshal(this);
843
            onLoad(getParent(),getRootDir().getName());
844 845 846 847 848 849 850 851 852 853

            // if everything went well, commit this new version
            out.commit();
            return;
        }

        // huh?
        rsp.sendError(SC_BAD_REQUEST);
    }

854 855 856 857
    /**
     * Derived class can override this to perform additional config submission work.
     */
    protected void submit(StaplerRequest req, StaplerResponse rsp) throws IOException, ServletException, FormException {
K
kohsuke 已提交
858 859 860 861 862 863 864 865 866 867
    }

    /**
     * Returns the image that shows the current buildCommand status.
     */
    public void doBuildStatus( StaplerRequest req, StaplerResponse rsp ) throws IOException {
        rsp.sendRedirect2(req.getContextPath()+"/nocacheImages/48x48/"+getBuildStatusUrl());
    }

    public String getBuildStatusUrl() {
868
        return getIconColor().getImage();
K
kohsuke 已提交
869 870 871 872 873 874
    }

    /**
     * Returns the graph that shows how long each build took.
     */
    public void doBuildTimeGraph( StaplerRequest req, StaplerResponse rsp ) throws IOException {
K
kohsuke 已提交
875 876 877 878
        if(getLastBuild()==null) {
            rsp.setStatus(HttpServletResponse.SC_NOT_FOUND);
            return;
        }
K
kohsuke 已提交
879 880
        if(req.checkIfModified(getLastBuild().getTimestamp(),rsp))
            return;
K
kohsuke 已提交
881 882 883
        ChartUtil.generateGraph(req,rsp, createBuildTimeTrendChart(),500,400);
    }

K
kohsuke 已提交
884 885 886 887
    /**
     * Returns the clickable map for the build time graph.
     * Loaded lazily by AJAX.
     */
K
kohsuke 已提交
888
    public void doBuildTimeGraphMap( StaplerRequest req, StaplerResponse rsp ) throws IOException {
K
kohsuke 已提交
889 890 891 892
        if(getLastBuild()==null) {
            rsp.setStatus(HttpServletResponse.SC_NOT_FOUND);
            return;
        }
K
kohsuke 已提交
893 894
        if(req.checkIfModified(getLastBuild().getTimestamp(),rsp))
            return;
K
kohsuke 已提交
895 896 897 898
        ChartUtil.generateClickableMap(req,rsp, createBuildTimeTrendChart(),500,400);
    }

    private JFreeChart createBuildTimeTrendChart() {
899
        class ChartLabel implements Comparable<ChartLabel> {
K
kohsuke 已提交
900
            final Run run;
K
kohsuke 已提交
901

902
            public ChartLabel(Run r) {
K
kohsuke 已提交
903 904 905
                this.run = r;
            }

906
            public int compareTo(ChartLabel that) {
K
kohsuke 已提交
907 908 909 910
                return this.run.number-that.run.number;
            }

            public boolean equals(Object o) {
911
                ChartLabel that = (ChartLabel) o;
K
kohsuke 已提交
912 913 914
                return run ==that.run;
            }

K
kohsuke 已提交
915
            public Color getColor() {
K
kohsuke 已提交
916
                // TODO: consider gradation. See http://www.javadrive.jp/java2d/shape/index9.html
K
kohsuke 已提交
917 918 919 920 921 922 923
                Result r = run.getResult();
                if(r ==Result.FAILURE || r== Result.ABORTED)
                    return ColorPalette.RED;
                else
                    return ColorPalette.BLUE;
            }

K
kohsuke 已提交
924 925 926 927 928 929 930 931 932 933 934 935 936
            public int hashCode() {
                return run.hashCode();
            }

            public String toString() {
                String l = run.getDisplayName();
                if(run instanceof Build) {
                    String s = ((Build)run).getBuiltOnStr();
                    if(s!=null)
                        l += ' '+s;
                }
                return l;
            }
K
kohsuke 已提交
937

K
kohsuke 已提交
938 939
        }

940
        DataSetBuilder<String,ChartLabel> data = new DataSetBuilder<String, ChartLabel>();
K
kohsuke 已提交
941 942
        for( Run r : getBuilds() ) {
            if(r.isBuilding())  continue;
K
i18n  
kohsuke 已提交
943
            data.add( ((double)r.getDuration())/(1000*60), "min", new ChartLabel(r));
K
kohsuke 已提交
944
        }
K
kohsuke 已提交
945

K
kohsuke 已提交
946
        final CategoryDataset dataset = data.build();
K
kohsuke 已提交
947 948 949 950

        final JFreeChart chart = ChartFactory.createStackedAreaChart(
            null,                   // chart title
            null,                   // unused
K
i18n  
kohsuke 已提交
951
            Messages.Job_minutes(),   // range axis label
K
kohsuke 已提交
952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979
            dataset,                  // data
            PlotOrientation.VERTICAL, // orientation
            false,                     // include legend
            true,                     // tooltips
            false                     // urls
        );

        chart.setBackgroundPaint(Color.white);

        final CategoryPlot plot = chart.getCategoryPlot();

        // plot.setAxisOffset(new Spacer(Spacer.ABSOLUTE, 5.0, 5.0, 5.0, 5.0));
        plot.setBackgroundPaint(Color.WHITE);
        plot.setOutlinePaint(null);
        plot.setForegroundAlpha(0.8f);
//        plot.setDomainGridlinesVisible(true);
//        plot.setDomainGridlinePaint(Color.white);
        plot.setRangeGridlinesVisible(true);
        plot.setRangeGridlinePaint(Color.black);

        CategoryAxis domainAxis = new ShiftedCategoryAxis(null);
        plot.setDomainAxis(domainAxis);
        domainAxis.setCategoryLabelPositions(CategoryLabelPositions.UP_90);
        domainAxis.setLowerMargin(0.0);
        domainAxis.setUpperMargin(0.0);
        domainAxis.setCategoryMargin(0.0);

        final NumberAxis rangeAxis = (NumberAxis) plot.getRangeAxis();
980
        ChartUtil.adjustChebyshev(dataset,rangeAxis);
K
kohsuke 已提交
981 982
        rangeAxis.setStandardTickUnits(NumberAxis.createIntegerTickUnits());

K
kohsuke 已提交
983 984
        StackedAreaRenderer ar = new StackedAreaRenderer2() {
            @Override
K
kohsuke 已提交
985
            public Paint getItemPaint(int row, int column) {
986
                ChartLabel key = (ChartLabel) dataset.getColumnKey(column);
K
kohsuke 已提交
987 988
                return key.getColor();
            }
K
kohsuke 已提交
989 990 991

            @Override
            public String generateURL(CategoryDataset dataset, int row, int column) {
992
                ChartLabel label = (ChartLabel) dataset.getColumnKey(column);
K
kohsuke 已提交
993
                return String.valueOf(label.run.number);
K
kohsuke 已提交
994
            }
K
kohsuke 已提交
995 996

            @Override
K
kohsuke 已提交
997
            public String generateToolTip(CategoryDataset dataset, int row, int column) {
998
                ChartLabel label = (ChartLabel) dataset.getColumnKey(column);
K
kohsuke 已提交
999
                return label.run.getDisplayName() + " : " + label.run.getDurationString();
K
kohsuke 已提交
1000
            }
K
kohsuke 已提交
1001
        };
K
kohsuke 已提交
1002
        plot.setRenderer(ar);
K
kohsuke 已提交
1003 1004 1005 1006

        // crop extra space around the graph
        plot.setInsets(new RectangleInsets(0,0,0,5.0));

K
kohsuke 已提交
1007
        return chart;
K
kohsuke 已提交
1008 1009 1010 1011 1012
    }

    /**
     * Renames this job.
     */
1013
    public /*not synchronized. see renameTo()*/ void doDoRename( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1014 1015 1016
        // rename is essentially delete followed by a create
        checkPermission(CREATE);
        checkPermission(DELETE);
K
kohsuke 已提交
1017 1018

        String newName = req.getParameter("newName");
1019 1020 1021 1022 1023 1024
        try {
            Hudson.checkGoodName(newName);
        } catch (ParseException e) {
            sendError(e,req,rsp);
            return;
        }
K
kohsuke 已提交
1025 1026

        renameTo(newName);
K
kohsuke 已提交
1027 1028 1029
        // send to the new job page
        // note we can't use getUrl() because that would pick up old name in the Ancestor.getUrl()
        rsp.sendRedirect2(req.getContextPath()+'/'+getParent().getUrl()+getShortUrl());
K
kohsuke 已提交
1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043
    }

    public void doRssAll( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
        rss(req, rsp, " all builds", new RunList(this));
    }
    public void doRssFailed( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
        rss(req, rsp, " failed builds", new RunList(this).failureOnly());
    }

    private void rss(StaplerRequest req, StaplerResponse rsp, String suffix, RunList runs) throws IOException, ServletException {
        RSS.forwardToRss(getDisplayName()+ suffix, getUrl(),
            runs.newBuilds(), Run.FEED_ADAPTER, req, rsp );
    }
}