diff options
author | michelou <michelou@epfl.ch> | 2006-10-08 21:07:23 +0000 |
---|---|---|
committer | michelou <michelou@epfl.ch> | 2006-10-08 21:07:23 +0000 |
commit | c986830f3c13ac70829430f84115b18f229579f9 (patch) | |
tree | 0c2e34b88d4ffc9058de8361afc9c23949bbbcf5 /src/actors/scala/actors/remote/NetKernel.scala | |
parent | fbc3a71a1e0d5cea346f0832202bbca8523f5aba (diff) | |
download | scala-c986830f3c13ac70829430f84115b18f229579f9.tar.gz scala-c986830f3c13ac70829430f84115b18f229579f9.tar.bz2 scala-c986830f3c13ac70829430f84115b18f229579f9.zip |
modified escapedStringValue and cleaned up comm...
modified escapedStringValue and cleaned up comments
Diffstat (limited to 'src/actors/scala/actors/remote/NetKernel.scala')
-rw-r--r-- | src/actors/scala/actors/remote/NetKernel.scala | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/src/actors/scala/actors/remote/NetKernel.scala b/src/actors/scala/actors/remote/NetKernel.scala index 19d6f81f6a..5209ae4069 100644 --- a/src/actors/scala/actors/remote/NetKernel.scala +++ b/src/actors/scala/actors/remote/NetKernel.scala @@ -1,8 +1,16 @@ +/* __ *\ +** ________ ___ / / ___ Scala API ** +** / __/ __// _ | / / / _ | (c) 2005-2006, LAMP/EPFL ** +** __\ \/ /__/ __ |/ /__/ __ | ** +** /____/\___/_/ |_/____/_/ | | ** +** |/ ** +\* */ + +// $Id: $ + package scala.actors.remote -import java.io.{IOException,StringReader,StringWriter} -import java.net.UnknownHostException -import scala.collection.mutable.{HashMap,HashSet} +import scala.collection.mutable.{HashMap, HashSet} case class NamedSend(senderName: Symbol, receiver: Symbol, data: Array[Byte]) @@ -25,7 +33,8 @@ class NetKernel(service: Service) { register(freshName, Actor.self) freshName } - case Some(name) => name + case Some(name) => + name } namedSend(node, senderName, name, msg) } @@ -40,9 +49,8 @@ class NetKernel(service: Service) { def act() = { a ! msg } override def !(msg: Any): Unit = { msg match { - case refmsg: AnyRef => { + case refmsg: AnyRef => namedSend(senderNode, receiver, senderName, refmsg) - } } } override def !?(msg: Any): Any = @@ -50,7 +58,8 @@ class NetKernel(service: Service) { } senderProxy.start() } - case None => // message is lost + case None => + // message is lost } } } |