← Back to branch summary

~libra-core/libra/master

« back to all changes in this revision

Viewing changes to libra/admin_api/device_pool/manage_pool.py

  • Committer: Michael Johnson
  • Date: 2014-07-30 20:12:47 UTC
  • Revision ID: git-v1:a0e8b91e160eba15f35717598b01f9c29a8575a5
LBAAS-583 - VIP assignment can fail without us noticing
LBAAS-621 - Correct libra to send gearman unique messages

Change-Id: I522493e1691de876a4500ca57ddbdb21ca9ad398

Show diffs side-by-side

added added

removed removed

Lines of Context:
libra/admin_api/device_pool/manage_pool.py
14
14
 
15
15
import ipaddress
16
16
import threading
 
17
import uuid
17
18
 
18
19
from datetime import datetime
19
20
from gearman.constants import JOB_UNKNOWN
76
77
                        'action': 'DELETE_DEVICE',
77
78
                        'name': device.name
78
79
                    }
79
 
                    message.append(dict(task='libra_pool_mgm', data=job_data))
 
80
                    unique_uuid = str(uuid.uuid4())
 
81
                    message.append(dict(task='libra_pool_mgm',
 
82
                                        data=job_data,
 
83
                                        unique=unique_uuid))
80
84
 
81
85
                counter = session.query(Counters).\
82
86
                    filter(Counters.name == 'devices_deleted').first()
177
181
        it = 0
178
182
        job_data = {'action': 'BUILD_DEVICE'}
179
183
        while it < count:
180
 
            message.append(dict(task='libra_pool_mgm', data=job_data))
 
184
            unique_uuid = str(uuid.uuid4())
 
185
            message.append(dict(task='libra_pool_mgm',
 
186
                                data=job_data,
 
187
                                unique=unique_uuid))
181
188
            it += 1
182
189
        gear = GearmanWork()
183
190
        gear.send_create_message(message)
187
194
        it = 0
188
195
        job_data = {'action': 'BUILD_IP'}
189
196
        while it < count:
190
 
            message.append(dict(task='libra_pool_mgm', data=job_data))
 
197
            unique_uuid = str(uuid.uuid4())
 
198
            message.append(dict(task='libra_pool_mgm',
 
199
                                data=job_data,
 
200
                                unique=unique_uuid))
191
201
            it += 1
192
202
        gear = GearmanWork()
193
203
        gear.send_vips_message(message)