net.yacy.peers

Class SeedDB

java.lang.Object

net.yacy.peers.SeedDB

All Implemented Interfaces:

AlternativeDomainNames

public final class SeedDB
extends java.lang.Object
implements AlternativeDomainNames

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SeedDB.seedEnum

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DBFILE_OWN_SEED public static final String DBFILE_OWN_SEED = "mySeed.txt"
private static int	dhtActivityMagic
static java.lang.String[]	doubleaccFields
protected java.lang.String	lastSeedUpload_myIP
protected int	lastSeedUpload_seedDBSize
long	lastSeedUpload_timeStamp
static java.lang.String[]	longaccFields
private java.io.File	myOwnSeedFile
private Seed	mySeed
private int	netRedundancy
NewsPool	newsPool
PeerActions	peerActions
Distribution	scheme
private MapDataMining	seedActiveDB
private java.io.File	seedActiveDBFile
private MapDataMining	seedPassiveDB
private java.io.File	seedPassiveDBFile
private MapDataMining	seedPotentialDB
private java.io.File	seedPotentialDBFile
static java.lang.String[]	sortFields

Constructor Summary

Constructors

Constructor and Description
SeedDB(java.io.File networkRoot, java.lang.String seedActiveDBFileName, java.lang.String seedPassiveDBFileName, java.lang.String seedPotentialDBFileName, java.io.File myOwnSeedFile, int redundancy, int partitionExponent, boolean useTailCache, boolean exceed134217727)

Method Summary

Methods

Modifier and Type	Method and Description
void	addConnected(Seed seed)
protected void	addDisconnected(Seed seed)
protected void	addPotential(Seed seed)
Seed	anySeedVersion(double minVersion)
private static java.lang.String	checkCache(java.util.ArrayList<java.lang.String> uv, java.util.Iterator<java.lang.String> check)
void	close()
java.util.TreeSet<byte[]>	clusterHashes(java.lang.String clusterdefinition)
long	countActivePPM()
float	countActiveQPM()
long	countActiveRWI()
long	countActiveURL()
long	countPassiveRWI()
long	countPassiveURL()
long	countPotentialRWI()
long	countPotentialURL()
private static java.util.Iterator<java.lang.String>	downloadSeedFile(DigestURL seedURL)
private Seed	get(byte[] hash, MapDataMining database)
Seed	get(java.lang.String hash)
private Seed	get(java.lang.String hash, MapDataMining database)
Seed	getConnected(byte[] hash)
Seed	getConnected(java.lang.String hash)
Seed	getDisconnected(byte[] hash)
Seed	getDisconnected(java.lang.String hash)
Seed	getPotential(byte[] hash)
Seed	getPotential(java.lang.String hash)
java.util.ArrayList<Seed>	getSeedlist(int maxcount, boolean addMySeed, boolean nodeonly, float minversion)
boolean	hasConnected(byte[] hash)
boolean	hasDisconnected(byte[] hash)
boolean	hasPotential(byte[] hash)
private void	initMySeed()
Seed	lookupByIP(java.net.InetAddress peerIP, int port, boolean lookupConnected, boolean lookupDisconnected, boolean lookupPotential)
Seed	lookupByIPs(java.util.Set<java.lang.String> peerIPs, int port, boolean lookupConnected, boolean lookupDisconnected, boolean lookupPotential)
Seed	lookupByName(java.lang.String peerName)
java.lang.String	myAlternativeAddress() while other servers may have alternative addresses, this server may also have an alternative address
java.lang.String	myID() return an unique ID of this server
java.lang.String	myIP() Deprecated.
java.util.Set<java.lang.String>	myIPs() return a set of IPs of this server
java.lang.String	myName() return a name of this server.
int	myPort() return the port of my server address
Seed	mySeed()
boolean	mySeedIsDefined()
boolean	noDHTActivity()
private static MapDataMining	openSeedTable(java.io.File seedDBFile)
int	redundancy()
void	relocate(java.io.File newNetworkRoot, int redundancy, int partitionExponent, boolean useTailCache, boolean exceed134217727)
void	removeDisconnected(java.lang.String peerHash)
void	removeMySeed()
void	removePotential(java.lang.String peerHash)
void	resetActiveTable()
private void	resetPassiveTable()
private void	resetPotentialTable()
private MapDataMining	resetSeedTable(MapDataMining seedDB, java.io.File seedDBFile)
java.lang.String	resolve(java.lang.String host) resolve a yacy address
void	saveMySeed()
java.util.Iterator<Seed>	seedsConnected(boolean up, boolean rot, byte[] firstHash, double minVersion)
java.util.Iterator<Seed>	seedsDisconnected(boolean up, boolean rot, byte[] firstHash, double minVersion)
java.util.Iterator<Seed>	seedsSortedConnected(boolean up, java.lang.String field)
java.util.Iterator<Seed>	seedsSortedDisconnected(boolean up, java.lang.String field)
java.util.Iterator<Seed>	seedsSortedPotential(boolean up, java.lang.String field)
void	setMyName(java.lang.String name)
int	sizeActiveSince(long limitMinutes) count the number of peers that had been seen within the given time limit
int	sizeConnected()
int	sizeDisconnected()
int	sizePotential()
private java.util.ArrayList<java.lang.String>	storeSeedList(java.io.File seedFile, boolean addMySeed)
void	updateConnected(Seed seed)
void	updateDisconnected(Seed seed)
void	updatePotential(Seed seed)
protected java.lang.String	uploadSeedList(yacySeedUploader uploader, serverSwitch sb, SeedDB seedDB, DigestURL seedURL)

