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

56 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
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
PJ Fanning
7e653454a9
use pekko: in urls and fix other branding issues (#184) 
* use pekko: in urls and fix other branding issues

* update comments

* fix artery test

* test changes

* scalafmt

* try to fix some tests and fixing more akka refs

* more akka refs

* more changes

* more akka refs

* Update LeaseMajoritySpec.scala

* Update docs/src/main/paradox/testing.md

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

* Update docs/src/main/paradox/project/migration-guides.md

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

* Update actor/src/main/scala/org/apache/pekko/serialization/Serialization.scala

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

* Update scripts/release-train-issue-template.md

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

* revert link-validation change

* Update JacksonModule.scala

* revert key name changes to fix 2 tests

* fix one test

* more test trouble

* more test issues

* fix hashing test

* Update RouterTest.java

* update code comment

---------

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
 2023-02-22 12:48:15 +01:00
PJ Fanning
2df8d99786
change deprecated versions to use Akka in name (#209) 
* change deprecated versions to use Akka in name

* scalafmt

* update markdown
 2023-02-21 11:13:05 +01:00
PJ Fanning
c32fcf1f0a
update more akka refs to use pekko name (#200) 2023-02-17 10:49:40 +01:00
PJ Fanning
3ee028f915
update some random akka refs (#196) 2023-02-16 10:39:18 +01:00
PJ Fanning
651d099700
remove test file with non Apache license (#171) 2023-02-13 10:27:15 +01:00