AbstractProject.java 70.8 KB
Newer Older
K
kohsuke 已提交
1 2 3
/*
 * The MIT License
 * 
4
 * Copyright (c) 2004-2011, Sun Microsystems, Inc., Kohsuke Kawaguchi,
5
 * Brian Westrich, Erik Ramfelt, Ertan Deniz, Jean-Baptiste Quenot,
6
 * Luca Domenico Milanesio, R. Tyler Ballance, Stephen Connolly, Tom Huybrechts,
7 8
 * id:cactusman, Yahoo! Inc., Andrew Bayer, Manufacture Francaise des Pneumatiques
 * Michelin, Romain Seguy
K
kohsuke 已提交
9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
 * 
 * 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.
 */
28 29
package hudson.model;

30
import hudson.Functions;
31
import java.util.regex.Pattern;
32
import antlr.ANTLRException;
K
kohsuke 已提交
33
import hudson.AbortException;
34
import hudson.CopyOnWrite;
35
import hudson.FeedAdapter;
36
import hudson.FilePath;
37
import hudson.Launcher;
38
import hudson.Util;
39
import hudson.cli.declarative.CLIMethod;
40
import hudson.cli.declarative.CLIResolver;
41
import hudson.diagnosis.OldDataMonitor;
M
mdonohue 已提交
42
import hudson.model.Cause.LegacyCodeCause;
43
import hudson.model.Cause.RemoteCause;
44
import hudson.model.Cause.UserCause;
45 46
import hudson.model.Descriptor.FormException;
import hudson.model.Fingerprint.RangeSet;
K
kohsuke 已提交
47
import hudson.model.Queue.Executable;
48
import hudson.model.Queue.Task;
49
import hudson.model.queue.SubTask;
50 51
import hudson.model.Queue.WaitingItem;
import hudson.model.RunMap.Constructor;
52 53
import hudson.model.labels.LabelAtom;
import hudson.model.labels.LabelExpression;
54
import hudson.model.queue.CauseOfBlockage;
55
import hudson.model.queue.SubTaskContributor;
K
kohsuke 已提交
56
import hudson.scm.ChangeLogSet;
K
kohsuke 已提交
57
import hudson.scm.ChangeLogSet.Entry;
58
import hudson.scm.NullSCM;
59
import hudson.scm.PollingResult;
60
import hudson.scm.SCM;
61
import hudson.scm.SCMRevisionState;
62
import hudson.scm.SCMS;
J
jbq 已提交
63
import hudson.search.SearchIndexBuilder;
K
kohsuke 已提交
64
import hudson.security.Permission;
65
import hudson.slaves.WorkspaceList;
66
import hudson.tasks.BuildStep;
67
import hudson.tasks.BuildStepDescriptor;
J
jbq 已提交
68
import hudson.tasks.BuildTrigger;
69
import hudson.tasks.BuildWrapperDescriptor;
70
import hudson.tasks.Mailer;
71
import hudson.tasks.Publisher;
K
kohsuke 已提交
72
import hudson.triggers.SCMTrigger;
73
import hudson.triggers.Trigger;
74
import hudson.triggers.TriggerDescriptor;
75 76
import hudson.util.AlternativeUiTextProvider;
import hudson.util.AlternativeUiTextProvider.Message;
77
import hudson.util.DescribableList;
78
import hudson.util.EditDistance;
S
 
shinodkm 已提交
79
import hudson.util.FormValidation;
K
kohsuke 已提交
80 81
import hudson.widgets.BuildHistoryWidget;
import hudson.widgets.HistoryWidget;
82
import jenkins.model.Jenkins;
K
kohsuke 已提交
83
import net.sf.json.JSONObject;
84 85
import org.kohsuke.args4j.Argument;
import org.kohsuke.args4j.CmdLineException;
86 87 88
import org.kohsuke.stapler.ForwardToView;
import org.kohsuke.stapler.HttpRedirect;
import org.kohsuke.stapler.HttpResponse;
89
import org.kohsuke.stapler.HttpResponses;
90
import org.kohsuke.stapler.QueryParameter;
K
kohsuke 已提交
91 92 93
import org.kohsuke.stapler.StaplerRequest;
import org.kohsuke.stapler.StaplerResponse;
import org.kohsuke.stapler.export.Exported;
94

K
kohsuke 已提交
95
import javax.servlet.ServletException;
96
import java.io.File;
97
import java.io.IOException;
K
kohsuke 已提交
98
import java.lang.reflect.InvocationTargetException;
K
kohsuke 已提交
99
import java.util.ArrayList;
100
import java.util.Arrays;
101
import java.util.Calendar;
102
import java.util.Collection;
J
jbq 已提交
103
import java.util.Collections;
104
import java.util.Comparator;
J
jbq 已提交
105
import java.util.HashSet;
106 107
import java.util.List;
import java.util.Map;
J
jbq 已提交
108
import java.util.Set;
109 110 111
import java.util.SortedMap;
import java.util.TreeMap;
import java.util.Vector;
K
kohsuke 已提交
112
import java.util.concurrent.Future;
113 114
import java.util.logging.Level;
import java.util.logging.Logger;
115

116 117 118
import static hudson.scm.PollingResult.*;
import static javax.servlet.http.HttpServletResponse.*;

119 120
/**
 * Base implementation of {@link Job}s that build software.
121
 *
122
 * For now this is primarily the common part of {@link Project} and MavenModule.
123
 *
124 125 126
 * @author Kohsuke Kawaguchi
 * @see AbstractBuild
 */
127
public abstract class AbstractProject<P extends AbstractProject<P,R>,R extends AbstractBuild<P,R>> extends Job<P,R> implements BuildableItem {
128

129
    /**
130 131 132
     * {@link SCM} associated with the project.
     * To allow derived classes to link {@link SCM} config to elsewhere,
     * access to this variable should always go through {@link #getScm()}.
133
     */
K
kohsuke 已提交
134
    private volatile SCM scm = new NullSCM();
135

136 137 138 139 140
    /**
     * State returned from {@link SCM#poll(AbstractProject, Launcher, FilePath, TaskListener, SCMRevisionState)}.
     */
    private volatile transient SCMRevisionState pollingBaseline = null;

141 142 143
    /**
     * All the builds keyed by their build number.
     */
144
    protected transient /*almost final*/ RunMap<R> builds = new RunMap<R>();
145 146 147 148

    /**
     * The quiet period. Null to delegate to the system default.
     */
K
kohsuke 已提交
149
    private volatile Integer quietPeriod = null;
S
 
shinodkm 已提交
150 151
    
    /**
152
     * The retry count. Null to delegate to the system default.
S
 
shinodkm 已提交
153
     */
154
    private volatile Integer scmCheckoutRetryCount = null;
155 156

    /**
157 158 159 160 161 162 163
     * If this project is configured to be only built on a certain label,
     * this value will be set to that label.
     *
     * For historical reasons, this is called 'assignedNode'. Also for
     * a historical reason, null to indicate the affinity
     * with the master node.
     *
164
     * @see #canRoam
165 166 167 168 169
     */
    private String assignedNode;

    /**
     * True if this project can be built on any node.
170
     *
171
     * <p>
172 173
     * This somewhat ugly flag combination is so that we can migrate
     * existing Hudson installations nicely.
174
     */
K
kohsuke 已提交
175
    private volatile boolean canRoam;
176 177 178 179

    /**
     * True to suspend new builds.
     */
K
kohsuke 已提交
180
    protected volatile boolean disabled;
181

182 183 184 185 186 187
    /**
     * True to keep builds of this project in queue when downstream projects are
     * building. False by default to keep from breaking existing behavior.
     */
    protected volatile boolean blockBuildWhenDownstreamBuilding = false;

188 189 190 191 192 193
    /**
     * True to keep builds of this project in queue when upstream projects are
     * building. False by default to keep from breaking existing behavior.
     */
    protected volatile boolean blockBuildWhenUpstreamBuilding = false;

194
    /**
195 196 197
     * Identifies {@link JDK} to be used.
     * Null if no explicit configuration is required.
     *
198
     * <p>
199
     * Can't store {@link JDK} directly because {@link Jenkins} and {@link Project}
200 201
     * are saved independently.
     *
202
     * @see Jenkins#getJDK(String)
203
     */
K
kohsuke 已提交
204
    private volatile String jdk;
205

K
kohsuke 已提交
206
    private volatile BuildAuthorizationToken authToken = null;
207

208 209 210
    /**
     * List of all {@link Trigger}s for this project.
     */
211
    protected List<Trigger<?>> triggers = new Vector<Trigger<?>>();
212

213 214
    /**
     * {@link Action}s contributed from subsidiary objects associated with
215 216 217 218
     * {@link AbstractProject}, such as from triggers, builders, publishers, etc.
     *
     * We don't want to persist them separately, and these actions
     * come and go as configuration change, so it's kept separate.
219
     */
220 221
    @CopyOnWrite
    protected transient volatile List<Action> transientActions = new Vector<Action>();
222

K
kohsuke 已提交
223 224
    private boolean concurrentBuild;

225 226 227
    /**
     * See {@link #setCustomWorkspace(String)}.
     *
228
     * @since 1.410
229 230 231
     */
    private String customWorkspace;
    
232
    protected AbstractProject(ItemGroup parent, String name) {
233
        super(parent,name);
234

235
        if(!Jenkins.getInstance().getNodes().isEmpty()) {
236
            // if a new job is configured with Hudson that already has slave nodes
237 238 239
            // make it roamable by default
            canRoam = true;
        }
240 241 242 243 244 245 246
    }

