Class AEProxyImpl

    • Field Detail

      • LOGID

        private static final LogIDs LOGID
      • last_debug

        private long last_debug
      • port

        private int port
      • connect_timeout

        private final long connect_timeout
      • read_timeout

        private final long read_timeout
      • ssc

        private java.nio.channels.ServerSocketChannel ssc
      • write_select_regs

        private final java.util.HashMap write_select_regs
      • allow_external_access

        private boolean allow_external_access
      • destroyed

        private volatile boolean destroyed
    • Method Detail

      • acceptLoop

        protected void acceptLoop​(java.nio.channels.ServerSocketChannel ssc)
      • checkTimeouts

        protected void checkTimeouts()
      • requestWriteSelect

        protected void requestWriteSelect​(AEProxyConnectionImpl processor,
                                          java.nio.channels.SocketChannel sc)
      • cancelWriteSelect

        protected void cancelWriteSelect​(java.nio.channels.SocketChannel sc)
      • requestReadSelect

        protected void requestReadSelect​(AEProxyConnectionImpl processor,
                                         java.nio.channels.SocketChannel sc)
      • cancelReadSelect

        protected void cancelReadSelect​(java.nio.channels.SocketChannel sc)
      • requestConnectSelect

        protected void requestConnectSelect​(AEProxyConnectionImpl processor,
                                            java.nio.channels.SocketChannel sc)
      • cancelConnectSelect

        protected void cancelConnectSelect​(java.nio.channels.SocketChannel sc)
      • selectSuccess

        public boolean selectSuccess​(VirtualChannelSelector selector,
                                     java.nio.channels.SocketChannel sc,
                                     java.lang.Object attachment)
        Description copied from interface: VirtualChannelSelector.VirtualSelectorListener
        Called when a channel is successfully selected for readyness.
        Specified by:
        selectSuccess in interface VirtualChannelSelector.VirtualSelectorListener
        attachment - originally given with the channel's registration
        Returns:
        indicator of whether or not any 'progress' was made due to this select null -> progress made, String -> location of non progress e.g. read-select -> read >0 bytes, write-select -> wrote > 0 bytes
      • getPort

        public int getPort()
        Specified by:
        getPort in interface AEProxy
      • destroy

        public void destroy()
        Specified by:
        destroy in interface AEProxy