Immutable local/remote SocketAddress within a ConnectionMetaData

jetty-core/jetty-fcgi/jetty-fcgi-server/src/main/java/org/eclipse/jetty/fcgi/server/internal/ServerFCGIConnection.java

@@ -13,7 +13,6 @@
 
 package org.eclipse.jetty.fcgi.server.internal;
 
-import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 import java.util.Set;
 import java.util.concurrent.TimeoutException;
@@ -25,12 +24,11 @@
 import org.eclipse.jetty.http.BadMessageException;
 import org.eclipse.jetty.http.HttpField;
 import org.eclipse.jetty.http.HttpVersion;
-import org.eclipse.jetty.io.AbstractConnection;
 import org.eclipse.jetty.io.ByteBufferPool;
-import org.eclipse.jetty.io.Connection;
 import org.eclipse.jetty.io.Content;
 import org.eclipse.jetty.io.EndPoint;
 import org.eclipse.jetty.io.RetainableByteBuffer;
+import org.eclipse.jetty.server.AbstractMetaDataConnection;
 import org.eclipse.jetty.server.ConnectionMetaData;
 import org.eclipse.jetty.server.Connector;
 import org.eclipse.jetty.server.HttpChannel;
@@ -40,7 +38,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class ServerFCGIConnection extends AbstractConnection implements ConnectionMetaData
+public class ServerFCGIConnection extends AbstractMetaDataConnection implements ConnectionMetaData
 {
     private static final Logger LOG = LoggerFactory.getLogger(ServerFCGIConnection.class);
 
@@ -60,7 +58,7 @@ public class ServerFCGIConnection extends AbstractConnection implements Connecti
 
     public ServerFCGIConnection(Connector connector, EndPoint endPoint, HttpConfiguration configuration, boolean sendStatus200)
     {
-        super(endPoint, connector.getExecutor());
+        super(connector, configuration, endPoint);
         this.connector = connector;
         this.networkByteBufferPool = connector.getByteBufferPool();
         this.flusher = new Flusher(endPoint);
@@ -106,12 +104,6 @@ public String getId()
         return id;
     }
 
-    @Override
-    public HttpConfiguration getHttpConfiguration()
-    {
-        return configuration;
-    }
-
     @Override
     public HttpVersion getHttpVersion()
     {
@@ -124,18 +116,6 @@ public String getProtocol()
         return "fcgi/1.0";
     }
 
-    @Override
-    public Connection getConnection()
-    {
-        return this;
-    }
-
-    @Override
-    public Connector getConnector()
-    {
-        return connector;
-    }
-
     @Override
     public boolean isPersistent()
     {
@@ -148,18 +128,6 @@ public boolean isSecure()
         return false;
     }
 
-    @Override
-    public SocketAddress getRemoteSocketAddress()
-    {
-        return getEndPoint().getRemoteSocketAddress();
-    }
-
-    @Override
-    public SocketAddress getLocalSocketAddress()
-    {
-        return getEndPoint().getLocalSocketAddress();
-    }
-
     @Override
     public Object removeAttribute(String name)
     {

jetty-core/jetty-http2/jetty-http2-server/src/main/java/org/eclipse/jetty/http2/server/internal/HTTP2ServerConnection.java

@@ -66,6 +66,8 @@ public class HTTP2ServerConnection extends HTTP2Connection implements Connection
     private final ServerSessionListener listener;
     private final HttpConfiguration httpConfig;
     private final String id;
+    private final SocketAddress localSocketAddress;
+    private final SocketAddress remoteSocketAddress;
 
     public HTTP2ServerConnection(Connector connector, EndPoint endPoint, HttpConfiguration httpConfig, HTTP2ServerSession session, int inputBufferSize, ServerSessionListener listener)
     {
@@ -74,6 +76,8 @@ public HTTP2ServerConnection(Connector connector, EndPoint endPoint, HttpConfigu
         this.listener = listener;
         this.httpConfig = httpConfig;
         this.id = StringUtil.randomAlphaNumeric(16);
+        localSocketAddress = httpConfig.getLocalAddress() != null ? httpConfig.getLocalAddress() : endPoint.getLocalSocketAddress();
+        remoteSocketAddress = endPoint.getRemoteSocketAddress();
     }
 
     @Override
@@ -400,13 +404,13 @@ public boolean isPushSupported()
     @Override
     public SocketAddress getRemoteSocketAddress()
     {
-        return getEndPoint().getRemoteSocketAddress();
+        return remoteSocketAddress;
     }
 
     @Override
     public SocketAddress getLocalSocketAddress()
     {
-        return getEndPoint().getLocalSocketAddress();
+        return localSocketAddress;
     }
 
     @Override

jetty-core/jetty-http3/jetty-http3-server/src/main/java/org/eclipse/jetty/http3/server/internal/ServerHTTP3StreamConnection.java

@@ -33,7 +33,7 @@
 import org.eclipse.jetty.util.Attributes;
 import org.eclipse.jetty.util.HostPort;
 
-public class ServerHTTP3StreamConnection extends HTTP3StreamConnection implements ConnectionMetaData
+public class ServerHTTP3StreamConnection extends HTTP3StreamConnection
 {
     private final HttpChannel.Factory httpChannelFactory = new HttpChannel.DefaultFactory();
     private final Attributes attributes = new Attributes.Lazy();
@@ -51,7 +51,8 @@ public ServerHTTP3StreamConnection(Connector connector, HttpConfiguration httpCo
 
     public Runnable onRequest(HTTP3StreamServer stream, HeadersFrame frame)
     {
-        HttpChannel httpChannel = httpChannelFactory.newHttpChannel(this);
+        // Create new metadata for every request as the local or remote address may have changed.
+        HttpChannel httpChannel = httpChannelFactory.newHttpChannel(new MetaData());
         HttpStreamOverHTTP3 httpStream = new HttpStreamOverHTTP3(this, httpChannel, stream);
         httpChannel.setHttpStream(httpStream);
         stream.setAttachment(httpStream);
@@ -87,107 +88,119 @@ void offer(Runnable task)
         session.offer(task, false);
     }
 
-    @Override
-    public String getId()
-    {
-        return session.getQuicSession().getConnectionId().toString();
-    }
-
-    @Override
-    public HttpConfiguration getHttpConfiguration()
-    {
-        return httpConfiguration;
-    }
-
-    @Override
-    public HttpVersion getHttpVersion()
-    {
-        return HttpVersion.HTTP_3;
-    }
-
-    @Override
-    public String getProtocol()
-    {
-        return getHttpVersion().asString();
-    }
-
-    @Override
-    public Connection getConnection()
-    {
-        return getEndPoint().getConnection();
-    }
-
-    @Override
-    public Connector getConnector()
-    {
-        return connector;
-    }
-
-    @Override
-    public boolean isPersistent()
-    {
-        return true;
-    }
-
-    @Override
-    public boolean isSecure()
-    {
-        return true;
-    }
-
-    @Override
-    public SocketAddress getRemoteSocketAddress()
-    {
-        return getEndPoint().getRemoteSocketAddress();
-    }
-
-    @Override
-    public SocketAddress getLocalSocketAddress()
-    {
-        return getEndPoint().getLocalSocketAddress();
-    }
-
-    @Override
-    public HostPort getServerAuthority()
-    {
-        HostPort override = httpConfiguration.getServerAuthority();
-        if (override != null)
-            return override;
-
-        // TODO cache the HostPort?
-        SocketAddress addr = getLocalSocketAddress();
-        if (addr instanceof InetSocketAddress inet)
-            return new HostPort(inet.getHostString(), inet.getPort());
-        return new HostPort(addr.toString(), -1);
-    }
-
-    @Override
-    public Object getAttribute(String name)
-    {
-        return attributes.getAttribute(name);
-    }
-
-    @Override
-    public Object setAttribute(String name, Object attribute)
-    {
-        return attributes.setAttribute(name, attribute);
-    }
-
-    @Override
-    public Object removeAttribute(String name)
-    {
-        return attributes.removeAttribute(name);
-    }
-
-    @Override
-    public Set<String> getAttributeNameSet()
-    {
-        return attributes.getAttributeNameSet();
-    }
-
-    @Override
-    public void clearAttributes()
-    {
-        attributes.clearAttributes();
+    private class MetaData implements ConnectionMetaData
+    {
+        private final SocketAddress localSocketAddress;
+        private final SocketAddress remoteSocketAddress;
+
+        private MetaData()
+        {
+            this.localSocketAddress = httpConfiguration.getLocalAddress() == null ? getEndPoint().getLocalSocketAddress() : httpConfiguration.getLocalAddress();
+            this.remoteSocketAddress = getEndPoint().getRemoteSocketAddress();
+        }
+
+        @Override
+        public String getId()
+        {
+            return session.getQuicSession().getConnectionId().toString();
+        }
+
+        @Override
+        public HttpConfiguration getHttpConfiguration()
+        {
+            return httpConfiguration;
+        }
+
+        @Override
+        public HttpVersion getHttpVersion()
+        {
+            return HttpVersion.HTTP_3;
+        }
+
+        @Override
+        public String getProtocol()
+        {
+            return getHttpVersion().asString();
+        }
+
+        @Override
+        public Connection getConnection()
+        {
+            return getEndPoint().getConnection();
+        }
+
+        @Override
+        public Connector getConnector()
+        {
+            return connector;
+        }
+
+        @Override
+        public boolean isPersistent()
+        {
+            return true;
+        }
+
+        @Override
+        public boolean isSecure()
+        {
+            return true;
+        }
+
+        @Override
+        public SocketAddress getRemoteSocketAddress()
+        {
+            return remoteSocketAddress;
+        }
+
+        @Override
+        public SocketAddress getLocalSocketAddress()
+        {
+            return localSocketAddress;
+        }
+
+        @Override
+        public HostPort getServerAuthority()
+        {
+            HostPort override = httpConfiguration.getServerAuthority();
+            if (override != null)
+                return override;
+
+            // TODO cache the HostPort?
+            SocketAddress addr = getLocalSocketAddress();
+            if (addr instanceof InetSocketAddress inet)
+                return new HostPort(inet.getHostString(), inet.getPort());
+            return new HostPort(addr.toString(), -1);
+        }
+
+        @Override
+        public Object getAttribute(String name)
+        {
+            return attributes.getAttribute(name);
+        }
+
+        @Override
+        public Object setAttribute(String name, Object attribute)
+        {
+            return attributes.setAttribute(name, attribute);
+        }
+
+        @Override
+        public Object removeAttribute(String name)
+        {
+            return attributes.removeAttribute(name);
+        }
+
+        @Override
+        public Set<String> getAttributeNameSet()
+        {
+            return attributes.getAttributeNameSet();
+        }
+
+        @Override
+        public void clearAttributes()
+        {
+            attributes.clearAttributes();
+        }
     }
 }

jetty-core/jetty-io/src/main/java/org/eclipse/jetty/io/AbstractEndPoint.java

@@ -69,10 +69,7 @@ public InetSocketAddress getLocalAddress()
     }
 
     @Override
-    public SocketAddress getLocalSocketAddress()
-    {
-        return null;
-    }
+    public abstract SocketAddress getLocalSocketAddress();
 
     @Override
     public InetSocketAddress getRemoteAddress()
@@ -84,10 +81,7 @@ public InetSocketAddress getRemoteAddress()
     }
 
     @Override
-    public SocketAddress getRemoteSocketAddress()
-    {
-        return null;
-    }
+    public abstract SocketAddress getRemoteSocketAddress();
 
     protected final void shutdownInput()
     {