Package org.drasyl.peer.connection.server

Class Server

java.lang.Object

org.drasyl.peer.connection.server.Server

All Implemented Interfaces:

AutoCloseable, DrasylNodeComponent

public class Server
extends Object
implements DrasylNodeComponent

The server binds to a defined port and thus allows the node to be discovered and contacted by other peers.

Constructor Summary

Constructors

Constructor	Description
Server(Identity identity, Pipeline pipeline, PeersManager peersManager, DrasylConfig config, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, io.netty.channel.EventLoopGroup bossGroup, AtomicBoolean opened, BooleanSupplier acceptNewConnectionsSupplier, Set<Endpoint> nodeEndpoints)	Server for accepting connections from child peers and non-child peers.
Server(Identity identity, Pipeline pipeline, PeersManager peersManager, DrasylConfig config, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, io.netty.channel.EventLoopGroup bossGroup, Set<Endpoint> nodeEndpoints, BooleanSupplier acceptNewConnectionsSupplier)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the server socket and all open client sockets.
void	open()	Starts the server.

Methods inherited from class java.lang.Object

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

Constructor Details

Server

public Server(Identity identity,
 Pipeline pipeline,
 PeersManager peersManager,
 DrasylConfig config,
 PeerChannelGroup channelGroup,
 io.netty.channel.EventLoopGroup workerGroup,
 io.netty.channel.EventLoopGroup bossGroup,
 Set<Endpoint> nodeEndpoints,
 BooleanSupplier acceptNewConnectionsSupplier)
       throws ServerException

Throws:

ServerException

Server

public Server(Identity identity,
 Pipeline pipeline,
 PeersManager peersManager,
 DrasylConfig config,
 PeerChannelGroup channelGroup,
 io.netty.channel.EventLoopGroup workerGroup,
 io.netty.channel.EventLoopGroup bossGroup,
 AtomicBoolean opened,
 BooleanSupplier acceptNewConnectionsSupplier,
 Set<Endpoint> nodeEndpoints)
       throws ServerException

Server for accepting connections from child peers and non-child peers.

Parameters:

identity - the identity manager

pipeline - the pipeline object

peersManager - the peers manager

config - config that should be used

channelGroup - the channel group

workerGroup - netty shared worker group

bossGroup - netty shared boss group

acceptNewConnectionsSupplier - the accept new connections supplier

nodeEndpoints - the node endpoints

Throws:

ServerException

Method Details

open

public void open()
          throws ServerException

Starts the server.

Specified by:

open in interface DrasylNodeComponent

Throws:

ServerException

close

public void close()

Closes the server socket and all open client sockets.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface DrasylNodeComponent