|
|
@ -263,9 +263,10 @@ public class RemoteSearch extends Thread {
|
|
|
|
int tmpoffset = 0;
|
|
|
|
int tmpoffset = 0;
|
|
|
|
int tmpcount = 10;
|
|
|
|
int tmpcount = 10;
|
|
|
|
while (tmpoffset + tmpcount <= count && tmpcount > 0) {
|
|
|
|
while (tmpoffset + tmpcount <= count && tmpcount > 0) {
|
|
|
|
|
|
|
|
int urls = 0;
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
event.rankingProcess.oneFeederStarted();
|
|
|
|
event.rankingProcess.oneFeederStarted();
|
|
|
|
int urls = Protocol.solrQuery(
|
|
|
|
urls = Protocol.solrQuery(
|
|
|
|
event,
|
|
|
|
event,
|
|
|
|
tmpoffset,
|
|
|
|
tmpoffset,
|
|
|
|
tmpcount,
|
|
|
|
tmpcount,
|
|
|
@ -286,6 +287,7 @@ public class RemoteSearch extends Thread {
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
event.rankingProcess.oneFeederTerminated();
|
|
|
|
event.rankingProcess.oneFeederTerminated();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (urls < tmpcount) break; // there won't be more
|
|
|
|
tmpoffset += tmpcount;
|
|
|
|
tmpoffset += tmpcount;
|
|
|
|
tmpcount = count - tmpoffset; // increase the tmpcount to get to all results in less time
|
|
|
|
tmpcount = count - tmpoffset; // increase the tmpcount to get to all results in less time
|
|
|
|
}
|
|
|
|
}
|
|
|
|