A B C D G H I J K L M N O P Q R S T U W

A

accepted - Variable in class net.sf.neem.impl.Transport

Acceptor - Class in net.sf.neem.impl

Listening socket accepting connections.

ackIn - Variable in class net.sf.neem.impl.Gossip

ackOut - Variable in class net.sf.neem.impl.Gossip

add(InetSocketAddress) - Method in class net.sf.neem.impl.Transport

Initiate connection to peer.

addPeer(String, int) - Method in class net.sf.neem.Protocol

addPeer(String, int) - Method in interface net.sf.neem.ProtocolMBean

Connect to a new peer.

Addresses - Class in net.sf.neem.impl

Address manipulation utilities.

Application - Interface in net.sf.neem.impl

High level handler for messages.

B

Buffers - Class in net.sf.neem.impl

Buffer manipulation utilities.

BufferTooSmallException - Exception in net.sf.neem

Attempt to receive with a buffer too small.

bytesIn - Variable in class net.sf.neem.impl.Transport

bytesOut - Variable in class net.sf.neem.impl.Transport

C

clone(ByteBuffer[]) - Static method in class net.sf.neem.impl.Buffers

Clone a buffer array.

close(Connection) - Method in interface net.sf.neem.impl.ConnectionListener

Notification of a connection being closed.

close(Connection) - Method in class net.sf.neem.impl.Overlay

close() - Method in class net.sf.neem.impl.Transport

Close all socket connections and release polling thread.

close() - Method in class net.sf.neem.MulticastChannel

Close the channel.

compact(ByteBuffer[]) - Static method in class net.sf.neem.impl.Buffers

Compact a buffer array to a single buffer.

connect(InetSocketAddress) - Method in class net.sf.neem.MulticastChannel

Add an address of a remote peer.

connected - Variable in class net.sf.neem.impl.Transport

Connection - Class in net.sf.neem.impl

Connection with a peer.

ConnectionListener - Interface in net.sf.neem.impl

Low level connection handler.

connections() - Method in class net.sf.neem.impl.Overlay

Get all connections that have been validated.

connections() - Method in class net.sf.neem.impl.Transport

Get all connections.

copy(ByteBuffer, ByteBuffer[]) - Static method in class net.sf.neem.impl.Buffers

Copy a buffer array to a single buffer.

count(ByteBuffer[]) - Static method in class net.sf.neem.impl.Buffers

Count remaining bytes in a buffer array.

D

dataIn - Variable in class net.sf.neem.impl.Gossip

DataListener - Interface in net.sf.neem.impl

Low level handler for messages.

dataOut - Variable in class net.sf.neem.impl.Gossip

deliv - Variable in class net.sf.neem.impl.Gossip

deliver(ByteBuffer[]) - Method in interface net.sf.neem.impl.Application

Deliver a message to the application.

doIt() - Method in class net.sf.neem.impl.Periodic

G

gc() - Method in class net.sf.neem.impl.Transport

Call periodically to garbage collect idle connections.

getAcceptedSocks() - Method in class net.sf.neem.Protocol

getAcceptedSocks() - Method in interface net.sf.neem.ProtocolMBean

Get number of socket connections accepted.

getBufferSize() - Method in class net.sf.neem.impl.Transport

getBufferSize() - Method in class net.sf.neem.Protocol

getBufferSize() - Method in interface net.sf.neem.ProtocolMBean

Get the default size of socket buffers.

getBytesReceived() - Method in class net.sf.neem.Protocol

getBytesReceived() - Method in interface net.sf.neem.ProtocolMBean

Get number of raw bytes received.

getBytesSent() - Method in class net.sf.neem.Protocol

getBytesSent() - Method in interface net.sf.neem.ProtocolMBean

Get number of raw bytes transmitted.

getConnectedSocks() - Method in class net.sf.neem.Protocol

getConnectedSocks() - Method in interface net.sf.neem.ProtocolMBean

Get number of successful sockets connected.

getDataReceived() - Method in class net.sf.neem.Protocol

getDataReceived() - Method in interface net.sf.neem.ProtocolMBean

Get number of data packets received.

getDataSent() - Method in class net.sf.neem.Protocol

getDataSent() - Method in interface net.sf.neem.ProtocolMBean

Get number of data packets transmitted.

getDelivered() - Method in class net.sf.neem.Protocol

getDelivered() - Method in interface net.sf.neem.ProtocolMBean

