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

61 commits

Author SHA1 Message Date
He-Pin(kerr)
2469f729f7
feat: Add support for switching scheduler (#1724) 2025-01-23 03:55:15 +08:00
He-Pin(kerr)
e5d766bbf1
chore: Proper test virtual thread dispatcher and update doc. (#1728) 2025-01-19 11:30:49 +08: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)
8f6f97aa2d
chore: Add identity function. (#1671) 2025-01-07 01:00:38 +08:00
He-Pin(kerr)
db94dedf23
feat: Add SchedulerTask which will be notified once cancelled. (#1593) 2024-12-29 17:08:01 +08:00
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
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)
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)
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
Philippus Baalman
7ce4c0c5ff
Use more realistic version numbers (#1323) 2024-05-13 10:19:10 +02: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
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
Nicolas Vollmar
fa5c83f36f Add handling for tcp register timeout leaving connection dead 2024-03-09 10:51:12 +01:00
AndyChen(Jingzhang)
2fdf7c9e9b
fix: proper path when promise actor terminated quickly (#1156) 2024-02-28 09:15:01 +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
He-Pin(kerr)
5e00e6b8b7
chore: Remove more reflectiveCall. (#1084) 2024-01-30 23:51:30 +08:00
He-Pin(kerr)
ae210b17d2
chore: Update java-formatter ignore lists (#1030) 
* chore: Update java-formatter ignore lists

* chore: Reformat JavaFutureTests.java
 2024-01-23 22:20:01 +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
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
PJ Fanning
2ae6c8d00c
tidy up imports in new docker code (#930) 
* tidy up imports in new docker code

* try to fix issues

* Update Dependencies.scala
 2024-01-12 22:06:01 +01:00
Samuele Resca
b7be586e77
Replacing deprecated docker-client with docker-java (#922) 
* Replacing deprecated docker-client with docker-java.

* Addressing feedback.

* Awaiting for image pull.

---------

Co-authored-by: Samuele Resca <sr7@ad.datcon.co.uk>
 2024-01-12 16:12:23 +00: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
f8c4aee8be Remove Scala 3 inline keyword from Java specific conversion methods 2024-01-01 01:55:16 +01:00
Matthew de Detrich
7ed85713e2 Fix header for Scala212CompatTest 2024-01-01 01:29:07 +01:00
PJ Fanning
8fefca1c81
add Akka path parsing tests (#819) 2023-11-28 10:51:24 +01:00
PJ Fanning
04451a6d19
remove mpl licensed file (#810) 2023-11-22 11:51:39 +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
15f02d696f
Update LineNumberSpec.scala (#683) 
update test

Update LineNumberSpec.scala
 2023-09-25 20:10:27 +01:00
He-Pin
e94e7b971b =test Skip ForkJoinPoolStarvationSpec on JDK 21. 2023-09-20 23:57:26 +08:00
Dongxu Wang
3775a18c2e
update ActorSystemSpec to use property based testing for its name (#575) 2023-08-17 09:17:57 +01:00
Dongxu Wang
80e4e800c8
improve a/an after get (#566) 2023-08-12 15:59:30 +01:00
Matthew de Detrich
bd9ff4da5b Fix new sources so that they use the Apache standard header 2023-07-12 16:04:47 +02:00
PJ Fanning
b0fdac259b
adjust ASF header (#450) 2023-06-22 14:19:26 +01:00
PJ Fanning
ead8c7e889
support negative short ids in async DNS resolver code (#401) 2023-06-15 20:32:35 +01:00
Iain Hull
c56edca78f
CVE-2023-31442 Address DNS poisoning vulnerability (#385) 
* CVE-2023-31442 Address DNS poisoning vulnerability (and DNS concurrency bug)

* Remove sequential dns id generator

* fix scalafmt

* Fix bug in isSameQuestion
And ensure that DnsClient only removes inflight messages when the
questions match

* fix up exception message to remove reference to 'sequence' generator

* Add tests to failed commands and drop requests

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
 2023-06-14 19:38:20 +01:00
Matthew de Detrich
17a986792c Add Iterable.once to ccompat 2023-06-09 16:59:03 +02:00
PJ Fanning
1612950702
fix up refs to Akka in source code (#374) 
* fix up refs to Akka in source code

* Update distributed-data.md
 2023-06-07 14:51:57 +01:00
Matthew de Detrich
480f516398
Unwrap single string interpolation syntax 2023-05-24 16:28:02 +02:00
Matthew de Detrich
898c69701b Add OptionConverters.toScala methods for java Optional primitives 2023-05-09 14:34:50 +02:00
Matthew de Detrich
0df71060ea Add OptionConverters.toJava and OptionConverters.toScala 2023-05-09 07:20:18 +02:00
Matthew de Detrich
1248fcf7cb Add java Optional primitive to Scala converters 2023-05-08 18:32:13 +02:00
Matthew de Detrich
0af7d3c5c1 Add toJavaPrimitive to OptionConverters 2023-05-08 19:53:25 +08:00
Matthew de Detrich
07df607192 Add FunctionConverters, FutureConverters and ObjectConverters 2023-05-08 12:03:37 +02:00
PJ Fanning
321c572114
upgrade to jackson 2.14.2 (#273) 
* upgrade to jackson 2.14.2

* scala 3.2.2 needed

* another deprecation issue

* ignore deprecation warnings in Scala 3 build

* Update PekkoDisciplinePlugin.scala

* scala 3.2 compile issues

* more scala upgrade issues

* import order

* Update actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/InteractionPatternsSpec.scala

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

---------

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
 2023-04-05 15:44:58 +02:00
Matthew de Detrich
c4e33c3972 Add Scala 2.12 equivalent Iterator apply method for ByteString 2023-03-21 14:13:37 +01:00
PJ Fanning
785369030d change default port number to 7355 2023-03-09 05:00:01 +08:00
PJ Fanning
0a8b8a572f
set license headers on conf files (#227) 2023-03-03 13:24:19 +01:00