Change-Id: I10e301867b348eff8846705f9078de1953543047
Reviewed-on: http://photon-jenkins.eng.vmware.com:8082/4350
Reviewed-by: gerrit-photon <photon-checkins@vmware.com>
Tested-by: gerrit-photon <photon-checkins@vmware.com>
... | ... |
@@ -214,6 +214,7 @@ class Scheduler(object): |
214 | 214 |
|
215 | 215 |
if len(Scheduler.listOfPackagesNextToBuild) > 0: |
216 | 216 |
ThreadPool.ThreadPool.activateWorkerThreads(len(Scheduler.listOfPackagesNextToBuild)) |
217 |
+ Scheduler.listOfPackagesToBuild.remove(package) |
|
217 | 218 |
else: |
218 | 219 |
try: |
219 | 220 |
if Scheduler.queueOfPackagesNextToBuild.qsize() == 0: |
... | ... |
@@ -224,27 +225,28 @@ class Scheduler(object): |
224 | 224 |
queueOfPackagesNextToBuild = Scheduler.__getListNextPackagesReadyToBuild() |
225 | 225 |
Scheduler.queueOfPackagesNextToBuild = queueOfPackagesNextToBuild |
226 | 226 |
|
227 |
- if Scheduler.queueOfPackagesNextToBuild and Scheduler.queueOfPackagesNextToBuild.qsize() == 0: |
|
228 |
- Scheduler.logger.info("Released scheduler lock") |
|
229 |
- Scheduler.lock.release() |
|
230 |
- return None |
|
227 |
+ if Scheduler.queueOfPackagesNextToBuild: |
|
228 |
+ if Scheduler.queueOfPackagesNextToBuild.qsize() == 0: |
|
229 |
+ Scheduler.logger.info("Released scheduler lock") |
|
230 |
+ Scheduler.lock.release() |
|
231 |
+ return None |
|
231 | 232 |
|
232 |
- packageTup=Scheduler.queueOfPackagesNextToBuild.get() |
|
233 |
+ packageTup=Scheduler.queueOfPackagesNextToBuild.get() |
|
233 | 234 |
|
234 |
- if packageTup[0] == 0 and Scheduler.isPriorityScheduler == 1: |
|
235 |
- queueOfPackagesNextToBuild = Scheduler.__getListNextPackagesReadyToBuild() |
|
236 |
- Scheduler.queueOfPackagesNextToBuild = queueOfPackagesNextToBuild |
|
237 |
- packageTup = Scheduler.queueOfPackagesNextToBuild.get() |
|
235 |
+ if packageTup[0] == 0: |
|
236 |
+ queueOfPackagesNextToBuild = Scheduler.__getListNextPackagesReadyToBuild() |
|
237 |
+ Scheduler.queueOfPackagesNextToBuild = queueOfPackagesNextToBuild |
|
238 |
+ packageTup = Scheduler.queueOfPackagesNextToBuild.get() |
|
238 | 239 |
|
239 |
- package = packageTup[1] |
|
240 |
- Scheduler.logger.info("PackagesNextToBuild " + str(packageTup)) |
|
241 |
- if Scheduler.queueOfPackagesNextToBuild.qsize() > 0: |
|
242 |
- ThreadPool.ThreadPool.activateWorkerThreads(Scheduler.queueOfPackagesNextToBuild.qsize()) |
|
240 |
+ package = packageTup[1] |
|
241 |
+ Scheduler.logger.info("PackagesNextToBuild " + str(packageTup)) |
|
242 |
+ if Scheduler.queueOfPackagesNextToBuild.qsize() > 0: |
|
243 |
+ ThreadPool.ThreadPool.activateWorkerThreads(Scheduler.queueOfPackagesNextToBuild.qsize()) |
|
244 |
+ Scheduler.queueOfPackagesToBuild.remove(package) |
|
243 | 245 |
|
244 | 246 |
Scheduler.logger.info("Released scheduler lock") |
245 | 247 |
Scheduler.lock.release() |
246 | 248 |
Scheduler.listOfPackagesCurrentlyBuilding.append(package) |
247 |
- Scheduler.listOfPackagesToBuild.remove(package) |
|
248 | 249 |
return package |
249 | 250 |
|
250 | 251 |
#can be synchronized TODO |