Get number of messages delivered to the application.

getFanout() - Method in class net.sf.neem.impl.Gossip

getFanout() - Method in class net.sf.neem.impl.Overlay

getGossipFanout() - Method in class net.sf.neem.Protocol

getGossipFanout() - Method in interface net.sf.neem.ProtocolMBean

Get the number of gossip target for each round.

getHintsReceived() - Method in class net.sf.neem.Protocol

getHintsReceived() - Method in interface net.sf.neem.ProtocolMBean

Get number of packet hints received.

getHintsSent() - Method in class net.sf.neem.Protocol

getHintsSent() - Method in interface net.sf.neem.ProtocolMBean

Get number of packet hints transmitted.

getId() - Method in class net.sf.neem.impl.Overlay

Get globally unique ID in the overlay.

getInterval() - Method in class net.sf.neem.impl.Periodic

getJoinRequests() - Method in class net.sf.neem.Protocol

getJoinRequests() - Method in interface net.sf.neem.ProtocolMBean

Get number of direct join requests received.

getLocalAddress() - Method in class net.sf.neem.Protocol

getLocalAddress() - Method in interface net.sf.neem.ProtocolMBean

Local listening socket.

getLocalId() - Method in class net.sf.neem.Protocol

getLocalId() - Method in interface net.sf.neem.ProtocolMBean

Get globally unique local id.

getLocalSocketAddress() - Method in class net.sf.neem.impl.Acceptor

getLocalSocketAddress() - Method in class net.sf.neem.impl.Overlay

getLocalSocketAddress() - Method in class net.sf.neem.impl.Transport

Get local address.

getLocalSocketAddress() - Method in class net.sf.neem.MulticastChannel

Get the address of the local socket.

getLoopbackMode() - Method in class net.sf.neem.MulticastChannel

Query local loopback mode status.

getMaxIds() - Method in class net.sf.neem.impl.Gossip

getMaxIds() - Method in class net.sf.neem.Protocol

getMaxIds() - Method in interface net.sf.neem.ProtocolMBean

Get the maximum number of cached message ids.

getMinPullSize() - Method in class net.sf.neem.impl.Gossip

getMinPullSize() - Method in class net.sf.neem.Protocol

getMinPullSize() - Method in interface net.sf.neem.ProtocolMBean

Get the minimum size of messages that can be pulled.

getMsg() - Method in class net.sf.neem.impl.Queued

Returns the message in this Queued

getMulticast() - Method in class net.sf.neem.Protocol

getMulticast() - Method in interface net.sf.neem.ProtocolMBean

Get number of messages multicast locally by the application.

getOverlayFanout() - Method in class net.sf.neem.Protocol

getOverlayFanout() - Method in interface net.sf.neem.ProtocolMBean

Get the number of neighbors.

getPacketsReceived() - Method in class net.sf.neem.Protocol

getPacketsReceived() - Method in interface net.sf.neem.ProtocolMBean

Get number of packets received.

getPacketsSent() - Method in class net.sf.neem.Protocol

getPacketsSent() - Method in interface net.sf.neem.ProtocolMBean

Get number of packets transmited.

getPeer() - Method in class net.sf.neem.impl.Connection

getPeerAddresses() - Method in class net.sf.neem.impl.Overlay

Get all peer addresses.

getPeerAddresses() - Method in class net.sf.neem.Protocol

getPeerAddresses() - Method in interface net.sf.neem.ProtocolMBean

Get list of currently connected peers.

getPeerIds() - Method in class net.sf.neem.Protocol

getPeerIds() - Method in interface net.sf.neem.ProtocolMBean

Get list of currently connected peer ids.

getPeers() - Method in class net.sf.neem.impl.Overlay

Get all connected peers.

getPeers() - Method in class net.sf.neem.impl.Transport

Get addresses of all connected peers.

getPeerSocketAddress() - Method in class net.sf.neem.MulticastChannel

Get the address that is being advertised to peers.

getPort() - Method in class net.sf.neem.impl.Queued

Returns the port to wich the message is intended

getProtocolMBean() - Method in class net.sf.neem.MulticastChannel

Obtain a reference to a JMX compliant management bean.

getPublicAddress() - Method in class net.sf.neem.Protocol

getPublicAddress() - Method in interface net.sf.neem.ProtocolMBean

Get the address being advertised to peers.

getPullPeriod() - Method in class net.sf.neem.impl.Gossip

