Skip to content
This repository was archived by the owner on Feb 24, 2026. It is now read-only.

Remote address in client connection channel #17

Merged
mjallday merged 4 commits into from
Jun 21, 2017
Merged

Remote address in client connection channel #17

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
a3524c0
Adds remote address to client to proxy channel on proxy to server con…
viacheslav-fomin-main Jun 19, 2017
fb4afda
Bumps up version
viacheslav-fomin-main Jun 19, 2017
12509ff
Renames remoteAddressAttrKey
viacheslav-fomin-main Jun 20, 2017
4924c6e
Camel case remote address att key vaule
viacheslav-fomin-main Jun 20, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
<groupId>org.littleshoot</groupId>
<artifactId>littleproxy</artifactId>
<packaging>jar</packaging>
<version>1.1.3.2-VGS-SNAPSHOT</version>
<version>1.1.3.3-VGS-SNAPSHOT</version>
Copy link
Copy Markdown
Collaborator Author

@viacheslav-fomin-main viacheslav-fomin-main Jun 19, 2017

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We will discuss the versioning mechanism when we all get together in one room

<name>LittleProxy</name>
<description>
LittleProxy is a high performance HTTP proxy written in Java and using the Netty networking framework.
Expand Down
5 changes: 5 additions & 0 deletions src/main/java/org/littleshoot/proxy/impl/ProxyToServerConnection.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import io.netty.handler.codec.http.LastHttpContent;
import io.netty.handler.timeout.IdleStateHandler;
import io.netty.handler.traffic.GlobalTrafficShapingHandler;
import io.netty.util.AttributeKey;
import io.netty.util.ReferenceCounted;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener;
Expand Down Expand Up @@ -137,6 +138,8 @@ public class ProxyToServerConnection extends ProxyConnection<HttpResponse> {
* Minimum size of the adaptive recv buffer when throttling is enabled.
*/
private static final int MINIMUM_RECV_BUFFER_SIZE_BYTES = 64;

public static final AttributeKey<InetSocketAddress> REMOTE_ADDRESS_ATTR_KEY = AttributeKey.valueOf("remoteAddressAttrKey");

/**
* Create a new ProxyToServerConnection.
Expand Down Expand Up @@ -528,6 +531,8 @@ private void respondWith(HttpObject httpObject) {
private void connectAndWrite(HttpRequest initialRequest) {
LOG.debug("Starting new connection to: {}", remoteAddress);

this.clientConnection.channel.attr(REMOTE_ADDRESS_ATTR_KEY).set(remoteAddress);

// Remember our initial request so that we can write it after connecting
this.initialRequest = initialRequest;
initializeConnectionFlow();
Expand Down