Skip to content

Commit e004814

Browse files
sadekmunawarSadek Munawar
andauthored
Fix Address ordering bug (#1562)
Co-authored-by: Sadek Munawar <[email protected]>
1 parent 3dd4e18 commit e004814

File tree

2 files changed

+38
-1
lines changed

2 files changed

+38
-1
lines changed
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one or more
3+
* contributor license agreements. See the NOTICE file distributed with
4+
* this work for additional information regarding copyright ownership.
5+
* The ASF licenses this file to You under the Apache License, Version 2.0
6+
* (the "License"); you may not use this file except in compliance with
7+
* the License. You may obtain a copy of the License at
8+
*
9+
* http://www.apache.org/licenses/LICENSE-2.0
10+
*
11+
* Unless required by applicable law or agreed to in writing, software
12+
* distributed under the License is distributed on an "AS IS" BASIS,
13+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
* See the License for the specific language governing permissions and
15+
* limitations under the License.
16+
*/
17+
18+
package org.apache.pekko.actor
19+
20+
import org.apache.pekko.testkit.PekkoSpec
21+
22+
class AddressSpec extends PekkoSpec {
23+
"Address ordering" must {
24+
25+
"work correctly with multiple mixed protocols" in {
26+
val pekkoAddress1 = Address("pekko", "system", "host1", 1000)
27+
val pekkoAddress2 = Address("pekko", "system", "host2", 1000)
28+
val akkaAddress1 = Address("akka", "system", "host1", 1000)
29+
val akkaAddress2 = Address("akka", "system", "host2", 1000)
30+
31+
val addresses = Seq(pekkoAddress1, pekkoAddress2, akkaAddress1, akkaAddress2)
32+
val sortedAddresses = addresses.sorted
33+
34+
sortedAddresses should ===(Seq(akkaAddress1, akkaAddress2, pekkoAddress1, pekkoAddress2))
35+
}
36+
}
37+
}

actor/src/main/scala/org/apache/pekko/actor/Address.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ object Address {
136136
*/
137137
implicit val addressOrdering: Ordering[Address] = Ordering.fromLessThan[Address] { (a, b) =>
138138
if (a eq b) false
139-
else if (a.protocol != b.protocol) a.system.compareTo(b.protocol) < 0
139+
else if (a.protocol != b.protocol) a.protocol.compareTo(b.protocol) < 0
140140
else if (a.system != b.system) a.system.compareTo(b.system) < 0
141141
else if (a.host != b.host) a.host.getOrElse("").compareTo(b.host.getOrElse("")) < 0
142142
else if (a.port != b.port) a.port.getOrElse(0) < b.port.getOrElse(0)

0 commit comments

Comments
 (0)