Class InternetDiscoveryChildrenHandler
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelDuplexHandler
org.drasyl.handler.remote.internet.InternetDiscoveryChildrenHandler
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
,io.netty.channel.ChannelOutboundHandler
- Direct Known Subclasses:
TraversingInternetDiscoveryChildrenHandler
public class InternetDiscoveryChildrenHandler
extends io.netty.channel.ChannelDuplexHandler
Joins one or multiple super peer(s) as a children. Uses the super peer with the best RTT as a
default gateway for outbound messages.
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static class
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected InetSocketAddress
protected final LongSupplier
protected final long
protected final int
protected final ProofOfWork
protected final IdentityPublicKey
protected final DuplicatePathEventFilter
protected final long
protected final Map<IdentityPublicKey,
InternetDiscoveryChildrenHandler.SuperPeer> -
Constructor Summary
ConstructorsConstructorDescriptionInternetDiscoveryChildrenHandler
(int myNetworkId, Identity myIdentity, long initialPingDelayMillis, long pingIntervalMillis, long pingTimeoutMillis, long maxTimeOffsetMillis, Map<IdentityPublicKey, InetSocketAddress> superPeerAddresses) InternetDiscoveryChildrenHandler
(int myNetworkId, IdentityPublicKey myPublicKey, IdentitySecretKey mySecretKey, ProofOfWork myProofOfWork, long initialPingDelayMillis, long pingIntervalMillis, long pingTimeoutMillis, long maxTimeOffsetMillis, Map<IdentityPublicKey, InetSocketAddress> superPeerAddresses) InternetDiscoveryChildrenHandler
(int myNetworkId, IdentityPublicKey myPublicKey, IdentitySecretKey mySecretKey, ProofOfWork myProofOfWork, LongSupplier currentTime, long initialPingDelayMillis, long pingIntervalMillis, long pingTimeoutMillis, long maxTimeOffsetMillis, Map<IdentityPublicKey, InetSocketAddress> superPeerAddresses) -
Method Summary
Modifier and TypeMethodDescriptionvoid
channelActive
(io.netty.channel.ChannelHandlerContext ctx) void
channelInactive
(io.netty.channel.ChannelHandlerContext ctx) void
channelRead
(io.netty.channel.ChannelHandlerContext ctx, Object msg) protected Set<InetSocketAddress>
protected boolean
void
userEventTriggered
(io.netty.channel.ChannelHandlerContext ctx, Object evt) void
write
(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) protected void
writeHelloMessage
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress publicKey, InetSocketAddress inetAddress, Set<InetSocketAddress> privateInetAddresses) Make sure to callChannel.flush()
by your own!Methods inherited from class io.netty.channel.ChannelDuplexHandler
bind, close, connect, deregister, disconnect, flush, read
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded, handlerRemoved
-
Field Details
-
myNetworkId
protected final int myNetworkId -
myPublicKey
-
myProofOfWork
-
currentTime
-
pingTimeoutMillis
protected final long pingTimeoutMillis -
maxTimeOffsetMillis
protected final long maxTimeOffsetMillis -
superPeers
-
pathEventFilter
-
bindAddress
-
-
Constructor Details
-
InternetDiscoveryChildrenHandler
public InternetDiscoveryChildrenHandler(int myNetworkId, IdentityPublicKey myPublicKey, IdentitySecretKey mySecretKey, ProofOfWork myProofOfWork, LongSupplier currentTime, long initialPingDelayMillis, long pingIntervalMillis, long pingTimeoutMillis, long maxTimeOffsetMillis, Map<IdentityPublicKey, InetSocketAddress> superPeerAddresses) -
InternetDiscoveryChildrenHandler
public InternetDiscoveryChildrenHandler(int myNetworkId, IdentityPublicKey myPublicKey, IdentitySecretKey mySecretKey, ProofOfWork myProofOfWork, long initialPingDelayMillis, long pingIntervalMillis, long pingTimeoutMillis, long maxTimeOffsetMillis, Map<IdentityPublicKey, InetSocketAddress> superPeerAddresses) -
InternetDiscoveryChildrenHandler
public InternetDiscoveryChildrenHandler(int myNetworkId, Identity myIdentity, long initialPingDelayMillis, long pingIntervalMillis, long pingTimeoutMillis, long maxTimeOffsetMillis, Map<IdentityPublicKey, InetSocketAddress> superPeerAddresses)
-
-
Method Details
-
channelActive
public void channelActive(io.netty.channel.ChannelHandlerContext ctx) - Specified by:
channelActive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelActive
in classio.netty.channel.ChannelInboundHandlerAdapter
-
channelInactive
public void channelInactive(io.netty.channel.ChannelHandlerContext ctx) - Specified by:
channelInactive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelInactive
in classio.netty.channel.ChannelInboundHandlerAdapter
-
channelRead
- Specified by:
channelRead
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelRead
in classio.netty.channel.ChannelInboundHandlerAdapter
-
write
public void write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) - Specified by:
write
in interfaceio.netty.channel.ChannelOutboundHandler
- Overrides:
write
in classio.netty.channel.ChannelDuplexHandler
-
userEventTriggered
- Specified by:
userEventTriggered
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
userEventTriggered
in classio.netty.channel.ChannelInboundHandlerAdapter
-
getPrivateAddresses
-
writeHelloMessage
protected void writeHelloMessage(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress publicKey, InetSocketAddress inetAddress, Set<InetSocketAddress> privateInetAddresses) Make sure to callChannel.flush()
by your own! -
isUnexpectedMessage
-