Fix group consolidation logic
This commit is contained in:
parent
fbf0ec4d9b
commit
415552989b
@ -358,8 +358,7 @@ class Controller(ServerBase):
|
|||||||
if len(sessions) <= 5 and
|
if len(sessions) <= 5 and
|
||||||
sum(s.bw_charge for s in sessions) < bw_limit]
|
sum(s.bw_charge for s in sessions) < bw_limit]
|
||||||
if len(groups) > 1:
|
if len(groups) > 1:
|
||||||
new_gid = max(group.gid for group in groups)
|
new_group = groups.pop()
|
||||||
new_group = self._new_group(new_gid)
|
|
||||||
for group in groups:
|
for group in groups:
|
||||||
self.groups.remove(group)
|
self.groups.remove(group)
|
||||||
for session in group_map[group]:
|
for session in group_map[group]:
|
||||||
|
|||||||
@ -118,7 +118,6 @@ class SessionBase(ServerSession):
|
|||||||
if msg:
|
if msg:
|
||||||
msg = 'disconnected' + msg
|
msg = 'disconnected' + msg
|
||||||
self.logger.info(msg)
|
self.logger.info(msg)
|
||||||
self.group = None
|
|
||||||
|
|
||||||
def count_pending_items(self):
|
def count_pending_items(self):
|
||||||
return self.rpc.pending_requests
|
return self.rpc.pending_requests
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user