From 1e0a29d9391c8e62ed8cab1664d645be20fbda11 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Fri, 5 Oct 2012 08:23:11 +0200 Subject: [PATCH] Wipe @author tags * we have collective code ownership and authorship is maintained by the git log --- .../src/main/scala/akka/actor/Deployer.scala | 2 -- .../cluster/ClusterMetricsCollector.scala | 20 ------------------- .../testkit/CallingThreadDispatcher.scala | 1 - .../scala/akka/testkit/TestActorRef.scala | 1 - .../main/scala/akka/testkit/TestFSMRef.scala | 1 - .../src/main/scala/akka/testkit/TestKit.scala | 1 - .../scala/akka/testkit/TestActorRefSpec.scala | 3 --- 7 files changed, 29 deletions(-) diff --git a/akka-actor/src/main/scala/akka/actor/Deployer.scala b/akka-actor/src/main/scala/akka/actor/Deployer.scala index 3f5e2b1785..dd3e88dcda 100644 --- a/akka-actor/src/main/scala/akka/actor/Deployer.scala +++ b/akka-actor/src/main/scala/akka/actor/Deployer.scala @@ -105,8 +105,6 @@ case object NoScopeGiven extends NoScopeGiven { /** * Deployer maps actor paths to actor deployments. - * - * @author Jonas Bonér */ private[akka] class Deployer(val settings: ActorSystem.Settings, val dynamicAccess: DynamicAccess) { diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala index ed485cae07..87bb15450b 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala @@ -33,8 +33,6 @@ import java.lang.System.{ currentTimeMillis ⇒ newTimestamp } * * Calculation of statistical data for each monitored process is delegated to the * [[akka.cluster.DataStream]] for exponential smoothing, with additional decay factor. - * - * @author Helena Edelson */ private[cluster] class ClusterMetricsCollector(publisher: ActorRef) extends Actor with ActorLogging { @@ -162,7 +160,6 @@ private[cluster] class ClusterMetricsCollector(publisher: ActorRef) extends Acto * INTERNAL API * * @param nodes metrics per node - * @author Helena Edelson */ private[cluster] case class MetricsGossip(rateOfDecay: Int, nodes: Set[NodeMetrics] = Set.empty) { @@ -243,8 +240,6 @@ private[cluster] case class MetricsGossipEnvelope(from: Address, gossip: Metrics * @param timestamp the most recent time of sampling * * @param startTime the time of initial sampling for this data stream - * - * @author Helena Edelson */ private[cluster] case class DataStream(decay: Int, ewma: ScalaNumber, startTime: Long, timestamp: Long) extends ClusterMessage with MetricNumericConverter { @@ -278,8 +273,6 @@ private[cluster] case class DataStream(decay: Int, ewma: ScalaNumber, startTime: * INTERNAL API * * Companion object of DataStream class. - * - * @author Helena Edelson */ private[cluster] object DataStream { @@ -297,8 +290,6 @@ private[cluster] object DataStream { * * @param average the data stream of the metric value, for trending over time. Metrics that are already * averages (e.g. system load average) or finite (e.g. as total cores), are not trended. - * - * @author Helena Edelson */ private[cluster] case class Metric(name: String, value: Option[ScalaNumber], average: Option[DataStream]) extends ClusterMessage with MetricNumericConverter { @@ -351,8 +342,6 @@ private[cluster] case class Metric(name: String, value: Option[ScalaNumber], ave * INTERNAL API * * Companion object of Metric class. - * - * @author Helena Edelson */ private[cluster] object Metric extends MetricNumericConverter { @@ -390,8 +379,6 @@ private[cluster] object Metric extends MetricNumericConverter { * @param timestamp the time of sampling * * @param metrics the array of sampled [[akka.actor.Metric]] - * - * @author Helena Edelson */ private[cluster] case class NodeMetrics(address: Address, timestamp: Long, metrics: Set[Metric] = Set.empty[Metric]) extends ClusterMessage { @@ -417,8 +404,6 @@ private[cluster] case class NodeMetrics(address: Address, timestamp: Long, metri * * Encapsulates evaluation of validity of metric values, conversion of an actual metric value to * a [[akka.cluster.Metric]] for consumption by subscribed cluster entities. - * - * @author Helena Edelson */ private[cluster] trait MetricNumericConverter { @@ -453,8 +438,6 @@ private[cluster] trait MetricNumericConverter { * @param sigar the optional org.hyperic.Sigar instance * * @param address The [[akka.actor.Address]] of the node being sampled - * - * @author Helena Edelson */ private[cluster] class MetricsCollector private (private val sigar: Option[AnyRef], address: Address) extends MetricNumericConverter { @@ -567,10 +550,7 @@ private[cluster] class MetricsCollector private (private val sigar: Option[AnyRe /** * INTERNAL API - * * Companion object of MetricsCollector class. - * - * @author Helena Edelson */ private[cluster] object MetricsCollector { def apply(address: Address, log: LoggingAdapter, dynamicAccess: DynamicAccess): MetricsCollector = diff --git a/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala b/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala index f47fa1acb6..0fbe4d7c18 100644 --- a/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala +++ b/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala @@ -118,7 +118,6 @@ object CallingThreadDispatcher { * is then executed. It is possible to suspend an actor from within its call * stack. * - * @author Roland Kuhn * @since 1.1 */ class CallingThreadDispatcher( diff --git a/akka-testkit/src/main/scala/akka/testkit/TestActorRef.scala b/akka-testkit/src/main/scala/akka/testkit/TestActorRef.scala index 57aedba34f..15a5174de7 100644 --- a/akka-testkit/src/main/scala/akka/testkit/TestActorRef.scala +++ b/akka-testkit/src/main/scala/akka/testkit/TestActorRef.scala @@ -16,7 +16,6 @@ import akka.pattern.ask * overrides the dispatcher to CallingThreadDispatcher and sets the receiveTimeout to None. Otherwise, * it acts just like a normal ActorRef. You may retrieve a reference to the underlying actor to test internal logic. * - * @author Roland Kuhn * @since 1.1 */ class TestActorRef[T <: Actor]( diff --git a/akka-testkit/src/main/scala/akka/testkit/TestFSMRef.scala b/akka-testkit/src/main/scala/akka/testkit/TestFSMRef.scala index 90f3b2f545..5d634de9ef 100644 --- a/akka-testkit/src/main/scala/akka/testkit/TestFSMRef.scala +++ b/akka-testkit/src/main/scala/akka/testkit/TestFSMRef.scala @@ -31,7 +31,6 @@ import scala.concurrent.util.FiniteDuration * assert (fsm.underlyingActor.getLog == IndexedSeq(FSMLogEntry(1, null, "hallo"))) * * - * @author Roland Kuhn * @since 1.2 */ class TestFSMRef[S, D, T <: Actor]( diff --git a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala index 28aa4e0220..9838f62d2a 100644 --- a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala +++ b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala @@ -637,7 +637,6 @@ trait TestKitBase { * are scaled using their Duration.dilated method, which uses the * TestKitExtension.Settings.TestTimeFactor settable via akka.conf entry "akka.test.timefactor". * - * @author Roland Kuhn * @since 1.1 */ class TestKit(_system: ActorSystem) extends { implicit val system = _system } with TestKitBase diff --git a/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala b/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala index 2e835b408f..0ee1923359 100644 --- a/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala +++ b/akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala @@ -17,10 +17,7 @@ import scala.concurrent.util.Duration /** * Test whether TestActorRef behaves as an ActorRef should, besides its own spec. - * - * @author Roland Kuhn */ - object TestActorRefSpec { var counter = 4