    @Override
    public void onCreatedFromScratch() {
        super.onCreatedFromScratch();
        // solicit initial contributions, especially from TransientProjectActionFactory
        updateTransientActions();
247 248
    }

249
    @Override
250
    public void onLoad(ItemGroup<? extends Item> parent, String name) throws IOException {
251
        super.onLoad(parent, name);
252 253

        this.builds = new RunMap<R>();
254
        this.builds.load(this,new Constructor<R>() {
255 256 257 258 259
            public R create(File dir) throws IOException {
                return loadBuild(dir);
            }
        });

260
        if(triggers==null) {
261
            // it didn't exist in < 1.28
262
            triggers = new Vector<Trigger<?>>();
263 264
            OldDataMonitor.report(this, "1.28");
        }
265
        for (Trigger t : triggers)
266
            t.start(this,false);
267 268
        if(scm==null)
            scm = new NullSCM(); // perhaps it was pointing to a plugin that no longer exists.
269

270 271
        if(transientActions==null)
            transientActions = new Vector<Action>();    // happens when loaded from disk
272
        updateTransientActions();
273 274
    }

275
    @Override
276
    protected void performDelete() throws IOException, InterruptedException {
K
kohsuke 已提交
277 278
        // prevent a new build while a delete operation is in progress
        makeDisabled(true);
279
        FilePath ws = getWorkspace();
280
        if(ws!=null) {
K
NPE fix  
kohsuke 已提交
281 282 283 284
            Node on = getLastBuiltOn();
            getScm().processWorkspaceBeforeDeletion(this, ws, on);
            if(on!=null)
                on.getFileSystemProvisioner().discardWorkspace(this,ws);
285
        }
K
kohsuke 已提交
286 287 288
        super.performDelete();
    }

K
kohsuke 已提交
289 290
    /**
     * Does this project perform concurrent builds?
K
kohsuke 已提交
291
     * @since 1.319
K
kohsuke 已提交
292
     */
K
kohsuke 已提交
293
    @Exported
K
kohsuke 已提交
294
    public boolean isConcurrentBuild() {
295
        return Jenkins.CONCURRENT_BUILD && concurrentBuild;
K
kohsuke 已提交
296 297 298 299 300 301 302
    }

    public void setConcurrentBuild(boolean b) throws IOException {
        concurrentBuild = b;
        save();
    }

303
    /**
304 305
     * If this project is configured to be always built on this node,
     * return that {@link Node}. Otherwise null.
306
     */
307
    public Label getAssignedLabel() {
308
        if(canRoam)
309 310
            return null;

311
        if(assignedNode==null)
312 313
            return Jenkins.getInstance().getSelfLabel();
        return Jenkins.getInstance().getLabel(assignedNode);
314 315
    }

316 317 318 319
    /**
     * Gets the textual representation of the assigned label as it was entered by the user.
     */
    public String getAssignedLabelString() {
320 321 322 323 324 325 326 327
        if (canRoam || assignedNode==null)    return null;
        try {
            LabelExpression.parseExpression(assignedNode);
            return assignedNode;
        } catch (ANTLRException e) {
            // must be old label or host name that includes whitespace or other unsafe chars
            return LabelAtom.escape(assignedNode);
        }
328 329
    }

K
kohsuke 已提交
330 331 332 333 334 335 336 337 338
    /**
     * Sets the assigned label.
     */
    public void setAssignedLabel(Label l) throws IOException {
        if(l==null) {
            canRoam = true;
            assignedNode = null;
        } else {
            canRoam = false;
339
            if(l== Jenkins.getInstance().getSelfLabel())  assignedNode = null;
340
            else                                        assignedNode = l.getExpression();
K
kohsuke 已提交
341 342 343 344
        }
        save();
    }

345 346 347 348 349 350 351
    /**
     * Assigns this job to the given node. A convenience method over {@link #setAssignedLabel(Label)}.
     */
    public void setAssignedNode(Node l) throws IOException {
        setAssignedLabel(l.getSelfLabel());
    }

352
    /**
353 354
     * Get the term used in the UI to represent this kind of {@link AbstractProject}.
     * Must start with a capital letter.
355 356 357
     */
    @Override
    public String getPronoun() {
K
Kohsuke Kawaguchi 已提交
358
        return AlternativeUiTextProvider.get(PRONOUN, this,Messages.AbstractProject_Pronoun());
359 360
    }

361 362 363 364 365 366 367 368 369
    /**
     * Gets the human readable display name to be rendered in the "Build Now" link.
     *
     * @since 1.401
     */
    public String getBuildNowText() {
        return AlternativeUiTextProvider.get(BUILD_NOW_TEXT,this,Messages.AbstractProject_BuildNow());
    }

370 371 372 373 374
    /**
     * Returns the root project value.
     *
     * @return the root project value.
     */
375
    public AbstractProject getRootProject() {
376
        if (this.getParent() instanceof Jenkins) {
377 378 379 380 381 382
            return this;
        } else {
            return ((AbstractProject) this.getParent()).getRootProject();
        }
    }

383 384
    /**
     * Gets the directory where the module is checked out.
385 386 387
     *
     * @return
     *      null if the workspace is on a slave that's not connected.
K
kohsuke 已提交
388
     * @deprecated as of 1.319
K
kohsuke 已提交
389 390 391 392 393
     *      To support concurrent builds of the same project, this method is moved to {@link AbstractBuild}.
     *      For backward compatibility, this method returns the right {@link AbstractBuild#getWorkspace()} if called
     *      from {@link Executor}, and otherwise the workspace of the last build.
     *
     *      <p>
394
     *      If you are calling this method during a build from an executor, switch it to {@link AbstractBuild#getWorkspace()}.
K
kohsuke 已提交
395 396 397 398
     *      If you are calling this method to serve a file from the workspace, doing a form validation, etc., then
     *      use {@link #getSomeWorkspace()}
     */
    public final FilePath getWorkspace() {
399 400 401 402 403 404 405 406 407 408 409 410
        AbstractBuild b = getBuildForDeprecatedMethods();
        return b != null ? b.getWorkspace() : null;

    }
    
    /**
     * Various deprecated methods in this class all need the 'current' build.  This method returns
     * the build suitable for that purpose.
     * 
     * @return An AbstractBuild for deprecated methods to use.
     */
    private AbstractBuild getBuildForDeprecatedMethods() {
K
kohsuke 已提交
411 412 413 414 415 416
        Executor e = Executor.currentExecutor();
        if(e!=null) {
            Executable exe = e.getCurrentExecutable();
            if (exe instanceof AbstractBuild) {
                AbstractBuild b = (AbstractBuild) exe;
                if(b.getProject()==this)
417
                    return b;
K
kohsuke 已提交
418 419 420
            }
        }
        R lb = getLastBuild();
421
        if(lb!=null)    return lb;
K
kohsuke 已提交
422 423 424 425 426 427 428 429 430 431 432 433 434
        return null;
    }

    /**
     * Gets a workspace for some build of this project.
     *
     * <p>
     * This is useful for obtaining a workspace for the purpose of form field validation, where exactly
     * which build the workspace belonged is less important. The implementation makes a cursory effort
     * to find some workspace.
     *
     * @return
     *      null if there's no available workspace.
K
kohsuke 已提交
435
     * @since 1.319
436
     */
K
kohsuke 已提交
437
    public final FilePath getSomeWorkspace() {
438 439 440 441 442 443 444 445 446 447
        R b = getSomeBuildWithWorkspace();
        return b!=null ? b.getWorkspace() : null;
    }

    /**
     * Gets some build that has a live workspace.
     *
     * @return null if no such build exists.
     */
    public final R getSomeBuildWithWorkspace() {
K
kohsuke 已提交
448 449 450
        int cnt=0;
        for (R b = getLastBuild(); cnt<5 && b!=null; b=b.getPreviousBuild()) {
            FilePath ws = b.getWorkspace();
451
            if (ws!=null)   return b;
K
kohsuke 已提交
452 453 454
        }
        return null;
    }
455

456 457 458
    /**
     * Returns the root directory of the checked-out module.
     * <p>
459 460
     * This is usually where <tt>pom.xml</tt>, <tt>build.xml</tt>
     * and so on exists.
K
kohsuke 已提交
461
     *
K
kohsuke 已提交
462
     * @deprecated as of 1.319
K
kohsuke 已提交
463
     *      See {@link #getWorkspace()} for a migration strategy.
464 465
     */
    public FilePath getModuleRoot() {
466 467
        AbstractBuild b = getBuildForDeprecatedMethods();
        return b != null ? b.getModuleRoot() : null;
468 469
    }

S
stephenconnolly 已提交
470 471 472 473 474 475
    /**
     * Returns the root directories of all checked-out modules.
     * <p>
     * Some SCMs support checking out multiple modules into the same workspace.
     * In these cases, the returned array will have a length greater than one.
     * @return The roots of all modules checked out from the SCM.
K
kohsuke 已提交
476
     *
K
kohsuke 已提交
477
     * @deprecated as of 1.319
K
kohsuke 已提交
478
     *      See {@link #getWorkspace()} for a migration strategy.
S
stephenconnolly 已提交
479 480
     */
    public FilePath[] getModuleRoots() {
481 482
        AbstractBuild b = getBuildForDeprecatedMethods();
        return b != null ? b.getModuleRoots() : null;
S
stephenconnolly 已提交
483 484
    }

485
    public int getQuietPeriod() {
486
        return quietPeriod!=null ? quietPeriod : Jenkins.getInstance().getQuietPeriod();
487
    }
S
 
shinodkm 已提交
488
    
489
    public int getScmCheckoutRetryCount() {
490
        return scmCheckoutRetryCount !=null ? scmCheckoutRetryCount : Jenkins.getInstance().getScmCheckoutRetryCount();
S
 
shinodkm 已提交
491
    }
492 493 494

    // ugly name because of EL
    public boolean getHasCustomQuietPeriod() {
495
        return quietPeriod!=null;
496
    }
K
kohsuke 已提交
497 498 499 500

