Class KcpHandshaker

java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.nio.AbstractNioChannel
io.netty.channel.nio.AbstractNioMessageChannel
emu.grasscutter.netty.KcpHandshaker
All Implemented Interfaces:
io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>

public class KcpHandshaker extends io.netty.channel.nio.AbstractNioMessageChannel
  • Nested Class Summary

    Nested classes/interfaces inherited from class io.netty.channel.nio.AbstractNioChannel

    io.netty.channel.nio.AbstractNioChannel.AbstractNioUnsafe, io.netty.channel.nio.AbstractNioChannel.NioUnsafe

    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 inherited from class io.netty.channel.nio.AbstractNioChannel

    readInterestOp
  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    KcpHandshaker(io.netty.channel.Channel parent, SelectableChannel ch, int readInterestOp)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    io.netty.channel.ChannelConfig
     
    protected void
    doBind(SocketAddress localAddress)
     
    protected boolean
    doConnect(SocketAddress remoteAddress, SocketAddress localAddress)
     
    protected void
     
    protected void
     
    protected int
     
    protected boolean
    doWriteMessage(Object msg, io.netty.channel.ChannelOutboundBuffer in)
     
    boolean
     
    protected SocketAddress
     
    io.netty.channel.ChannelMetadata
     
    protected SocketAddress
     

    Methods inherited from class io.netty.channel.nio.AbstractNioMessageChannel

    closeOnReadError, continueOnWriteError, continueReading, doBeginRead, doWrite, newUnsafe

    Methods inherited from class io.netty.channel.nio.AbstractNioChannel

    clearReadPending, doClose, doDeregister, doRegister, eventLoop, isCompatible, isOpen, isReadPending, javaChannel, newDirectBuffer, newDirectBuffer, selectionKey, setReadPending, unsafe

    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, doShutdownOutput, equals, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, 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
  • Constructor Details

    • KcpHandshaker

      protected KcpHandshaker(io.netty.channel.Channel parent, SelectableChannel ch, int readInterestOp)
  • Method Details

    • config

      public io.netty.channel.ChannelConfig config()
    • isActive

      public boolean isActive()
    • metadata

      public io.netty.channel.ChannelMetadata metadata()
    • doReadMessages

      protected int doReadMessages(List<Object> buf) throws Exception
      Specified by:
      doReadMessages in class io.netty.channel.nio.AbstractNioMessageChannel
      Throws:
      Exception
    • doWriteMessage

      protected boolean doWriteMessage(Object msg, io.netty.channel.ChannelOutboundBuffer in) throws Exception
      Specified by:
      doWriteMessage in class io.netty.channel.nio.AbstractNioMessageChannel
      Throws:
      Exception
    • doConnect

      protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
      Specified by:
      doConnect in class io.netty.channel.nio.AbstractNioChannel
      Throws:
      Exception
    • doFinishConnect

      protected void doFinishConnect() throws Exception
      Specified by:
      doFinishConnect in class io.netty.channel.nio.AbstractNioChannel
      Throws:
      Exception
    • localAddress0

      protected SocketAddress localAddress0()
      Specified by:
      localAddress0 in class io.netty.channel.AbstractChannel
    • remoteAddress0

      protected SocketAddress remoteAddress0()
      Specified by:
      remoteAddress0 in class io.netty.channel.AbstractChannel
    • doBind

      protected void doBind(SocketAddress localAddress) throws Exception
      Specified by:
      doBind in class io.netty.channel.AbstractChannel
      Throws:
      Exception
    • doDisconnect

      protected void doDisconnect() throws Exception
      Specified by:
      doDisconnect in class io.netty.channel.AbstractChannel
      Throws:
      Exception