Methods inherited from class java.lang.Object

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

Field Detail

dhtActivityMagic

private static final int dhtActivityMagic

See Also:

Constant Field Values

DBFILE_OWN_SEED

public static final java.lang.String DBFILE_OWN_SEED

public static final String DBFILE_OWN_SEED = "mySeed.txt"

Name of the file containing the database holding this peer's seed

See Also:

Constant Field Values

sortFields

public static final java.lang.String[] sortFields

longaccFields

public static final java.lang.String[] longaccFields

doubleaccFields

public static final java.lang.String[] doubleaccFields

seedActiveDBFile

private java.io.File seedActiveDBFile

seedPassiveDBFile

private java.io.File seedPassiveDBFile

seedPotentialDBFile

private java.io.File seedPotentialDBFile

myOwnSeedFile

private java.io.File myOwnSeedFile

seedActiveDB

private MapDataMining seedActiveDB

seedPassiveDB

private MapDataMining seedPassiveDB

seedPotentialDB

private MapDataMining seedPotentialDB

lastSeedUpload_seedDBSize

protected int lastSeedUpload_seedDBSize

lastSeedUpload_timeStamp

public long lastSeedUpload_timeStamp

lastSeedUpload_myIP

protected java.lang.String lastSeedUpload_myIP

peerActions

public PeerActions peerActions

newsPool

public NewsPool newsPool

netRedundancy

private int netRedundancy

scheme

public Distribution scheme

mySeed

private Seed mySeed

Constructor Detail

SeedDB

public SeedDB(java.io.File networkRoot,
      java.lang.String seedActiveDBFileName,
      java.lang.String seedPassiveDBFileName,
      java.lang.String seedPotentialDBFileName,
      java.io.File myOwnSeedFile,
      int redundancy,
      int partitionExponent,
      boolean useTailCache,
      boolean exceed134217727)

Method Detail

relocate

public void relocate(java.io.File newNetworkRoot,
            int redundancy,
            int partitionExponent,
            boolean useTailCache,
            boolean exceed134217727)

initMySeed

private void initMySeed()

redundancy

public int redundancy()

mySeedIsDefined

public boolean mySeedIsDefined()

mySeed

public Seed mySeed()

setMyName

public void setMyName(java.lang.String name)

myAlternativeAddress

public java.lang.String myAlternativeAddress()

Description copied from interface: AlternativeDomainNames

while other servers may have alternative addresses, this server may also have an alternative address

Specified by:

myAlternativeAddress in interface AlternativeDomainNames

Returns:

the alternative address of this server which other servers may can resolve

myIP

@Deprecated
public java.lang.String myIP()

Deprecated.

myIPs

public java.util.Set<java.lang.String> myIPs()

Description copied from interface: AlternativeDomainNames

return a set of IPs of this server

Specified by:

myIPs in interface AlternativeDomainNames

Returns:

IP as set of strings of this server

myPort

public int myPort()

Description copied from interface: AlternativeDomainNames

return the port of my server address

Specified by:

myPort in interface AlternativeDomainNames

Returns:

port number of this server

myName

public java.lang.String myName()

Description copied from interface: AlternativeDomainNames

return a name of this server. this may be any string and there is no need that it must be unique

Specified by:

myName in interface AlternativeDomainNames

Returns:

myID

public java.lang.String myID()

Description copied from interface: AlternativeDomainNames

return an unique ID of this server

Specified by:

myID in interface AlternativeDomainNames

Returns:

removeMySeed

public void removeMySeed()

saveMySeed

public void saveMySeed()

noDHTActivity

public boolean noDHTActivity()

openSeedTable

private static MapDataMining openSeedTable(java.io.File seedDBFile)

resetSeedTable

