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

K
kohsuke 已提交
26
import hudson.AbortException;
27
import hudson.FeedAdapter;
28
import hudson.FilePath;
29
import hudson.Launcher;
30
import hudson.Util;
31 32
import hudson.cli.declarative.CLIResolver;
import hudson.cli.declarative.CLIMethod;
K
kohsuke 已提交
33
import hudson.slaves.WorkspaceList;
M
mdonohue 已提交
34
import hudson.model.Cause.LegacyCodeCause;
35
import hudson.model.Cause.UserCause;
36
import hudson.model.Cause.RemoteCause;
37 38 39
import hudson.model.Descriptor.FormException;
import hudson.model.Fingerprint.RangeSet;
import hudson.model.RunMap.Constructor;
40
import hudson.model.Queue.WaitingItem;
K
kohsuke 已提交
41
import hudson.model.Queue.Executable;
K
kohsuke 已提交
42
import hudson.scm.ChangeLogSet;
K
kohsuke 已提交
43
import hudson.scm.ChangeLogSet.Entry;
44
import hudson.scm.NullSCM;
45
import hudson.scm.SCM;
K
kohsuke 已提交
46
import hudson.scm.SCMS;
J
jbq 已提交
47
import hudson.search.SearchIndexBuilder;
K
kohsuke 已提交
48
import hudson.security.Permission;
49
import hudson.tasks.BuildStep;
J
jbq 已提交
50
import hudson.tasks.BuildTrigger;
51
import hudson.tasks.Mailer;
52
import hudson.tasks.Publisher;
53
import hudson.tasks.BuildStepDescriptor;
K
kohsuke 已提交
54
import hudson.tasks.BuildWrapperDescriptor;
K
kohsuke 已提交
55
import hudson.triggers.SCMTrigger;
56
import hudson.triggers.Trigger;
57
import hudson.triggers.TriggerDescriptor;
58
import hudson.util.DescribableList;
59
import hudson.util.EditDistance;
S
 
shinodkm 已提交
60
import hudson.util.FormValidation;
K
kohsuke 已提交
61 62 63 64 65 66
import hudson.widgets.BuildHistoryWidget;
import hudson.widgets.HistoryWidget;
import net.sf.json.JSONObject;
import org.kohsuke.stapler.StaplerRequest;
import org.kohsuke.stapler.StaplerResponse;
import org.kohsuke.stapler.export.Exported;
S
 
shinodkm 已提交
67
import org.kohsuke.stapler.QueryParameter;
68 69 70
import org.kohsuke.stapler.HttpResponse;
import org.kohsuke.stapler.HttpRedirect;
import org.kohsuke.stapler.ForwardToView;
71
import org.kohsuke.args4j.Argument;
S
 
shinodkm 已提交
72

73

K
kohsuke 已提交
74
import javax.servlet.ServletException;
75
import java.io.File;
76
import java.io.IOException;
K
kohsuke 已提交
77
import java.lang.reflect.InvocationTargetException;
K
kohsuke 已提交
78
import java.util.ArrayList;
79
import java.util.Arrays;
80
import java.util.Calendar;
81
import java.util.Collection;
J
jbq 已提交
82
import java.util.Collections;
83
import java.util.Comparator;
J
jbq 已提交
84
import java.util.HashSet;
85 86
import java.util.List;
import java.util.Map;
J
jbq 已提交
87
import java.util.Set;
88 89 90
import java.util.SortedMap;
import java.util.TreeMap;
import java.util.Vector;
K
kohsuke 已提交
91
import java.util.concurrent.Future;
92 93
import java.util.logging.Level;
import java.util.logging.Logger;
94 95 96

/**
 * Base implementation of {@link Job}s that build software.
97
 *
98
 * For now this is primarily the common part of {@link Project} and MavenModule.
99
 *
100 101 102
 * @author Kohsuke Kawaguchi
 * @see AbstractBuild
 */
103
public abstract class AbstractProject<P extends AbstractProject<P,R>,R extends AbstractBuild<P,R>> extends Job<P,R> implements BuildableItem {
104

105
    /**
106 107 108
     * {@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()}.
109
     */
K
kohsuke 已提交
110
    private volatile SCM scm = new NullSCM();
111

112 113 114
    /**
     * All the builds keyed by their build number.
     */
115
    protected transient /*almost final*/ RunMap<R> builds = new RunMap<R>();
116 117 118 119

    /**
     * The quiet period. Null to delegate to the system default.
     */
K
kohsuke 已提交
120
    private volatile Integer quietPeriod = null;
S
 
shinodkm 已提交
121 122
    
    /**
123
     * The retry count. Null to delegate to the system default.
S
 
shinodkm 已提交
124
     */
125
    private volatile Integer scmCheckoutRetryCount = null;
126 127

    /**
128 129 130 131 132 133 134
     * 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.
     *
135
     * @see #canRoam
136 137 138 139 140
     */
    private String assignedNode;

