raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Removing dead imports from akka-remote

Browse source
This commit is contained in:
Viktor Klang 2012-01-25 15:55:27 +01:00
parent 7f0c4e3d63
commit 1590438b0c
14 changed files with 3 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-remote/src/main/scala/akka/remote/AccrualFailureDetector.scala
View file

@ -11,8 +11,6 @@ import scala.annotation.tailrec
import System.{ currentTimeMillis ⇒ newTimestamp } import System.{ currentTimeMillis ⇒ newTimestamp }
import akka.actor.ActorSystem
/** /**
* Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al. as defined in their paper: * Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al. as defined in their paper:
* [http://ddg.jaist.ac.jp/pub/HDY+04.pdf] * [http://ddg.jaist.ac.jp/pub/HDY+04.pdf]

2
akka-remote/src/main/scala/akka/remote/Gossiper.scala
View file

@ -9,7 +9,6 @@ import akka.actor.Status._
import akka.event.Logging import akka.event.Logging
import akka.util.Duration import akka.util.Duration
import akka.config.ConfigurationException import akka.config.ConfigurationException
import akka.serialization.SerializationExtension
import java.util.concurrent.atomic.AtomicReference import java.util.concurrent.atomic.AtomicReference
import java.util.concurrent.TimeUnit.SECONDS import java.util.concurrent.TimeUnit.SECONDS
@ -19,7 +18,6 @@ import System.{ currentTimeMillis ⇒ newTimestamp }
import scala.collection.immutable.Map import scala.collection.immutable.Map
import scala.annotation.tailrec import scala.annotation.tailrec
import com.google.protobuf.ByteString
import java.util.concurrent.TimeoutException import java.util.concurrent.TimeoutException
import akka.dispatch.Await import akka.dispatch.Await
import akka.pattern.ask import akka.pattern.ask

4
akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala
View file

@ -5,9 +5,7 @@
package akka.remote package akka.remote
import scala.collection.mutable import scala.collection.mutable
import akka.actor.{ LocalActorRef, Actor, ActorRef, Props, newUuid } import akka.actor.{ Actor, Props, ActorSystemImpl }
import akka.actor.Actor._
import akka.actor.ActorSystemImpl
/** /**
* Stream of all kinds of network events, remote failure and connection events, cluster failure and connection events etc. * Stream of all kinds of network events, remote failure and connection events, cluster failure and connection events etc.

4
akka-remote/src/main/scala/akka/remote/Remote.scala
View file

@ -7,9 +7,7 @@ package akka.remote
import akka.actor._ import akka.actor._
import akka.event._ import akka.event._
import akka.util._ import akka.util._
import akka.util.duration._ import akka.serialization.{ Serialization, SerializationExtension }
import akka.util.Helpers._
import akka.serialization.{ JavaSerializer, Serialization, SerializationExtension }
import akka.dispatch.MessageDispatcher import akka.dispatch.MessageDispatcher
import akka.dispatch.SystemMessage import akka.dispatch.SystemMessage
import scala.annotation.tailrec import scala.annotation.tailrec

7
akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala
View file

@ -6,16 +6,9 @@ package akka.remote
import akka.actor._ import akka.actor._
import akka.dispatch._ import akka.dispatch._
import akka.util.duration._
import akka.util.Timeout
import akka.config.ConfigurationException
import akka.event.{ DeathWatch, Logging } import akka.event.{ DeathWatch, Logging }
import akka.serialization.Compression.LZF
import com.google.protobuf.ByteString
import akka.event.EventStream import akka.event.EventStream
import akka.dispatch.Promise
import akka.config.ConfigurationException import akka.config.ConfigurationException
import java.util.concurrent.{ TimeoutException }
/** /**
* Remote ActorRefProvider. Starts up actor on remote node and creates a RemoteActorRef representing it. * Remote ActorRefProvider. Starts up actor on remote node and creates a RemoteActorRef representing it.

1
akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala
View file

@ -6,7 +6,6 @@ package akka.remote
import akka.actor._ import akka.actor._
import akka.routing._ import akka.routing._
import akka.actor.ActorSystem
import akka.event.Logging import akka.event.Logging
import scala.collection.immutable.Map import scala.collection.immutable.Map

3
akka-remote/src/main/scala/akka/remote/RemoteInterface.scala
View file

@ -7,13 +7,10 @@ package akka.remote
import akka.actor._ import akka.actor._
import akka.AkkaException import akka.AkkaException
import scala.reflect.BeanProperty import scala.reflect.BeanProperty
import java.io.{ PrintWriter, PrintStream }
import java.net.InetSocketAddress
import java.net.URI import java.net.URI
import java.net.URISyntaxException import java.net.URISyntaxException
import java.net.InetAddress import java.net.InetAddress
import java.net.UnknownHostException import java.net.UnknownHostException
import java.net.UnknownServiceException
import akka.event.Logging import akka.event.Logging
/** /**

1
akka-remote/src/main/scala/akka/remote/RemoteSettings.scala
View file

@ -8,7 +8,6 @@ import akka.util.Duration
import java.util.concurrent.TimeUnit.MILLISECONDS import java.util.concurrent.TimeUnit.MILLISECONDS
import java.net.InetAddress import java.net.InetAddress
import akka.config.ConfigurationException import akka.config.ConfigurationException
import com.eaio.uuid.UUID
import scala.collection.JavaConverters._ import scala.collection.JavaConverters._
class RemoteSettings(val config: Config, val systemName: String) { class RemoteSettings(val config: Config, val systemName: String) {

3
akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala
View file

@ -4,7 +4,7 @@
package akka.remote.netty package akka.remote.netty
import akka.actor.{ ActorRef, IllegalActorStateException, simpleName } import akka.actor.{ ActorRef, simpleName }
import akka.remote._ import akka.remote._
import RemoteProtocol._ import RemoteProtocol._
import akka.util._ import akka.util._
@ -25,7 +25,6 @@ import akka.actor.ActorSystemImpl
import org.jboss.netty.handler.execution.{ ExecutionHandler, OrderedMemoryAwareThreadPoolExecutor } import org.jboss.netty.handler.execution.{ ExecutionHandler, OrderedMemoryAwareThreadPoolExecutor }
import java.util.concurrent._ import java.util.concurrent._
import locks.ReentrantReadWriteLock import locks.ReentrantReadWriteLock
import akka.dispatch.MonitorableThreadFactory
class RemoteClientMessageBufferException(message: String, cause: Throwable = null) extends AkkaException(message, cause) { class RemoteClientMessageBufferException(message: String, cause: Throwable = null) extends AkkaException(message, cause) {
def this(msg: String) = this(msg, null) def this(msg: String) = this(msg, null)

3
akka-remote/src/multi-jvm/scala/akka/remote/DirectRoutedRemoteActorMultiJvmSpec.scala
View file

@ -1,11 +1,8 @@
package akka.remote package akka.remote
import akka.remote._
import akka.routing._
import akka.actor.{ Actor, Props } import akka.actor.{ Actor, Props }
import akka.testkit._ import akka.testkit._
import akka.dispatch.Await import akka.dispatch.Await
import akka.pattern.ask
object DirectRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { object DirectRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec {
override def NrOfNodes = 2 override def NrOfNodes = 2

4
akka-remote/src/multi-jvm/scala/akka/remote/NewRemoteActorMultiJvmSpec.scala
View file

@ -1,12 +1,8 @@
package akka.remote package akka.remote
import akka.actor.{ Actor, Props } import akka.actor.{ Actor, Props }
import akka.remote._
import akka.routing._
import akka.testkit._ import akka.testkit._
import akka.util.duration._
import akka.dispatch.Await import akka.dispatch.Await
import akka.pattern.ask
object NewRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { object NewRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec {
override def NrOfNodes = 2 override def NrOfNodes = 2

2
akka-remote/src/multi-jvm/scala/akka/remote/RandomRoutedRemoteActorMultiJvmSpec.scala
View file

@ -1,11 +1,9 @@
package akka.remote package akka.remote
import akka.actor.{ Actor, Props } import akka.actor.{ Actor, Props }
import akka.remote._
import akka.routing._ import akka.routing._
import akka.testkit.DefaultTimeout import akka.testkit.DefaultTimeout
import akka.dispatch.Await import akka.dispatch.Await
import akka.pattern.ask
object RandomRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { object RandomRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec {
override def NrOfNodes = 4 override def NrOfNodes = 4

2
akka-remote/src/multi-jvm/scala/akka/remote/RoundRobinRoutedRemoteActorMultiJvmSpec.scala
View file

@ -1,11 +1,9 @@
package akka.remote package akka.remote
import akka.actor.{ Actor, Props } import akka.actor.{ Actor, Props }
import akka.remote._
import akka.routing._ import akka.routing._
import akka.testkit.DefaultTimeout import akka.testkit.DefaultTimeout
import akka.dispatch.Await import akka.dispatch.Await
import akka.pattern.ask
object RoundRobinRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec { object RoundRobinRoutedRemoteActorMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec {
override def NrOfNodes = 4 override def NrOfNodes = 4

1
akka-remote/src/multi-jvm/scala/akka/remote/ScatterGatherRoutedRemoteActorMultiJvmSpec.scala
View file

@ -1,7 +1,6 @@
package akka.remote package akka.remote
import akka.actor.{ Actor, Props } import akka.actor.{ Actor, Props }
import akka.remote._
import akka.routing._ import akka.routing._
import akka.testkit._ import akka.testkit._
import akka.util.duration._ import akka.util.duration._