You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2023/03/08 21:00:12 UTC
[incubator-pekko] 04/05: replace 2551 with 7354
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
commit 5322174ecc57cbf7ab0d2babe219d1e4f7b2b7c5
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Wed Mar 8 11:40:04 2023 +0100
replace 2551 with 7354
---
.../apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala | 8 ++++----
.../org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala | 8 ++++----
.../org/apache/pekko/cluster/typed/BasicClusterExampleTest.java | 4 ++--
.../org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala | 8 ++++----
cluster/jmx-client/pekko-cluster | 6 +++---
.../apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala | 4 ++--
.../src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala | 2 +-
.../src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala | 2 +-
.../test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala | 2 +-
.../scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala | 2 +-
docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java | 2 +-
19 files changed, 32 insertions(+), 32 deletions(-)
diff --git a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
index 29547b593f..5546d14c62 100644
--- a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
+++ b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
@@ -28,10 +28,10 @@ class MetricsSelectorSpec extends AnyWordSpec with Matchers {
override def capacity(nodeMetrics: Set[NodeMetrics]): Map[Address, Double] = Map.empty
}
- val a1 = Address("pekko", "sys", "a1", 2551)
- val b1 = Address("pekko", "sys", "b1", 2551)
- val c1 = Address("pekko", "sys", "c1", 2551)
- val d1 = Address("pekko", "sys", "d1", 2551)
+ val a1 = Address("pekko", "sys", "a1", 7354)
+ val b1 = Address("pekko", "sys", "b1", 7354)
+ val c1 = Address("pekko", "sys", "c1", 7354)
+ val d1 = Address("pekko", "sys", "d1", 7354)
val decayFactor = Some(0.18)
diff --git a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
index ccf8b40f88..8f92164152 100644
--- a/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
+++ b/cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
@@ -35,10 +35,10 @@ class WeightedRouteesSpec extends PekkoSpec(ConfigFactory.parseString("""
if (RARP(system).provider.remoteSettings.Artery.Enabled) "pekko"
else "pekko.tcp"
- val a1 = Address(protocol, "sys", "a1", 2551)
- val b1 = Address(protocol, "sys", "b1", 2551)
- val c1 = Address(protocol, "sys", "c1", 2551)
- val d1 = Address(protocol, "sys", "d1", 2551)
+ val a1 = Address(protocol, "sys", "a1", 7354)
+ val b1 = Address(protocol, "sys", "b1", 7354)
+ val c1 = Address(protocol, "sys", "c1", 7354)
+ val d1 = Address(protocol, "sys", "d1", 7354)
val routeeA = ActorSelectionRoutee(system.actorSelection(RootActorPath(a1) / "user" / "a"))
val routeeB = ActorSelectionRoutee(system.actorSelection(RootActorPath(b1) / "user" / "b"))
diff --git a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
index b92d3d01e2..fe5445af20 100644
--- a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
+++ b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
@@ -45,7 +45,7 @@ public class BasicClusterExampleTest { // extends JUnitSuite {
+ " remote.artery { \n"
+ " canonical { \n"
+ " hostname = \"127.0.0.1\" \n"
- + " port = 2551 \n"
+ + " port = 7354 \n"
+ " } \n"
+ " } \n"
+ "} \n");
@@ -131,7 +131,7 @@ public class BasicClusterExampleTest { // extends JUnitSuite {
// #join-seed-nodes
List<Address> seedNodes = new ArrayList<>();
- seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:2551"));
+ seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:7354"));
seedNodes.add(AddressFromURIString.parse("pekko://ClusterSystem@127.0.0.1:7355"));
Cluster.get(system).manager().tell(new JoinSeedNodes(seedNodes));
diff --git a/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala b/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
index 6e3a4a13e8..5e9dda4298 100644
--- a/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
+++ b/cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
@@ -46,13 +46,13 @@ pekko {
remote.artery {
canonical {
hostname = "127.0.0.1"
- port = 2551
+ port = 7354
}
}
cluster {
seed-nodes = [
- "pekko://ClusterSystem@127.0.0.1:2551",
+ "pekko://ClusterSystem@127.0.0.1:7354",
"pekko://ClusterSystem@127.0.0.1:7355"]
downing-provider-class = "org.apache.pekko.cluster.sbr.SplitBrainResolverProvider"
@@ -75,7 +75,7 @@ pekko {
import pekko.cluster.typed.JoinSeedNodes
val seedNodes: List[Address] =
- List("pekko://ClusterSystem@127.0.0.1:2551", "pekko://ClusterSystem@127.0.0.1:7355").map(
+ List("pekko://ClusterSystem@127.0.0.1:7354", "pekko://ClusterSystem@127.0.0.1:7355").map(
AddressFromURIString.parse)
Cluster(system).manager ! JoinSeedNodes(seedNodes)
// #join-seed-nodes
@@ -163,7 +163,7 @@ pekko {
remote.artery {
canonical {
hostname = "127.0.0.1"
- port = 2551
+ port = 7354
}
}
}
diff --git a/cluster/jmx-client/pekko-cluster b/cluster/jmx-client/pekko-cluster
index 2bb59b63a4..ac347238fc 100755
--- a/cluster/jmx-client/pekko-cluster
+++ b/cluster/jmx-client/pekko-cluster
@@ -219,9 +219,9 @@ do
printf "Examples: $0 localhost 9999 is-available\n"
printf " $0 localhost 9999 join pekko.tcp://MySystem@darkstar:7355\n"
printf " $0 localhost 9999 cluster-status\n"
- printf " $0 localhost 9999 -p 2551 is-available\n"
- printf " $0 localhost 9999 -p 2551 join pekko.tcp://MySystem@darkstar:7355\n"
- printf " $0 localhost 9999 -p 2551 cluster-status\n"
+ printf " $0 localhost 9999 -p 7354 is-available\n"
+ printf " $0 localhost 9999 -p 7354 join pekko.tcp://MySystem@darkstar:7355\n"
+ printf " $0 localhost 9999 -p 7354 cluster-status\n"
exit 1
;;
esac
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
index 3df03b3147..e2c828ad78 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
@@ -61,7 +61,7 @@ class ClusterDomainEventPublisherSpec
val cJoining = TestMember(Address(protocol, "sys", "c", 7355), Joining, Set("GRP"))
val cUp = cJoining.copy(status = Up)
val cRemoved = cUp.copy(status = Removed)
- val a51Up = TestMember(Address(protocol, "sys", "a", 2551), Up)
+ val a51Up = TestMember(Address(protocol, "sys", "a", 7354), Up)
val dUp = TestMember(Address(protocol, "sys", "d", 7355), Up, Set("GRP"))
val eUp = TestMember(Address(protocol, "sys", "e", 7355), Up, Set("GRP"), OtherDataCenter)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
index c48c080db8..29cf0ac607 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Internal.DataEnvelope
class DataEnvelopeSpec extends AnyWordSpec with Matchers {
import PruningState._
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
index d04649f707..51178dfe7f 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
@@ -22,7 +22,7 @@ import pekko.cluster.UniqueAddress
import pekko.cluster.ddata.Replicator.Changed
class GCounterSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
index e13375382b..e4f326968d 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class LWWMapSpec extends AnyWordSpec with Matchers {
import LWWRegister.defaultClock
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A LWWMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
index df5465c757..864655d026 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class LWWRegisterSpec extends AnyWordSpec with Matchers {
import LWWRegister.defaultClock
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A LWWRegister" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
index bb830c5d67..c8b2b7136b 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
@@ -33,7 +33,7 @@ object LotsOfDataBot {
def main(args: Array[String]): Unit = {
if (args.isEmpty)
- startup(Seq("2551", "7355", "0"))
+ startup(Seq("7354", "7355", "0"))
else
startup(args.toIndexedSeq)
}
@@ -57,7 +57,7 @@ object LotsOfDataBot {
pekko.cluster {
seed-nodes = [
- "pekko://ClusterSystem@127.0.0.1:2551",
+ "pekko://ClusterSystem@127.0.0.1:7354",
"pekko://ClusterSystem@127.0.0.1:7355"]
downing-provider-class = org.apache.pekko.cluster.testkit.AutoDowning
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
index f2b1dd82f2..f40e9a16d0 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
@@ -24,7 +24,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORMapSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A ORMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
index a469da028c..15653f7f67 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORMultiMapSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A ORMultiMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
index f8a1cee29d..b04164324c 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
@@ -25,7 +25,7 @@ import pekko.cluster.ddata.Replicator.Changed
class ORSetSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
index 6e062dd0f0..3f8468db86 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.ddata.Replicator.Changed
class PNCounterMapSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A PNCounterMap" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
index 0ef9d4f761..7990808c51 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
@@ -22,7 +22,7 @@ import pekko.cluster.UniqueAddress
import pekko.cluster.ddata.Replicator.Changed
class PNCounterSpec extends AnyWordSpec with Matchers {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
"A PNCounter" must {
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
index 24ab7c978b..d6f3c7cc69 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
@@ -23,7 +23,7 @@ import pekko.cluster.UniqueAddress
class PruningStateSpec extends AnyWordSpec with Matchers {
import PruningState._
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
diff --git a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
index ff65f934b4..b1a3d2c07a 100644
--- a/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
+++ b/distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
@@ -29,7 +29,7 @@ class VersionVectorSpec
with Matchers
with BeforeAndAfterAll {
- val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 2551), 1L)
+ val node1 = UniqueAddress(Address("pekko", "Sys", "localhost", 7354), 1L)
val node2 = UniqueAddress(node1.address.copy(port = Some(7355)), 2L)
val node3 = UniqueAddress(node1.address.copy(port = Some(7356)), 3L)
val node4 = UniqueAddress(node1.address.copy(port = Some(7357)), 4L)
diff --git a/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java b/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
index 07a05c6ed3..162a4784df 100644
--- a/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
+++ b/docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
@@ -28,7 +28,7 @@ public class StatsSampleOneMasterMain {
public static void main(String[] args) {
if (args.length == 0) {
- startup(new String[] {"2551", "7355", "0"});
+ startup(new String[] {"7354", "7355", "0"});
StatsSampleOneMasterClientMain.main(new String[0]);
} else {
startup(args);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org