    /**
     * True if this project can be built on any node.
141
     *
142
     * <p>
143 144
     * This somewhat ugly flag combination is so that we can migrate
     * existing Hudson installations nicely.
145
     */
K
kohsuke 已提交
146
    private volatile boolean canRoam;
147 148 149 150

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

153 154 155 156 157 158
    /**
     * 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;

159
    /**
160 161 162
     * Identifies {@link JDK} to be used.
     * Null if no explicit configuration is required.
     *
163
     * <p>
164 165 166
     * Can't store {@link JDK} directly because {@link Hudson} and {@link Project}
     * are saved independently.
     *
167 168
     * @see Hudson#getJDK(String)
     */
K
kohsuke 已提交
169
    private volatile String jdk;
170

171 172 173 174
    /**
     * @deprecated
     */
    private transient boolean enableRemoteTrigger;
175

K
kohsuke 已提交
176
    private volatile BuildAuthorizationToken authToken = null;
177

178 179 180
    /**
     * List of all {@link Trigger}s for this project.
     */
181
    protected List<Trigger<?>> triggers = new Vector<Trigger<?>>();
182

183 184
    /**
     * {@link Action}s contributed from subsidiary objects associated with
185 186 187 188
     * {@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.
189
     */
190
    protected transient /*final*/ List<Action> transientActions = new Vector<Action>();
191

K
kohsuke 已提交
192 193
    private boolean concurrentBuild;

194
    protected AbstractProject(ItemGroup parent, String name) {
195
        super(parent,name);
196

K
kohsuke 已提交
197
        if(!Hudson.getInstance().getNodes().isEmpty()) {
198
            // if a new job is configured with Hudson that already has slave nodes
199 200 201 202 203
            // make it roamable by default
            canRoam = true;
        }
    }

204
    @Override
205
    public void onLoad(ItemGroup<? extends Item> parent, String name) throws IOException {
206
        super.onLoad(parent, name);
207 208

        this.builds = new RunMap<R>();
209
        this.builds.load(this,new Constructor<R>() {
210 211 212 213 214
            public R create(File dir) throws IOException {
                return loadBuild(dir);
            }
        });

215
        if(triggers==null)
216
            // it didn't exist in < 1.28
217
            triggers = new Vector<Trigger<?>>();
218
        for (Trigger t : triggers)
219
            t.start(this,false);
220 221
        if(scm==null)
            scm = new NullSCM(); // perhaps it was pointing to a plugin that no longer exists.
222

223 224
        if(transientActions==null)
            transientActions = new Vector<Action>();    // happens when loaded from disk
225
        updateTransientActions();
226 227
    }

228
    protected void performDelete() throws IOException, InterruptedException {
K
kohsuke 已提交
229 230
        // prevent a new build while a delete operation is in progress
        makeDisabled(true);
231
        FilePath ws = getWorkspace();
232
        if(ws!=null) {
K
NPE fix  
kohsuke 已提交
233 234 235 236
            Node on = getLastBuiltOn();
            getScm().processWorkspaceBeforeDeletion(this, ws, on);
            if(on!=null)
                on.getFileSystemProvisioner().discardWorkspace(this,ws);
237
        }
K
kohsuke 已提交
238 239 240
        super.performDelete();
    }

K
kohsuke 已提交
241 242
    /**
     * Does this project perform concurrent builds?
K
kohsuke 已提交
243
     * @since 1.319
K
kohsuke 已提交
244 245 246 247 248 249 250 251 252 253
     */
    public boolean isConcurrentBuild() {
        return Hudson.CONCURRENT_BUILD && concurrentBuild;
    }

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

254
    /**
255 256
     * If this project is configured to be always built on this node,
     * return that {@link Node}. Otherwise null.
257
     */
258
    public Label getAssignedLabel() {
259
        if(canRoam)
260 261
            return null;

262
        if(assignedNode==null)
263 264
            return Hudson.getInstance().getSelfLabel();
        return Hudson.getInstance().getLabel(assignedNode);
265 266
    }

K
kohsuke 已提交
267 268 269 270 271 272 273 274 275 276 277 278 279 280 281
    /**
     * Sets the assigned label.
     */
    public void setAssignedLabel(Label l) throws IOException {
        if(l==null) {
            canRoam = true;
            assignedNode = null;
        } else {
            canRoam = false;
            if(l==Hudson.getInstance().getSelfLabel())  assignedNode = null;
            else                                        assignedNode = l.getName();
        }
        save();
    }

282
    /**
283 284
     * Get the term used in the UI to represent this kind of {@link AbstractProject}.
     * Must start with a capital letter.
285 286 287
     */
    @Override
    public String getPronoun() {
288
        return Messages.AbstractProject_Pronoun();
289 290
    }

291 292 293 294 295 296 297 298 299 300 301 302 303
    /**
     * Returns the root project value.
     *
     * @return the root project value.
     */
	public AbstractProject getRootProject() {
        if (this.getParent() instanceof Hudson) {
            return this;
        } else {
            return ((AbstractProject) this.getParent()).getRootProject();
        }
    }

304 305
    /**
     * Gets the directory where the module is checked out.
306 307 308
     *
     * @return
     *      null if the workspace is on a slave that's not connected.
K
kohsuke 已提交
309
     * @deprecated as of 1.319
K
kohsuke 已提交
310 311 312 313 314 315 316 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
     *      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>
     *      If your are calling this method during a build from an executor, swtich it to {@link AbstractBuild#getWorkspace()}.
     *      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() {
        Executor e = Executor.currentExecutor();
        if(e!=null) {
            Executable exe = e.getCurrentExecutable();
            if (exe instanceof AbstractBuild) {
                AbstractBuild b = (AbstractBuild) exe;
                if(b.getProject()==this)
                    return b.getWorkspace();
            }
        }
        R lb = getLastBuild();
        if(lb!=null)    return lb.getWorkspace();
        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 已提交
344
     * @since 1.319
345
     */
K
kohsuke 已提交
346
    public final FilePath getSomeWorkspace() {
347 348 349 350 351 352 353 354 355 356
        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 已提交
357 358 359
        int cnt=0;
        for (R b = getLastBuild(); cnt<5 && b!=null; b=b.getPreviousBuild()) {
            FilePath ws = b.getWorkspace();
360
            if (ws!=null)   return b;
K
kohsuke 已提交
361 362 363
        }
        return null;
    }
364

365 366 367
    /**
     * Returns the root directory of the checked-out module.
     * <p>
368 369
     * This is usually where <tt>pom.xml</tt>, <tt>build.xml</tt>
     * and so on exists.
K
kohsuke 已提交
370
     *
K
kohsuke 已提交
371
     * @deprecated as of 1.319
K
kohsuke 已提交
372
     *      See {@link #getWorkspace()} for a migration strategy.
373 374
     */
    public FilePath getModuleRoot() {
K
kohsuke 已提交
375
        FilePath ws = getWorkspace();
376
        if(ws==null)    return null;
K
kohsuke 已提交
377
        return getScm().getModuleRoot(ws);
378 379
    }

S
stephenconnolly 已提交
380 381 382 383 384 385
    /**
     * 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 已提交
386
     *
K
kohsuke 已提交
387
     * @deprecated as of 1.319
K
kohsuke 已提交
388
     *      See {@link #getWorkspace()} for a migration strategy.
S
stephenconnolly 已提交
389 390 391 392 393
     */
    public FilePath[] getModuleRoots() {
        return getScm().getModuleRoots(getWorkspace());
    }

394
    public int getQuietPeriod() {
395
        return quietPeriod!=null ? quietPeriod : Hudson.getInstance().getQuietPeriod();
396
    }
S
 
shinodkm 已提交
397
    
398 399
    public int getScmCheckoutRetryCount() {
        return scmCheckoutRetryCount !=null ? scmCheckoutRetryCount : Hudson.getInstance().getScmCheckoutRetryCount();
S
 
shinodkm 已提交
400
    }
401 402 403

