jlengrand/vert.x
1
0
Fork 0
mirror of https://github.com/jlengrand/vert.x.git synced 2026-03-10 08:51:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cache ConnectionBase localAddress / remoteAddress instances - see #3185

Browse Source
This commit is contained in:
Julien Viet
2019-11-07 19:18:44 +01:00
parent 06561c4f84
commit 86ea4440d9
1 changed files with 18 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/io/vertx/core/net/impl/ConnectionBase.java
View File

@@ -62,6 +62,8 @@ public abstract class ConnectionBase {
private Handler<Void> closeHandler;
private int writeInProgress;
private Object metric;
private SocketAddress remoteAddress;
private SocketAddress localAddress;
// State accessed exclusively from the event loop thread
private boolean read;
@@ -424,19 +426,27 @@ public abstract class ConnectionBase {
}
public SocketAddress remoteAddress() {
java.net.SocketAddress addr = chctx.channel().remoteAddress();
if (addr != null) {
return vertx.transport().convert(addr);
SocketAddress address = remoteAddress;
if (address == null) {
java.net.SocketAddress addr = chctx.channel().remoteAddress();
if (addr != null) {
address = vertx.transport().convert(addr);
remoteAddress = address;
}
}
return null;
return address;
}
public SocketAddress localAddress() {
java.net.SocketAddress addr = chctx.channel().localAddress();
if (addr != null) {
return vertx.transport().convert(addr);
SocketAddress address = localAddress;
if (address == null) {
java.net.SocketAddress addr = chctx.channel().localAddress();
if (addr != null) {
address = vertx.transport().convert(addr);
localAddress = address;
}
}
return null;
return address;
}
public void handleMessage(Object msg) {