public class RemoteSearch
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
private Blacklist |
blacklist |
private Classification.ContentDomain |
contentdom |
private int |
count |
private SearchEvent |
event |
private java.lang.String |
excludehashes |
private java.lang.String |
language |
static ConcurrentLog |
log |
private int |
maxDistance |
private int |
partitions |
private SecondarySearchSuperviser |
secondarySearchSuperviser |
private Seed |
targetPeer |
private long |
time |
private int |
urls |
private java.lang.String |
wordhashes |
private static java.lang.ThreadGroup |
ysThreadGroup |
Constructor and Description |
---|
RemoteSearch(SearchEvent event,
java.lang.String wordhashes,
java.lang.String excludehashes,
java.lang.String language,
Classification.ContentDomain contentdom,
int count,
long time,
int maxDistance,
int partitions,
Seed targetPeer,
SecondarySearchSuperviser secondarySearchSuperviser,
Blacklist blacklist) |
Modifier and Type | Method and Description |
---|---|
static int |
collectedLinks(RemoteSearch[] searchThreads) |
static void |
interruptAlive(RemoteSearch[] searchThreads) |
static void |
primaryRemoteSearches(SearchEvent event,
int start,
int count,
long time,
Blacklist blacklist,
java.util.SortedSet<byte[]> clusterselection) |
static int |
remainingWaiting(RemoteSearch[] searchThreads) |
void |
run() |
static java.lang.Thread |
secondaryRemoteSearch(SearchEvent event,
java.util.Set<java.lang.String> wordhashes,
java.lang.String urlhashes,
long time,
java.lang.String targethash,
Blacklist blacklist) |
static java.lang.String |
set2string(HandleSet hashes) |
static java.lang.Thread |
solrRemoteSearch(SearchEvent event,
SolrQuery solrQuery,
int start,
int count,
Seed targetPeer,
int partitions,
Blacklist blacklist) |
Seed |
target() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
private static final java.lang.ThreadGroup ysThreadGroup
public static final ConcurrentLog log
private final SearchEvent event
private final java.lang.String wordhashes
private final java.lang.String excludehashes
private final Classification.ContentDomain contentdom
private final int partitions
private final SecondarySearchSuperviser secondarySearchSuperviser
private final Blacklist blacklist
private final Seed targetPeer
private int urls
private final int count
private final int maxDistance
private final long time
private final java.lang.String language
public RemoteSearch(SearchEvent event, java.lang.String wordhashes, java.lang.String excludehashes, java.lang.String language, Classification.ContentDomain contentdom, int count, long time, int maxDistance, int partitions, Seed targetPeer, SecondarySearchSuperviser secondarySearchSuperviser, Blacklist blacklist)
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public static java.lang.String set2string(HandleSet hashes)
public Seed target()
public static void primaryRemoteSearches(SearchEvent event, int start, int count, long time, Blacklist blacklist, java.util.SortedSet<byte[]> clusterselection)
public static java.lang.Thread secondaryRemoteSearch(SearchEvent event, java.util.Set<java.lang.String> wordhashes, java.lang.String urlhashes, long time, java.lang.String targethash, Blacklist blacklist)
public static java.lang.Thread solrRemoteSearch(SearchEvent event, SolrQuery solrQuery, int start, int count, Seed targetPeer, int partitions, Blacklist blacklist)
public static int remainingWaiting(RemoteSearch[] searchThreads)
public static int collectedLinks(RemoteSearch[] searchThreads)
public static void interruptAlive(RemoteSearch[] searchThreads)