one more SolrIndexSearcher bugfix

pull/1/head
Michael Peter Christen 11 years ago
parent 78c01b3eff
commit 046f5a03cb

@ -425,13 +425,12 @@ public class EmbeddedSolrConnector extends SolrServerConnector implements SolrCo
public void run() { public void run() {
int o = offset, responseCount = 0; int o = offset, responseCount = 0;
DocListSearcher docListSearcher = null; DocListSearcher docListSearcher = null;
SolrIndexSearcher searcher = null;
while (System.currentTimeMillis() < endtime) { while (System.currentTimeMillis() < endtime) {
try { try {
responseCount = 0; responseCount = 0;
docListSearcher = new DocListSearcher(querystring, o, pagesize, CollectionSchema.id.getSolrFieldName()); docListSearcher = new DocListSearcher(querystring, o, pagesize, CollectionSchema.id.getSolrFieldName());
responseCount = docListSearcher.response.size(); responseCount = docListSearcher.response.size();
searcher = docListSearcher.request.getSearcher(); SolrIndexSearcher searcher = docListSearcher.request.getSearcher();
DocIterator iterator = docListSearcher.response.iterator(); DocIterator iterator = docListSearcher.response.iterator();
for (int i = 0; i < responseCount; i++) { for (int i = 0; i < responseCount; i++) {
Document doc = searcher.doc(iterator.nextDoc(), SOLR_ID_FIELDS); Document doc = searcher.doc(iterator.nextDoc(), SOLR_ID_FIELDS);
@ -441,7 +440,6 @@ public class EmbeddedSolrConnector extends SolrServerConnector implements SolrCo
break; break;
} catch (IOException e) { } catch (IOException e) {
} finally { } finally {
if (searcher != null) try {searcher.close();} catch (IOException e) {}
if (docListSearcher != null) docListSearcher.close(); if (docListSearcher != null) docListSearcher.close();
} }
if (responseCount < pagesize) break; if (responseCount < pagesize) break;

Loading…
Cancel
Save