Updated Branches: refs/heads/master 42c37dbf0 -> 9c1afd00e
Use a fair ordering policy for reader and writer threads Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/9c1afd00 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/9c1afd00 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/9c1afd00 Branch: refs/heads/master Commit: 9c1afd00eaf7cfa31f212774617b44c98f459f6d Parents: 42c37db Author: Chris Snow <[email protected]> Authored: Wed Dec 11 19:15:21 2013 +0000 Committer: Chris Snow <[email protected]> Committed: Wed Dec 11 19:15:21 2013 +0000 ---------------------------------------------------------------------- .../stratos/messaging/message/receiver/tenant/TenantManager.java | 2 +- .../messaging/message/receiver/topology/TopologyManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9c1afd00/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantManager.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantManager.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantManager.java index 13cf1e8..56598c4 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantManager.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantManager.java @@ -39,7 +39,7 @@ public class TenantManager { private static final Log log = LogFactory.getLog(TenantManager.class); private static volatile TenantManager instance; - private static volatile ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + private static volatile ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true); private static volatile ReentrantReadWriteLock.ReadLock readLock = lock.readLock(); private static volatile ReentrantReadWriteLock.WriteLock writeLock = lock.writeLock(); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9c1afd00/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyManager.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyManager.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyManager.java index faceff5..dafa12f 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyManager.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyManager.java @@ -35,7 +35,7 @@ public class TopologyManager { private static final Log log = LogFactory.getLog(TopologyManager.class); private static volatile Topology topology; - private static volatile ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + private static volatile ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true); private static volatile ReentrantReadWriteLock.ReadLock readLock = lock.readLock(); private static volatile ReentrantReadWriteLock.WriteLock writeLock = lock.writeLock();