getPullPeriod() - Method in class net.sf.neem.Protocol

getPullPeriod() - Method in interface net.sf.neem.ProtocolMBean

Get period for retrying to pull known messages.

getPullReceived() - Method in class net.sf.neem.Protocol

getPullReceived() - Method in interface net.sf.neem.ProtocolMBean

Get number of pull request transmitted.

getPullSent() - Method in class net.sf.neem.Protocol

getPullSent() - Method in interface net.sf.neem.ProtocolMBean

Get number of pull requests transmitted.

getPurgedConnections() - Method in class net.sf.neem.Protocol

getPurgedConnections() - Method in interface net.sf.neem.ProtocolMBean

Get number of connections purged after overflowing local neighborhood.

getPushTimeToLive() - Method in class net.sf.neem.Protocol

getPushTimeToLive() - Method in interface net.sf.neem.ProtocolMBean

Get the maximum number of times that a message is pushed.

getPushttl() - Method in class net.sf.neem.impl.Gossip

getQueueSize() - Method in class net.sf.neem.impl.Transport

getQueueSize() - Method in class net.sf.neem.Protocol

getQueueSize() - Method in interface net.sf.neem.ProtocolMBean

Get the default size of buffer queues.

getRemoteAddress() - Method in class net.sf.neem.impl.Connection

getRequired() - Method in exception net.sf.neem.BufferTooSmallException

Obtains the number of bytes remaining required in the buffer to properly handle the next message in the queue.

getShufflePeriod() - Method in class net.sf.neem.impl.Overlay

getShufflePeriod() - Method in class net.sf.neem.Protocol

getShufflePeriod() - Method in interface net.sf.neem.ProtocolMBean

Get the delay between periodic shuffle.

getShufflesReceived() - Method in class net.sf.neem.Protocol

getShufflesReceived() - Method in interface net.sf.neem.ProtocolMBean

Get number of shuffle requests received.

getShufflesSent() - Method in class net.sf.neem.Protocol

getShufflesSent() - Method in interface net.sf.neem.ProtocolMBean

Get number of shuffle requests transmitted.

getTimeToLive() - Method in class net.sf.neem.Protocol

getTimeToLive() - Method in interface net.sf.neem.ProtocolMBean

Get the maximum number of times that a message is relayed.

getTruncateMode() - Method in class net.sf.neem.MulticastChannel

Query local message truncate mode.

getTtl() - Method in class net.sf.neem.impl.Gossip

Gossip - Class in net.sf.neem.impl

Implementation of gossip.

Gossip(Random, Transport, Overlay, short, short) - Constructor for class net.sf.neem.impl.Gossip

Creates a new instance of Gossip.

H

handler(Application) - Method in class net.sf.neem.impl.Gossip

Handler - Class in net.sf.neem.impl

Abstract event handler.

Handler(Transport) - Constructor for class net.sf.neem.impl.Handler

I

id - Variable in class net.sf.neem.impl.Connection

Used by overlay management to assign an unique id to the remote process.

id - Variable in class net.sf.neem.impl.Known

isEmpty() - Method in class net.sf.neem.impl.Queue

isOpen() - Method in class net.sf.neem.MulticastChannel

True if the channel has not yet been (explicitly or implicitly) closed.

J

joins - Variable in class net.sf.neem.impl.Overlay

K

Known - Class in net.sf.neem.impl

Known but yet unreceived message.

Known(UUID, Connection) - Constructor for class net.sf.neem.impl.Known

L

last - Variable in class net.sf.neem.impl.Known

listen - Variable in class net.sf.neem.impl.Connection

Used by overlay management to keep the socket where this peer can be contacted.

logger - Static variable in class net.sf.neem.impl.Handler

M

max - Variable in class net.sf.neem.impl.Queue

mcast - Variable in class net.sf.neem.impl.Gossip

mkUniverse(int) - Static method in class net.sf.neem.impl.RandomSamples

Initializes the universe for computing random samples.

multicast(ByteBuffer[]) - Method in class net.sf.neem.impl.Gossip

MulticastChannel - Class in net.sf.neem

Channel interface to a NeEM epidemic multicast group.

MulticastChannel(InetSocketAddress) - Constructor for class net.sf.neem.MulticastChannel

Creates a new instance of a multicast channel.

MulticastChannel(InetSocketAddress, InetSocketAddress, UUID) - Constructor for class net.sf.neem.MulticastChannel

