Making sure that akka-remote and akka-remote-tests pass

akka-actor/src/main/scala/akka/serialization/Serialization.scala

@@ -168,11 +168,8 @@ class Serialization(val system: ExtendedActorSystem) extends Extension {
    * serializerMap is a Map whose keys is the class that is serializable and values is the serializer
    * to be used for that class.
    */
-  private val serializerMap: ConcurrentHashMap[Class[_], Serializer] = {
+  private val serializerMap: ConcurrentHashMap[Class[_], Serializer] =
-    val serializerMap = new ConcurrentHashMap[Class[_], Serializer]
+    (new ConcurrentHashMap[Class[_], Serializer] /: bindings) { case (map, (c, s)) ⇒ map.put(c, s); map }
-    for ((c, s) ← bindings) serializerMap.put(c, s)
-    serializerMap
-  }
 
   /**
    * Maps from a Serializer Identity (Int) to a Serializer instance (optimization)

akka-remote-tests/src/main/scala/akka/remote/testconductor/Conductor.scala

@@ -3,6 +3,8 @@
  */
 package akka.remote.testconductor
 
+import language.postfixOps
+
 import akka.actor.{ Actor, ActorRef, ActorSystem, LoggingFSM, Props }
 import RemoteConnection.getAddrString
 import TestConductorProtocol._
@@ -430,6 +432,7 @@ private[akka] class Controller(private var initialParticipants: Int, controllerP
         case GetAddress(node) ⇒
           if (nodes contains node) sender ! ToClient(AddressReply(node, nodes(node).addr))
           else addrInterest += node -> ((addrInterest get node getOrElse Set()) + sender)
+        case _: Done ⇒ //FIXME what should happen?
       }
     case op: CommandOp ⇒
       op match {

akka-remote-tests/src/main/scala/akka/remote/testconductor/DataTypes.scala

@@ -3,6 +3,8 @@
  */
 package akka.remote.testconductor
 
+import language.implicitConversions
+
 import org.jboss.netty.handler.codec.oneone.OneToOneEncoder
 import org.jboss.netty.channel.ChannelHandlerContext
 import org.jboss.netty.channel.Channel

akka-remote-tests/src/main/scala/akka/remote/testconductor/NetworkFailureInjector.scala

@@ -3,6 +3,8 @@
  */
 package akka.remote.testconductor
 
+import language.postfixOps
+
 import java.net.InetSocketAddress
 
 import scala.annotation.tailrec

akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala

@@ -3,6 +3,8 @@
  */
 package akka.remote.testconductor
 
+import language.postfixOps
+
 import akka.actor.{ Actor, ActorRef, ActorSystem, LoggingFSM, Props }
 import RemoteConnection.getAddrString
 import akka.util.duration._
@@ -184,7 +186,7 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress)
     case Event(Disconnected, _) ⇒
       log.info("disconnected from TestConductor")
       throw new ConnectionFailure("disconnect")
-    case Event(ToServer(Done), Data(Some(channel), _)) ⇒
+    case Event(ToServer(_: Done), Data(Some(channel), _)) ⇒
       channel.write(Done)
       stay
     case Event(ToServer(msg), d @ Data(Some(channel), None)) ⇒
@@ -232,6 +234,7 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress)
         case TerminateMsg(exit) ⇒
           System.exit(exit)
           stay // needed because Java doesn’t have Nothing
+        case _: Done ⇒ stay //FIXME what should happen?
       }
   }
 

akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala

@@ -3,6 +3,8 @@
  */
 package akka.remote.testconductor
 
+import language.postfixOps
+
 import akka.testkit.AkkaSpec
 import akka.actor.Props
 import akka.actor.AddressFromURIString

akka-remote-tests/src/test/scala/akka/remote/testkit/MultiNodeSpec.scala

@@ -3,6 +3,8 @@
  */
 package akka.remote.testkit
 
+import language.implicitConversions
+
 import java.net.InetSocketAddress
 
 import com.typesafe.config.{ ConfigObject, ConfigFactory, Config }