You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2014/07/25 19:57:01 UTC
[05/11] git commit: Synchonise accesses of attributes in
ServerPoolImpl.stop
Synchonise accesses of attributes in ServerPoolImpl.stop
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/8bd94d12
Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/8bd94d12
Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/8bd94d12
Branch: refs/heads/master
Commit: 8bd94d124177503f63bcadbbc1176ac1fd1eef07
Parents: f1a465c
Author: Sam Corbett <sa...@cloudsoftcorp.com>
Authored: Wed Jul 23 14:36:37 2014 +0100
Committer: Sam Corbett <sa...@cloudsoftcorp.com>
Committed: Wed Jul 23 14:36:37 2014 +0100
----------------------------------------------------------------------
.../main/java/brooklyn/entity/pool/ServerPoolImpl.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/8bd94d12/software/base/src/main/java/brooklyn/entity/pool/ServerPoolImpl.java
----------------------------------------------------------------------
diff --git a/software/base/src/main/java/brooklyn/entity/pool/ServerPoolImpl.java b/software/base/src/main/java/brooklyn/entity/pool/ServerPoolImpl.java
index c0b88cd..7e4f907 100644
--- a/software/base/src/main/java/brooklyn/entity/pool/ServerPoolImpl.java
+++ b/software/base/src/main/java/brooklyn/entity/pool/ServerPoolImpl.java
@@ -135,10 +135,12 @@ public class ServerPoolImpl extends DynamicClusterImpl implements ServerPool {
public void stop() {
super.stop();
deleteLocation();
- setAttribute(AVAILABLE_COUNT, 0);
- setAttribute(CLAIMED_COUNT, 0);
- getAttribute(ENTITY_MACHINE).clear();
- getAttribute(MACHINE_ENTITY).clear();
+ synchronized (mutex) {
+ setAttribute(AVAILABLE_COUNT, 0);
+ setAttribute(CLAIMED_COUNT, 0);
+ getAttribute(ENTITY_MACHINE).clear();
+ getAttribute(MACHINE_ENTITY).clear();
+ }
}
private void addMembershipTrackerPolicy() {