// Trigger generations
def dslTriggerKernel = """\
import hudson.model.*
+import jenkins.model.*
import hudson.AbortException
import hudson.console.HyperlinkNote
import java.util.concurrent.CancellationException
Random random = new Random()
def jobs = hudson.model.Hudson.instance.items
def fail = false
-def jobStartWith = "dsl-kernel-"
+def jobStartWithKernel = "KERNELPREFIX"
+def jobStartWithModule = "MODULEPREFIX"
def toBuild = []
def counter = 0
+def limitQueue = 4
def anotherBuild
jobs.each { job ->
def jobName = job.getName()
- if (jobName.startsWith(jobStartWith)) {
+ if (jobName.startsWith(jobStartWithKernel)) {
counter = counter + 1
def lastBuild = job.getLastBuild()
if (lastBuild == null || lastBuild.result != Result.SUCCESS) {
println "Nb of live kernel enabled build node "+ kernelEnabledNode
def ongoingBuild = []
-def queueInstance = Jenkins.instance.queue
-
+def q = jenkins.model.Jenkins.getInstance().getQueue()
while (toBuild.size() != 0) {
- if(ongoingBuild.size() <= (kernelEnabledNode.intdiv(2))) {
+ // Throttle the build with both the number of current parent task and queued
+ // task.Look for both kernel and downstream module from previous kernel.
+ def queuedTask = q.getItems().findAll {
+ it.task.name.startsWith(jobStartWithKernel) ||
+ it.task.name.startsWith(jobStartWithModule)
+ }
+
+ if ((ongoingBuild.size() <= kernelEnabledNode) && (queuedTask.size() < limitQueue)) {
def job = toBuild.pop()
ongoingBuild.push(job.scheduleBuild2(0))
- println "\\t trigering" + HyperlinkNote.encodeTo('/' + job.url, job.fullDisplayName)
- println "Debug: currenlty queued task" + queueInstance.items.size()
+ println "Currently " + queuedTask.findAll{it.task.name.startsWith(jobStartWithModule)}.size() + " module jobs are queued"
+ println "Currently " + queuedTask.findAll{it.task.name.startsWith(jobStartWithKernel)}.size() + " kernel jobs are queued"
+ println "\\t trigering " + HyperlinkNote.encodeTo('/' + job.url, job.fullDisplayName)
} else {
Thread.sleep(random.nextInt(120000))
ongoingBuild.removeAll{ it.isCancelled() || it.isDone() }
throw new AbortException("Some job failed")
}
"""
+
+ dslTriggerKernel = dslTriggerKernel.replaceAll("KERNELPREFIX", kernelPrefix)
+ dslTriggerKernel = dslTriggerKernel.replaceAll("MODULEPREFIX", modulesPrefix)
if (isJenkinsInstance) {
freeStyleJob("dsl-trigger-kernel") {
steps {
}
modulesBranches.each { branch ->
+ dslTriggerModule = dslTriggerModule.replaceAll("JOBPREFIX",modulesPrefix + separator + branch + separator)
freeStyleJob("dsl-trigger-module-${branch}") {
steps {
- systemGroovyCommand(dslTriggerModule.replaceAll("JOBPREFIX",modulesPrefix + separator + branch + separator))
+ systemGroovyCommand(dslTriggerModule)
}
triggers {
scm('@daily')