This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch issue-2860-tls-graphstage-path
in repository https://gitbox.apache.org/repos/asf/pekko.git
discard cbe3cc3e91 feat(stream): add clean-room GraphStage TLS implementation
(TlsGraphStage)
add 29b723f043 fix: eliminate it.isEmpty and double-traversal risk in
CompactByteString.apply(IterableOnce[Byte]) (#2875)
add f5c37ba255 feat(stream): replace fanout publisher runtime with
GraphStage bridge (#2874)
add bdb0e87580 chore: keep nightly virtualize change minimal (#2882)
add a36d126509 Scale MapAsyncPartitionedSpec patience with test timefactor
(#2884)
add 166e8df8f7 test: scale stream tck shutdown timeout (#2885)
add e72dd27236 fix: stabilise JDK 21+ / JDK 25 nightly test runs (#2889)
add c57fdcd983 Update SnapshotSerializerSpec.scala (#2891)
add 980d2bd844 fix: auto-tune ForkJoinPool minimum-runnable on JDK 21+
(#2890)
add 2a0faf2cda upgrade license headers (#2893)
add d2bc2c84d8 Update commons-io to 2.22.0 (#2892)
add bc78cd16d5 ByteStringBuilder.putInt/putLong: eliminate closure
allocation via SWARUtil VarHandle writes (#2879)
add 88f338134c test(dispatch): pin minimum-runnable=-1 in
ForkJoinExecutorConfiguratorSpec auto fixtures (#2894)
add b24d1045e1 fix: stabilize async DNS dispatchers under low
minimum-runnable (#2895)
add b0f9779b47 test: fix flaky 'stop an underutilizationStreak when fully
utilized' on JDK 25 (#2898)
add a257a9fca1 Fix copyToBuffer: guard negative return in
ByteString1C.writeToBuffer (#2897)
add b96d35d79d fix: MapAsyncPartitioned drainQueue concurrent-modification
race (#2899)
add b07587b205 feat: Add TlsGraphStage direct-push engine for internal
GraphStage path
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (cbe3cc3e91)
\
N -- N -- N refs/heads/issue-2860-tls-graphstage-path
(b07587b205)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/nightly-builds.yml | 8 +-
.../typed/javadsl/LogCapturingExtension.scala | 4 +
.../javadsl/JUnit5IntegrationExampleTest.java | 59 --
.../JUnitJupiterIntegrationExampleTest.java | 4 +
.../javadsl/ActorTestKitJUnitJupiterTest.java | 4 +
.../actor/testkit/typed/scaladsl/GreeterMain.scala | 4 +
.../ForkJoinExecutorConfiguratorSpec.scala | 195 ++++
.../pekko/routing/MetricsBasedResizerSpec.scala | 4 +
.../org/apache/pekko/util/ByteStringSpec.scala | 477 +++++++++
.../scala/org/apache/pekko/util/SWARUtilSpec.scala | 222 ++++
actor/src/main/resources/reference.conf | 21 +-
.../dispatch/ForkJoinExecutorConfigurator.scala | 39 +-
.../scala/org/apache/pekko/util/ByteString.scala | 72 +-
.../scala/org/apache/pekko/util/SWARUtil.scala | 124 +++
bench-jmh/src/main/resources/keystore | Bin 2397 -> 0 bytes
bench-jmh/src/main/resources/truststore | Bin 857 -> 0 bytes
.../org/apache/pekko/stream/TlsBenchmark.scala | 256 -----
.../pekko/util/ByteString_putInt_Benchmark.scala | 101 ++
.../delivery/ReliableDeliveryShardingSpec.scala | 15 +-
discovery/src/main/resources/reference.conf | 5 +-
.../ddata/ReplicatorWildcardSubscriptionSpec.scala | 4 +
docs/src/main/paradox/dispatchers.md | 8 +
docs/src/main/paradox/typed/dispatchers.md | 8 +
.../scaladsl/EventSourcedStashOverflowSpec.scala | 2 +-
.../serialization/SnapshotSerializer.scala | 38 +-
.../persistence/journal/SteppingInmemJournal.scala | 2 +-
.../serialization/SnapshotSerializerSpec.scala | 44 +-
project/Dependencies.scala | 2 +-
.../pekko/stream/tck/ActorSystemLifecycle.scala | 2 +-
.../org/apache/pekko/stream/tck/Timeouts.scala | 4 +-
stream-tests/src/test/resources/application.conf | 10 +
.../pekko/stream/impl/FanoutProcessorSpec.scala | 144 ---
.../stream/impl/FanoutPublisherBehaviorSpec.scala | 229 ++++
.../stream/io/TlsGraphStageIsolatedSpec.scala | 256 +++++
.../apache/pekko/stream/io/TlsGraphStageSpec.scala | 349 ------
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 5 +-
.../scaladsl/FlowMapAsyncPartitionedSpec.scala | 9 +
.../pekko/stream/MapAsyncPartitionedSpec.scala | 17 +-
...p.excludes => remove-fanout-processor.excludes} | 7 +-
stream/src/main/resources/reference.conf | 12 -
.../apache/pekko/stream/MapAsyncPartitioned.scala | 12 +-
.../apache/pekko/stream/impl/FanoutProcessor.scala | 188 ----
.../stream/impl/FanoutPublisherBridgeStage.scala | 240 +++++
.../scala/org/apache/pekko/stream/impl/Sinks.scala | 12 +-
.../pekko/stream/impl/io/TlsGraphStage.scala | 1119 ++++++--------------
.../org/apache/pekko/stream/scaladsl/TLS.scala | 12 +-
46 files changed, 2401 insertions(+), 1948 deletions(-)
delete mode 100644
actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/JUnit5IntegrationExampleTest.java
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfiguratorSpec.scala
delete mode 100644 bench-jmh/src/main/resources/keystore
delete mode 100644 bench-jmh/src/main/resources/truststore
delete mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/TlsBenchmark.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_putInt_Benchmark.scala
create mode 100644 stream-tests/src/test/resources/application.conf
delete mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/impl/FanoutProcessorSpec.scala
create mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/impl/FanoutPublisherBehaviorSpec.scala
create mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/io/TlsGraphStageIsolatedSpec.scala
delete mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/io/TlsGraphStageSpec.scala
copy
stream/src/main/mima-filters/2.0.x.backwards.excludes/{remove-internal-unzip.excludes
=> remove-fanout-processor.excludes} (81%)
delete mode 100644
stream/src/main/scala/org/apache/pekko/stream/impl/FanoutProcessor.scala
create mode 100644
stream/src/main/scala/org/apache/pekko/stream/impl/FanoutPublisherBridgeStage.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
