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

replace 2551 with 7354

Browse source
This commit is contained in:
PJ Fanning 2023-03-08 11:40:04 +01:00 • committed by kerr
parent c23f9fb834
commit 5322174ecc
19 changed files with 32 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

8
cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/ClusterMetricsRoutingSpec.scala
View file

@ -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)

8
cluster-metrics/src/test/scala/org/apache/pekko/cluster/metrics/WeightedRouteesSpec.scala
View file

@ -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"))

4
cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/typed/BasicClusterExampleTest.java
View file

@ -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));

8
cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala
View file

@ -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
}
}
}

6
cluster/jmx-client/pekko-cluster
View file

@ -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

2
cluster/src/test/scala/org/apache/pekko/cluster/ClusterDomainEventPublisherSpec.scala
View file

@ -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)

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/DataEnvelopeSpec.scala
View file

@ -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)

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/GCounterSpec.scala
View file

@ -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)

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWMapSpec.scala
View file

@ -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 {

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LWWRegisterSpec.scala
View file

@ -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 {

4
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/LotsOfDataBot.scala
View file

@ -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

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMapSpec.scala
View file

@ -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 {

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORMultiMapSpec.scala
View file

@ -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 {

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ORSetSpec.scala
View file

@ -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)

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterMapSpec.scala
View file

@ -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 {

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PNCounterSpec.scala
View file

@ -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 {

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/PruningStateSpec.scala
View file

@ -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)

2
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/VersionVectorSpec.scala
View file

@ -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)

2
docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java
View file

@ -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);