Merge pull request #32380 from mrsaldana/netty-transport-http-readOnlySocketExpose

Netty support for Read-Only Socket

Author: mrsaldana

dev/com.ibm.ws.transport.http/src/com/ibm/ws/http/netty/inbound/NettyTCPReadRequestContext.java

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2023, 2025 IBM Corporation and others.
+ * Copyright (c) 2023, 2026 IBM Corporation and others.
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License 2.0
  * which accompanies this distribution, and is available at
@@ -11,7 +11,10 @@
 
 import java.io.EOFException;
 import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
 import java.net.Socket;
+import java.net.SocketAddress;
 import java.net.SocketTimeoutException;
 import java.nio.ByteBuffer;
 import java.util.Objects;
@@ -34,6 +37,9 @@
 import com.ibm.wsspi.tcpchannel.TCPReadRequestContext;
 
 import io.netty.channel.Channel;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.openliberty.http.netty.channel.ReadOnlySocket;
 
 /**
  *
@@ -61,6 +67,8 @@ public class NettyTCPReadRequestContext implements TCPReadRequestContext {
 
     private VirtualConnection vc = null;
 
+    private volatile Socket cachedSocket;
+
     public NettyTCPReadRequestContext(NettyTCPConnectionContext connectionContext, Channel nettyChannel) {
 
         this.connectionContext = connectionContext;
@@ -85,7 +93,10 @@ public TCPConnectionContext getInterface() {
 
     @Override
     public Socket getSocket() {
-        throw new UnsupportedOperationException("Can not get the socket from a Netty connection!");
+        if(cachedSocket == null){
+            cachedSocket = new ReadOnlySocket(nettyChannel);       
+        }
+        return cachedSocket;
     }
 
     /**
@@ -412,5 +423,4 @@ public void setBuffer(WsByteBuffer buf) {
     public void setVC(VirtualConnection vc) {
         this.vc = vc;
     }
-
 }