Class ServerFCGIConnection
java.lang.Object
org.eclipse.jetty.io.AbstractConnection
org.eclipse.jetty.fcgi.server.ServerFCGIConnection
- All Implemented Interfaces:
Closeable, AutoCloseable, Connection
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from interface Connection
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ConcurrentMap<Integer, HttpChannelOverFCGI> private final HttpConfigurationprivate final Connectorprivate final Flusherprivate static final Loggerprivate final ServerParserprivate final boolean -
Constructor Summary
ConstructorsConstructorDescriptionServerFCGIConnection(Connector connector, EndPoint endPoint, HttpConfiguration configuration, boolean sendStatus200) -
Method Summary
Modifier and TypeMethodDescriptionvoidCallback method invoked when the endpoint is ready to be read.voidonOpen()Callback method invoked when this connection is opened.protected booleanonReadTimeout(Throwable timeout) Callback method invoked when the endpoint failed to be ready to be read after a timeoutprivate voidparse(ByteBuffer buffer) private voidshutdown()Methods inherited from class AbstractConnection
addListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterested
-
Field Details
-
LOG
-
channels
-
connector
-
sendStatus200
private final boolean sendStatus200 -
flusher
-
configuration
-
parser
-
-
Constructor Details
-
ServerFCGIConnection
public ServerFCGIConnection(Connector connector, EndPoint endPoint, HttpConfiguration configuration, boolean sendStatus200)
-
-
Method Details
-
onOpen
public void onOpen()Description copied from interface:ConnectionCallback method invoked when this connection is opened.
Creators of the connection implementation are responsible for calling this method.
- Specified by:
onOpenin interfaceConnection- Overrides:
onOpenin classAbstractConnection
-
onFillable
public void onFillable()Description copied from class:AbstractConnectionCallback method invoked when the endpoint is ready to be read.
- Specified by:
onFillablein classAbstractConnection- See Also:
-
onReadTimeout
Description copied from class:AbstractConnectionCallback method invoked when the endpoint failed to be ready to be read after a timeout
- Overrides:
onReadTimeoutin classAbstractConnection- Parameters:
timeout- the cause of the read timeout- Returns:
- true to signal that the endpoint must be closed, false to keep the endpoint open
-
parse
-
shutdown
private void shutdown()
-