Creates a new instance of a multicast channel.

N

nackIn - Variable in class net.sf.neem.impl.Gossip

nackOut - Variable in class net.sf.neem.impl.Gossip

net.sf.neem - package net.sf.neem

Provides a simple and safe interface to NeEM targeted at the application programmer.

net.sf.neem.impl - package net.sf.neem.impl

Contains building blocks of NeEM for protocol development and customization.

O

open(Connection) - Method in interface net.sf.neem.impl.ConnectionListener

Notification of a new connection.

open(Connection) - Method in class net.sf.neem.impl.Overlay

Overlay - Class in net.sf.neem.impl

Implementation of overlay management.

Overlay(Random, InetSocketAddress, UUID, Transport, short, short, short) - Constructor for class net.sf.neem.impl.Overlay

Creates a new instance of Overlay

P

Periodic - Class in net.sf.neem.impl

A stopable and restartable periodic activity.

Periodic(Random, Transport, int) - Constructor for class net.sf.neem.impl.Periodic

pktIn - Variable in class net.sf.neem.impl.Transport

pktOut - Variable in class net.sf.neem.impl.Transport

pop() - Method in class net.sf.neem.impl.Queue

Retrieves (dequeues) an Object from this queue.

Protocol - Class in net.sf.neem

Implementation of the NeEM management bean.

ProtocolMBean - Interface in net.sf.neem

Interface for a JMX management bean.

purged - Variable in class net.sf.neem.impl.Overlay

push(Queued) - Method in class net.sf.neem.impl.Queue

Inserts (enqueues) an Object to this queue.

Q

queue - Variable in class net.sf.neem.impl.Connection

Message queue

Queue - Class in net.sf.neem.impl

Implementation of a FIFO queue with random purging.

Queue(int, Random) - Constructor for class net.sf.neem.impl.Queue

Creates a new queue.

queue(Runnable) - Method in class net.sf.neem.impl.Transport

Queue processing task.

Queued - Class in net.sf.neem.impl

Message and port wrapper for distribution enqueueing.

Queued(ByteBuffer[], short) - Constructor for class net.sf.neem.impl.Queued

Creates a new instance of Queued

R

RandomSamples - Class in net.sf.neem.impl

Efficient computation of random samples from a small universe.

RandomSamples() - Constructor for class net.sf.neem.impl.RandomSamples

read(ByteBuffer) - Method in class net.sf.neem.MulticastChannel

Receive a message.

readAddressFromBuffer(ByteBuffer[]) - Static method in class net.sf.neem.impl.Addresses

Read a socket address from an array of ByteBuffers into an InetSocketAddress.

readUUIDFromBuffer(ByteBuffer[]) - Static method in class net.sf.neem.impl.UUIDs

Read an UUID from an array of ByteBuffers into an UUID.

receive(ByteBuffer[], Connection, short) - Method in interface net.sf.neem.impl.DataListener

Receive a message from from a connection.

receive(ByteBuffer[], Connection, short) - Method in class net.sf.neem.impl.Gossip

receive(ByteBuffer[], Connection, short) - Method in class net.sf.neem.impl.Overlay

resetCounters() - Method in class net.sf.neem.impl.Gossip

resetCounters() - Method in class net.sf.neem.impl.Overlay

resetCounters() - Method in class net.sf.neem.impl.Transport

resetCounters() - Method in class net.sf.neem.Protocol

resetCounters() - Method in interface net.sf.neem.ProtocolMBean

Resets all counters.

run() - Method in class net.sf.neem.impl.Transport

Main loop.

S

schedule(Runnable, long) - Method in class net.sf.neem.impl.Transport

Schedule processing task.

send(ByteBuffer[], short) - Method in class net.sf.neem.impl.Connection

Send message to peers

senders - Variable in class net.sf.neem.impl.Known

setBufferSize(int) - Method in class net.sf.neem.impl.Transport

setBufferSize(int) - Method in class net.sf.neem.Protocol

setBufferSize(int) - Method in interface net.sf.neem.ProtocolMBean

Set the default size of socket buffers.

setConnectionListener(ConnectionListener) - Method in class net.sf.neem.impl.Transport

Sets the reference to the connection handler.

setDataListener(DataListener, short) - Method in class net.sf.neem.impl.Transport

Add a reference to a message handler.

setFanout(int) - Method in class net.sf.neem.impl.Gossip

