+
+ // Trigger generations
+ def dslTriggerKernel = """\
+import hudson.model.*
+import jenkins.model.*
+import hudson.AbortException
+import hudson.console.HyperlinkNote
+import java.util.concurrent.CancellationException
+import java.util.Random
+
+
+Random random = new Random()
+def jobs = hudson.model.Hudson.instance.items
+def fail = false
+def jobStartWith = "dsl-kernel-"
+def toBuild = []
+def counter = 0
+def limitQueue = 4
+
+def anotherBuild
+jobs.each { job ->
+ def jobName = job.getName()
+ if (jobName.startsWith(jobStartWith)) {
+ counter = counter + 1
+ def lastBuild = job.getLastBuild()
+ if (lastBuild == null || lastBuild.result != Result.SUCCESS) {
+ toBuild.push(job)
+ } else {
+ println("\\tAlready built")
+ }
+ }
+}
+
+println "Kernel total "+ counter
+println "Kernel to build "+ toBuild.size()
+
+
+def kernelEnabledNode = 0
+hudson.model.Hudson.instance.nodes.each { node ->
+ if (node.getLabelString().contains("kernel")){
+ kernelEnabledNode++
+ }
+}
+println "Nb of live kernel enabled build node "+ kernelEnabledNode
+
+def ongoingBuild = []
+def q = jenkins.model.Jenkins.getInstance().getQueue()
+
+
+while (toBuild.size() != 0) {
+ // Throttle the build with both the number of current parent task and queued
+ // task.
+ def queuedTask = q.getItems().findAll { it.task.name.startsWith(jobStartWith) }
+ 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" + q.getItems().size()
+ } else {
+ Thread.sleep(random.nextInt(120000))
+ ongoingBuild.removeAll{ it.isCancelled() || it.isDone() }
+ }
+}
+
+if (fail){
+ throw new AbortException("Some job failed")
+}
+"""
+ def dslTriggerModule = """\
+import hudson.model.*
+import hudson.AbortException
+import hudson.console.HyperlinkNote
+import java.util.concurrent.CancellationException
+import java.util.Random
+
+
+Random random = new Random()
+def jobs = hudson.model.Hudson.instance.items
+def fail = false
+def jobStartWith = "JOBPREFIX"
+def toBuild = []
+def counter = 0
+
+def anotherBuild
+jobs.each { job ->
+ def jobName = job.getName()
+ if (jobName.startsWith(jobStartWith)) {
+ counter = counter + 1
+ toBuild.push(job)
+ }
+}
+
+// Get valid node
+def kernelEnabledNode = 0
+hudson.model.Hudson.instance.nodes.each { node ->
+ if (node.getLabelString().contains("kernel")){
+ kernelEnabledNode++
+ }
+}
+
+def ongoingBuild = []
+while (toBuild.size() != 0) {
+ if(ongoingBuild.size() <= (kernelEnabledNode.intdiv(2))) {
+ def job = toBuild.pop()
+ ongoingBuild.push(job.scheduleBuild2(0))
+ println "\\t trigering " + HyperlinkNote.encodeTo('/' + job.url, job.fullDisplayName)
+ } else {
+ Thread.sleep(random.nextInt(60000))
+ ongoingBuild.removeAll{ it.isCancelled() || it.isDone() }
+ }
+}
+
+if (fail){
+ throw new AbortException("Some job failed")
+}
+"""
+ if (isJenkinsInstance) {
+ freeStyleJob("dsl-trigger-kernel") {
+ steps {
+ systemGroovyCommand(dslTriggerKernel)
+ }
+ triggers {
+ cron("H 0 * * *")
+ }
+ }
+
+ modulesBranches.each { branch ->
+ freeStyleJob("dsl-trigger-module-${branch}") {
+ steps {
+ systemGroovyCommand(dslTriggerModule.replaceAll("JOBPREFIX",modulesPrefix + separator + branch + separator))
+ }
+ triggers {
+ scm('@daily')
+ }
+ }
+ }
+ }