This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a change to branch feature/artery-frequency-sketch
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit f6d81c299d feat: replace CountMinSketch with FastFrequencySketch in
Artery compression
add 7b6b7ed6c1 make one of the new persistence-tck journal tests optional
(#3083)
add 005e242489 fix(actor-typed): discard stale ReceiveTimeout after
cancelReceiveTimeout to avoid NPE (#3086)
add 1d75d4e852 docs: Licensing Rules 顶部增加新文件 header 强制流程提示 (#3087)
add 4d942a0ca7 use assertInstanceof (#3088)
add 0830f58d28 fix: correct various typos across pekko modules (#3084)
add baa1229037 refactor: modernize BlogPostEntity Java test code with Java
17 records (#3085)
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 640e790be5 Fix comparing release against pre-release versions (#3154)
add 72c92cc678 fix: use Timers for finishConnect retry instead of raw
scheduler callback (#3156)
add 1ba7efbe86 fix: initialize timer stage deadlines in preStart instead
of at construction (#3111)
add f3654268e7 Preserve throttler tokens on failed writes (#3097)
add 61e165c23d use Locale.ROOT for toLowerCase/toUpperCase (#3159)
add 5b2f4b468b Ignore stale classic remoting ACKs #3126 (#3158)
add c532ea043b fix: delay unfoldResourceAsync close until pending read
completes (#3157)
add 3cd574c36c feat: replace CountMinSketch with FastFrequencySketch in
Artery compression
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 (f6d81c299d)
\
N -- N -- N refs/heads/feature/artery-frequency-sketch
(3cd574c36c)
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 +
AGENTS.md | 2 +
.../typed/javadsl/SyncTestingExampleTest.java | 105 ++-------
.../testkit/typed/javadsl/BehaviorTestKitTest.java | 161 ++++---------
.../pekko/dispatch/CompletionStagesTests.java | 4 +-
.../org/apache/pekko/event/LoggingAdapterTest.java | 4 +-
.../apache/pekko/japi/pf/ReceiveBuilderTest.java | 28 +--
.../org/apache/pekko/pattern/PatternsTest.java | 6 +-
.../org/apache/pekko/io/TcpConnectionSpec.scala | 42 ++++
.../scala/org/apache/pekko/util/ReflectSpec.scala | 28 +++
.../scala/org/apache/pekko/util/VersionSpec.scala | 1 +
.../org/apache/pekko/typed/AggregatorTest.java | 74 ++----
.../org/apache/pekko/typed/BubblingSample.java | 22 +-
.../pekko/typed/InteractionPatternsTest.java | 252 +++++----------------
.../org/apache/pekko/typed/StashDocSample.java | 44 +---
.../apache/pekko/typed/StyleGuideDocExamples.java | 211 ++++-------------
.../coexistence/ClassicWatchingTypedTest.java | 11 +-
.../pekko/typed/fromclassic/TypedSample.java | 28 +--
.../actor/typed/CancelReceiveTimeoutSpec.scala | 106 +++++++++
.../pekko/actor/typed/TransformMessagesSpec.scala | 3 +-
.../{adpater => adapter}/PropsAdapterSpec.scala | 2 +-
.../typed/internal/adapter/ActorAdapter.scala | 6 +-
.../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 +-
.../apache/pekko/io/TcpOutgoingConnection.scala | 15 +-
.../scala/org/apache/pekko/io/UdpConnection.scala | 5 +-
.../scala/org/apache/pekko/io/UdpListener.scala | 5 +-
.../org/apache/pekko/io/dns/IdGenerator.scala | 6 +-
.../main/scala/org/apache/pekko/japi/JavaAPI.scala | 4 +-
.../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 +-
.../main/scala/org/apache/pekko/util/Version.scala | 2 +-
.../pekko/stream/ActorRefSourceBenchmark.scala | 107 +++++++++
.../metrics/protobuf/MessageSerializer.scala | 12 +-
.../sharding/typed/ShardingMessageExtractor.scala | 2 +-
.../typed/internal/ClusterShardingImpl.scala | 7 +-
.../jdocs/delivery/PointToPointDocExample.java | 36 +--
.../java/jdocs/delivery/ShardingDocExample.java | 123 +++-------
.../java/jdocs/delivery/WorkPullingDocExample.java | 130 +++--------
.../sharding/typed/AccountExampleDocTest.java | 7 +-
.../AccountExamplePersistenceProbeDocTest.java | 10 +-
.../cluster/sharding/typed/AccountExampleTest.java | 8 +-
.../AccountExampleWithEventHandlersInState.java | 106 +++------
.../typed/AccountExampleWithMutableState.java | 106 ++-------
.../typed/AccountExampleWithNullDurableState.java | 81 ++-----
.../typed/AccountExampleWithNullState.java | 106 +++------
.../sharding/typed/ShardingCompileOnlyTest.java | 20 +-
.../typed/ShardingReplyCompileOnlyTest.java | 18 +-
.../pekko/cluster/sharding/ClusterSharding.scala | 14 +-
.../org/apache/pekko/cluster/sharding/Shard.scala | 3 +-
.../pekko/cluster/sharding/ShardRegion.scala | 3 +-
.../ClusterShardingMessageSerializer.scala | 12 +-
.../passivation/simulator/AccessPattern.scala | 3 +-
.../passivation/simulator/SimulatorSettings.scala | 23 +-
.../pekko/cluster/client/ClusterClient.scala | 3 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 5 +-
.../DistributedPubSubMessageSerializer.scala | 12 +-
.../ddata/typed/javadsl/ReplicatorDocSample.java | 56 ++---
.../cluster/typed/SingletonCompileOnlyTest.java | 10 +-
.../scala/org/apache/pekko/cluster/Cluster.scala | 3 +-
.../org/apache/pekko/cluster/VectorClock.scala | 6 +-
.../protobuf/ClusterMessageSerializer.scala | 12 +-
.../cluster/sbr/SplitBrainResolverSettings.scala | 8 +-
.../apache/pekko/cluster/ddata/DurableStore.scala | 3 +-
.../apache/pekko/cluster/ddata/Replicator.scala | 4 +-
.../ddata/protobuf/SerializationSupport.scala | 12 +-
.../src/test/java/jdocs/cluster/StatsMessages.java | 36 +--
docs/src/test/java/jdocs/cluster/StatsService.java | 4 +-
.../java/jdocs/cluster/TransformationBackend.java | 2 +-
.../java/jdocs/cluster/TransformationMessages.java | 42 +---
docs/src/test/java/jdocs/ddata/ShoppingCart.java | 81 ++-----
docs/src/test/java/jdocs/io/JavaUdpMulticast.java | 3 +-
.../src/test/scala/docs/io/ScalaUdpMulticast.scala | 3 +-
.../persistence/PersistencePluginDocSpec.scala | 30 +--
.../pekko/remote/testkit/PerfFlamesSupport.scala | 4 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 6 +-
.../apache/pekko/persistence/CapabilityFlags.scala | 10 +
.../japi/journal/JavaJournalPerfSpec.scala | 2 +
.../pekko/persistence/journal/JournalSpec.scala | 24 +-
.../journal/inmem/InmemJournalSpec.scala | 1 +
.../journal/leveldb/LeveldbJournalJavaSpec.scala | 3 +
.../journal/leveldb/LeveldbJournalNativeSpec.scala | 2 +
...bJournalNoAtomicPersistMultipleEventsSpec.scala | 2 +
.../PersistenceTestKitJournalCompatSpec.scala | 1 +
.../persistence/typed/ReplicatedMovieExample.java | 30 +--
.../typed/ReplicatedShoppingCartExample.java | 34 +--
.../typed/internal/EventSourcedSettings.scala | 3 +-
.../state/internal/DurableStateSettings.scala | 3 +-
.../typed/BasicPersistentBehaviorTest.java | 40 +---
.../pekko/persistence/typed/BlogPostEntity.java | 116 ++--------
.../typed/BlogPostEntityDurableState.java | 82 ++-----
.../pekko/persistence/typed/MovieWatchList.java | 50 +---
.../pekko/persistence/typed/NullBlogState.java | 107 ++-------
.../pekko/persistence/typed/OptionalBlogState.java | 108 ++-------
...rsistentFsmToTypedMigrationCompileOnlyTest.java | 28 +--
.../persistence/typed/WebStoreCustomerFSM.java | 70 +-----
.../javadsl/PersistentActorCompileOnlyTest.java | 68 ++----
.../pekko/persistence/fsm/PersistentFSM.scala | 3 +-
.../serialization/SnapshotSerializer.scala | 3 +-
.../pekko/persistence/serialization/package.scala | 19 +-
.../snapshot/local/LocalSnapshotStore.scala | 6 +-
.../persistence/fsm/AbstractPersistentFSMTest.java | 78 +------
.../persistence/AtLeastOnceDeliverySpec.scala | 3 +-
project/build.properties | 2 +-
project/plugins.sbt | 4 +-
.../pekko/remote/artery/aeron/AeronErrorLog.java | 12 +-
.../remote/artery/compress/CountMinSketch.java | 4 +-
.../org/apache/pekko/remote/AckedDelivery.scala | 26 ++-
.../scala/org/apache/pekko/remote/Endpoint.scala | 34 +--
.../org/apache/pekko/remote/RemoteSettings.scala | 6 +-
.../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 +-
.../transport/ThrottlerTransportAdapter.scala | 63 ++++--
.../apache/pekko/remote/AckedDeliverySpec.scala | 11 +
.../remote/transport/ThrottlerHandleSpec.scala | 130 +++++++++++
.../serialization/jackson/JacksonSerializer.scala | 11 +-
.../serialization/jackson3/JacksonSerializer.scala | 11 +-
.../impl/fusing/GraphInterpreterSpecKit.scala | 4 +-
.../org/apache/pekko/stream/javadsl/FlowTest.java | 2 +-
.../org/apache/pekko/stream/javadsl/TcpTest.java | 9 +-
.../apache/pekko/stream/impl/TimeoutsSpec.scala | 93 ++++++++
.../apache/pekko/stream/io/FileSourceSpec.scala | 44 +++-
.../pekko/stream/scaladsl/ActorRefSourceSpec.scala | 89 +++++++-
.../pekko/stream/scaladsl/FlowIdleInjectSpec.scala | 42 ++++
.../scaladsl/FlowMapAsyncPartitionedSpec.scala | 55 +++++
.../pekko/stream/scaladsl/FlowMapAsyncSpec.scala | 47 ++++
.../scaladsl/FlowMapAsyncUnorderedSpec.scala | 53 +++++
.../pekko/stream/scaladsl/StreamRefsSpec.scala | 63 +++++-
.../scaladsl/UnfoldResourceAsyncSourceSpec.scala | 34 +++
.../typed/ActorSourceWithBackpressureExample.java | 18 +-
.../scala/org/apache/pekko/stream/Attributes.scala | 4 +-
.../apache/pekko/stream/MapAsyncPartitioned.scala | 41 +++-
.../apache/pekko/stream/impl/ActorRefSource.scala | 172 ++++++++------
.../org/apache/pekko/stream/impl/Timers.scala | 25 +-
.../stream/impl/UnfoldResourceSourceAsync.scala | 21 +-
.../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 +++--
.../scala/org/apache/pekko/testkit/TestKit.scala | 3 +-
.../org/apache/pekko/testkit/TestKitUtils.scala | 10 +-
192 files changed, 2370 insertions(+), 2819 deletions(-)
create mode 100644
actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/CancelReceiveTimeoutSpec.scala
rename
actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/{adpater
=> adapter}/PropsAdapterSpec.scala (97%)
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/stream/ActorRefSourceBenchmark.scala
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/transport/ThrottlerHandleSpec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
