honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-05 20:48:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

improve javadocs

Browse Source
This commit is contained in:
Michael McCandless 2015-10-06 04:27:52 -04:00 committed by mikemccand
parent a082135538
commit 0aabfe383c
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
core/src/main/java/org/elasticsearch/index/shard/IndexShard.java
View File

@ -1040,6 +1040,7 @@ public class IndexShard extends AbstractIndexShardComponent implements IndexSett
engine.getTranslog().updateBuffer(shardTranslogBufferSize); engine.getTranslog().updateBuffer(shardTranslogBufferSize);
} }
/** Record that this shard is now inactive, and decrease the indexing and translog buffers to tiny values. */
public void markAsInactive() { public void markAsInactive() {
if (active.getAndSet(false)) { if (active.getAndSet(false)) {
updateBufferSize(EngineConfig.INACTIVE_SHARD_INDEXING_BUFFER, TranslogConfig.INACTIVE_SHARD_TRANSLOG_BUFFER); updateBufferSize(EngineConfig.INACTIVE_SHARD_INDEXING_BUFFER, TranslogConfig.INACTIVE_SHARD_TRANSLOG_BUFFER);

11
core/src/main/java/org/elasticsearch/indices/memory/IndexingMemoryController.java
View File

@ -29,12 +29,10 @@ import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.FutureUtils; import org.elasticsearch.common.util.concurrent.FutureUtils;
import org.elasticsearch.index.IndexService; import org.elasticsearch.index.IndexService;
import org.elasticsearch.index.engine.EngineClosedException; import org.elasticsearch.index.engine.EngineClosedException;
import org.elasticsearch.index.engine.EngineConfig;
import org.elasticsearch.index.engine.FlushNotAllowedEngineException; import org.elasticsearch.index.engine.FlushNotAllowedEngineException;
import org.elasticsearch.index.shard.IndexShard; import org.elasticsearch.index.shard.IndexShard;
import org.elasticsearch.index.shard.IndexShardState; import org.elasticsearch.index.shard.IndexShardState;
import org.elasticsearch.index.shard.ShardId; import org.elasticsearch.index.shard.ShardId;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.indices.IndicesService; import org.elasticsearch.indices.IndicesService;
import org.elasticsearch.monitor.jvm.JvmInfo; import org.elasticsearch.monitor.jvm.JvmInfo;
import org.elasticsearch.threadpool.ThreadPool; import org.elasticsearch.threadpool.ThreadPool;
@ -236,6 +234,7 @@ public class IndexingMemoryController extends AbstractLifecycleComponent<Indexin
return null; return null;
} }
/** set new indexing and translog buffers on this shard. this may cause the shard to refresh to free up heap. */
protected void updateShardBuffers(ShardId shardId, ByteSizeValue shardIndexingBufferSize, ByteSizeValue shardTranslogBufferSize) { protected void updateShardBuffers(ShardId shardId, ByteSizeValue shardIndexingBufferSize, ByteSizeValue shardTranslogBufferSize) {
final IndexShard shard = getShard(shardId); final IndexShard shard = getShard(shardId);
if (shard != null) { if (shard != null) {
@ -251,6 +250,8 @@ public class IndexingMemoryController extends AbstractLifecycleComponent<Indexin
} }
} }
/** returns {@code Boolean.TRUE} if no indexing operations have arrived to this shard since the {@code inactiveTimeNS},
* {@code Boolean.FALSE} if they have, and {@code null} if the shard is unknown */
protected boolean isShardIdle(ShardId shardId, long inactiveTimeNS) { protected boolean isShardIdle(ShardId shardId, long inactiveTimeNS) {
final IndexShard shard = getShard(shardId); final IndexShard shard = getShard(shardId);
if (shard == null) { if (shard == null) {
@ -269,7 +270,7 @@ public class IndexingMemoryController extends AbstractLifecycleComponent<Indexin
return indexShard.getActive(); return indexShard.getActive();
} }
/** Check if any shards active status changed, now. */ /** check if any shards active status changed, now. */
public void forceCheck() { public void forceCheck() {
statusChecker.run(); statusChecker.run();
} }
@ -343,7 +344,7 @@ public class IndexingMemoryController extends AbstractLifecycleComponent<Indexin
/** /**
* purge any existing statuses that are no longer updated * purge any existing statuses that are no longer updated
* *
* @return true if any change * @return the changes applied
*/ */
private EnumSet<ShardStatusChangeType> purgeDeletedAndClosedShards() { private EnumSet<ShardStatusChangeType> purgeDeletedAndClosedShards() {
EnumSet<ShardStatusChangeType> changes = EnumSet.noneOf(ShardStatusChangeType.class); EnumSet<ShardStatusChangeType> changes = EnumSet.noneOf(ShardStatusChangeType.class);
@ -397,7 +398,7 @@ public class IndexingMemoryController extends AbstractLifecycleComponent<Indexin
return System.nanoTime(); return System.nanoTime();
} }
// update inactive indexing buffer size /** notify this shard that it is now inactive, so it can drop its indexing buffer to 512 KB */
protected void markShardAsInactive(ShardId shardId) { protected void markShardAsInactive(ShardId shardId) {
String ignoreReason = null; String ignoreReason = null;
final IndexShard shard = getShard(shardId); final IndexShard shard = getShard(shardId);