release after we notify the user

This commit is contained in:
kimchy 2010-04-08 13:57:00 +03:00
parent a208eb5a50
commit 25433ace48
2 changed files with 2 additions and 2 deletions

View File

@ -171,8 +171,8 @@ public class TransportSearchDfsQueryThenFetchAction extends TransportSearchTypeA
final Map<SearchShardTarget, ExtTIntArrayList> docIdsToLoad = searchPhaseController.docIdsToLoad(sortedShardList);
if (docIdsToLoad.isEmpty()) {
releaseIrrelevantSearchContexts(queryResults, docIdsToLoad);
finishHim();
releaseIrrelevantSearchContexts(queryResults, docIdsToLoad);
}
final AtomicInteger counter = new AtomicInteger(docIdsToLoad.size());

View File

@ -85,8 +85,8 @@ public class TransportSearchQueryThenFetchAction extends TransportSearchTypeActi
final Map<SearchShardTarget, ExtTIntArrayList> docIdsToLoad = searchPhaseController.docIdsToLoad(sortedShardList);
if (docIdsToLoad.isEmpty()) {
releaseIrrelevantSearchContexts(queryResults, docIdsToLoad);
finishHim();
releaseIrrelevantSearchContexts(queryResults, docIdsToLoad);
}
final AtomicInteger counter = new AtomicInteger(docIdsToLoad.size());