setFanout(int) - Method in class net.sf.neem.impl.Overlay

setGossipFanout(int) - Method in class net.sf.neem.Protocol

setGossipFanout(int) - Method in interface net.sf.neem.ProtocolMBean

Set the number of gossip target for each round.

setInterval(int) - Method in class net.sf.neem.impl.Periodic

setLoopbackMode(boolean) - Method in class net.sf.neem.MulticastChannel

Disable/enable local loopback mode.

setMaxIds(int) - Method in class net.sf.neem.impl.Gossip

setMaxIds(int) - Method in class net.sf.neem.Protocol

setMaxIds(int) - Method in interface net.sf.neem.ProtocolMBean

Set the maximum number of cached message ids.

setMinPullSize(int) - Method in class net.sf.neem.impl.Gossip

setMinPullSize(int) - Method in class net.sf.neem.Protocol

setMinPullSize(int) - Method in interface net.sf.neem.ProtocolMBean

Set the minimum size of messages that can be pulled.

setOverlayFanout(int) - Method in class net.sf.neem.Protocol

setOverlayFanout(int) - Method in interface net.sf.neem.ProtocolMBean

Set the number of neighbors.

setPullPeriod(int) - Method in class net.sf.neem.impl.Gossip

setPullPeriod(int) - Method in class net.sf.neem.Protocol

setPullPeriod(int) - Method in interface net.sf.neem.ProtocolMBean

Set period for retrying to pull known messages.

setPushTimeToLive(int) - Method in class net.sf.neem.Protocol

setPushTimeToLive(int) - Method in interface net.sf.neem.ProtocolMBean

Set the maximum number of times that a message is pushed.

setPushttl(int) - Method in class net.sf.neem.impl.Gossip

setQueueSize(int) - Method in class net.sf.neem.impl.Transport

setQueueSize(int) - Method in class net.sf.neem.Protocol

setQueueSize(int) - Method in interface net.sf.neem.ProtocolMBean

Set the default size of buffer queues.

setShufflePeriod(int) - Method in class net.sf.neem.impl.Overlay

setShufflePeriod(int) - Method in class net.sf.neem.Protocol

setShufflePeriod(int) - Method in interface net.sf.neem.ProtocolMBean

Set the delay between periodic shuffle.

setTimeToLive(int) - Method in class net.sf.neem.Protocol

setTimeToLive(int) - Method in interface net.sf.neem.ProtocolMBean

Set the maximum number of times that a message is relayed.

setTruncateMode(boolean) - Method in class net.sf.neem.MulticastChannel

Disable/enable local message truncate mode.

setTtl(int) - Method in class net.sf.neem.impl.Gossip

shuffleIn - Variable in class net.sf.neem.impl.Overlay

shuffleOut - Variable in class net.sf.neem.impl.Overlay

slice(ByteBuffer[], int) - Static method in class net.sf.neem.impl.Buffers

Remove data from the head of a buffer array.

sliceCompact(ByteBuffer[], int) - Static method in class net.sf.neem.impl.Buffers

Remove a contiguous header from the head of a buffer array.

sock - Variable in class net.sf.neem.impl.Connection

start() - Method in class net.sf.neem.impl.Periodic

stop() - Method in class net.sf.neem.impl.Periodic

T

toString() - Method in class net.sf.neem.impl.Queue

toString() - Method in class net.sf.neem.impl.Queued

tradePeers(Connection, Connection) - Method in class net.sf.neem.impl.Overlay

Connect two other peers by informing one of the other.

transport - Variable in class net.sf.neem.impl.Handler

Transport - Class in net.sf.neem.impl

Implementation of the network layer.

Transport(Random, InetSocketAddress) - Constructor for class net.sf.neem.impl.Transport

U

uniformSample(int, int[], Random) - Static method in class net.sf.neem.impl.RandomSamples

Efficiently calculate a random sample.

UUIDs - Class in net.sf.neem.impl

UUID manipulation utilities.

W

write(ByteBuffer) - Method in class net.sf.neem.MulticastChannel

Send a message to members of the group.

writeAddressToBuffer(InetSocketAddress) - Static method in class net.sf.neem.impl.Addresses

Write a socket address to a ByteBuffer.

writeUUIDToBuffer(UUID) - Static method in class net.sf.neem.impl.UUIDs

Write an UUID to a ByteBuffer.

A B C D G H I J K L M N O P Q R S T U W