clarified buffer_size;
authorwenzelm
Fri, 24 Nov 2023 21:32:32 +0100
changeset 79055 c83cdd300848
parent 79054 edc0dbd59d48
child 79056 1f34f6394383
clarified buffer_size;
src/Pure/System/system_channel.scala
--- a/src/Pure/System/system_channel.scala	Fri Nov 24 20:58:29 2023 +0100
+++ b/src/Pure/System/system_channel.scala	Fri Nov 24 21:32:32 2023 +0100
@@ -8,7 +8,8 @@
 
 
 import java.io.{InputStream, OutputStream}
-import java.net.{InetAddress, InetSocketAddress, ProtocolFamily, ServerSocket, SocketAddress, StandardProtocolFamily, UnixDomainSocketAddress}
+import java.net.{InetAddress, InetSocketAddress, ProtocolFamily, ServerSocket, SocketAddress,
+  StandardProtocolFamily, UnixDomainSocketAddress, StandardSocketOptions}
 import java.nio.channels.{ServerSocketChannel, Channels}
 
 
@@ -16,8 +17,11 @@
   def apply(unix_domain: Boolean = false): System_Channel =
     if (unix_domain) new Unix else new Inet
 
+  val buffer_size: Integer = Integer.valueOf(131072)
+
   class Inet extends System_Channel(StandardProtocolFamily.INET) {
     server.bind(new InetSocketAddress(Server.localhost, 0), 50)
+    server.setOption(StandardSocketOptions.SO_RCVBUF, buffer_size)
 
     override def address: String =
       Server.print_address(server.getLocalAddress.asInstanceOf[InetSocketAddress].getPort)
@@ -28,6 +32,7 @@
     private val socket_file_name = socket_file.getPath
 
     server.bind(UnixDomainSocketAddress.of(socket_file_name))
+    server.setOption(StandardSocketOptions.SO_RCVBUF, buffer_size)
 
     override def address: String = socket_file_name
     override def shutdown(): Unit = {