    // ugly name because of EL
    public boolean getHasCustomQuietPeriod() {
404
        return quietPeriod!=null;
405
    }
S
 
shinodkm 已提交
406
    
407 408
    public boolean hasCustomScmCheckoutRetryCount(){
    	return scmCheckoutRetryCount != null;
S
 
shinodkm 已提交
409
    }
410 411

    public final boolean isBuildable() {
K
kohsuke 已提交
412
        return !isDisabled();
413 414
    }

415
    /**
416 417
     * Used in <tt>sidepanel.jelly</tt> to decide whether to display
     * the config/delete/build links.
418 419 420 421 422
     */
    public boolean isConfigurable() {
        return true;
    }

423 424 425 426
    public boolean blockBuildWhenUpstreamBuilding() {
    	return blockBuildWhenUpstreamBuilding;
    }

427 428 429
    public boolean isDisabled() {
        return disabled;
    }
S
 
shinodkm 已提交
430 431 432 433 434 435 436 437 438 439 440 441 442
    
    /**
     * Validates the retry count Regex
     */
    public FormValidation doCheckRetryCount(@QueryParameter String value)throws IOException,ServletException{
    	// 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();
    }
443

444 445 446 447
    /**
     * Marks the build as disabled.
     */
    public void makeDisabled(boolean b) throws IOException {
448
        if(disabled==b)     return; // noop
449
        this.disabled = b;
K
bug fix  
kohsuke 已提交
450 451
        if(b)
            Hudson.getInstance().getQueue().cancel(this);
452 453 454
        save();
    }

455 456 457 458 459 460 461 462 463 464
    @CLIMethod(name="disable-job")
    public void disable() throws IOException {
        makeDisabled(true);
    }

