Class HttpReceiverOverHTTP

    • Field Detail

      • inMessages

        private final java.util.concurrent.atomic.LongAdder inMessages
      • shutdown

        private boolean shutdown
      • complete

        private boolean complete
      • unsolicited

        private boolean unsolicited
      • method

        private java.lang.String method
      • status

        private int status
    • Method Detail

      • getResponseBuffer

        protected java.nio.ByteBuffer getResponseBuffer()
      • acquireNetworkBuffer

        private void acquireNetworkBuffer()
      • reacquireNetworkBuffer

        private void reacquireNetworkBuffer()
      • releaseNetworkBuffer

        private void releaseNetworkBuffer()
      • onUpgradeFrom

        protected java.nio.ByteBuffer onUpgradeFrom()
      • process

        private void process()
      • parse

        private boolean parse()
        Parses an HTTP response in the receivers buffer.
        Returns:
        true to indicate that parsing should be interrupted (and will be resumed by another thread).
      • fillInterested

        protected void fillInterested()
      • shutdown

        private void shutdown()
      • isShutdown

        protected boolean isShutdown()
      • startResponse

        public boolean startResponse​(HttpVersion version,
                                     int status,
                                     java.lang.String reason)
        Description copied from interface: HttpParser.ResponseHandler
        This is the method called by parser when the HTTP request line is parsed
        Specified by:
        startResponse in interface HttpParser.ResponseHandler
        Parameters:
        version - the http version in use
        status - the response status
        reason - the response reason phrase
        Returns:
        true if handling parsing should return
      • reset

        protected void reset()
        Description copied from class: HttpReceiver
        Resets the state of this HttpReceiver.

        Subclasses should override (but remember to call super) to reset their own state.

        Either this method or HttpReceiver.dispose() is called.

        Overrides:
        reset in class HttpReceiver
      • failAndClose

        private void failAndClose​(java.lang.Throwable failure)
      • getMessagesIn

        long getMessagesIn()