org.egothor.robot.module

Class T5

java.lang.Object

java.lang.Thread

org.egothor.robot.module.T5

All Implemented Interfaces:

Runnable

public final class T5
extends Thread

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
AtomicLong	cnt_dnsfailed
AtomicLong	cnt_finished
AtomicLong	cnt_iplocked
AtomicLong	cnt_ok
AtomicLong	cnt_oknew
AtomicLong	cnt_wwwfailed

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
T5(T0 t0, MultiLock<DNSClient.DataBlock> lockedIPs, BlockingArray<Server> resReady, RequestQueue resolved, BlockingArray<Server> finished, PageRankWriter pgw, int postProcessQueuesSize, String index_dir, long ippause, int dnsretries, int wwwretries, int turnupwheel, Subnet transmitterClient)

Method Summary

Modifier and Type	Method and Description
double	getCompleteTime()
double	getConnectionTime()
int	getDocumentParserLoad()
double	getHTMLParserTime()
double	getHTTPParserTime()
double	getInvertizeTime()
int	getLinksExtractorLoad()
double	getPushLinkTime()
double	getReadTime()
double	getWriteTime()
boolean	isBroken()
void	process(Response r) Process the response (index, save or add linx to the system).
void	run()
void	shutdown(int delay)
void	start()
void	switchOff() This module will send all Servers to T0.hybernate(org.egothor.robot.module.Server) or T0.kick(org.egothor.robot.module.Server) and not to resReady, resolved queues.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

cnt_finished

public AtomicLong cnt_finished

cnt_iplocked

public AtomicLong cnt_iplocked

cnt_ok

public AtomicLong cnt_ok

cnt_oknew

public AtomicLong cnt_oknew

cnt_dnsfailed

public AtomicLong cnt_dnsfailed

cnt_wwwfailed

public AtomicLong cnt_wwwfailed

Constructor Detail

T5

public T5(T0 t0,
          MultiLock<DNSClient.DataBlock> lockedIPs,
          BlockingArray<Server> resReady,
          RequestQueue resolved,
          BlockingArray<Server> finished,
          PageRankWriter pgw,
          int postProcessQueuesSize,
          String index_dir,
          long ippause,
          int dnsretries,
          int wwwretries,
          int turnupwheel,
          Subnet transmitterClient)

Method Detail

getCompleteTime

public double getCompleteTime()

getConnectionTime

public double getConnectionTime()

getWriteTime

public double getWriteTime()

getReadTime

public double getReadTime()

getHTTPParserTime

public double getHTTPParserTime()

getHTMLParserTime

public double getHTMLParserTime()

getInvertizeTime

public double getInvertizeTime()

getDocumentParserLoad

public int getDocumentParserLoad()

getPushLinkTime

public double getPushLinkTime()

getLinksExtractorLoad

public int getLinksExtractorLoad()

switchOff

public void switchOff()

This module will send all Servers to T0.hybernate(org.egothor.robot.module.Server) or T0.kick(org.egothor.robot.module.Server) and not to resReady, resolved queues.

start

public void start()

Overrides:

start in class Thread

isBroken

public boolean isBroken()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

shutdown

public void shutdown(int delay)

process

public void process(Response r)

Process the response (index, save or add linx to the system).