Module io.helidon.webserver

Package io.helidon.webserver.http1

Class Http1Connection

java.lang.Object

io.helidon.webserver.http1.Http1Connection

All Implemented Interfaces:

InterruptableTask<Void>, ServerConnection, Runnable, Callable<Void>

public class Http1Connection
extends Object
implements ServerConnection, InterruptableTask<Void>

HTTP/1.1 server connection.

Method Summary

Modifier and Type	Method	Description
boolean	canInterrupt()	Signals if a task can be interrupted at the time this method is called.
void	close(boolean interrupt)	Close a connection.
void	handle(Limit limit)	Start handling the connection.
void	handle(Semaphore requestSemaphore)	Start handling the connection.
Duration	idleTime()	How long is this connection idle.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.common.task.InterruptableTask

call, run

Method Details

canInterrupt

public boolean canInterrupt()

Description copied from interface: InterruptableTask

Signals if a task can be interrupted at the time this method is called.

Specified by:

canInterrupt in interface InterruptableTask<Void>

Returns:

outcome of interruptable test

handle

public void handle(Limit limit)
            throws InterruptedException

Description copied from interface: ServerConnection

Start handling the connection. Data is provided through ServerConnectionSelector.connection(io.helidon.webserver.ConnectionContext).

Specified by:

handle in interface ServerConnection

Parameters:

limit - that is responsible for maximal concurrent request limit, the connection implementation is responsible invoking each request within the limit's LimitAlgorithm.invoke(java.util.concurrent.Callable)

Throws:

InterruptedException - to interrupt any waiting state and terminate this connection

handle

public void handle(Semaphore requestSemaphore)
            throws InterruptedException

Description copied from interface: ServerConnection

Start handling the connection. Data is provided through ServerConnectionSelector.connection(io.helidon.webserver.ConnectionContext).

Specified by:

handle in interface ServerConnection

Parameters:

requestSemaphore - semaphore that is responsible for maximal concurrent request limit, the connection implementation is responsible for acquiring a permit from the semaphore for the duration of a request, and releasing it when the request ends; please be very careful, as this may lead to complete stop of the server if incorrectly implemented

Throws:

InterruptedException - to interrupt any waiting state and terminate this connection

idleTime

public Duration idleTime()

Description copied from interface: ServerConnection

How long is this connection idle. This is a duration from the last request to now.

Specified by:

idleTime in interface ServerConnection

Returns:

idle duration

close

public void close(boolean interrupt)

Description copied from interface: ServerConnection

Close a connection. This may be called during shutdown of the server, or when idle timeout is reached.

Specified by:

close in interface ServerConnection

Parameters:

interrupt - whether to interrupt in progress requests (always interrupts idle requests waiting for initial request data)