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