Revise cluster lock invocations to use new API

This commit is contained in:
tengqm
2015-02-02 17:50:10 +08:00
parent 91cf056b34
commit a186e32050
4 changed files with 77 additions and 82 deletions

View File

@@ -175,7 +175,7 @@ class ClusterLock(BaseLock):
self.target_type = 'cluster'
def lock_create(cluster_id, engine_id):
return db_api.cluster_lock_create(cluster_id, engine_id)
return db_api.cluster_lock_acquire(cluster_id, engine_id)
def lock_release(cluster_id, engine_id):
return db_api.cluster_lock_release(cluster_id, engine_id)