Class HttpConnectionOverFCGI
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Connection
,Connection
,Attachable
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
private static final class
private class
Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Map
<Integer, HttpChannelOverFCGI> private Object
private final AtomicBoolean
private final HttpConnectionOverFCGI.Delegate
private final HttpDestination
private final Flusher
private final Queue
<HttpChannelOverFCGI> private static final Logger
private final boolean
private RetainableByteBuffer
private final ClientParser
private final Promise
<Connection> private final LinkedList
<Integer> -
Constructor Summary
ConstructorsConstructorDescriptionHttpConnectionOverFCGI
(EndPoint endPoint, HttpDestination destination, Promise<Connection> promise, boolean multiplexed) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected HttpChannelOverFCGI
acquireHttpChannel
(int id, Request request) private int
void
close()
Performs a logical close of this connection.protected void
protected boolean
closeByHTTP
(HttpFields fields) private void
failAndClose
(Throwable failure) protected Flusher
boolean
isClosed()
protected HttpChannelOverFCGI
newHttpChannel
(Request request) private RetainableByteBuffer
void
Callback method invoked when the endpoint is ready to be read.boolean
Callback method invoked upon an idle timeout event.void
onOpen()
Callback method invoked when this connection is opened.private boolean
parse
(ByteBuffer buffer) (package private) void
process()
private void
protected void
release
(HttpChannelOverFCGI channel) private void
private void
releaseRequest
(int request) void
send
(Request request, Response.CompleteListener listener) Sends a request with an associated response listener.protected SendFailure
send
(HttpExchange exchange) void
setAttachment
(Object obj) Attaches the given object to this stream for later retrieval.private void
shutdown()
Methods inherited from class org.eclipse.jetty.io.AbstractConnection
addListener, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onReadTimeout, removeListener, setInputBufferSize, toString, tryFillInterested, tryFillInterested
-
Field Details
-
LOG
-
requests
-
activeChannels
-
idleChannels
-
closed
-
destination
-
promise
-
multiplexed
private final boolean multiplexed -
flusher
-
delegate
-
parser
-
networkBuffer
-
attachment
-
-
Constructor Details
-
HttpConnectionOverFCGI
public HttpConnectionOverFCGI(EndPoint endPoint, HttpDestination destination, Promise<Connection> promise, boolean multiplexed)
-
-
Method Details
-
getHttpDestination
-
getFlusher
-
send
Description copied from interface:Connection
Sends a request with an associated response listener.Request.send(Response.CompleteListener)
will eventually call this method to send the request. It is exposed to allow applications to send requests via unpooled connections.- Specified by:
send
in interfaceConnection
- Parameters:
request
- the request to sendlistener
- the response listener
-
send
-
onOpen
public void onOpen()Description copied from interface:Connection
Callback method invoked when this connection is opened.
Creators of the connection implementation are responsible for calling this method.
- Specified by:
onOpen
in interfaceConnection
- Overrides:
onOpen
in classAbstractConnection
-
onFillable
public void onFillable()Description copied from class:AbstractConnection
Callback method invoked when the endpoint is ready to be read.
- Specified by:
onFillable
in classAbstractConnection
- See Also:
-
reacquireNetworkBuffer
private void reacquireNetworkBuffer() -
newNetworkBuffer
-
releaseNetworkBuffer
private void releaseNetworkBuffer() -
process
void process() -
parse
-
shutdown
private void shutdown() -
onIdleExpired
public boolean onIdleExpired()Description copied from interface:Connection
Callback method invoked upon an idle timeout event.
Implementations of this method may return true to indicate that the idle timeout handling should proceed normally, typically failing the EndPoint and causing it to be closed.
When false is returned, the handling of the idle timeout event is halted immediately and the EndPoint left in the state it was before the idle timeout event.
- Specified by:
onIdleExpired
in interfaceConnection
- Overrides:
onIdleExpired
in classAbstractConnection
- Returns:
- true to let the EndPoint handle the idle timeout, false to tell the EndPoint to halt the handling of the idle timeout.
-
release
-
close
public void close()Description copied from interface:Connection
Performs a logical close of this connection.
For simple connections, this may just mean to delegate the close to the associated
EndPoint
but, for example, SSL connections should write the SSL close message before closing the associatedEndPoint
.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceConnection
- Specified by:
close
in interfaceConnection
- Overrides:
close
in classAbstractConnection
-
close
-
isClosed
public boolean isClosed()- Specified by:
isClosed
in interfaceConnection
- Returns:
- whether this connection has been closed
- See Also:
-
setAttachment
Description copied from interface:Attachable
Attaches the given object to this stream for later retrieval.- Specified by:
setAttachment
in interfaceAttachable
- Parameters:
obj
- the object to attach to this instance
-
getAttachment
- Specified by:
getAttachment
in interfaceAttachable
- Returns:
- the object attached to this instance
- See Also:
-
closeByHTTP
-
abort
-
failAndClose
-
acquireRequest
private int acquireRequest() -
releaseRequest
private void releaseRequest(int request) -
acquireHttpChannel
-
newHttpChannel
-
toConnectionString
- Overrides:
toConnectionString
in classAbstractConnection
-