|
|
|
@ -113,7 +113,7 @@ public final class SearchEvent {
|
|
|
|
|
boolean remote = (query.domType == QueryParams.SEARCHDOM_GLOBALDHT) || (query.domType == QueryParams.SEARCHDOM_CLUSTERALL);
|
|
|
|
|
if (remote && peers.sizeConnected() == 0) remote = false;
|
|
|
|
|
final long start = System.currentTimeMillis();
|
|
|
|
|
if (remote) {
|
|
|
|
|
if (remote) {
|
|
|
|
|
// initialize a ranking process that is the target for data
|
|
|
|
|
// that is generated concurrently from local and global search threads
|
|
|
|
|
this.rankingProcess = new RankingProcess(this.query, this.order, max_results_preparation);
|
|
|
|
@ -144,8 +144,8 @@ public final class SearchEvent {
|
|
|
|
|
(query.domType == QueryParams.SEARCHDOM_GLOBALDHT) ? null : preselectedPeerHashes,
|
|
|
|
|
burstRobinsonPercent,
|
|
|
|
|
burstMultiwordPercent);
|
|
|
|
|
Log.logFine("SEARCH_EVENT", "STARTING " + this.primarySearchThreads.length + " THREADS TO CATCH EACH " + remote_maxcount + " URLs");
|
|
|
|
|
if (this.primarySearchThreads != null) {
|
|
|
|
|
Log.logFine("SEARCH_EVENT", "STARTING " + this.primarySearchThreads.length + " THREADS TO CATCH EACH " + remote_maxcount + " URLs");
|
|
|
|
|
this.rankingProcess.moreFeeders(this.primarySearchThreads.length);
|
|
|
|
|
EventTracker.update(EventTracker.EClass.SEARCH, new ProfilingGraph.searchEvent(query.id(true), Type.REMOTESEARCH_START, "", this.primarySearchThreads.length, System.currentTimeMillis() - timer), false);
|
|
|
|
|
// finished searching
|
|
|
|
|