    @CLIMethod(name="enable-job")
    public void enable() throws IOException {
        makeDisabled(false);
    }

K
kohsuke 已提交
465 466
    @Override
    public BallColor getIconColor() {
467
        if(isDisabled())
468
            return BallColor.DISABLED;
K
kohsuke 已提交
469 470 471
        else
            return super.getIconColor();
    }
472

473
    protected void updateTransientActions() {
474
        synchronized(transientActions) {
475
            transientActions.clear();
476

477
            for (JobProperty<? super P> p : properties) {
478 479
                Action a = p.getJobAction((P)this);
                if(a!=null)
480 481 482 483 484
                    transientActions.add(a);
            }
        }
    }

485
    /**
486 487
     * Returns the live list of all {@link Publisher}s configured for this project.
     *
488
     * <p>
489 490
     * This method couldn't be called <tt>getPublishers()</tt> because existing methods
     * in sub-classes return different inconsistent types.
491
     */
492
    public abstract DescribableList<Publisher,Descriptor<Publisher>> getPublishersList();
493

K
kohsuke 已提交
494 495 496 497 498 499
    @Override
    public void addProperty(JobProperty<? super P> jobProp) throws IOException {
        super.addProperty(jobProp);
        updateTransientActions();
    }

500 501 502 503
    public List<ProminentProjectAction> getProminentActions() {
        List<Action> a = getActions();
        List<ProminentProjectAction> pa = new Vector<ProminentProjectAction>();
        for (Action action : a) {
504
            if(action instanceof ProminentProjectAction)
505 506 507 508 509
                pa.add((ProminentProjectAction) action);
        }
        return pa;
    }

510
    @Override
511
    public void doConfigSubmit( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException, FormException {
512
        super.doConfigSubmit(req,rsp);
513 514

        Set<AbstractProject> upstream = Collections.emptySet();
515 516
        if(req.getParameter("pseudoUpstreamTrigger")!=null) {
            upstream = new HashSet<AbstractProject>(Items.fromNameList(req.getParameter("upstreamProjects"),AbstractProject.class));
517 518 519 520 521 522 523 524 525
        }

        // dependency setting might have been changed by the user, so rebuild.
        Hudson.getInstance().rebuildDependencyGraph();

        // 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

526
        for (AbstractProject<?,?> p : Hudson.getInstance().getAllItems(AbstractProject.class)) {
527
            boolean isUpstream = upstream.contains(p);
528 529 530
            synchronized(p) {
                // does 'p' include us in its BuildTrigger? 
                DescribableList<Publisher,Descriptor<Publisher>> pl = p.getPublishersList();
531
                BuildTrigger trigger = pl.get(BuildTrigger.class);
532 533 534
                List<AbstractProject> newChildProjects = trigger == null ? new ArrayList<AbstractProject>():trigger.getChildProjects();
                if(isUpstream) {
                    if(!newChildProjects.contains(this))
535 536 537 538 539
                        newChildProjects.add(this);
                } else {
                    newChildProjects.remove(this);
                }

540
                if(newChildProjects.isEmpty()) {
541
                    pl.remove(BuildTrigger.class);
542
                } else {
543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565
                    // 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)
                            combinedChildren.addAll(bt.getChildProjects());
                        existing = new BuildTrigger(new ArrayList<AbstractProject>(combinedChildren),existingList.get(0).getThreshold());
                        pl.add(existing);
                        break;
                    }

566 567
                    if(existing!=null && existing.hasSame(newChildProjects))
                        continue;   // no need to touch
568
                    pl.replace(new BuildTrigger(newChildProjects,
569
                        existing==null?Result.SUCCESS:existing.getThreshold()));
570 571 572 573 574 575 576 577 578 579 580
                }
            }
        }

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

        // this is to reflect the upstream build adjustments done above
        Hudson.getInstance().rebuildDependencyGraph();
    }

M
mdonohue 已提交
581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596
	/**
	 * @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());
    }
    
597 598
    /**
     * Schedules a build of this project.
599 600 601 602 603
     *
     * @return
     *      true if the project is actually added to the queue.
     *      false if the queue contained it and therefore the add()
     *      was noop
604
     */
M
mdonohue 已提交
605 606
    public boolean scheduleBuild(Cause c) {
        return scheduleBuild(getQuietPeriod(), c);
K
kohsuke 已提交
607 608
    }

M
mdonohue 已提交
609
    public boolean scheduleBuild(int quietPeriod, Cause c) {
610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625
        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) {
626 627 628 629 630 631 632 633
        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.
     */
    public Future<R> scheduleBuild2(int quietPeriod, Cause c, Action... actions) {
634
        if (isDisabled())
635
            return null;
636

637 638 639 640 641
        List<Action> queueActions = new ArrayList(Arrays.asList(actions));
        if (isParameterized() && Util.filter(queueActions, ParametersAction.class).isEmpty()) {
            queueActions.add(new ParametersAction(getDefaultParametersValues()));
        }

S
sogabe 已提交
642 643 644 645
        if (c != null) {
            queueActions.add(new CauseAction(c));
        }

646 647 648 649
        WaitingItem i = Hudson.getInstance().getQueue().schedule(this, quietPeriod, queueActions);
        if(i!=null)
            return (Future)i.getFuture();
        return null;
650 651 652 653 654 655
    }

    private List<ParameterValue> getDefaultParametersValues() {
        ParametersDefinitionProperty paramDefProp = getProperty(ParametersDefinitionProperty.class);
        ArrayList<ParameterValue> defValues = new ArrayList<ParameterValue>();
        
M
mindless 已提交
656 657 658
        /*
         * This check is made ONLY if someone will call this method even if isParametrized() is false.
         */
659 660 661 662 663 664 665 666 667 668 669 670 671
        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 已提交
672 673
    }

M
mdonohue 已提交
674
	/**
675 676 677 678 679 680
     * Schedules a build, and returns a {@link Future} object
     * to wait for the completion of the build.
     *
     * <p>
     * Production code shouldn't be using this, but for tests, this is very convenience, so this isn't marked
     * as deprecated.
M
mdonohue 已提交
681 682 683 684 685
	 */
    public Future<R> scheduleBuild2(int quietPeriod) {
    	return scheduleBuild2(quietPeriod, new LegacyCodeCause());
    }
    
K
kohsuke 已提交
686
    /**
687 688
     * Schedules a build of this project, and returns a {@link Future} object
     * to wait for the completion of the build.
K
kohsuke 已提交
689
     */
M
mdonohue 已提交
690
    public Future<R> scheduleBuild2(int quietPeriod, Cause c) {
691 692 693
        return scheduleBuild2(quietPeriod, c, new Action[0]);
    }

694 695 696 697
    /**
     * Schedules a polling of this project.
     */
    public boolean schedulePolling() {
698
        if(isDisabled())    return false;
699
        SCMTrigger scmt = getTrigger(SCMTrigger.class);
700
        if(scmt==null)      return false;
701 702 703 704
        scmt.run();
        return true;
    }

705 706 707 708 709
    /**
     * Returns true if the build is in the queue.
     */
    @Override
    public boolean isInQueue() {
710
        return Hudson.getInstance().getQueue().contains(this);
711 712
    }

K
kohsuke 已提交
713 714 715 716 717
    @Override
    public Queue.Item getQueueItem() {
        return Hudson.getInstance().getQueue().getItem(this);
    }

K
kohsuke 已提交
718 719 720
    /**
     * Gets the JDK that this project is configured with, or null.
     */
721
    public JDK getJDK() {
722
        return Hudson.getInstance().getJDK(jdk);
723 724 725 726 727
    }

    /**
     * Overwrites the JDK setting.
     */
K
kohsuke 已提交
728
    public void setJDK(JDK jdk) throws IOException {
729 730 731 732
        this.jdk = jdk.getName();
        save();
    }

733 734
    public BuildAuthorizationToken getAuthToken() {
        return authToken;
735 736 737 738 739 740 741 742 743 744
    }

    public SortedMap<Integer, ? extends R> _getRuns() {
        return builds.getView();
    }

    public void removeRun(R run) {
        this.builds.remove(run);
    }

745 746 747 748 749
    /**
     * Determines Class&lt;R>.
     */
    protected abstract Class<R> getBuildClass();

H
huybrechts 已提交
750
    // keep track of the previous time we started a build
751
    private transient long lastBuildStartTime;
H
huybrechts 已提交
752
    
753 754 755
    /**
     * Creates a new build of this project for immediate execution.
     */
H
huybrechts 已提交
756 757 758 759 760 761 762 763 764 765 766
    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();
767
        try {
768
            R lastBuild = getBuildClass().getConstructor(getClass()).newInstance(this);
769 770 771 772 773 774 775
            builds.put(lastBuild);
            return lastBuild;
        } catch (InstantiationException e) {
            throw new Error(e);
        } catch (IllegalAccessException e) {
            throw new Error(e);
        } catch (InvocationTargetException e) {
776
            throw handleInvocationTargetException(e);
777 778 779 780
        } catch (NoSuchMethodException e) {
            throw new Error(e);
        }
    }
781

782
    private IOException handleInvocationTargetException(InvocationTargetException e) {
783
        Throwable t = e.getTargetException();
784 785 786
        if(t instanceof Error)  throw (Error)t;
        if(t instanceof RuntimeException)   throw (RuntimeException)t;
        if(t instanceof IOException)    return (IOException)t;
787 788 789
        throw new Error(t);
    }

790 791 792
    /**
     * Loads an existing build record from disk.
     */
793 794
    protected R loadBuild(File dir) throws IOException {
        try {
795
            return getBuildClass().getConstructor(getClass(),File.class).newInstance(this,dir);
796 797 798 799 800
        } catch (InstantiationException e) {
            throw new Error(e);
        } catch (IllegalAccessException e) {
            throw new Error(e);
        } catch (InvocationTargetException e) {
801
            throw handleInvocationTargetException(e);
802 803 804 805
        } catch (NoSuchMethodException e) {
            throw new Error(e);
        }
    }
806

K
kohsuke 已提交
807 808
    /**
     * {@inheritDoc}
809
     *
K
kohsuke 已提交
810 811
     * <p>
     * Note that this method returns a read-only view of {@link Action}s.
812 813
     * {@link BuildStep}s and others who want to add a project action
     * should do so by implementing {@link BuildStep#getProjectAction(AbstractProject)}.
K
kohsuke 已提交
814
     */
815 816 817 818
    public synchronized List<Action> getActions() {
        // add all the transient actions, too
        List<Action> actions = new Vector<Action>(super.getActions());
        actions.addAll(transientActions);
819
        // return the read only list to cause a failure on plugins who try to add an action here
K
kohsuke 已提交
820
        return Collections.unmodifiableList(actions);
821 822
    }

823 824
    /**
     * Gets the {@link Node} where this project was last built on.
825 826 827 828
     *
     * @return
     *      null if no information is available (for example,
     *      if no build was done yet.)
829 830 831 832
     */
    public Node getLastBuiltOn() {
        // where was it built on?
        AbstractBuild b = getLastBuild();
833
        if(b==null)
834 835 836 837 838
            return null;
        else
            return b.getBuiltOn();
    }

839
    /**
840
     * {@inheritDoc}
841
     *
842
     * <p>
843
     * A project must be blocked if its own previous build is in progress,
844 845
     * or if the blockBuildWhenUpstreamBuilding option is true and an upstream
     * project is building, but derived classes can also check other conditions.
846
     */
847
    public boolean isBuildBlocked() {
848 849 850 851 852 853 854 855 856
        boolean blocked = isBuilding() && !isConcurrentBuild();
	if (!blocked && blockBuildWhenUpstreamBuilding) {
            AbstractProject bup = getBuildingUpstream();
            if(bup!=null) {
                return true;
            }
        }
        return blocked;

857 858
    }

859
    public String getWhyBlocked() {
860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895
	if (isBuilding() && !isConcurrentBuild()) { 
	    AbstractBuild<?, ?> build = getLastBuild();
	    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);
	}
	else {
	    AbstractProject bup = getBuildingUpstream();
            String projectName = "";
            if(bup!=null) {
                projectName = bup.getName();
            }
            return Messages.AbstractProject_UpstreamBuildInProgress(projectName);
    	}
    }


    /**
     * Returns the project if any of the upstream project (or itself) is either
     * 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() {
    	DependencyGraph graph = Hudson.getInstance().getDependencyGraph();
        Set<AbstractProject> tups = graph.getTransitiveUpstream(this);
        tups.add(this);
        for (AbstractProject tup : tups) {
            if(tup!=this && (tup.isBuilding() || tup.isInQueue()))
                return tup;
        }
        return null;
896 897 898 899
    }

    public final long getEstimatedDuration() {
        AbstractBuild b = getLastSuccessfulBuild();
900
        if(b==null)     return -1;
901 902

        long duration = b.getDuration();
903
        if(duration==0) return -1;
904 905 906 907

        return duration;
    }

908
    public R createExecutable() throws IOException {
909
        if(isDisabled())    return null;
910
        return newBuild();
911 912
    }

913 914 915 916
    public void checkAbortPermission() {
        checkPermission(AbstractProject.ABORT);
    }

K
kohsuke 已提交
917 918 919 920
    public boolean hasAbortPermission() {
        return hasPermission(AbstractProject.ABORT);
    }

921 922
    /**
     * Gets the {@link Resource} that represents the workspace of this project.
923
     * Useful for locking and mutual exclusion control.
K
kohsuke 已提交
924
     *
K
kohsuke 已提交
925
     * @deprecated as of 1.319
K
kohsuke 已提交
926 927 928 929 930 931 932
     *      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}.
933 934
     */
    public Resource getWorkspaceResource() {
935
        return new Resource(getFullDisplayName()+" workspace");
936 937 938 939 940 941
    }

    /**
     * List of necessary resources to perform the build of this project.
     */
    public ResourceList getResourceList() {
942
        final Set<ResourceActivity> resourceActivities = getResourceActivities();
943
        final List<ResourceList> resourceLists = new ArrayList<ResourceList>(1 + resourceActivities.size());
944 945 946 947 948 949 950 951 952 953
        for (ResourceActivity activity : resourceActivities) {
            if (activity != this && activity != null) {
                // defensive infinite recursion and null check
                resourceLists.add(activity.getResourceList());
            }
        }
        return ResourceList.union(resourceLists);
    }

    /**
954 955
     * 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.
956 957
     */
    protected Set<ResourceActivity> getResourceActivities() {
K
kohsuke 已提交
958
        return Collections.emptySet();
959 960
    }

