Package org.drasyl.peer.connection.client

Class SuperPeerClient

java.lang.Object

org.drasyl.peer.connection.client.SuperPeerClient

All Implemented Interfaces:

AutoCloseable, DrasylNodeComponent

public class SuperPeerClient
extends Object

This class represents the link between DrasylNode and the super peer. It is responsible for maintaining the connection to the super peer and updates the data of the super peer in PeersManager.

Field Summary

Fields

Modifier and Type	Field	Description
protected io.netty.channel.Channel	channel
protected final BooleanSupplier	doNewConnectionsSupplier

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SuperPeerClient(DrasylConfig config, io.netty.channel.EventLoopGroup workerGroup, BooleanSupplier doNewConnectionsSupplier, DrasylFunction<Endpoint,io.netty.bootstrap.Bootstrap,ClientException> bootstrapSupplier)
	SuperPeerClient(DrasylConfig config, Identity identity, PeersManager peersManager, Pipeline pipeline, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, BooleanSupplier doNewConnectionsSupplier)

Method Summary

Modifier and Type	Method	Description
void	close()	Stops the component.
protected void	failed()	This method is called if a connection was not possible and no further connection attempts will be made.
protected org.slf4j.Logger	getLogger()
protected static ClientChannelInitializer	initiateChannelInitializer(ClientEnvironment environment, Class<? extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>> clazz)
void	open()	Starts the component.
protected boolean	shouldRetry()

Methods inherited from class java.lang.Object

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

Field Details

doNewConnectionsSupplier

protected final BooleanSupplier doNewConnectionsSupplier

channel

protected io.netty.channel.Channel channel

Constructor Details

SuperPeerClient

protected SuperPeerClient(DrasylConfig config,
 io.netty.channel.EventLoopGroup workerGroup,
 BooleanSupplier doNewConnectionsSupplier,
 DrasylFunction<Endpoint,io.netty.bootstrap.Bootstrap,ClientException> bootstrapSupplier)

SuperPeerClient

public SuperPeerClient(DrasylConfig config,
 Identity identity,
 PeersManager peersManager,
 Pipeline pipeline,
 PeerChannelGroup channelGroup,
 io.netty.channel.EventLoopGroup workerGroup,
 BooleanSupplier doNewConnectionsSupplier)

Method Details

getLogger

protected org.slf4j.Logger getLogger()

open

public void open()

Description copied from interface: DrasylNodeComponent

Starts the component.

Specified by:

open in interface DrasylNodeComponent

shouldRetry

protected boolean shouldRetry()

Returns:

true if the client should attempt to reconnect. Otherwise false is returned

failed

protected void failed()

This method is called if a connection was not possible and no further connection attempts will be made.

close

public void close()

Description copied from interface: DrasylNodeComponent

Stops the component.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface DrasylNodeComponent

initiateChannelInitializer

protected static ClientChannelInitializer initiateChannelInitializer(ClientEnvironment environment,
 Class<? extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>> clazz)
                                                              throws ClientException

Throws:

ClientException