src/Pure/System/system_channel.scala
author wenzelm
Sat, 05 Aug 2017 15:48:02 +0200
changeset 66346 30663525e057
parent 62306 5c0a5c30cda8
child 69124 6ededdc829bb
permissions -rw-r--r--
default according to Java API, instead of jEdit usage;
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
45027
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     1
/*  Title:      Pure/System/system_channel.scala
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     2
    Author:     Makarius
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     3
59350
acba5d6fdb2f discontinued fifo channel, always use portable socket;
wenzelm
parents: 59341
diff changeset
     4
Socket-based system channel for inter-process communication.
45027
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     5
*/
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     6
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     7
package isabelle
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     8
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
     9
59350
acba5d6fdb2f discontinued fifo channel, always use portable socket;
wenzelm
parents: 59341
diff changeset
    10
import java.io.{InputStream, OutputStream}
45028
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    11
import java.net.{ServerSocket, InetAddress}
45027
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
    12
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
    13
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
    14
object System_Channel
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
    15
{
59350
acba5d6fdb2f discontinued fifo channel, always use portable socket;
wenzelm
parents: 59341
diff changeset
    16
  def apply(): System_Channel = new System_Channel
45027
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
    17
}
f459e93a038e more abstract wrapping of fifos as System_Channel;
wenzelm
parents:
diff changeset
    18
59350
acba5d6fdb2f discontinued fifo channel, always use portable socket;
wenzelm
parents: 59341
diff changeset
    19
class System_Channel private
45028
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    20
{
66346
30663525e057 default according to Java API, instead of jEdit usage;
wenzelm
parents: 62306
diff changeset
    21
  private val server = new ServerSocket(0, 50, InetAddress.getByName("127.0.0.1"))
45028
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    22
62306
wenzelm
parents: 62299
diff changeset
    23
  val server_name: String = "127.0.0.1:" + server.getLocalPort
wenzelm
parents: 62299
diff changeset
    24
  override def toString: String = server_name
45028
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    25
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    26
  def rendezvous(): (OutputStream, InputStream) =
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    27
  {
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    28
    val socket = server.accept
54340
18c621069bf8 prefer TCP_NODELAY -- avoid extra buffering due to Nagle's algorithm;
wenzelm
parents: 54005
diff changeset
    29
    socket.setTcpNoDelay(true)
45028
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    30
    (socket.getOutputStream, socket.getInputStream)
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    31
  }
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    32
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    33
  def accepted() { server.close }
d608dd8cd409 alternative Socket_Channel;
wenzelm
parents: 45027
diff changeset
    34
}