You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/05/11 06:05:48 UTC
usergrid git commit: USERGRID-507 - Increase hystrix timeout for
WriteUniqueVerify.
Repository: usergrid
Updated Branches:
refs/heads/release-2.1.1 3a9623927 -> f723f36df
USERGRID-507 - Increase hystrix timeout for WriteUniqueVerify.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/f723f36d
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/f723f36d
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/f723f36d
Branch: refs/heads/release-2.1.1
Commit: f723f36dfbdb1ad70171d2d0ddab11b2303cf03e
Parents: 3a96239
Author: Michael Russo <mr...@apigee.com>
Authored: Wed May 11 14:04:54 2016 +0800
Committer: Michael Russo <mr...@apigee.com>
Committed: Wed May 11 14:04:54 2016 +0800
----------------------------------------------------------------------
.../collection/mvcc/stage/write/WriteUniqueVerify.java | 13 +++++++++----
1 file changed, 9 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/f723f36d/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/write/WriteUniqueVerify.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/write/WriteUniqueVerify.java b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/write/WriteUniqueVerify.java
index d05f838..2c47bdb 100644
--- a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/write/WriteUniqueVerify.java
+++ b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/write/WriteUniqueVerify.java
@@ -23,6 +23,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import com.netflix.hystrix.HystrixCommandProperties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -68,6 +69,8 @@ public class WriteUniqueVerify implements Action1<CollectionIoEvent<MvccEntity>>
public static int uniqueVerifyPoolSize = 100;
+ private static int uniqueVerifyTimeoutMillis= 5000;
+
protected final SerializationFig serializationFig;
protected final Keyspace keyspace;
@@ -221,8 +224,10 @@ public class WriteUniqueVerify implements Action1<CollectionIoEvent<MvccEntity>>
/**
* Command group used for realtime user commands
*/
- public static final HystrixCommand.Setter
- REPLAY_GROUP = HystrixCommand.Setter.withGroupKey(
- HystrixCommandGroupKey.Factory.asKey( "uniqueVerify" ) ).andThreadPoolPropertiesDefaults(
- HystrixThreadPoolProperties.Setter().withCoreSize( uniqueVerifyPoolSize ) );
+ private static final HystrixCommand.Setter
+ REPLAY_GROUP = HystrixCommand.Setter.withGroupKey( HystrixCommandGroupKey.Factory.asKey( "uniqueVerify" ) )
+ .andThreadPoolPropertiesDefaults(
+ HystrixThreadPoolProperties.Setter().withCoreSize( uniqueVerifyPoolSize ) )
+ .andCommandPropertiesDefaults(
+ HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(uniqueVerifyTimeoutMillis));
}