You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2016/08/25 13:10:09 UTC
svn commit: r1757680 -
/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java
Author: orudyy
Date: Thu Aug 25 13:10:09 2016
New Revision: 1757680
URL: http://svn.apache.org/viewvc?rev=1757680&view=rev
Log:
QPID-6982: [Java Broker] Cache await attainment timeout evaluation result in order to fix performance degradation
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java?rev=1757680&r1=1757679&r2=1757680&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/model/AbstractConfiguredObject.java Thu Aug 25 13:10:09 2016
@@ -193,6 +193,7 @@ public abstract class AbstractConfigured
private boolean _openFailed;
private volatile State _state = State.UNINITIALIZED;
private volatile Date _lastOpenedTime;
+ private volatile int _awaitAttainmentTimeout;
protected static Map<Class<? extends ConfiguredObject>, ConfiguredObject<?>> parentsMap(ConfiguredObject<?>... parents)
{
@@ -2992,16 +2993,18 @@ public abstract class AbstractConfigured
private int getAwaitAttainmentTimeout()
{
- int awaitAttainmentTimeout;
- try
- {
- awaitAttainmentTimeout = getContextValue(Integer.class, AWAIT_ATTAINMENT_TIMEOUT);
- }
- catch (IllegalArgumentException e)
+ if (_awaitAttainmentTimeout == 0)
{
- awaitAttainmentTimeout = DEFAULT_AWAIT_ATTAINMENT_TIMEOUT;
+ try
+ {
+ _awaitAttainmentTimeout = getContextValue(Integer.class, AWAIT_ATTAINMENT_TIMEOUT);
+ }
+ catch (IllegalArgumentException e)
+ {
+ _awaitAttainmentTimeout = DEFAULT_AWAIT_ATTAINMENT_TIMEOUT;
+ }
}
- return awaitAttainmentTimeout;
+ return _awaitAttainmentTimeout;
}
protected final <C extends ConfiguredObject> C awaitChildClassToAttainState(final Class<C> childClass, final String name)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org