You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ch...@apache.org on 2013/12/11 20:32:19 UTC
git commit: Use a fair ordering policy for reader and writer threads
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 <ch...@apache.org>
Authored: Wed Dec 11 19:15:21 2013 +0000
Committer: Chris Snow <ch...@apache.org>
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();