Package | Description |
---|---|
org.littleshoot.proxy | |
org.littleshoot.proxy.impl |
Constructor and Description |
---|
FullFlowContext(ClientToProxyConnection clientConnection,
ProxyToServerConnection serverConnection) |
Modifier and Type | Field and Description |
---|---|
private ProxyToServerConnection |
ClientToProxyConnection.currentServerConnection
This is the current server connection that we're using while transferring
chunked data.
|
private ProxyToServerConnection |
ProxyToServerConnection.serverConnection |
private ProxyToServerConnection |
ConnectionFlow.serverConnection |
Modifier and Type | Field and Description |
---|---|
private Map<String,ProxyToServerConnection> |
ClientToProxyConnection.serverConnectionsByHostAndPort
Keep track of all ProxyToServerConnections by host+port.
|
Modifier and Type | Method and Description |
---|---|
(package private) static ProxyToServerConnection |
ProxyToServerConnection.create(DefaultHttpProxyServer proxyServer,
ClientToProxyConnection clientConnection,
String serverHostAndPort,
HttpFilters initialFilters,
io.netty.handler.codec.http.HttpRequest initialHttpRequest,
io.netty.handler.traffic.GlobalTrafficShapingHandler globalTrafficShapingHandler)
Create a new ProxyToServerConnection.
|
Modifier and Type | Method and Description |
---|---|
private void |
ClientToProxyConnection.closeConnectionsAfterWriteIfNecessary(ProxyToServerConnection serverConnection,
io.netty.handler.codec.http.HttpRequest currentHttpRequest,
io.netty.handler.codec.http.HttpResponse currentHttpResponse,
io.netty.handler.codec.http.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(io.netty.handler.codec.http.HttpRequest initialRequest,
ProxyToServerConnection serverConnection) |
private void |
ClientToProxyConnection.forceDisconnect(ProxyToServerConnection serverConnection) |
(package private) void |
ClientToProxyConnection.respond(ProxyToServerConnection serverConnection,
HttpFilters filters,
io.netty.handler.codec.http.HttpRequest currentHttpRequest,
io.netty.handler.codec.http.HttpResponse currentHttpResponse,
io.netty.handler.codec.http.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)
Called when
ProxyToServerConnection starts its connection flow. |
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.
|
Constructor and Description |
---|
ConnectionFlow(ClientToProxyConnection clientConnection,
ProxyToServerConnection serverConnection,
Object connectLock)
Construct a new
ConnectionFlow for the given client and server
connections. |
Copyright © 2009–2018 LittleShoot. All rights reserved.