raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
27397 commits 1 branch 31 tags 268 MiB
Commit graph

103 commits

Author SHA1 Message Date
sadekmunawar
e004814731
Fix Address ordering bug (#1562) 
Co-authored-by: Sadek Munawar <musadek@amazon.com>
 2024-11-25 10:24:54 +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
PJ Fanning
f24e43687b
mark stop() method as noinline (#1485) 
* mark stop() method as noinline

* Update Dispatch.scala
 2024-09-25 10:00:21 +01:00
hughsimpson
c3999a0df4
Fix downstream kamon instrumentation (#1489) 
* add @noinline annotation to MessageBuffer.Node.apply

* add @noinline annotation to Envelope.copy

* add overriding defn of copy with @noinline annotation to ThreadPoolConfig

* add comments
 2024-09-21 14:00:43 +01:00
Andy(Jingzhang)Chen
d1ec224330
additional mailbox selector for typed props (#1096) 
* additional mailbox selector for typed props

* add unit test

* chore change of unit test

* Revert "configuration typo"

This reverts commit 7917feb32a4b042124513d98068db832cc59a541.

* fix pekko imports

* mention interoperability in doc

* share configuration in tests

* revert configuration change

* fix new typo

* fix jdocs tests

* optimized import

* mention api version in doc

* resolve import issue
 2024-08-28 19:12:35 +01:00
PJ Fanning
5a3f6f1863
add since marker in Timers.scala (#1457) 2024-08-28 13:51:54 +01:00
PJ Fanning
0fa708382c
Add new migration strategy for Pekko Persistence snapshots (#1423) 
* Add new migration strategy for Pekko Persistence snapshots

Update reference.conf

Update SnapshotSerializerSpec.scala

new impl

* add more tests

* add akka mode test

* rename file

* Update SnapshotSerializerMigrationAkkaSpec.scala

* extend akka test

* Update reference.conf

* Update SnapshotSerializer.scala

* rename config

* fix name of tests
 2024-08-21 11:58:16 +01:00
PJ Fanning
22194535fb
Add test for virtual thread support (#1436) 
* feat: Add virtual thread support

* use public lookup

* try to add test

* Update VirtualThreadPoolDispatcherSpec.scala

* Update VirtualThreadPoolDispatcherSpec.scala

* Apply suggestions from code review

Co-authored-by: Andy(Jingzhang)Chen <iRoiocam@gmail.com>

---------

Co-authored-by: He-Pin <hepin1989@gmail.com>
Co-authored-by: Andy(Jingzhang)Chen <iRoiocam@gmail.com>
 2024-08-14 18:59:42 +01:00
AndyChen(Jingzhang)
0153485657
fix: only setFailed when actor not null (#1399) 
* fix: only setFailed when actor not null

* chore: use ne rather than !=
 2024-07-18 22:57:34 +08:00
AndyChen(Jingzhang)
73c93622f1
fix: resolves and addition tests for child preStart supervise (#1385) 
* chore: add unit test for child actor initial exception supervise

* make assertion correct

* trying to fix assertion failed

* distinguish between fatal and normal fault

* fix unit tests

* trying to fix

* fix NPE

* revert isFailed condition

* revert isFailed place

* additional tests
 2024-07-15 22:54:06 +01:00
He-Pin(kerr)
979964eac9
chore: Fix typo in LARS comments (#1373) 2024-06-18 13:50:26 +08:00
He-Pin(kerr)
ce9f5a072f
feat: Support adjust the scheduler's tick-duration. (#1366) 2024-06-18 12:34:45 +08: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
He-Pin(kerr)
a9584ec520
feat: Add UntypedAbstractActorWithTimers (#1361) 2024-06-14 16:14:55 +08:00
João Costa
cce5f9b0d9
Avoid boxing in Framing (#1247) 
* Fix FramingBenchmark

* Add specialized indexOfByte

* Rename indexOfByte to indexOf

* Add missing @since(1.1.0) and reformat scaladoc

* Fix Scala 2.12 ambiguity problem

* Inline nextString

* Change default ByteString#indexOf to call indexWhere

This is always overriden, but I guess it won't hurt to have a default

* Remove default indexOf override

Calling indexWhere is already the default

* Fix MiMa issues
 2024-05-06 20:19:40 +01:00
scala-steward-asf[bot]
b6f2c5774e
Update scala-library to 2.13.14 (#1308) 
* Update scala-library to 2.13.14

* rename var that causes compile issue

* Update PekkoDisciplinePlugin.scala

* Update link-validator.conf

---------

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>
 2024-05-04 15:20:47 +02:00
João Costa
b5eb6ff01a
Replace Akka reference With Pekko (#1303) 2024-04-29 16:15:21 +02:00
He-Pin(kerr)
77532c1bb5
feat: Add retry with predicate (#1269) 2024-04-23 20:34:16 +08:00
João Costa
f70c26087c
chore: Fix ByteIterator#indexWhere (#1282) 
It would blow up when from was out of bounds.
 2024-04-16 10:41:21 +08:00
PJ Fanning
276a757d77
fix issue with forkjoin (#1245) 2024-03-31 19:12:45 +02:00
PJ Fanning
a2835b029d
support jdk9 forkjoinpool maximum-pool-size (#485) 
* support jdk9 forkjoinpool maximum-pool-size

Update PekkoJdk9ForkJoinPool.scala

Update ForkJoinPoolConstants.scala

scala 2.12 compile issue

review comments

use methodhandle

review comments

* refactor imports

Update PekkoJdk9ForkJoinPool.scala
 2024-03-30 13:45:02 +01:00
PJ Fanning
e3410bcaa8
Pekko becomes TLP (#1214) 2024-03-22 14:16:08 +01:00
Nicolas Vollmar
fa5c83f36f Add handling for tcp register timeout leaving connection dead 2024-03-09 10:51:12 +01:00
He-Pin(kerr)
1c85155047
chore: Replace Akka with Pekko in ActorSystem.scala (#1163) 2024-03-01 11:37:25 +08:00
AndyChen(Jingzhang)
2fdf7c9e9b
fix: proper path when promise actor terminated quickly (#1156) 2024-02-28 09:15:01 +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
ef628ea320
add asInputStream to ByteString (#1085) 
* add getInputStream to ByteString

* scala 2 updates

* rename as asInputStream

* make methods final

* use different asInputStream implementations on different subclasses

Co-Authored-By: João Ferreira <943051+jtjeferreira@users.noreply.github.com>

* Update ByteBufferBackedInputStream.scala

scalafmt

* remove default asInputStream impl

* add some tests - more needed

* Create bytestring-inputstream.excludes

* scalafmt

* Update bytestring-inputstream.excludes

* Update ByteStringInputStreamSpec.scala

* Update ByteStringInputStreamSpec.scala

* Update ByteStringInputStreamSpec.scala

* add benchmark

* Update ByteString_asInputStream_Benchmark.scala

* change to iterator earlier in chain

---------

Co-authored-by: João Ferreira <943051+jtjeferreira@users.noreply.github.com>
 2024-02-05 16:09:56 +01:00
Matthew de Detrich
25f80a160a Remove scala 3 inline keyword since its erased in bytecode 2024-01-29 11:57:03 +01:00
Matthew de Detrich
24ce39c010 Add targetName overloaded methods for Scala 3 inline methods 2024-01-29 00:21:36 +01:00
He-Pin(kerr)
8e7ae52a06
perf: Make use of System.arraycopy directly. (#1001) 2024-01-26 19:54:46 +08:00
He-Pin
4d8aa26404 chore: Add PekkoManagedBlocker to reduce memory. 2024-01-23 22:20:54 +08:00
AndyChen
7b2a3d8c27
fix: reject zero and negative periodic tasks schedule (#887) 
* fix: reject zero and negative periodic tasks schedule

* fix: undo the symbol change

* use different test name, redescribe the exception

* abstract check function

* remove the printlns change

* reduce time units scale convert
 2024-01-18 12:47:13 +01:00
PJ Fanning
7c82c2a1c4
fix up javadoc on Creator trait (#961) 2024-01-16 00:56:25 +08:00
He-Pin(kerr)
87609395a6
chore: Deprecate JAPI. (#949) 2024-01-15 19:34:25 +08:00
He-Pin(kerr)
df302b8ee6
feat: Add create method to PFBuilder. (#947) 2024-01-15 17:37:14 +08: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
d5381958c8
fix ByteStringBuilder.addAll (#903) 
* fix ByteStringBuilder.addAll

* sort out tests for different scala versions

* rework tests

* rework unmanaged source dirs
 2024-01-04 12:21:13 +01:00
Matthew de Detrich
ca64e66bc7 Fix Windows path issue with option-converters.excludes 2024-01-04 04:57:35 +01:00
Matthew de Detrich
f8c4aee8be Remove Scala 3 inline keyword from Java specific conversion methods 2024-01-01 01:55:16 +01:00
Matthew de Detrich
0f1db5301e Fix remaining missing inline statements/annotations 2023-12-30 07:13:27 +01:00
Matthew de Detrich
8cb7d256dc Remove @inline annotations and enable Scala 2 inliner 2023-12-30 03:41:12 +01:00
PJ Fanning
f6af100531
rework noisy dns log (#835) 2023-12-08 10:24:35 +01:00
PJ Fanning
860d0166a2
do not render env variables in configs (#771) 
* do not render env variables in configs

* redact username when logging configs

* Update ActorSystemSpec.scala

* add test

scalafmt

* try/finally
 2023-11-13 21:30:02 +01:00
PJ Fanning
99b4df31d4
mark function tail recursive (#780) 2023-11-07 00:15:11 +01:00
Matthew de Detrich
34815bc196 Replace Akka reference with Pekko 2023-10-09 17:53:29 +02:00
AndyChen
225701d4d6
fix: confusion deadletter while ask timeout #668 (#664) 
* fix: keep typed ask deadletter same as classic

* fix: compile on scala3

* fix: a more convincing test

* chore: remove unnecessary header

* chore: use raw apache license

* chore: grammar and sort imports

* chore: grammar fix

* chore: copyright

* fix: immutable object domain

* fix: make it simple
 2023-09-30 18:11:48 +01:00
Naoki Yamada
201992d984 Fix invalid scaladoc links which cannot be found (#353) 
* Add enough package name
* Fix invalid syntax of links to a method
 2023-09-26 19:26:45 +08:00
He-Pin
3ae618450f Make use of SAM instead. 2023-09-24 23:09:06 +08:00