org.egothor.robot.module

Class T0

java.lang.Object

java.lang.Thread

org.egothor.robot.module.T0

All Implemented Interfaces:

Runnable, T0MBean

public class T0
extends Thread
implements T0MBean

Entry gate to Robot DB. Note: HashURI operates with unescaped and normalized URIs while queues use raw forms of URI parts.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
T0(String base_dir, BlockingArray<Server> resReady, Config config)

Method Summary

Modifier and Type	Method and Description
double	getLinkPushToServerQueueTime()
int	getServersLoaded()
long	getSize()
boolean	isBroken()
long	push(URI uri) Pushes unnormalised URI into Robot's queues or Robot's cache with new links.
void	run()
void	setAddMoreURIs(boolean state)
void	shutdown()
void	switchOff() This module will stop loading more Server-s into memory.

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.egothor.robot.module.T0MBean

getName

Constructor Detail

T0

public T0(String base_dir,
          BlockingArray<Server> resReady,
          Config config)
   throws IOException,
          NoSuchAlgorithmException

Parameters:

base_dir -

resReady -

config -

Throws:

IOException

NoSuchAlgorithmException

Method Detail

getSize

public long getSize()

Specified by:

getSize in interface T0MBean

switchOff

public void switchOff()

This module will stop loading more Server-s into memory.

getServersLoaded

public int getServersLoaded()

Specified by:

getServersLoaded in interface T0MBean

shutdown

public void shutdown()

push

public long push(URI uri)

Pushes unnormalised URI into Robot's queues or Robot's cache with new links.

Specified by:

push in interface T0MBean

Parameters:

uri - new URI to be added

Returns:

0 if the URI is invalid, else the unique ID of the URI in the robot

setAddMoreURIs

public void setAddMoreURIs(boolean state)

Specified by:

setAddMoreURIs in interface T0MBean

getLinkPushToServerQueueTime

public double getLinkPushToServerQueueTime()

Specified by:

getLinkPushToServerQueueTime in interface T0MBean

isBroken

public boolean isBroken()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread