Revision 9cf4a3c0
b/snf-cyclades-app/synnefo/logic/backend_allocator.py | ||
---|---|---|
63 | 63 |
|
64 | 64 |
log.debug("Allocating VM: %r", vm) |
65 | 65 |
|
66 |
# Refresh backends, if needed |
|
67 |
refresh_backends_stats() |
|
68 |
|
|
69 | 66 |
# Get available backends |
70 | 67 |
available_backends = get_available_backends() |
71 | 68 |
|
69 |
# Refresh backends, if needed |
|
70 |
refresh_backends_stats(available_backends) |
|
71 |
|
|
72 | 72 |
if not available_backends: |
73 | 73 |
return None |
74 | 74 |
|
... | ... | |
129 | 129 |
backend.save() |
130 | 130 |
|
131 | 131 |
|
132 |
def refresh_backends_stats(): |
|
132 |
def refresh_backends_stats(backends):
|
|
133 | 133 |
""" Refresh the statistics of the backends. |
134 | 134 |
|
135 | 135 |
Set db backend state to the actual state of the backend, if |
... | ... | |
139 | 139 |
|
140 | 140 |
now = datetime.datetime.now() |
141 | 141 |
delta = datetime.timedelta(minutes=settings.BACKEND_REFRESH_MIN) |
142 |
for b in Backend.objects.filter(drained=False, offline=False):
|
|
142 |
for b in backends:
|
|
143 | 143 |
if now > b.updated + delta: |
144 |
log.debug("Updating resources of backend %r", b) |
|
144 |
log.debug("Updating resources of backend %r. Last Updated %r", |
|
145 |
b, b.updated) |
|
145 | 146 |
update_resources(b) |
Also available in: Unified diff