Adds more logging
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/a33f616b Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/a33f616b Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/a33f616b Branch: refs/heads/master Commit: a33f616beed86f475999a5904520776494891968 Parents: 06c9c10 Author: Todd Nine <[email protected]> Authored: Tue Nov 17 11:17:07 2015 -0700 Committer: Todd Nine <[email protected]> Committed: Tue Nov 17 11:17:07 2015 -0700 ---------------------------------------------------------------------- .../impl/shard/impl/NodeShardAllocationImpl.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/a33f616b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java index 0cc12b6..d52f807 100644 --- a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java +++ b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java @@ -138,11 +138,13 @@ public class NodeShardAllocationImpl implements NodeShardAllocation { * Nothing to do, it's been created very recently, we don't create a new one */ if ( shardEntryGroup.isCompactionPending() ) { + LOG.trace( "Shard entry group {} is compacting, not auditing", shardEntryGroup ); return false; } //we can't allocate, we have more than 1 write shard currently. We need to compact first if ( shardEntryGroup.entrySize() != 1 ) { + LOG.trace( "Shard entry group {} does not have 1 entry, not allocating", shardEntryGroup ); return false; } @@ -151,9 +153,12 @@ public class NodeShardAllocationImpl implements NodeShardAllocation { * Check the min shard in our system */ final Shard shard = shardEntryGroup.getMinShard(); + final long minTime = getMinTime(); - if ( shard.getCreatedTime() >= getMinTime() ) { + + if ( shard.getCreatedTime() >= minTime ) { + LOG.trace( "Shard entry group {} and shard {} is before the minimum created time of {}. Not allocating.does not have 1 entry, not allocating", shardEntryGroup, shard, minTime ); return false; } @@ -253,7 +258,7 @@ public class NodeShardAllocationImpl implements NodeShardAllocation { @Override public long getMinTime() { - final long minimumAllowed = 2 * graphFig.getShardCacheTimeout(); + final long minimumAllowed = ( long ) (2.5 * graphFig.getShardCacheTimeout()); final long minDelta = graphFig.getShardMinDelta();
