2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-16 18:49:04 +00:00

Limit firmware updates to 256 at a time

To keep the concurrent update level to a fairly widely attainable limit,
impose 256 at a time limit.  This is a gigantic improvement over most
previous circumstances still, and can comfortably accommodate three of
the most dense racks at a time.
This commit is contained in:
Jarrod Johnson 2017-10-20 08:43:43 -04:00
parent 444ba917eb
commit aa0255bf62

View File

@ -23,6 +23,8 @@ import confluent.messages as msg
import eventlet
updatesbytarget = {}
updatepool = eventlet.greenpool.GreenPool(256)
def execupdate(handler, filename, updateobj):
try:
@ -48,7 +50,8 @@ class Updater(object):
self.phase = 'initializing'
self.detail = ''
self.percent = 0.0
self.updateproc = eventlet.spawn(execupdate, handler, filename, self)
#Change the below to a pool???
self.updateproc = updatepool.spawn(execupdate, handler, filename, self)
if (node, tenant) not in updatesbytarget:
updatesbytarget[(node, tenant)] = {}
if name is None: