Class ParseTimeoutUpdater

    • Constructor Detail

      • ParseTimeoutUpdater

        public ParseTimeoutUpdater​(org.xnio.channels.ConnectedChannel channel,
                                   long requestParseTimeout,
                                   long requestIdleTimeout)
        Creates new instance of ParseTimeoutSourceConduit.
        Parameters:
        channel - Channel which will be closed in case of timeout.
        requestParseTimeout - Timeout value. Negative value will indicate that this updated is disabled.
        requestIdleTimeout -
      • ParseTimeoutUpdater

        public ParseTimeoutUpdater​(org.xnio.channels.ConnectedChannel channel,
                                   long requestParseTimeout,
                                   long requestIdleTimeout,
                                   Runnable closeTask)
        Creates new instance of ParseTimeoutSourceConduit.
        Parameters:
        channel - Channel which will be closed in case of timeout.
        requestParseTimeout - Timeout value. Negative value will indicate that this updated is disabled.
        requestIdleTimeout -
    • Method Detail

      • connectionIdle

        public void connectionIdle()
        Called when the connection goes idle
      • failedParse

        public void failedParse()
        Called when a request is received, however it is not parsed in a single read() call. This starts a timer, and if the request is not parsed within this time then the connection is closed.
      • requestStarted

        public void requestStarted()
        Cancels timeout countdown.

        Should be called after parsing is complete (to avoid closing connection during other activities).

      • run

        public void run()
        Specified by:
        run in interface Runnable