    /**
     * Sets the custom quiet period of this project, or revert to the global default if null is given. 
     */
501
    public void setQuietPeriod(Integer seconds) throws IOException {
K
kohsuke 已提交
502 503 504
        this.quietPeriod = seconds;
        save();
    }
S
 
shinodkm 已提交
505
    
506
    public boolean hasCustomScmCheckoutRetryCount(){
507
        return scmCheckoutRetryCount != null;
S
 
shinodkm 已提交
508
    }
509

510
    @Override
511
    public boolean isBuildable() {
J
jpederzolli 已提交
512
        return !isDisabled() && !isHoldOffBuildUntilSave();
513 514
    }

515
    /**
516 517
     * Used in <tt>sidepanel.jelly</tt> to decide whether to display
     * the config/delete/build links.
518 519 520 521 522
     */
    public boolean isConfigurable() {
        return true;
    }

523 524 525 526 527 528 529 530 531
    public boolean blockBuildWhenDownstreamBuilding() {
        return blockBuildWhenDownstreamBuilding;
    }

    public void setBlockBuildWhenDownstreamBuilding(boolean b) throws IOException {
        blockBuildWhenDownstreamBuilding = b;
        save();
    }

532
    public boolean blockBuildWhenUpstreamBuilding() {
533
        return blockBuildWhenUpstreamBuilding;
534 535
    }

536
    public void setBlockBuildWhenUpstreamBuilding(boolean b) throws IOException {
537 538
        blockBuildWhenUpstreamBuilding = b;
        save();
539 540
    }

541 542 543
    public boolean isDisabled() {
        return disabled;
    }
S
 
shinodkm 已提交
544 545 546 547 548
    
    /**
     * Validates the retry count Regex
     */
    public FormValidation doCheckRetryCount(@QueryParameter String value)throws IOException,ServletException{
549 550 551 552 553 554 555
        // retry count is optional so this is ok
        if(value == null || value.trim().equals(""))
            return FormValidation.ok();
        if (!value.matches("[0-9]*")) {
            return FormValidation.error("Invalid retry count");
        } 
        return FormValidation.ok();
S
 
shinodkm 已提交
556
    }
557

558 559 560 561
    /**
     * Marks the build as disabled.
     */
    public void makeDisabled(boolean b) throws IOException {
562
        if(disabled==b)     return; // noop
563
        this.disabled = b;
K
bug fix  
kohsuke 已提交
564
        if(b)
565
            Jenkins.getInstance().getQueue().cancel(this);
566 567 568
        save();
    }

569 570 571 572 573 574 575 576
    public void disable() throws IOException {
        makeDisabled(true);
    }

    public void enable() throws IOException {
        makeDisabled(false);
    }

K
kohsuke 已提交
577 578
    @Override
    public BallColor getIconColor() {
579
        if(isDisabled())
580
            return BallColor.DISABLED;
K
kohsuke 已提交
581 582 583
        else
            return super.getIconColor();
    }
584

585 586 587 588 589 590 591
    /**
     * effectively deprecated. Since using updateTransientActions correctly
     * under concurrent environment requires a lock that can too easily cause deadlocks.
     *
     * <p>
     * Override {@link #createTransientActions()} instead.
     */
592
    protected void updateTransientActions() {
593 594 595 596
        transientActions = createTransientActions();
    }