private MapDataMining resetSeedTable(MapDataMining seedDB,
                           java.io.File seedDBFile)

resetActiveTable

public void resetActiveTable()

resetPassiveTable

private void resetPassiveTable()

resetPotentialTable

private void resetPotentialTable()

close

public void close()

seedsSortedConnected

public java.util.Iterator<Seed> seedsSortedConnected(boolean up,
                                            java.lang.String field)

seedsSortedDisconnected

public java.util.Iterator<Seed> seedsSortedDisconnected(boolean up,
                                               java.lang.String field)

seedsSortedPotential

public java.util.Iterator<Seed> seedsSortedPotential(boolean up,
                                            java.lang.String field)

clusterHashes

public java.util.TreeSet<byte[]> clusterHashes(java.lang.String clusterdefinition)

seedsConnected

public java.util.Iterator<Seed> seedsConnected(boolean up,
                                      boolean rot,
                                      byte[] firstHash,
                                      double minVersion)

seedsDisconnected

public java.util.Iterator<Seed> seedsDisconnected(boolean up,
                                         boolean rot,
                                         byte[] firstHash,
                                         double minVersion)

anySeedVersion

public Seed anySeedVersion(double minVersion)

sizeActiveSince

public int sizeActiveSince(long limitMinutes)

count the number of peers that had been seen within the given time limit

Parameters:

limitMinutes - the time limit in minutes. 1440 minutes is a day

Returns:

the number of peers seen in the given time

sizeConnected

public int sizeConnected()

sizeDisconnected

public int sizeDisconnected()

sizePotential

public int sizePotential()

countActiveURL

public long countActiveURL()

countActiveRWI

public long countActiveRWI()

countActivePPM

public long countActivePPM()

countActiveQPM

public float countActiveQPM()

countPassiveURL

public long countPassiveURL()

countPassiveRWI

public long countPassiveRWI()

countPotentialURL

public long countPotentialURL()

countPotentialRWI

public long countPotentialRWI()

addConnected

public void addConnected(Seed seed)

addDisconnected

protected void addDisconnected(Seed seed)

addPotential

protected void addPotential(Seed seed)

removeDisconnected

public void removeDisconnected(java.lang.String peerHash)

removePotential

public void removePotential(java.lang.String peerHash)

hasConnected

public boolean hasConnected(byte[] hash)

hasDisconnected

public boolean hasDisconnected(byte[] hash)

hasPotential

public boolean hasPotential(byte[] hash)

get

private Seed get(java.lang.String hash,
       MapDataMining database)

get

private Seed get(byte[] hash,
       MapDataMining database)

getConnected

public Seed getConnected(java.lang.String hash)

getConnected

public Seed getConnected(byte[] hash)

getDisconnected

public Seed getDisconnected(java.lang.String hash)

getDisconnected

public Seed getDisconnected(byte[] hash)

getPotential

public Seed getPotential(java.lang.String hash)

getPotential

public Seed getPotential(byte[] hash)

get

public Seed get(java.lang.String hash)

updateConnected

public void updateConnected(Seed seed)

updateDisconnected

public void updateDisconnected(Seed seed)

updatePotential

public void updatePotential(Seed seed)

lookupByName

public Seed lookupByName(java.lang.String peerName)

lookupByIPs

public Seed lookupByIPs(java.util.Set<java.lang.String> peerIPs,
               int port,
               boolean lookupConnected,
               boolean lookupDisconnected,
               boolean lookupPotential)

lookupByIP

public Seed lookupByIP(java.net.InetAddress peerIP,
              int port,
              boolean lookupConnected,
              boolean lookupDisconnected,
              boolean lookupPotential)

storeSeedList

private java.util.ArrayList<java.lang.String> storeSeedList(java.io.File seedFile,
                                                  boolean addMySeed)
                                                     throws java.io.IOException

Throws:

java.io.IOException

getSeedlist

public java.util.ArrayList<Seed> getSeedlist(int maxcount,
                                    boolean addMySeed,
                                    boolean nodeonly,
                                    float minversion)

uploadSeedList

protected java.lang.String uploadSeedList(yacySeedUploader uploader,
                              serverSwitch sb,
                              SeedDB seedDB,
                              DigestURL seedURL)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

downloadSeedFile

private static java.util.Iterator<java.lang.String> downloadSeedFile(DigestURL seedURL)
                                                              throws java.io.IOException

Throws:

java.io.IOException

checkCache

private static java.lang.String checkCache(java.util.ArrayList<java.lang.String> uv,
                          java.util.Iterator<java.lang.String> check)

resolve

public java.lang.String resolve(java.lang.String host)

resolve a yacy address

Specified by:

resolve in interface AlternativeDomainNames

Returns:

an alternative name