You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2014/02/26 23:25:05 UTC
[12/13] git commit: adding circuit breaker to stop at 10k connections
adding circuit breaker to stop at 10k connections
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/2f3085eb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/2f3085eb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/2f3085eb
Branch: refs/pull/62/merge
Commit: 2f3085eb5b42720e576efc8e77cf744b3ed0ecef
Parents: b2eeae7
Author: Shawn Feldman <sh...@gmail.com>
Authored: Wed Feb 26 15:14:51 2014 -0700
Committer: Shawn Feldman <sh...@gmail.com>
Committed: Wed Feb 26 15:14:51 2014 -0700
----------------------------------------------------------------------
.../usergrid/services/users/activities/ActivitiesService.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2f3085eb/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java b/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
index 0eff887..12807b6 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
@@ -136,10 +136,15 @@ public class ActivitiesService extends GenericCollectionService {
List<EntityRef> refs = new ArrayList<EntityRef>();
ConnectedEntityRef c;
+ int breaker = 10000;
//collect
while (itr.hasNext()) {
c = (ConnectedEntityRef) itr.next();
refs.add(c);
+ //break out when you get too big
+ if( refs.size() > breaker ){
+ break;
+ }
}
//add to collections
if (refs.size() > 0) {