961
    public boolean checkout(AbstractBuild build, Launcher launcher, BuildListener listener, File changelogFile) throws IOException {
962
        SCM scm = getScm();
963 964
        if(scm==null)
            return true;    // no SCM
965 966

        try {
K
kohsuke 已提交
967
            FilePath workspace = build.getWorkspace();
968
            workspace.mkdirs();
969
            return scm.checkout(build, launcher, workspace, listener, changelogFile);
970
        } catch (InterruptedException e) {
K
i18n  
kohsuke 已提交
971
            listener.getLogger().println(Messages.AbstractProject_ScmAborted());
972
            LOGGER.log(Level.INFO,build.toString()+" aborted",e);
973 974 975 976 977 978
            return false;
        }
    }

    /**
     * Checks if there's any update in SCM, and returns true if any is found.
979
     *
980
     * <p>
981 982
     * The caller is responsible for coordinating the mutual exclusion between
     * a build and polling, as both touches the workspace.
983
     */
984
    public boolean pollSCMChanges( TaskListener listener ) {
985
        SCM scm = getScm();
986
        if(scm==null) {
K
i18n  
kohsuke 已提交
987
            listener.getLogger().println(Messages.AbstractProject_NoSCM());
988 989
            return false;
        }
990
        if(isDisabled()) {
K
i18n  
kohsuke 已提交
991
            listener.getLogger().println(Messages.AbstractProject_Disabled());
992
            return false;
993 994 995
        }

        try {
K
kohsuke 已提交
996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018
            if(scm.requiresWorkspaceForPolling()) {
                // lock the workspace of the last build
                FilePath ws=null;
                R lb = getLastBuild();
                if (lb!=null)   ws = lb.getWorkspace();

                if (ws==null || !ws.exists()) {
                    // 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());
                        return false;
                    }
                    if (ws == null)
                        listener.getLogger().println(Messages.AbstractProject_WorkspaceOffline());
                    else
                        listener.getLogger().println(Messages.AbstractProject_NoWorkspace());
                    listener.getLogger().println(Messages.AbstractProject_NewBuildForWorkspace());
                    return true;
                } else {
                    WorkspaceList l = lb.getBuiltOn().toComputer().getWorkspaceList();
1019 1020 1021 1022 1023 1024
                    // if doing non-concurrent build, acquite a workspace in a way that causes builds to block for this workspace.
                    // 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
1025
                    WorkspaceList.Lease lease = l.acquire(ws, !concurrentBuild);
K
kohsuke 已提交
1026 1027 1028 1029
                    try {
                        LOGGER.fine("Polling SCM changes of " + getName());
                        return scm.pollChanges(this, ws.createLauncher(listener), ws, listener);
                    } finally {
1030
                        lease.release();
K
kohsuke 已提交
1031
                    }
K
kohsuke 已提交
1032
                }
K
kohsuke 已提交
1033 1034 1035 1036
            } else {
                // polling without workspace
                LOGGER.fine("Polling SCM changes of " + getName());
                return scm.pollChanges(this, null, null, listener);
K
kohsuke 已提交
1037
            }
1038
        } catch (AbortException e) {
K
i18n  
kohsuke 已提交
1039
            listener.fatalError(Messages.AbstractProject_Aborted());
1040
            LOGGER.log(Level.FINE, "Polling "+this+" aborted",e);
1041
            return false;
1042 1043 1044 1045
        } catch (IOException e) {
            e.printStackTrace(listener.fatalError(e.getMessage()));
            return false;
        } catch (InterruptedException e) {
1046
            e.printStackTrace(listener.fatalError(Messages.AbstractProject_PollingABorted()));
1047 1048 1049 1050
            return false;
        }
    }

