+// Divide the valid node by validNodeDivider based on user defined label slave descriminant ex arck type
+def finalValidNodeCount = validNodeCount.intdiv(validNodeDivider
+
+// Scheduling
+
+def ongoingBuild = []
+def q = jenkins.model.Jenkins.getInstance().getQueue()
+def queuedTaskKernel = 0
+def queuedTaskModule = 0
+def sleep = 0
+
+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.
+ queuedTaskKernel = q.getItems().findAll {it.task.getParent().getDisplayName().startsWith(jobStartWithKernel)}.size()
+ queuedTaskModule = q.getItems().findAll {it.task.getParent().getDisplayName().startsWith(jobStartWithModule)}.size()
+ if ((ongoingBuild.size() <= finalValidNodeCount) && (queuedTaskKernel + queuedTaskModule < limitQueue)) {
+ def job = toBuild.pop()
+ ongoingBuild.push(job.scheduleBuild2(0))
+ println "\t trigering " + HyperlinkNote.encodeTo('/' + job.url, job.fullDisplayName)
+ } else {
+ println "Holding trigger"
+ println "Currently " + ongoingBuild.size() + " build ongoing. Max = " + validNodeCount
+ println "Currently " + queuedTaskKernel + " Kernel build ongoing."
+ println "Currently " + queuedTaskModule + " LTTng-modules build ongoing."
+ println "Limit for combination of both:" + limitQueue
+
+ sleep = random.nextInt(60000)
+ println "Sleeping for " + sleep.intdiv(1000) + " seconds"
+ Thread.sleep(sleep)
+ ongoingBuild.removeAll{ it.isCancelled() || it.isDone() }
+ }
+}