net.yacy.search

Class AutoSearch

java.lang.Object

java.lang.Thread

net.yacy.kelondro.workflow.AbstractThread

net.yacy.kelondro.workflow.AbstractBusyThread

net.yacy.search.AutoSearch

All Implemented Interfaces:

java.lang.Runnable, BusyThread, WorkflowThread

public class AutoSearch
extends AbstractBusyThread

AutoSearch retrieves queries from Bookmarks or a property file (if existing) and loops to a list of connected peers and asks each for results which are added to the local index.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	currentQuery
private java.util.Set<java.lang.String>	currentTargets
int	gotresults
private long	lastInitTime
private java.util.Set<java.lang.String>	querystack
(package private) Switchboard	sb

Fields inherited from class net.yacy.kelondro.workflow.AbstractThread

busytime, memuse, running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AutoSearch(Switchboard xsb)

Method Summary

Methods

Modifier and Type	Method and Description
private boolean	checkBookmarkDB() Check BookmarkDB for existing queries return true if new entry added to query queue.
void	close()
void	freemem() is called when an outOfMemoryCycle is performed this method should try to free some memory, so that the job can be executed
int	getJobCount() Estimate of queries to perform
private void	initPeerList() Get peers to query (peers connected)
boolean	job() Process query queue, select one query and peer to ask next
private void	processSingleTarget(Seed seed) Calls one peer for search results of the current query and adds it to the local index.
private void	saveasPropFile() Save current queries to a (temporary) property file to allow continue after a restart.

Methods inherited from class net.yacy.kelondro.workflow.AbstractBusyThread

getBusyCycles, getBusySleep, getHighCPUCycles, getIdleCycles, getIdleSleep, getOutOfMemoryCycles, getSleepTime, intermission, notifyThread, run, setBusySleep, setIdleSleep, setLoadPreReqisite, setMemPreReqisite, setObeyIntermission, setStartupSleep

Methods inherited from class net.yacy.kelondro.workflow.AbstractThread

announceThreadBlockApply, announceThreadBlockRelease, getBlockTime, getExecTime, getLongDescription, getMemoryUse, getMonitorURL, getShortDescription, jobExceptionHandler, open, setDescription, shutdownInProgress, terminate

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.yacy.kelondro.workflow.WorkflowThread

getBlockTime, getExecTime, getLongDescription, getMemoryUse, getMonitorURL, getShortDescription, isAlive, jobExceptionHandler, open, setDescription, shutdownInProgress, start, terminate

Field Detail

querystack

private java.util.Set<java.lang.String> querystack

currentQuery

public java.lang.String currentQuery

currentTargets

private java.util.Set<java.lang.String> currentTargets

sb

final Switchboard sb

gotresults

public int gotresults

lastInitTime

private long lastInitTime

Constructor Detail

AutoSearch

public AutoSearch(Switchboard xsb)

Method Detail

saveasPropFile

private void saveasPropFile()

Save current queries to a (temporary) property file to allow continue after a restart. Existing file will be overwritten or deleted.

initPeerList

private void initPeerList()

Get peers to query (peers connected)

checkBookmarkDB

private boolean checkBookmarkDB()

Check BookmarkDB for existing queries return true if new entry added to query queue. Store queries in (temporary) property file

Returns:

true if new query from bookmark was added

job

public boolean job()

Process query queue, select one query and peer to ask next

Returns:

true if something processed

processSingleTarget

private void processSingleTarget(Seed seed)

Calls one peer for search results of the current query and adds it to the local index. Depending on peers SolrAvailable flag the a solr query or opensearch/rss query is used.

Parameters:

seed - the peer to ask

getJobCount

public int getJobCount()

Estimate of queries to perform

freemem

public void freemem()

Description copied from interface: BusyThread

is called when an outOfMemoryCycle is performed this method should try to free some memory, so that the job can be executed

close

public void close()

Specified by:

close in interface WorkflowThread

Overrides:

close in class AbstractThread