PJ Fanning
92ca0314c0
silence compiler warnings new in scala 2.13.17 ( #2255 )
...
* silence compiler warning new in scala 2.13.17
* Update FrequencySketch.scala
2025-09-21 23:01:40 +08:00
He-Pin(kerr)
4f2434b650
chore: Drop @unused annotation from pekko ( #2241 )
2025-09-20 13:28:02 +08:00
He-Pin(kerr)
870d4499cc
chore: sort imports ( #2235 )
2025-09-20 11:30:05 +08:00
He-Pin(kerr)
8254acc0e8
chore: Remove ccompat.JavaConverters ( #2234 )
2025-09-20 01:12:16 +08:00
He-Pin(kerr)
8c48393cd3
chore: Remove pekko.dispatch.ExecutionContexts.parasitic ( #2208 )
...
* chore: Remove pekko.dispatch.ExecutionContexts.parasitic
* .
2025-09-19 22:17:20 +08:00
He-Pin(kerr)
5acdace08c
chore: Remove compat Future ( #2212 )
2025-09-19 22:16:21 +08:00
PJ Fanning
f2b677dfa0
remove scala 2.12 support ( #1986 )
...
* remove scala 2.12 support
* move around some source because we don't need as many source dirs
* move more files
* remove annotations
* remove annotations
* Create remove-scala-2.12-support.excludes
* remove some scala-2.12 refs
* remove compat.PartialFunction
* Update remove-scala-2.12-support.excludes
2025-09-13 10:03:10 +01:00
PJ Fanning
18d7ff815a
bind instanceof to named variables ( #2088 )
...
* bind instanceof to named variables
* Update StashJavaAPITestActors.java
* Update InteractionPatternsTest.java
2025-08-25 13:44:38 +01:00
He-Pin(kerr)
00b0a99278
chore: bump javafmt to 0.10.0 ( #2081 )
...
* chore: bump javafmt to 0.10.0
* chore: format with javafmt
2025-08-25 19:32:35 +08:00
He-Pin(kerr)
a2aa52faf5
chore: Remove deprecated AssociationHandle.disassociate ( #2074 )
2025-08-24 09:19:22 +08:00
PJ Fanning
19d4fd1bfa
remove deprecated method in AeronErrorLog ( #2055 )
...
* remove deprecated method in AeronErrorLog
* Update remove-deprecated-methods.excludes
2025-08-23 11:39:12 +01:00
PJ Fanning
e0619c34fb
generate source with protobuf 32 ( #2036 )
...
* generate source with protobuf 32
* javafmt
2025-08-20 08:21:18 +01:00
He-Pin(kerr)
7325c729ce
Make use of eq and ne. ( #1994 )
...
* chore: make use of eq instead of ==
* chore: make use of ne instead of !=
2025-08-03 17:32:32 +08:00
PJ Fanning
db60119b42
avoid sun.misc.Unsafe by using VarHandles ( #1990 )
...
* don't use unsafe to update nextName
Update Children.scala
Update Children.scala
use varhandle
Update AbstractActorCell.java
review comment
Update Children.scala
remove more usages of Unsafe
more
more
more
javafmt
Update LightArrayRevolverScheduler.scala
Update AbstractNodeQueue.java
Update AbstractBoundedNodeQueue.java
Revert "more"
This reverts commit ef119f4ebf9fa528a880dd13dd833e4e8c6effc8.
revert some promise actor changes
javafmt
* watchedBy
* Reapply "more"
This reverts commit ba2b43cd7d920a67e2e3ac9355c50c6b8169d451.
try again
* remove imports
* javafmt
* Update Unsafe.java
* Create util-unsafe-refactor.excludes
* internal api
2025-08-02 12:10:52 +01:00
PJ Fanning
5aad47eb6c
remove deprecated code from pekko-remote ( #1983 )
...
* remove deprecated code from pekko-remote
* undo disassociate changes
* Update Transport.scala
* Update remove-deprecated-methods.excludes
* Update remove-deprecated-methods.excludes
2025-08-01 08:53:11 +01:00
PJ Fanning
6a995664ea
move jdk9 source code ( #1976 )
...
* move jdk9 source code
* Update Events.scala
* javafmt
* unused import
* remote classes
* Update JFRRemotingFlightRecorder.scala
* stream tests
* javafmt
* doc links
* remove PekkoDependWalker
* build issues
* remove mention of JDK 9
* Update JavaFlowSupport.java
2025-07-31 10:36:49 +01:00
PJ Fanning
2b5b3f8f43
remove some more deprecated code from pekko-actor ( #1969 )
...
* remove some deprecated code from pekko-actor
Update Scheduler.scala
Update AbstractActor.scala
mima filters
remove more deprecated code from pekko-actor
revert
* Delete TypedActorRemoteDeploySpec.scala
* Update remove-deprecated-methods.excludes
2025-07-31 09:07:14 +01:00
scala-steward-asf[bot]
23518214bb
Update aeron-client, aeron-driver to 1.48.5 ( #1973 )
...
* Update aeron-client, aeron-driver to 1.48.5
* ThreadHints is deprecated
* Update Dependencies.scala
---------
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
2025-07-30 18:23:41 +01:00
PJ Fanning
f23107fc43
Remove java8 home and scala steward pins related to java 11 and java 17 ( #1968 )
...
* remove use of java8 home
* scala deprecations
* upgrade paradox
* getId is deprecated
* remove targetSystemJdk build option
* Update JdkOptions.scala
2025-07-30 13:34:30 +01:00
PJ Fanning
2323878ae1
Remove some deprecated code in pekko-actor ( #1945 )
...
* remove some deprecated code from pekko-actor
* Update Scheduler.scala
* Update ActorCreationTest.java
* remove more code
* Update DnsProvider.scala
* Update DnsProvider.scala
* Update AbstractActor.scala
* mima filters
* Update remove-deprecated-methods.excludes
* Update Scheduler.scala
2025-07-29 08:57:15 +01:00
PJ Fanning
220981a141
try making TLS v1.3 the default ( #1901 )
...
* try making TLS v1.3 the default
* tls 1.3 in docs and some test fixes (new cipher suites)
* remove TLS_CHACHA20_POLY1305_SHA256
* run java 24 tests
* Update RemoteConfigSpec.scala
* Revert "run java 24 tests"
This reverts commit 479408951303e4389b88d288a5ac4aa0d448c4d3.
* test issues
* Update TcpSpec.scala
2025-06-24 10:23:14 +01:00
He-Pin(kerr)
9577b01b10
chore: bump scalafmt to 3.9.7 ( #1916 )
2025-06-24 10:27:14 +02:00
PJ Fanning
e6e653b0a8
remote duplicate line in reference.conf ( #1913 )
2025-06-20 12:25:22 +02:00
PJ Fanning
d7f0d51028
support akka configs in InitJoinAck ( #1877 )
...
* support akka configs in InitJoinAck
* Update SeedNodeProcess.scala
* add tests
* add akka version
* Init join ack test (#4 )
* modify mixed protocol test to be strict
Update ClusterDaemon.scala
* Update SeedNodeProcess.scala
* refactor
* rename methods (review comment)
2025-06-03 19:14:09 +01:00
PJ Fanning
c44dc07ed8
Issue forming mixed Akka/Pekko cluster when classic remoting with SSL/TLS is used ( #1857 )
...
* create test for mixed cluster (classic netty with ssl)
* wip
* truststore/keystore
* Update MixedProtocolClusterSpec.scala
* Update MixedProtocolClusterSpec.scala
2025-05-21 20:58:30 +01:00
PJ Fanning
05044a65d3
protobuf-java 4.29.3 ( #1795 )
...
* try protobuf-java 4.30.0
* regen code
* javafmt
* mima
* Create protoc4-upgrade.excludes
* more mima
* Update protoc4-upgrade.excludes
2025-04-17 23:10:33 +02:00
PJ Fanning
92ed723260
upgrade to Netty 4.2.0.Final ( #1794 )
...
* Test Netty 4.2.0.RC4
* ignore deprecated warnings (for now)
* refactor
* Update Dependencies.scala
2025-04-15 15:49:17 +02:00
scala-steward-asf[bot]
919d9c9309
Update protobuf-java to 3.25.6 ( #1748 )
...
* Update protobuf-java to 3.25.6
* regenerate protobuf classes with protoc 25.6
---------
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
Co-authored-by: Arnout Engelen <arnout@bzzt.net>
2025-01-27 11:26:18 +01:00
scala-steward-asf[bot]
5b2aab6f7a
Update scalafmt-core to 3.8.4 ( #1717 )
...
* Update scalafmt-core to 3.8.4
* Reformat with scalafmt 3.8.4
Executed command: scalafmt --non-interactive
* Add 'Reformat with scalafmt 3.8.4' to .git-blame-ignore-revs
* remove postfixOps imports
Assuming we want to keep the default
`rewrite.avoidInfix.excludePostfix = false` - otherwise
we can drop this commit
---------
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
Co-authored-by: Arnout Engelen <arnout@bzzt.net>
2025-01-18 10:36:38 +08:00
He-Pin(kerr)
a75bc7a772
chore: Make code compiles on JDK 23 ( #1726 )
2025-01-18 05:28:40 +08:00
He-Pin(kerr)
dbc9ed3a99
chore: Add support for controlling the NettyTransport's byteBuf allocator type. ( #1707 )
...
* chore: Add support for controlling the NettyTransport's byteBuf allocator type.
* chore: extract deriveByteBufAllocator method
2025-01-14 18:41:35 +08:00
PJ Fanning
ec5e33fdb9
add non-default config that allows InboundQuarantineCheck to ignore 'harmless' quarantine events ( #1555 )
...
* stub test for harmless=true
Update OutboundIdleShutdownSpec.scala
Update OutboundIdleShutdownSpec.scala
Update OutboundIdleShutdownSpec.scala
* add quarantinedButHarmless check for tests
* new test case
* Update OutboundIdleShutdownSpec.scala
* try to not shutdown when quarantine is harmless
* Update OutboundIdleShutdownSpec.scala
* Create quarantine.backwards.excludes
* Update quarantine.backwards.excludes
* update log message
* try to add config
* Update ArterySettings.scala
* add tests
* Update OutboundIdleShutdownSpec.scala
* rework test
2025-01-04 11:04:06 +01:00
He-Pin(kerr)
03712a927e
perf: optmize NettyChannelHandlerAdapter with explict extends. ( #1667 )
2025-01-04 00:27:42 +08:00
PJ Fanning
ef212e9a98
reimplement fix for akka/pekko cluster ( #1594 )
...
* Revert "revert #1568 due to test failures (#1587 )"
This reverts commit 7af03e5215 .
* temp run nightly test in this PR
* no need for square brackets because the set print adds them
* logging to find issue
* support tcp protocols
* Update ClusterDaemon.scala
* remove temp logging
* try to fix issue in Remoting
* extra tests
* more tests
* ignore udp tests
* try to make tests tidy up after failures
* Update MixedProtocolClusterSpec.scala
* Update MixedProtocolClusterSpec.scala
* run main cluster tests for PR
2025-01-01 12:13:50 +01:00
PJ Fanning
1e09622775
reduce use of scala.collection.JavaConverters ( #1511 )
...
Update Index.scala
Update Index.scala
2024-10-02 10:40:51 +01:00
PJ Fanning
711f711360
replace more uses of Util.immutableSeq ( #1509 )
...
* replace more uses of Util.immutableSeq
* Update ClusterClient.scala
* more changes
* Update NettySSLSupport.scala
* Update ClusterClient.scala
* Update ClusterClient.scala
2024-10-01 13:43:31 +01:00
scala-steward-asf[bot]
fa1351b213
Reformat with scalafmt 3.8.2
...
Executed command: scalafmt --non-interactive
2024-06-16 07:56:40 +01:00
PJ Fanning
e3410bcaa8
Pekko becomes TLP ( #1214 )
2024-03-22 14:16:08 +01:00
PJ Fanning
0646754739
forward fit Akka compat changes ( #1211 )
...
* Handle mixed akka/pekko protocol names
* add extra changes needed to get akka cluster support
* add default for pekko.remote.akka.version (#1112 )
* add default for pekko.cluster.akka.version
* refactor configs
* Update reference.conf
* add validations for config settings
* Update RemoteSettings.scala
* Update RemoteSettingsSpec.scala
* scalafmt
---------
Co-authored-by: Matthew de Detrich <matthew.dedetrich@aiven.io>
2024-03-22 10:23:09 +01:00
Nicolas Vollmar
613a45bad9
Rework PhiAccrualFailureDetector to enable monitoring of interval ( #1137 )
...
* Introduce trait to avoid matching concrete subclass
* Extract interval method to make it available for recording metrics
---------
Co-authored-by: Matthew de Detrich <matthew.dedetrich@aiven.io>
2024-02-26 12:27:04 +01:00
PJ Fanning
46f93816ce
Protobuf 3.23.4 ( #1103 )
...
* protobuf-java 3.22.5
* deprecation issue
* protobuf-java 3.23.4
2024-02-07 14:32:56 +01:00
AndyChen(Jingzhang)
8ce4973fc9
Configuration typo fixes ( #1100 )
...
* configuration typo
* chore: all module configuration typo fix
* apply suggestion
2024-02-05 17:21:23 +01:00
PJ Fanning
8f142e3e18
improve performance in PEM reader ( #997 )
...
* improve performance in PEM reader
* revert use of java 11 readString method
2024-01-20 18:17:26 +01:00
PJ Fanning
11ba3d7bef
fix managerName to use pekko ( #587 )
...
* fix managerName to use `pekko`
* make name configurable
* Update PekkoProtocolTransport.scala
2024-01-16 13:53:57 +01:00
PJ Fanning
8c688dad2e
use more of StandardCharsets ( #952 )
...
* use more of StandardCharsets
* scalafmt
2024-01-14 23:50:50 +01:00
Laglangyue
6872f9c8b7
Fix some non-standard comments ( #939 )
...
* Fix some non-standard comments
* revert
---------
Co-authored-by: Jiafu Tang <jiafu.tang@qq.com>
2024-01-14 12:47:51 +01:00
PJ Fanning
6883d15576
use StandardCharsets ( #934 )
2024-01-13 12:40:16 +01:00
PJ Fanning
468aab0c63
reformat some headers ( #921 )
...
* reformat some headers
* add new line at EOF
2024-01-09 19:14:17 +01:00
Matthew de Detrich
8cb7d256dc
Remove @inline annotations and enable Scala 2 inliner
2023-12-30 03:41:12 +01:00
PJ Fanning
ccce880d4c
license headers for mima files ( #813 )
2023-11-23 09:41:44 +01:00