private void |
ClientToProxyConnection.closeConnectionsAfterWriteIfNecessary(ProxyToServerConnection serverConnection,
HttpRequest currentHttpRequest,
HttpResponse currentHttpResponse,
HttpObject httpObject) |
This method takes care of closing client to proxy and/or proxy to server
connections after finishing a write.
|
private void |
ClientToProxyConnection.connectionFailedUnrecoverably(HttpRequest initialRequest,
ProxyToServerConnection serverConnection) |
|
private void |
ClientToProxyConnection.forceDisconnect(ProxyToServerConnection serverConnection) |
|
(package private) void |
ClientToProxyConnection.respond(ProxyToServerConnection serverConnection,
HttpFilters filters,
HttpRequest currentHttpRequest,
HttpResponse currentHttpResponse,
HttpObject httpObject) |
Send a response to the client.
|
protected void |
ClientToProxyConnection.serverBecameSaturated(ProxyToServerConnection serverConnection) |
When a server becomes saturated, we stop reading from the client.
|
protected void |
ClientToProxyConnection.serverBecameWriteable(ProxyToServerConnection serverConnection) |
When a server becomes writeable, we check to see if all servers are
writeable and if they are, we resume reading.
|
protected boolean |
ClientToProxyConnection.serverConnectionFailed(ProxyToServerConnection serverConnection,
ConnectionState lastStateBeforeFailure,
Throwable cause) |
If the ProxyToServerConnection fails to complete its connection
lifecycle successfully, this method is called to let us know about it.
|
protected void |
ClientToProxyConnection.serverConnectionFlowStarted(ProxyToServerConnection serverConnection) |
|
protected void |
ClientToProxyConnection.serverConnectionSucceeded(ProxyToServerConnection serverConnection,
boolean shouldForwardInitialRequest) |
If the ProxyToServerConnection completes its connection lifecycle
successfully, this method is called to let us know about it.
|
protected void |
ClientToProxyConnection.serverDisconnected(ProxyToServerConnection serverConnection) |
On disconnect of the server, track that we have one fewer connected
servers and then disconnect the client if necessary.
|
private void |
ClientToProxyConnection.switchToWebSocketProtocol(ProxyToServerConnection serverConnection) |
|
(package private) void |
ClientToProxyConnection.timedOut(ProxyToServerConnection serverConnection) |
|