File tree Expand file tree Collapse file tree 1 file changed +10
-9
lines changed
server/src/main/java/org/elasticsearch/search Expand file tree Collapse file tree 1 file changed +10
-9
lines changed Original file line number Diff line number Diff line change @@ -372,7 +372,8 @@ public class SearchService extends AbstractLifecycleComponent implements IndexEv
372372 private final String sessionId ;
373373
374374 private final Tracer tracer ;
375- private Map <ShardId , Set <Supplier <ReaderContext >>> relocatingContexts = ConcurrentCollections .newConcurrentMapWithAggressiveConcurrency ();
375+ private Map <ShardId , Set <Supplier <ReaderContext >>> relocatingContexts = ConcurrentCollections
376+ .newConcurrentMapWithAggressiveConcurrency ();
376377
377378 public SearchService (
378379 ClusterService clusterService ,
@@ -1985,14 +1986,14 @@ protected void doRun() {
19851986 }
19861987 }
19871988 // TODO clean up pending relocating contexts. How long to wait for a relocation to complete?
1988- // for (Set<Supplier<ReaderContext>> contexts : relocatingContexts.values()) {
1989- // for (Supplier<ReaderContext> context : contexts) {
1990- // if (context.isExpired()) {
1991- // logger.debug("freeing relocating search context [{}]", context.id());
1992- // freeReaderContext(context.id());
1993- // }
1994- // }
1995- // }<
1989+ // for (Set<Supplier<ReaderContext>> contexts : relocatingContexts.values()) {
1990+ // for (Supplier<ReaderContext> context : contexts) {
1991+ // if (context.isExpired()) {
1992+ // logger.debug("freeing relocating search context [{}]", context.id());
1993+ // freeReaderContext(context.id());
1994+ // }
1995+ // }
1996+ // }<
19961997 }
19971998
19981999 @ Override
You can’t perform that action at this time.
0 commit comments