A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.
This report presents the forensic synthetic code analysis of akka/akka-core, a Scala project with 13,281 GitHub stars. SynthScan v2.0 examined 698,816 lines of code across 3763 source files, recording 462 pattern matches distributed across 10 syntactic categories. The overall adjusted score of 3.5 places this repository in the Likely human-written band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 462 distinct pattern matches across 10 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …ka/actor/testkit/typed/scaladsl/ActorTestKitSpec.scala | 113 | scalaTestWithActorTestKit2.testKit.system.settings.config.hasPath("test.from-application") should ===(false) | CODE |
| CRITICAL | …ala/akka/actor/testkit/typed/scaladsl/ManualTime.scala | 41 | "make sure to include akka.actor.testkit.typed.scaladsl.ManualTime.config() when setting up the test") | CODE |
| CRITICAL | …scala/akka/actor/testkit/typed/javadsl/TestProbe.scala | 43 | def fail(error: String): FishingOutcome = akka.actor.testkit.typed.FishingOutcome.Fail(error) | CODE |
| CRITICAL | …cala/akka/actor/testkit/typed/javadsl/ManualTime.scala | 42 | "make sure to include akka.actor.testkit.typed.scaladsl.ManualTime.config() when setting up the test") | CODE |
| CRITICAL | …/cluster/sharding/typed/ShardingMessageExtractor.scala | 80 | akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor.shardId(entityId, numberOfShards) | CODE |
| CRITICAL | …/cluster/sharding/typed/ShardingMessageExtractor.scala | 95 | akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor.shardId(entityId, numberOfShards) | CODE |
| CRITICAL | …a/cluster/sharding/typed/javadsl/ClusterSharding.scala | 360 | new akka.cluster.sharding.typed.scaladsl.Entity( | CODE |
| CRITICAL | …ster/sharding/typed/javadsl/ShardedDaemonProcess.scala | 23 | akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess(system).asJava | CODE |
| CRITICAL | …a/akka/actor/typed/scaladsl/adapter/PropsAdapter.scala | 23 | akka.actor.typed.internal.adapter.PropsAdapter( | CODE |
| CRITICAL | …/src/main/scala/akka/actor/typed/javadsl/Adapter.scala | 147 | akka.actor.typed.internal.adapter.PropsAdapter( | CODE |
| CRITICAL | …akka/cluster/ddata/typed/javadsl/DistributedData.scala | 51 | val distributedData = akka.cluster.ddata.typed.scaladsl.DistributedData(context.getSystem) | CODE |
| CRITICAL | …akka/cluster/ddata/typed/javadsl/DistributedData.scala | 94 | akka.cluster.ddata.typed.scaladsl.DistributedData(system).replicator.narrow[Replicator.Command] | CODE |
| CRITICAL | …akka/cluster/ddata/typed/javadsl/DistributedData.scala | 97 | akka.cluster.ddata.typed.scaladsl.DistributedData(system).selfUniqueAddress | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 912 | // Construct using akka.remote.testconductor.TestConductorProtocol.Wrapper.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2162 | // Construct using akka.remote.testconductor.TestConductorProtocol.Hello.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3003 | // Construct using akka.remote.testconductor.TestConductorProtocol.EnterBarrier.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3775 | // Construct using akka.remote.testconductor.TestConductorProtocol.AddressRequest.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4741 | // Construct using akka.remote.testconductor.TestConductorProtocol.Address.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 5749 | // Construct using akka.remote.testconductor.TestConductorProtocol.InjectFailure.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 506 | return hello_ == null ? akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 513 | return hello_ == null ? akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 532 | return barrier_ == null ? akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : barr | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 539 | return barrier_ == null ? akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : barr | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 558 | return failure_ == null ? akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : fai | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 565 | return failure_ == null ? akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : fai | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 633 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : addr_ | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 640 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : addr_ | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 967 | return akka.remote.testconductor.TestConductorProtocol.Wrapper.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1064 | if (other == akka.remote.testconductor.TestConductorProtocol.Wrapper.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1194 | return hello_ == null ? akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1236 | hello_ != akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1279 | akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1315 | return barrier_ == null ? akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1357 | barrier_ != akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1400 | akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : barrier_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1436 | return failure_ == null ? akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1478 | failure_ != akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1521 | akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : failure_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1637 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : a | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1679 | addr_ != akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1722 | akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1943 | return address_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : address_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1950 | return address_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : address_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2199 | return akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2278 | if (other == akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2447 | return address_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addre | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2489 | address_ != akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2532 | akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : address_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2759 | akka.remote.testconductor.TestConductorProtocol.BarrierOp result = akka.remote.testconductor.TestConductorProtocol | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3031 | return akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3112 | if (other == akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3164 | akka.remote.testconductor.TestConductorProtocol.BarrierOp.forNumber(tmpRaw); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3289 | akka.remote.testconductor.TestConductorProtocol.BarrierOp result = akka.remote.testconductor.TestConductorProtoc | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3558 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3565 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3812 | return akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3891 | if (other == akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4059 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4101 | addr_ != akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4144 | akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| 141 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …-cluster/src/test/scala/akka/cluster/ClusterSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …ala/akka/cluster/ClusterDomainEventPublisherSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …akka/cluster/routing/ClusterRouterSupervisorSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …st/scala/akka/cluster/ddata/LocalConcurrencySpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …t/scala/akka/cluster/metrics/WeightedRouteesSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …lti-jvm/scala/akka/cluster/ClusterDeathWatchSpec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/RestartNode3Spec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …m/scala/akka/remote/RemoteQuarantinePiercingSpec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …kka/remote/artery/RemoteRestartedQuarantinedSpec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …cala/akka/cluster/MultiDcHeartbeatTakingOverSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …src/multi-jvm/scala/akka/cluster/MultiDcJoinSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/MultiDcJoin2Spec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …i-jvm/scala/akka/cluster/MultiDcSunnyWeatherSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …cala/akka/cluster/MultiDcHeartbeatTakingOverSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …src/multi-jvm/scala/akka/cluster/MultiDcJoinSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/MultiDcJoin2Spec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …i-jvm/scala/akka/cluster/MultiDcSunnyWeatherSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …lti-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …/multi-jvm/scala/akka/cluster/MultiDcClusterSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …multi-jvm/scala/akka/cluster/MultiDcLastNodeSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …luster/sharding/typed/MultiDcClusterShardingSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …a/akka/cluster/typed/MultiDcClusterSingletonSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/typed/PubSubSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …lti-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …/multi-jvm/scala/akka/cluster/MultiDcClusterSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …multi-jvm/scala/akka/cluster/MultiDcLastNodeSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …luster/sharding/typed/MultiDcClusterShardingSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …a/akka/cluster/typed/MultiDcClusterSingletonSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/typed/PubSubSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …la/akka/cluster/sbr/IndirectlyConnected5NodeSpec.scala | 0 | akka { loglevel = info cluster { downing-provider-class = "akka.cluster.sbr.splitbrainresolverprovider" split-brain-reso | STRING |
| HIGH | …la/akka/cluster/sbr/IndirectlyConnected3NodeSpec.scala | 0 | akka { loglevel = info cluster { downing-provider-class = "akka.cluster.sbr.splitbrainresolverprovider" split-brain-reso | STRING |
| HIGH | …ster/sbr/DownAllWhenIndirectlyConnected3NodeSpec.scala | 0 | akka { loglevel = info cluster { downing-provider-class = "akka.cluster.sbr.splitbrainresolverprovider" split-brain-reso | STRING |
| HIGH | …/test/scala/akka/stream/io/TlsStageEdgeCasesSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …la/akka/stream/scaladsl/CancellationStrategySpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …test/scala/akka/io/dns/internal/TcpDnsClientSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …rc/test/scala/akka/io/dns/internal/DnsClientSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …/scala/akka/io/dns/internal/AsyncDnsResolverSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …cala/akka/pattern/BackoffOnRestartSupervisorSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …-actor-tests/src/test/scala/akka/pattern/AskSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …/test/scala/akka/stream/scaladsl/FlowRecoverSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …rc/test/scala/akka/stream/scaladsl/RetryFlowSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …test/scala/akka/stream/scaladsl/FlowMapErrorSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/LazyFlowSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/LazySinkSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …c/test/scala/akka/stream/scaladsl/FlowBufferSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …/scala/akka/stream/scaladsl/FlowInitialDelaySpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …c/test/scala/akka/stream/scaladsl/FlowFilterSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/FlowScanSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/HeadSinkSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …/akka/stream/scaladsl/CoupledTerminationFlowSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …st/scala/akka/stream/scaladsl/GraphUnzipWithSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …test/scala/akka/stream/scaladsl/GraphPartialSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …rc/test/scala/akka/stream/scaladsl/FlowLimitSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …scala/akka/stream/scaladsl/FlowLimitWeightedSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …est/scala/akka/stream/scaladsl/FlowAlsoToAllSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …st/scala/akka/stream/scaladsl/FlowOnCompleteSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …st/scala/akka/stream/scaladsl/CollectionSinkSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …/test/scala/akka/stream/scaladsl/FlowGroupedSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …est/scala/akka/stream/scaladsl/FlowMapConcatSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| 82 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …kka/actor/testkit/typed/internal/ActorSystemStub.scala | 141 | // this is backward compatible with the old behaviour, hence it uses the loader used to load the test-kit | COMMENT |
| LOW | …ts/src/test/java/akka/stream/javadsl/GraphDslTest.java | 221 | } | COMMENT |
| LOW | …akka/remote/artery/RollingEventLogSimulationSpec.scala | 161 | COMMENT | |
| LOW | …/scala/akka/remote/artery/tcp/ArteryTcpTransport.scala | 281 | serverBinding = Some(binding) | COMMENT |
| LOW | …test/scala/akka/cluster/sharding/SupervisionSpec.scala | 141 | ClusterShardingSettings(system), | COMMENT |
| LOW | akka-pki/src/main/scala/akka/pki/pem/PEMDecoder.scala | 21 | // Luckily, Java Pattern's \s matches the RFCs W ABNF expression perfectly | COMMENT |
| LOW | …r-tests/src/test/scala/akka/util/TokenBucketSpec.scala | 121 | bucket.init() | COMMENT |
| LOW | scripts/release-prep.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/multi-node-log-replace.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | kubernetes/create-cluster-gke.sh | 1 | #!/bin/bash -e | COMMENT |
| LOW | …ctor/src/main/scala/akka/routing/SmallestMailbox.scala | 41 | else selectNext(routees) | COMMENT |
| LOW | akka-docs/src/test/java/jdocs/stream/HubDocTest.java | 101 | Source<String, NotUsed> source = sinkAndSource.second(); | COMMENT |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 21 | // #or-else | COMMENT |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 41 | // #concat | COMMENT |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 501 | void takeExample() { | COMMENT |
| LOW | …/java/jdocs/stream/operators/sourceorflow/Sliding.java | 21 | // [1, 2] | COMMENT |
| LOW | …ava/jdocs/stream/operators/sourceorflow/MapConcat.java | 21 | void example() { | COMMENT |
| LOW | …st/java/jdocs/stream/operators/sourceorflow/Split.java | 101 | // 6 | COMMENT |
| LOW | …a/jdocs/stream/operators/sourceorflow/MergeLatest.java | 21 | prices | COMMENT |
| LOW | …c/test/java/jdocs/stream/operators/source/Restart.java | 41 | // logs | COMMENT |
| LOW | …c/test/java/jdocs/stream/operators/source/Restart.java | 61 | // --> 2 second gap | COMMENT |
| LOW | …s/src/test/java/jdocs/stream/operators/source/Zip.java | 81 | // this will print | COMMENT |
| LOW | …c/test/java/jdocs/stream/operators/source/Combine.java | 61 | // 10 | COMMENT |
| LOW | …/src/test/java/jdocs/stream/operators/source/From.java | 21 | // 1 | COMMENT |
| LOW | …test/java/jdocs/stream/operators/flow/StatefulMap.java | 101 | // 3 | COMMENT |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 481 | final ActorRef persistentActor = system.actorOf(Props.create(MyPersistentActor.class)); | COMMENT |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 581 | COMMENT | |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 641 | COMMENT | |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 701 | // #safe-shutdown | COMMENT |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 721 | // SAFE: | COMMENT |
| LOW | akka-docs/src/test/java/jdocs/actor/ActorDocTest.java | 301 | // #preStart | COMMENT |
| LOW | …st/scala/docs/serialization/SerializationDocSpec.scala | 21 | //#marker-interface | COMMENT |
| LOW | …t/scala/docs/stream/operators/sourceorflow/Split.scala | 41 | .splitWhen(_._2) // split when time bucket changes | COMMENT |
| LOW | …t/scala/docs/stream/operators/sourceorflow/Split.scala | 81 | .map(_.head._1) | COMMENT |
| LOW | …a/docs/stream/operators/sourceorflow/MergeLatest.scala | 21 | .runForeach(println) | COMMENT |
| LOW | …scala/docs/stream/operators/sourceorflow/Sliding.scala | 41 | // 4.4 = average of 3, 10, 2, 3, 4 | COMMENT |
| LOW | …ala/docs/stream/operators/sourceorflow/MapConcat.scala | 21 | // 1 | COMMENT |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 41 | longWords.runForeach(println) | COMMENT |
| LOW | …src/test/scala/docs/stream/operators/source/From.scala | 21 | // 2 | COMMENT |
| LOW | …/test/scala/docs/stream/operators/source/Restart.scala | 41 | // --> 1 second gap | COMMENT |
| LOW | …/src/test/scala/docs/stream/operators/source/Zip.scala | 41 | // 5 | COMMENT |
| LOW | …/src/test/scala/docs/stream/operators/source/Zip.scala | 61 | // #zipAll-simple | COMMENT |
| LOW | …/test/scala/docs/stream/operators/source/Combine.scala | 21 | val source3 = Source(12 to 14) | COMMENT |
| LOW | …/test/scala/docs/stream/operators/source/Combine.scala | 41 | val source2 = Source(8 to 10) | COMMENT |
| LOW | …est/scala/docs/stream/operators/flow/StatefulMap.scala | 81 | //prints | COMMENT |
| LOW | …ala/docs/stream/cookbook/RecipeCollectingMetrics.scala | 21 | // //#periodic-metrics-collection | COMMENT |
| LOW | …ala/docs/stream/cookbook/RecipeCollectingMetrics.scala | 41 | // manualTick.sendNext(()) | COMMENT |
| LOW | …ala/docs/stream/cookbook/RecipeCollectingMetrics.scala | 61 | // **Situation:** Given performance counters expressed as a stream of updates we want to gather a periodic re | COMMENT |
| LOW | …c/test/scala/docs/persistence/PersistenceDocSpec.scala | 341 | } | COMMENT |
| LOW | …c/test/scala/docs/persistence/PersistenceDocSpec.scala | 441 | persistentActor ! PoisonPill | COMMENT |
| LOW | …c/test/scala/docs/persistence/PersistenceDocSpec.scala | 461 | // b | COMMENT |
| LOW | …src/test/scala/typed/tutorial_5/DeviceGroupQuery.scala | 121 | } | COMMENT |
| LOW | akka-docs/src/main/paradox/general/configuration.md | 101 | # Logger config for Akka internals and classic actors, the new API relies | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 35 | """Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolo | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 35 | """Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolo | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 37 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 37 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 39 | et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 40 | sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 40 | sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 42 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 42 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 46 | dolore te feugait nulla facilisi. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 46 | dolore te feugait nulla facilisi. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 55 | assum. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt ut laoreet | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 55 | assum. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt ut laoreet | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 63 | ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 63 | ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 65 | Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 65 | Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 68 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 68 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 73 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy e""".replace( | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 73 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy e""".replace( | STRING |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 527 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 527 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 546 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 546 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 19 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 19 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 36 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 36 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ream/src/main/scala/akka/stream/stage/GraphStage.scala | 1018 | private def setOrAddEmitting[T](out: Outlet[T], next: Emitting[T]): Unit = | CODE |
| LOW | …t/src/test/scala/akka/testkit/metrics/MetricsKit.scala | 153 | private[metrics] def getOrRegister[M <: Metric](key: String, metric: => M)(implicit tag: ClassTag[M]): M = { | CODE |
| LOW | …rc/main/scala/akka/remote/artery/LruBoundedCache.scala | 79 | final def getOrCompute(k: K): V = | CODE |
| LOW | …te/src/main/scala/akka/remote/artery/Association.scala | 792 | private def getOrCreateQueueWrapper(queueIndex: Int, capacity: Int): QueueWrapper = { | CODE |
| LOW | …src/main/scala/akka/stream/GraphBuilderBenchmark.scala | 27 | def graph_with_junctions_gradual(): RunnableGraph[NotUsed] = | CODE |
| LOW | …src/main/scala/akka/stream/GraphBuilderBenchmark.scala | 31 | def graph_with_junctions_immediate(): RunnableGraph[NotUsed] = | CODE |
| LOW | …/main/scala/akka/stream/MaterializationBenchmark.scala | 129 | def graph_with_junctions_gradual(): NotUsed = graphWithJunctionsGradual.run() | CODE |
| LOW | …/main/scala/akka/stream/MaterializationBenchmark.scala | 132 | def graph_with_junctions_immediate(): NotUsed = graphWithJunctionsImmediate.run() | CODE |
| LOW | …/src/main/scala/akka/stream/FusedGraphsBenchmark.scala | 289 | def broadcast_zip_balance_merge(blackhole: org.openjdk.jmh.infra.Blackhole): Unit = { | STRING |
| LOW | …ted-data/src/main/scala/akka/cluster/ddata/ORMap.scala | 213 | def getOrElse(key: A, default: => B): B = values.getOrElse(key, default) | CODE |
| LOW | …ata/src/main/scala/akka/cluster/ddata/ORMultiMap.scala | 129 | def getOrElse(key: A, default: => Set[B]): Set[B] = | CODE |
| LOW | …rding/src/main/scala/akka/cluster/sharding/Shard.scala | 1145 | def getOrCreateEntity(id: EntityId): ActorRef = { | CODE |
| LOW | …nce/src/main/scala/akka/persistence/Eventsourced.scala | 121 | private def getAndClearInstrumentationContext(seqNr: Long): EventsourcedInstrumentation.Context = { | CODE |
| LOW | akka-actor/src/main/scala/akka/util/MessageBuffer.scala | 213 | private def getOrAddBuffer(id: I): MessageBuffer = { | CODE |
| LOW | akka-actor/src/main/scala/akka/util/MessageBuffer.scala | 279 | def getOrEmpty(id: I): MessageBuffer = { | CODE |
| LOW | akka-actor/src/main/scala/akka/util/OptionVal.scala | 57 | def getOrElse[B >: A](default: B): B = | CODE |
| LOW | …/main/scala/akka/pattern/CircuitBreakersRegistry.scala | 73 | private[akka] def getOrCreate(id: String, config: Config): CircuitBreaker = | CODE |
| LOW | …main/scala/akka/actor/dungeon/LicenseKeySupplier.scala | 24 | def implementing_this_is_a_violation_of_the_akka_license(): Unit | CODE |
| LOW | akka-actor/src/main/scala/akka/japi/JavaAPI.scala | 175 | def getOrElse[B >: A](defaultValue: B): B | CODE |
| LOW | akka-actor/src/main/scala/akka/japi/JavaAPI.scala | 214 | def getOrElse[B >: A](defaultValue: B): B = v | CODE |
| LOW | akka-actor/src/main/scala/akka/japi/JavaAPI.scala | 224 | def getOrElse[B](defaultValue: B): B = defaultValue | CODE |
| LOW | …erialization/jackson/JacksonObjectMapperProvider.scala | 334 | def getOrCreate(bindingName: String, jsonFactory: Option[JsonFactory]): ObjectMapper = { | CODE |
| LOW | …erialization/jackson/JacksonObjectMapperProvider.scala | 353 | def getOrCreate(bindingName: String, jsonFactory: Optional[JsonFactory]): ObjectMapper = | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …testkit/src/test/scala/akka/testkit/AkkaSpecSpec.scala | 39 | // verbose config just for demonstration purposes, please leave in in case of debugging | COMMENT |
| LOW | …n/scala/akka/persistence/journal/JournalPerfSpec.scala | 119 | * methods (don't forget to call `super` in your overridden methods). | STRING |
| LOW | …/main/scala/akka/persistence/journal/JournalSpec.scala | 36 | * methods (don't forget to call `super` in your overridden methods). | STRING |
| LOW | …cala/akka/persistence/snapshot/SnapshotStoreSpec.scala | 35 | * methods (don't forget to call `super` in your overridden methods). | STRING |
| LOW | …kka/persistence/japi/journal/JavaJournalPerfSpec.scala | 41 | * methods (don't forget to call `super` in your overridden methods). | COMMENT |
| LOW | …la/akka/persistence/japi/journal/JavaJournalSpec.scala | 21 | * methods (don't forget to call `super` in your overridden methods). | COMMENT |
| LOW | …/persistence/japi/snapshot/JavaSnapshotStoreSpec.scala | 22 | * methods (don't forget to call `super` in your overridden methods). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | akka-remote/src/test/resources/ssl/gen-functions.sh | 11 | # Create a certificate used for peer-to-peer, under the example.com CA | COMMENT |
| MEDIUM | akka-remote/src/test/resources/ssl/gen-functions.sh | 24 | # Create a certificate signing request for $PREFIX.example.com | COMMENT |
| MEDIUM | akka-remote/src/test/resources/ssl/genca.sh | 5 | # Create a self signed key pair root CA certificate. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …src/main/scala/akka/stream/impl/TraversalBuilder.scala | 973 | * Since the exposed output port has been wired optimistically to -1, we need to check if this is correct, | COMMENT |
| LOW | …a-stream/src/main/scala/akka/stream/scaladsl/Hub.scala | 659 | * we need to check if it was blocking us from advancing (being the slowest). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/typed/internal/receptionist/ClusterReceptionist.scala | 242 | // which is possible for OR CRDTs - done with an adapter to leverage the existing NodesRemoved message | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | kubernetes/create-cluster-gke.sh | 17 | # Usage: | COMMENT |