Class TRNonBlockingServerProcessor

    • Field Detail

      • socket_channel

        private final java.nio.channels.SocketChannel socket_channel
      • start_time

        private long start_time
      • read_buffer

        private java.nio.ByteBuffer read_buffer
      • post_data_buffer

        private java.nio.ByteBuffer post_data_buffer
      • request_header

        private java.lang.String request_header
      • lc_request_header

        private java.lang.String lc_request_header
      • write_buffer

        private java.nio.ByteBuffer write_buffer
      • keep_alive

        private boolean keep_alive
    • Constructor Detail

      • TRNonBlockingServerProcessor

        protected TRNonBlockingServerProcessor​(TRTrackerServerTCP _server,
                                               java.nio.channels.SocketChannel _socket)
    • Method Detail

      • processRead

        protected int processRead()
      • processWrite

        protected int processWrite()
      • process

        protected abstract java.io.ByteArrayOutputStream process​(java.lang.String input_header,
                                                                 java.lang.String lowercase_input_header,
                                                                 java.lang.String url_path,
                                                                 java.net.InetSocketAddress client_address,
                                                                 boolean announce_and_scrape_only,
                                                                 java.io.InputStream is,
                                                                 AsyncController async)
                                                          throws java.io.IOException
        Throws:
        java.io.IOException
      • asyncProcessComplete

        protected void asyncProcessComplete​(java.io.ByteArrayOutputStream response)
      • getSocketChannel

        protected java.nio.channels.SocketChannel getSocketChannel()
      • getPostData

        protected byte[] getPostData()
      • getStartTime

        protected long getStartTime()
      • getKeepAlive

        protected boolean getKeepAlive()
      • setKeepAlive

        protected void setKeepAlive​(boolean k)
      • failed

        protected void failed()
      • writeComplete

        protected void writeComplete()
      • completed

        protected void completed()
      • closed

        protected void closed()