Package org.drasyl.handler.remote

Class PeersManager

java.lang.Object

org.drasyl.handler.remote.PeersManager

public class PeersManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PeersManager.PathId

Constructor Summary

Constructors

Constructor	Description
PeersManager()

Method Summary

Modifier and Type	Method	Description
void	acknowledgementMessageReceived(DrasylAddress peerKey, PeersManager.PathId id)
void	acknowledgementMessageReceived(DrasylAddress peerKey, PeersManager.PathId id, int rtt)
boolean	addChildrenPath(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint)
boolean	addChildrenPath(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint, int rtt)
boolean	addSuperPeerPath(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint, int rtt)
void	applicationMessageReceived(DrasylAddress peerKey)
void	applicationMessageSent(DrasylAddress peerKey)
Set<DrasylAddress>	getPeers(PeersManager.PathId id)
boolean	hasApplicationTraffic(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey)
boolean	hasDefaultPeer()
boolean	hasPath(PeersManager.PathId id)
boolean	hasPath(DrasylAddress peerKey)
boolean	hasPath(DrasylAddress peerKey, PeersManager.PathId id)
void	helloMessageReceived(DrasylAddress peerKey, PeersManager.PathId id)
void	helloMessageSent(DrasylAddress peerKey, PeersManager.PathId id)
boolean	isReachable(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id)
boolean	isStale(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id)
boolean	removeChildrenPath(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id)
void	removeChildrenPaths(io.netty.channel.ChannelHandlerContext ctx, PeersManager.PathId id)
boolean	removeSuperPeerPath(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id)
void	removeSuperPeerPaths(io.netty.channel.ChannelHandlerContext ctx, PeersManager.PathId id)
InetSocketAddress	resolve(DrasylAddress peerKey)
InetSocketAddress	resolveInetAddress(DrasylAddress peerKey, PeersManager.PathId id)
int	rtt(DrasylAddress peerKey, PeersManager.PathId id)
DrasylAddress	setDefaultPeer(DrasylAddress newDefaultPeerKey)
DrasylAddress	setDefaultPeerIfUnset(DrasylAddress newDefaultPeerKey)
String	toString()
boolean	tryAddChildrenPath(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint)
DrasylAddress	unsetDefaultPeer()

Methods inherited from class java.lang.Object

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

Constructor Details

PeersManager

public PeersManager()

Method Details

toString

public String toString()

Overrides:

toString in class Object

hasApplicationTraffic

public boolean hasApplicationTraffic(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey)

applicationMessageSent

public void applicationMessageSent(DrasylAddress peerKey)

applicationMessageReceived

public void applicationMessageReceived(DrasylAddress peerKey)

resolve

public InetSocketAddress resolve(DrasylAddress peerKey)

hasPath

public boolean hasPath(PeersManager.PathId id)

hasPath

public boolean hasPath(DrasylAddress peerKey)

hasPath

public boolean hasPath(DrasylAddress peerKey,
 PeersManager.PathId id)

hasDefaultPeer

public boolean hasDefaultPeer()

setDefaultPeer

public DrasylAddress setDefaultPeer(DrasylAddress newDefaultPeerKey)

Throws:

NullPointerException - if newDefaultPeerKey is null

setDefaultPeerIfUnset

public DrasylAddress setDefaultPeerIfUnset(DrasylAddress newDefaultPeerKey)

unsetDefaultPeer

public DrasylAddress unsetDefaultPeer()

addSuperPeerPath

public boolean addSuperPeerPath(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id,
 InetSocketAddress endpoint,
 int rtt)

removeSuperPeerPath

public boolean removeSuperPeerPath(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id)

removeSuperPeerPaths

public void removeSuperPeerPaths(io.netty.channel.ChannelHandlerContext ctx,
 PeersManager.PathId id)

addChildrenPath

public boolean addChildrenPath(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id,
 InetSocketAddress endpoint,
 int rtt)

addChildrenPath

public boolean addChildrenPath(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id,
 InetSocketAddress endpoint)

tryAddChildrenPath

public boolean tryAddChildrenPath(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id,
 InetSocketAddress endpoint)

removeChildrenPath

public boolean removeChildrenPath(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id)

removeChildrenPaths

public void removeChildrenPaths(io.netty.channel.ChannelHandlerContext ctx,
 PeersManager.PathId id)

getPeers

public Set<DrasylAddress> getPeers(PeersManager.PathId id)

isStale

public boolean isStale(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id)

isReachable

public boolean isReachable(io.netty.channel.ChannelHandlerContext ctx,
 DrasylAddress peerKey,
 PeersManager.PathId id)

helloMessageReceived

public void helloMessageReceived(DrasylAddress peerKey,
 PeersManager.PathId id)

helloMessageSent

public void helloMessageSent(DrasylAddress peerKey,
 PeersManager.PathId id)

acknowledgementMessageReceived

public void acknowledgementMessageReceived(DrasylAddress peerKey,
 PeersManager.PathId id,
 int rtt)

acknowledgementMessageReceived

public void acknowledgementMessageReceived(DrasylAddress peerKey,
 PeersManager.PathId id)

rtt

public int rtt(DrasylAddress peerKey,
 PeersManager.PathId id)

resolveInetAddress

public InetSocketAddress resolveInetAddress(DrasylAddress peerKey,
 PeersManager.PathId id)