1051 1052
    /**
     * Returns true if this user has made a commit to this project.
1053
     *
1054 1055 1056
     * @since 1.191
     */
    public boolean hasParticipant(User user) {
1057 1058
        for( R build = getLastBuild(); build!=null; build=build.getPreviousBuild())
            if(build.hasParticipant(user))
1059 1060 1061 1062
                return true;
        return false;
    }

1063 1064 1065 1066 1067 1068 1069 1070
    public SCM getScm() {
        return scm;
    }

    public void setScm(SCM scm) {
        this.scm = scm;
    }

1071 1072 1073
    /**
     * Adds a new {@link Trigger} to this {@link Project} if not active yet.
     */
1074
    public void addTrigger(Trigger<?> trigger) throws IOException {
1075
        addToList(trigger,triggers);
1076 1077
    }

1078
    public void removeTrigger(TriggerDescriptor trigger) throws IOException {
1079
        removeFromList(trigger,triggers);
1080 1081
    }

1082 1083 1084 1085
    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()) {
1086
                // replace
1087
                collection.set(i,item);
1088 1089 1090 1091 1092 1093 1094 1095 1096
                save();
                return;
            }
        }
        // add
        collection.add(item);
        save();
    }

1097 1098 1099 1100
    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) {
1101 1102 1103 1104 1105 1106 1107 1108
                // found it
                collection.remove(i);
                save();
                return;
            }
        }
    }

1109 1110
    public synchronized Map<TriggerDescriptor,Trigger> getTriggers() {
        return (Map)Descriptor.toMap(triggers);
1111 1112
    }

1113
    /**
1114
     * Gets the specific trigger, or null if the propert is not configured for this job.
1115 1116 1117
     */
    public <T extends Trigger> T getTrigger(Class<T> clazz) {
        for (Trigger p : triggers) {
1118
            if(clazz.isInstance(p))
1119 1120 1121 1122 1123
                return clazz.cast(p);
        }
        return null;
    }

1124 1125 1126 1127 1128
//
//
// fingerprint related
//
//
1129 1130 1131 1132 1133 1134
    /**
     * True if the builds of this project produces {@link Fingerprint} records.
     */
    public abstract boolean isFingerprintConfigured();

    /**
1135 1136
     * Gets the other {@link AbstractProject}s that should be built
     * when a build of this project is completed.
1137
     */
K
kohsuke 已提交
1138
    @Exported
1139 1140 1141
    public final List<AbstractProject> getDownstreamProjects() {
        return Hudson.getInstance().getDependencyGraph().getDownstream(this);
    }
1142

K
kohsuke 已提交
1143
    @Exported
1144 1145
    public final List<AbstractProject> getUpstreamProjects() {
        return Hudson.getInstance().getDependencyGraph().getUpstream(this);
K
kohsuke 已提交
1146 1147
    }

K
kohsuke 已提交
1148
    /**
1149 1150 1151 1152
     * 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 已提交
1153 1154 1155
     */
    public final List<AbstractProject> getBuildTriggerUpstreamProjects() {
        ArrayList<AbstractProject> result = new ArrayList<AbstractProject>();
1156 1157
        for (AbstractProject<?,?> ap : getUpstreamProjects()) {
            BuildTrigger buildTrigger = ap.getPublishersList().get(BuildTrigger.class);
1158 1159 1160
            if (buildTrigger != null)
                if (buildTrigger.getChildProjects().contains(this))
                    result.add(ap);
1161
        }        
K
kohsuke 已提交
1162
        return result;
1163 1164
    }    
    
K
kohsuke 已提交
1165 1166
    /**
     * Gets all the upstream projects including transitive upstream projects.
1167
     *
K
kohsuke 已提交
1168 1169 1170
     * @since 1.138
     */
    public final Set<AbstractProject> getTransitiveUpstreamProjects() {
1171
        return Hudson.getInstance().getDependencyGraph().getTransitiveUpstream(this);
K
kohsuke 已提交
1172 1173 1174
    }

    /**
1175 1176
     * Gets all the downstream projects including transitive downstream projects.
     *
K
kohsuke 已提交
1177 1178 1179
     * @since 1.138
     */
    public final Set<AbstractProject> getTransitiveDownstreamProjects() {
1180
        return Hudson.getInstance().getDependencyGraph().getTransitiveDownstream(this);
1181 1182 1183 1184 1185
    }

    /**
     * Gets the dependency relationship map between this project (as the source)
     * and that project (as the sink.)
1186 1187 1188 1189
     *
     * @return
     *      can be empty but not null. build number of this project to the build
     *      numbers of that project.
1190 1191
     */
    public SortedMap<Integer, RangeSet> getRelationship(AbstractProject that) {
1192
        TreeMap<Integer,RangeSet> r = new TreeMap<Integer,RangeSet>(REVERSE_INTEGER_COMPARATOR);
1193 1194 1195 1196 1197 1198 1199 1200 1201

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

        return r;
    }

    /**
     * Helper method for getDownstreamRelationship.
1202 1203
     *
     * For each given build, find the build number range of the given project and put that into the map.
1204
     */