    protected List<Action> createTransientActions() {
597
        Vector<Action> ta = new Vector<Action>();
598

599 600
        for (JobProperty<? super P> p : properties)
            ta.addAll(p.getJobActions((P)this));
601

602 603
        for (TransientProjectActionFactory tpaf : TransientProjectActionFactory.all())
            ta.addAll(Util.fixNull(tpaf.createFor(this))); // be defensive against null
604
        return ta;
605 606
    }

607
    /**
608 609
     * Returns the live list of all {@link Publisher}s configured for this project.
     *
610
     * <p>
611 612
     * This method couldn't be called <tt>getPublishers()</tt> because existing methods
     * in sub-classes return different inconsistent types.
613
     */
614
    public abstract DescribableList<Publisher,Descriptor<Publisher>> getPublishersList();
615

K
kohsuke 已提交
616 617 618 619 620 621
    @Override
    public void addProperty(JobProperty<? super P> jobProp) throws IOException {
        super.addProperty(jobProp);
        updateTransientActions();
    }

622 623 624 625
    public List<ProminentProjectAction> getProminentActions() {
        List<Action> a = getActions();
        List<ProminentProjectAction> pa = new Vector<ProminentProjectAction>();
        for (Action action : a) {
626
            if(action instanceof ProminentProjectAction)
627 628 629 630 631
                pa.add((ProminentProjectAction) action);
        }
        return pa;
    }

632
    @Override
633
    public void doConfigSubmit( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException, FormException {
634
        super.doConfigSubmit(req,rsp);
635

636 637
        updateTransientActions();

638
        Set<AbstractProject> upstream = Collections.emptySet();
639
        if(req.getParameter("pseudoUpstreamTrigger")!=null) {
640
            upstream = new HashSet<AbstractProject>(Items.fromNameList(getParent(),req.getParameter("upstreamProjects"),AbstractProject.class));
641 642 643
        }

        // dependency setting might have been changed by the user, so rebuild.
644
        Jenkins.getInstance().rebuildDependencyGraph();
645 646 647 648 649

        // reflect the submission of the pseudo 'upstream build trriger'.
        // this needs to be done after we release the lock on 'this',
        // or otherwise we could dead-lock

650
        for (AbstractProject<?,?> p : Jenkins.getInstance().getAllItems(AbstractProject.class)) {
651 652
            // Don't consider child projects such as MatrixConfiguration:
            if (!p.isConfigurable()) continue;
653
            boolean isUpstream = upstream.contains(p);
654 655 656
            synchronized(p) {
                // does 'p' include us in its BuildTrigger? 
                DescribableList<Publisher,Descriptor<Publisher>> pl = p.getPublishersList();
657
                BuildTrigger trigger = pl.get(BuildTrigger.class);
658
                List<AbstractProject> newChildProjects = trigger == null ? new ArrayList<AbstractProject>():trigger.getChildProjects(p);
659 660
                if(isUpstream) {
                    if(!newChildProjects.contains(this))
661 662 663 664 665
                        newChildProjects.add(this);
                } else {
                    newChildProjects.remove(this);
                }

666
                if(newChildProjects.isEmpty()) {
667
                    pl.remove(BuildTrigger.class);
668
                } else {
669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685
                    // here, we just need to replace the old one with the new one,
                    // but there was a regression (we don't know when it started) that put multiple BuildTriggers
                    // into the list.
                    // for us not to lose the data, we need to merge them all.
                    List<BuildTrigger> existingList = pl.getAll(BuildTrigger.class);
                    BuildTrigger existing;
                    switch (existingList.size()) {
                    case 0:
                        existing = null;
                        break;
                    case 1:
                        existing = existingList.get(0);
                        break;
                    default:
                        pl.removeAll(BuildTrigger.class);
                        Set<AbstractProject> combinedChildren = new HashSet<AbstractProject>();
                        for (BuildTrigger bt : existingList)
686
                            combinedChildren.addAll(bt.getChildProjects(p));
687 688 689 690 691
                        existing = new BuildTrigger(new ArrayList<AbstractProject>(combinedChildren),existingList.get(0).getThreshold());
                        pl.add(existing);
                        break;
                    }

692
                    if(existing!=null && existing.hasSame(p,newChildProjects))
693
                        continue;   // no need to touch
694
                    pl.replace(new BuildTrigger(newChildProjects,
695
                        existing==null?Result.SUCCESS:existing.getThreshold()));
696 697 698 699 700
                }
            }
        }

        // notify the queue as the project might be now tied to different node
701
        Jenkins.getInstance().getQueue().scheduleMaintenance();
702 703

        // this is to reflect the upstream build adjustments done above
704
        Jenkins.getInstance().rebuildDependencyGraph();
705 706
    }

M
mdonohue 已提交
707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722
	/**
	 * @deprecated
	 *    Use {@link #scheduleBuild(Cause)}.  Since 1.283
	 */
    public boolean scheduleBuild() {
    	return scheduleBuild(new LegacyCodeCause());
    }
    
	/**
	 * @deprecated
	 *    Use {@link #scheduleBuild(int, Cause)}.  Since 1.283
	 */
    public boolean scheduleBuild(int quietPeriod) {
    	return scheduleBuild(quietPeriod, new LegacyCodeCause());
    }
    
723 724
    /**
     * Schedules a build of this project.
725 726 727 728 729
     *
     * @return
     *      true if the project is actually added to the queue.
     *      false if the queue contained it and therefore the add()
     *      was noop
730
     */
M
mdonohue 已提交
731 732
    public boolean scheduleBuild(Cause c) {
        return scheduleBuild(getQuietPeriod(), c);
K
kohsuke 已提交
733 734
    }

M
mdonohue 已提交
735
    public boolean scheduleBuild(int quietPeriod, Cause c) {
736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751
        return scheduleBuild(quietPeriod, c, new Action[0]);
    }

    /**
     * Schedules a build.
     *
     * Important: the actions should be persistable without outside references (e.g. don't store
     * references to this project). To provide parameters for a parameterized project, add a ParametersAction. If
     * no ParametersAction is provided for such a project, one will be created with the default parameter values.
     *
     * @param quietPeriod the quiet period to observer
     * @param c the cause for this build which should be recorded
     * @param actions a list of Actions that will be added to the build
     * @return whether the build was actually scheduled
     */
    public boolean scheduleBuild(int quietPeriod, Cause c, Action... actions) {
752 753 754 755 756 757
        return scheduleBuild2(quietPeriod,c,actions)!=null;
    }

    /**
     * Schedules a build of this project, and returns a {@link Future} object
     * to wait for the completion of the build.
758 759 760
     *
     * @param actions
     *      For the convenience of the caller, this array can contain null, and those will be silently ignored.
761 762
     */
    public Future<R> scheduleBuild2(int quietPeriod, Cause c, Action... actions) {
K
kohsuke 已提交
763 764 765 766 767 768 769 770 771 772 773 774
        return scheduleBuild2(quietPeriod,c,Arrays.asList(actions));
    }

    /**
     * Schedules a build of this project, and returns a {@link Future} object
     * to wait for the completion of the build.
     *
     * @param actions
     *      For the convenience of the caller, this collection can contain null, and those will be silently ignored.
     * @since 1.383
     */
    public Future<R> scheduleBuild2(int quietPeriod, Cause c, Collection<? extends Action> actions) {
775
        if (!isBuildable())
776
            return null;
777

K
kohsuke 已提交
778
        List<Action> queueActions = new ArrayList<Action>(actions);
779 780 781 782
        if (isParameterized() && Util.filter(queueActions, ParametersAction.class).isEmpty()) {
            queueActions.add(new ParametersAction(getDefaultParametersValues()));
        }

S
sogabe 已提交
783 784 785 786
        if (c != null) {
            queueActions.add(new CauseAction(c));
        }

787
        WaitingItem i = Jenkins.getInstance().getQueue().schedule(this, quietPeriod, queueActions);
788 789 790
        if(i!=null)
            return (Future)i.getFuture();
        return null;
791 792 793 794 795 796
    }

    private List<ParameterValue> getDefaultParametersValues() {
        ParametersDefinitionProperty paramDefProp = getProperty(ParametersDefinitionProperty.class);
        ArrayList<ParameterValue> defValues = new ArrayList<ParameterValue>();
        
M
mindless 已提交
797 798 799
        /*
         * This check is made ONLY if someone will call this method even if isParametrized() is false.
         */
800 801 802 803 804 805 806 807 808 809 810 811 812
        if(paramDefProp == null)
            return defValues;
        
        /* Scan for all parameter with an associated default values */
        for(ParameterDefinition paramDefinition : paramDefProp.getParameterDefinitions())
        {
           ParameterValue defaultValue  = paramDefinition.getDefaultParameterValue();
            
            if(defaultValue != null)
                defValues.add(defaultValue);           
        }
        
        return defValues;
K
kohsuke 已提交
813 814
    }

815
    /**
816 817 818 819
     * Schedules a build, and returns a {@link Future} object
     * to wait for the completion of the build.
     *
     * <p>
820
     * Production code shouldn't be using this, but for tests this is very convenient, so this isn't marked
821
     * as deprecated.
822
     */
M
mdonohue 已提交
823
    public Future<R> scheduleBuild2(int quietPeriod) {
824
        return scheduleBuild2(quietPeriod, new LegacyCodeCause());
M
mdonohue 已提交
825 826
    }
    
K
kohsuke 已提交
827
    /**
828 829
     * Schedules a build of this project, and returns a {@link Future} object
     * to wait for the completion of the build.
K
kohsuke 已提交
830
     */
K
kohsuke 已提交
831
    public Future<R> scheduleBuild2(int quietPeriod, Cause c) {
832 833 834
        return scheduleBuild2(quietPeriod, c, new Action[0]);
    }

835 836 837 838
    /**
     * Schedules a polling of this project.
     */
    public boolean schedulePolling() {
839
        if(isDisabled())    return false;
840
        SCMTrigger scmt = getTrigger(SCMTrigger.class);
841
        if(scmt==null)      return false;
842 843 844 845
        scmt.run();
        return true;
    }

846 847 848 849 850
    /**
     * Returns true if the build is in the queue.
     */
    @Override
    public boolean isInQueue() {
851
        return Jenkins.getInstance().getQueue().contains(this);
852 853
    }

K
kohsuke 已提交
854 855
    @Override
    public Queue.Item getQueueItem() {
856
        return Jenkins.getInstance().getQueue().getItem(this);
K
kohsuke 已提交
857 858
    }

K
kohsuke 已提交
859 860 861
    /**
     * Gets the JDK that this project is configured with, or null.
     */
862
    public JDK getJDK() {
863
        return Jenkins.getInstance().getJDK(jdk);
864 865 866 867 868
    }

    /**
     * Overwrites the JDK setting.
     */
K
kohsuke 已提交
869
    public void setJDK(JDK jdk) throws IOException {
870 871 872 873
        this.jdk = jdk.getName();
        save();
    }

874 875
    public BuildAuthorizationToken getAuthToken() {
        return authToken;
876 877
    }

878
    @Override
879 880 881 882
    public SortedMap<Integer, ? extends R> _getRuns() {
        return builds.getView();
    }

883
    @Override
884 885 886 887
    public void removeRun(R run) {
        this.builds.remove(run);
    }

888 889 890 891 892
    /**
     * Determines Class&lt;R>.
     */
    protected abstract Class<R> getBuildClass();

H
huybrechts 已提交
893
    // keep track of the previous time we started a build
894
    private transient long lastBuildStartTime;
H
huybrechts 已提交
895
    
896 897 898
    /**
     * Creates a new build of this project for immediate execution.
     */
H
huybrechts 已提交
899 900 901 902 903 904 905 906 907 908 909
    protected synchronized R newBuild() throws IOException {
    	// make sure we don't start two builds in the same second
    	// so the build directories will be different too
    	long timeSinceLast = System.currentTimeMillis() - lastBuildStartTime;
    	if (timeSinceLast < 1000) {
    		try {
				Thread.sleep(1000 - timeSinceLast);
			} catch (InterruptedException e) {
			}
    	}
    	lastBuildStartTime = System.currentTimeMillis();
910
        try {
911
            R lastBuild = getBuildClass().getConstructor(getClass()).newInstance(this);
912 913 914 915 916 917 918
            builds.put(lastBuild);
            return lastBuild;
        } catch (InstantiationException e) {
            throw new Error(e);
        } catch (IllegalAccessException e) {
            throw new Error(e);
        } catch (InvocationTargetException e) {
919
            throw handleInvocationTargetException(e);
920 921 922 923
        } catch (NoSuchMethodException e) {
            throw new Error(e);
        }
    }
924

925
    private IOException handleInvocationTargetException(InvocationTargetException e) {
926
        Throwable t = e.getTargetException();
927 928 929
        if(t instanceof Error)  throw (Error)t;
        if(t instanceof RuntimeException)   throw (RuntimeException)t;
        if(t instanceof IOException)    return (IOException)t;
930 931 932
        throw new Error(t);
    }

933 934 935
    /**
     * Loads an existing build record from disk.
     */
936 937
    protected R loadBuild(File dir) throws IOException {
        try {
938
            return getBuildClass().getConstructor(getClass(),File.class).newInstance(this,dir);
939 940 941 942 943
        } catch (InstantiationException e) {
            throw new Error(e);
        } catch (IllegalAccessException e) {
            throw new Error(e);
        } catch (InvocationTargetException e) {
944
            throw handleInvocationTargetException(e);
945 946 947 948
        } catch (NoSuchMethodException e) {
            throw new Error(e);
        }
    }
949

K
kohsuke 已提交
950 951
    /**
     * {@inheritDoc}
952
     *
K
kohsuke 已提交
953 954
     * <p>
     * Note that this method returns a read-only view of {@link Action}s.
955
     * {@link BuildStep}s and others who want to add a project action
956
     * should do so by implementing {@link BuildStep#getProjectActions(AbstractProject)}.
957 958
     *
     * @see TransientProjectActionFactory
K
kohsuke 已提交
959
     */
960
    @Override
961 962 963 964
    public synchronized List<Action> getActions() {
        // add all the transient actions, too
        List<Action> actions = new Vector<Action>(super.getActions());
        actions.addAll(transientActions);
965
        // return the read only list to cause a failure on plugins who try to add an action here
K
kohsuke 已提交
966
        return Collections.unmodifiableList(actions);
967 968
    }

969 970
    /**
     * Gets the {@link Node} where this project was last built on.
971 972 973 974
     *
     * @return
     *      null if no information is available (for example,
     *      if no build was done yet.)
975 976 977 978
     */
    public Node getLastBuiltOn() {
        // where was it built on?
        AbstractBuild b = getLastBuild();
979
        if(b==null)
980 981 982 983 984
            return null;
        else
            return b.getBuiltOn();
    }

985 986 987 988
    public Object getSameNodeConstraint() {
        return this; // in this way, any member that wants to run with the main guy can nominate the project itself 
    }

989 990 991 992
    public final Task getOwnerTask() {
        return this;
    }

993
    /**
994
     * {@inheritDoc}
995
     *
996
     * <p>
997
     * A project must be blocked if its own previous build is in progress,
998 999
     * or if the blockBuildWhenUpstreamBuilding option is true and an upstream
     * project is building, but derived classes can also check other conditions.
1000
     */
1001
    public boolean isBuildBlocked() {
1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017
        return getCauseOfBlockage()!=null;
    }

    public String getWhyBlocked() {
        CauseOfBlockage cb = getCauseOfBlockage();
        return cb!=null ? cb.getShortDescription() : null;
    }

    /**
     * Blocked because the previous build is already in progress.
     */
    public static class BecauseOfBuildInProgress extends CauseOfBlockage {
        private final AbstractBuild<?,?> build;

        public BecauseOfBuildInProgress(AbstractBuild<?, ?> build) {
            this.build = build;
1018 1019
        }

1020
        @Override
1021 1022 1023 1024 1025 1026 1027 1028
        public String getShortDescription() {
            Executor e = build.getExecutor();
            String eta = "";
            if (e != null)
                eta = Messages.AbstractProject_ETA(e.getEstimatedRemainingTime());
            int lbn = build.getNumber();
            return Messages.AbstractProject_BuildInProgress(lbn, eta);
        }
1029
    }
1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045
    
    /**
     * Because the downstream build is in progress, and we are configured to wait for that.
     */
    public static class BecauseOfDownstreamBuildInProgress extends CauseOfBlockage {
        public final AbstractProject<?,?> up;

        public BecauseOfDownstreamBuildInProgress(AbstractProject<?,?> up) {
            this.up = up;
        }

        @Override
        public String getShortDescription() {
            return Messages.AbstractProject_DownstreamBuildInProgress(up.getName());
        }
    }
1046

1047 1048 1049 1050 1051 1052 1053 1054 1055 1056
    /**
     * Because the upstream build is in progress, and we are configured to wait for that.
     */
    public static class BecauseOfUpstreamBuildInProgress extends CauseOfBlockage {
        public final AbstractProject<?,?> up;

        public BecauseOfUpstreamBuildInProgress(AbstractProject<?,?> up) {
            this.up = up;
        }

1057
        @Override
1058 1059 1060
        public String getShortDescription() {
            return Messages.AbstractProject_UpstreamBuildInProgress(up.getName());
        }
1061 1062
    }

1063 1064 1065
    public CauseOfBlockage getCauseOfBlockage() {
        if (isBuilding() && !isConcurrentBuild())
            return new BecauseOfBuildInProgress(getLastBuild());
1066 1067 1068 1069
        if (blockBuildWhenDownstreamBuilding()) {
            AbstractProject<?,?> bup = getBuildingDownstream();
            if (bup!=null)
                return new BecauseOfDownstreamBuildInProgress(bup);
1070 1071
        }
        if (blockBuildWhenUpstreamBuilding()) {
1072 1073 1074 1075 1076 1077
            AbstractProject<?,?> bup = getBuildingUpstream();
            if (bup!=null)
                return new BecauseOfUpstreamBuildInProgress(bup);
        }
        return null;
    }
1078

1079
    /**
1080 1081
     * Returns the project if any of the downstream project is either
     * building, waiting, pending or buildable.
1082 1083 1084 1085 1086
     * <p>
     * This means eventually there will be an automatic triggering of
     * the given project (provided that all builds went smoothly.)
     */
    protected AbstractProject getBuildingDownstream() {
1087
        Set<Task> unblockedTasks = Jenkins.getInstance().getQueue().getUnblockedTasks();
1088

1089
        for (AbstractProject tup : Jenkins.getInstance().getDependencyGraph().getTransitiveDownstream(this)) {
1090
			if (tup!=this && (tup.isBuilding() || unblockedTasks.contains(tup)))
1091 1092 1093 1094 1095
                return tup;
        }
        return null;
    }

1096
    /**
1097
     * Returns the project if any of the upstream project is either
1098 1099 1100 1101 1102 1103
     * building or is in the queue.
     * <p>
     * This means eventually there will be an automatic triggering of
     * the given project (provided that all builds went smoothly.)
     */
    protected AbstractProject getBuildingUpstream() {
1104
        Set<Task> unblockedTasks = Jenkins.getInstance().getQueue().getUnblockedTasks();
1105

1106
        for (AbstractProject tup : Jenkins.getInstance().getDependencyGraph().getTransitiveUpstream(this)) {
1107
			if (tup!=this && (tup.isBuilding() || unblockedTasks.contains(tup)))
1108 1109 1110
                return tup;
        }
        return null;
1111 1112
    }

1113 1114
    public List<SubTask> getSubTasks() {
        List<SubTask> r = new ArrayList<SubTask>();
1115
        r.add(this);
1116 1117 1118
        for (SubTaskContributor euc : SubTaskContributor.all())
            r.addAll(euc.forProject(this));
        for (JobProperty<? super P> p : properties)
1119
            r.addAll(p.getSubTasks());
1120
        return r;
1121 1122
    }

1123
    public R createExecutable() throws IOException {
1124
        if(isDisabled())    return null;
1125
        return newBuild();
1126 1127
    }

1128 1129 1130 1131
    public void checkAbortPermission() {
        checkPermission(AbstractProject.ABORT);
    }

K
kohsuke 已提交
1132 1133 1134 1135
    public boolean hasAbortPermission() {
        return hasPermission(AbstractProject.ABORT);
    }

1136 1137
    /**
     * Gets the {@link Resource} that represents the workspace of this project.
1138
     * Useful for locking and mutual exclusion control.
K
kohsuke 已提交
1139
     *
K
kohsuke 已提交
1140
     * @deprecated as of 1.319
K
kohsuke 已提交
1141 1142 1143 1144 1145 1146 1147
     *      Projects no longer have a fixed workspace, ands builds will find an available workspace via
     *      {@link WorkspaceList} for each build (furthermore, that happens after a build is started.)
     *      So a {@link Resource} representation for a workspace at the project level no longer makes sense.
     *
     *      <p>
     *      If you need to lock a workspace while you do some computation, see the source code of
     *      {@link #pollSCMChanges(TaskListener)} for how to obtain a lock of a workspace through {@link WorkspaceList}.
1148 1149
     */
    public Resource getWorkspaceResource() {
1150
        return new Resource(getFullDisplayName()+" workspace");
1151 1152 1153 1154 1155 1156
    }

    /**
     * List of necessary resources to perform the build of this project.
     */
    public ResourceList getResourceList() {
1157
        final Set<ResourceActivity> resourceActivities = getResourceActivities();
1158
        final List<ResourceList> resourceLists = new ArrayList<ResourceList>(1 + resourceActivities.size());
1159 1160 1161 1162 1163 1164 1165 1166 1167 1168
        for (ResourceActivity activity : resourceActivities) {
            if (activity != this && activity != null) {
                // defensive infinite recursion and null check
                resourceLists.add(activity.getResourceList());
            }
        }
        return ResourceList.union(resourceLists);
    }

    /**
1169 1170
     * Set of child resource activities of the build of this project (override in child projects).
     * @return The set of child resource activities of the build of this project.
1171 1172
     */
    protected Set<ResourceActivity> getResourceActivities() {
K
kohsuke 已提交
1173
        return Collections.emptySet();
1174 1175
    }

1176
    public boolean checkout(AbstractBuild build, Launcher launcher, BuildListener listener, File changelogFile) throws IOException, InterruptedException {
1177
        SCM scm = getScm();
1178 1179
        if(scm==null)
            return true;    // no SCM
1180

1181 1182
        FilePath workspace = build.getWorkspace();
        workspace.mkdirs();
1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195
        
        boolean r = scm.checkout(build, launcher, workspace, listener, changelogFile);
        calcPollingBaseline(build, launcher, listener);
        return r;
    }

    /**
     * Pushes the baseline up to the newly checked out revision.
     */
    private void calcPollingBaseline(AbstractBuild build, Launcher launcher, TaskListener listener) throws IOException, InterruptedException {
        SCMRevisionState baseline = build.getAction(SCMRevisionState.class);
        if (baseline==null) {
            try {
1196
                baseline = getScm()._calcRevisionsFromBuild(build, launcher, listener);
1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209
            } catch (AbstractMethodError e) {
                baseline = SCMRevisionState.NONE; // pre-1.345 SCM implementations, which doesn't use the baseline in polling
            }
            if (baseline!=null)
                build.addAction(baseline);
        }
        pollingBaseline = baseline;
    }

    /**
     * For reasons I don't understand, if I inline this method, AbstractMethodError escapes try/catch block.
     */
    private SCMRevisionState safeCalcRevisionsFromBuild(AbstractBuild build, Launcher launcher, TaskListener listener) throws IOException, InterruptedException {
1210
        return getScm()._calcRevisionsFromBuild(build, launcher, listener);
1211 1212 1213 1214
    }

    /**
     * Checks if there's any update in SCM, and returns true if any is found.
1215
     *
1216 1217
     * @deprecated as of 1.346
     *      Use {@link #poll(TaskListener)} instead.
1218
     */
1219
    public boolean pollSCMChanges( TaskListener listener ) {
1220 1221 1222 1223 1224 1225 1226
        return poll(listener).hasChanges();
    }

    /**
     * Checks if there's any update in SCM, and returns true if any is found.
     *
     * <p>
1227 1228
     * The implementation is responsible for ensuring mutual exclusion between polling and builds
     * if necessary.
1229 1230 1231 1232
     *
     * @since 1.345
     */
    public PollingResult poll( TaskListener listener ) {
1233
        SCM scm = getScm();
1234
        if (scm==null) {
K
i18n  
kohsuke 已提交
1235
            listener.getLogger().println(Messages.AbstractProject_NoSCM());
1236
            return NO_CHANGES;
1237
        }
1238
        if (isDisabled()) {
K
i18n  
kohsuke 已提交
1239
            listener.getLogger().println(Messages.AbstractProject_Disabled());
1240 1241 1242 1243 1244
            return NO_CHANGES;
        }

        R lb = getLastBuild();
        if (lb==null) {
1245
            listener.getLogger().println(Messages.AbstractProject_NoBuilds());
1246
            return isInQueue() ? NO_CHANGES : BUILD_NOW;
1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261
        }

        if (pollingBaseline==null) {
            R success = getLastSuccessfulBuild(); // if we have a persisted baseline, we'll find it by this
            for (R r=lb; r!=null; r=r.getPreviousBuild()) {
                SCMRevisionState s = r.getAction(SCMRevisionState.class);
                if (s!=null) {
                    pollingBaseline = s;
                    break;
                }
                if (r==success) break;  // searched far enough
            }
            // NOTE-NO-BASELINE:
            // if we don't have baseline yet, it means the data is built by old Hudson that doesn't set the baseline
            // as action, so we need to compute it. This happens later.
1262 1263 1264
        }

        try {
1265
            if (scm.requiresWorkspaceForPolling()) {
K
kohsuke 已提交
1266
                // lock the workspace of the last build
1267
                FilePath ws=lb.getWorkspace();
K
kohsuke 已提交
1268

1269
                if (workspaceOffline(lb)) {
K
kohsuke 已提交
1270 1271 1272 1273 1274 1275
                    // workspace offline. build now, or nothing will ever be built
                    Label label = getAssignedLabel();
                    if (label != null && label.isSelfLabel()) {
                        // if the build is fixed on a node, then attempting a build will do us
                        // no good. We should just wait for the slave to come back.
                        listener.getLogger().println(Messages.AbstractProject_NoWorkspace());
1276
                        return NO_CHANGES;
K
kohsuke 已提交
1277
                    }
1278 1279 1280
                    listener.getLogger().println( ws==null
                        ? Messages.AbstractProject_WorkspaceOffline()
                        : Messages.AbstractProject_NoWorkspace());
1281 1282 1283 1284 1285 1286 1287
                    if (isInQueue()) {
                        listener.getLogger().println(Messages.AbstractProject_AwaitingBuildForWorkspace());
                        return NO_CHANGES;
                    } else {
                        listener.getLogger().println(Messages.AbstractProject_NewBuildForWorkspace());
                        return BUILD_NOW;
                    }
K
kohsuke 已提交
1288 1289
                } else {
                    WorkspaceList l = lb.getBuiltOn().toComputer().getWorkspaceList();
1290
                    // if doing non-concurrent build, acquire a workspace in a way that causes builds to block for this workspace.
1291 1292 1293 1294 1295
                    // this prevents multiple workspaces of the same job --- the behavior of Hudson < 1.319.
                    //
                    // OTOH, if a concurrent build is chosen, the user is willing to create a multiple workspace,
                    // so better throughput is achieved over time (modulo the initial cost of creating that many workspaces)
                    // by having multiple workspaces
1296
                    WorkspaceList.Lease lease = l.acquire(ws, !concurrentBuild);
1297
                    Launcher launcher = ws.createLauncher(listener);
K
kohsuke 已提交
1298 1299
                    try {
                        LOGGER.fine("Polling SCM changes of " + getName());
1300 1301 1302 1303 1304
                        if (pollingBaseline==null) // see NOTE-NO-BASELINE above
                            calcPollingBaseline(lb,launcher,listener);
                        PollingResult r = scm.poll(this, launcher, ws, listener, pollingBaseline);
                        pollingBaseline = r.remote;
                        return r;
K
kohsuke 已提交
1305
                    } finally {
1306
                        lease.release();
K
kohsuke 已提交
1307
                    }
K
kohsuke 已提交
1308
                }
K
kohsuke 已提交
1309 1310 1311
            } else {
                // polling without workspace
                LOGGER.fine("Polling SCM changes of " + getName());
1312 1313 1314 1315 1316 1317

                if (pollingBaseline==null) // see NOTE-NO-BASELINE above
                    calcPollingBaseline(lb,null,listener);
                PollingResult r = scm.poll(this, null, null, listener, pollingBaseline);
                pollingBaseline = r.remote;
                return r;
K
kohsuke 已提交
1318
            }
1319
        } catch (AbortException e) {
1320
            listener.getLogger().println(e.getMessage());
K
i18n  
kohsuke 已提交
1321
            listener.fatalError(Messages.AbstractProject_Aborted());
1322
            LOGGER.log(Level.FINE, "Polling "+this+" aborted",e);
1323
            return NO_CHANGES;
1324 1325
        } catch (IOException e) {
            e.printStackTrace(listener.fatalError(e.getMessage()));
1326
            return NO_CHANGES;
1327
        } catch (InterruptedException e) {
1328
            e.printStackTrace(listener.fatalError(Messages.AbstractProject_PollingABorted()));
1329
            return NO_CHANGES;
1330 1331
        }
    }
1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349
    
    private boolean workspaceOffline(R build) throws IOException, InterruptedException {
        FilePath ws = build.getWorkspace();
        if (ws==null || !ws.exists()) {
            return true;
        }
        
        Node builtOn = build.getBuiltOn();
        if (builtOn == null) { // node built-on doesn't exist anymore
            return true;
        }
        
        if (builtOn.toComputer() == null) { // node still exists, but has 0 executors - o.s.l.t.
            return true;
        }
        
        return false;
    }
1350

1351 1352
    /**
     * Returns true if this user has made a commit to this project.
1353
     *
1354 1355 1356
     * @since 1.191
     */
    public boolean hasParticipant(User user) {
1357 1358
        for( R build = getLastBuild(); build!=null; build=build.getPreviousBuild())
            if(build.hasParticipant(user))
1359 1360 1361 1362
                return true;
        return false;
    }

1363
    @Exported
1364 1365 1366 1367
    public SCM getScm() {
        return scm;
    }

1368
    public void setScm(SCM scm) throws IOException {
1369
        this.scm = scm;
1370
        save();
1371 1372
    }

1373 1374 1375
    /**
     * Adds a new {@link Trigger} to this {@link Project} if not active yet.
     */
1376
    public void addTrigger(Trigger<?> trigger) throws IOException {
1377
        addToList(trigger,triggers);
1378 1379
    }

1380
    public void removeTrigger(TriggerDescriptor trigger) throws IOException {
1381
        removeFromList(trigger,triggers);
1382 1383
    }

1384 1385 1386 1387
    protected final synchronized <T extends Describable<T>>
    void addToList( T item, List<T> collection ) throws IOException {
        for( int i=0; i<collection.size(); i++ ) {
            if(collection.get(i).getDescriptor()==item.getDescriptor()) {
1388
                // replace
1389
                collection.set(i,item);
1390 1391 1392 1393 1394 1395 1396
                save();
                return;
            }
        }
        // add
        collection.add(item);
        save();
1397
        updateTransientActions();
1398 1399
    }

1400 1401 1402 1403
    protected final synchronized <T extends Describable<T>>
    void removeFromList(Descriptor<T> item, List<T> collection) throws IOException {
        for( int i=0; i< collection.size(); i++ ) {
            if(collection.get(i).getDescriptor()==item) {
1404 1405 1406
                // found it
                collection.remove(i);
                save();
1407
                updateTransientActions();
1408 1409 1410 1411 1412
                return;
            }
        }
    }

1413 1414
    public synchronized Map<TriggerDescriptor,Trigger> getTriggers() {
        return (Map)Descriptor.toMap(triggers);
1415 1416
    }

1417
    /**
1418
     * Gets the specific trigger, or null if the propert is not configured for this job.
1419 1420 1421
     */
    public <T extends Trigger> T getTrigger(Class<T> clazz) {
        for (Trigger p : triggers) {
1422
            if(clazz.isInstance(p))
1423 1424 1425 1426 1427
                return clazz.cast(p);
        }
        return null;
    }

1428 1429 1430 1431 1432
//
//
// fingerprint related
//
//
1433 1434 1435 1436 1437 1438
    /**
     * True if the builds of this project produces {@link Fingerprint} records.
     */
    public abstract boolean isFingerprintConfigured();

    /**
1439 1440
     * Gets the other {@link AbstractProject}s that should be built
     * when a build of this project is completed.
1441
     */
K
kohsuke 已提交
1442
    @Exported
1443
    public final List<AbstractProject> getDownstreamProjects() {
1444
        return Jenkins.getInstance().getDependencyGraph().getDownstream(this);
1445
    }
1446

K
kohsuke 已提交
1447
    @Exported
1448
    public final List<AbstractProject> getUpstreamProjects() {
1449
        return Jenkins.getInstance().getDependencyGraph().getUpstream(this);
K
kohsuke 已提交
1450 1451
    }

K
kohsuke 已提交
1452
    /**
1453 1454 1455 1456
     * Returns only those upstream projects that defines {@link BuildTrigger} to this project.
     * This is a subset of {@link #getUpstreamProjects()}
     *
     * @return A List of upstream projects that has a {@link BuildTrigger} to this project.
K
kohsuke 已提交
1457 1458 1459
     */
    public final List<AbstractProject> getBuildTriggerUpstreamProjects() {
        ArrayList<AbstractProject> result = new ArrayList<AbstractProject>();
1460 1461
        for (AbstractProject<?,?> ap : getUpstreamProjects()) {
            BuildTrigger buildTrigger = ap.getPublishersList().get(BuildTrigger.class);
1462
            if (buildTrigger != null)
1463
                if (buildTrigger.getChildProjects(ap).contains(this))
1464
                    result.add(ap);
1465
        }        
K
kohsuke 已提交
1466
        return result;
1467 1468
    }    
    
K
kohsuke 已提交
1469 1470
    /**
     * Gets all the upstream projects including transitive upstream projects.
1471
     *
K
kohsuke 已提交
1472 1473 1474
     * @since 1.138
     */
    public final Set<AbstractProject> getTransitiveUpstreamProjects() {
1475
        return Jenkins.getInstance().getDependencyGraph().getTransitiveUpstream(this);
K
kohsuke 已提交
1476 1477 1478
    }

    /**
1479 1480
     * Gets all the downstream projects including transitive downstream projects.
     *
K
kohsuke 已提交
1481 1482 1483
     * @since 1.138
     */
    public final Set<AbstractProject> getTransitiveDownstreamProjects() {
1484
        return Jenkins.getInstance().getDependencyGraph().getTransitiveDownstream(this);
1485 1486 1487 1488 1489
    }

    /**
     * Gets the dependency relationship map between this project (as the source)
     * and that project (as the sink.)
1490 1491 1492 1493
     *
     * @return
     *      can be empty but not null. build number of this project to the build
     *      numbers of that project.
1494 1495
     */
    public SortedMap<Integer, RangeSet> getRelationship(AbstractProject that) {
1496
        TreeMap<Integer,RangeSet> r = new TreeMap<Integer,RangeSet>(REVERSE_INTEGER_COMPARATOR);
1497 1498 1499 1500 1501 1502 1503 1504 1505

        checkAndRecord(that, r, this.getBuilds());
        // checkAndRecord(that, r, that.getBuilds());

        return r;
    }

    /**
     * Helper method for getDownstreamRelationship.
1506 1507
     *
     * For each given build, find the build number range of the given project and put that into the map.
1508
     */
1509
    private void checkAndRecord(AbstractProject that, TreeMap<Integer, RangeSet> r, Collection<R> builds) {
1510 1511
        for (R build : builds) {
            RangeSet rs = build.getDownstreamRelationship(that);
1512
            if(rs==null || rs.isEmpty())
1513 1514 1515 1516 1517
                continue;

            int n = build.getNumber();

            RangeSet value = r.get(n);
1518 1519
            if(value==null)
                r.put(n,rs);
1520 1521 1522 1523 1524
            else
                value.add(rs);
        }
    }

1525 1526 1527 1528 1529 1530
    /**
     * Builds the dependency graph.
     * @see DependencyGraph
     */
    protected abstract void buildDependencyGraph(DependencyGraph graph);

1531
    @Override
K
kohsuke 已提交
1532 1533
    protected SearchIndexBuilder makeSearchIndex() {
        SearchIndexBuilder sib = super.makeSearchIndex();
1534
        if(isBuildable() && hasPermission(Jenkins.ADMINISTER))
1535
            sib.add("build","build");
K
kohsuke 已提交
1536 1537 1538
        return sib;
    }

1539 1540
    @Override
    protected HistoryWidget createHistoryWidget() {
1541
        return new BuildHistoryWidget<R>(this,getBuilds(),HISTORY_ADAPTER);
1542
    }
1543
    
K
kohsuke 已提交
1544
    public boolean isParameterized() {
1545
        return getProperty(ParametersDefinitionProperty.class) != null;
K
kohsuke 已提交
1546
    }
1547

1548 1549 1550 1551 1552
//
//
// actions
//
//
1553 1554 1555
    /**
     * Schedules a new build command.
     */
1556
    public void doBuild( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1557
        BuildAuthorizationToken.checkPermission(this, authToken, req, rsp);
1558

K
kohsuke 已提交
1559 1560 1561
        // if a build is parameterized, let that take over
        ParametersDefinitionProperty pp = getProperty(ParametersDefinitionProperty.class);
        if (pp != null) {
1562
            pp._doBuild(req,rsp);
K
kohsuke 已提交
1563 1564 1565
            return;
        }

1566 1567 1568
        if (!isBuildable())
            throw HttpResponses.error(SC_INTERNAL_SERVER_ERROR,new IOException(getFullName()+" is not buildable"));

1569
        Jenkins.getInstance().getQueue().schedule(this, getDelay(req), getBuildCause(req));
1570 1571 1572 1573 1574 1575 1576
        rsp.forwardToPreviousPage(req);
    }

    /**
     * Computes the build cause, using RemoteCause or UserCause as appropriate.
     */
    /*package*/ CauseAction getBuildCause(StaplerRequest req) {
1577 1578
        Cause cause;
        if (authToken != null && authToken.getToken() != null && req.getParameter("token") != null) {
1579 1580
            // Optional additional cause text when starting via token
            String causeText = req.getParameter("cause");
1581
            cause = new RemoteCause(req.getRemoteAddr(), causeText);
1582 1583 1584
        } else {
            cause = new UserCause();
        }
1585
        return new CauseAction(cause);
1586 1587 1588 1589 1590 1591
    }

    /**
     * Computes the delay by taking the default value and the override in the request parameter into the account.
     */
    public int getDelay(StaplerRequest req) throws ServletException {
1592
        String delay = req.getParameter("delay");
1593 1594 1595 1596 1597 1598 1599 1600 1601
        if (delay==null)    return getQuietPeriod();

        try {
            // TODO: more unit handling
            if(delay.endsWith("sec"))   delay=delay.substring(0,delay.length()-3);
            if(delay.endsWith("secs"))  delay=delay.substring(0,delay.length()-4);
            return Integer.parseInt(delay);
        } catch (NumberFormatException e) {
            throw new ServletException("Invalid delay parameter value: "+delay);
1602
        }
1603
    }
1604

1605 1606 1607 1608
    /**
     * Supports build trigger with parameters via an HTTP GET or POST.
     * Currently only String parameters are supported.
     */
1609
    public void doBuildWithParameters(StaplerRequest req, StaplerResponse rsp) throws IOException, ServletException {
1610 1611 1612 1613 1614 1615 1616 1617 1618 1619
        BuildAuthorizationToken.checkPermission(this, authToken, req, rsp);

        ParametersDefinitionProperty pp = getProperty(ParametersDefinitionProperty.class);
        if (pp != null) {
            pp.buildWithParameters(req,rsp);
        } else {
        	throw new IllegalStateException("This build is not parameterized!");
        }
    	
    }
1620 1621 1622 1623

    /**
     * Schedules a new SCM polling command.
     */
1624
    public void doPolling( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1625 1626 1627
        BuildAuthorizationToken.checkPermission(this, authToken, req, rsp);
        schedulePolling();
        rsp.forwardToPreviousPage(req);
1628 1629 1630 1631 1632
    }

    /**
     * Cancels a scheduled build.
     */
1633
    public void doCancelQueue( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1634
        checkPermission(BUILD);
1635

1636
        Jenkins.getInstance().getQueue().cancel(this);
1637 1638 1639
        rsp.forwardToPreviousPage(req);
    }

1640
    @Override
1641 1642
    protected void submit(StaplerRequest req, StaplerResponse rsp) throws IOException, ServletException, FormException {
        super.submit(req,rsp);
1643

1644
        makeDisabled(req.getParameter("disable")!=null);
1645 1646

        jdk = req.getParameter("jdk");
1647
        if(req.getParameter("hasCustomQuietPeriod")!=null) {
1648 1649 1650 1651
            quietPeriod = Integer.parseInt(req.getParameter("quiet_period"));
        } else {
            quietPeriod = null;
        }
1652 1653
        if(req.getParameter("hasCustomScmCheckoutRetryCount")!=null) {
            scmCheckoutRetryCount = Integer.parseInt(req.getParameter("scmCheckoutRetryCount"));
S
 
shinodkm 已提交
1654
        } else {
1655
            scmCheckoutRetryCount = null;
S
 
shinodkm 已提交
1656
        }
1657
        blockBuildWhenDownstreamBuilding = req.getParameter("blockBuildWhenDownstreamBuilding")!=null;
1658 1659
        blockBuildWhenUpstreamBuilding = req.getParameter("blockBuildWhenUpstreamBuilding")!=null;

1660
        if(req.hasParameter("customWorkspace")) {
1661 1662 1663
            customWorkspace = Util.fixEmptyAndTrim(req.getParameter("customWorkspace.directory"));
            if(customWorkspace==null)
            	throw new FormException("Custom workspace is empty", "customWorkspace");
1664 1665 1666 1667
        } else {
            customWorkspace = null;
        }
        
1668
        if(req.getParameter("hasSlaveAffinity")!=null) {
1669
            assignedNode = Util.fixEmptyAndTrim(req.getParameter("_.assignedLabelString"));
1670 1671 1672
        } else {
            assignedNode = null;
        }
1673
        canRoam = assignedNode==null;
1674

1675
        concurrentBuild = req.getSubmittedForm().has("concurrentBuild");
K
kohsuke 已提交
1676

1677
        authToken = BuildAuthorizationToken.create(req);
1678

K
kohsuke 已提交
1679
        setScm(SCMS.parseSCM(req,this));
1680 1681 1682

        for (Trigger t : triggers)
            t.stop();
1683
        triggers = buildDescribable(req, Trigger.for_(this));
1684
        for (Trigger t : triggers)
1685
            t.start(this,true);
1686 1687
    }

K
kohsuke 已提交
1688 1689 1690 1691 1692 1693 1694 1695 1696
    /**
     * @deprecated
     *      As of 1.261. Use {@link #buildDescribable(StaplerRequest, List)} instead.
     */
    protected final <T extends Describable<T>> List<T> buildDescribable(StaplerRequest req, List<? extends Descriptor<T>> descriptors, String prefix) throws FormException, ServletException {
        return buildDescribable(req,descriptors);
    }

    protected final <T extends Describable<T>> List<T> buildDescribable(StaplerRequest req, List<? extends Descriptor<T>> descriptors)
1697
        throws FormException, ServletException {
1698

1699
        JSONObject data = req.getSubmittedForm();
1700
        List<T> r = new Vector<T>();
1701
        for (Descriptor<T> d : descriptors) {
1702 1703 1704
            String safeName = d.getJsonSafeClassName();
            if (req.getParameter(safeName) != null) {
                T instance = d.newInstance(req, data.getJSONObject(safeName));
1705
                r.add(instance);
1706 1707
            }
        }
1708
        return r;
1709 1710 1711 1712 1713
    }

    /**
     * Serves the workspace files.
     */
1714
    public DirectoryBrowserSupport doWs( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException, InterruptedException {
1715
        checkPermission(AbstractProject.WORKSPACE);
K
kohsuke 已提交
1716
        FilePath ws = getSomeWorkspace();
1717
        if ((ws == null) || (!ws.exists())) {
1718
            // if there's no workspace, report a nice error message
1719 1720 1721 1722
            // Would be good if when asked for *plain*, do something else!
            // (E.g. return 404, or send empty doc.)
            // Not critical; client can just check if content type is not text/plain,
            // which also serves to detect old versions of Hudson.
1723
            req.getView(this,"noWorkspace.jelly").forward(req,rsp);
1724
            return null;
1725
        } else {
1726
            return new DirectoryBrowserSupport(this, ws, getDisplayName()+" workspace", "folder.png", true);
1727 1728
        }
    }
1729

1730 1731 1732
    /**
     * Wipes out the workspace.
     */
1733
    public HttpResponse doDoWipeOutWorkspace() throws IOException, ServletException, InterruptedException {
1734
        checkPermission(Functions.isWipeOutPermissionEnabled() ? WIPEOUT : BUILD);
1735 1736 1737 1738
        R b = getSomeBuildWithWorkspace();
        FilePath ws = b!=null ? b.getWorkspace() : null;
        if (ws!=null && getScm().processWorkspaceBeforeDeletion(this, ws, b.getBuiltOn())) {
            ws.deleteRecursive();
1739 1740 1741 1742
            return new HttpRedirect(".");
        } else {
            // If we get here, that means the SCM blocked the workspace deletion.
            return new ForwardToView(this,"wipeOutWorkspaceBlocked.jelly");
1743
        }
1744 1745
    }

1746
    @CLIMethod(name="disable-job")
1747
    public HttpResponse doDisable() throws IOException, ServletException {
1748 1749 1750
        requirePOST();
        checkPermission(CONFIGURE);
        makeDisabled(true);
1751
        return new HttpRedirect(".");
1752 1753
    }

1754
    @CLIMethod(name="enable-job")
1755
    public HttpResponse doEnable() throws IOException, ServletException {
1756
        requirePOST();
1757 1758
        checkPermission(CONFIGURE);
        makeDisabled(false);
1759
        return new HttpRedirect(".");
1760 1761
    }

K
kohsuke 已提交
1762 1763 1764
    /**
     * RSS feed for changes in this project.
     */
1765
    public void doRssChangelog(  StaplerRequest req, StaplerResponse rsp  ) throws IOException, ServletException {
K
kohsuke 已提交
1766 1767 1768 1769 1770 1771 1772 1773 1774
        class FeedItem {
            ChangeLogSet.Entry e;
            int idx;

            public FeedItem(Entry e, int idx) {
                this.e = e;
                this.idx = idx;
            }

1775
            AbstractBuild<?,?> getBuild() {
K
kohsuke 已提交
1776 1777 1778 1779 1780 1781
                return e.getParent().build;
            }
        }

        List<FeedItem> entries = new ArrayList<FeedItem>();

1782 1783 1784 1785
        for(R r=getLastBuild(); r!=null; r=r.getPreviousBuild()) {
            int idx=0;
            for( ChangeLogSet.Entry e : r.getChangeSet())
                entries.add(new FeedItem(e,idx++));
K
kohsuke 已提交
1786 1787
        }

1788 1789 1790 1791 1792 1793 1794
        RSS.forwardToRss(
            getDisplayName()+' '+getScm().getDescriptor().getDisplayName()+" changes",
            getUrl()+"changes",
            entries, new FeedAdapter<FeedItem>() {
                public String getEntryTitle(FeedItem item) {
                    return "#"+item.getBuild().number+' '+item.e.getMsg()+" ("+item.e.getAuthor()+")";
                }
K
kohsuke 已提交
1795

1796 1797 1798
                public String getEntryUrl(FeedItem item) {
                    return item.getBuild().getUrl()+"changes#detail"+item.idx;
                }
K
kohsuke 已提交
1799

1800 1801 1802
                public String getEntryID(FeedItem item) {
                    return getEntryUrl(item);
                }
K
kohsuke 已提交
1803

1804 1805 1806 1807 1808 1809
                public String getEntryDescription(FeedItem item) {
                    StringBuilder buf = new StringBuilder();
                    for(String path : item.e.getAffectedPaths())
                        buf.append(path).append('\n');
                    return buf.toString();
                }
1810

1811 1812 1813
                public Calendar getEntryTimestamp(FeedItem item) {
                    return item.getBuild().getTimestamp();
                }
1814

1815
                public String getEntryAuthor(FeedItem entry) {
1816
                    return Mailer.descriptor().getAdminAddress();
1817 1818 1819
                }
            },
            req, rsp );
K
kohsuke 已提交
1820 1821
    }

1822 1823 1824 1825 1826 1827 1828
    /**
     * {@link AbstractProject} subtypes should implement this base class as a descriptor.
     *
     * @since 1.294
     */
    public static abstract class AbstractProjectDescriptor extends TopLevelItemDescriptor {
        /**
1829
         * {@link AbstractProject} subtypes can override this method to veto some {@link Descriptor}s
1830
         * from showing up on their configuration screen. This is often useful when you are building
1831 1832
         * a workflow/company specific project type, where you want to limit the number of choices
         * given to the users.
1833 1834
         *
         * <p>
1835 1836 1837 1838
         * Some {@link Descriptor}s define their own schemes for controlling applicability
         * (such as {@link BuildStepDescriptor#isApplicable(Class)}),
         * This method works like AND in conjunction with them;
         * Both this method and that method need to return true in order for a given {@link Descriptor}
1839 1840 1841 1842
         * to show up for the given {@link Project}.
         *
         * <p>
         * The default implementation returns true for everything.
1843 1844
         *
         * @see BuildStepDescriptor#isApplicable(Class) 
K
kohsuke 已提交
1845 1846
         * @see BuildWrapperDescriptor#isApplicable(AbstractProject) 
         * @see TriggerDescriptor#isApplicable(Item)
1847
         */
K
kohsuke 已提交
1848
        @Override
1849
        public boolean isApplicable(Descriptor descriptor) {
1850 1851
            return true;
        }
1852 1853

        public FormValidation doCheckAssignedLabelString(@QueryParameter String value) {
1854 1855
            if (Util.fixEmpty(value)==null)
                return FormValidation.ok(); // nothing typed yet
1856 1857 1858
            try {
                Label.parseExpression(value);
            } catch (ANTLRException e) {
S
Seiji Sogabe 已提交
1859 1860
                return FormValidation.error(e,
                        Messages.AbstractProject_AssignedLabelString_InvalidBooleanExpression(e.getMessage()));
1861 1862
            }
            // TODO: if there's an atom in the expression that is empty, report it
1863
            if (Jenkins.getInstance().getLabel(value).isEmpty())
S
Seiji Sogabe 已提交
1864
                return FormValidation.warning(Messages.AbstractProject_AssignedLabelString_NoMatch());
1865 1866
            return FormValidation.ok();
        }
1867

1868 1869 1870 1871 1872 1873 1874
        public FormValidation doCheckCustomWorkspace(@QueryParameter String customWorkspace){
        	if(Util.fixEmptyAndTrim(customWorkspace)==null)
        		return FormValidation.error("Custom workspace is empty");
        	else
        		return FormValidation.ok();
        }
        
1875 1876
        public AutoCompletionCandidates doAutoCompleteUpstreamProjects(@QueryParameter String value) {
            AutoCompletionCandidates candidates = new AutoCompletionCandidates();
1877
            List<Job> jobs = Jenkins.getInstance().getItems(Job.class);
1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888
            for (Job job: jobs) {
                if (job.getFullName().startsWith(value)) {
                    if (job.hasPermission(Item.READ)) {
                        candidates.add(job.getFullName());
                    }
                }
            }
            return candidates;
        }

        public AutoCompletionCandidates doAutoCompleteAssignedLabelString(@QueryParameter String value) {
1889
            AutoCompletionCandidates c = new AutoCompletionCandidates();
1890
            Set<Label> labels = Jenkins.getInstance().getLabels();
1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943
            List<String> queries = new AutoCompleteSeeder(value).getSeeds();

            for (String term : queries) {
                for (Label l : labels) {
                    if (l.getName().startsWith(term)) {
                        c.add(l.getName());
                    }
                }
            }
            return c;
        }

        /**
        * Utility class for taking the current input value and computing a list
        * of potential terms to match against the list of defined labels.
         */
        static class AutoCompleteSeeder {
            private String source;
            private Pattern quoteMatcher = Pattern.compile("(\\\"?)(.+?)(\\\"?+)(\\s*)");

            AutoCompleteSeeder(String source) {
                this.source = source;
            }

            List<String> getSeeds() {
                ArrayList<String> terms = new ArrayList();
                boolean trailingQuote = source.endsWith("\"");
                boolean leadingQuote = source.startsWith("\"");
                boolean trailingSpace = source.endsWith(" ");

                if (trailingQuote || (trailingSpace && !leadingQuote)) {
                    terms.add("");
                } else {
                    if (leadingQuote) {
                        int quote = source.lastIndexOf('"');
                        if (quote == 0) {
                            terms.add(source.substring(1));
                        } else {
                            terms.add("");
                        }
                    } else {
                        int space = source.lastIndexOf(' ');
                        if (space > -1) {
                            terms.add(source.substring(space+1));
                        } else {
                            terms.add(source);
                        }
                    }
                }

                return terms;
            }
        }
1944 1945
    }

1946
    /**
1947
     * Finds a {@link AbstractProject} that has the name closest to the given name.
1948 1949
     */
    public static AbstractProject findNearest(String name) {
1950
        List<AbstractProject> projects = Jenkins.getInstance().getItems(AbstractProject.class);
1951
        String[] names = new String[projects.size()];
1952
        for( int i=0; i<projects.size(); i++ )
1953 1954 1955
            names[i] = projects.get(i).getName();

        String nearest = EditDistance.findNearest(name, names);
1956
        return (AbstractProject) Jenkins.getInstance().getItem(nearest);
1957
    }
1958 1959 1960

    private static final Comparator<Integer> REVERSE_INTEGER_COMPARATOR = new Comparator<Integer>() {
        public int compare(Integer o1, Integer o2) {
1961
            return o2-o1;
1962 1963
        }
    };
1964

1965
    private static final Logger LOGGER = Logger.getLogger(AbstractProject.class.getName());
1966

1967
    /**
1968
     * Permission to abort a build. For now, let's make it the same as {@link #BUILD}
1969 1970
     */
    public static final Permission ABORT = BUILD;
1971

K
Kohsuke Kawaguchi 已提交
1972 1973 1974
    /**
     * Replaceable "Build Now" text.
     */
1975 1976
    public static final Message<AbstractProject> BUILD_NOW_TEXT = new Message<AbstractProject>();

1977 1978 1979 1980 1981 1982
    /**
     * Used for CLI binding.
     */
    @CLIResolver
    public static AbstractProject resolveForCLI(
            @Argument(required=true,metaVar="NAME",usage="Job name") String name) throws CmdLineException {
1983
        AbstractProject item = Jenkins.getInstance().getItemByFullName(name, AbstractProject.class);
1984 1985 1986 1987
        if (item==null)
            throw new CmdLineException(null,Messages.AbstractItem_NoSuchJobExists(name,AbstractProject.findNearest(name).getFullName()));
        return item;
    }
1988 1989 1990 1991 1992 1993 1994 1995 1996 1997 1998 1999 2000 2001 2002 2003 2004 2005 2006

    public String getCustomWorkspace() {
        return customWorkspace;
    }

    /**
     * User-specified workspace directory, or null if it's up to Jenkins.
     *
     * <p>
     * Normally a project uses the workspace location assigned by its parent container,
     * but sometimes people have builds that have hard-coded paths.
     *
     * <p>
     * This is not {@link File} because it may have to hold a path representation on another OS.
     *
     * <p>
     * If this path is relative, it's resolved against {@link Node#getRootPath()} on the node where this workspace
     * is prepared. 
     *
2007
     * @since 1.410
2008 2009
     */
    public void setCustomWorkspace(String customWorkspace) throws IOException {
2010
        this.customWorkspace= Util.fixEmptyAndTrim(customWorkspace);
2011 2012
        save();
    }
2013
    
2014
}