Package org.drasyl.channel

Class DrasylServerChannel

java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.AbstractServerChannel
org.drasyl.channel.DrasylServerChannel
All Implemented Interfaces:
io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.channel.ServerChannel, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>
@UnstableApi public class DrasylServerChannel extends io.netty.channel.AbstractServerChannel
A virtual ServerChannel used for overlay network management. This channel must be bind to an Identity.

(Currently) only compatible with NioEventLoop.

Inspired by LocalServerChannel.

See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

    io.netty.channel.AbstractChannel.AbstractUnsafe

    Nested classes/interfaces inherited from interface io.netty.channel.Channel

    io.netty.channel.Channel.Unsafe

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    final Map<SocketAddress,DrasylChannel>
    channels
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    DrasylServerChannel()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.netty.channel.DefaultChannelConfig
    config()
     
    protected void
    doBeginRead()
     
    protected void
    doBind(SocketAddress localAddress)
     
    protected void
    doClose()
     
    protected void
    doRegister()
     
    boolean
    isActive()
     
    protected boolean
    isCompatible(io.netty.channel.EventLoop loop)
     
    boolean
    isOpen()
     
    protected DrasylAddress
    localAddress0()
     
    protected DrasylChannel
    newDrasylChannel(DrasylAddress peer)
     
    io.netty.util.concurrent.Promise<DrasylChannel>
    serve(DrasylAddress peer)
     
    io.netty.util.concurrent.Promise<DrasylChannel>
    serve(DrasylAddress peer, io.netty.util.concurrent.Promise<DrasylChannel> promise)
     

    Methods inherited from class io.netty.channel.AbstractServerChannel

    doDisconnect, doWrite, filterOutboundMessage, metadata, newUnsafe, remoteAddress, remoteAddress0

    Methods inherited from class io.netty.channel.AbstractChannel

    alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush

    Methods inherited from class io.netty.util.DefaultAttributeMap

    attr, hasAttr

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface io.netty.util.AttributeMap

    attr, hasAttr

    Methods inherited from interface io.netty.channel.Channel

    alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isRegistered, isWritable, localAddress, parent, pipeline, read, unsafe

    Methods inherited from interface io.netty.channel.ChannelOutboundInvoker

    bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

    Methods inherited from interface java.lang.Comparable

    compareTo

  • Field Details

  • Constructor Details

    • DrasylServerChannel

      public DrasylServerChannel()

  • Method Details

    • isCompatible

      protected boolean isCompatible(io.netty.channel.EventLoop loop)
      Specified by:
      isCompatible in class io.netty.channel.AbstractChannel

    • localAddress0

      protected DrasylAddress localAddress0()
      Specified by:
      localAddress0 in class io.netty.channel.AbstractChannel

    • doBind

      protected void doBind(SocketAddress localAddress)
      Specified by:
      doBind in class io.netty.channel.AbstractChannel

    • doRegister

      protected void doRegister() throws Exception
      Overrides:
      doRegister in class io.netty.channel.AbstractChannel
      Throws:
      Exception

    • doClose

      protected void doClose()
      Specified by:
      doClose in class io.netty.channel.AbstractChannel

    • doBeginRead

      protected void doBeginRead()
      Specified by:
      doBeginRead in class io.netty.channel.AbstractChannel

    • config

      public io.netty.channel.DefaultChannelConfig config()

    • isOpen

      public boolean isOpen()

    • isActive

      public boolean isActive()

    • newDrasylChannel

      protected DrasylChannel newDrasylChannel(DrasylAddress peer)

    • serve

      public io.netty.util.concurrent.Promise<DrasylChannel> serve(DrasylAddress peer, io.netty.util.concurrent.Promise<DrasylChannel> promise)

    • serve

      public io.netty.util.concurrent.Promise<DrasylChannel> serve(DrasylAddress peer)