1205
    private void checkAndRecord(AbstractProject that, TreeMap<Integer, RangeSet> r, Collection<R> builds) {
1206 1207
        for (R build : builds) {
            RangeSet rs = build.getDownstreamRelationship(that);
1208
            if(rs==null || rs.isEmpty())
1209 1210 1211 1212 1213
                continue;

            int n = build.getNumber();

            RangeSet value = r.get(n);
1214 1215
            if(value==null)
                r.put(n,rs);
1216 1217 1218 1219 1220
            else
                value.add(rs);
        }
    }

1221 1222 1223 1224 1225 1226
    /**
     * Builds the dependency graph.
     * @see DependencyGraph
     */
    protected abstract void buildDependencyGraph(DependencyGraph graph);

K
kohsuke 已提交
1227 1228
    protected SearchIndexBuilder makeSearchIndex() {
        SearchIndexBuilder sib = super.makeSearchIndex();
1229 1230
        if(isBuildable() && Hudson.isAdmin())
            sib.add("build","build");
K
kohsuke 已提交
1231 1232 1233
        return sib;
    }

1234 1235
    @Override
    protected HistoryWidget createHistoryWidget() {
1236
        return new BuildHistoryWidget<R>(this,getBuilds(),HISTORY_ADAPTER);
1237
    }
1238
    
K
kohsuke 已提交
1239
    public boolean isParameterized() {
1240
        return getProperty(ParametersDefinitionProperty.class) != null;
K
kohsuke 已提交
1241
    }
1242

1243 1244 1245 1246 1247
//
//
// actions
//
//
1248 1249 1250
    /**
     * Schedules a new build command.
     */
1251
    public void doBuild( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1252
        BuildAuthorizationToken.checkPermission(this, authToken, req, rsp);
1253

K
kohsuke 已提交
1254 1255 1256
        // if a build is parameterized, let that take over
        ParametersDefinitionProperty pp = getProperty(ParametersDefinitionProperty.class);
        if (pp != null) {
1257
            pp._doBuild(req,rsp);
K
kohsuke 已提交
1258 1259 1260
            return;
        }

1261 1262
        Cause cause;
        if (authToken != null && authToken.getToken() != null && req.getParameter("token") != null) {
1263 1264
            // Optional additional cause text when starting via token
            String causeText = req.getParameter("cause");
1265
            cause = new RemoteCause(req.getRemoteAddr(), causeText);
1266 1267 1268 1269
        } else {
            cause = new UserCause();
        }

1270
        String delay = req.getParameter("delay");
1271
        if (delay!=null) {
M
mindless 已提交
1272 1273 1274 1275 1276
            if (!isDisabled()) {
                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);
1277
                    Hudson.getInstance().getQueue().schedule(this, Integer.parseInt(delay),
1278
                    		new CauseAction(cause));
M
mindless 已提交
1279 1280 1281 1282 1283
                } catch (NumberFormatException e) {
                    throw new ServletException("Invalid delay parameter value: "+delay);
                }
            }
        } else {
1284
            scheduleBuild(cause);
1285
        }
1286 1287
        rsp.forwardToPreviousPage(req);
    }
1288

1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304
    /**
     * Supports build trigger with parameters via an HTTP GET or POST.
     * Currently only String parameters are supported.
     */
    public void doBuildWithParameters(StaplerRequest req, StaplerResponse rsp) throws IOException {
        BuildAuthorizationToken.checkPermission(this, authToken, req, rsp);

        ParametersDefinitionProperty pp = getProperty(ParametersDefinitionProperty.class);
        if (pp != null) {
            pp.buildWithParameters(req,rsp);
            return;
        } else {
        	throw new IllegalStateException("This build is not parameterized!");
        }
    	
    }
1305 1306 1307 1308

    /**
     * Schedules a new SCM polling command.
     */
1309
    public void doPolling( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException {
1310 1311 1312
        BuildAuthorizationToken.checkPermission(this, authToken, req, rsp);
        schedulePolling();
        rsp.forwardToPreviousPage(req);
1313 1314 1315 1316 1317
    }

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

1321
        Hudson.getInstance().getQueue().cancel(this);
1322 1323 1324
        rsp.forwardToPreviousPage(req);
    }

1325
    @Override
1326 1327
    protected void submit(StaplerRequest req, StaplerResponse rsp) throws IOException, ServletException, FormException {
        super.submit(req,rsp);
1328

1329
        makeDisabled(req.getParameter("disable")!=null);
1330 1331

        jdk = req.getParameter("jdk");
1332
        if(req.getParameter("hasCustomQuietPeriod")!=null) {
1333 1334 1335 1336
            quietPeriod = Integer.parseInt(req.getParameter("quiet_period"));
        } else {
            quietPeriod = null;
        }
1337 1338
        if(req.getParameter("hasCustomScmCheckoutRetryCount")!=null) {
            scmCheckoutRetryCount = Integer.parseInt(req.getParameter("scmCheckoutRetryCount"));
S
 
shinodkm 已提交
1339
        } else {
1340
        	scmCheckoutRetryCount = null;
S
 
shinodkm 已提交
1341
        }
1342

1343
        if(req.getParameter("hasSlaveAffinity")!=null) {
1344 1345
            canRoam = false;
            assignedNode = req.getParameter("slave");
1346 1347 1348
            if(assignedNode !=null) {
                if(Hudson.getInstance().getLabel(assignedNode).isEmpty())
                    assignedNode = null;   // no such label
1349 1350 1351 1352 1353 1354
            }
        } else {
            canRoam = true;
            assignedNode = null;
        }

K
kohsuke 已提交
1355 1356
        setConcurrentBuild(req.getSubmittedForm().has("concurrentBuild"));

1357
        authToken = BuildAuthorizationToken.create(req);
1358

K
kohsuke 已提交
1359
        setScm(SCMS.parseSCM(req,this));
1360 1361 1362

        for (Trigger t : triggers)
            t.stop();
1363
        triggers = buildDescribable(req, Trigger.for_(this));
1364
        for (Trigger t : triggers)
1365
            t.start(this,true);
1366 1367

        updateTransientActions();
1368 1369
    }

K
kohsuke 已提交
1370 1371 1372 1373 1374 1375 1376 1377 1378
    /**
     * @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)
1379
        throws FormException, ServletException {
1380

1381
        JSONObject data = req.getSubmittedForm();
1382
        List<T> r = new Vector<T>();
1383 1384 1385 1386
        for (Descriptor<T> d : descriptors) {
            String name = d.getJsonSafeClassName();
            if (req.getParameter(name) != null) {
                T instance = d.newInstance(req, data.getJSONObject(name));
1387
                r.add(instance);
1388 1389
            }
        }
1390
        return r;
1391 1392 1393 1394 1395
    }

    /**
     * Serves the workspace files.
     */
