Absorb core ShardsIndicesStatusChecker logic into body of run
This commit is contained in:
parent
5341404f01
commit
56328160c9
|
@ -241,10 +241,6 @@ public class IndexingMemoryController extends AbstractLifecycleComponent<Indexin
|
||||||
class ShardsIndicesStatusChecker implements Runnable {
|
class ShardsIndicesStatusChecker implements Runnable {
|
||||||
@Override
|
@Override
|
||||||
public synchronized void run() {
|
public synchronized void run() {
|
||||||
calcAndSetShardBuffers();
|
|
||||||
}
|
|
||||||
|
|
||||||
private void calcAndSetShardBuffers() {
|
|
||||||
List<IndexShard> availableShards = availableShards();
|
List<IndexShard> availableShards = availableShards();
|
||||||
List<IndexShard> activeShards = new ArrayList<>();
|
List<IndexShard> activeShards = new ArrayList<>();
|
||||||
for (IndexShard shard : availableShards) {
|
for (IndexShard shard : availableShards) {
|
||||||
|
|
Loading…
Reference in New Issue