+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.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 "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() }
+ }
+}
+
+if (fail){
+ throw new AbortException("Some job failed")
+}
+"""
+ def dslTriggerModule = """\