This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a change to branch fix/actor-selection-queue-distribution
in repository https://gitbox.apache.org/repos/asf/pekko.git
discard 141c6b5603 test(artery): add SelectParent and SelectChildPattern
coverage for ActorSelection lane distribution
discard 37d7aedc9b fix(artery): avoid full actor selection parse for lane hash
discard e3498b70bd test(artery): keep send consistency spec unchanged
discard d70f79d1b0 fix(artery): distribute inbound actor selection messages
discard 1737629f19 test(artery): reduce ActorSelection round-trips from 1000
to 100
discard a07f152380 test(artery): add unit tests for ActorSelection lane
distribution
discard cd2b9fc108 fix(artery): distribute ActorSelection messages across
outbound lanes by target path
add 41b142dd23 perf(stream): optimize Source.actorRef with direct-push
fast path and message-only FunctionRef (#3091)
add 048c5f4a5a test: select the active FileSource actor in dispatcher
checks (#3002)
add 3424402ec1 pin sbt version entry in .scala-steward.conf (#3115)
add d75bf95017 fix: keep lazy dispatch state on VarHandle (#3116)
add b61d9d0b5e chore(deps): bump actions/checkout from 6.0.3 to 7.0.0
(#3117)
add 3eb757c061 chore(deps): bump sbt/setup-sbt from 1.2.1 to 1.4.0 (#3118)
add 85bc2aa1d3 perf(stream): extract reportStageError out of
GraphInterpreter.execute hot loop (#3119)
add e6d1533a72 Fix a few broken Scaladoc links reported by unidoc #353
(#3120)
add b09ee8b2f4 Update sbt-welcome to 0.6.0 (#3121)
add d1d2c1ef4c Update sbt, scripted-plugin to 1.12.13 (#3123)
add c0ed0aff7a Update sbt-sbom to 0.6.0 (#3122)
add f57cc814c7 fix(stream): log supervision Resume/Restart in MapAsync
operators (#3124)
add f571b64f78 refactor: use RandomGenerator interface instead of
java.util.Random (#3153)
add e1e2f2a4b1 refactor: use ProcessHandle.current().pid() instead of
RuntimeMXBean hack (#3152)
add f60702a4de refactor: replace manual stream copy loops with
transferTo/readAllBytes (#3146)
add fe5771080c refactor: use String.formatted() instead of String.format()
(#3144)
add 6628442f16 fix: remove redundant Float cast in CountMinSketch pattern
match (#3142)
add 71588172e8 refactor: use StackWalker for stack trace inspection in
TestKitUtils (#3141)
add 52755c47c0 refactor: use ByteBuffer fluent API chains with JDK 9
covariant returns (#3139)
add 3ac83fbd31 fix(stream): prevent double materialization of SourceRef
and SinkRef with clear error (#3114)
add 58a9bf0077 perf: use Arrays.copyOf/copyOfRange instead of manual new
Array + arraycopy (#3150)
add 6ad445271c refactor: use StandardCharsets.UTF_8 with
URLEncoder/URLDecoder (#3147)
add 0bbdbf78ec refactor: simplify Collections.unmodifiableSet(emptySet())
to Set.of() (#3138)
add acd4926ac1 refactor: use CompletableFuture.orTimeout in
FutureTimeoutSupport (#3137)
add b7ba750296 refactor: replace sun.reflect.Reflection with StackWalker
in Reflect (#3151)
add 22d44aa429 refactor: use Files.readString() in PemManagersProvider
(#3143)
add 88320c6978 refactor: use HexFormat for hex encoding instead of manual
formatting (#3145)
add 713ad01e16 perf: add Thread.onSpinWait() to CAS spin loops (#3149)
add d957aa9887 docs: update Scaladoc examples from Arrays.asList to
List.of (#3140)
add cd980eac30 use decodeString(StandardCharsets.UTF_8) (#3155)
add 619392945d fix(artery): distribute ActorSelection messages across
outbound lanes by target path
add a41c216b39 test(artery): add unit tests for ActorSelection lane
distribution
add 34482bbff7 test(artery): reduce ActorSelection round-trips from 1000
to 100
add 5e5d1d8bcb fix(artery): distribute inbound actor selection messages
add ca3f3c2f97 test(artery): keep send consistency spec unchanged
add 43f7d970e1 fix(artery): avoid full actor selection parse for lane hash
add 2739672b59 test(artery): add SelectParent and SelectChildPattern
coverage for ActorSelection lane distribution
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 (141c6b5603)
\
N -- N -- N refs/heads/fix/actor-selection-queue-distribution
(2739672b59)
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/binary-compatibility-checks.yml | 4 +-
.github/workflows/build-test-prValidation.yml | 16 +-
.github/workflows/dependency-graph.yml | 4 +-
.github/workflows/format.yml | 2 +-
.github/workflows/generate-doc-check.yml | 4 +-
.github/workflows/headers.yml | 4 +-
.github/workflows/link-validator.yml | 4 +-
.github/workflows/nightly-1.0-builds.yml | 12 +-
.github/workflows/nightly-1.1-builds.yml | 12 +-
.github/workflows/nightly-1.2-builds.yml | 12 +-
.github/workflows/nightly-1.3-builds.yml | 12 +-
.github/workflows/nightly-1.4-builds.yml | 12 +-
.github/workflows/nightly-1.5-builds.yml | 12 +-
.github/workflows/nightly-1.6-builds.yml | 12 +-
.github/workflows/nightly-1.7-builds.yml | 12 +-
.github/workflows/nightly-builds-aeron.yml | 4 +-
.github/workflows/nightly-builds.yml | 12 +-
.github/workflows/publish-1.0-docs.yml | 4 +-
.github/workflows/publish-1.0-nightly.yml | 4 +-
.github/workflows/publish-1.1-docs.yml | 4 +-
.github/workflows/publish-1.1-nightly.yml | 4 +-
.github/workflows/publish-1.2-docs.yml | 4 +-
.github/workflows/publish-1.2-nightly.yml | 4 +-
.github/workflows/publish-1.3-docs.yml | 4 +-
.github/workflows/publish-1.3-nightly.yml | 4 +-
.github/workflows/publish-1.4-docs.yml | 4 +-
.github/workflows/publish-1.4-nightly.yml | 4 +-
.github/workflows/publish-1.5-docs.yml | 4 +-
.github/workflows/publish-1.5-nightly.yml | 4 +-
.github/workflows/publish-1.6-docs.yml | 4 +-
.github/workflows/publish-1.6-nightly.yml | 4 +-
.github/workflows/publish-1.7-nightly.yml | 4 +-
.github/workflows/publish-2.0-docs.yml | 4 +-
.github/workflows/publish-nightly.yml | 4 +-
.github/workflows/stage-release-candidate.yml | 8 +-
.github/workflows/timing-tests.yml | 4 +-
.scala-steward.conf | 2 +
.../scala/org/apache/pekko/util/ReflectSpec.scala | 28 ++++
.../io/UnsynchronizedByteArrayInputStream.java | 2 +-
.../apache/pekko/dispatch/AbstractDispatcher.scala | 30 ++--
.../scala/org/apache/pekko/dispatch/Mailbox.scala | 80 ++++++----
actor/src/main/scala/org/apache/pekko/io/Tcp.scala | 4 +-
.../scala/org/apache/pekko/io/TcpConnection.scala | 4 +-
.../scala/org/apache/pekko/io/UdpConnection.scala | 5 +-
.../scala/org/apache/pekko/io/UdpListener.scala | 5 +-
.../org/apache/pekko/io/dns/IdGenerator.scala | 6 +-
.../org/apache/pekko/pattern/AskSupport.scala | 7 +-
.../pekko/pattern/FutureTimeoutSupport.scala | 28 ++--
.../scala/org/apache/pekko/util/ByteString.scala | 9 +-
.../main/scala/org/apache/pekko/util/Reflect.scala | 11 +-
.../pekko/stream/ActorRefSourceBenchmark.scala | 107 +++++++++++++
.../metrics/protobuf/MessageSerializer.scala | 12 +-
.../sharding/typed/ShardingMessageExtractor.scala | 2 +-
.../typed/internal/ClusterShardingImpl.scala | 7 +-
.../pekko/cluster/sharding/ClusterSharding.scala | 14 +-
.../org/apache/pekko/cluster/sharding/Shard.scala | 3 +-
.../pekko/cluster/sharding/ShardRegion.scala | 3 +-
.../ClusterShardingMessageSerializer.scala | 12 +-
.../pekko/cluster/client/ClusterClient.scala | 3 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 5 +-
.../DistributedPubSubMessageSerializer.scala | 12 +-
.../org/apache/pekko/cluster/VectorClock.scala | 6 +-
.../protobuf/ClusterMessageSerializer.scala | 12 +-
.../ddata/protobuf/SerializationSupport.scala | 12 +-
docs/src/test/java/jdocs/io/JavaUdpMulticast.java | 3 +-
.../src/test/scala/docs/io/ScalaUdpMulticast.scala | 3 +-
.../pekko/remote/testkit/PerfFlamesSupport.scala | 4 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 6 +-
.../serialization/SnapshotSerializer.scala | 3 +-
.../pekko/persistence/serialization/package.scala | 19 +--
.../snapshot/local/LocalSnapshotStore.scala | 6 +-
project/build.properties | 2 +-
project/plugins.sbt | 4 +-
.../pekko/remote/artery/aeron/AeronErrorLog.java | 12 +-
.../remote/artery/compress/CountMinSketch.java | 2 +-
.../scala/org/apache/pekko/remote/Remoting.scala | 4 +-
.../pekko/remote/artery/ImmutableLongMap.scala | 3 +-
.../pekko/remote/artery/tcp/TcpFraming.scala | 2 +-
.../artery/tcp/ssl/PemManagersProvider.scala | 3 +-
.../serialization/jackson/JacksonSerializer.scala | 11 +-
.../serialization/jackson3/JacksonSerializer.scala | 11 +-
.../apache/pekko/stream/io/FileSourceSpec.scala | 44 ++++--
.../pekko/stream/scaladsl/ActorRefSourceSpec.scala | 89 ++++++++++-
.../scaladsl/FlowMapAsyncPartitionedSpec.scala | 55 +++++++
.../pekko/stream/scaladsl/FlowMapAsyncSpec.scala | 47 ++++++
.../scaladsl/FlowMapAsyncUnorderedSpec.scala | 53 +++++++
.../pekko/stream/scaladsl/StreamRefsSpec.scala | 63 +++++++-
.../scala/org/apache/pekko/stream/Attributes.scala | 4 +-
.../apache/pekko/stream/MapAsyncPartitioned.scala | 41 ++++-
.../apache/pekko/stream/impl/ActorRefSource.scala | 172 +++++++++++++--------
.../stream/impl/fusing/GraphInterpreter.scala | 76 +++++----
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 72 ++++++++-
.../pekko/stream/impl/fusing/StreamOfStreams.scala | 2 +-
.../pekko/stream/impl/io/TlsEngineHelpers.scala | 3 +-
.../pekko/stream/impl/streamref/SinkRefImpl.scala | 18 ++-
.../stream/impl/streamref/SourceRefImpl.scala | 18 ++-
.../org/apache/pekko/stream/javadsl/Flow.scala | 8 +-
.../org/apache/pekko/stream/javadsl/Graph.scala | 2 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 8 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 4 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 6 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 55 ++++---
.../org/apache/pekko/testkit/TestKitUtils.scala | 10 +-
103 files changed, 1092 insertions(+), 517 deletions(-)
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/ActorRefSourceBenchmark.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
