release before we notify the user

This commit is contained in:
kimchy 2010-04-08 13:58:00 +03:00
parent 25433ace48
commit e0058ff80d
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()) {
finishHim();
releaseIrrelevantSearchContexts(queryResults, docIdsToLoad);
finishHim();
}
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()) {
finishHim();
releaseIrrelevantSearchContexts(queryResults, docIdsToLoad);
finishHim();
}
final AtomicInteger counter = new AtomicInteger(docIdsToLoad.size());