net.yacy.peers

Class Transmission.Chunk

java.lang.Object

net.yacy.kelondro.workflow.WorkflowJob

net.yacy.peers.Transmission.Chunk

All Implemented Interfaces:

java.lang.Iterable<ReferenceContainer<WordReference>>

Enclosing class:

Transmission

public class Transmission.Chunk
extends WorkflowJob
implements java.lang.Iterable<ReferenceContainer<WordReference>>

Field Summary

Fields

Modifier and Type	Field and Description
private HandleSet	badReferences
private ReferenceContainerCache<WordReference>	containers
private Seed	dhtTarget a dispatcher entry contains - the primary target, which is a word hash, as marker for the entry - a set of indexContainers in a cache, - the associated URLs in a set to have a cache for the transmission to multiple peers and to ensure that all entries in the indexContainers have a reference in the urls - a set of yacy seeds which will shrink as the containers are transmitted to them
private HandleSet	references

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

poisonPill, status, STATUS_FINISHED, STATUS_INITIATED, STATUS_POISON, STATUS_RUNNING, STATUS_STARTED

Constructor Summary

Constructors

Constructor and Description
Transmission.Chunk(Seed dhtTarget) generate a new dispatcher target.

Method Summary

Methods

Modifier and Type	Method and Description
void	add(ReferenceContainer<WordReference> container) add a container to the Entry cache.
int	containersSize()
Seed	dhtTarget()
java.util.Iterator<ReferenceContainer<WordReference>>	iterator() get all containers from the entry.
void	restore()
boolean	transmit()
private ReferenceContainer<WordReference>	trimContainer(ReferenceContainer<WordReference> container, int max)

Methods inherited from class java.lang.Object

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

Field Detail

dhtTarget

private final Seed dhtTarget

a dispatcher entry contains - the primary target, which is a word hash, as marker for the entry - a set of indexContainers in a cache, - the associated URLs in a set to have a cache for the transmission to multiple peers and to ensure that all entries in the indexContainers have a reference in the urls - a set of yacy seeds which will shrink as the containers are transmitted to them

containers

private final ReferenceContainerCache<WordReference> containers

references

private final HandleSet references

badReferences

private final HandleSet badReferences

Constructor Detail

Transmission.Chunk

public Transmission.Chunk(Seed dhtTarget)

generate a new dispatcher target. such a target is defined with a primary target and a set of target peers that shall receive the entries of the containers the payloadrow defines the structure of container entries

Parameters:

dhtTarget -

Method Detail

trimContainer

private ReferenceContainer<WordReference> trimContainer(ReferenceContainer<WordReference> container,
                                              int max)
                                                 throws SpaceExceededException

Throws:

SpaceExceededException

add

public void add(ReferenceContainer<WordReference> container)
         throws SpaceExceededException

add a container to the Entry cache. all entries in the container are checked and only such are stored which have a reference entry

Parameters:

container -

Throws:

SpaceExceededException

iterator

public java.util.Iterator<ReferenceContainer<WordReference>> iterator()

get all containers from the entry. This method may be used to flush remaining entries if they had been finished transmission without success (not enough peers arrived)

Specified by:

iterator in interface java.lang.Iterable<ReferenceContainer<WordReference>>

containersSize

public int containersSize()

dhtTarget

public Seed dhtTarget()

transmit

public boolean transmit()

restore

public void restore()