apache / incubator-pekkoConditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 7,951 units with 98,612 lines of code in units (59.8% of code).

7 very complex units (1,829 lines of code)
36 complex units (3,698 lines of code)
241 medium complex units (11,667 lines of code)
713 simple units (16,462 lines of code)
6,954 very simple units (64,956 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
private def active() in actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala	314	90	1
private def active() in actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/ProducerControllerImpl.scala	380	78	1
override def createLogicAndMaterializedValue() in stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala	344	71	1
def props() in cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala	161	69	3
def matchingRole() in cluster-tools/src/main/scala/org/apache/pekko/cluster/pubsub/DistributedPubSubMediator.scala	144	64	1
def createLogicAndMaterializedValue() in remote/src/main/scala/org/apache/pekko/remote/artery/Codecs.scala	212	56	1
def behavior() in cluster-typed/src/main/scala/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionist.scala	274	52	2
override def createLogic() in remote/src/main/scala/org/apache/pekko/remote/artery/SystemMessageDelivery.scala	191	50	1
def apply() in cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/internal/ReplicatorBehavior.scala	157	49	2
override def createLogic() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala	152	48	1
override def manifest() in cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializer.scala	45	43	1
override def toBinary() in cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/protobuf/ClusterShardingMessageSerializer.scala	46	43	1
private def active() in cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala	241	42	1
def this() in stream/src/main/scala/org/apache/pekko/stream/scaladsl/Hub.scala	175	40	1
def logDebug() in cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala	75	37	1
override def createLogicAndMaterializedValue() in stream/src/main/scala/org/apache/pekko/stream/impl/QueueSource.scala	171	37	1
def toBinary() in remote/src/main/scala/org/apache/pekko/remote/serialization/MiscMessageSerializer.scala	37	36	1
override def manifest() in remote/src/main/scala/org/apache/pekko/remote/serialization/MiscMessageSerializer.scala	39	36	1
override def createLogic() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala	106	35	1
def generateOperations() in distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorMapDeltaSpec.scala	75	35	1
def receiveGossip() in cluster/src/main/scala/org/apache/pekko/cluster/ClusterDaemon.scala	104	34	1
def send() in remote/src/main/scala/org/apache/pekko/remote/artery/Association.scala	97	32	3
override def createLogicAndMaterializedValue() in stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SinkRefImpl.scala	183	31	1
override def shutdown() in stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala	125	31	0
def this() in actor/src/main/scala/org/apache/pekko/event/Logging.scala	74	31	3
override def createLogicAndMaterializedValue() in stream/src/main/scala/org/apache/pekko/stream/impl/BoundedSourceQueue.scala	99	30	1
override def initialAttributes: Attributes = DefaultAttributes.flatMapPrefix and SourceLocation.forLambda() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/FlatMapPrefix.scala	138	29	1
override protected def initialAttributes: Attributes = DefaultAttributes.split and SourceLocation.forLambda() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala	123	29	1
final def receive = receiveWriteJournal.orElse[Any, Unit]() in persistence/src/main/scala/org/apache/pekko/persistence/journal/AsyncWriteJournal.scala	121	29	1
def dispatch() in remote/src/main/scala/org/apache/pekko/remote/artery/MessageDispatcher.scala	66	29	1
private def attachOutboundStreamRestart() in remote/src/main/scala/org/apache/pekko/remote/artery/Association.scala	94	29	5
def leaderActionsOnConvergence() in cluster/src/main/scala/org/apache/pekko/cluster/ClusterDaemon.scala	94	28	0
def fromBinary() in cluster/src/main/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializer.scala	29	28	2
def createLogicAndMaterializedValue() in stream/src/main/scala/org/apache/pekko/stream/impl/ActorRefSource.scala	115	28	1
override def createLogic() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala	99	28	1
def this() in persistence/src/main/scala/org/apache/pekko/persistence/journal/ReplayFilter.scala	80	28	4
def ready() in actor/src/main/scala/org/apache/pekko/io/dns/internal/DnsClient.scala	94	28	1
override def createLogic() in remote/src/main/scala/org/apache/pekko/remote/artery/Handshake.scala	117	28	1
override def fromBinary() in serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala	62	27	2
override def initialAttributes = DefaultAttributes.mapAsync and SourceLocation.forLambda() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala	68	27	1
override def initialAttributes = DefaultAttributes.mapAsyncUnordered and SourceLocation.forLambda() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala	56	27	1
def isLocalSender() in distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala	93	27	0
override def onNext() in stream/src/main/scala/org/apache/pekko/stream/impl/StreamLayout.scala	57	26	1
override def initialAttributes = Attributes.name() in stream/src/main/scala/org/apache/pekko/stream/impl/io/TcpStages.scala	129	25	1
def actorOf() in actor/src/main/scala/org/apache/pekko/actor/ActorRefProvider.scala	84	25	8
def createLogic() in stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala	65	24	1
def this() in stream/src/main/scala/org/apache/pekko/stream/scaladsl/Graph.scala	86	24	2
def toBinary() in distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatedDataSerializer.scala	26	24	1
final def systemInvoke() in actor/src/main/scala/org/apache/pekko/actor/ActorCell.scala	49	24	1
def invoke() in actor/src/main/scala/org/apache/pekko/actor/TypedActor.scala	34	24	3