1396
    public void doWs( StaplerRequest req, StaplerResponse rsp ) throws IOException, ServletException, InterruptedException {
1397
        checkPermission(AbstractProject.WORKSPACE);
K
kohsuke 已提交
1398
        FilePath ws = getSomeWorkspace();
1399
        if ((ws == null) || (!ws.exists())) {
1400
            // if there's no workspace, report a nice error message
1401 1402 1403 1404
            // 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.
1405
            req.getView(this,"noWorkspace.jelly").forward(req,rsp);
1406
        } else {
1407
            new DirectoryBrowserSupport(this,getDisplayName()+" workspace").serveFile(req, rsp, ws, "folder.gif", true);
1408 1409
        }
    }
1410

1411 1412 1413
    /**
     * Wipes out the workspace.
     */
1414
    public HttpResponse doDoWipeOutWorkspace() throws IOException, ServletException, InterruptedException {
1415
        checkPermission(BUILD);
1416 1417 1418 1419
        R b = getSomeBuildWithWorkspace();
        FilePath ws = b!=null ? b.getWorkspace() : null;
        if (ws!=null && getScm().processWorkspaceBeforeDeletion(this, ws, b.getBuiltOn())) {
            ws.deleteRecursive();
1420 1421 1422 1423
            return new HttpRedirect(".");
        } else {
            // If we get here, that means the SCM blocked the workspace deletion.
            return new ForwardToView(this,"wipeOutWorkspaceBlocked.jelly");
1424
        }
1425 1426
    }

1427
    public HttpResponse doDisable() throws IOException, ServletException {
1428 1429 1430
        requirePOST();
        checkPermission(CONFIGURE);
        makeDisabled(true);
1431
        return new HttpRedirect(".");
1432 1433
    }

1434
    public HttpResponse doEnable() throws IOException, ServletException {
1435 1436
        checkPermission(CONFIGURE);
        makeDisabled(false);
1437
        return new HttpRedirect(".");
1438 1439
    }

K
kohsuke 已提交
1440 1441 1442
    /**
     * RSS feed for changes in this project.
     */
1443
    public void doRssChangelog(  StaplerRequest req, StaplerResponse rsp  ) throws IOException, ServletException {
K
kohsuke 已提交
1444 1445 1446 1447 1448 1449 1450 1451 1452
        class FeedItem {
            ChangeLogSet.Entry e;
            int idx;

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

1453
            AbstractBuild<?,?> getBuild() {
K
kohsuke 已提交
1454 1455 1456 1457 1458 1459
                return e.getParent().build;
            }
        }

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

1460 1461 1462 1463
        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 已提交
1464 1465
        }

1466 1467 1468 1469 1470 1471 1472
        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 已提交
1473

1474 1475 1476
                public String getEntryUrl(FeedItem item) {
                    return item.getBuild().getUrl()+"changes#detail"+item.idx;
                }
K
kohsuke 已提交
1477

1478 1479 1480
                public String getEntryID(FeedItem item) {
                    return getEntryUrl(item);
                }
K
kohsuke 已提交
1481

1482 1483 1484 1485 1486 1487
                public String getEntryDescription(FeedItem item) {
                    StringBuilder buf = new StringBuilder();
                    for(String path : item.e.getAffectedPaths())
                        buf.append(path).append('\n');
                    return buf.toString();
                }
1488

1489 1490 1491
                public Calendar getEntryTimestamp(FeedItem item) {
                    return item.getBuild().getTimestamp();
                }
1492

1493
                public String getEntryAuthor(FeedItem entry) {
1494
                    return Mailer.descriptor().getAdminAddress();
1495 1496 1497
                }
            },
            req, rsp );
K
kohsuke 已提交
1498 1499
    }

1500 1501 1502 1503 1504 1505 1506
    /**
     * {@link AbstractProject} subtypes should implement this base class as a descriptor.
     *
     * @since 1.294
     */
    public static abstract class AbstractProjectDescriptor extends TopLevelItemDescriptor {
        /**
1507
         * {@link AbstractProject} subtypes can override this method to veto some {@link Descriptor}s
1508
         * from showing up on their configuration screen. This is often useful when you are building
1509 1510
         * a workflow/company specific project type, where you want to limit the number of choices
         * given to the users.
1511 1512
         *
         * <p>
1513 1514 1515 1516
         * 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}
1517 1518 1519 1520
         * to show up for the given {@link Project}.
         *
         * <p>
         * The default implementation returns true for everything.
1521 1522
         *
         * @see BuildStepDescriptor#isApplicable(Class) 
K
kohsuke 已提交
1523 1524
         * @see BuildWrapperDescriptor#isApplicable(AbstractProject) 
         * @see TriggerDescriptor#isApplicable(Item)
1525
         */
K
kohsuke 已提交
1526
        @Override
1527
        public boolean isApplicable(Descriptor descriptor) {
1528 1529 1530 1531
            return true;
        }
    }

1532
    /**
1533
     * Finds a {@link AbstractProject} that has the name closest to the given name.
1534 1535
     */
    public static AbstractProject findNearest(String name) {
1536
        List<AbstractProject> projects = Hudson.getInstance().getItems(AbstractProject.class);
1537
        String[] names = new String[projects.size()];
1538
        for( int i=0; i<projects.size(); i++ )
1539 1540 1541
            names[i] = projects.get(i).getName();

        String nearest = EditDistance.findNearest(name, names);
1542
        return (AbstractProject)Hudson.getInstance().getItem(nearest);
1543
    }
1544 1545 1546

    private static final Comparator<Integer> REVERSE_INTEGER_COMPARATOR = new Comparator<Integer>() {
        public int compare(Integer o1, Integer o2) {
1547
            return o2-o1;
1548 1549
        }
    };
1550

1551
    private static final Logger LOGGER = Logger.getLogger(AbstractProject.class.getName());
1552

1553
    /**
1554
     * Permission to abort a build. For now, let's make it the same as {@link #BUILD}
1555 1556
     */
    public static final Permission ABORT = BUILD;
1557
}
1558