A B C D E F G H I K L M N O P Q R S T U V W X Z

A

acceptFirstClassOnly() - Method in class net.tomp2p.peers.DefaultMapAcceptHandler

acceptPeer(boolean, PeerAddress) - Method in class net.tomp2p.peers.DefaultMapAcceptHandler

acceptPeer(boolean, PeerAddress) - Method in interface net.tomp2p.peers.MapAcceptHandler

acquire(Semaphore, int) - Method in class net.tomp2p.connection.DefaultReservation

acquire(Semaphore, int) - Method in interface net.tomp2p.connection.Reservation

Action - Class in net.tomp2p.upnp

An object to represent a service action proposed by an UPNP service

ActionMessage - Class in net.tomp2p.upnp

Message object for an UPNP action, simply call setInputParameter() to add the required action message params and then service() to receive the ActionResponse built with the parsed UPNP device SOAP xml response.

ActionMessage(Service, Action) - Constructor for class net.tomp2p.upnp.ActionMessage

Protected constuctor so that only messages factories can build it

ActionResponse - Class in net.tomp2p.upnp

An action response container Object

ActionResponse() - Constructor for class net.tomp2p.upnp.ActionResponse

activePeers(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

add(Bindings) - Method in class net.tomp2p.connection.Bindings

Adds the results from an other binding.

add(K) - Method in class net.tomp2p.futures.FutureLateJoin

Add a future when ready.

add(K) - Method in class net.tomp2p.futures.FutureLaterJoin

Add a future when ready.

add(PeerAddress) - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

add(Number160, Number160, Collection<Data>, RoutingConfiguration, RequestP2PConfiguration, boolean, boolean, boolean, boolean, FutureCreate<FutureDHT>, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedHashTable

add(Number160) - Method in class net.tomp2p.p2p.Peer

add(E) - Method in class net.tomp2p.rpc.CountingBloomFilter

add(E) - Method in class net.tomp2p.rpc.SimpleBloomFilter

add(PeerAddress, Number160, Number160, Collection<Data>, boolean, boolean, boolean, ChannelCreator, boolean, SenderCacheStrategy) - Method in class net.tomp2p.rpc.StorageRPC

Adds data on a remote peer.

addActive(Number160, Number160, PeerAddress, byte[], int, int) - Method in class net.tomp2p.storage.TrackerStorage

addAddress(InetAddress) - Method in class net.tomp2p.connection.Bindings

Adds an address that we want to listen to.

addAddressFilter(InetAddress) - Method in class net.tomp2p.peers.PeerMap

addAll(Collection<? extends E>) - Method in class net.tomp2p.rpc.CountingBloomFilter

addAll(Collection<? extends E>) - Method in class net.tomp2p.rpc.SimpleBloomFilter

AddBuilder - Class in net.tomp2p.p2p.builder

AddBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.AddBuilder

addCancellation(Cancellable) - Method in interface net.tomp2p.futures.BaseFuture

Adds a cancel listener to this future, which is called when cancel is executed.

addCancellation(Cancellable) - Method in class net.tomp2p.futures.BaseFutureImpl

addCleanup(Cancellable) - Method in interface net.tomp2p.futures.FutureCleanup

Call to add cleanup classes for the future e.g.

addCleanup(Cancellable) - Method in class net.tomp2p.futures.FutureDHT

addCleanup(Cancellable) - Method in class net.tomp2p.futures.FutureTracker

addConnectionQueue(FutureChannel, Semaphore, Runnable) - Method in class net.tomp2p.connection.Scheduler

addInterface(String) - Method in class net.tomp2p.connection.Bindings

Adds an interface that will be searched for.

addListener(BaseFutureListener<? extends BaseFuture>) - Method in interface net.tomp2p.futures.BaseFuture

Adds a listener which is notified when the state of this future changes.

addListener(BaseFutureListener<? extends BaseFuture>, boolean) - Method in interface net.tomp2p.futures.BaseFuture

Adds a listener which is notified when the state of this future changes.

addListener(BaseFutureListener<? extends BaseFuture>) - Method in class net.tomp2p.futures.BaseFutureImpl

addListener(BaseFutureListener<? extends BaseFuture>, boolean) - Method in class net.tomp2p.futures.BaseFutureImpl

addListener(TaskResultListener) - Method in class net.tomp2p.task.TaskManager

addMarkerForSignature() - Method in class net.tomp2p.message.ProtocolChunkedInput

addPeerListener(PeerListener) - Method in class net.tomp2p.p2p.Peer

Adds a listener to peer events.

addPeerMapChangeListener(PeerMapChangeListener) - Method in class net.tomp2p.peers.PeerMap

addPeerOfflineListener(PeerStatusListener) - Method in class net.tomp2p.peers.PeerMap

addPortMapping(String, String, String, int, int) - Method in class net.tomp2p.upnp.InternetGatewayDevice

addPortMapping(String, String, String, int, String, int, int) - Method in class net.tomp2p.upnp.InternetGatewayDevice

Configures a nat entry on the UPNP device.

addQueue(FutureRunnable) - Method in class net.tomp2p.connection.Scheduler

addReleaseListener(BaseFuture, ConnectionReservation, ChannelCreator, int) - Static method in class net.tomp2p.utils.Utils

addReleaseListenerAll(BaseFuture, ConnectionReservation, ChannelCreator) - Static method in class net.tomp2p.utils.Utils

addRequests(FutureResponse) - Method in class net.tomp2p.futures.FutureDHT

Adds all requests that have been created for the DHT operations.

addRequests(FutureAsyncTask) - Method in class net.tomp2p.futures.FutureTask

Adds all requests that have been created for the DHT operations.

addResponsibilityListener(ResponsibilityListener) - Method in class net.tomp2p.replication.Replication

addTimeout(Number160, Number160, Number160, long) - Method in interface net.tomp2p.storage.Storage

addTimeout(Number160, Number160, Number160, long) - Method in class net.tomp2p.storage.StorageDisk

addTimeout(Number160, Number160, Number160, long) - Method in class net.tomp2p.storage.StorageMemory

addToTracker(Number160, Number160, byte[], RoutingConfiguration, TrackerConfiguration, boolean, FutureCreate<BaseFuture>, Set<Number160>, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedTracker

addToTracker(PeerAddress, Number160, Number160, byte[], boolean, boolean, Set<Number160>, ChannelCreator, boolean, boolean) - Method in class net.tomp2p.rpc.TrackerRPC

addToTracker(PeerAddress, Number160, Number160, byte[], int, int, boolean, boolean, Set<Number160>, ChannelCreator, boolean, boolean) - Method in class net.tomp2p.rpc.TrackerRPC

addTracker(Number160) - Method in class net.tomp2p.p2p.Peer

AddTrackerBuilder - Class in net.tomp2p.p2p.builder

AddTrackerBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.AddTrackerBuilder

addTrackerMaintenance(PeerAddress, PeerAddress, Number160, Number160, TrackerStorage) - Method in class net.tomp2p.p2p.Maintenance

adjustConfiguration(RequestP2PConfiguration, SortedMap<PeerAddress, DigestInfo>) - Static method in class net.tomp2p.p2p.DistributedHashTable

Adjusts the number of minimum requests in the P2P configuration.

adjustMinimumResult(int) - Method in class net.tomp2p.p2p.RequestP2PConfiguration

ALL_DEVICES - Static variable in class net.tomp2p.upnp.Discovery

allowedvalues - Variable in class net.tomp2p.upnp.StateVariable

A set of allowed values (String objects) for the variable

approximateCount(E) - Method in class net.tomp2p.rpc.CountingBloomFilter

Returns the number of times that an element has been added.

aquireSingleConnection() - Method in class net.tomp2p.connection.PeerConnection

Acquire one connection.

Argument - Class in net.tomp2p.upnp

An argument for a service action

Argument.Direction - Enum in net.tomp2p.upnp

arguments - Variable in class net.tomp2p.upnp.Action

AsyncTask - Class in net.tomp2p.task

AsyncTask(TaskRPC, Scheduler, PeerBean) - Constructor for class net.tomp2p.task.AsyncTask

await() - Method in interface net.tomp2p.futures.BaseFuture

Wait for the asynchronous operation to end.

await(long) - Method in interface net.tomp2p.futures.BaseFuture

Wait for the asynchronous operation to end with the specified timeout.

await() - Method in class net.tomp2p.futures.BaseFutureImpl

await(long) - Method in class net.tomp2p.futures.BaseFutureImpl

awaitListeners() - Method in interface net.tomp2p.futures.BaseFuture

Waits until all the listener finished.

awaitListeners() - Method in class net.tomp2p.futures.BaseFutureImpl

awaitUninterruptibly() - Method in interface net.tomp2p.futures.BaseFuture

Wait for the asynchronous operation to end without interruption.

awaitUninterruptibly(long) - Method in interface net.tomp2p.futures.BaseFuture

Wait for the asynchronous operation to end with the specified timeout without interruption.

awaitUninterruptibly() - Method in class net.tomp2p.futures.BaseFutureImpl

awaitUninterruptibly(long) - Method in class net.tomp2p.futures.BaseFutureImpl

B

BaseFuture - Interface in net.tomp2p.futures

Represents the result of an asynchronous operation.

BaseFuture.FutureType - Enum in net.tomp2p.futures

The first state is always INIT and will always end in either OK, FAILED, or CANCEl

BaseFutureAdapter<F extends BaseFuture> - Class in net.tomp2p.futures

The BaseFuture always completes either successfully or failed.

BaseFutureAdapter() - Constructor for class net.tomp2p.futures.BaseFutureAdapter

BaseFutureImpl<K extends BaseFuture> - Class in net.tomp2p.futures

The base for all BaseFuture implementations.

BaseFutureImpl() - Constructor for class net.tomp2p.futures.BaseFutureImpl

Default constructor that sets the lock object, which is used for synchronization to this instance.

BaseFutureListener<F extends BaseFuture> - Interface in net.tomp2p.futures

Something interested in being notified when the result of an BaseFuture becomes available.

bestEffortclose(Closeable...) - Static method in class net.tomp2p.utils.Utils

BIN_BASE64 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

MIME-style Base64 encoded binary BLOB.

BIN_BASE64_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

BIN_HEX - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Hexadecimal digits representing octets.

BIN_HEX_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Bindings - Class in net.tomp2p.connection

Gathers information about interface bindings.

Bindings() - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to everything

Bindings(InetAddress) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to a specified address

Bindings(String) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to a specified interface

Bindings(Bindings.Protocol) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to a specified protocol

Bindings(Bindings.Protocol, String) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to a specified protocol and interface

Bindings(Bindings.Protocol, String, InetAddress) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to a specified protocol and interface and address

Bindings(InetAddress, int, int) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to everything and provides information about manual port forwarding

Bindings(Bindings.Protocol, InetAddress, int, int) - Constructor for class net.tomp2p.connection.Bindings

Creates a Binding class that binds to a specified protocol and provides information about manual port forwarding

Bindings.Protocol - Enum in net.tomp2p.connection

Types of protocols.

bitLength() - Method in class net.tomp2p.peers.Number160

Calculates the number of bits used to represent this number.

BITS - Static variable in class net.tomp2p.peers.Number160

BLOOMFILTER_SIZE - Static variable in class net.tomp2p.p2p.Peer

BOOLEAN - Static variable in interface net.tomp2p.upnp.StateVariableTypes

0, false, or no for false; 1, true, or yes for true.

BOOLEAN_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

bootstrap(Peer[]) - Static method in class net.tomp2p.examples.ExampleUtils

Bootstraps peers to the first peer in the array.

bootstrap(Collection<PeerAddress>, int, int, int, int, boolean, boolean, ChannelCreator) - Method in class net.tomp2p.p2p.DistributedRouting

Bootstraps to the given peerAddresses, i.e.

bootstrap() - Method in class net.tomp2p.p2p.Peer

BootstrapBuilder - Class in net.tomp2p.p2p.builder

Boostraps to a known peer.

BootstrapBuilder(Peer) - Constructor for class net.tomp2p.p2p.builder.BootstrapBuilder

broadcast(Number160) - Method in class net.tomp2p.p2p.Peer

BroadcastBuilder - Class in net.tomp2p.p2p.builder

BroadcastBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.BroadcastBuilder

BroadcastHandler - Interface in net.tomp2p.p2p

BroadcastRPC - Class in net.tomp2p.rpc

BroadcastRPC(PeerBean, ConnectionBean, BroadcastHandler) - Constructor for class net.tomp2p.rpc.BroadcastRPC

build(URL, String, String, String, String, InetAddress) - Static method in class net.tomp2p.upnp.RootDevice

BYTE_ARRAY_SIZE - Static variable in class net.tomp2p.peers.Number160

byteArrayToInt(byte[], int) - Static method in class net.tomp2p.rpc.SimpleBloomFilter

byteArrayToInt(byte[]) - Static method in class net.tomp2p.utils.Utils

C

CacheKey - Class in net.tomp2p.rpc

CacheKey(PeerAddress, Message.Type, boolean) - Constructor for class net.tomp2p.rpc.CacheKey

CacheMap<K,V> - Class in net.tomp2p.utils

The CacheMap is a LRU cache with a given capacity.

CacheMap(int, boolean) - Constructor for class net.tomp2p.utils.CacheMap

Creates a new CacheMap with a fixed capacity

cacheSize() - Method in class net.tomp2p.storage.KeyLock

cancel() - Method in class net.tomp2p.connection.ReplyTimeoutHandler

cancel() - Method in class net.tomp2p.futures.BaseFutureImpl

cancel() - Method in interface net.tomp2p.futures.Cancellable

This method gets called if a future is cancelled.

cancel(boolean, int, BaseFuture[]) - Static method in class net.tomp2p.p2p.DistributedRouting

Cancellable - Interface in net.tomp2p.futures

A cancelable class should implement this method use use it for future objects.

changeAddress(InetAddress) - Method in class net.tomp2p.peers.PeerAddress

changeDomain(Number160) - Method in class net.tomp2p.peers.Number480

changeFirewalledTCP(boolean) - Method in class net.tomp2p.peers.PeerAddress

changeFirewalledUDP(boolean) - Method in class net.tomp2p.peers.PeerAddress

changePeerId(Number160) - Method in class net.tomp2p.peers.PeerAddress

changePorts(int, int) - Method in class net.tomp2p.peers.PeerAddress

channelClosed(ChannelHandlerContext, ChannelStateEvent) - Method in class net.tomp2p.rpc.RequestHandlerTCP

channelClosed(ChannelHandlerContext, ChannelStateEvent) - Method in class net.tomp2p.rpc.RequestHandlerUDP

ChannelCreator - Class in net.tomp2p.connection

Creates the channels.

channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in class net.tomp2p.connection.DispatcherReply

channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in class net.tomp2p.connection.ReplyTimeoutHandler

CHAR - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Unicode string.

CHAR_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

checkEntryProtection(Map<Number160, Data>) - Static method in class net.tomp2p.utils.Utils

checkIdentity(Number160, PublicKey) - Method in class net.tomp2p.p2p.IdentityManagement

checkResponsibility(Number160) - Method in class net.tomp2p.replication.Replication

checkTimeout() - Method in class net.tomp2p.storage.StorageGeneric

childDevices - Variable in class net.tomp2p.upnp.Device

clear() - Method in class net.tomp2p.connection.Bindings

Clears all lists: listenInterfaceHints, listenAddresses, broadcastAddresses.

clear() - Method in class net.tomp2p.rpc.CountingBloomFilter

Clear the Bloom Filter

clear() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Clear the Bloom Filter

clear() - Method in class net.tomp2p.utils.ConcurrentCacheMap

clearInputParameters() - Method in class net.tomp2p.upnp.ActionMessage

Method to clear all set input parameters so that this object can be reused

clearQueue() - Method in class net.tomp2p.natpmp.NatPmpDevice

Clears the queue of messages to send.

close(PeerAddress) - Method in class net.tomp2p.connection.ChannelCreator

Closes a permanent connection.

close() - Method in class net.tomp2p.connection.PeerConnection

Closes and releases the connection from the reservation.

close() - Method in class net.tomp2p.message.ProtocolChunkedInput

close() - Method in interface net.tomp2p.storage.Storage

close() - Method in class net.tomp2p.storage.StorageDisk

close() - Method in class net.tomp2p.storage.StorageMemory

closeNeighbors(PeerAddress, Number160, Number160, Collection<Number160>, Message.Type, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.NeighborRPC

Requests close neighbors from the remote peer.

closePeers(Number160, int) - Method in class net.tomp2p.peers.PeerMap

Returns close peer from the set to a given key.

compareAndPut(PeerAddress, Number160, Number160, Map<Number160, HashData>, FutureSuccessEvaluator, boolean, boolean, boolean, boolean, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.StorageRPC

Compares and puts data on a peer.

compareAndPut(Number160, Number160, Map<Number160, HashData>, PublicKey, boolean, boolean) - Method in class net.tomp2p.storage.StorageGeneric

Compares and puts the data if the compare matches

compareTo(MessageID) - Method in class net.tomp2p.message.MessageID

compareTo(Number160) - Method in class net.tomp2p.peers.Number160

compareTo(Number320) - Method in class net.tomp2p.peers.Number320

compareTo(Number480) - Method in class net.tomp2p.peers.Number480

compareTo(PeerAddress) - Method in class net.tomp2p.peers.PeerAddress

compareTo(ShortString) - Method in class net.tomp2p.peers.ShortString

compareTo(TrackerData) - Method in class net.tomp2p.storage.TrackerData

completed - Variable in class net.tomp2p.futures.BaseFutureImpl

compress(byte[]) - Static method in class net.tomp2p.utils.Utils

ConcurrentCacheMap<K,V> - Class in net.tomp2p.utils

A map with expiration and more or less LRU.

ConcurrentCacheMap() - Constructor for class net.tomp2p.utils.ConcurrentCacheMap

Creates a new instance of ConcurrentCacheMap using the supplied values and a CacheMap for the internal data structure.

ConcurrentCacheMap(int, int) - Constructor for class net.tomp2p.utils.ConcurrentCacheMap

Creates a new instance of ConcurrentCacheMap using the supplied values and a CacheMap for the internal data structure.

ConcurrentCacheMap(int, int, boolean) - Constructor for class net.tomp2p.utils.ConcurrentCacheMap

Creates a new instance of ConcurrentCacheMap using the supplied values and a CacheMap for the internal data structure.

ConnectionBean - Class in net.tomp2p.connection

A bean that holds sharable configuration settings for the peer.

ConnectionBean(int, DispatcherReply, Sender, ChannelGroup, ConnectionReservation, ConnectionConfiguration, Scheduler) - Constructor for class net.tomp2p.connection.ConnectionBean

ConnectionConfiguration - Class in net.tomp2p.p2p

ConnectionConfiguration() - Constructor for class net.tomp2p.p2p.ConnectionConfiguration

ConnectionHandler - Class in net.tomp2p.connection

Handles the server connections of a node, i.e.

ConnectionHandler(int, int, Number160, Bindings, int, ConnectionConfiguration, File, KeyPair, PeerMap, Timer, int, int, int, int) - Constructor for class net.tomp2p.connection.ConnectionHandler

ConnectionHandler(ConnectionHandler, Number160, KeyPair, PeerMap) - Constructor for class net.tomp2p.connection.ConnectionHandler

Attaches a peer to an existing connection and use existing information.

ConnectionReservation - Class in net.tomp2p.connection

The connection pool limits the connection used in the application.

ConnectionReservation(ChannelFactory, ChannelFactory, ConnectionConfiguration, MessageLogger, Statistics, Scheduler) - Constructor for class net.tomp2p.connection.ConnectionReservation

contains(PeerAddress) - Method in class net.tomp2p.peers.PeerMap

contains(Object) - Method in class net.tomp2p.rpc.CountingBloomFilter

contains(Object) - Method in class net.tomp2p.rpc.SimpleBloomFilter

contains(Number160, Number160, Number160) - Method in interface net.tomp2p.storage.Storage

contains(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageDisk

contains(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageMemory

containsAll(Collection<?>) - Method in class net.tomp2p.rpc.CountingBloomFilter

containsAll(Collection<?>) - Method in class net.tomp2p.rpc.SimpleBloomFilter

containsInterface(String) - Method in class net.tomp2p.connection.Bindings

Checks if the user provided an interface hint

containsKey(Object) - Method in class net.tomp2p.utils.ConcurrentCacheMap

containsValue(Object) - Method in class net.tomp2p.utils.ConcurrentCacheMap

controlURL - Variable in class net.tomp2p.upnp.Service

convert(Collection<TrackerData>) - Static method in class net.tomp2p.utils.Utils

copyToCurrent(byte[]) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(int) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(byte) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(long) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(short) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(ChannelBuffer) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(byte[], int, int) - Method in interface net.tomp2p.message.ProtocolChunked

copyToCurrent(byte[]) - Method in class net.tomp2p.message.ProtocolChunkedInput

copyToCurrent(int) - Method in class net.tomp2p.message.ProtocolChunkedInput

copyToCurrent(byte) - Method in class net.tomp2p.message.ProtocolChunkedInput

copyToCurrent(long) - Method in class net.tomp2p.message.ProtocolChunkedInput

copyToCurrent(short) - Method in class net.tomp2p.message.ProtocolChunkedInput

copyToCurrent(ChannelBuffer) - Method in class net.tomp2p.message.ProtocolChunkedInput

copyToCurrent(byte[], int, int) - Method in class net.tomp2p.message.ProtocolChunkedInput

couldProvideMoreData() - Method in class net.tomp2p.storage.TrackerData

CountingBloomFilter<E> - Class in net.tomp2p.rpc

A counting Bloom Filter (see http://en.wikipedia.org/wiki/Bloom_filter) that uses java.util.Random as a primitive hash function, and which implements Java's Set interface for convenience.

CountingBloomFilter(int, int[]) - Constructor for class net.tomp2p.rpc.CountingBloomFilter

Constructs a CountingBloomFilter out of existing data.

create() - Method in interface net.tomp2p.futures.FutureCreator

create(ChannelCreator, PeerAddress) - Method in interface net.tomp2p.p2p.DistributedHashTable.Operation

create(PeerAddress, boolean) - Method in interface net.tomp2p.p2p.DistributedTracker.Operation

Creates an RPC.

createAndAttachNodes(int, int) - Static method in class net.tomp2p.examples.ExampleUtils

Create peers with a port and attach it to the first peer in the array.

createComparator(Number160) - Static method in class net.tomp2p.peers.PeerMap

createData(ByteBuffer[], int, int, boolean, boolean, PeerAddress) - Static method in class net.tomp2p.message.DataCodec

createHash(int) - Static method in class net.tomp2p.peers.Number160

Create a new Number160 from the integer, which fills all the 160bits.

createHash(long) - Static method in class net.tomp2p.peers.Number160

Create a new Number160 from the long, which fills all the 160bit.

createHash(String) - Static method in class net.tomp2p.peers.Number160

Create a new Number160 using SHA1 on the string.

createMessage(PeerAddress, Message.Command, Message.Type) - Method in class net.tomp2p.rpc.ReplyHandler

createPeerComparator(Number160) - Method in class net.tomp2p.peers.PeerMap

Creates a comparator that orders to peers according to their distance to the specified id.

createPeerComparator() - Method in class net.tomp2p.peers.PeerMap

createPeerConnection(PeerAddress, int) - Method in class net.tomp2p.p2p.Peer

Opens a TCP connection and keeps it open.

createRandomNodeID() - Static method in class net.tomp2p.utils.Utils

createResponseMessage(Message, Message.Type) - Method in class net.tomp2p.rpc.ReplyHandler

createSocketTCP() - Method in class net.tomp2p.peers.PeerAddress

Returns the socket address.

createSocketUDP() - Method in class net.tomp2p.peers.PeerAddress

Returns the socket address.

createTCPChannel(ReplyTimeoutHandler, RequestHandlerTCP<? extends BaseFuture>, int, InetSocketAddress) - Method in class net.tomp2p.connection.ChannelCreator

Creates a TCP channel future.

createTempDir() - Static method in class net.tomp2p.utils.Utils

createUDPChannel(ReplyTimeoutHandler, RequestHandlerUDP<? extends BaseFuture>, boolean) - Method in class net.tomp2p.connection.ChannelCreator

Creates a UDP channel.

CumulativeScheme - Class in net.tomp2p.p2p

CumulativeScheme() - Constructor for class net.tomp2p.p2p.CumulativeScheme

currentTimeMillis() - Method in interface net.tomp2p.utils.Timing

currentTimeMillis() - Method in class net.tomp2p.utils.TimingImpl

currentTimeMillis() - Static method in class net.tomp2p.utils.Timings

customLoggerMessage(String) - Method in class net.tomp2p.connection.ConnectionHandler

Writes a custom message to the logger filter.

customLoggerMessage(String) - Method in class net.tomp2p.p2p.Peer

customMessage(String) - Method in class net.tomp2p.connection.MessageLogger

Prints out custom messages.

D

Data - Class in net.tomp2p.storage

This class holds the data for the transport.

Data(Object) - Constructor for class net.tomp2p.storage.Data

Data(Object, Number160) - Constructor for class net.tomp2p.storage.Data

Data(byte[]) - Constructor for class net.tomp2p.storage.Data

Data(byte[], Number160) - Constructor for class net.tomp2p.storage.Data

Data(ByteBuffer[], int, Number160) - Constructor for class net.tomp2p.storage.Data

Data(byte[], int, int, Number160) - Constructor for class net.tomp2p.storage.Data

DataCodec - Class in net.tomp2p.message

Encoder and decoder for Data.

DataCodec() - Constructor for class net.tomp2p.message.DataCodec

dataType - Variable in class net.tomp2p.upnp.StateVariable

The variable UPNP data type

DATE - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Date in a subset of ISO 8601 format without time data.

DATE_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

DATETIME - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Date in ISO 8601 format with optional time but no time zone.

DATETIME_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

DATETIME_TZ - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Date in ISO 8601 format with optional time and optional time zone.

DATETIME_TZ_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

debugArray(byte[], int, int) - Static method in class net.tomp2p.utils.Utils

debugArray(byte[]) - Static method in class net.tomp2p.utils.Utils

decode(byte[]) - Method in class net.tomp2p.message.SHA1Signature

decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in class net.tomp2p.message.TomP2PDecoderTCP

decode(ChannelHandlerContext, Channel, ChannelBuffer, SocketAddress) - Method in class net.tomp2p.message.TomP2PDecoderUDP

decodeData(ChannelBuffer, PeerAddress) - Static method in class net.tomp2p.message.DataCodec

decodeHeader(ChannelBuffer, InetSocketAddress, InetSocketAddress) - Static method in class net.tomp2p.message.MessageCodec

Decode a message header from a Netty buffer

decodeJavaObject(ChannelBuffer) - Static method in class net.tomp2p.utils.Utils

decodeJavaObject(byte[], int, int) - Static method in class net.tomp2p.utils.Utils

decodePayload(Message.Content, ChannelBuffer, Message) - Static method in class net.tomp2p.message.MessageCodec

Decodes the payload from a Netty buffer in a big switch

decodePublicKey(ChannelBuffer, byte[]) - Static method in class net.tomp2p.message.MessageCodec

DecoderException - Exception in net.tomp2p.message

DecoderException(String) - Constructor for exception net.tomp2p.message.DecoderException

decodeSignature(Signature, Message, ChannelBuffer) - Static method in class net.tomp2p.message.MessageCodec

decrementTCPChannelCreation() - Method in class net.tomp2p.p2p.Statistics

decrementUDPChannelCreation() - Method in class net.tomp2p.p2p.Statistics

DEFAULT_DOMAIN - Static variable in class net.tomp2p.p2p.builder.DHTBuilder

DEFAULT_DOMAIN - Static variable in class net.tomp2p.p2p.builder.TrackerBuilder

DEFAULT_MX - Static variable in class net.tomp2p.upnp.Discovery

DEFAULT_PORT - Static variable in class net.tomp2p.connection.Bindings

The default port of TomP2P

DEFAULT_SEARCH - Static variable in class net.tomp2p.upnp.Discovery

DEFAULT_SSDP_SEARCH_PORT - Static variable in class net.tomp2p.upnp.Discovery

DEFAULT_TIME_TO_LIVE - Static variable in class net.tomp2p.utils.ConcurrentCacheMap

Time to live for a value.

DEFAULT_TIMEOUT - Static variable in class net.tomp2p.upnp.Discovery

DEFAULT_TTL - Static variable in class net.tomp2p.upnp.Discovery

DefaultBroadcastHandler - Class in net.tomp2p.p2p

DefaultBroadcastHandler(Peer, Random) - Constructor for class net.tomp2p.p2p.DefaultBroadcastHandler

defaultDirectReplication - Variable in class net.tomp2p.p2p.builder.DHTBuilder

DefaultMapAcceptHandler - Class in net.tomp2p.peers

DefaultMapAcceptHandler(boolean) - Constructor for class net.tomp2p.peers.DefaultMapAcceptHandler

DefaultReservation - Class in net.tomp2p.connection

DefaultReservation() - Constructor for class net.tomp2p.connection.DefaultReservation

DefaultStorageReplication - Class in net.tomp2p.replication

DefaultStorageReplication(Peer, StorageGeneric, StorageRPC, Map<BaseFuture, Long>, boolean) - Constructor for class net.tomp2p.replication.DefaultStorageReplication

defaultValue - Variable in class net.tomp2p.upnp.StateVariable

The default value of the state variable

deletePortMapping(String, int, String) - Method in class net.tomp2p.upnp.InternetGatewayDevice

Deletes a port mapping on the IDG device

Device - Class in net.tomp2p.upnp

This class represents an UPNP device, this device contains a set of services that will be needed to access the device functionalities.

Device(Node, Device, URL) - Constructor for class net.tomp2p.upnp.Device

deviceType - Variable in class net.tomp2p.upnp.Device

DHTBuilder<K extends DHTBuilder<K>> - Class in net.tomp2p.p2p.builder

DHTBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.DHTBuilder

difference(Collection<K>, Collection<K>, Collection<K>) - Static method in class net.tomp2p.utils.Utils

Stores the differences of two collections in a result collection.

difference(Collection<K>, Collection<K>, Collection<K>...) - Static method in class net.tomp2p.utils.Utils

Stores the differences of multiple collections in a result collection.

Digest - Interface in net.tomp2p.storage

The storage stores Number480, which is separated in 3 Number160.

digest(Number160, Number160, Collection<Number160>) - Method in interface net.tomp2p.storage.Digest

Calculates a digest over a specific location and domain.

digest(Number160, Number160, SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>) - Method in interface net.tomp2p.storage.Digest

Calculates a digest over a specific location and domain.

digest(Number160, Number160, SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>) - Method in class net.tomp2p.storage.StorageGeneric

digest(Number160, Number160, Collection<Number160>) - Method in class net.tomp2p.storage.StorageGeneric

digest(Number160, Number160, SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>) - Method in class net.tomp2p.storage.TrackerStorage

digest(Number160, Number160, Collection<Number160>) - Method in class net.tomp2p.storage.TrackerStorage

digest() - Method in class net.tomp2p.task.TaskManager

DigestInfo - Class in net.tomp2p.rpc

Calculates or sets a global hash.

DigestInfo() - Constructor for class net.tomp2p.rpc.DigestInfo

Empty constructor is used to add the hashes to the list.

DigestInfo(int) - Constructor for class net.tomp2p.rpc.DigestInfo

Create a digest with the size only.

DigestInfo(Number160, Number160, int) - Constructor for class net.tomp2p.rpc.DigestInfo

If a global hash has already been calculated, then this constructor is used to store those.

DigestResult - Class in net.tomp2p.rpc

DigestResult(SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>) - Constructor for class net.tomp2p.rpc.DigestResult

DigestResult(Map<Number160, Number160>) - Constructor for class net.tomp2p.rpc.DigestResult

direct(Number160, ChannelBuffer, boolean, RoutingConfiguration, RequestP2PConfiguration, FutureCreate<FutureDHT>, boolean, boolean, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedHashTable

DirectDataRPC - Class in net.tomp2p.rpc

DirectDataRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.DirectDataRPC

direction - Variable in class net.tomp2p.upnp.Argument

directReplication - Variable in class net.tomp2p.p2p.builder.DHTBuilder

discover() - Method in class net.tomp2p.p2p.Peer

discover() - Static method in class net.tomp2p.upnp.Discovery

Devices discovering on all network interfaces with default values, all root devices will be searched

discover(String) - Static method in class net.tomp2p.upnp.Discovery

Devices discovering on all network interfaces with a given root device to search

discover(int, String) - Static method in class net.tomp2p.upnp.Discovery

Devices discovering on all network interfaces with a given timeout and a given root device to search

discover(int, int, int, String) - Static method in class net.tomp2p.upnp.Discovery

Devices discovering on all network interfaces with a given timeout and a given root device to search, as well as a ttl and mx param

discover(int, int, int, String, NetworkInterface) - Static method in class net.tomp2p.upnp.Discovery

Devices discovering with a given timeout and a given root device to search on an given network interface, as well as a ttl and mx param

DiscoverBuilder - Class in net.tomp2p.p2p.builder

DiscoverBuilder(Peer) - Constructor for class net.tomp2p.p2p.builder.DiscoverBuilder

discoveredDevice(String, String, String, String, URL, String, InetAddress) - Method in interface net.tomp2p.upnp.DiscoveryResultsHandler

Method called by the DiscoveryListener class when a search response message has been received from the network

discoverInterfaces(Bindings) - Static method in class net.tomp2p.connection.DiscoverNetworks

Search for local interfaces.

discoverNetwork(NetworkInterface, Bindings) - Static method in class net.tomp2p.connection.DiscoverNetworks

Discovers network interfaces and addresses.

DiscoverNetworks - Class in net.tomp2p.connection

A class to search for addresses to bind the sockets to.

DiscoverNetworks() - Constructor for class net.tomp2p.connection.DiscoverNetworks

Discovery - Class in net.tomp2p.upnp

Class to discover an UPNP device on the network.
A multicast socket will be created to discover devices, the binding port for this socket is set to 1901, if this is causing a problem you can use the net.sbbi.upnp.Discovery.bindPort system property to specify another port.

Discovery() - Constructor for class net.tomp2p.upnp.Discovery

DiscoveryListener - Class in net.tomp2p.upnp

This class can be used to listen for UPNP devices responses when a search message is sent by a control point ( using the net.sbbi.upnp.Discovery.sendSearchMessage() method )

DiscoveryResultsHandler - Interface in net.tomp2p.upnp

This interface can be use to register against the DiscoveryListener class to receive SSDP search responses.

disjunction(Map<K, V>, Collection<K>) - Static method in class net.tomp2p.utils.Utils

DispatcherReply - Class in net.tomp2p.connection

Used to deliver incoming REQUEST messages to their specific handlers.

DispatcherReply(int, PeerBean, ConnectionConfiguration, ChannelGroup, PeerMap) - Constructor for class net.tomp2p.connection.DispatcherReply

Constructor

DistributedHashTable - Class in net.tomp2p.p2p

DistributedHashTable(DistributedRouting, StorageRPC, DirectDataRPC) - Constructor for class net.tomp2p.p2p.DistributedHashTable

DistributedHashTable.Operation - Interface in net.tomp2p.p2p

DistributedRouting - Class in net.tomp2p.p2p

Handles routing of nodes to other nodes

DistributedRouting(PeerBean, NeighborRPC) - Constructor for class net.tomp2p.p2p.DistributedRouting

DistributedTask - Class in net.tomp2p.p2p

DistributedTask(DistributedRouting, AsyncTask) - Constructor for class net.tomp2p.p2p.DistributedTask

DistributedTracker - Class in net.tomp2p.p2p

DistributedTracker(PeerBean, DistributedRouting, TrackerRPC, PeerExchangeRPC) - Constructor for class net.tomp2p.p2p.DistributedTracker

DistributedTracker.Operation - Interface in net.tomp2p.p2p

This interface is used for the RPC operations.

domainKey - Variable in class net.tomp2p.p2p.builder.DHTBuilder

domainKey - Variable in class net.tomp2p.p2p.builder.TrackerBuilder

done(PeerAddress, PeerAddress) - Method in class net.tomp2p.futures.FutureDiscover

Gets called if the discovery was a success and an other peer could ping us with TCP and UDP.

done() - Method in class net.tomp2p.futures.FutureLaterJoin

If no more futures are added, done() must be called to evaluate the results.

done(int) - Method in class net.tomp2p.futures.FutureLaterJoin

If no more futures are added, done() must be called to evaluate the results.

doubleValue() - Method in class net.tomp2p.peers.Number160

doubleValue() - Method in class net.tomp2p.peers.Number320

doubleValue() - Method in class net.tomp2p.peers.Number480

E

EMPTY_BYTE_ARRAY - Static variable in class net.tomp2p.message.MessageCodec

EMPTY_IPv4 - Static variable in class net.tomp2p.peers.PeerAddress

encode() - Method in class net.tomp2p.message.SHA1Signature

encodeData(ProtocolChunked, Data) - Static method in class net.tomp2p.message.DataCodec

encodeHeader(ChannelBuffer, Message) - Static method in class net.tomp2p.message.MessageCodec

The format looks as follows: 32bit p2p version - 32bit id - 4bit message type - 4bit message name - 160bit sender id - 16bit tcp port - 16bit udp port - 160bit recipient id - 16bit (4x4)content type - 8bit network address information.

encodeJavaObject(Object) - Static method in class net.tomp2p.utils.Utils

encodePayload(Message, ProtocolChunkedInput) - Static method in class net.tomp2p.message.MessageCodec

Encode payload

enqueueMessage(Message) - Method in class net.tomp2p.natpmp.NatPmpDevice

Enqueues a message for sending.

entrySet() - Method in class net.tomp2p.utils.ConcurrentCacheMap

equals(Object) - Method in class net.tomp2p.message.MessageID

equals(Object) - Method in class net.tomp2p.peers.Number160

equals(Object) - Method in class net.tomp2p.peers.Number320

equals(Object) - Method in class net.tomp2p.peers.Number480

equals(Object) - Method in class net.tomp2p.peers.PeerAddress

equals(Object) - Method in class net.tomp2p.peers.ShortString

equals(Object) - Method in class net.tomp2p.rpc.CacheKey

equals(Object) - Method in class net.tomp2p.rpc.CountingBloomFilter

equals(Object) - Method in class net.tomp2p.rpc.DigestInfo

equals(Object) - Method in class net.tomp2p.rpc.DigestResult

equals(Object) - Method in class net.tomp2p.rpc.SimpleBloomFilter

equals(Object) - Method in class net.tomp2p.storage.TrackerData

evaluate(Message, Message) - Method in interface net.tomp2p.futures.FutureSuccessEvaluator

evaluate(Message, Message) - Method in class net.tomp2p.futures.FutureSuccessEvaluatorCommunication

evaluate(Message, Message) - Method in class net.tomp2p.futures.FutureSuccessEvaluatorOperation

evaluate1(Number160, Number160, Map<PeerAddress, Collection<Number160>>, Map<PeerAddress, Collection<Number480>>) - Method in class net.tomp2p.p2p.CumulativeScheme

evaluate1(Number160, Number160, Map<PeerAddress, Collection<Number160>>, Map<PeerAddress, Collection<Number480>>) - Method in interface net.tomp2p.p2p.EvaluatingSchemeDHT

evaluate1(Number160, Number160, Map<PeerAddress, Collection<Number160>>, Map<PeerAddress, Collection<Number480>>) - Method in class net.tomp2p.p2p.VotingSchemeDHT

evaluate2(Map<PeerAddress, Map<Number160, Data>>) - Method in class net.tomp2p.p2p.CumulativeScheme

evaluate2(Map<PeerAddress, Map<Number160, Data>>) - Method in interface net.tomp2p.p2p.EvaluatingSchemeDHT

evaluate2(Map<PeerAddress, Map<Number160, Data>>) - Method in class net.tomp2p.p2p.VotingSchemeDHT

evaluate3(Map<PeerAddress, Object>) - Method in class net.tomp2p.p2p.CumulativeScheme

evaluate3(Map<PeerAddress, Object>) - Method in interface net.tomp2p.p2p.EvaluatingSchemeDHT

evaluate3(Map<PeerAddress, Object>) - Method in class net.tomp2p.p2p.VotingSchemeDHT

evaluate4(Map<PeerAddress, ChannelBuffer>) - Method in class net.tomp2p.p2p.CumulativeScheme

evaluate4(Map<PeerAddress, ChannelBuffer>) - Method in interface net.tomp2p.p2p.EvaluatingSchemeDHT

evaluate4(Map<PeerAddress, ChannelBuffer>) - Method in class net.tomp2p.p2p.VotingSchemeDHT

evaluate5(Map<PeerAddress, DigestResult>) - Method in class net.tomp2p.p2p.CumulativeScheme

evaluate5(Map<PeerAddress, DigestResult>) - Method in interface net.tomp2p.p2p.EvaluatingSchemeDHT

evaluate5(Map<PeerAddress, DigestResult>) - Method in class net.tomp2p.p2p.VotingSchemeDHT

evaluateSingle(Map<PeerAddress, Collection<TrackerData>>) - Method in interface net.tomp2p.p2p.EvaluatingSchemeTracker

evaluateSingle(Map<PeerAddress, Collection<TrackerData>>) - Method in class net.tomp2p.p2p.VotingSchemeTracker

EvaluatingSchemeDHT - Interface in net.tomp2p.p2p

EvaluatingSchemeTracker - Interface in net.tomp2p.p2p

eventSubURL - Variable in class net.tomp2p.upnp.Service

exampleAllMaster() - Static method in class net.tomp2p.examples.ExampleSecurity

ExampleBloomFilter - Class in net.tomp2p.examples

ExampleBloomFilter() - Constructor for class net.tomp2p.examples.ExampleBloomFilter

ExampleBootstrap - Class in net.tomp2p.examples

See http://tomp2p.net/doc/quick/ for more information

ExampleBootstrap() - Constructor for class net.tomp2p.examples.ExampleBootstrap

ExampleCache - Class in net.tomp2p.examples

ExampleCache() - Constructor for class net.tomp2p.examples.ExampleCache

ExampleConsistency - Class in net.tomp2p.examples

ExampleConsistency() - Constructor for class net.tomp2p.examples.ExampleConsistency

ExampleDHT - Class in net.tomp2p.examples

ExampleDHT() - Constructor for class net.tomp2p.examples.ExampleDHT

ExampleDirectReplication - Class in net.tomp2p.examples

ExampleDirectReplication() - Constructor for class net.tomp2p.examples.ExampleDirectReplication

ExampleDiscover - Class in net.tomp2p.examples

ExampleDiscover() - Constructor for class net.tomp2p.examples.ExampleDiscover

ExampleDNS - Class in net.tomp2p.examples

See http://tomp2p.net/doc/quick/ for more information on this

ExampleDNS(int) - Constructor for class net.tomp2p.examples.ExampleDNS

ExampleDST - Class in net.tomp2p.examples

ExampleDST() - Constructor for class net.tomp2p.examples.ExampleDST

ExampleFastSS - Class in net.tomp2p.examples

ExampleFastSS() - Constructor for class net.tomp2p.examples.ExampleFastSS

exampleGetBlocking(Peer[], Number160) - Static method in class net.tomp2p.examples.ExamplePutGet

exampleGetNonBlocking(Peer[], Number160) - Static method in class net.tomp2p.examples.ExamplePutGet

ExampleHashMap - Class in net.tomp2p.examples

This example shows how TomP2P can be used to have Objects instead of Number160.

ExampleHashMap() - Constructor for class net.tomp2p.examples.ExampleHashMap

ExampleIndirectReplication - Class in net.tomp2p.examples

ExampleIndirectReplication() - Constructor for class net.tomp2p.examples.ExampleIndirectReplication

ExampleMapReduce - Class in net.tomp2p.examples

ExampleMapReduce() - Constructor for class net.tomp2p.examples.ExampleMapReduce

ExampleMultiColumn - Class in net.tomp2p.examples

ExampleMultiColumn() - Constructor for class net.tomp2p.examples.ExampleMultiColumn

ExampleNAT - Class in net.tomp2p.examples

ExampleNAT() - Constructor for class net.tomp2p.examples.ExampleNAT

ExampleNATChat - Class in net.tomp2p.examples

ExampleNATChat() - Constructor for class net.tomp2p.examples.ExampleNATChat

exampleNoneMaster() - Static method in class net.tomp2p.examples.ExampleSecurity

ExamplePersistentConnection - Class in net.tomp2p.examples

ExamplePersistentConnection() - Constructor for class net.tomp2p.examples.ExamplePersistentConnection

ExamplePutGet - Class in net.tomp2p.examples

This simple example creates 10 nodes, bootstraps to the first and put and get data from those 10 nodes.

ExamplePutGet() - Constructor for class net.tomp2p.examples.ExamplePutGet

examplePutGet(Peer[], Number160) - Static method in class net.tomp2p.examples.ExamplePutGet

examplePutGetConfig(Peer[], Number160) - Static method in class net.tomp2p.examples.ExamplePutGet

ExampleSecurity - Class in net.tomp2p.examples

ExampleSecurity() - Constructor for class net.tomp2p.examples.ExampleSecurity

ExampleSend - Class in net.tomp2p.examples

ExampleSend() - Constructor for class net.tomp2p.examples.ExampleSend

ExampleTracker - Class in net.tomp2p.examples

ExampleTracker() - Constructor for class net.tomp2p.examples.ExampleTracker

ExampleUnQL - Class in net.tomp2p.examples

ExampleUnQL() - Constructor for class net.tomp2p.examples.ExampleUnQL

ExampleUtils - Class in net.tomp2p.examples

This simple example creates 10 nodes, bootstraps to the first and put and get data from those 10 nodes.

ExampleUtils() - Constructor for class net.tomp2p.examples.ExampleUtils

ExampleWSJSON - Class in net.tomp2p.examples.ws

ExampleWSJSON() - Constructor for class net.tomp2p.examples.ws.ExampleWSJSON

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class net.tomp2p.connection.DispatcherReply

Called if we get an exception

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class net.tomp2p.connection.ReplyTimeoutHandler

exceptionCaught(Throwable) - Method in class net.tomp2p.futures.BaseFutureAdapter

Prints out the error using the logger and System.err.

exceptionCaught(Throwable) - Method in interface net.tomp2p.futures.BaseFutureListener

If the operation complete is called and the methed throws an exception

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class net.tomp2p.message.TomP2PDecoderTCP

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class net.tomp2p.rpc.ReplyHandler

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class net.tomp2p.rpc.RequestHandlerTCP

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class net.tomp2p.rpc.RequestHandlerUDP

exceptionGenerated(Message, NatPmpException) - Method in interface net.tomp2p.natpmp.MessageResponseInterface

An exception was generated during the message sending process.

execute(Peer, String) - Static method in class net.tomp2p.examples.ExampleUnQL

execute(Peer, Number160, Map<Number160, Data>) - Method in interface net.tomp2p.task.Worker

expectedFalsePositiveProbability() - Method in class net.tomp2p.rpc.CountingBloomFilter

Calculates the approximate probability of the contains() method returning true for an object that had not previously been inserted into the bloom filter.

expectedFalsePositiveProbability() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Calculates the approximate probability of the contains() method returning true for an object that had not previously been inserted into the bloom filter.

expectedLength(int) - Static method in class net.tomp2p.peers.PeerAddress

expectedLength() - Method in class net.tomp2p.peers.PeerAddress

expectedSocketLength(int) - Static method in class net.tomp2p.peers.PeerAddress

expiredCounter() - Method in class net.tomp2p.utils.ConcurrentCacheMap

ExternalAddressRequestMessage - Class in net.tomp2p.natpmp

This class manages an External Address message.

ExternalAddressRequestMessage(MessageResponseInterface) - Constructor for class net.tomp2p.natpmp.ExternalAddressRequestMessage

Constructs a new ExternalAddressRequestMessage.

extractContentKeys(Collection<Number480>) - Static method in class net.tomp2p.utils.Utils

F

failed(String) - Method in interface net.tomp2p.futures.FutureRunnable

A run() method that fails is very silent, thus we provide failed, which can be used to set a future to fail.

findContentForResponsiblePeerID(Number160) - Method in interface net.tomp2p.storage.ReplicationStorage

findContentForResponsiblePeerID(Number160) - Method in class net.tomp2p.storage.StorageDisk

findContentForResponsiblePeerID(Number160) - Method in class net.tomp2p.storage.StorageMemory

findContentForResponsiblePeerID(Number160) - Method in class net.tomp2p.storage.StorageMemoryReplication

findContentForResponsiblePeerID(Number160) - Method in class net.tomp2p.storage.TrackerStorage

findPeerIDForResponsibleContent(Number160) - Method in interface net.tomp2p.storage.ReplicationStorage

findPeerIDForResponsibleContent(Number160) - Method in class net.tomp2p.storage.StorageDisk

findPeerIDForResponsibleContent(Number160) - Method in class net.tomp2p.storage.StorageMemory

findPeerIDForResponsibleContent(Number160) - Method in class net.tomp2p.storage.StorageMemoryReplication

findPeerIDForResponsibleContent(Number160) - Method in class net.tomp2p.storage.TrackerStorage

finished() - Method in class net.tomp2p.message.Message

fireAndForgetTCP(ChannelCreator) - Method in class net.tomp2p.rpc.RequestHandlerTCP

fireAndForgetTCP(ChannelCreator, int) - Method in class net.tomp2p.rpc.RequestHandlerTCP

fireAndForgetUDP(ChannelCreator) - Method in class net.tomp2p.rpc.RequestHandlerUDP

fireTCP(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

fireUDP(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

FIXED_14_4 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Same as r8 but no more than 14 digits to the left of the decimal point and no more than 4 to the right.

FIXED_14_4_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

FLOAT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Floating point number.

FLOAT_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

floatValue() - Method in class net.tomp2p.peers.Number160

floatValue() - Method in class net.tomp2p.peers.Number320

floatValue() - Method in class net.tomp2p.peers.Number480

flush(boolean) - Method in class net.tomp2p.message.ProtocolChunkedInput

format(LogRecord) - Method in class net.tomp2p.utils.LogFormatter

forwardMessage(Message) - Method in class net.tomp2p.rpc.ReplyHandler

friendlyName - Variable in class net.tomp2p.upnp.Device

fromInteger(int) - Static method in class net.tomp2p.utils.Utils

Returns an Inet4Address having the integer value specified by the argument.

FUTURE_DHT_SHUTDOWN - Static variable in class net.tomp2p.p2p.builder.DHTBuilder

FUTURE_TRACKER_SHUTDOWN - Static variable in class net.tomp2p.p2p.builder.TrackerBuilder

FutureAsyncTask - Class in net.tomp2p.futures

A future to keep track of a future task.

FutureAsyncTask(PeerAddress) - Constructor for class net.tomp2p.futures.FutureAsyncTask

Constructor

FutureBootstrap - Interface in net.tomp2p.futures

Used for bootstrapping.

FutureChannel - Class in net.tomp2p.futures

Keeps track of the creation of a UDP or TCP channel.

FutureChannel() - Constructor for class net.tomp2p.futures.FutureChannel

Constructor.

FutureChannelCreator - Class in net.tomp2p.futures

This future is used for the connection reservation.

FutureChannelCreator() - Constructor for class net.tomp2p.futures.FutureChannelCreator

futureChannelCreator - Variable in class net.tomp2p.p2p.builder.DHTBuilder

futureChannelCreator - Variable in class net.tomp2p.p2p.builder.TrackerBuilder

FutureCleanup - Interface in net.tomp2p.futures

Some futures have a longer life span than others.

FutureCreate<K extends BaseFuture> - Interface in net.tomp2p.futures

DHT and Tracker operations may occur repeatedly.

futureCreate - Variable in class net.tomp2p.p2p.builder.DHTBuilder

FutureCreator<K extends BaseFuture> - Interface in net.tomp2p.futures

For direct replication, the DHT needs to be created repeatedly.

FutureDHT - Class in net.tomp2p.futures

The future object for the get() and put() operations including routing.

FutureDHT() - Constructor for class net.tomp2p.futures.FutureDHT

FutureDHT(int, EvaluatingSchemeDHT, FutureCreate<FutureDHT>) - Constructor for class net.tomp2p.futures.FutureDHT

Creates a new DHT future object that keeps track of the status of the DHT operations.

FutureDiscover - Class in net.tomp2p.futures

The future that keeps track of network discovery such as discovery if its behind a NAT, the status if UPNP or NAT-PMP could be established, if there is portforwarding.

FutureDiscover() - Constructor for class net.tomp2p.futures.FutureDiscover

FutureForkJoin<K extends BaseFuture> - Class in net.tomp2p.futures

The key future for recursive loops.

FutureForkJoin(K...) - Constructor for class net.tomp2p.futures.FutureForkJoin

Facade if we expect everything to return successfully

FutureForkJoin(int, boolean, K...) - Constructor for class net.tomp2p.futures.FutureForkJoin

Create a future fork join object

FutureLateJoin<K extends BaseFuture> - Class in net.tomp2p.futures

FutureLateJoin is similar to FutureForkJoin.

FutureLateJoin(int) - Constructor for class net.tomp2p.futures.FutureLateJoin

Create this future and set the minSuccess to the number of expected futures.

FutureLateJoin(int, int) - Constructor for class net.tomp2p.futures.FutureLateJoin

Create this future.

FutureLaterJoin<K extends BaseFuture> - Class in net.tomp2p.futures

FutureLaterJoin is similar to FutureLateJoin.

FutureLaterJoin() - Constructor for class net.tomp2p.futures.FutureLaterJoin

Create this future.

FutureResponse - Class in net.tomp2p.futures

Each response has one request messages.

FutureResponse(Message) - Constructor for class net.tomp2p.futures.FutureResponse

Create the future and set the request message

FutureResponse(Message, boolean) - Constructor for class net.tomp2p.futures.FutureResponse

FutureResponse(Message, FutureSuccessEvaluator) - Constructor for class net.tomp2p.futures.FutureResponse

FutureResponse(Message, FutureSuccessEvaluator, boolean) - Constructor for class net.tomp2p.futures.FutureResponse

Create the future and set the request message

FutureRouting - Class in net.tomp2p.futures

The routing future keeps track of the routing process.

FutureRouting() - Constructor for class net.tomp2p.futures.FutureRouting

FutureRunnable - Interface in net.tomp2p.futures

A future runnable is used for running futures in the background (in a different thread)

FutureSuccessEvaluator - Interface in net.tomp2p.futures

FutureSuccessEvaluatorCommunication - Class in net.tomp2p.futures

The communication future success evaluator returns OK if the communication was successful, otherwise it returns FAILED.

FutureSuccessEvaluatorCommunication() - Constructor for class net.tomp2p.futures.FutureSuccessEvaluatorCommunication

FutureSuccessEvaluatorOperation - Class in net.tomp2p.futures

The operation future success evaluator returns OK if the operation was successful, otherwise it returns FAILED.

FutureSuccessEvaluatorOperation() - Constructor for class net.tomp2p.futures.FutureSuccessEvaluatorOperation

FutureTask - Class in net.tomp2p.futures

This future keeps track of one or more tasks send to remote peers.

FutureTask() - Constructor for class net.tomp2p.futures.FutureTask

FutureTracker - Class in net.tomp2p.futures

This class holds the object for future results from the tracker get() and add().

FutureTracker() - Constructor for class net.tomp2p.futures.FutureTracker

FutureTracker(FutureCreate<BaseFuture>) - Constructor for class net.tomp2p.futures.FutureTracker

Create a future object for storing

FutureTracker(EvaluatingSchemeTracker, Set<Number160>) - Constructor for class net.tomp2p.futures.FutureTracker

Create a future object for retrieving.

FutureWrappedBootstrap<K extends BaseFuture> - Class in net.tomp2p.futures

The bootstrap will be a wrapped future, because we need to ping a server first, and if this ping is successful, we can bootstrap.

FutureWrappedBootstrap() - Constructor for class net.tomp2p.futures.FutureWrappedBootstrap

FutureWrapper<K extends BaseFuture> - Class in net.tomp2p.futures

Wraps a future into an other future.

FutureWrapper() - Constructor for class net.tomp2p.futures.FutureWrapper

G

Gateway - Class in net.tomp2p.natpmp

Gateway() - Constructor for class net.tomp2p.natpmp.Gateway

get(Number160, Number160, Collection<Number160>, SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>, RoutingConfiguration, RequestP2PConfiguration, EvaluatingSchemeDHT, boolean, boolean, boolean, boolean, boolean, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedHashTable

get(Number160) - Method in class net.tomp2p.p2p.Peer

get(PeerAddress, Number160, Number160, Collection<Number160>, SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>, boolean, boolean, boolean, boolean, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.StorageRPC

Get the data from a remote peer.

get(Number160, Number160, Number160) - Method in interface net.tomp2p.storage.Storage

get(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageDisk

get(Number160, Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageGeneric

get(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageMemory

get(Object) - Method in class net.tomp2p.utils.ConcurrentCacheMap

getAbortCause() - Method in exception net.tomp2p.connection.PeerException

getActionArgument(String) - Method in class net.tomp2p.upnp.Action

Look for an Argument for a given name

getAddresses() - Method in class net.tomp2p.connection.Bindings

getAll() - Method in class net.tomp2p.peers.PeerMap

Return all addresses from the neighbor list.

getAsyncTask() - Method in class net.tomp2p.p2p.Peer

getAtLeastEntriesFromTrackers() - Method in class net.tomp2p.p2p.TrackerConfiguration

getAtLeastSucessfulRequestes() - Method in class net.tomp2p.p2p.TrackerConfiguration

getAttachement() - Method in class net.tomp2p.futures.FutureDHT

getAttachement() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getAttachement() - Method in class net.tomp2p.storage.TrackerData

getAvailableActionsName() - Method in class net.tomp2p.upnp.Service

getAvailableActionsSize() - Method in class net.tomp2p.upnp.Service

getAvailableStateVariableName() - Method in class net.tomp2p.upnp.Service

getAvailableStateVariableSize() - Method in class net.tomp2p.upnp.Service

getAvgGap() - Method in class net.tomp2p.p2p.Statistics

getAvgStoredKeys() - Method in class net.tomp2p.futures.FutureDHT

getBagSize() - Method in class net.tomp2p.p2p.PeerMaker

getBindings() - Method in class net.tomp2p.p2p.Peer

getBindings() - Method in class net.tomp2p.p2p.PeerMaker

getBitSet() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Returns the bitset that backs the bloom filter

getBloomFilter() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getBloomFilter1() - Method in class net.tomp2p.message.Message

getBloomFilter2() - Method in class net.tomp2p.message.Message

getBootstrapTo() - Method in interface net.tomp2p.futures.FutureBootstrap

Returns the Peers we bootstrapped in no particular order.

getBootstrapTo() - Method in class net.tomp2p.futures.FutureWrappedBootstrap

Returns a list of of peers that were involved in the bootstrapping

getBootstrapTo() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getBroadcastAddresses() - Method in class net.tomp2p.connection.Bindings

getBroadcastCounter() - Method in class net.tomp2p.p2p.DefaultBroadcastHandler

getBroadcastHandler() - Method in class net.tomp2p.p2p.PeerMaker

getBroadcastHandler() - Method in class net.tomp2p.rpc.BroadcastRPC

getBroadcastRPC() - Method in class net.tomp2p.p2p.Peer

getBuffer() - Method in class net.tomp2p.futures.FutureResponse

Returns the raw buffer or null if the answer was empty.

getBuffer() - Method in class net.tomp2p.p2p.builder.SendBuilder

getBuffer() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

GetBuilder - Class in net.tomp2p.p2p.builder

GetBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.GetBuilder

getCacheSize() - Method in class net.tomp2p.p2p.PeerMaker

getCacheTimeoutMillis() - Method in class net.tomp2p.p2p.PeerMaker

getChannel() - Method in class net.tomp2p.futures.FutureChannel

getChannelBuffer() - Method in class net.tomp2p.futures.FutureDHT

Return the data from send_direct (Netty buffer) after evaluation.

getChannelCreator() - Method in class net.tomp2p.connection.PeerConnection

getChannelCreator() - Method in class net.tomp2p.futures.FutureChannelCreator

getChannelFuture() - Method in class net.tomp2p.futures.FutureChannel

getChannelGroup() - Method in class net.tomp2p.connection.ConnectionBean

getChecked(PeerAddress) - Method in class net.tomp2p.peers.PeerMapStat

getChecked() - Method in class net.tomp2p.peers.PeerStat

getChildDevice(String) - Method in class net.tomp2p.upnp.Device

Looks for a child UPNP device definition file, the whole devices tree will be searched, starting from the current device node.

getChildDevices() - Method in class net.tomp2p.upnp.Device

Generates a list of all the child ( not only top level, full childrens hierarchy included ) UPNPDevice objects for this device.

getCommand() - Method in class net.tomp2p.message.Message

Command of the message, such as GET, PING, etc.

getCompleted() - Method in class net.tomp2p.futures.FutureForkJoin

Returns a list of evaluated futures.

getConfiguration() - Method in class net.tomp2p.connection.ConnectionBean

getConfiguration() - Method in class net.tomp2p.p2p.Peer

getConfiguration() - Method in class net.tomp2p.p2p.PeerMaker

getConnection() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

getConnectionBean() - Method in class net.tomp2p.connection.ConnectionHandler

getConnectionBean() - Method in class net.tomp2p.p2p.Peer

getConnectionBean() - Method in class net.tomp2p.rpc.ReplyHandler

getConnectionHandler() - Method in class net.tomp2p.p2p.Peer

getConnectionReservation() - Method in class net.tomp2p.connection.ConnectionBean

getConnectTimeoutMillis() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getContentBloomFilter(int, int) - Method in class net.tomp2p.rpc.DigestInfo

getContentBloomFilter() - Method in class net.tomp2p.rpc.DigestResult

getContentDigest() - Method in class net.tomp2p.rpc.DigestInfo

getContentKey() - Method in class net.tomp2p.p2p.builder.GetBuilder

getContentKey() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

getContentKey() - Method in class net.tomp2p.peers.Number480

getContentKeys() - Method in class net.tomp2p.p2p.builder.GetBuilder

getContentKeys() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

getContentType1() - Method in class net.tomp2p.message.Message

Returns first content type.

getContentType2() - Method in class net.tomp2p.message.Message

Returns second content type, only if first is not empty

getContentType3() - Method in class net.tomp2p.message.Message

Returns second content type, only if first is not empty

getContentType4() - Method in class net.tomp2p.message.Message

Returns second content type, only if first is not empty

getCreated() - Method in class net.tomp2p.peers.PeerStat

getCreated() - Method in class net.tomp2p.storage.Data

getCreatorThread() - Method in class net.tomp2p.connection.ChannelCreator

getCurrentPermits() - Method in class net.tomp2p.connection.ChannelCreator

getData() - Method in class net.tomp2p.futures.FutureDHT

getData() - Method in class net.tomp2p.p2p.builder.AddBuilder

getData() - Method in class net.tomp2p.p2p.builder.PutBuilder

getData() - Method in class net.tomp2p.rpc.HashData

getData() - Method in class net.tomp2p.storage.Data

getDataMap() - Method in class net.tomp2p.futures.FutureAsyncTask

getDataMap() - Method in class net.tomp2p.futures.FutureDHT

Return the data from get() after evaluation.

getDataMap() - Method in class net.tomp2p.message.Message

getDataMap() - Method in class net.tomp2p.p2p.builder.BroadcastBuilder

getDataMap() - Method in class net.tomp2p.p2p.builder.PutBuilder

getDataMap() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

getDataMap480() - Method in class net.tomp2p.message.Message

getDataSet() - Method in class net.tomp2p.p2p.builder.AddBuilder

getDataTypeAsClass() - Method in class net.tomp2p.upnp.StateVariable

The variable JAVA data type (using an UPNP->Java mapping)

getDefaultDirectReplication() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getDefaultDirectReplication() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getDefaultPEX() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getDestination() - Method in class net.tomp2p.connection.PeerConnection

getDetailErrorCode() - Method in exception net.tomp2p.upnp.UPNPResponseException

getDetailErrorDescription() - Method in exception net.tomp2p.upnp.UPNPResponseException

getDeviceDefinitionXML() - Method in class net.tomp2p.upnp.RootDevice

Retrieves the device definition XML data

getDevices(int) - Static method in class net.tomp2p.upnp.InternetGatewayDevice

Lookup all the IGD (IP or PPP) devices on the network.

getDevices(int, int, int, NetworkInterface) - Static method in class net.tomp2p.upnp.InternetGatewayDevice

Lookup all the IGD (IP urn:schemas-upnp-org:service:WANIPConnection:1, or PPP urn:schemas-upnp-org:service:WANPPPConnection:1) devices for a given network interface.

getDigest() - Method in class net.tomp2p.futures.FutureDHT

Return the digest information from the get() after evaluation.

getDigests() - Method in class net.tomp2p.rpc.DigestInfo

getDirectDataRPC() - Method in class net.tomp2p.p2p.Peer

getDirectHits() - Method in class net.tomp2p.futures.FutureRouting

The direct hits set contains those peers that reported to have the key (Number160) we were looking for.

getDirectHits() - Method in class net.tomp2p.p2p.RoutingConfiguration

getDirectHitsDigest() - Method in class net.tomp2p.futures.FutureRouting

The direct hits map contains those peers that reported to have the key (Number160) we were looking for including its digest (size of the result set and its xored hashes).

getDirectParent() - Method in class net.tomp2p.upnp.Device

Return the parent UPNPDevice, null if the device is an UPNPRootDevice

getDirectTrackers() - Method in class net.tomp2p.futures.FutureTracker

getDiscoverTimeoutSec() - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

getDiscoverTimeoutSec() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getDiscoveryUDN() - Method in class net.tomp2p.upnp.RootDevice

getDiscoveryUSN() - Method in class net.tomp2p.upnp.RootDevice

getDispatcherRequest() - Method in class net.tomp2p.connection.ConnectionBean

getDistributedHashMap() - Method in class net.tomp2p.p2p.Peer

getDistributedRouting() - Method in class net.tomp2p.p2p.Peer

getDistributedTask() - Method in class net.tomp2p.p2p.Peer

getDistributedTracker() - Method in class net.tomp2p.p2p.Peer

getDomainKey() - Method in class net.tomp2p.futures.FutureDHT

getDomainKey() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getDomainKey() - Method in class net.tomp2p.p2p.builder.TrackerBuilder

getDomainKey() - Method in class net.tomp2p.peers.Number320

getDomainKey() - Method in class net.tomp2p.peers.Number480

getEstimatedNumberOfNodes() - Method in class net.tomp2p.p2p.Statistics

getEvalKeys() - Method in class net.tomp2p.futures.FutureDHT

Returns the keys that have been stored or removed after evaluation.

getEvaluatingScheme() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

getEvaluationScheme() - Method in class net.tomp2p.p2p.builder.GetBuilder

getExpectedElements() - Method in class net.tomp2p.rpc.CountingBloomFilter

Returns the expected elements that was provided by the user.

getExpectedElements() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Returns the expected elements that was provided by the user.

getExpirationMillis() - Method in class net.tomp2p.storage.Data

getExternalAddress() - Method in class net.tomp2p.connection.Bindings

getExternalAddress() - Method in class net.tomp2p.natpmp.ExternalAddressRequestMessage

Gets the NAT-PMP gateway's external address.

getExternalIPAddress() - Method in class net.tomp2p.upnp.InternetGatewayDevice

Retrieves the external IP address

getExternalPort() - Method in class net.tomp2p.natpmp.MapRequestMessage

Gets the external port that was assigned.

getFaildeReason() - Method in class net.tomp2p.task.TaskStatus

getFailedReason() - Method in interface net.tomp2p.futures.BaseFuture

The default failed reason is Unknown.

getFailedReason() - Method in class net.tomp2p.futures.BaseFutureImpl

getFailedReason() - Method in class net.tomp2p.futures.FutureForkJoin

getFailedReason() - Method in class net.tomp2p.futures.FutureRouting

getFailureCount() - Method in class net.tomp2p.futures.FutureTask

getFaultCode() - Method in exception net.tomp2p.upnp.UPNPResponseException

getFaultString() - Method in exception net.tomp2p.upnp.UPNPResponseException

getFileMessageLogger() - Method in class net.tomp2p.p2p.PeerMaker

getFinished() - Method in class net.tomp2p.message.Message

getFoundAddresses() - Method in class net.tomp2p.connection.Bindings

Returns a list of InetAddresses to listen to.

getFromTracker(Number160, Number160, RoutingConfiguration, TrackerConfiguration, boolean, EvaluatingSchemeTracker, boolean, boolean, Set<Number160>, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedTracker

getFromTracker(PeerAddress, Number160, Number160, boolean, boolean, Set<Number160>, ChannelCreator) - Method in class net.tomp2p.rpc.TrackerRPC

getFromTracker(PeerAddress, Number160, Number160, boolean, boolean, Set<Number160>, ChannelCreator, boolean, boolean) - Method in class net.tomp2p.rpc.TrackerRPC

getFutureChannelCreator() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getFutureChannelCreator() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

getFutureChannelCreator() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

getFutureChannelCreator() - Method in class net.tomp2p.p2p.builder.TrackerBuilder

getFutureCreate() - Method in class net.tomp2p.futures.FutureDHT

Returns the future object that keeps information about future object, based on this object

getFutureCreate() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getFutureCreate() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getFutureRequests() - Method in class net.tomp2p.futures.FutureDHT

Returns back those futures that are still running.

getFutureResponse() - Method in class net.tomp2p.rpc.RequestHandlerTCP

getFutureResponse() - Method in class net.tomp2p.rpc.RequestHandlerUDP

getFutureRouting() - Method in class net.tomp2p.futures.FutureDHT

Returns the future object that was used for the routing.

getFuturesDone() - Method in class net.tomp2p.futures.FutureLateJoin

Returns the finished futures.

getFuturesDone() - Method in class net.tomp2p.futures.FutureLaterJoin

Returns the finished futures.

getGenericPortMappingEntry(int) - Method in class net.tomp2p.upnp.InternetGatewayDevice

Retrieves a generic port mapping entry.

getHandshakeRPC() - Method in class net.tomp2p.p2p.Peer

getHash() - Method in class net.tomp2p.rpc.HashData

getHash() - Method in class net.tomp2p.storage.Data

getHashDataMap() - Method in class net.tomp2p.message.Message

getId() - Method in class net.tomp2p.message.MessageID

Returns the message Id

getID() - Method in class net.tomp2p.peers.PeerAddress

The id of the peer.

getIdleTCPMillis() - Method in class net.tomp2p.connection.PeerConnection

getIdleTCPMillis() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getIdleUDPMillis() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getIGDRootDevice() - Method in class net.tomp2p.upnp.InternetGatewayDevice

Retrieves the IDG UNPNRootDevice object

getInetAddress() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getInetAddress() - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

getInetAddress() - Method in class net.tomp2p.p2p.builder.PingBuilder

getInetAddress() - Method in class net.tomp2p.peers.PeerAddress

Returns the address or null if no address set

getInputActionArgument(String) - Method in class net.tomp2p.upnp.Action

Look for an input ServiceActionArgument for a given name

getInputActionArguments() - Method in class net.tomp2p.upnp.Action

Return a list containing input ( when a response is sent ) arguments objects

getInteger() - Method in class net.tomp2p.message.Message

getInterfaces() - Method in class net.tomp2p.connection.Bindings

getInternalPort() - Method in class net.tomp2p.natpmp.MapRequestMessage

Gets the internal port on which mapped data will arrive.

getIntSet() - Method in class net.tomp2p.rpc.CountingBloomFilter

Returns the bitset that backs the bloom filter

getIP() - Static method in class net.tomp2p.natpmp.Gateway

getIsoDate(Date) - Static method in class net.tomp2p.upnp.ISO8601Date

Generate a ISO 8601 date

getIsoDateTime(Date) - Static method in class net.tomp2p.upnp.ISO8601Date

Generate a ISO 8601 date time without timezone

getIsoDateTimeZone(Date) - Static method in class net.tomp2p.upnp.ISO8601Date

Generate a ISO 8601 date time with timezone

getIsoTime(Date) - Static method in class net.tomp2p.upnp.ISO8601Date

Generate a ISO 8601 time

getIsoTimeZone(Date) - Static method in class net.tomp2p.upnp.ISO8601Date

Generate a ISO 8601 time

getKey() - Method in class net.tomp2p.message.Message

getKeyBloomFilter() - Method in class net.tomp2p.p2p.builder.GetBuilder

getKeyBloomFilter(int, int) - Method in class net.tomp2p.rpc.DigestInfo

getKeyBloomFilter() - Method in class net.tomp2p.rpc.DigestResult

getKeyDigest() - Method in class net.tomp2p.rpc.DigestInfo

getKeyDigest() - Method in class net.tomp2p.rpc.DigestResult

getKeyKey1() - Method in class net.tomp2p.message.Message

getKeyKey2() - Method in class net.tomp2p.message.Message

getKeyMap() - Method in class net.tomp2p.message.Message

getKeyPair() - Method in class net.tomp2p.connection.PeerBean

getKeyPair() - Method in class net.tomp2p.p2p.PeerMaker

getKeys() - Method in class net.tomp2p.futures.FutureDHT

Deprecated.

getKeys() - Method in class net.tomp2p.message.Message

getKeys480() - Method in class net.tomp2p.message.Message

getKnownPeers() - Method in class net.tomp2p.futures.FutureTracker

getKnownPeers() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

getLast() - Method in class net.tomp2p.futures.FutureForkJoin

Returns the last evaluated future.

getLast(List<K>) - Static method in class net.tomp2p.utils.Utils

getLastSeenOnline() - Method in class net.tomp2p.peers.PeerStat

getLastSeenOnlineTime(PeerAddress) - Method in class net.tomp2p.peers.PeerMapStat

getLastSuceessFuture() - Method in class net.tomp2p.futures.FutureLateJoin

getLastSuceessFuture() - Method in class net.tomp2p.futures.FutureLaterJoin

getLength() - Method in class net.tomp2p.message.Message

The length of the payload

getLength() - Method in class net.tomp2p.storage.Data

getLength() - Method in class net.tomp2p.storage.TrackerData

getListeners() - Method in class net.tomp2p.p2p.Peer

getLocalIP() - Method in class net.tomp2p.upnp.RootDevice

getLocalizedMessage() - Method in exception net.tomp2p.upnp.UPNPResponseException

getLocationKey() - Method in class net.tomp2p.futures.FutureDHT

getLocationKey() - Method in class net.tomp2p.peers.Number320

getLocationKey() - Method in class net.tomp2p.peers.Number480

getLockNumber160() - Method in class net.tomp2p.storage.StorageGeneric

getLockNumber320() - Method in class net.tomp2p.storage.StorageGeneric

getLockNumber480() - Method in class net.tomp2p.storage.StorageGeneric

getLockStorage() - Method in class net.tomp2p.storage.StorageGeneric

getLong() - Method in class net.tomp2p.message.Message

getMaintenanceThreads() - Method in class net.tomp2p.p2p.PeerMaker

getMapAcceptHandler() - Method in class net.tomp2p.p2p.PeerMaker

getMasterPeer() - Method in class net.tomp2p.p2p.PeerMaker

getMaxCreating() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getMaxFailure() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

getMaxFailure() - Method in class net.tomp2p.p2p.TrackerConfiguration

getMaxFailures() - Method in class net.tomp2p.p2p.RoutingConfiguration

getMaxFullTrackers() - Method in class net.tomp2p.p2p.TrackerConfiguration

getMaxMessageSize() - Method in class net.tomp2p.p2p.PeerMaker

getMaxNoNewInfo(int) - Method in class net.tomp2p.p2p.RoutingConfiguration

getMaxNoNewInfoDiff() - Method in class net.tomp2p.p2p.RoutingConfiguration

This returns the difference to the min value of P2P configuration.

getMaxNrBeforeExclude() - Method in class net.tomp2p.p2p.PeerMaker

getMaxOpenConnection() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getMaxPrimaryTrackers() - Method in class net.tomp2p.p2p.TrackerConfiguration

getMaxSuccess() - Method in class net.tomp2p.p2p.RoutingConfiguration

getMessage(String) - Method in class net.tomp2p.upnp.UPNPMessageFactory

Creation of a new ActionMessage to communicate with the UPNP device

getMessage() - Method in exception net.tomp2p.upnp.UPNPResponseException

getMessageId() - Method in class net.tomp2p.message.Message

Randomly generated message ID

getMinimumResults() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

getName() - Method in class net.tomp2p.connection.ChannelCreator

getName() - Method in class net.tomp2p.upnp.Action

The action name

getNatMappingsCount() - Method in class net.tomp2p.upnp.InternetGatewayDevice

Retrieves the current number of mapping in the NAT table

getNATUtils() - Method in class net.tomp2p.connection.ConnectionHandler

getNeighborRPC() - Method in class net.tomp2p.p2p.Peer

getNeighbors() - Method in class net.tomp2p.message.Message

Returns the stored neighbors

getNodeAddress() - Method in class net.tomp2p.message.MessageID

The node address of sender or recipient

getNumber1() - Method in class net.tomp2p.message.SHA1Signature

getNumber2() - Method in class net.tomp2p.message.SHA1Signature

getObject() - Method in class net.tomp2p.futures.FutureDHT

Return the data from send_direct (Object) after evaluation.

getObject() - Method in class net.tomp2p.futures.FutureResponse

Returns the object or null if the underlying buffer was raw or the answer was empty.

getObject() - Method in class net.tomp2p.p2p.builder.SendBuilder

getObject() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

getObject() - Method in class net.tomp2p.storage.Data

getOffset() - Method in class net.tomp2p.storage.Data

getOffset() - Method in class net.tomp2p.storage.TrackerData

getOperation() - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

getOptions() - Method in class net.tomp2p.message.Message

getOptions() - Method in class net.tomp2p.peers.PeerAddress

getOutActionArgument(String) - Method in class net.tomp2p.upnp.ActionResponse

getOutActionArgumentNames() - Method in class net.tomp2p.upnp.ActionResponse

getOutActionArgumentValue(String) - Method in class net.tomp2p.upnp.ActionResponse

getOutputActionArgument(String) - Method in class net.tomp2p.upnp.Action

Look for an output Argument for a given name

getOutputActionArguments() - Method in class net.tomp2p.upnp.Action

Return a list containing output ( when a response is received ) arguments objects

getOutsideTCPPort() - Method in class net.tomp2p.connection.Bindings

getOutsideUDPPort() - Method in class net.tomp2p.connection.Bindings

getP2PID() - Method in class net.tomp2p.connection.ConnectionBean

getP2PID() - Method in class net.tomp2p.p2p.Peer

getP2PId() - Method in class net.tomp2p.p2p.PeerMaker

getParallel() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

getParallel() - Method in class net.tomp2p.p2p.RoutingConfiguration

getParallel() - Method in class net.tomp2p.p2p.TrackerConfiguration

getParallelDiff() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

getPayload1() - Method in class net.tomp2p.message.Message

getPayload2() - Method in class net.tomp2p.message.Message

getPeer() - Method in class net.tomp2p.connection.PeerBean

getPeerAddress() - Method in class net.tomp2p.futures.FutureDiscover

The peerAddress where we are reachable

getPeerAddress() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getPeerAddress() - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

getPeerAddress() - Method in class net.tomp2p.p2p.builder.PingBuilder

getPeerAddress() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

Deprecated.

getPeerAddress() - Method in class net.tomp2p.p2p.IdentityManagement

getPeerAddress() - Method in class net.tomp2p.p2p.Peer

getPeerAddress() - Method in class net.tomp2p.rpc.StorageRPC

getPeerAddress() - Method in class net.tomp2p.rpc.TrackerRPC

getPeerAddress() - Method in class net.tomp2p.storage.TrackerData

getPeerBean() - Method in class net.tomp2p.connection.ConnectionHandler

getPeerBean() - Method in class net.tomp2p.p2p.Peer

getPeerBean() - Method in class net.tomp2p.rpc.ReplyHandler

getPeerExchangeRPC() - Method in class net.tomp2p.p2p.Peer

getPeerID() - Method in class net.tomp2p.p2p.Peer

getPeerId() - Method in class net.tomp2p.storage.Data

getPeerMap() - Method in class net.tomp2p.connection.PeerBean

getPeerMap() - Method in class net.tomp2p.rpc.RequestHandlerTCP

getPeerMap() - Method in class net.tomp2p.rpc.RequestHandlerUDP

getPeersOnTracker() - Method in class net.tomp2p.futures.FutureTracker

getPendingFutures() - Method in class net.tomp2p.p2p.Peer

getPermits() - Method in class net.tomp2p.connection.ChannelCreator

getPexWaitSec() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getPort() - Method in class net.tomp2p.p2p.builder.PingBuilder

getPortMappingLifetime() - Method in class net.tomp2p.natpmp.MapRequestMessage

Gets the assigned port mapping lifetime.

getPortTCP() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getPortTCP() - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

getPortUDP() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getPortUDP() - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

getPotentialHits() - Method in class net.tomp2p.futures.FutureRouting

The potential hits set contains those peers that are in the direct hit and that did report to *not* have the key (Number160) we were looking for.

getPotentialTrackers() - Method in class net.tomp2p.futures.FutureTracker

getPrimanyFactor() - Method in class net.tomp2p.storage.TrackerStorage

getProtectionDomainEnable() - Method in class net.tomp2p.storage.StorageGeneric

getProtectionDomainMode() - Method in class net.tomp2p.storage.StorageGeneric

getProtectionEntryEnable() - Method in class net.tomp2p.storage.StorageGeneric

getProtectionEntryMode() - Method in class net.tomp2p.storage.StorageGeneric

getProtocol() - Method in class net.tomp2p.connection.Bindings

getPublicKey() - Method in class net.tomp2p.message.Message

getPublicKey() - Method in class net.tomp2p.storage.Data

getQueue() - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

getQueuePosition() - Method in class net.tomp2p.task.TaskStatus

getQuitRPC() - Method in class net.tomp2p.p2p.Peer

getRandom() - Method in class net.tomp2p.p2p.PeerMaker

getRawData() - Method in class net.tomp2p.futures.FutureDHT

Returns the raw data from the get operation

getRawDataMap() - Method in class net.tomp2p.futures.FutureTask

getRawDigest() - Method in class net.tomp2p.futures.FutureDHT

getRawDirectData1() - Method in class net.tomp2p.futures.FutureDHT

Return raw data from send_dircet (Netty buffer).

getRawDirectData2() - Method in class net.tomp2p.futures.FutureDHT

Return raw data from send_dircet (Object).

getRawKeys() - Method in class net.tomp2p.futures.FutureDHT

Returns the raw keys from the storage or removal operation

getRawKeys480() - Method in class net.tomp2p.futures.FutureDHT

getRawPeersOnTracker() - Method in class net.tomp2p.futures.FutureTracker

getRecipient() - Method in class net.tomp2p.message.Message

The ID of the recipient.

getRecipient() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

getReferrer() - Method in class net.tomp2p.storage.TrackerData

getRefreshSeconds() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getRelatedStateVariable() - Method in class net.tomp2p.upnp.Argument

The related service state variable for this ServiceActionArgument

getRemotePeer() - Method in class net.tomp2p.futures.FutureAsyncTask

getRemotePeer() - Method in class net.tomp2p.rpc.CacheKey

getRepetitions() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

getRepetitions() - Method in class net.tomp2p.p2p.builder.SendBuilder

getReplicationRefreshMillis() - Method in class net.tomp2p.p2p.PeerMaker

getReplicationStorage() - Method in class net.tomp2p.connection.PeerBean

getReplicationThreads() - Method in class net.tomp2p.p2p.PeerMaker

getReplicationTracker() - Method in class net.tomp2p.connection.PeerBean

getReporter() - Method in class net.tomp2p.futures.FutureDiscover

getRequest() - Method in class net.tomp2p.futures.FutureResponse

The future response always keeps a reference to the request.

getRequestedExternalPort() - Method in class net.tomp2p.natpmp.MapRequestMessage

Get sthe external port that was requested.

getRequestedPortMappingLifetime() - Method in class net.tomp2p.natpmp.MapRequestMessage

Gets the requested port mapping lifetime.

getRequestP2PConfiguration() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getRequestP2PConfiguration() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getRequestP2PConfiguration() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

getReservation() - Method in class net.tomp2p.connection.ConnectionReservation

getResponse() - Method in class net.tomp2p.futures.FutureResponse

Returns the response message.

getResponseException() - Method in class net.tomp2p.natpmp.Message

Gets the excpetion associated with the response.

getResultCode() - Method in class net.tomp2p.natpmp.Message

Gets the result code.

getRoutingConfiguration() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

getRoutingConfiguration() - Method in class net.tomp2p.p2p.builder.DHTBuilder

getRoutingConfiguration() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

getRoutingConfiguration() - Method in class net.tomp2p.p2p.builder.TrackerBuilder

getRoutingPath() - Method in class net.tomp2p.futures.FutureRouting

Returns the peers that have been asked to provide neighbor information.

getSCDPData() - Method in class net.tomp2p.upnp.Service

getScheduledExecutorServiceMaintenance() - Method in class net.tomp2p.connection.Scheduler

getScheduledExecutorServiceReplication() - Method in class net.tomp2p.connection.Scheduler

getScheduledFutures() - Method in class net.tomp2p.p2p.Peer

getScheduler() - Method in class net.tomp2p.connection.ConnectionBean

getSecondaryFactor() - Method in class net.tomp2p.storage.TrackerStorage

getSecondsSinceEpoch() - Method in class net.tomp2p.natpmp.Message

Gets the seconds since epoch as received from the NAT-PMP gateway.

getSelf() - Method in class net.tomp2p.p2p.IdentityManagement

getSender() - Method in class net.tomp2p.connection.ConnectionBean

getSender() - Method in class net.tomp2p.message.Message

The ID of the sender.

getSenderCacheStrategy() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

getServerPeerAddress() - Method in class net.tomp2p.connection.PeerBean

getService(String) - Method in class net.tomp2p.upnp.Device

Looks for a UPNP device service definition object for the given service URI (Type)

getServiceByID(String) - Method in class net.tomp2p.upnp.Device

Looks for a UPNP device service definition object for the given service ID

getServices(String) - Method in class net.tomp2p.upnp.Device

Looks for the all the UPNP device service definition object for the current UPNP device object.

getSize() - Method in class net.tomp2p.rpc.DigestInfo

getSocketAddressSize() - Method in class net.tomp2p.peers.PeerAddress

getSpecificPortMappingEntry(String, int, String) - Method in class net.tomp2p.upnp.InternetGatewayDevice

Retrieves information about a specific port mapping

getSpecVersionMajor() - Method in class net.tomp2p.upnp.RootDevice

getSpecVersionMajor() - Method in class net.tomp2p.upnp.Service

getSpecVersionMinor() - Method in class net.tomp2p.upnp.RootDevice

getSpecVersionMinor() - Method in class net.tomp2p.upnp.Service

getStateVariableMessage(String) - Method in class net.tomp2p.upnp.UPNPMessageFactory

Creation of a new StateVariableMessage to communicate with the UPNP device, for a service state variable query

getStateVariableValue() - Method in class net.tomp2p.upnp.StateVariableResponse

getStatistics() - Method in class net.tomp2p.connection.PeerBean

getStatistics() - Method in class net.tomp2p.peers.PeerMap

getStatus() - Method in class net.tomp2p.task.TaskStatus

getStorage() - Method in class net.tomp2p.connection.PeerBean

getStorage() - Method in class net.tomp2p.p2p.PeerMaker

getStoreRPC() - Method in class net.tomp2p.p2p.Peer

getSuccessCount() - Method in class net.tomp2p.futures.FutureTask

getSuccessCounter() - Method in class net.tomp2p.futures.FutureForkJoin

Returns the number of successful finished futures

getTaskManager() - Method in class net.tomp2p.connection.PeerBean

getTaskRPC() - Method in class net.tomp2p.p2p.Peer

getTaskRPC() - Method in class net.tomp2p.task.TaskManager

getTCPChannelCount() - Method in class net.tomp2p.p2p.Statistics

getTCPChannelCreationCount() - Method in class net.tomp2p.p2p.Statistics

getTcpPort() - Method in class net.tomp2p.p2p.PeerMaker

getTimer() - Method in class net.tomp2p.p2p.Peer

getTracker(Number160) - Method in class net.tomp2p.p2p.Peer

GetTrackerBuilder - Class in net.tomp2p.p2p.builder

GetTrackerBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.GetTrackerBuilder

getTrackerConfiguration() - Method in class net.tomp2p.p2p.builder.TrackerBuilder

getTrackerData() - Method in class net.tomp2p.message.Message

getTrackerRPC() - Method in class net.tomp2p.p2p.Peer

getTrackers() - Method in class net.tomp2p.futures.FutureTracker

Evaluates the data from the trackers.

getTrackerStorage() - Method in class net.tomp2p.connection.PeerBean

getTrackerTimeoutSec() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

getTrackerTimoutSeconds() - Method in class net.tomp2p.p2p.ConnectionConfiguration

getTrackerTimoutSeconds() - Method in class net.tomp2p.storage.TrackerStorage

getTTLSeconds() - Method in class net.tomp2p.storage.Data

getType() - Method in interface net.tomp2p.futures.BaseFuture

If the type is not OK, then something unexpected happened.

getType() - Method in class net.tomp2p.futures.BaseFutureImpl

getType() - Method in class net.tomp2p.message.Message

Determines if its a request oCommandr reply, and what kind of reply (error, warning states)

getType() - Method in class net.tomp2p.rpc.CacheKey

getUDPChannelCount() - Method in class net.tomp2p.p2p.Statistics

getUDPChannelCreationCount() - Method in class net.tomp2p.p2p.Statistics

getUdpPort() - Method in class net.tomp2p.p2p.PeerMaker

getUPNPServiceAction(String) - Method in class net.tomp2p.upnp.Service

Retrieves a service action for its given name

getUPNPServiceStateVariable(String) - Method in class net.tomp2p.upnp.Service

Retrieves a service state variable for its given name

getURL(String, URL) - Static method in class net.tomp2p.upnp.Device

Parsing an URL from the descriptionXML file

getValidityTime() - Method in class net.tomp2p.upnp.RootDevice

The validity time for this device in milliseconds,

getValue() - Method in class net.tomp2p.upnp.StateVariable

Call to the UPNP device to retrieve the state variable actual value

getValueBloomFilter() - Method in class net.tomp2p.p2p.builder.GetBuilder

getVendorFirmware() - Method in class net.tomp2p.upnp.RootDevice

getVersion() - Method in class net.tomp2p.message.Message

Returns the version, which is 32bit.

getWaitingTimeBetweenNodeMaintenenceSeconds() - Method in class net.tomp2p.p2p.PeerMaker

getWorkerThreads() - Method in class net.tomp2p.p2p.PeerMaker

getWrappedFuture() - Method in class net.tomp2p.futures.FutureWrapper

getXML(URL) - Static method in class net.tomp2p.upnp.XMLUtil

Fetches the xml, fixes any wonky characters in it

getXMLString(URL) - Static method in class net.tomp2p.upnp.XMLUtil

H

handleDownstream(ChannelHandlerContext, ChannelEvent) - Method in class net.tomp2p.message.TomP2PEncoderTCP

handleDownstream(ChannelHandlerContext, ChannelEvent) - Method in class net.tomp2p.message.TomP2PEncoderUDP

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.BroadcastRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.DirectDataRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.HandshakeRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.NeighborRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.PeerExchangeRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.QuitRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.ReplyHandler

If the message is OK, that has been previously checked by the user using checkMessage, a reply to the message is generated here.

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.StorageRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.TaskRPC

handleResponse(Message, boolean) - Method in class net.tomp2p.rpc.TrackerRPC

handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class net.tomp2p.connection.MessageLogger

handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class net.tomp2p.message.TomP2PDecoderUDP

HandshakeRPC - Class in net.tomp2p.rpc

HandshakeRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.HandshakeRPC

HandshakeRPC(PeerBean, ConnectionBean, List<PeerListener>) - Constructor for class net.tomp2p.rpc.HandshakeRPC

hasContent() - Method in class net.tomp2p.message.Message

hashCode() - Method in class net.tomp2p.message.MessageID

hashCode() - Method in class net.tomp2p.peers.Number160

hashCode() - Method in class net.tomp2p.peers.Number320

hashCode() - Method in class net.tomp2p.peers.Number480

hashCode() - Method in class net.tomp2p.peers.PeerAddress

hashCode() - Method in class net.tomp2p.rpc.CacheKey

hashCode() - Method in class net.tomp2p.rpc.CountingBloomFilter

hashCode() - Method in class net.tomp2p.rpc.DigestInfo

hashCode() - Method in class net.tomp2p.rpc.DigestResult

hashCode() - Method in class net.tomp2p.rpc.SimpleBloomFilter

hashCode() - Method in class net.tomp2p.storage.TrackerData

hashCode() - Method in class net.tomp2p.utils.ConcurrentCacheMap

HashData - Class in net.tomp2p.rpc

A bean that stores a hash and data.

HashData(Number160, Data) - Constructor for class net.tomp2p.rpc.HashData

hasNextChunk() - Method in class net.tomp2p.message.ProtocolChunkedInput

hasObjectDataReply() - Method in class net.tomp2p.rpc.DirectDataRPC

hasRawDataReply() - Method in class net.tomp2p.rpc.DirectDataRPC

HEADER_SIZE - Static variable in class net.tomp2p.message.MessageCodec

I

I1 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

1 Byte int.

I1_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

I2 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

2 Byte int.

I2_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

I4 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

4 Byte int.

I4_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

IdentityManagement - Class in net.tomp2p.p2p

IdentityManagement(PeerAddress) - Constructor for class net.tomp2p.p2p.IdentityManagement

incChecked(PeerAddress) - Method in class net.tomp2p.peers.PeerMapStat

incChecked() - Method in class net.tomp2p.peers.PeerStat

incrementTCPChannelCreation() - Method in class net.tomp2p.p2p.Statistics

incrementUDPChannelCreation() - Method in class net.tomp2p.p2p.Statistics

init(TaskRPC) - Method in class net.tomp2p.task.TaskManager

insert() - Method in interface net.tomp2p.examples.ws.Service

insert() - Method in class net.tomp2p.examples.ws.ServiceImpl

INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Fixed point, integer number.

INT_ARRAY_SIZE - Static variable in class net.tomp2p.peers.Number160

INT_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

interMediateResponse(FutureResponse) - Method in interface net.tomp2p.p2p.DistributedHashTable.Operation

InternetGatewayDevice - Class in net.tomp2p.upnp

This class can be used to access some functionalities on the InternetGatewayDevice on your network without having to know anything about the required input/output parameters.

intToByteArray(int, int, byte[]) - Static method in class net.tomp2p.rpc.SimpleBloomFilter

intToByteArray(int) - Static method in class net.tomp2p.utils.Utils

intValue() - Method in class net.tomp2p.peers.Number160

intValue() - Method in class net.tomp2p.peers.Number320

intValue() - Method in class net.tomp2p.peers.Number480

isAcquired() - Method in class net.tomp2p.futures.FutureChannel

isAll() - Method in class net.tomp2p.p2p.builder.GetBuilder

isAll() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

isAllAddresses() - Method in class net.tomp2p.connection.Bindings

isAllInterfaces() - Method in class net.tomp2p.connection.Bindings

isAllProtocols() - Method in class net.tomp2p.connection.Bindings

isBehindFirewall() - Method in class net.tomp2p.p2p.ConnectionConfiguration

isBehindFirewallPeerMap() - Method in class net.tomp2p.p2p.PeerMaker

Deprecated.

isBroadcast() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

isBroadcast() - Method in class net.tomp2p.p2p.builder.PingBuilder

isCancelOnFinish() - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

isCancelOnFinish() - Method in class net.tomp2p.p2p.builder.SendBuilder

isClosed() - Method in class net.tomp2p.connection.PeerConnection

isCloser(Number160, PeerAddress, PeerAddress) - Method in class net.tomp2p.peers.PeerMap

Returns -1 if the first remote node is closer to the key, if the second is closer, then 1 is returned.

isCloser(Number160, Number160, Number160) - Method in class net.tomp2p.peers.PeerMap

Returns -1 if the first key is closer to the key, if the second is closer, then 1 is returned.

isCompleted() - Method in interface net.tomp2p.futures.BaseFuture

Checks if the asynchronous operation is finished.

isCompleted() - Method in class net.tomp2p.futures.BaseFutureImpl

isConvertNumber480to160() - Method in class net.tomp2p.message.Message

isDigest() - Method in class net.tomp2p.p2p.builder.GetBuilder

isDirectReplication() - Method in class net.tomp2p.p2p.builder.DHTBuilder

isDirectReplication() - Method in class net.tomp2p.storage.Data

isDisableBind() - Method in class net.tomp2p.p2p.ConnectionConfiguration

isDiscoveredTCP() - Method in class net.tomp2p.futures.FutureDiscover

Checks if this peer can be reached via TCP.

isDiscoveredUDP() - Method in class net.tomp2p.futures.FutureDiscover

Checks if this peer can be reached via UDP.

isDomainProtectedByOthers(Number160, Number160, PublicKey) - Method in interface net.tomp2p.storage.Storage

isDomainProtectedByOthers(Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.StorageDisk

isDomainProtectedByOthers(Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.StorageMemory

isEmpty() - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

isEmpty() - Method in class net.tomp2p.rpc.DigestInfo

isEmpty() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

isEmpty() - Method in class net.tomp2p.utils.ConcurrentCacheMap

isEnableBroadcast() - Method in class net.tomp2p.p2p.PeerMaker

isEnableDHT() - Method in class net.tomp2p.p2p.PeerMaker

isEnableDirectDataRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnableHandShakeRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnableIndirectReplication() - Method in class net.tomp2p.p2p.PeerMaker

isEnableMaintenance() - Method in class net.tomp2p.p2p.PeerMaker

isEnableNeighborRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnablePeerExchangeRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnableQuitRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnableRouting() - Method in class net.tomp2p.p2p.PeerMaker

isEnableStorageRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnableTask() - Method in class net.tomp2p.p2p.PeerMaker

isEnableTaskRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEnableTracker() - Method in class net.tomp2p.p2p.PeerMaker

isEnableTrackerRPC() - Method in class net.tomp2p.p2p.PeerMaker

isEndOfInput() - Method in class net.tomp2p.message.ProtocolChunkedInput

isError() - Method in class net.tomp2p.message.Message

isError(Message.Type) - Static method in class net.tomp2p.message.Message

isExpectAttachement() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

isExternalAddress() - Method in class net.tomp2p.connection.Bindings

isFailed() - Method in interface net.tomp2p.futures.BaseFuture

Checks if operation has failed.

isFailed() - Method in class net.tomp2p.futures.BaseFutureImpl

isFileReference() - Method in class net.tomp2p.storage.Data

isFillPrimaryStorageFast() - Method in class net.tomp2p.storage.TrackerStorage

isFireAndForget() - Method in class net.tomp2p.message.Message

isFirewalledTCP(int) - Static method in class net.tomp2p.peers.PeerAddress

isFirewalledTCP() - Method in class net.tomp2p.peers.PeerAddress

isFirewalledUDP(int) - Static method in class net.tomp2p.peers.PeerAddress

isFirewalledUDP() - Method in class net.tomp2p.peers.PeerAddress

isForceRoutingOnlyToSelf() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

isForceStorageUDP() - Method in class net.tomp2p.p2p.ConnectionConfiguration

isForceTCP() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

isForceTCP() - Method in class net.tomp2p.p2p.RoutingConfiguration

isForceTCP() - Method in class net.tomp2p.p2p.TrackerConfiguration

isForceTrackerTCP() - Method in class net.tomp2p.p2p.ConnectionConfiguration

isForceUPD() - Method in class net.tomp2p.p2p.RequestP2PConfiguration

isForceUPD() - Method in class net.tomp2p.p2p.TrackerConfiguration

isHintSign() - Method in class net.tomp2p.message.Message

isIPv4() - Method in class net.tomp2p.connection.Bindings

isIPv4() - Method in class net.tomp2p.peers.PeerAddress

isIPv6() - Method in class net.tomp2p.connection.Bindings

isIPv6() - Method in class net.tomp2p.peers.PeerAddress

isKadCloser(Number160, PeerAddress, PeerAddress) - Static method in class net.tomp2p.peers.PeerMap

Returns -1 if the first remote node is closer to the key, if the secondBITS is closer, then 1 is returned.

isKeepAlive() - Method in class net.tomp2p.message.Message

isKeepAliveAndReuse() - Method in class net.tomp2p.connection.ChannelCreator

isLimitTracker() - Method in class net.tomp2p.p2p.ConnectionConfiguration

isList() - Method in class net.tomp2p.p2p.builder.AddBuilder

isListenAll() - Method in class net.tomp2p.connection.Bindings

isListening() - Method in class net.tomp2p.connection.ConnectionHandler

isListening() - Method in class net.tomp2p.p2p.Peer

isManualCleanup() - Method in class net.tomp2p.p2p.builder.DHTBuilder

isManualCleanup() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

isMessageSign() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

isMessageTooLargeForUDP() - Method in class net.tomp2p.p2p.builder.GetBuilder

Check if the message size exceeds the UDP size.

isMinReached() - Method in class net.tomp2p.futures.FutureDHT

Checks if the minimum of expected results have been reached.

isNet6(int) - Static method in class net.tomp2p.peers.PeerAddress

isNotOk() - Method in class net.tomp2p.message.Message

ISO8601Date - Class in net.tomp2p.upnp

ISO8601 Date implementation taken from org.w3c package and modified to work with UPNP date types

ISO8601Date() - Constructor for class net.tomp2p.upnp.ISO8601Date

isOk() - Method in class net.tomp2p.message.Message

isPeerRemovedTemporarly(PeerAddress) - Method in class net.tomp2p.peers.PeerMap

Checks if this peer has been removed.

isPrimary(FutureResponse) - Static method in class net.tomp2p.rpc.TrackerRPC

isProtectDomain() - Method in class net.tomp2p.p2p.builder.DHTBuilder

isProtectedEntry() - Method in class net.tomp2p.storage.Data

isPutIfAbsent() - Method in class net.tomp2p.p2p.builder.PutBuilder

isRange() - Method in class net.tomp2p.p2p.builder.GetBuilder

isReleaseEarly() - Method in class net.tomp2p.futures.FutureDHT

isReplicationEnabled() - Method in class net.tomp2p.replication.Replication

isRequest() - Method in class net.tomp2p.message.Message

isReturnBloomFilter() - Method in class net.tomp2p.p2p.builder.GetBuilder

isReturnResults() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

isRunning() - Method in class net.tomp2p.p2p.Peer

isSecondary(FutureResponse) - Static method in class net.tomp2p.rpc.TrackerRPC

isSecondaryTracker(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

A peer is a secondary tracker if the peers stores itself on the tracker as well.

isSetExternalPortsManually() - Method in class net.tomp2p.connection.Bindings

isShared() - Method in class net.tomp2p.futures.FutureResponse

isShutdown() - Method in class net.tomp2p.natpmp.NatPmpDevice

Flag indicates if this NatPmpDevice is shutdown.

isShutdown() - Method in class net.tomp2p.p2p.Peer

Returns true if shutdown has been initiated

isSignMessage() - Method in class net.tomp2p.p2p.builder.DHTBuilder

isSignMessage() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

isSignMessage() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

isSignMessage() - Method in class net.tomp2p.rpc.CacheKey

isSuccess() - Method in interface net.tomp2p.futures.BaseFuture

Returns the opposite of isFailed (returns !isFailed).

isSuccess() - Method in class net.tomp2p.futures.BaseFutureImpl

isTcpPEX() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

isTcpPing() - Method in class net.tomp2p.p2p.builder.PingBuilder

isUDP() - Method in class net.tomp2p.message.Message

isUDP() - Method in class net.tomp2p.p2p.builder.BroadcastBuilder

isUseSecondaryTrackers() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

isZero() - Method in class net.tomp2p.peers.Number160

Checks if this number is zero

iterator() - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

iterator() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

K

keepTrack(PeerAddress, Number160, TaskResultListener) - Method in class net.tomp2p.connection.Scheduler

KeyLock<K> - Class in net.tomp2p.storage

KeyLock() - Constructor for class net.tomp2p.storage.KeyLock

keySet() - Method in class net.tomp2p.utils.ConcurrentCacheMap

L

limit(Collection<K>, int) - Static method in class net.tomp2p.utils.Utils

limit(Map<K, V>, int) - Static method in class net.tomp2p.utils.Utils

limitRandom(Map<Number160, TrackerData>, int) - Static method in class net.tomp2p.utils.Utils

loadFile(File) - Static method in class net.tomp2p.utils.Utils

locationKey - Variable in class net.tomp2p.p2p.builder.DHTBuilder

locationKey - Variable in class net.tomp2p.p2p.builder.TrackerBuilder

lock - Variable in class net.tomp2p.futures.BaseFutureImpl

lock(K) - Method in class net.tomp2p.storage.KeyLock

LogFormatter - Class in net.tomp2p.utils

LogFormatter() - Constructor for class net.tomp2p.utils.LogFormatter

longValue() - Method in class net.tomp2p.peers.Number160

longValue() - Method in class net.tomp2p.peers.Number320

longValue() - Method in class net.tomp2p.peers.Number480

M

main(String[]) - Static method in class net.tomp2p.examples.ExampleBloomFilter

main(String[]) - Static method in class net.tomp2p.examples.ExampleBootstrap

Starts the boostrap example.

main(String[]) - Static method in class net.tomp2p.examples.ExampleCache

main(String[]) - Static method in class net.tomp2p.examples.ExampleConsistency

main(String[]) - Static method in class net.tomp2p.examples.ExampleDHT

main(String[]) - Static method in class net.tomp2p.examples.ExampleDirectReplication

main(String[]) - Static method in class net.tomp2p.examples.ExampleDiscover

main(String[]) - Static method in class net.tomp2p.examples.ExampleDNS

main(String[]) - Static method in class net.tomp2p.examples.ExampleDST

main(String[]) - Static method in class net.tomp2p.examples.ExampleFastSS

main(String[]) - Static method in class net.tomp2p.examples.ExampleHashMap

main(String[]) - Static method in class net.tomp2p.examples.ExampleIndirectReplication

main(String[]) - Static method in class net.tomp2p.examples.ExampleMapReduce

main(String[]) - Static method in class net.tomp2p.examples.ExampleMultiColumn

main(String[]) - Static method in class net.tomp2p.examples.ExampleNAT

main(String[]) - Static method in class net.tomp2p.examples.ExampleNATChat

main(String[]) - Static method in class net.tomp2p.examples.ExamplePersistentConnection

main(String[]) - Static method in class net.tomp2p.examples.ExamplePutGet

main(String[]) - Static method in class net.tomp2p.examples.ExampleSecurity

main(String[]) - Static method in class net.tomp2p.examples.ExampleSend

main(String[]) - Static method in class net.tomp2p.examples.ExampleTracker

main(String[]) - Static method in class net.tomp2p.examples.ExampleUnQL

main(String[]) - Static method in class net.tomp2p.examples.ws.ExampleWSJSON

Maintenance - Class in net.tomp2p.p2p

Maintenance() - Constructor for class net.tomp2p.p2p.Maintenance

makeAndListen() - Method in class net.tomp2p.p2p.PeerMaker

makeSHAHash(File) - Static method in class net.tomp2p.utils.Utils

makeSHAHash(String) - Static method in class net.tomp2p.utils.Utils

makeSHAHash(ByteBuffer) - Static method in class net.tomp2p.utils.Utils

makeSHAHash(byte[]) - Static method in class net.tomp2p.utils.Utils

makeSHAHash(byte[], int, int) - Static method in class net.tomp2p.utils.Utils

manualCleanup - Variable in class net.tomp2p.p2p.builder.DHTBuilder

manualCleanup() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

manufacturer - Variable in class net.tomp2p.upnp.Device

manufacturerURL - Variable in class net.tomp2p.upnp.Device

map() - Method in interface net.tomp2p.storage.Storage

The storage is typically backed by multiple Java collections (HashMap, TreeMap, etc.).

map() - Method in class net.tomp2p.storage.StorageDisk

map() - Method in class net.tomp2p.storage.StorageMemory

MapAcceptHandler - Interface in net.tomp2p.peers

mapPMP(int, int, int, int) - Method in class net.tomp2p.connection.NATUtils

Maps with the PMP protocol (http://en.wikipedia.org/wiki/NAT_Port_Mapping_Protocol).

MapRequestMessage - Class in net.tomp2p.natpmp

This class manages an External Address message.

MapRequestMessage(boolean, int, int, int, MessageResponseInterface) - Constructor for class net.tomp2p.natpmp.MapRequestMessage

Constructs a new MapRequestMessage.

mapUPNP(String, int, int, int, int) - Method in class net.tomp2p.connection.NATUtils

Maps with UPNP protocol (http://en.wikipedia.org/wiki/Internet_Gateway_Device_Protocol).

max() - Method in class net.tomp2p.peers.Number320

MAX_BYTE - Static variable in class net.tomp2p.message.MessageCodec

MAX_ENTRIES - Static variable in class net.tomp2p.utils.ConcurrentCacheMap

Max.

MAX_MSG_SIZE_UDP - Static variable in class net.tomp2p.rpc.TrackerRPC

MAX_PORT - Static variable in class net.tomp2p.connection.Bindings

aeu

MAX_VALUE - Static variable in class net.tomp2p.peers.Number160

maximumRangeValue - Variable in class net.tomp2p.upnp.StateVariable

The maximum value as a string

meResponsible(Number160) - Method in class net.tomp2p.replication.DefaultStorageReplication

meResponsible(Number160) - Method in interface net.tomp2p.replication.ResponsibilityListener

meResponsible(Number160) - Method in class net.tomp2p.replication.TrackerStorageReplication

merge(SimpleBloomFilter<E>) - Method in class net.tomp2p.rpc.SimpleBloomFilter

meshPeers(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

Message - Class in net.tomp2p.message

The message is in binary format in TomP2P.

Message() - Constructor for class net.tomp2p.message.Message

Creates message with a random ID

Message - Class in net.tomp2p.natpmp

The message class manages a message that is being sent to a NAT-PMP gateway.

Message.Command - Enum in net.tomp2p.message

Message.Content - Enum in net.tomp2p.message

Message.Type - Enum in net.tomp2p.message

MessageCodec - Class in net.tomp2p.message

MessageCodec() - Constructor for class net.tomp2p.message.MessageCodec

MessageID - Class in net.tomp2p.message

A message ID consists of the message id, which is created randomly and the nodeaddress.

MessageID(Message) - Constructor for class net.tomp2p.message.MessageID

Creates a message Id.

MessageLogger - Class in net.tomp2p.connection

Prints the received message to a gzip encoded file.

MessageLogger(File) - Constructor for class net.tomp2p.connection.MessageLogger

Creates a new message logger that outputs the received messages in a gzipped file.

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class net.tomp2p.connection.DispatcherReply

Called if we get a message

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class net.tomp2p.connection.PerformanceFilter

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class net.tomp2p.connection.ReplyTimeoutHandler

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class net.tomp2p.rpc.RequestHandlerTCP

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class net.tomp2p.rpc.RequestHandlerUDP

MessageResponseInterface - Interface in net.tomp2p.natpmp

This interface defines methods that are used for message responses.

min() - Method in class net.tomp2p.peers.Number320

MIN_DYN_PORT - Static variable in class net.tomp2p.connection.Bindings

IANA recommends to use ports higher than 49152

minimumRangeValue - Variable in class net.tomp2p.upnp.StateVariable

The minimum value as a string

modelDescription - Variable in class net.tomp2p.upnp.Device

modelName - Variable in class net.tomp2p.upnp.Device

modelNumber - Variable in class net.tomp2p.upnp.Device

modelURL - Variable in class net.tomp2p.upnp.Device

moveFromSecondaryToMesh(PeerAddress, PeerAddress, Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.TrackerStorage

MultiByteBufferInputStream - Class in net.tomp2p.utils

MultiByteBufferInputStream(ChannelBuffer) - Constructor for class net.tomp2p.utils.MultiByteBufferInputStream

N

name - Variable in class net.tomp2p.upnp.Action

name - Variable in class net.tomp2p.upnp.Argument

name - Variable in class net.tomp2p.upnp.StateVariable

State variable name

NatPmpDevice - Class in net.tomp2p.natpmp

This class manages a NAT-PMP device.

NatPmpDevice(InetAddress) - Constructor for class net.tomp2p.natpmp.NatPmpDevice

Constructs a new NatPmpDevice.

NatPmpException - Exception in net.tomp2p.natpmp

This class is used for exceptions specific to jNAT-PMPlib.

NATUtils - Class in net.tomp2p.connection

This class is used to do automatic port forwarding.

NATUtils() - Constructor for class net.tomp2p.connection.NATUtils

Constructor.

NEIGHBOR_SIZE - Static variable in class net.tomp2p.rpc.NeighborRPC

NeighborRPC - Class in net.tomp2p.rpc

NeighborRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.NeighborRPC

net.tomp2p.connection - package net.tomp2p.connection

net.tomp2p.examples - package net.tomp2p.examples

net.tomp2p.examples.ws - package net.tomp2p.examples.ws

net.tomp2p.futures - package net.tomp2p.futures

net.tomp2p.message - package net.tomp2p.message

net.tomp2p.natpmp - package net.tomp2p.natpmp

net.tomp2p.p2p - package net.tomp2p.p2p

net.tomp2p.p2p.builder - package net.tomp2p.p2p.builder

net.tomp2p.peers - package net.tomp2p.peers

net.tomp2p.replication - package net.tomp2p.replication

net.tomp2p.rpc - package net.tomp2p.rpc

net.tomp2p.storage - package net.tomp2p.storage

net.tomp2p.task - package net.tomp2p.task

net.tomp2p.upnp - package net.tomp2p.upnp

net.tomp2p.utils - package net.tomp2p.utils

nextChunk() - Method in class net.tomp2p.message.ProtocolChunkedInput

noResponseReceived(Message) - Method in interface net.tomp2p.natpmp.MessageResponseInterface

No response was received.

notifyListeners(Number320, Map<Number160, Data>) - Method in class net.tomp2p.task.TaskManager

notifyListerenrs() - Method in class net.tomp2p.futures.BaseFutureImpl

Always call this from outside synchronized(lock)!

notifyOnShutdown() - Method in interface net.tomp2p.p2p.PeerListener

notifyOnStart() - Method in interface net.tomp2p.p2p.PeerListener

nullCheck(Object...) - Static method in class net.tomp2p.utils.Utils

nullCheckRetVal(Object...) - Static method in class net.tomp2p.utils.Utils

NUMBER - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Same as r8.

Number160 - Class in net.tomp2p.peers

This class represents a 160 bit number.

Number160() - Constructor for class net.tomp2p.peers.Number160

Create a Key with value 0.

Number160(ShortString) - Constructor for class net.tomp2p.peers.Number160

Number160(int...) - Constructor for class net.tomp2p.peers.Number160

Create an instance with an integer array.

Number160(String) - Constructor for class net.tomp2p.peers.Number160

Create a Key from a string.

Number160(int) - Constructor for class net.tomp2p.peers.Number160

Creates a Key with the integer value

Number160(long) - Constructor for class net.tomp2p.peers.Number160

Number160(byte[]) - Constructor for class net.tomp2p.peers.Number160

Creates a new Key using the byte array.

Number160(byte[], int, int) - Constructor for class net.tomp2p.peers.Number160

Creates a new Key using the byte array.

Number160(Random) - Constructor for class net.tomp2p.peers.Number160

Creates a new Key with random values in it.

Number320 - Class in net.tomp2p.peers

Number320(Number160, Number160) - Constructor for class net.tomp2p.peers.Number320

Number480 - Class in net.tomp2p.peers

Number480(Number160, Number160, Number160) - Constructor for class net.tomp2p.peers.Number480

Number480(Number320, Number160) - Constructor for class net.tomp2p.peers.Number480

NUMBER_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

O

ObjectDataReply - Interface in net.tomp2p.rpc

offset() - Method in class net.tomp2p.peers.PeerAddress

When deserializing, we need to know how much we deserialized from the constructor call.

ONE - Static variable in class net.tomp2p.peers.Number160

online(PeerAddress) - Method in class net.tomp2p.peers.PeerMapStat

onlineTime() - Method in class net.tomp2p.peers.PeerStat

operationComplete(F) - Method in interface net.tomp2p.futures.BaseFutureListener

Invoked when the operation associated with the BaseFuture has been completed.

otherResponsible(Number160, PeerAddress) - Method in class net.tomp2p.replication.DefaultStorageReplication

otherResponsible(Number160, PeerAddress) - Method in interface net.tomp2p.replication.ResponsibilityListener

otherResponsible(Number160, PeerAddress) - Method in class net.tomp2p.replication.TrackerStorageReplication

P

parallelRequest(Number160) - Method in class net.tomp2p.p2p.Peer

ParallelRequestBuilder - Class in net.tomp2p.p2p.builder

ParallelRequestBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.ParallelRequestBuilder

parallelRequests(RequestP2PConfiguration, NavigableSet<PeerAddress>, boolean, FutureChannelCreator, ConnectionReservation, boolean, DistributedHashTable.Operation) - Method in class net.tomp2p.p2p.DistributedHashTable

Creates RPCs and executes them parallel.

parent - Variable in class net.tomp2p.upnp.Action

parent - Variable in class net.tomp2p.upnp.Device

parent - Variable in class net.tomp2p.upnp.StateVariable

The parent Service Object

parse(String) - Static method in class net.tomp2p.upnp.ISO8601Date

Parse the given string in ISO 8601 format and build a Date object.

peer - Variable in class net.tomp2p.p2p.builder.DHTBuilder

peer - Variable in class net.tomp2p.p2p.builder.TrackerBuilder

Peer - Class in net.tomp2p.p2p

TomP2P implements besides the following distributed hash table (DHT) operations: value=get(locationKey) put(locationKey,value) remove(locationKey) also the following operations: value=get(locationKey,contentKey) put(locationKey,contentKey,value) remove(locationKey,contentKey) The advantage of TomP2P is that multiple values can be stored in one location.

PeerAddress - Class in net.tomp2p.peers

A PeerAddress contains the node ID and how to contact this node using both TCP and UDP.

PeerAddress(byte[]) - Constructor for class net.tomp2p.peers.PeerAddress

Creates a new peeraddress, where the byte array has to be in the rigth format and in the right size.

PeerAddress(byte[], int) - Constructor for class net.tomp2p.peers.PeerAddress

Creates a PeerAddress from a continuous byte array.

PeerAddress(Number160, ChannelBuffer) - Constructor for class net.tomp2p.peers.PeerAddress

PeerAddress(Number160, byte[], int) - Constructor for class net.tomp2p.peers.PeerAddress

PeerAddress(byte[], byte[]) - Constructor for class net.tomp2p.peers.PeerAddress

The format of the peer address can also be split.

PeerAddress(Number160) - Constructor for class net.tomp2p.peers.PeerAddress

If you only need to know the id

PeerAddress(Number160, InetAddress) - Constructor for class net.tomp2p.peers.PeerAddress

If you only need to know the id and InetAddress

PeerAddress(Number160, InetAddress, int, int, boolean, boolean) - Constructor for class net.tomp2p.peers.PeerAddress

Creates a PeerAddress

PeerAddress(Number160, InetAddress, int, int) - Constructor for class net.tomp2p.peers.PeerAddress

PeerAddress(Number160, String, int, int) - Constructor for class net.tomp2p.peers.PeerAddress

PeerAddress(Number160, InetSocketAddress) - Constructor for class net.tomp2p.peers.PeerAddress

PeerAddress(Number160, PeerAddress) - Constructor for class net.tomp2p.peers.PeerAddress

PeerAddress(Number160, InetAddress, int, int, int) - Constructor for class net.tomp2p.peers.PeerAddress

PeerBean - Class in net.tomp2p.connection

A bean that holds non-sharable (unique for each peer) configuration settings for the peer.

PeerBean(KeyPair) - Constructor for class net.tomp2p.connection.PeerBean

Creates a bean with a key pair.

PeerConnection - Class in net.tomp2p.connection

This is a handle for permanent connections.

PeerConnection(PeerAddress, ConnectionReservation, ChannelCreator, int) - Constructor for class net.tomp2p.connection.PeerConnection

PeerException - Exception in net.tomp2p.connection

This exception is used internally and passed over to the method exceptionCaught.

PeerException(PeerException.AbortCause, String) - Constructor for exception net.tomp2p.connection.PeerException

Specified error with custom message

PeerException.AbortCause - Enum in net.tomp2p.connection

USER_ABORT means that this peer aborts the communication.

peerExchange(PeerAddress, Number160, Number160, boolean, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.PeerExchangeRPC

Peer exchange (PEX) information about other peers from the swarm, to not ask the primary trackers too often.

PeerExchangeRPC - Class in net.tomp2p.rpc

PeerExchangeRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.PeerExchangeRPC

peerFail(PeerAddress, boolean) - Method in class net.tomp2p.p2p.IdentityManagement

peerFail(PeerAddress, boolean) - Method in interface net.tomp2p.peers.PeerStatusListener

Called if the peer does not send answer in time.

peerFail(PeerAddress, boolean) - Method in class net.tomp2p.storage.TrackerStorage

peerFound(PeerAddress, PeerAddress) - Method in class net.tomp2p.peers.PeerMap

Adds a neighbor to the neighbor list.

peerInserted(PeerAddress) - Method in interface net.tomp2p.peers.PeerMapChangeListener

This method is called if a peer is added to the map

peerInserted(PeerAddress) - Method in class net.tomp2p.replication.Replication

PeerListener - Interface in net.tomp2p.p2p

PeerMaker - Class in net.tomp2p.p2p

PeerMaker(Number160) - Constructor for class net.tomp2p.p2p.PeerMaker

PeerMaker(KeyPair) - Constructor for class net.tomp2p.p2p.PeerMaker

PeerMap - Class in net.tomp2p.peers

This routing implementation uses is based on Kademlia.

PeerMap(Number160, int, int, int, int[], int, boolean) - Constructor for class net.tomp2p.peers.PeerMap

Deprecated.

PeerMap(Number160, int, int, int, int[], int, MapAcceptHandler) - Constructor for class net.tomp2p.peers.PeerMap

Creates the bag for the peers.

PeerMapChangeListener - Interface in net.tomp2p.peers

This interface can be added to the map, to get notified of peer insertion or removal.

PeerMapStat - Class in net.tomp2p.peers

PeerMapStat() - Constructor for class net.tomp2p.peers.PeerMapStat

peerOffline(PeerAddress, PeerStatusListener.Reason) - Method in class net.tomp2p.p2p.IdentityManagement

peerOffline(PeerAddress, boolean) - Method in class net.tomp2p.peers.PeerMap

Remove a peer from the list.

peerOffline(PeerAddress, PeerStatusListener.Reason) - Method in interface net.tomp2p.peers.PeerStatusListener

Called if the peer does not send multiple answer in time.

peerOffline(PeerAddress, PeerStatusListener.Reason) - Method in class net.tomp2p.storage.TrackerStorage

peerOnline(PeerAddress) - Method in class net.tomp2p.p2p.IdentityManagement

peerOnline(PeerAddress) - Method in interface net.tomp2p.peers.PeerStatusListener

Called if the peer is online and we verified it.

peerOnline(PeerAddress) - Method in class net.tomp2p.storage.TrackerStorage

peerRemoved(PeerAddress) - Method in interface net.tomp2p.peers.PeerMapChangeListener

This method is called if a peer is removed from the map

peerRemoved(PeerAddress) - Method in class net.tomp2p.replication.Replication

peersForMaintenance() - Method in class net.tomp2p.peers.PeerMap

PeerStat - Class in net.tomp2p.peers

PeerStat() - Constructor for class net.tomp2p.peers.PeerStat

PeerStatusListener - Interface in net.tomp2p.peers

PeerStatusListener.Reason - Enum in net.tomp2p.peers

The reason NOT_REACHABLE means that the peer is offline and cannot be contacted, while REMOVED_FROM_MAP means that this peer has been removed from the neigbhor list, but may still be reachable.

peerUpdated(PeerAddress) - Method in interface net.tomp2p.peers.PeerMapChangeListener

This method is called if a peer is updated.

peerUpdated(PeerAddress) - Method in class net.tomp2p.replication.Replication

PerformanceFilter - Class in net.tomp2p.connection

Measures the number of outgoing and incoming packets.

PerformanceFilter() - Constructor for class net.tomp2p.connection.PerformanceFilter

ping(InetSocketAddress) - Method in class net.tomp2p.p2p.builder.PingBuilder

Pings a peer.

ping(InetSocketAddress, boolean) - Method in class net.tomp2p.p2p.builder.PingBuilder

Pings a peer.

ping() - Method in class net.tomp2p.p2p.Peer

pingBroadcastUDP(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

PingBuilder - Class in net.tomp2p.p2p.builder

PingBuilder(Peer) - Constructor for class net.tomp2p.p2p.builder.PingBuilder

pingTCP(PeerAddress) - Method in class net.tomp2p.rpc.HandshakeRPC

pingTCP(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

pingTCPDiscover(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

pingTCPProbe(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

pingUDP(PeerAddress) - Method in class net.tomp2p.rpc.HandshakeRPC

pingUDP(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

pingUDPDiscover(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

pingUDPProbe(PeerAddress, ChannelCreator) - Method in class net.tomp2p.rpc.HandshakeRPC

pollRandom(Collection<K>, Random) - Static method in class net.tomp2p.utils.Utils

Returns a random element from a collection.

pollRandomKey(Map<K, V>, Random) - Static method in class net.tomp2p.utils.Utils

portTCP() - Method in class net.tomp2p.peers.PeerAddress

portUDP() - Method in class net.tomp2p.peers.PeerAddress

preBuild(String) - Method in class net.tomp2p.p2p.builder.DHTBuilder

preBuild(String) - Method in class net.tomp2p.p2p.builder.TrackerBuilder

prepareDeadLockCheck() - Method in class net.tomp2p.connection.DefaultReservation

prepareDeadLockCheck() - Method in interface net.tomp2p.connection.Reservation

prepareSend(PeerAddress, ChannelBuffer, boolean) - Method in class net.tomp2p.rpc.DirectDataRPC

Prepares for sending to a remote peer.

presentationURL - Variable in class net.tomp2p.upnp.Device

protectDomain - Variable in class net.tomp2p.p2p.builder.DHTBuilder

protectDomain(Number160, Number160, PublicKey) - Method in interface net.tomp2p.storage.Storage

protectDomain(Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.StorageDisk

protectDomain(Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.StorageMemory

ProtocolChunked - Interface in net.tomp2p.message

ProtocolChunkedInput - Class in net.tomp2p.message

ProtocolChunkedInput(ChannelHandlerContext, PrivateKey) - Constructor for class net.tomp2p.message.ProtocolChunkedInput

put(Number160, Number160, Map<Number160, Data>, RoutingConfiguration, RequestP2PConfiguration, boolean, boolean, boolean, boolean, FutureCreate<FutureDHT>, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedHashTable

put(Number160) - Method in class net.tomp2p.p2p.Peer

put(Number160, Number160) - Method in class net.tomp2p.rpc.DigestInfo

Stores a key and the hash of the content for further processing

put(PeerAddress, Number160, Number160, Map<Number160, Data>, boolean, boolean, boolean, ChannelCreator, boolean, SenderCacheStrategy) - Method in class net.tomp2p.rpc.StorageRPC

Stores data on a remote peer.

put(Number160, Number160, Number160, Data) - Method in interface net.tomp2p.storage.Storage

put(Number160, Number160, Number160, Data) - Method in class net.tomp2p.storage.StorageDisk

put(Number160, Number160, Number160, Data, PublicKey, boolean, boolean) - Method in class net.tomp2p.storage.StorageGeneric

put(Number160, Number160, Number160, Data) - Method in class net.tomp2p.storage.StorageMemory

put(Number160, Number160, PeerAddress, PublicKey, byte[]) - Method in class net.tomp2p.storage.TrackerStorage

put(Number160, Number160, PeerAddress, PublicKey, byte[], int, int) - Method in class net.tomp2p.storage.TrackerStorage

put(K, V) - Method in class net.tomp2p.utils.CacheMap

put(K, V) - Method in class net.tomp2p.utils.ConcurrentCacheMap

putAll(Map<? extends K, ? extends V>) - Method in class net.tomp2p.utils.ConcurrentCacheMap

PutBuilder - Class in net.tomp2p.p2p.builder

PutBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.PutBuilder

putIfAbsent(CacheKey, RequestHandlerTCP<FutureResponse>, ChannelCreator) - Method in class net.tomp2p.rpc.SenderCacheStrategy

putIfAbsent(PeerAddress, Number160, Number160, Map<Number160, Data>, boolean, boolean, boolean, ChannelCreator, boolean, SenderCacheStrategy) - Method in class net.tomp2p.rpc.StorageRPC

Stores data on a remote peer.

putIfAbsent(K, V) - Method in class net.tomp2p.utils.CacheMap

If the key is not associated with a value, associate it with the value.

putIfAbsent(K, V) - Method in class net.tomp2p.utils.ConcurrentCacheMap

putReferred(Number160, Number160, PeerAddress, PeerAddress, byte[], int, int, TrackerStorage.ReferrerType) - Method in class net.tomp2p.storage.TrackerStorage

Q

query() - Method in interface net.tomp2p.examples.ws.Service

query() - Method in class net.tomp2p.examples.ws.ServiceImpl

quit(PeerAddress, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.QuitRPC

Sends a message that indicates this peer is about to quit.

QuitRPC - Class in net.tomp2p.rpc

QuitRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.QuitRPC

R

R4 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

4 Byte float.

R4_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

R8 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

8 Byte float.

R8_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

RawDataReply - Interface in net.tomp2p.rpc

read() - Method in class net.tomp2p.utils.MultiByteBufferInputStream

read(byte[], int, int) - Method in class net.tomp2p.utils.MultiByteBufferInputStream

readBytes() - Method in class net.tomp2p.peers.PeerAddress

reason - Variable in class net.tomp2p.futures.BaseFutureImpl

receive(Number160, Map<Number160, Data>, int, boolean) - Method in interface net.tomp2p.p2p.BroadcastHandler

receive(Number160, Map<Number160, Data>, int, boolean) - Method in class net.tomp2p.p2p.DefaultBroadcastHandler

refreshSeconds - Variable in class net.tomp2p.p2p.builder.DHTBuilder

registerIoHandler(Number160, ReplyHandler, Message.Command...) - Method in class net.tomp2p.connection.DispatcherReply

Registers a handler with this dispatcher.

registerIoHandler(Message.Command...) - Method in class net.tomp2p.rpc.ReplyHandler

registerResultsHandler(DiscoveryResultsHandler, String) - Method in class net.tomp2p.upnp.DiscoveryListener

Registers an SSDP response message handler

relatedStateVariableName - Variable in class net.tomp2p.upnp.Argument

release(ChannelCreator, int) - Method in class net.tomp2p.connection.ConnectionReservation

Release a channelcreator.

release(ChannelCreator) - Method in class net.tomp2p.connection.ConnectionReservation

Release a channelcreator.

release(ChannelCreator) - Method in class net.tomp2p.p2p.Peer

Release a ChannelCreator.

releaseEarly() - Method in class net.tomp2p.futures.FutureDHT

releaseSingleConnection() - Method in class net.tomp2p.connection.PeerConnection

Releases one connection.

remove(Number160, Number160, Collection<Number160>, RoutingConfiguration, RequestP2PConfiguration, boolean, boolean, boolean, FutureCreate<FutureDHT>, FutureChannelCreator, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedHashTable

remove(Number160) - Method in class net.tomp2p.p2p.Peer

remove(Object) - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

remove(Object) - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

remove(PeerAddress, Number160, Number160, Collection<Number160>, boolean, boolean, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.StorageRPC

Removes data from a peer.

remove(Number160, Number160, Number160) - Method in interface net.tomp2p.storage.Storage

remove(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageDisk

remove(Number160, Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.StorageGeneric

remove(Number160, Number160, Number160, Number160, PublicKey) - Method in class net.tomp2p.storage.StorageGeneric

remove(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageMemory

remove(Object) - Method in class net.tomp2p.utils.ConcurrentCacheMap

remove(Object, Object) - Method in class net.tomp2p.utils.ConcurrentCacheMap

removeActive(Number160, Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

removeAll(Collection<?>) - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

removeAll(Collection<?>) - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

RemoveBuilder - Class in net.tomp2p.p2p.builder

RemoveBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.RemoveBuilder

removeDeadLockCheck(long) - Method in class net.tomp2p.connection.DefaultReservation

removeDeadLockCheck(long) - Method in interface net.tomp2p.connection.Reservation

removeDomainProtection(Number160) - Method in class net.tomp2p.storage.StorageGeneric

removeEldestEntry(Map.Entry<K, V>) - Method in class net.tomp2p.utils.CacheMap

removeIoHandler(Number160) - Method in class net.tomp2p.connection.DispatcherReply

If we shutdown, we remove the handlers.

removeListener(BaseFutureListener<? extends BaseFuture>) - Method in interface net.tomp2p.futures.BaseFuture

Removes a listener which is notified when the state of this future changes.

removeListener(BaseFutureListener<? extends BaseFuture>) - Method in class net.tomp2p.futures.BaseFutureImpl

removeListener(TaskResultListener) - Method in class net.tomp2p.task.TaskManager

removePeerListener(PeerListener) - Method in class net.tomp2p.p2p.Peer

Removes a peer listener.

removePeerMapChangeListener(PeerMapChangeListener) - Method in class net.tomp2p.peers.PeerMap

removePeerOfflineListener(PeerStatusListener) - Method in class net.tomp2p.peers.PeerMap

removeReferred(Number160, Number160, Number160, PeerAddress) - Method in class net.tomp2p.storage.TrackerStorage

removeResponsibility(Number160) - Method in interface net.tomp2p.storage.ReplicationStorage

removeResponsibility(Number160) - Method in class net.tomp2p.storage.StorageDisk

removeResponsibility(Number160) - Method in class net.tomp2p.storage.StorageMemory

removeResponsibility(Number160) - Method in class net.tomp2p.storage.StorageMemoryReplication

removeResponsibility(Number160) - Method in class net.tomp2p.storage.TrackerStorage

removeResponsibilityListener(ResponsibilityListener) - Method in class net.tomp2p.replication.Replication

removeStat(PeerAddress) - Method in class net.tomp2p.peers.PeerMapStat

removeTimeout(Number160, Number160, Number160) - Method in interface net.tomp2p.storage.Storage

removeTimeout(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageDisk

removeTimeout(Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageMemory

repeated(K) - Method in interface net.tomp2p.futures.FutureCreate

Called if a future has been created without user interaction

repeated(FutureDHT) - Method in class net.tomp2p.futures.FutureDHT

Called for futures created based on this future.

repeated(BaseFuture) - Method in class net.tomp2p.futures.FutureTracker

Called if a future is created based on this future.

replace(K, V, V) - Method in class net.tomp2p.utils.ConcurrentCacheMap

replace(K, V) - Method in class net.tomp2p.utils.ConcurrentCacheMap

replaceDataMap(Map<Number480, Data>) - Method in class net.tomp2p.message.Message

Replication - Class in net.tomp2p.replication

This class has 3 methods that are called from outside eventes: check, peerInsert, peerRemoved.

Replication(ReplicationStorage, PeerAddress, PeerMap) - Constructor for class net.tomp2p.replication.Replication

ReplicationStorage - Interface in net.tomp2p.storage

reply(PeerAddress, Object) - Method in interface net.tomp2p.rpc.ObjectDataReply

reply(PeerAddress, ChannelBuffer) - Method in interface net.tomp2p.rpc.RawDataReply

Replies to a direct message from a peer.

ReplyHandler - Class in net.tomp2p.rpc

ReplyHandler(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.ReplyHandler

ReplyTimeoutHandler - Class in net.tomp2p.connection

Code inspired by Netty's TimeoutHandlers from Trustin Lee and adapted/extended to a reply timeout handler.

ReplyTimeoutHandler(Timer, long, PeerAddress) - Constructor for class net.tomp2p.connection.ReplyTimeoutHandler

RequestHandlerTCP<K extends FutureResponse> - Class in net.tomp2p.rpc

Is able to send TCP messages (as a request) and processes incoming replies.

RequestHandlerTCP(K, PeerBean, ConnectionBean, Message) - Constructor for class net.tomp2p.rpc.RequestHandlerTCP

RequestHandlerUDP<K extends FutureResponse> - Class in net.tomp2p.rpc

Is able to send UDP messages (as a request) and processes incoming replies.

RequestHandlerUDP(K, PeerBean, ConnectionBean, Message) - Constructor for class net.tomp2p.rpc.RequestHandlerUDP

requestP2PConfiguration - Variable in class net.tomp2p.p2p.builder.DHTBuilder

RequestP2PConfiguration - Class in net.tomp2p.p2p

This name was chosen over P2PConfiguration, as it already exists

RequestP2PConfiguration(int, int, int) - Constructor for class net.tomp2p.p2p.RequestP2PConfiguration

RequestP2PConfiguration(int, int, int, boolean, boolean) - Constructor for class net.tomp2p.p2p.RequestP2PConfiguration

RequestP2PConfiguration(int, int, int, boolean, boolean, SenderCacheStrategy) - Constructor for class net.tomp2p.p2p.RequestP2PConfiguration

Reservation - Interface in net.tomp2p.connection

reserve(int) - Method in class net.tomp2p.connection.ConnectionReservation

Reserves connections.

reserve(int, String) - Method in class net.tomp2p.connection.ConnectionReservation

Reserves connections.

reserve(int, boolean) - Method in class net.tomp2p.connection.ConnectionReservation

Reserves connections.

reserve(int, boolean, String) - Method in class net.tomp2p.connection.ConnectionReservation

Reserves connections.

reserve(RoutingConfiguration, RequestP2PConfiguration, String) - Method in class net.tomp2p.p2p.Peer

Reserves a connection for a routing and DHT operation.

reserved(ChannelCreator) - Method in class net.tomp2p.futures.FutureChannelCreator

Called if a channel creator could be created.

resetValidityTime(String) - Method in class net.tomp2p.upnp.RootDevice

Resets the device validity time

response(FutureDHT) - Method in interface net.tomp2p.p2p.DistributedHashTable.Operation

responseReceived(Message) - Method in interface net.tomp2p.natpmp.MessageResponseInterface

A response was received.

ResponsibilityListener - Interface in net.tomp2p.replication

responsibleDomains(Number160) - Method in class net.tomp2p.storage.TrackerStorage

ResultCode - Enum in net.tomp2p.natpmp

Enumerates the result codes from NAT-PMP messages.

resume() - Method in class net.tomp2p.message.ProtocolChunkedInput

retainAll(Collection<?>) - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

retainAll(Collection<?>) - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

ROOT_DEVICES - Static variable in class net.tomp2p.upnp.Discovery

RootDevice - Class in net.tomp2p.upnp

Root UPNP device that is contained in a device definition file.

RootDevice(Document, URL, String, URL, String, String, String, InetAddress) - Constructor for class net.tomp2p.upnp.RootDevice

route(Number160, Number160, Collection<Number160>, Message.Type, int, int, int, int, int, boolean, ChannelCreator) - Method in class net.tomp2p.p2p.DistributedRouting

Looks for a route to the given locationKey

routingConfiguration - Variable in class net.tomp2p.p2p.builder.DHTBuilder

routingConfiguration - Variable in class net.tomp2p.p2p.builder.TrackerBuilder

RoutingConfiguration - Class in net.tomp2p.p2p

RoutingConfiguration(int, int, int) - Constructor for class net.tomp2p.p2p.RoutingConfiguration

RoutingConfiguration(int, int, int, int) - Constructor for class net.tomp2p.p2p.RoutingConfiguration

RoutingConfiguration(int, int, int, int, int) - Constructor for class net.tomp2p.p2p.RoutingConfiguration

RoutingConfiguration(int, int, int, int, int, boolean) - Constructor for class net.tomp2p.p2p.RoutingConfiguration

run() - Method in class net.tomp2p.replication.DefaultStorageReplication

run() - Method in class net.tomp2p.upnp.DiscoveryListener

runDeadLockProof(Scheduler, FutureRunnable) - Method in class net.tomp2p.connection.DefaultReservation

runDeadLockProof(Scheduler, FutureRunnable) - Method in interface net.tomp2p.connection.Reservation

S

Scheduler - Class in net.tomp2p.connection

Scheduler(int, int) - Constructor for class net.tomp2p.connection.Scheduler

scheduleTimeout(BaseFuture, int, String) - Method in class net.tomp2p.connection.Scheduler

SCPDURL - Variable in class net.tomp2p.upnp.Service

secondaryPeers(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

SEGMENT_NR - Static variable in class net.tomp2p.utils.ConcurrentCacheMap

Number of segments that can be accessed concurrently

self(K) - Method in class net.tomp2p.futures.BaseFutureImpl

self(K) - Method in class net.tomp2p.p2p.builder.DHTBuilder

self(K) - Method in class net.tomp2p.p2p.builder.TrackerBuilder

self() - Method in class net.tomp2p.peers.PeerMap

Each node that has a bag has an ID itself to define what is close.

send(Number160) - Method in class net.tomp2p.p2p.Peer

The send method works as follows:

send(PeerAddress, Number160, Map<Number160, Data>, ChannelCreator, int, boolean) - Method in class net.tomp2p.rpc.BroadcastRPC

send(PeerAddress, Number160, Map<Number160, Data>, int, ChannelCreator, int, boolean) - Method in class net.tomp2p.rpc.BroadcastRPC

send(PeerAddress, ChannelBuffer, boolean, ChannelCreator, boolean) - Method in class net.tomp2p.rpc.DirectDataRPC

send(PeerAddress, ChannelBuffer, boolean, ChannelCreator, int, boolean) - Method in class net.tomp2p.rpc.DirectDataRPC

Send data directly to a peer.

sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture>, FutureResponse, Message, ChannelCreator) - Method in interface net.tomp2p.connection.Sender

Sent the message via UDP broadcast.

sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture>, FutureResponse, Message, ChannelCreator) - Method in class net.tomp2p.connection.SenderNetty

sendBroadcastUDP(ChannelCreator) - Method in class net.tomp2p.rpc.RequestHandlerUDP

SendBuilder - Class in net.tomp2p.p2p.builder

SendBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.SendBuilder

sendDirect(PeerAddress) - Method in class net.tomp2p.p2p.Peer

sendDirect(PeerConnection) - Method in class net.tomp2p.p2p.Peer

sendDirect() - Method in class net.tomp2p.p2p.Peer

Deprecated.

SendDirectBuilder - Class in net.tomp2p.p2p.builder

SendDirectBuilder(Peer, PeerAddress) - Constructor for class net.tomp2p.p2p.builder.SendDirectBuilder

SendDirectBuilder(Peer, PeerConnection) - Constructor for class net.tomp2p.p2p.builder.SendDirectBuilder

SendDirectBuilder(Peer) - Constructor for class net.tomp2p.p2p.builder.SendDirectBuilder

Deprecated.

Sender - Interface in net.tomp2p.connection

SenderCacheStrategy - Class in net.tomp2p.rpc

SenderCacheStrategy(int, int) - Constructor for class net.tomp2p.rpc.SenderCacheStrategy

SenderNetty - Class in net.tomp2p.connection

Handles sending of messages.

SenderNetty(ConnectionConfiguration, Timer) - Constructor for class net.tomp2p.connection.SenderNetty

The sender is shared for all master and child peers

sendEvents - Variable in class net.tomp2p.upnp.StateVariable

Boolean to indicate if the variable is sending events when value of the var is changing.

sendResult(PeerAddress, ChannelCreator, Number160, Map<Number160, Data>, KeyPair, boolean, boolean) - Method in class net.tomp2p.rpc.TaskRPC

sendSearchMessage(InetAddress, int, int, String) - Static method in class net.tomp2p.upnp.Discovery

Sends an SSDP search message on the network

sendTask(PeerAddress, ChannelCreator, Number160, Map<Number160, Data>, Worker, KeyPair, boolean, boolean) - Method in class net.tomp2p.rpc.TaskRPC

Sends a task to a remote peer.

sendTCP(RequestHandlerTCP<? extends BaseFuture>, FutureResponse, Message, ChannelCreator, int) - Method in interface net.tomp2p.connection.Sender

Sent the message via TCP.

sendTCP(RequestHandlerTCP<? extends BaseFuture>, FutureResponse, Message, ChannelCreator, int) - Method in class net.tomp2p.connection.SenderNetty

sendTCP(ChannelCreator) - Method in class net.tomp2p.rpc.RequestHandlerTCP

sendTCP(ChannelCreator, int) - Method in class net.tomp2p.rpc.RequestHandlerTCP

sendUDP(RequestHandlerUDP<? extends BaseFuture>, FutureResponse, Message, ChannelCreator) - Method in interface net.tomp2p.connection.Sender

Sent the message via UDP.

sendUDP(RequestHandlerUDP<? extends BaseFuture>, FutureResponse, Message, ChannelCreator) - Method in class net.tomp2p.connection.SenderNetty

sendUDP(ChannelCreator) - Method in class net.tomp2p.rpc.RequestHandlerUDP

SENT_PEERS_CACHE_SIZE - Static variable in class net.tomp2p.rpc.PeerExchangeRPC

serialNumber - Variable in class net.tomp2p.upnp.Device

serverAddressChanged(PeerAddress, PeerAddress, boolean) - Method in interface net.tomp2p.p2p.PeerListener

Service - Interface in net.tomp2p.examples.ws

service() - Method in class net.tomp2p.upnp.ActionMessage

Executes the message and retuns the UPNP device response, according to the UPNP specs, this method could take up to 30 secs to process ( time allowed for a device to respond to a request )

Service - Class in net.tomp2p.upnp

Representation of an UPNP service

Service(Node, URL, Device) - Constructor for class net.tomp2p.upnp.Service

service() - Method in class net.tomp2p.upnp.StateVariableMessage

Executes the state variable query and returns the UPNP device response, according to the UPNP specs, this method could take up to 30 secs to process ( time allowed for a device to respond to a request )

service - Variable in class net.tomp2p.upnp.UPNPMessageFactory

serviceId - Variable in class net.tomp2p.upnp.Service

ServiceImpl - Class in net.tomp2p.examples.ws

ServiceImpl() - Constructor for class net.tomp2p.examples.ws.ServiceImpl

serviceOwnerDevice - Variable in class net.tomp2p.upnp.Service

services - Variable in class net.tomp2p.upnp.Device

serviceType - Variable in class net.tomp2p.upnp.Service

setAcquired(boolean) - Method in class net.tomp2p.futures.FutureChannel

Set a flag if a semaphore has been acquired for this channel.

setAll(boolean) - Method in class net.tomp2p.p2p.builder.GetBuilder

setAll() - Method in class net.tomp2p.p2p.builder.GetBuilder

setAll(boolean) - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setAll() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setAsyncTask(AsyncTask) - Method in class net.tomp2p.p2p.Peer

setAttachement(byte[]) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setBagSize(int) - Method in class net.tomp2p.p2p.PeerMaker

setBehindFirewall(boolean) - Method in class net.tomp2p.p2p.ConnectionConfiguration

By setting this flag, the peer assumes that it is behind a firewall and will announce itself as unreachable.

setBehindFirewallPeerMap(boolean) - Method in class net.tomp2p.p2p.PeerMaker

Deprecated.

setBindings(Bindings) - Method in class net.tomp2p.p2p.PeerMaker

setBloomFilter(SimpleBloomFilter<Number160>) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setBootstrapTo(Collection<PeerAddress>) - Method in class net.tomp2p.futures.FutureWrappedBootstrap

The addresses we boostrap to.

setBootstrapTo(Collection<PeerAddress>) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setBroadcast() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setBroadcast(boolean) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setBroadcast() - Method in class net.tomp2p.p2p.builder.PingBuilder

setBroadcast(boolean) - Method in class net.tomp2p.p2p.builder.PingBuilder

setBroadcastHandler(BroadcastHandler) - Method in class net.tomp2p.p2p.PeerMaker

setBroadcastRPC(BroadcastRPC) - Method in class net.tomp2p.p2p.Peer

setBuffer(ChannelBuffer) - Method in class net.tomp2p.p2p.builder.SendBuilder

setBuffer(ChannelBuffer) - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

setCacheSize(int) - Method in class net.tomp2p.p2p.PeerMaker

setCacheTimeoutMillis(int) - Method in class net.tomp2p.p2p.PeerMaker

setCancelOnFinish() - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

setCancelOnFinish(boolean) - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

setCancelOnFinish(boolean) - Method in class net.tomp2p.p2p.builder.SendBuilder

setCancelOnFinish() - Method in class net.tomp2p.p2p.builder.SendBuilder

setChannel(Channel) - Method in class net.tomp2p.futures.FutureChannel

Finishes this future.

setChannelFuture(ChannelFuture) - Method in class net.tomp2p.futures.FutureChannel

Set the channel future.

setCommand(Message.Command) - Method in class net.tomp2p.message.Message

Command of the message, such as GET, PING, etc.

setCompletedAndNotify() - Method in class net.tomp2p.futures.BaseFutureImpl

Make sure that the calling method has synchronized (lock)

setConfiguration(ConnectionConfiguration) - Method in class net.tomp2p.p2p.PeerMaker

setConnection(PeerConnection) - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

setConnectTimeoutMillis(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setContentBloomFilter(SimpleBloomFilter<Number160>) - Method in class net.tomp2p.rpc.DigestResult

setContentKey(Number160) - Method in class net.tomp2p.p2p.builder.GetBuilder

setContentKey(Number160) - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setContentKeys(Collection<Number160>) - Method in class net.tomp2p.p2p.builder.GetBuilder

Set the content keys that should be found.

setContentKeys(Collection<Number160>) - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setContentType(Message.Content) - Method in class net.tomp2p.message.Message

Convient method to set content type.

setConvertNumber480to160(boolean) - Method in class net.tomp2p.message.Message

setCreated(long) - Method in class net.tomp2p.peers.PeerStat

setDaemon(boolean) - Method in class net.tomp2p.upnp.DiscoveryListener

Sets the listener as a daemon thread

setData(Data) - Method in class net.tomp2p.p2p.builder.AddBuilder

setData(Data) - Method in class net.tomp2p.p2p.builder.PutBuilder

setData(Number160, Data) - Method in class net.tomp2p.p2p.builder.PutBuilder

setDataMap(Map<Number160, Data>) - Method in class net.tomp2p.futures.FutureAsyncTask

Finishes the future and notifies listeners.

setDataMap(Map<Number160, Data>) - Method in class net.tomp2p.message.Message

setDataMap(Map<Number160, Data>) - Method in class net.tomp2p.p2p.builder.BroadcastBuilder

setDataMap(Map<Number160, Data>) - Method in class net.tomp2p.p2p.builder.PutBuilder

setDataMap(Map<Number160, Data>) - Method in class net.tomp2p.p2p.builder.SubmitBuilder

setDataMap480(Map<Number480, Data>) - Method in class net.tomp2p.message.Message

setDataMapConvert(Map<Number480, Data>) - Method in class net.tomp2p.message.Message

setDataSet(Collection<Data>) - Method in class net.tomp2p.p2p.builder.AddBuilder

setDefaultDirectReplication(FutureCreator<FutureTracker>) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setDefaultDirectReplication(FutureCreator<FutureDHT>) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setDefaultPEX(FutureCreator<FutureLateJoin<FutureResponse>>) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setDigest(boolean) - Method in class net.tomp2p.p2p.builder.GetBuilder

setDigest() - Method in class net.tomp2p.p2p.builder.GetBuilder

setDirectData1(Map<PeerAddress, ChannelBuffer>) - Method in class net.tomp2p.futures.FutureDHT

Finish the future and set the keys and data that have send directly using the Netty buffer.

setDirectData2(Map<PeerAddress, Object>) - Method in class net.tomp2p.futures.FutureDHT

Finish the future and set the keys and data that have send directly using an object.

setDirectDataRPC(DirectDataRPC) - Method in class net.tomp2p.p2p.Peer

setDirectReplication(boolean) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setDirectReplication() - Method in class net.tomp2p.p2p.builder.DHTBuilder

setDirectReplication() - Method in class net.tomp2p.storage.Data

setDirectReplication(boolean) - Method in class net.tomp2p.storage.Data

setDisableBind(boolean) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setDiscoveredTCP() - Method in class net.tomp2p.futures.FutureDiscover

Intermediate result if TCP has been discovered.

setDiscoveredUDP() - Method in class net.tomp2p.futures.FutureDiscover

Intermediate result if UDP has been discovered.

setDiscoverTimeoutSec(int) - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

setDiscoverTimeoutSec(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setDistributedHashMap(DistributedHashTable) - Method in class net.tomp2p.p2p.Peer

setDistributedRouting(DistributedRouting) - Method in class net.tomp2p.p2p.Peer

setDistributedTask(DistributedTask) - Method in class net.tomp2p.p2p.Peer

setDistributedTracker(DistributedTracker) - Method in class net.tomp2p.p2p.Peer

setDomainKey(Number160) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setDomainKey(Number160) - Method in class net.tomp2p.p2p.builder.TrackerBuilder

setDone(Object) - Method in class net.tomp2p.futures.FutureDHT

Finish the future and set a general purpose attachement.

setDone() - Method in class net.tomp2p.futures.FutureTask

Finishes the future.

setEnableBroadcast(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableDHT(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableDirectDataRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableHandShakeRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableIndirectReplication(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableMaintenance(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableNeighborRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnablePeerExchangeRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableQuitRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableRouting(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableStorageRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableTask(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableTaskRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableTracker(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEnableTrackerRPC(boolean) - Method in class net.tomp2p.p2p.PeerMaker

setEvaluatingScheme(EvaluatingSchemeTracker) - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setEvaluationScheme(EvaluatingSchemeDHT) - Method in class net.tomp2p.p2p.builder.GetBuilder

setExpectAttachement() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setExpectAttachement(boolean) - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setFaildeReason(String) - Method in class net.tomp2p.task.TaskStatus

setFailed(String) - Method in interface net.tomp2p.futures.BaseFuture

Sets the failed flat to true and the completed flag to true.

setFailed(BaseFuture) - Method in interface net.tomp2p.futures.BaseFuture

Sets the failed flat to true and the completed flag to true.

setFailed(String, BaseFuture) - Method in interface net.tomp2p.futures.BaseFuture

Sets the failed flat to true and the completed flag to true.

setFailed(Throwable) - Method in interface net.tomp2p.futures.BaseFuture

Sets the failed flat to true and the completed flag to true.

setFailed(String, Throwable) - Method in interface net.tomp2p.futures.BaseFuture

Sets the failed flat to true and the completed flag to true.

setFailed(BaseFuture) - Method in class net.tomp2p.futures.BaseFutureImpl

setFailed(String, BaseFuture) - Method in class net.tomp2p.futures.BaseFutureImpl

setFailed(Throwable) - Method in class net.tomp2p.futures.BaseFutureImpl

setFailed(String, Throwable) - Method in class net.tomp2p.futures.BaseFutureImpl

setFailed(String) - Method in class net.tomp2p.futures.BaseFutureImpl

setFailed(String) - Method in class net.tomp2p.futures.FutureResponse

setFileMessageLogger(File) - Method in class net.tomp2p.p2p.PeerMaker

setFileReference() - Method in class net.tomp2p.storage.Data

setFileReference(boolean) - Method in class net.tomp2p.storage.Data

setFillPrimaryStorageFast(boolean) - Method in class net.tomp2p.storage.TrackerStorage

setForceRoutingOnlyToSelf() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setForceRoutingOnlyToSelf(boolean) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setForceStorageUDP(boolean) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setForceTrackerTCP(boolean) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setFutureChannelCreator(FutureChannelCreator) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setFutureChannelCreator(FutureChannelCreator) - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

setFutureChannelCreator(FutureChannelCreator) - Method in class net.tomp2p.p2p.builder.SubmitBuilder

setFutureChannelCreator(FutureChannelCreator) - Method in class net.tomp2p.p2p.builder.TrackerBuilder

setFutureCreate(FutureCreate<BaseFuture>) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setFutureCreate(FutureCreate<FutureDHT>) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setFutureRouting(FutureRouting) - Method in class net.tomp2p.futures.FutureDHT

Sets the future object that was used for the routing.

setFutureTimeout(BaseFuture, int, String) - Method in class net.tomp2p.p2p.Peer

Sets a timeout for this future.

setHandshakeRPC(HandshakeRPC) - Method in class net.tomp2p.p2p.Peer

setHashDataMap(Map<Number160, HashData>) - Method in class net.tomp2p.message.Message

setHintSign(boolean) - Method in class net.tomp2p.message.Message

setIdleTCPMillis(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setIdleUDPMillis(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setImpl(Timing) - Static method in class net.tomp2p.utils.Timings

setInetAddress(InetAddress) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setInetAddress(InetAddress) - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

setInetAddress(InetAddress) - Method in class net.tomp2p.p2p.builder.PingBuilder

setInputParameter(String, Object) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call.

setInputParameter(String, String) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call.

setInputParameter(String, Date) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, boolean) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, byte) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, short) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, int) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, long) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, float) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInputParameter(String, double) - Method in class net.tomp2p.upnp.ActionMessage

Set the value of an input parameter before a message service call

setInteger(int) - Method in class net.tomp2p.message.Message

setIsUDP(boolean) - Method in class net.tomp2p.p2p.builder.BroadcastBuilder

setKeepAlive(boolean) - Method in class net.tomp2p.message.Message

setKeepAlive(boolean) - Method in class net.tomp2p.rpc.RequestHandlerTCP

setKey(Number160) - Method in class net.tomp2p.message.Message

setKeyBloomFilter(SimpleBloomFilter<Number160>) - Method in class net.tomp2p.p2p.builder.GetBuilder

setKeyBloomFilter(SimpleBloomFilter<Number160>) - Method in class net.tomp2p.rpc.DigestResult

setKeyDigest(Map<Number160, Number160>) - Method in class net.tomp2p.rpc.DigestResult

setKeyKey(Number160, Number160) - Method in class net.tomp2p.message.Message

setKeyMap(Map<Number160, Number160>) - Method in class net.tomp2p.message.Message

setKeyObject(Number160, Object) - Method in class net.tomp2p.p2p.builder.PutBuilder

setKeyPair(KeyPair) - Method in class net.tomp2p.p2p.PeerMaker

setKeys(Collection<Number160>) - Method in class net.tomp2p.message.Message

setKeys480(Collection<Number480>) - Method in class net.tomp2p.message.Message

setKeysConvert(Collection<Number480>) - Method in class net.tomp2p.message.Message

setKnownPeers(Set<Number160>) - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setLastSeenOnline(long) - Method in class net.tomp2p.peers.PeerStat

setLength(long) - Method in class net.tomp2p.message.Message

Set payload length.

setLimitTracker(boolean) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setList(boolean) - Method in class net.tomp2p.p2p.builder.AddBuilder

setList() - Method in class net.tomp2p.p2p.builder.AddBuilder

setLong(long) - Method in class net.tomp2p.message.Message

setMaintenanceThreads(int) - Method in class net.tomp2p.p2p.PeerMaker

setManualCleanup(boolean) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setManualCleanup() - Method in class net.tomp2p.p2p.builder.DHTBuilder

setManualCleanup(boolean) - Method in class net.tomp2p.p2p.builder.SubmitBuilder

setMapAcceptHandler(MapAcceptHandler) - Method in class net.tomp2p.p2p.PeerMaker

setMasterPeer(Peer) - Method in class net.tomp2p.p2p.PeerMaker

setMaxCreating(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setMaxMessageSize(int) - Method in class net.tomp2p.p2p.PeerMaker

setMaxNrBeforeExclude(int) - Method in class net.tomp2p.p2p.PeerMaker

setMaxOpenConnection(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setMessageId(int) - Method in class net.tomp2p.message.Message

For deserialization, we need to set the id

setMessageSign() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setMessageSign(boolean) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setNeighborRPC(NeighborRPC) - Method in class net.tomp2p.p2p.Peer

setNeighbors(SortedMap<PeerAddress, DigestInfo>, NavigableSet<PeerAddress>, SortedSet<PeerAddress>, boolean, boolean) - Method in class net.tomp2p.futures.FutureRouting

Sets the result of the routing process and finishes the future.

setNeighbors(Collection<PeerAddress>) - Method in class net.tomp2p.message.Message

setNeighbors(Collection<PeerAddress>, int) - Method in class net.tomp2p.message.Message

setObject(Object) - Method in class net.tomp2p.p2p.builder.AddBuilder

setObject(Object) - Method in class net.tomp2p.p2p.builder.PutBuilder

setObject(Object) - Method in class net.tomp2p.p2p.builder.SendBuilder

setObject(Object) - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

setObjectDataReply(ObjectDataReply) - Method in class net.tomp2p.p2p.Peer

setOperation(DistributedHashTable.Operation) - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

setOptions(int) - Method in class net.tomp2p.message.Message

setP2PId(int) - Method in class net.tomp2p.p2p.PeerMaker

setPayload(ChannelBuffer) - Method in class net.tomp2p.message.Message

setPeer(Peer) - Method in class net.tomp2p.connection.PeerBean

setPeerAddress(PeerAddress) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setPeerAddress(PeerAddress) - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

setPeerAddress(PeerAddress) - Method in class net.tomp2p.p2p.builder.PingBuilder

setPeerAddress(PeerAddress) - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

Deprecated.

setPeerExchangeRPC(PeerExchangeRPC) - Method in class net.tomp2p.p2p.Peer

setPeerMap(PeerMap) - Method in class net.tomp2p.connection.PeerBean

setPeerMapConfiguration(int, int, int, int[], int, boolean) - Method in class net.tomp2p.p2p.PeerMaker

Deprecated.

setPeerMapConfiguration(int, int, int, int[], int, MapAcceptHandler) - Method in class net.tomp2p.p2p.PeerMaker

setPexWaitSec(int) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setPort(int) - Method in class net.tomp2p.p2p.builder.PingBuilder

setPorts(int) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setPorts(int) - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

setPorts(int) - Method in class net.tomp2p.p2p.PeerMaker

setPortTCP(int) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setPortTCP(int) - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

setPortUDP(int) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setPortUDP(int) - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

setPrimanyFactor(int) - Method in class net.tomp2p.storage.TrackerStorage

setProgress(FutureAsyncTask) - Method in class net.tomp2p.futures.FutureTask

This is called for intermediate results.

setProtectDomain(boolean) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setProtectDomain() - Method in class net.tomp2p.p2p.builder.DHTBuilder

setProtectedEntry() - Method in class net.tomp2p.storage.Data

setProtectedEntry(boolean) - Method in class net.tomp2p.storage.Data

setProtection(StorageGeneric.ProtectionEnable, StorageGeneric.ProtectionMode, StorageGeneric.ProtectionEnable, StorageGeneric.ProtectionMode) - Method in class net.tomp2p.storage.StorageGeneric

setProtectionDomainEnable(StorageGeneric.ProtectionEnable) - Method in class net.tomp2p.storage.StorageGeneric

setProtectionDomainMode(StorageGeneric.ProtectionMode) - Method in class net.tomp2p.storage.StorageGeneric

setProtectionEntryEnable(StorageGeneric.ProtectionEnable) - Method in class net.tomp2p.storage.StorageGeneric

setProtectionEntryMode(StorageGeneric.ProtectionMode) - Method in class net.tomp2p.storage.StorageGeneric

setPublicKey(PublicKey) - Method in class net.tomp2p.message.Message

setPublicKey(PublicKey) - Method in class net.tomp2p.storage.Data

setPublicKeyAndSign(KeyPair) - Method in class net.tomp2p.message.Message

setPutIfAbsent(boolean) - Method in class net.tomp2p.p2p.builder.PutBuilder

setPutIfAbsent() - Method in class net.tomp2p.p2p.builder.PutBuilder

setQueue(NavigableSet<PeerAddress>) - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

setQueuePosition(int) - Method in class net.tomp2p.task.TaskStatus

setQuitRPC(QuitRPC) - Method in class net.tomp2p.p2p.Peer

setRandom(Random) - Method in class net.tomp2p.p2p.PeerMaker

setRange(boolean) - Method in class net.tomp2p.p2p.builder.GetBuilder

setRange() - Method in class net.tomp2p.p2p.builder.GetBuilder

setRawDataReply(RawDataReply) - Method in class net.tomp2p.p2p.Peer

setReceivedData(Map<PeerAddress, Map<Number160, Data>>) - Method in class net.tomp2p.futures.FutureDHT

Finish the future and set the keys and data that have been received.

setReceivedDigest(Map<PeerAddress, DigestResult>) - Method in class net.tomp2p.futures.FutureDHT

Finishes the future and set the digest information that have been received.

setRecipient(PeerAddress) - Method in class net.tomp2p.message.Message

Set the ID of the recipient.

setRecipient(PeerAddress) - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

setRefreshSeconds(int) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setRefreshSeconds(int) - Method in class net.tomp2p.p2p.builder.GetBuilder

setRemovedKeys(Map<PeerAddress, Collection<Number160>>) - Method in class net.tomp2p.futures.FutureDHT

Finish the future and set the keys that have been removed.

setRepetitions(int) - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setRepetitions(int) - Method in class net.tomp2p.p2p.builder.SendBuilder

setReplicationRefreshMillis(int) - Method in class net.tomp2p.p2p.PeerMaker

setReplicationStorage(Replication) - Method in class net.tomp2p.connection.PeerBean

setReplicationThreads(int) - Method in class net.tomp2p.p2p.PeerMaker

setReplicationTracker(Replication) - Method in class net.tomp2p.connection.PeerBean

setReply(RawDataReply) - Method in class net.tomp2p.rpc.DirectDataRPC

setReply(ObjectDataReply) - Method in class net.tomp2p.rpc.DirectDataRPC

setReplyTimeoutHandler(ReplyTimeoutHandler) - Method in class net.tomp2p.futures.FutureResponse

Set the cancel operation for the timeout handler.

setRequestP2PConfiguration(RequestP2PConfiguration) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setRequestP2PConfiguration(RequestP2PConfiguration) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setRequestP2PConfiguration(RequestP2PConfiguration) - Method in class net.tomp2p.p2p.builder.SubmitBuilder

setReservation(Reservation) - Method in class net.tomp2p.connection.ConnectionReservation

setResponse() - Method in class net.tomp2p.futures.FutureResponse

If we don't get a reply message, which is the case for fire-and-forget messages, then set the reply to null and set this future to complete with the type Success.

setResponse(Message) - Method in class net.tomp2p.futures.FutureResponse

Gets called if a peer responds.

setReturnBloomFilter(boolean) - Method in class net.tomp2p.p2p.builder.GetBuilder

setReturnBloomFilter() - Method in class net.tomp2p.p2p.builder.GetBuilder

setReturnResults(boolean) - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setReturnResults() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

setRoutingConfiguration(RoutingConfiguration) - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

setRoutingConfiguration(RoutingConfiguration) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setRoutingConfiguration(RoutingConfiguration) - Method in class net.tomp2p.p2p.builder.SubmitBuilder

setRoutingConfiguration(RoutingConfiguration) - Method in class net.tomp2p.p2p.builder.TrackerBuilder

setSecondaryFactor(int) - Method in class net.tomp2p.storage.TrackerStorage

setSeenOnlineTime(PeerAddress) - Method in class net.tomp2p.peers.PeerMapStat

setSender(Sender) - Method in class net.tomp2p.connection.ConnectionBean

setSender(PeerAddress) - Method in class net.tomp2p.message.Message

The ID of the sender.

setServerPeerAddress(PeerAddress) - Method in class net.tomp2p.connection.PeerBean

setSignMessage(boolean) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setSignMessage() - Method in class net.tomp2p.p2p.builder.DHTBuilder

setSignMessage() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setSignMessage(boolean) - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setSignMessage(boolean) - Method in class net.tomp2p.p2p.builder.SubmitBuilder

setSignReply(boolean) - Method in class net.tomp2p.rpc.ReplyHandler

setStatistics(Statistics) - Method in class net.tomp2p.connection.PeerBean

setStatus(TaskStatus.Status) - Method in class net.tomp2p.task.TaskStatus

setStorage(StorageGeneric) - Method in class net.tomp2p.connection.PeerBean

setStorage(StorageGeneric) - Method in class net.tomp2p.p2p.PeerMaker

setStorageRPC(StorageRPC) - Method in class net.tomp2p.p2p.Peer

setStoredKeys(Number160, Number160, Map<PeerAddress, Collection<Number160>>, Map<PeerAddress, Collection<Number480>>) - Method in class net.tomp2p.futures.FutureDHT

Finish the future and set the keys that have been stored.

setTaskManager(TaskManager) - Method in class net.tomp2p.connection.PeerBean

setTaskRPC(TaskRPC) - Method in class net.tomp2p.p2p.Peer

setTCP() - Method in class net.tomp2p.message.Message

setTcpPEX() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setTcpPEX(boolean) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setTcpPing() - Method in class net.tomp2p.p2p.builder.PingBuilder

setTcpPing(boolean) - Method in class net.tomp2p.p2p.builder.PingBuilder

setTcpPort(int) - Method in class net.tomp2p.p2p.PeerMaker

setTimeout(Timer, int) - Method in class net.tomp2p.futures.FutureDiscover

Creates a new future object and creates a timer that fires failed after a timeout.

setTrackerConfiguration(TrackerConfiguration) - Method in class net.tomp2p.p2p.builder.TrackerBuilder

setTrackerData(Collection<TrackerData>) - Method in class net.tomp2p.message.Message

setTrackerRPC(TrackerRPC) - Method in class net.tomp2p.p2p.Peer

setTrackers(Set<PeerAddress>, Set<PeerAddress>, Map<PeerAddress, Collection<TrackerData>>) - Method in class net.tomp2p.futures.FutureTracker

Set the result of the tracker process.

setTrackerStorage(TrackerStorage) - Method in class net.tomp2p.connection.PeerBean

setTrackerTimeoutSec(int) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setTrackerTimoutSeconds(int) - Method in class net.tomp2p.p2p.ConnectionConfiguration

setTTLSeconds(int) - Method in class net.tomp2p.storage.Data

setTwoBloomFilter(SimpleBloomFilter<Number160>, SimpleBloomFilter<Number160>) - Method in class net.tomp2p.message.Message

setType(Message.Type) - Method in class net.tomp2p.message.Message

Set the message type.

setUDP() - Method in class net.tomp2p.message.Message

setUdpPort(int) - Method in class net.tomp2p.p2p.PeerMaker

setupCancel(FutureCleanup, ScheduledFuture<?>) - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

setupCancel(FutureCleanup, ScheduledFuture<?>) - Method in class net.tomp2p.p2p.builder.DHTBuilder

setupPortForwanding(String) - Method in class net.tomp2p.p2p.Peer

The Dynamic and/or Private Ports are those from 49152 through 65535 (http://www.iana.org/assignments/port-numbers)

setUseSecondaryTrackers() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setUseSecondaryTrackers(boolean) - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

setValueBloomFilter(SimpleBloomFilter<Number160>) - Method in class net.tomp2p.p2p.builder.GetBuilder

setVersion(int) - Method in class net.tomp2p.message.Message

For deserialization

setWaitingTimeBetweenNodeMaintenenceSeconds(int[]) - Method in class net.tomp2p.p2p.PeerMaker

setWorkerThreads(int) - Method in class net.tomp2p.p2p.PeerMaker

SHA1Signature - Class in net.tomp2p.message

SHA1Signature() - Constructor for class net.tomp2p.message.SHA1Signature

SHA1Signature(Number160, Number160) - Constructor for class net.tomp2p.message.SHA1Signature

share() - Method in class net.tomp2p.futures.FutureResponse

shiftLeft(int) - Method in class net.tomp2p.peers.Number160

Shift left the 160bit number.

shiftRight(int) - Method in class net.tomp2p.peers.Number160

Shift right the 160bit number.

ShortString - Class in net.tomp2p.peers

A short string stores strings with length of up to 19 characters.

ShortString(String) - Constructor for class net.tomp2p.peers.ShortString

Creates a short string, encodes string in UTF-8 and checks for its length

ShortString(Number160) - Constructor for class net.tomp2p.peers.ShortString

Creates a short string, decodes the byte array from UTF-8 and checks for its length

shutdown() - Method in class net.tomp2p.connection.ChannelCreator

Shuts down this channelcreator.

shutdown() - Method in class net.tomp2p.connection.ConnectionHandler

Shuts down the dispatcher and frees resources.

shutdown() - Method in class net.tomp2p.connection.ConnectionReservation

Close all open connections and prevent creating new ones.

shutdown() - Method in class net.tomp2p.connection.DefaultReservation

shutdown() - Method in class net.tomp2p.connection.MessageLogger

Shutdown the stream.

shutdown() - Method in class net.tomp2p.connection.NATUtils

Since shutdown is also called from the shutdown hook, it might get called twice.

shutdown() - Method in interface net.tomp2p.connection.Reservation

shutdown() - Method in class net.tomp2p.connection.Scheduler

shutdown() - Method in interface net.tomp2p.connection.Sender

Shuts down the sender.

shutdown() - Method in class net.tomp2p.connection.SenderNetty

shutdown() - Method in class net.tomp2p.futures.FutureDHT

shutdown() - Method in class net.tomp2p.futures.FutureTracker

shutdown() - Method in class net.tomp2p.natpmp.NatPmpDevice

Shuts down this NatPmpDevice.

shutdown() - Method in class net.tomp2p.p2p.Peer

Closes all connections of this node

shutdown() - Method in class net.tomp2p.task.TaskManager

signMessage - Variable in class net.tomp2p.p2p.builder.DHTBuilder

signMessage() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

SimpleBloomFilter<E> - Class in net.tomp2p.rpc

A simple Bloom Filter (see http://en.wikipedia.org/wiki/Bloom_filter) that uses java.util.Random as a primitive hash function, and which implements Java's Set interface for convenience.

SimpleBloomFilter(int, int) - Constructor for class net.tomp2p.rpc.SimpleBloomFilter

Construct an empty SimpleBloomFilter.

SimpleBloomFilter(byte[]) - Constructor for class net.tomp2p.rpc.SimpleBloomFilter

Constructs a SimpleBloomFilter out of existing data.

SimpleBloomFilter(ChannelBuffer, int) - Constructor for class net.tomp2p.rpc.SimpleBloomFilter

SimpleBloomFilter(byte[], int, int) - Constructor for class net.tomp2p.rpc.SimpleBloomFilter

Constructs a SimpleBloomFilter out of existing data.

SimpleBloomFilter(int, int, BitSet) - Constructor for class net.tomp2p.rpc.SimpleBloomFilter

Constructs a SimpleBloomFilter out of existing data.

size() - Method in class net.tomp2p.message.ProtocolChunkedInput

size() - Method in class net.tomp2p.peers.PeerMap

The peerCount keeps track of the total number of peer in the system.

size() - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

size() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

size() - Method in class net.tomp2p.utils.ConcurrentCacheMap

SIZE_IP_SOCKv4 - Static variable in class net.tomp2p.peers.PeerAddress

SIZE_IP_SOCKv6 - Static variable in class net.tomp2p.peers.PeerAddress

SIZE_IPv4 - Static variable in class net.tomp2p.peers.PeerAddress

SIZE_IPv6 - Static variable in class net.tomp2p.peers.PeerAddress

sizePrimary(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

sizeSecondary(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

sleep(int) - Method in interface net.tomp2p.utils.Timing

Sleeps with throwing an InterruptedException

sleep(int) - Method in class net.tomp2p.utils.TimingImpl

sleep(int) - Static method in class net.tomp2p.utils.Timings

sleepUninterruptibly(int) - Method in interface net.tomp2p.utils.Timing

Sleeps without throwing an InterruptedException

sleepUninterruptibly(int) - Method in class net.tomp2p.utils.TimingImpl

sleepUninterruptibly(int) - Static method in class net.tomp2p.utils.Timings

SSDP_IP - Static variable in class net.tomp2p.upnp.Discovery

SSDP_PORT - Static variable in class net.tomp2p.upnp.Discovery

start() - Method in class net.tomp2p.p2p.builder.AddBuilder

start() - Method in class net.tomp2p.p2p.builder.AddTrackerBuilder

start() - Method in class net.tomp2p.p2p.builder.BootstrapBuilder

start() - Method in class net.tomp2p.p2p.builder.BroadcastBuilder

start() - Method in class net.tomp2p.p2p.builder.DHTBuilder

start() - Method in class net.tomp2p.p2p.builder.DiscoverBuilder

start() - Method in class net.tomp2p.p2p.builder.GetBuilder

start() - Method in class net.tomp2p.p2p.builder.GetTrackerBuilder

start() - Method in class net.tomp2p.p2p.builder.ParallelRequestBuilder

start() - Method in class net.tomp2p.p2p.builder.PingBuilder

start() - Method in class net.tomp2p.p2p.builder.PutBuilder

start() - Method in class net.tomp2p.p2p.builder.RemoveBuilder

start() - Method in class net.tomp2p.p2p.builder.SendBuilder

start() - Method in class net.tomp2p.p2p.builder.SendDirectBuilder

start() - Method in class net.tomp2p.p2p.builder.SubmitBuilder

start() - Method in class net.tomp2p.p2p.builder.TrackerBuilder

startClient(String) - Static method in class net.tomp2p.examples.ExampleDiscover

startClientNAT(String) - Static method in class net.tomp2p.examples.ExampleNAT

startClientNAT(String) - Static method in class net.tomp2p.examples.ExampleNATChat

startDelayedChannelCreator() - Method in class net.tomp2p.connection.Scheduler

startMaintainance(PeerMap, HandshakeRPC, ConnectionReservation, int) - Method in class net.tomp2p.connection.Scheduler

startPeerExchange(Number160, Number160, FutureChannelCreator, ConnectionReservation, boolean) - Method in class net.tomp2p.p2p.DistributedTracker

startServer() - Static method in class net.tomp2p.examples.ExampleDiscover

startServer() - Method in class net.tomp2p.examples.ExampleNAT

startServer(String) - Method in class net.tomp2p.examples.ExampleNATChat

startTimeout() - Method in class net.tomp2p.connection.Scheduler

startTracking(TaskRPC, ConnectionReservation) - Method in class net.tomp2p.connection.Scheduler

startupTCP(InetSocketAddress, DispatcherReply, int) - Method in class net.tomp2p.connection.ConnectionHandler

Creates TCP channels and listens on them

startupUDP(InetSocketAddress, DispatcherReply) - Method in class net.tomp2p.connection.ConnectionHandler

Creates UDP channels and listens on them

stateVar - Variable in class net.tomp2p.upnp.StateVariableResponse

StateVariable - Class in net.tomp2p.upnp

Class to contain a service state variable definition

StateVariableMessage - Class in net.tomp2p.upnp

This class is used to create state variable messages to communicate with the device

StateVariableResponse - Class in net.tomp2p.upnp

This class contains data returned by a state variable query response

StateVariableTypes - Interface in net.tomp2p.upnp

Interface to defined allowed values for service state variables data types

Statistics - Class in net.tomp2p.p2p

Statistics(List<Map<Number160, PeerAddress>>, Number160, int, int) - Constructor for class net.tomp2p.p2p.Statistics

stepRangeValue - Variable in class net.tomp2p.upnp.StateVariable

The value step range as a string

stopKeepTrack(Number320) - Method in class net.tomp2p.connection.Scheduler

Storage - Interface in net.tomp2p.storage

StorageDisk - Class in net.tomp2p.storage

StorageDisk(String) - Constructor for class net.tomp2p.storage.StorageDisk

StorageGeneric - Class in net.tomp2p.storage

StorageGeneric() - Constructor for class net.tomp2p.storage.StorageGeneric

StorageGeneric.ProtectionEnable - Enum in net.tomp2p.storage

StorageGeneric.ProtectionMode - Enum in net.tomp2p.storage

StorageGeneric.PutStatus - Enum in net.tomp2p.storage

StorageMemory - Class in net.tomp2p.storage

StorageMemory() - Constructor for class net.tomp2p.storage.StorageMemory

StorageMemoryReplication - Class in net.tomp2p.storage

StorageMemoryReplication() - Constructor for class net.tomp2p.storage.StorageMemoryReplication

StorageRPC - Class in net.tomp2p.rpc

StorageRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.StorageRPC

STRING - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Unicode string.

STRING_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

subMap(Number160, Number160, Number160, Number160) - Method in interface net.tomp2p.storage.Storage

subMap(Number160) - Method in interface net.tomp2p.storage.Storage

subMap(Number160, Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageDisk

subMap(Number160) - Method in class net.tomp2p.storage.StorageDisk

subMap(Number160, Number160, Number160, Number160) - Method in class net.tomp2p.storage.StorageMemory

subMap(Number160) - Method in class net.tomp2p.storage.StorageMemory

subMapTimeout(long) - Method in interface net.tomp2p.storage.Storage

subMapTimeout(long) - Method in class net.tomp2p.storage.StorageDisk

subMapTimeout(long) - Method in class net.tomp2p.storage.StorageMemory

submit(Number160, Map<Number160, Data>, Worker, RoutingConfiguration, RequestP2PConfiguration, FutureChannelCreator, boolean, boolean, ConnectionReservation) - Method in class net.tomp2p.p2p.DistributedTask

Submit a task to the DHT.

submit(Number160, Worker) - Method in class net.tomp2p.p2p.Peer

submit(PeerAddress, ChannelCreator, Number160, Map<Number160, Data>, Worker, boolean, boolean) - Method in class net.tomp2p.task.AsyncTask

SubmitBuilder - Class in net.tomp2p.p2p.builder

SubmitBuilder(Peer, Number160, Worker) - Constructor for class net.tomp2p.p2p.builder.SubmitBuilder

submitTask(Peer, Number160, Worker, Map<Number160, Data>, PeerAddress, boolean) - Method in class net.tomp2p.task.TaskManager

subtract(Collection<K>, Collection<K>) - Static method in class net.tomp2p.utils.Utils

subtract(Map<K, V>, Collection<K>) - Static method in class net.tomp2p.utils.Utils

T

taskFailed(Number320) - Method in class net.tomp2p.task.AsyncTask

taskFailed(Number320) - Method in interface net.tomp2p.task.TaskResultListener

TaskManager - Class in net.tomp2p.task

TaskManager(ConnectionBean, int) - Constructor for class net.tomp2p.task.TaskManager

taskReceived(Number320, Map<Number160, Data>) - Method in class net.tomp2p.task.AsyncTask

taskReceived(Number320, Map<Number160, Data>) - Method in interface net.tomp2p.task.TaskResultListener

TaskResultListener - Interface in net.tomp2p.task

TaskRPC - Class in net.tomp2p.rpc

TaskRPC(PeerBean, ConnectionBean) - Constructor for class net.tomp2p.rpc.TaskRPC

taskStatus(PeerAddress, ChannelCreator, Collection<Number160>, boolean) - Method in class net.tomp2p.rpc.TaskRPC

taskStatus(Number320) - Method in class net.tomp2p.task.TaskManager

TaskStatus - Class in net.tomp2p.task

TaskStatus() - Constructor for class net.tomp2p.task.TaskStatus

text1 - Static variable in class net.tomp2p.examples.ExampleMapReduce

text2 - Static variable in class net.tomp2p.examples.ExampleMapReduce

text3 - Static variable in class net.tomp2p.examples.ExampleMapReduce

THREAD_NAME - Static variable in class net.tomp2p.connection.ConnectionHandler

TIME - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Time in a subset of ISO 8601 format with no date and no time zone.

TIME_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

TIME_TZ - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Time in a subset of ISO 8601 format with optional time zone but no date.

TIME_TZ_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Timing - Interface in net.tomp2p.utils

The timing class for TomP2P.

TimingImpl - Class in net.tomp2p.utils

The implementation that is used for normal operation.

TimingImpl() - Constructor for class net.tomp2p.utils.TimingImpl

Timings - Class in net.tomp2p.utils

Static interface for the Timing framework

Timings() - Constructor for class net.tomp2p.utils.Timings

toArray() - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

toArray(T[]) - Method in class net.tomp2p.rpc.CountingBloomFilter

Not implemented

toArray() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

toArray(T[]) - Method in class net.tomp2p.rpc.SimpleBloomFilter

Not implemented

toByteArray(byte[], int) - Method in class net.tomp2p.peers.Number160

Fills the byte array with this number

toByteArray() - Method in class net.tomp2p.peers.Number160

Returns a byte array, which is always of size 20.

toByteArray() - Method in class net.tomp2p.peers.PeerAddress

Serializes to a new array with the proper size

toByteArray(byte[], int) - Method in class net.tomp2p.peers.PeerAddress

Serializes to an existing array.

toByteArray() - Method in class net.tomp2p.rpc.SimpleBloomFilter

Returns a byte array of at least length 8.

toByteArraySocketAddress() - Method in class net.tomp2p.peers.PeerAddress

toByteArraySocketAddress(byte[], int) - Method in class net.tomp2p.peers.PeerAddress

toIntArray() - Method in class net.tomp2p.peers.Number160

Returns a copy of the backing array, which is always of size 5.

TomP2PDecoderTCP - Class in net.tomp2p.message

The decoder first decodes the header.

TomP2PDecoderTCP() - Constructor for class net.tomp2p.message.TomP2PDecoderTCP

Default constructor with no message size limit.

TomP2PDecoderTCP(int) - Constructor for class net.tomp2p.message.TomP2PDecoderTCP

Limits the message size

TomP2PDecoderUDP - Class in net.tomp2p.message

TomP2PDecoderUDP() - Constructor for class net.tomp2p.message.TomP2PDecoderUDP

TomP2PEncoderTCP - Class in net.tomp2p.message

TomP2PEncoderTCP() - Constructor for class net.tomp2p.message.TomP2PEncoderTCP

TomP2PEncoderUDP - Class in net.tomp2p.message

TomP2PEncoderUDP() - Constructor for class net.tomp2p.message.TomP2PEncoderUDP

toNumber160() - Method in class net.tomp2p.peers.ShortString

tooClose(Collection<PeerAddress>) - Static method in class net.tomp2p.p2p.Statistics

toString() - Method in exception net.tomp2p.connection.PeerException

toString() - Method in class net.tomp2p.message.Message

toString() - Method in class net.tomp2p.message.MessageID

toString(boolean) - Method in class net.tomp2p.peers.Number160

Shows the content in a human readable manner

toString() - Method in class net.tomp2p.peers.Number160

toString() - Method in class net.tomp2p.peers.Number320

toString() - Method in class net.tomp2p.peers.Number480

toString() - Method in class net.tomp2p.peers.PeerAddress

toString() - Method in class net.tomp2p.peers.PeerMap

toString() - Method in class net.tomp2p.peers.ShortString

toString() - Method in class net.tomp2p.rpc.CountingBloomFilter

toString() - Method in class net.tomp2p.rpc.SimpleBloomFilter

toString() - Method in class net.tomp2p.storage.Data

toString() - Method in class net.tomp2p.storage.TrackerData

toString() - Method in class net.tomp2p.upnp.Action

toString() - Method in class net.tomp2p.upnp.ActionResponse

toString() - Method in class net.tomp2p.upnp.Argument

toString() - Method in class net.tomp2p.upnp.Device

toString() - Method in class net.tomp2p.upnp.Service

toString() - Method in class net.tomp2p.upnp.StateVariable

TRACKER_CACHE_SIZE - Static variable in class net.tomp2p.storage.TrackerStorage

TRACKER_SIZE - Static variable in class net.tomp2p.storage.TrackerStorage

TrackerBuilder<K extends TrackerBuilder<K>> - Class in net.tomp2p.p2p.builder

TrackerBuilder(Peer, Number160) - Constructor for class net.tomp2p.p2p.builder.TrackerBuilder

trackerConfiguration - Variable in class net.tomp2p.p2p.builder.TrackerBuilder

TrackerConfiguration - Class in net.tomp2p.p2p

TrackerConfiguration(int, int, int, int) - Constructor for class net.tomp2p.p2p.TrackerConfiguration

TrackerConfiguration(int, int, int, int, int, int) - Constructor for class net.tomp2p.p2p.TrackerConfiguration

TrackerConfiguration(int, int, int, int, int, int, boolean, boolean) - Constructor for class net.tomp2p.p2p.TrackerConfiguration

TrackerData - Class in net.tomp2p.storage

TrackerData(PeerAddress, PeerAddress, byte[], int, int) - Constructor for class net.tomp2p.storage.TrackerData

TrackerData(PeerAddress, PeerAddress, byte[], int, int, boolean) - Constructor for class net.tomp2p.storage.TrackerData

TrackerRPC - Class in net.tomp2p.rpc

TrackerRPC(PeerBean, ConnectionBean, ConnectionConfiguration) - Constructor for class net.tomp2p.rpc.TrackerRPC

TrackerStorage - Class in net.tomp2p.storage

The maintenance for the tracker is done by the client peer.

TrackerStorage(IdentityManagement, int, PeerBean, Maintenance) - Constructor for class net.tomp2p.storage.TrackerStorage

TrackerStorage.ReferrerType - Enum in net.tomp2p.storage

TrackerStorageReplication - Class in net.tomp2p.replication

TrackerStorageReplication(Peer, PeerExchangeRPC, Map<BaseFuture, Long>, TrackerStorage, boolean) - Constructor for class net.tomp2p.replication.TrackerStorageReplication

transferToCurrent(FileChannel, long) - Method in interface net.tomp2p.message.ProtocolChunked

transferToCurrent(FileChannel, long) - Method in class net.tomp2p.message.ProtocolChunkedInput

triggerStatUpdate(boolean, int) - Method in class net.tomp2p.p2p.Statistics

type - Variable in class net.tomp2p.futures.BaseFutureImpl

U

UDN - Variable in class net.tomp2p.upnp.Device

UDP_LIMIT - Static variable in class net.tomp2p.connection.ConnectionHandler

UI1 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Unsigned 1 Byte int.

UI1_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

UI2 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Unsigned 2 Byte int.

UI2_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

UI4 - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Unsigned 4 Byte int.

UI4_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

uncompress(byte[], int, int) - Static method in class net.tomp2p.utils.Utils

uncompress(byte[]) - Static method in class net.tomp2p.utils.Utils

unlock(K, Lock) - Method in class net.tomp2p.storage.KeyLock

unRegisterResultsHandler(DiscoveryResultsHandler, String) - Method in class net.tomp2p.upnp.DiscoveryListener

Unregisters an SSDP response message handler

unsignedInt(int) - Method in class net.tomp2p.peers.Number160

For debugging...

UPC - Variable in class net.tomp2p.upnp.Device

updateExistingPeerAddress(PeerAddress) - Method in class net.tomp2p.peers.PeerMap

Checks if a peer already existis in this map and if it does, it will update the entry becaues the peer address (e.g.

updatePeerMapIfCloser(Number160, Number160) - Method in class net.tomp2p.replication.Replication

updateResponsibilities(Number160, Number160) - Method in interface net.tomp2p.storage.ReplicationStorage

updateResponsibilities(Number160, Number160) - Method in class net.tomp2p.storage.StorageDisk

updateResponsibilities(Number160, Number160) - Method in class net.tomp2p.storage.StorageMemory

updateResponsibilities(Number160, Number160) - Method in class net.tomp2p.storage.StorageMemoryReplication

updateResponsibilities(Number160, Number160) - Method in class net.tomp2p.storage.TrackerStorage

UPNPMessageFactory - Class in net.tomp2p.upnp

Factory to create UPNP messages to access and communicate with a given UPNPDevice service capabilities

UPNPMessageFactory(Service) - Constructor for class net.tomp2p.upnp.UPNPMessageFactory

UPNPResponseException - Exception in net.tomp2p.upnp

An exception throws when parsing a message if a SOAP fault exception is returned.

URI - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Universal Resource Identifier.

URI_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

USN - Variable in class net.tomp2p.upnp.Device

USN - Variable in class net.tomp2p.upnp.Service

Utils - Class in net.tomp2p.utils

Utils() - Constructor for class net.tomp2p.utils.Utils

UUID - Static variable in interface net.tomp2p.upnp.StateVariableTypes

Universally Unique ID.

UUID_INT - Static variable in interface net.tomp2p.upnp.StateVariableTypes

V

valueOf(String) - Static method in enum net.tomp2p.connection.Bindings.Protocol

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.connection.PeerException.AbortCause

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.futures.BaseFuture.FutureType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.message.Message.Command

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.message.Message.Content

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.message.Message.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.natpmp.ResultCode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.peers.PeerStatusListener.Reason

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.storage.StorageGeneric.ProtectionEnable

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.storage.StorageGeneric.ProtectionMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.storage.StorageGeneric.PutStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.storage.TrackerStorage.ReferrerType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.tomp2p.upnp.Argument.Direction

Returns the enum constant of this type with the specified name.

values() - Static method in enum net.tomp2p.connection.Bindings.Protocol

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.connection.PeerException.AbortCause

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.futures.BaseFuture.FutureType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.message.Message.Command

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.message.Message.Content

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.message.Message.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.natpmp.ResultCode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.peers.PeerStatusListener.Reason

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.storage.StorageGeneric.ProtectionEnable

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.storage.StorageGeneric.ProtectionMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.storage.StorageGeneric.PutStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.storage.TrackerStorage.ReferrerType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum net.tomp2p.upnp.Argument.Direction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Method in class net.tomp2p.utils.ConcurrentCacheMap

VotingSchemeDHT - Class in net.tomp2p.p2p

VotingSchemeDHT() - Constructor for class net.tomp2p.p2p.VotingSchemeDHT

VotingSchemeTracker - Class in net.tomp2p.p2p

VotingSchemeTracker() - Constructor for class net.tomp2p.p2p.VotingSchemeTracker

W

waitFor(K) - Method in class net.tomp2p.futures.FutureWrapper

Wait for the future, which will cause this future to complete if the wrapped future completes.

waitUntilQueueEmpty() - Method in class net.tomp2p.natpmp.NatPmpDevice

Synchronously waits until the queue is empty before returning.

Worker - Interface in net.tomp2p.task

writeComplete(ChannelHandlerContext, WriteCompletionEvent) - Method in class net.tomp2p.connection.ReplyTimeoutHandler

writeRequested(ChannelHandlerContext, MessageEvent) - Method in class net.tomp2p.connection.PerformanceFilter

X

XMLUtil - Class in net.tomp2p.upnp

Handy stuff for dealing with XML

XMLUtil() - Constructor for class net.tomp2p.upnp.XMLUtil

xor(Number160) - Method in class net.tomp2p.peers.Number160

Xor operation.

xpath - Static variable in class net.tomp2p.upnp.XMLUtil

XPath instance

Z

ZERO - Static variable in class net.tomp2p.peers.Number160

A B C D E F G H I K L M N O P Q R S T U V W X Z