total uncompressed bytes
11.5 MB
total files
1179
Fix
1175 wasted files
total waste: 11.5 MB
- aeron/cppbuild/googletest-release-1.10.0.zip : 1.1 MB
- aeron/cppbuild/zlib1211.zip : 747.4 KB
- aeron/cppbuild/HdrHistogram_c-0.9.13.zip : 271.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/MediaDriver.java : 133.6 KB
- aeron/aeron-driver/src/main/c/aeron_driver_conductor.c : 132.5 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java : 109.8 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/AeronArchive.java : 107.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModule.java : 106.4 KB
- aeron/cppbuild/Doxyfile.in : 103.2 KB
- aeron/aeron-driver/src/main/c/aeron_driver_context.c : 83.8 KB
- aeron/aeron-driver/src/test/c/aeron_driver_conductor_network_test.cpp : 79.4 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/Archive.java : 77.8 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/DriverConductorTest.java : 75.2 KB
- aeron/aeron-archive/src/main/cpp/client/AeronArchive.h : 71.6 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveConductor.java : 69.9 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DriverConductor.java : 67.3 KB
- aeron/aeron-client/src/main/c/aeron_client_conductor.c : 63.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/AeronCluster.java : 62.7 KB
- aeron/gradle/wrapper/gradle-wrapper.jar : 58.9 KB
- aeron/aeron-driver/src/test/c/util/aeron_math_test.cpp : 57.2 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ArchiveToolTests.java : 55.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/Configuration.java : 53.9 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusteredServiceContainer.java : 52.4 KB
- aeron/aeron-client/src/main/java/io/aeron/Aeron.java : 52.2 KB
- aeron/aeron-client/src/main/c/aeronc.h : 51.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveTool.java : 51.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ArchiveProxy.java : 50.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackup.java : 47.2 KB
- aeron/aeron-samples/src/docs/asciidoc/Cluster-Tutorial.asciidoc : 47.1 KB
- aeron/aeron-client/src/main/java/io/aeron/ChannelUriStringBuilder.java : 45.9 KB
- aeron/aeron-archive/src/main/cpp/client/ArchiveProxy.h : 45.6 KB
- aeron/aeron-driver/src/test/c/aeron_driver_conductor_ipc_test.cpp : 44.3 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/RecordingLog.java : 44.3 KB
- aeron/aeron-driver/src/main/c/aeron_network_publication.c : 42.2 KB
- aeron/aeron-client/src/test/cpp/ClientConductorTest.cpp : 39.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterMember.java : 38.8 KB
- aeron/aeron-driver/src/main/c/aeron_driver.c : 38.6 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterTest.java : 38.6 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/TestCluster.java : 38.4 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/Catalog.java : 38.1 KB
- aeron/aeron-driver/src/main/c/aeronmd.h : 37.7 KB
- aeron/aeron-driver/src/main/c/aeron_publication_image.c : 37.4 KB
- aeron/aeron-client/src/main/java/io/aeron/ClientConductor.java : 37.1 KB
- aeron/aeron-driver/src/main/c/aeron_driver_name_resolver.c : 36.5 KB
- aeron/aeron-driver/src/main/c/agent/aeron_driver_agent.c : 36.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java : 36.1 KB
- aeron/aeron-client/src/main/cpp/ClientConductor.cpp : 36.0 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ArchiveEventDissector.java : 34.8 KB
- aeron/aeron-cluster/src/main/resources/cluster/aeron-cluster-codecs.xml : 34.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterTool.java : 33.3 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ControlSessionDemuxer.java : 33.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/Election.java : 33.0 KB
- aeron/aeron-client/src/test/cpp/ImageTest.cpp : 33.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java : 32.4 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/LogBufferDescriptor.java : 32.0 KB
- aeron/aeron-client/src/main/cpp/Image.h : 31.8 KB
- aeron/aeron-archive/src/test/cpp/AeronArchiveTest.cpp : 31.7 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackupAgent.java : 31.0 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/ArchiveTest.java : 30.9 KB
- aeron/aeron-archive/src/main/resources/archive/aeron-archive-codecs.xml : 30.6 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ReplaySessionTest.java : 30.5 KB
- aeron/aeron-driver/src/main/c/media/aeron_receive_channel_endpoint.c : 29.9 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ArchiveEventDissectorTest.java : 29.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/UdpChannel.java : 28.9 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusteredServiceAgent.java : 28.6 KB
- aeron/aeron-client/src/main/java/io/aeron/Image.java : 28.2 KB
- aeron/aeron-client/src/test/c/aeron_image_test.cpp : 28.1 KB
- aeron/aeron-client/src/main/java/io/aeron/CommonContext.java : 28.1 KB
- aeron/aeron-client/src/test/java/io/aeron/ImageTest.java : 27.7 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ElectionTest.java : 27.4 KB
- aeron/aeron-driver/src/test/c/aeron_uri_test.cpp : 27.2 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/ExclusiveTermAppender.java : 26.7 KB
- aeron/aeron-driver/src/test/c/aeron_driver_conductor_spy_test.cpp : 26.0 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/ReceiverTest.java : 25.9 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermAppender.java : 25.7 KB
- aeron/aeron-client/src/main/java/io/aeron/Publication.java : 25.1 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/ReplicateRecordingTest.java : 25.0 KB
- aeron/aeron-driver/src/test/c/aeron_data_packet_dispatcher_test.cpp : 25.0 KB
- aeron/aeron-driver/src/main/c/aeron_driver_conductor.h : 24.7 KB
- aeron/build.gradle : 24.6 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/DriverEventDissectorTest.java : 24.3 KB
- aeron/aeron-client/src/main/cpp/Publication.h : 24.2 KB
- aeron/aeron-client/src/test/c/aeron_client_conductor_test.cpp : 24.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ControlSession.java : 23.9 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/UdpChannelTest.java : 23.8 KB
- aeron/aeron-driver/src/test/c/aeron_loss_detector_test.cpp : 23.5 KB
- aeron/aeron-driver/src/test/c/aeron_flow_control_test.cpp : 23.4 KB
- aeron/aeron-client/src/main/cpp/ExclusivePublication.h : 22.8 KB
- aeron/aeron-driver/src/test/c/aeron_driver_conductor_test.h : 22.7 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/PubAndSubTest.java : 22.5 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ReplicationSession.java : 22.4 KB
- aeron/aeron-client/src/test/java/io/aeron/ClientConductorTest.java : 22.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/ReceiveChannelEndpoint.java : 22.2 KB
- aeron/aeron-client/src/main/java/io/aeron/ExclusivePublication.java : 22.0 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/DriverEventDissector.java : 22.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusPublisher.java : 21.9 KB
- aeron/aeron-driver/src/main/c/aeron_driver_receiver.c : 21.8 KB
- aeron/aeron-driver/src/main/c/uri/aeron_uri.c : 21.7 KB
- aeron/aeron-driver/src/test/c/aeron_udp_channel_test.cpp : 21.5 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/SenderTest.java : 21.5 KB
- aeron/aeron-client/src/test/cpp/concurrent/ManyToOneRingBufferTest.cpp : 21.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/IndexedReplicatedRecording.java : 20.8 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterNodeRestartTest.java : 20.5 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MultiDestinationSubscriptionTest.java : 20.3 KB
- aeron/aeron-driver/src/main/c/aeron_ipc_publication.c : 20.0 KB
- aeron/aeron-client/src/main/cpp/ClientConductor.h : 19.9 KB
- aeron/aeron-archive/src/main/cpp/client/ArchiveProxy.cpp : 19.9 KB
- aeron/aeron-client/src/main/c/aeron_image.c : 19.9 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/StartFromTruncatedRecordingLogTest.java : 19.7 KB
- aeron/aeron-client/src/main/c/aeron_exclusive_publication.c : 19.6 KB
- aeron/aeron-driver/src/test/c/aeron_publication_image_test.cpp : 19.6 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/RecordingLogTest.java : 19.5 KB
- aeron/aeron-driver/src/test/c/aeron_name_resolver_test.cpp : 19.5 KB
- aeron/aeron-driver/src/main/c/aeron_data_packet_dispatcher.c : 19.5 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ReplaySession.java : 19.0 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/CatalogTest.java : 18.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ReplayMerge.java : 18.8 KB
- aeron/aeron-client/src/main/java/io/aeron/Subscription.java : 18.8 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/TaggedFlowControlSystemTest.java : 18.4 KB
- aeron/aeron-cluster/src/main/resources/cluster/fpl/sbe.xsd : 18.3 KB
- aeron/aeron-archive/src/main/resources/archive/fpl/sbe.xsd : 18.3 KB
- aeron/aeron-archive/src/main/cpp/client/ArchiveConfiguration.h : 18.2 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/AuthenticationTest.java : 17.9 KB
- aeron/aeron-client/src/main/c/util/aeron_netutil.c : 17.8 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermAppenderTest.java : 17.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DriverNameResolver.java : 17.5 KB
- aeron/aeron-driver/src/test/c/aeron_spsc_rb_test.cpp : 17.3 KB
- aeron/aeron-driver/src/main/c/media/aeron_send_channel_endpoint.c : 17.2 KB
- aeron/aeron-driver/src/test/c/aeron_mpsc_rb_test.cpp : 17.1 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ArchiveTest.java : 17.0 KB
- aeron/aeron-client/src/main/cpp/Subscription.h : 16.8 KB
- aeron/aeron-client/src/test/cpp/concurrent/OneToOneRingBufferTest.cpp : 16.7 KB
- aeron/aeron-client/src/main/java/io/aeron/ChannelUri.java : 16.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java : 16.4 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_exclusive_term_appender.h : 16.4 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/EventLogAgent.java : 16.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/IpcPublication.java : 16.4 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/RecordingWriterTests.java : 16.1 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_appender.h : 15.6 KB
- aeron/aeron-client/src/main/cpp/Aeron.h : 15.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DataPacketDispatcher.java : 15.5 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MultiDestinationCastTest.java : 15.5 KB
- aeron/aeron-client/src/main/cpp/concurrent/AtomicBuffer.h : 15.4 KB
- aeron/aeron-client/src/main/cpp/Context.h : 15.4 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/TermAppender.h : 15.4 KB
- aeron/aeron-driver/src/main/c/aeron_driver_receiver_proxy.c : 15.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/LogBufferDescriptor.h : 15.3 KB
- aeron/aeron-client/src/main/c/aeron_client.c : 15.1 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterBackupTest.java : 15.0 KB
- aeron/aeron-driver/src/main/c/CMakeLists.txt : 14.9 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MinFlowControlSystemTest.java : 14.9 KB
- aeron/aeron-client/src/main/c/aeron_agent.c : 14.9 KB
- aeron/aeron-client/src/main/java/io/aeron/CncFileDescriptor.java : 14.8 KB
- aeron/aeron-client/src/main/c/aeron_publication.c : 14.8 KB
- aeron/aeron-client/src/main/c/aeron_subscription.c : 14.6 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel_transport_bindings.c : 14.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/ManageRecordingHistoryTest.java : 14.5 KB
- aeron/aeron-driver/src/main/c/aeron_flow_control.c : 14.5 KB
- aeron/aeron-client/src/main/c/aeron_fragment_assembler.c : 14.4 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/TestNode.java : 14.3 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/BacklogStat.java : 14.2 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/NameReResolutionTest.java : 14.1 KB
- aeron/aeron-client/src/main/java/io/aeron/ConcurrentPublication.java : 14.0 KB
- aeron/aeron-samples/src/main/cpp/PingPong.cpp : 13.8 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/ArchiveAuthenticationTest.java : 13.8 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/DriverNameResolverTest.java : 13.6 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/LossDetectorTest.java : 13.5 KB
- aeron/aeron-driver/src/main/c/aeron_driver_sender.c : 13.4 KB
- aeron/aeron-client/src/test/c/concurrent/aeron_term_appender_test.cpp : 13.4 KB
- aeron/aeron-test-support/src/main/java/io/aeron/test/Tests.java : 13.3 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusAdapter.java : 13.3 KB
- aeron/aeron-client/src/main/c/util/aeron_fileutil.c : 13.2 KB
- aeron/aeron-client/src/test/c/concurrent/aeron_exclusive_term_appender_test.cpp : 13.2 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/ExclusiveTermAppender.h : 13.0 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel.c : 12.9 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/CTestMediaDriver.java : 12.9 KB
- aeron/aeron-client/src/test/cpp/concurrent/BroadcastReceiverTest.cpp : 12.8 KB
- aeron/aeron-driver/src/main/c/aeron_min_flow_control.c : 12.6 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/FrameDescriptor.java : 12.6 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterNodeTest.java : 12.6 KB
- aeron/CMakeLists.txt : 12.5 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/LogPublisher.java : 12.5 KB
- aeron/aeron-client/src/main/cpp/ChannelUriStringBuilder.h : 12.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ClientCommandAdapter.java : 12.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/UdpChannelTransport.java : 12.3 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/MultiModuleSharedDriverTest.java : 12.3 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel_transport_bindings.h : 12.2 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/RetransmitHandlerTest.java : 12.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/SendChannelEndpoint.java : 12.2 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/cluster/SingleNodeCluster.java : 12.1 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/DataPacketDispatcherTest.java : 12.1 KB
- aeron/aeron-driver/src/main/c/aeron_driver_context.h : 11.9 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_destination_tracker.c : 11.9 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/ExclusivePublicationTest.java : 11.8 KB
- aeron/aeron-client/src/main/cpp/DriverProxy.h : 11.8 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/ReplayMergeTest.java : 11.7 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/Cluster.java : 11.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/PublicationParams.java : 11.6 KB
- aeron/aeron-client/src/test/cpp/concurrent/TermAppenderTest.cpp : 11.5 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/SelectorAndTransportTest.java : 11.5 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/EmbeddedReplayThroughput.java : 11.5 KB
- aeron/aeron-client/src/main/c/aeron_context.c : 11.5 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ConsensusModuleAgentTest.java : 11.3 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusterMarkFile.java : 11.2 KB
- aeron/aeron-driver/src/test/c/aeron_logbuffer_unblocker_test.cpp : 11.2 KB
- aeron/aeron-client/src/main/c/aeron_client_conductor.h : 11.2 KB
- aeron/aeron-samples/src/main/cpp/Ping.cpp : 11.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/Receiver.java : 11.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/ringbuffer/ManyToOneRingBuffer.h : 11.1 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/ExtendRecordingTest.java : 11.1 KB
- aeron/aeron-samples/src/main/cpp/ExclusiveThroughput.cpp : 11.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/MultiSndDestination.java : 11.0 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel_transport.c : 11.0 KB
- aeron/aeron-client/src/main/c/util/aeron_parse_util.c : 10.9 KB
- aeron/aeron-client/src/main/c/util/aeron_http_util.c : 10.9 KB
- aeron/README.md : 10.8 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/AeronStat.java : 10.8 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/EventConfiguration.java : 10.8 KB
- aeron/aeron-client/src/test/cpp/concurrent/BroadcastTransmitterTest.cpp : 10.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/StreamCounter.java : 10.6 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/RecoveryState.java : 10.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/ChannelEndpointStatusTest.java : 10.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/FileReceiver.java : 10.3 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/StatusMessageFlyweight.java : 10.3 KB
- aeron/LICENSE : 10.3 KB
- aeron/aeron-driver/src/test/c/aeron_loss_reporter_test.cpp : 10.2 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/DataHeaderFlyweight.java : 10.2 KB
- aeron/aeron-client/src/main/java/io/aeron/DriverProxy.java : 10.2 KB
- aeron/aeron-driver/src/test/c/aeron_c_system_test.cpp : 10.1 KB
- aeron/aeron-driver/src/main/c/aeron_position.c : 10.1 KB
- aeron/aeron-samples/src/main/cpp/Throughput.cpp : 10.1 KB
- aeron/aeron-client/src/main/c/util/aeron_properties_util.c : 10.1 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/BasicArchiveTest.java : 10.0 KB
- aeron/aeron-client/src/test/c/concurrent/aeron_broadcast_receiver_test.cpp : 9.9 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermScannerTest.java : 9.8 KB
- aeron/aeron-client/src/test/cpp/concurrent/TermScannerTest.cpp : 9.7 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/DynamicMembershipTest.java : 9.7 KB
- aeron/aeron-client/src/test/cpp/concurrent/TermReaderTest.cpp : 9.7 KB
- aeron/aeron-client/src/main/c/collections/aeron_int64_counter_map.h : 9.7 KB
- aeron/aeron-driver/src/main/c/aeron_publication_image.h : 9.7 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/BoundedLogAdapter.java : 9.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/SpySimulatedConnectionTest.java : 9.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/StopStartSecondSubscriberTest.java : 9.6 KB
- aeron/aeron-driver/src/test/c/aeron_parse_util_test.cpp : 9.6 KB
- aeron/aeron-client/src/main/cpp/ChannelUri.h : 9.6 KB
- aeron/aeron-archive/src/main/cpp/client/ReplayMerge.cpp : 9.6 KB
- aeron/aeron-client/src/test/cpp/concurrent/TermBlockScannerTest.cpp : 9.6 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/LogAdapter.java : 9.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/SubscriptionLink.java : 9.5 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/DriverEventLoggerTest.java : 9.5 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_mpsc_rb.c : 9.5 KB
- aeron/aeron-driver/src/main/c/media/aeron_receive_channel_endpoint.h : 9.4 KB
- aeron/aeron-driver/src/main/c/aeron_driver_conductor_proxy.c : 9.4 KB
- aeron/aeron-driver/src/main/c/aeron_network_publication.h : 9.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/EgressPoller.java : 9.3 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterTimerTest.java : 9.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_distinct_error_log.c : 9.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_counters_manager.c : 9.3 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermUnblockerTest.java : 9.3 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedPingPong.java : 9.3 KB
- aeron/aeron-driver/src/test/c/collections/aeron_int64_to_tagged_ptr_hash_map_test.cpp : 9.2 KB
- aeron/aeron-client/src/main/c/collections/aeron_int64_to_tagged_ptr_hash_map.h : 9.2 KB
- aeron/aeron-driver/src/test/c/aeron_distinct_error_log_test.cpp : 9.1 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_transport_poller.c : 9.1 KB
- aeron/aeron-client/src/main/java/io/aeron/DriverEventsAdapter.java : 9.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveMarkFile.java : 8.9 KB
- aeron/aeron-driver/src/test/c/aeron_counters_manager_test.cpp : 8.9 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/cluster/BasicAuctionClusteredService.java : 8.9 KB
- aeron/aeron-client/src/test/cpp/ExclusivePublicationTest.cpp : 8.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingDescriptorPoller.java : 8.9 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MultiDriverTest.java : 8.8 KB
- aeron/aeron-client/src/test/cpp/FragmentAssemblerTest.cpp : 8.8 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_counters_manager.h : 8.8 KB
- aeron/aeron-samples/src/main/cpp/StreamingPublisher.cpp : 8.8 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/SamplesUtil.java : 8.8 KB
- aeron/aeron-client/src/main/java/io/aeron/command/ImageBuffersReadyFlyweight.java : 8.8 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/status/RecordingPos.java : 8.7 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/WildcardPortsSystemTest.java : 8.7 KB
- aeron/aeron-client/src/test/cpp/PublicationTest.cpp : 8.7 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/DedicatedModeArchiveConductor.java : 8.7 KB
- aeron/aeron-client/src/main/cpp/util/MemoryMappedFile.cpp : 8.7 KB
- aeron/aeron-client/src/main/java/io/aeron/LogBuffers.java : 8.7 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterControl.java : 8.7 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/ResolutionEntryFlyweight.java : 8.6 KB
- aeron/aeron-driver/src/main/c/aeron_driver_sender_proxy.c : 8.6 KB
- aeron/aeron-driver/src/test/c/aeron_receiver_test.h : 8.6 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ControlResponsePoller.java : 8.5 KB
- aeron/aeron-client/src/main/c/aeron_socket.c : 8.5 KB
- aeron/aeron-driver/src/test/c/collections/aeron_bit_set_test.cpp : 8.5 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/cluster/BasicAuctionClusteredServiceNode.java : 8.4 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ClusterLoggingAgentTest.java : 8.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/NetworkUtil.java : 8.4 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingSubscriptionDescriptorPoller.java : 8.4 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermReaderTest.java : 8.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/StreamStat.java : 8.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ServiceProxy.java : 8.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/AbstractMinMulticastFlowControl.java : 8.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MemoryOrderingTest.java : 8.3 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/RecordingSessionTest.java : 8.3 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/media/NetworkUtilTest.java : 8.2 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/LogInspector.java : 8.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ControlResponseProxy.java : 8.2 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/FileSender.java : 8.2 KB
- aeron/aeron-client/src/main/cpp/concurrent/CountersReader.h : 8.2 KB
- aeron/aeron-client/src/main/c/collections/aeron_str_to_ptr_hash_map.h : 8.2 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterSession.java : 8.1 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ListRecordingsForUriSessionTest.java : 8.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/cluster/BasicAuctionClusterClient.java : 8.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/ringbuffer/OneToOneRingBuffer.h : 8.1 KB
- aeron/aeron-client/src/test/java/io/aeron/BufferBuilderTest.java : 8.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ConsensusModuleProxy.java : 8.0 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/DriverEventEncoderTest.java : 8.0 KB
- aeron/aeron-client/src/main/java/io/aeron/command/PublicationBuffersReadyFlyweight.java : 7.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/RecordingReader.java : 7.9 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClientSession.java : 7.8 KB
- aeron/aeron-driver/src/test/c/media/aeron_udp_channel_transport_loss_test.cpp : 7.8 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_logbuffer_descriptor.h : 7.8 KB
- aeron/aeron-archive/src/main/cpp/client/ReplayMerge.h : 7.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/CubicCongestionControl.java : 7.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/reports/LossReport.java : 7.7 KB
- aeron/aeron-client/src/test/cpp/command/CommandTest.cpp : 7.6 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterControlAdapter.java : 7.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/DataTransportPoller.java : 7.6 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/CommonEventEncoderTest.java : 7.6 KB
- aeron/aeron-client/src/main/cpp/CncFileDescriptor.h : 7.5 KB
- aeron/aeron-driver/src/test/c/aeron_term_scanner_test.cpp : 7.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/buffer/MappedRawLog.java : 7.5 KB
- aeron/aeron-archive/src/main/cpp/client/AeronArchive.cpp : 7.4 KB
- aeron/aeron-client/src/test/c/concurrent/aeron_broadcast_transmitter_test.cpp : 7.4 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermBlockScannerTest.java : 7.4 KB
- aeron/aeron-client/src/main/cpp/DriverListenerAdapter.h : 7.4 KB
- aeron/aeron-samples/src/main/cpp/Pong.cpp : 7.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/UntetheredSubscriptionTest.java : 7.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/RetransmitHandler.java : 7.3 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/RecordingWriter.java : 7.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/SocketAddressParser.java : 7.2 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/IngressAdapter.java : 7.2 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/DriverEventLogger.java : 7.2 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MaxFlowControlStrategySystemTest.java : 7.2 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/DriverLoggingAgentTest.java : 7.2 KB
- aeron/aeron-samples/src/main/cpp/BasicPublisher.cpp : 7.2 KB
- aeron/aeron-client/src/main/java/io/aeron/ControlledFragmentAssembler.java : 7.2 KB
- aeron/aeron-client/src/main/c/collections/aeron_int64_to_ptr_hash_map.h : 7.1 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingPos.h : 7.1 KB
- aeron/aeron-driver/src/test/c/aeron_driver_conductor_counter_test.cpp : 7.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleSnapshotLoader.java : 7.1 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ArchiveEventCode.java : 7.1 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/LogBufferUnblockerTest.java : 7.0 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/PongTest.java : 7.0 KB
- aeron/aeron-client/src/test/java/io/aeron/FragmentAssemblerTest.java : 7.0 KB
- aeron/aeron-driver/src/test/c/collections/aeron_int64_to_ptr_hash_map_test.cpp : 7.0 KB
- aeron/aeron-archive/README.md : 7.0 KB
- aeron/aeron-client/src/main/java/io/aeron/command/CounterMessageFlyweight.java : 7.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedDualExclusiveThroughput.java : 6.9 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/Ping.java : 6.9 KB
- aeron/aeron-client/src/test/cpp/concurrent/DistinctErrorLogTest.cpp : 6.9 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel_transport_loss.c : 6.9 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/TaggedMulticastFlowControlTest.java : 6.9 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/SnapshotTaker.java : 6.9 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAdapter.java : 6.8 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/RecordingSession.java : 6.8 KB
- aeron/aeron-client/src/test/java/io/aeron/FlyweightTest.java : 6.8 KB
- aeron/.github/workflows/ci.yml : 6.8 KB
- aeron/aeron-driver/src/test/c/collections/aeron_int64_counter_map_test.cpp : 6.7 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/ImageAvailabilityTest.java : 6.7 KB
- aeron/aeron-client/src/test/cpp/concurrent/CountersManagerTest.cpp : 6.7 KB
- aeron/aeron-client/src/main/c/aeron_windows.c : 6.7 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_spsc_rb.c : 6.7 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/Header.java : 6.6 KB
- aeron/aeron-client/src/main/c/util/aeron_error.c : 6.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/SessionSpecificSubscriptionTest.java : 6.6 KB
- aeron/aeron-client/src/main/java/io/aeron/status/LocalSocketAddressStatus.java : 6.6 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/MultipleSubscribersWithFragmentAssembly.java : 6.6 KB
- aeron/aeron-driver/src/test/c/aeron_term_gap_filler_test.cpp : 6.5 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/BufferClaim.java : 6.5 KB
- aeron/aeron-driver/src/main/c/aeron_name_resolver.c : 6.5 KB
- aeron/aeron-client/src/main/java/io/aeron/FragmentAssembler.java : 6.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/Sender.java : 6.4 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ListRecordingsSessionTest.java : 6.4 KB
- aeron/aeron-client/src/test/cpp/ClientConductorFixture.h : 6.4 KB
- aeron/aeron-driver/src/test/c/aeron_mpsc_concurrent_array_queue_test.cpp : 6.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/ArchiveCreator.java : 6.4 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermGapFillerTest.java : 6.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/MultiRcvDestination.java : 6.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ReceiverProxy.java : 6.3 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermReader.java : 6.2 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ConsensusModuleContextCloseTests.java : 6.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingSignalAdapter.java : 6.2 KB
- aeron/aeron-driver/src/main/c/aeron_data_packet_dispatcher.h : 6.2 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/media/SocketAddressParserTest.java : 6.2 KB
- aeron/aeron-driver/src/test/c/aeron_retransmit_handler_test.cpp : 6.2 KB
- aeron/aeron-driver/src/main/c/aeron_ipc_publication.h : 6.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ClientProxy.java : 6.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingEventsPoller.java : 6.2 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/RecordedBasicPublisher.java : 6.2 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/HeaderFlyweight.java : 6.2 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/SetupFlyweight.java : 6.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/EmbeddedRecordingThroughput.java : 6.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleSnapshotTaker.java : 6.1 KB
- aeron/aeron-client/src/main/cpp/util/Exceptions.h : 6.1 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/SessionSpecificPublicationTest.java : 6.1 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/TwoBufferOfferMessageTest.java : 6.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/StreamingPublisher.java : 6.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveMigration_1_2.java : 6.1 KB
- aeron/aeron-driver/src/test/c/aeron_properties_test.cpp : 6.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DriverNameResolverCache.java : 6.1 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ArchiveLoggingAgentTest.java : 6.1 KB
- aeron/aeron-client/src/main/cpp/CMakeLists.txt : 6.0 KB
- aeron/aeron-client/src/test/c/aeron_subscription_test.cpp : 6.0 KB
- aeron/aeron-driver/src/main/c/aeron_retransmit_handler.c : 6.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveMigration_0_1.java : 6.0 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterToolTest.java : 6.0 KB
- aeron/aeron-samples/src/main/cpp/RateSubscriber.cpp : 6.0 KB
- aeron/config/checkstyle/checkstyle.xml : 6.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/buffer/FileStoreLogFactory.java : 6.0 KB
- aeron/aeron-archive/src/main/cpp/client/ControlResponsePoller.h : 5.9 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/MultiplePublishersWithFragmentation.java : 5.9 KB
- aeron/aeron-client/src/main/cpp/concurrent/CountersManager.h : 5.9 KB
- aeron/aeron-client/src/main/java/io/aeron/status/HeartbeatTimestamp.java : 5.8 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/MinMulticastFlowControlTest.java : 5.8 KB
- aeron/gradlew : 5.8 KB
- aeron/aeron-client/src/main/cpp/command/ImageBuffersReadyFlyweight.h : 5.8 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ArchiveEventLoggerTest.java : 5.7 KB
- aeron/aeron-client/src/main/java/io/aeron/command/ImageMessageFlyweight.java : 5.7 KB
- aeron/aeron-client/src/test/cpp/concurrent/TermGapScannerTest.cpp : 5.7 KB
- aeron/aeron-client/src/main/java/io/aeron/BufferBuilder.java : 5.7 KB
- aeron/aeron-client/src/main/cpp/concurrent/errors/DistinctErrorLog.h : 5.7 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingDescriptorPoller.cpp : 5.7 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ArchiveTests.java : 5.7 KB
- aeron/aeron-samples/src/main/cpp/BasicSubscriber.cpp : 5.7 KB
- aeron/aeron-client/src/main/cpp/Aeron.cpp : 5.7 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ControlResponseAdapter.java : 5.7 KB
- aeron/aeron-driver/src/main/c/media/aeron_send_channel_endpoint.h : 5.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/Header.h : 5.6 KB
- aeron/aeron-client/src/main/c/CMakeLists.txt : 5.6 KB
- aeron/aeron-driver/src/test/c/aeron_spsc_concurrent_array_queue_test.cpp : 5.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/LossDetector.java : 5.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/FrameDescriptor.h : 5.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/ControlTransportPoller.java : 5.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/atomic/Atomic64_gcc_x86_64.h : 5.6 KB
- aeron/aeron-archive/src/main/cpp/CMakeLists.txt : 5.5 KB
- aeron/aeron-client/src/main/cpp/ControlledFragmentAssembler.h : 5.5 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ClusterEventLoggerTest.java : 5.5 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/EventLogReaderAgent.java : 5.5 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/RttMeasurementFlyweight.java : 5.4 KB
- aeron/aeron-driver/src/test/c/aeron_test_udp_bindings.h : 5.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/CounterTest.java : 5.4 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/CmdInterceptor.java : 5.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/BufferClaimMessageTest.java : 5.4 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/client/AeronArchiveTest.java : 5.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/BasicPublisher.java : 5.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/PublishFromArbitraryPositionTest.java : 5.3 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusteredService.java : 5.3 KB
- aeron/aeron-client/src/main/java/io/aeron/ImageControlledFragmentAssembler.java : 5.3 KB
- aeron/aeron-client/src/main/cpp/util/BitUtil.h : 5.3 KB
- aeron/aeron-client/src/test/java/io/aeron/PublicationTest.java : 5.3 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingSubscriptionDescriptorPoller.cpp : 5.3 KB
- aeron/aeron-client/src/test/java/io/aeron/SubscriptionTest.java : 5.3 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/RateReporter.java : 5.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/GapFillLossTest.java : 5.3 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/DriverEventEncoder.java : 5.2 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingDescriptorPoller.h : 5.2 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/EgressAdapter.java : 5.2 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ClusterEventEncoderTest.java : 5.2 KB
- aeron/aeron-driver/src/main/c/aeron_csv_table_name_resolver.c : 5.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveSpiedThroughput.java : 5.1 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/DriverEventCode.java : 5.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveVectoredIpcThroughput.java : 5.1 KB
- aeron/aeron-samples/src/main/cpp/AeronStat.cpp : 5.1 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/MultiClusteredServicesTest.java : 5.1 KB
- aeron/aeron-client/src/main/java/io/aeron/command/SubscriptionMessageFlyweight.java : 5.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/AgentRunner.h : 5.1 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermUnblocker.java : 5.1 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/CommonEventDissector.java : 5.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ServiceSnapshotLoader.java : 5.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackupMediaDriver.java : 5.1 KB
- aeron/aeron-client/src/main/java/io/aeron/DirectBufferVector.java : 5.1 KB
- aeron/aeron-client/src/main/c/command/aeron_control_protocol.h : 5.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusteredMediaDriver.java : 5.1 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/CommonEventEncoder.java : 5.1 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/UntetheredSubscriptionTest.java : 5.0 KB
- aeron/aeron-samples/src/main/cpp/LossStat.cpp : 5.0 KB
- aeron/aeron-client/src/main/cpp/concurrent/atomic/Atomic64_gcc_cpp11.h : 5.0 KB
- aeron/aeron-driver/src/main/c/aeron_name_resolver_cache.c : 5.0 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/MediaDriverTestWatcher.java : 5.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/RecordingEventsProxy.java : 5.0 KB
- aeron/aeron-samples/src/main/cpp/DriverTool.cpp : 5.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/SendSelectReceiveUdpPing.java : 5.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/SubscriptionParams.java : 5.0 KB
- aeron/aeron-driver/src/main/c/aeron_driver_receiver.h : 5.0 KB
- aeron/aeron-client/src/main/cpp/command/PublicationBuffersReadyFlyweight.h : 5.0 KB
- aeron/aeron-client/src/main/java/io/aeron/status/ReadableCounter.java : 5.0 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterTests.java : 5.0 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermRebuilderTest.java : 4.9 KB
- aeron/aeron-client/src/main/java/io/aeron/command/ErrorResponseFlyweight.java : 4.9 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedThroughput.java : 4.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingEventsAdapter.java : 4.9 KB
- aeron/aeron-driver/src/main/c/media/aeron_receive_destination.c : 4.9 KB
- aeron/aeron-client/src/main/c/protocol/aeron_udp_protocol.h : 4.9 KB
- aeron/aeron-client/src/main/cpp/FragmentAssembler.h : 4.9 KB
- aeron/aeron-driver/src/main/c/aeron_driver_receiver_proxy.h : 4.9 KB
- aeron/buildSrc/src/main/java/io/aeron/build/AsciidoctorPreprocessTask.java : 4.8 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DriverConductorProxy.java : 4.8 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_spsc_concurrent_array_queue.h : 4.8 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_thread.c : 4.8 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/BufferClaim.h : 4.8 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveThroughput.java : 4.8 KB
- aeron/aeron-client/src/main/java/io/aeron/ImageFragmentAssembler.java : 4.8 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveBufferClaimIpcThroughput.java : 4.8 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/archive/Common.java : 4.8 KB
- aeron/aeron-client/src/main/java/io/aeron/command/DestinationMessageFlyweight.java : 4.7 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedBufferClaimIpcThroughput.java : 4.7 KB
- aeron/aeron-driver/src/test/c/CMakeLists.txt : 4.7 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/FragmentedMessageTest.java : 4.7 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/SampleConfiguration.java : 4.7 KB
- aeron/aeron-driver/src/main/c/uri/aeron_uri.h : 4.7 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/PublicationUnblockTest.java : 4.7 KB
- aeron/aeron-samples/src/main/cpp/ErrorStat.cpp : 4.6 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/EgressPublisher.java : 4.6 KB
- aeron/aeron-client/src/test/cpp/concurrent/ConcurrentTest.cpp : 4.6 KB
- aeron/aeron-client/src/main/cpp/command/CounterMessageFlyweight.h : 4.6 KB
- aeron/aeron-client/src/main/java/io/aeron/protocol/NakFlyweight.java : 4.6 KB
- aeron/aeron-driver/src/main/c/aeron_loss_detector.c : 4.6 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveIpcThroughput.java : 4.6 KB
- aeron/aeron-client/src/main/c/collections/aeron_bit_set.h : 4.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/SenderProxy.java : 4.6 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/SimplePublisher.java : 4.6 KB
- aeron/aeron-client/src/test/java/io/aeron/ChannelUriTest.java : 4.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/ControlledMessageTest.java : 4.6 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/SendHackSelectReceiveUdpPing.java : 4.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/StatusUtil.java : 4.6 KB
- aeron/aeron-client/src/main/cpp/protocol/StatusMessageFlyweight.h : 4.6 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/EmbeddedIpcThroughput.java : 4.6 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/IpcPublicationTest.java : 4.6 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_mpsc_concurrent_array_queue.h : 4.6 KB
- aeron/aeron-driver/src/main/c/aeron_flow_control.h : 4.5 KB
- aeron/aeron-driver/src/main/c/aeron_system_counters.c : 4.5 KB
- aeron/aeron-driver/src/main/c/reports/aeron_loss_reporter.c : 4.5 KB
- aeron/aeron-driver/src/test/c/collections/aeron_str_to_ptr_hash_map_test.cpp : 4.5 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/SimpleSubscriber.java : 4.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/CongestionControl.java : 4.5 KB
- aeron/aeron-driver/src/main/c/aeron_congestion_control.c : 4.4 KB
- aeron/aeron-client/src/test/cpp/concurrent/ErrorLogReaderTest.cpp : 4.4 KB
- aeron/aeron-client/src/main/java/io/aeron/command/PublicationMessageFlyweight.java : 4.4 KB
- aeron/aeron-client/src/main/c/aeronc.c : 4.4 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingSubscriptionDescriptorPoller.h : 4.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/InterfaceSearchAddress.java : 4.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/SpySubscriptionTest.java : 4.4 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchivingMediaDriver.java : 4.4 KB
- aeron/aeron-client/src/main/cpp/ImageControlledFragmentAssembler.h : 4.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/CncFileReader.java : 4.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MultiSubscriberTest.java : 4.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/ReceiveChannelEndpointThreadLocals.java : 4.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/Pong.java : 4.4 KB
- aeron/aeron-client/src/main/cpp/concurrent/broadcast/BroadcastTransmitter.h : 4.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/reports/LossReportReader.java : 4.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/ErrorReportTestUtil.java : 4.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/OptimalMulticastDelayGenerator.java : 4.3 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/buffer/FileStoreLogFactoryTest.java : 4.3 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/WriteReceiveUdpPing.java : 4.3 KB
- aeron/aeron-archive/src/main/cpp/client/ControlResponsePoller.cpp : 4.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/broadcast/BroadcastReceiver.h : 4.3 KB
- aeron/aeron-client/src/test/cpp/util/UtilTest.cpp : 4.3 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/CatalogViewTest.java : 4.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/DebugChannelEndpointConfiguration.java : 4.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_distinct_error_log.h : 4.3 KB
- aeron/aeron-driver/src/main/c/aeron_loss_detector.h : 4.2 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/SendReceiveUdpPing.java : 4.2 KB
- aeron/aeron-client/src/main/java/io/aeron/command/TerminateDriverFlyweight.java : 4.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SystemCounterDescriptor.java : 4.2 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingSignalAdapter.cpp : 4.2 KB
- aeron/aeron-client/src/main/java/io/aeron/status/ChannelEndpointStatus.java : 4.2 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_logbuffer_descriptor.c : 4.2 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingEventsPoller.cpp : 4.2 KB
- aeron/aeron-client/src/main/cpp/ExclusivePublication.cpp : 4.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/DebugReceiveChannelEndpoint.java : 4.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ControlRequestDecoders.java : 4.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/UdpNameResolutionTransport.java : 4.1 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/HeaderWriter.java : 4.1 KB
- aeron/aeron-driver/src/main/c/aeron_position.h : 4.1 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/TermGapScannerTest.java : 4.1 KB
- aeron/aeron-client/src/main/c/aeron_subscription.h : 4.1 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ClusterEventEncoder.java : 4.1 KB
- aeron/aeron-client/src/main/c/aeron_exclusive_publication.h : 4.1 KB
- aeron/aeron-archive/src/main/cpp/client/ControlResponseAdapter.cpp : 4.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/ImageRateSubscriber.java : 4.1 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_unblocker.c : 4.0 KB
- aeron/aeron-client/src/main/cpp/util/StringUtil.h : 4.0 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingEventsAdapter.cpp : 4.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/ReplayedBasicSubscriber.java : 4.0 KB
- aeron/aeron-client/src/test/cpp/ChannelUriTest.cpp : 4.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/IngressSessionDecorator.java : 4.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/SampleAuthenticator.java : 4.0 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ClusterEventLogger.java : 4.0 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/MultiNodeTest.java : 4.0 KB
- aeron/aeron-driver/src/test/c/aeron_name_resolver_cache_test.cpp : 3.9 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/CommonEventDissectorTest.java : 3.9 KB
- aeron/aeron-client/src/main/cpp/util/CommandOption.cpp : 3.9 KB
- aeron/aeron-driver/src/main/c/aeron_driver_sender.h : 3.9 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/DriverTool.java : 3.9 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_appender.c : 3.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/CatalogView.java : 3.9 KB
- aeron/aeron-client/src/main/cpp/Publication.cpp : 3.8 KB
- aeron/.github/workflows/ci-low-cadence.yml : 3.8 KB
- aeron/aeron-driver/src/main/c/aeronmd.c : 3.8 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermScanner.java : 3.8 KB
- aeron/aeron-client/src/main/cpp/concurrent/reports/LossReportDescriptor.h : 3.8 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/LogReplay.java : 3.8 KB
- aeron/aeron-client/src/main/cpp/BufferBuilder.h : 3.8 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingSignalAdapter.h : 3.8 KB
- aeron/aeron-client/src/main/cpp/command/SubscriptionMessageFlyweight.h : 3.8 KB
- aeron/aeron-client/src/main/cpp/ImageFragmentAssembler.h : 3.8 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/TimerService.java : 3.8 KB
- aeron/aeron-client/src/main/c/util/aeron_dlopen.c : 3.7 KB
- aeron/aeron-client/src/test/java/io/aeron/DriverProxyTest.java : 3.7 KB
- aeron/aeron-client/src/main/c/aeron_agent.h : 3.7 KB
- aeron/buildSrc/src/main/java/io/aeron/build/TutorialPublishTask.java : 3.7 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/checksum/ChecksumsTest.java : 3.7 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/ClusterClock.java : 3.7 KB
- aeron/aeron-client/src/main/java/io/aeron/command/ControlProtocolEvents.java : 3.7 KB
- aeron/aeron-client/src/main/cpp/HeartbeatTimestamp.h : 3.7 KB
- aeron/aeron-samples/src/main/cpp/RateReporter.h : 3.7 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingEventsAdapter.h : 3.7 KB
- aeron/aeron-client/src/main/java/io/aeron/command/CorrelatedMessageFlyweight.java : 3.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/BackOffIdleStrategy.h : 3.6 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/SelectReceiveSendUdpPong.java : 3.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/atomic/Atomic64_msvc.h : 3.6 KB
- aeron/aeron-client/src/main/cpp/command/ImageMessageFlyweight.h : 3.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/MaxPositionPublicationTest.java : 3.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/errors/ErrorLogDescriptor.h : 3.6 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_broadcast_transmitter.c : 3.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/AtomicArrayUpdater.h : 3.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/DistinctErrorLogTestWatcher.java : 3.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/DebugSendChannelEndpoint.java : 3.6 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_exclusive_term_appender.c : 3.6 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_broadcast_receiver.h : 3.6 KB
- aeron/aeron-archive/src/main/cpp/client/RecordingEventsPoller.h : 3.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/ReceiveDestinationTransport.java : 3.6 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ArchiveException.java : 3.6 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/package-info.java : 3.5 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ServiceAdapter.java : 3.5 KB
- aeron/aeron-client/src/main/cpp/concurrent/AgentInvoker.h : 3.5 KB
- aeron/aeron-archive/src/main/cpp/client/ControlResponseAdapter.h : 3.5 KB
- aeron/aeron-client/src/main/cpp/command/ErrorResponseFlyweight.h : 3.5 KB
- aeron/aeron-client/src/main/c/util/aeron_fileutil.h : 3.5 KB
- aeron/aeron-samples/src/main/cpp/raw/TimeTests.cpp : 3.5 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ListRecordingSubscriptionsSession.java : 3.5 KB
- aeron/aeron-client/src/main/java/io/aeron/Counter.java : 3.5 KB
- aeron/aeron-driver/src/main/c/aeron_driver_conductor_proxy.h : 3.5 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/reports/LossReportReaderTest.java : 3.5 KB
- aeron/aeron-cluster/src/main/resources/cluster/aeron-cluster-mark-codecs.xml : 3.5 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/SegmentInspector.java : 3.5 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/TestBackupNode.java : 3.5 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/BasicSubscriber.java : 3.4 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermGapScanner.java : 3.4 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ClusterEventDissector.java : 3.4 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/reports/LossReportTest.java : 3.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/SnapshotRetrieveMonitor.java : 3.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/UnmodifiableClientSessionCollection.java : 3.4 KB
- aeron/aeron-client/src/main/java/io/aeron/ErrorCode.java : 3.4 KB
- aeron/aeron-client/src/main/cpp/command/PublicationMessageFlyweight.h : 3.4 KB
- aeron/aeron-client/src/main/c/aeron_image.h : 3.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/HackSelectReceiveSendUdpPong.java : 3.3 KB
- aeron/aeron-client/src/test/cpp/concurrent/MockAtomicBuffer.h : 3.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/LifecycleTest.java : 3.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/AtomicCounter.h : 3.3 KB
- aeron/aeron-client/src/main/c/util/aeron_netutil.h : 3.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_thread.h : 3.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_broadcast_receiver.c : 3.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_atomic64_gcc_x86_64.h : 3.3 KB
- aeron/aeron-client/src/main/cpp/command/ControlProtocolEvents.h : 3.3 KB
- aeron/aeron-client/src/main/c/util/aeron_bitutil.h : 3.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/TermReader.h : 3.2 KB
- aeron/aeron-client/src/main/cpp/protocol/SetupFlyweight.h : 3.2 KB
- aeron/aeron-driver/src/main/c/aeron_driver_common.h : 3.2 KB
- aeron/aeron-client/src/main/java/io/aeron/command/SubscriptionReadyFlyweight.java : 3.2 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/ControlledEgressListener.java : 3.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ListRecordingsForUriSession.java : 3.2 KB
- aeron/aeron-driver/src/test/c/aeron_strutil_test.cpp : 3.2 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ArchiveEventLogger.java : 3.2 KB
- aeron/aeron-client/src/test/cpp/CMakeLists.txt : 3.2 KB
- aeron/aeron-client/src/main/c/protocol/aeron_udp_protocol.c : 3.2 KB
- aeron/aeron-client/src/main/cpp/concurrent/reports/LossReportReader.h : 3.2 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_destination_tracker.h : 3.2 KB
- aeron/aeron-client/src/test/java/io/aeron/ChannelUriStringBuilderTest.java : 3.2 KB
- aeron/aeron-driver/src/main/c/aeron_name_resolver.h : 3.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultMulticastFlowControlSupplier.java : 3.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/status/StatusIndicatorReader.h : 3.1 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ClusterEventDissectorTest.java : 3.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/RateSubscriber.java : 3.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/SessionWorker.java : 3.1 KB
- aeron/aeron-client/src/main/java/io/aeron/exceptions/AeronException.java : 3.1 KB
- aeron/cppbuild/cppbuild : 3.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/NetworkPublicationThreadLocals.java : 3.1 KB
- aeron/aeron-client/src/main/java/io/aeron/command/CounterUpdateFlyweight.java : 3.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/ringbuffer/RecordDescriptor.h : 3.1 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ChannelEndpointInterceptor.java : 3.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/TaggedMulticastFlowControl.java : 3.1 KB
- aeron/aeron-archive/src/main/cpp/client/ArchiveException.h : 3.1 KB
- aeron/gradlew.bat : 3.1 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/Common.java : 3.0 KB
- aeron/aeron-client/src/main/c/aeron_publication.h : 3.0 KB
- aeron/aeron-client/src/main/cpp/command/Flyweight.h : 3.0 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/TerminateDriverTest.java : 3.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/ReceiveSendUdpPong.java : 3.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusterCounters.java : 3.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/FlowControl.java : 3.0 KB
- aeron/aeron-client/src/main/java/io/aeron/command/RemoveMessageFlyweight.java : 3.0 KB
- aeron/aeron-client/src/main/cpp/command/TerminateDriverFlyweight.h : 3.0 KB
- aeron/aeron-client/src/main/c/util/aeron_strutil.c : 3.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/ReceiveWriteUdpPong.java : 3.0 KB
- aeron/aeron-driver/src/test/c/EmbeddedMediaDriver.h : 3.0 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_atomic64_msvc.h : 3.0 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/buffer/TestLogFactory.java : 3.0 KB
- aeron/aeron-client/src/main/c/aeron_socket.h : 3.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/checksum/Crc32c.java : 3.0 KB
- aeron/aeron-driver/src/main/c/reports/aeron_loss_reporter.h : 2.9 KB
- aeron/aeron-driver/src/main/c/aeron_congestion_control.h : 2.9 KB
- aeron/aeron-samples/src/main/cpp/CMakeLists.txt : 2.9 KB
- aeron/aeron-driver/src/main/c/aeron_system_counters.h : 2.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/checksum/Checksums.java : 2.9 KB
- aeron/aeron-driver/src/main/c/aeron_driver_sender_proxy.h : 2.9 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/ControlSessionTest.java : 2.9 KB
- aeron/aeron-client/src/main/c/aeron_cnc_file_descriptor.h : 2.9 KB
- aeron/aeron-client/src/main/cpp/protocol/HeaderFlyweight.h : 2.9 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingDescriptorConsumer.java : 2.9 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/ReentrantClientTest.java : 2.9 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermBlockScanner.java : 2.8 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ClusterMemberTest.java : 2.8 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/EgressListener.java : 2.8 KB
- aeron/aeron-client/src/main/c/util/aeron_clock.c : 2.8 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterSessionProxy.java : 2.8 KB
- aeron/aeron-client/src/main/cpp/concurrent/broadcast/CopyBroadcastReceiver.h : 2.8 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultCongestionControlSupplier.java : 2.8 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/SharedModeArchiveConductor.java : 2.8 KB
- aeron/aeron-client/src/main/c/util/aeron_arrayutil.h : 2.8 KB
- aeron/aeron-cluster/README.md : 2.8 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_transport_poller.h : 2.7 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ServiceAck.java : 2.7 KB
- aeron/aeron-client/src/main/java/io/aeron/security/Authenticator.java : 2.7 KB
- aeron/aeron-client/src/main/cpp/protocol/NakFlyweight.h : 2.7 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/TestMediaDriver.java : 2.7 KB
- aeron/aeron-archive/src/main/resources/archive/aeron-archive-mark-codecs.xml : 2.7 KB
- aeron/aeron-client/src/main/c/aeron_fragment_assembler.h : 2.7 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/LogBufferUnblocker.java : 2.7 KB
- aeron/aeron-client/src/main/cpp/LogBuffers.cpp : 2.7 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ClusterInterceptor.java : 2.6 KB
- aeron/aeron-client/src/main/cpp/protocol/DataHeaderFlyweight.h : 2.6 KB
- aeron/aeron-driver/src/main/c/concurrent/aeron_logbuffer_unblocker.c : 2.6 KB
- aeron/aeron-client/src/main/cpp/util/MemoryMappedFile.h : 2.6 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/JavaTestMediaDriver.java : 2.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/PendingSetupMessageFromSource.java : 2.6 KB
- aeron/aeron-client/src/main/cpp/util/CommandOptionParser.cpp : 2.6 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/EventConfigurationTest.java : 2.6 KB
- aeron/aeron-client/src/main/cpp/command/RemoveMessageFlyweight.h : 2.6 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_gap_scanner.h : 2.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/broadcast/RecordDescriptor.h : 2.6 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/checksum/Crc32.java : 2.6 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/checksum/Crc32cTest.java : 2.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/StaticWindowCongestionControl.java : 2.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/status/LocalSocketAddressStatus.h : 2.5 KB
- aeron/aeron-client/src/main/cpp/Subscription.cpp : 2.5 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ClusterEventCode.java : 2.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/AeronClient.java : 2.5 KB
- aeron/aeron-samples/scripts/archive/README.md : 2.5 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/DataFrameHeader.h : 2.5 KB
- aeron/aeron-driver/src/main/c/aeron_retransmit_handler.h : 2.5 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/DefaultMulticastFlowControlSupplierTest.java : 2.5 KB
- aeron/aeron-client/src/main/cpp/command/SubscriptionReadyFlyweight.h : 2.5 KB
- aeron/aeron-client/src/test/java/io/aeron/logbuffer/ExclusiveTermAppenderTest.java : 2.5 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/RecordingExtent.java : 2.5 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/LossReportTestUtil.java : 2.4 KB
- aeron/aeron-client/src/main/c/collections/aeron_int64_counter_map.c : 2.4 KB
- aeron/aeron-driver/src/main/c/agent/aeron_driver_agent.h : 2.4 KB
- aeron/aeron-client/src/main/cpp/command/CorrelatedMessageFlyweight.h : 2.4 KB
- aeron/aeron-client/src/main/cpp/command/CounterUpdateFlyweight.h : 2.4 KB
- aeron/aeron-client/src/main/cpp/concurrent/errors/ErrorLogReader.h : 2.4 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/TermBlockScanner.h : 2.4 KB
- aeron/aeron-samples/src/test/java/io/aeron/samples/LogInspectorAsciiFormatBytesTest.java : 2.4 KB
- aeron/aeron-client/src/main/java/io/aeron/command/OperationSucceededFlyweight.java : 2.4 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_rb.h : 2.4 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/AgentTests.java : 2.4 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/ControlledFragmentHandler.java : 2.4 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/ErrorStat.java : 2.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ServiceSnapshotTaker.java : 2.4 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel_transport.h : 2.4 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/TermScanner.h : 2.4 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/SingleNodeTest.java : 2.3 KB
- aeron/aeron-client/src/main/c/aeron_alloc.c : 2.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/MaxMulticastFlowControl.java : 2.3 KB
- aeron/aeron-client/src/main/java/io/aeron/exceptions/RegistrationException.java : 2.3 KB
- aeron/aeron-client/src/main/c/aeron_context.h : 2.3 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermGapFiller.java : 2.3 KB
- aeron/aeron-driver/src/main/c/media/aeron_receive_destination.h : 2.3 KB
- aeron/aeron-client/src/main/java/io/aeron/command/ClientTimeoutFlyweight.java : 2.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/TermBufferLengthTest.java : 2.3 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ListRecordingsSession.java : 2.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/reports/LossReportUtil.java : 2.3 KB
- aeron/aeron-client/src/test/java/io/aeron/command/CounterMessageFlyweightTest.java : 2.3 KB
- aeron/aeron-client/src/main/c/util/aeron_http_util.h : 2.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/PerImageIndicator.java : 2.3 KB
- aeron/aeron-client/src/main/cpp/util/CommandOption.h : 2.3 KB
- aeron/aeron-driver/src/main/c/README.md : 2.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/buffer/RawLog.java : 2.2 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/SpecifiedPositionPublicationTest.java : 2.2 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/StubClusteredService.java : 2.2 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterTermination.java : 2.2 KB
- aeron/aeron-samples/README.md : 2.2 KB
- aeron/aeron-client/src/test/cpp/ChannelUriStringBuilderTest.cpp : 2.2 KB
- aeron/aeron-driver/src/main/c/aeron_name_resolver_cache.h : 2.2 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/AppointedLeaderTest.java : 2.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/UnicastFlowControl.java : 2.2 KB
- aeron/aeron-client/src/main/c/aeron_counter.c : 2.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/NameResolver.java : 2.2 KB
- aeron/aeron-client/src/main/cpp/command/DestinationMessageFlyweight.h : 2.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ControlSessionProxy.java : 2.2 KB
- aeron/aeron-driver/src/main/c/aeron_termination_validator.c : 2.1 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackupEventsListener.java : 2.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/CongestionControlSupplier.java : 2.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/TermGapScanner.h : 2.1 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_spsc_concurrent_array_queue.c : 2.1 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel.h : 2.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/PublicationLink.java : 2.1 KB
- aeron/aeron-client/src/test/cpp/util/MemoryMappedFileTest.cpp : 2.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/CubicCongestionControlConfiguration.java : 2.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingEventsListener.java : 2.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/CubicCongestionControlSupplier.java : 2.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultUnicastFlowControlSupplier.java : 2.1 KB
- aeron/aeron-client/src/main/c/collections/aeron_int64_to_tagged_ptr_hash_map.c : 2.1 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_mpsc_concurrent_array_queue.c : 2.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/MigrationUtils.java : 2.1 KB
- aeron/aeron-client/src/main/java/io/aeron/DriverEventsListener.java : 2.0 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_mpsc_rb.h : 2.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/AbstractListRecordingsSession.java : 2.0 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_scanner.h : 2.0 KB
- aeron/aeron-client/src/main/cpp/command/OperationSucceededFlyweight.h : 2.0 KB
- aeron/aeron-client/src/test/c/aeron_client_test_utils.h : 2.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveMigrationPlanner.java : 2.0 KB
- aeron/buildSrc/src/main/java/io/aeron/build/GithubUtil.java : 2.0 KB
- aeron/aeron-client/src/main/cpp/Counter.h : 2.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/ImageRateReporter.java : 2.0 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/TermRebuilder.java : 2.0 KB
- aeron/aeron-client/src/main/cpp/util/MacroUtil.h : 2.0 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ActiveLogEvent.java : 2.0 KB
- aeron/aeron-client/src/main/cpp/concurrent/ringbuffer/RingBufferDescriptor.h : 2.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/package-info.java : 2.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SystemCounters.java : 2.0 KB
- aeron/aeron-client/src/main/cpp/command/ClientTimeoutFlyweight.h : 2.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/LossStat.java : 2.0 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/SetControllableIdleStrategy.java : 2.0 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/test/StubCsvNameResolver.java : 2.0 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/HeaderWriter.h : 1.9 KB
- aeron/aeron-client/src/main/cpp/concurrent/status/UnsafeBufferPosition.h : 1.9 KB
- aeron/aeron-client/src/main/c/util/aeron_clock.h : 1.9 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/ClientHeartbeatTimestamp.java : 1.9 KB
- aeron/aeron-driver/src/test/c/aeron_driver_conductor_clock_test.cpp : 1.9 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/SubscriberPosition.java : 1.9 KB
- aeron/aeron-client/src/test/java/io/aeron/command/TerminateDriverFlyweightTest.java : 1.9 KB
- aeron/config/ide/idea/aeron.xml : 1.9 KB
- aeron/aeron-client/src/main/cpp/Context.cpp : 1.9 KB
- aeron/aeron-driver/src/test/c/aeron_driver_configuration_test.cpp : 1.9 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/checksum/Crc32Test.java : 1.9 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SubscriberPos.java : 1.9 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/LowLatencyMediaDriver.java : 1.8 KB
- aeron/aeron-client/src/main/c/util/aeron_strutil.h : 1.8 KB
- aeron/cppbuild/cppbuild-vs.cmd : 1.8 KB
- aeron/aeron-client/src/main/c/collections/aeron_str_to_ptr_hash_map.c : 1.8 KB
- aeron/aeron-client/src/main/java/io/aeron/ReservedValueSupplier.java : 1.8 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/SessionKey.java : 1.8 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SenderBpe.java : 1.8 KB
- aeron/aeron-driver/src/main/c/media/aeron_udp_channel_transport_loss.h : 1.8 KB
- aeron/aeron-client/src/main/java/io/aeron/security/DefaultAuthenticatorSupplier.java : 1.8 KB
- aeron/aeron-client/src/main/c/collections/aeron_int64_to_ptr_hash_map.c : 1.8 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/CleanupInterceptor.java : 1.8 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_rebuilder.h : 1.8 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/RawBlockHandler.java : 1.8 KB
- aeron/aeron-client/src/test/c/CMakeLists.txt : 1.8 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/RandomLossGenerator.java : 1.7 KB
- aeron/aeron-client/src/main/c/aeron_log_buffer.c : 1.7 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_spsc_rb.h : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/buffer/LogFactory.java : 1.7 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_broadcast_descriptor.h : 1.7 KB
- aeron/aeron-driver/src/main/c/aeron_driver.h : 1.7 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/FailControlResponseListener.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/ReceiverHwm.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/PublisherPos.java : 1.7 KB
- aeron/aeron-client/src/main/java/io/aeron/security/SessionProxy.java : 1.7 KB
- aeron/aeron-client/src/main/java/io/aeron/exceptions/TimeoutException.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/UdpTransportPoller.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/PublisherLimit.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/MinMulticastFlowControl.java : 1.7 KB
- aeron/aeron-client/src/main/cpp/util/ScopeUtils.h : 1.7 KB
- aeron/aeron-samples/scripts/cluster/basic-auction-cluster : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/StaticDelayGenerator.java : 1.7 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/MediaDriverTest.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/CounterLink.java : 1.7 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/ServiceIpcIngressTest.java : 1.7 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/ReceiverPos.java : 1.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DriverManagedResource.java : 1.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/Subscribable.java : 1.6 KB
- aeron/aeron-client/src/main/c/util/aeron_parse_util.h : 1.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ReceiveChannelEndpointSupplier.java : 1.6 KB
- aeron/aeron-samples/src/main/cpp/Configuration.h : 1.6 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_gap_filler.c : 1.6 KB
- aeron/aeron-client/src/main/c/aeron_version.c : 1.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/NetworkInterfaceShim.java : 1.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SenderPos.java : 1.6 KB
- aeron/aeron-samples/scripts/cluster/basic-auction-client : 1.6 KB
- aeron/aeron-client/src/main/c/util/aeron_properties_util.h : 1.6 KB
- aeron/aeron-driver/src/main/c/aeron_driver_name_resolver.h : 1.6 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SenderLimit.java : 1.6 KB
- aeron/aeron-client/src/test/cpp/util/TestUtils.h : 1.6 KB
- aeron/aeron-client/src/main/cpp/concurrent/broadcast/BroadcastBufferDescriptor.h : 1.6 KB
- aeron/aeron-test-support/src/main/java/io/aeron/test/CountingFragmentHandler.java : 1.6 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/NanosecondClusterClock.java : 1.5 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingSignalConsumer.java : 1.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/PreferredMulticastFlowControl.java : 1.5 KB
- aeron/aeron-client/src/main/java/io/aeron/security/CredentialsSupplier.java : 1.5 KB
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/Samples.java : 1.5 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ControlEventListener.java : 1.5 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/EventCodeType.java : 1.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/ReceiveLocalSocketAddress.java : 1.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/ReceiveChannelStatus.java : 1.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SendLocalSocketAddress.java : 1.5 KB
- aeron/aeron-samples/scripts/archive/embedded-recording-throughput.bat : 1.5 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/FragmentHandler.java : 1.5 KB
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/BlockHandler.java : 1.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ThreadingMode.java : 1.5 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/SendChannelStatus.java : 1.5 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/ClusterException.java : 1.5 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/ControlInterceptor.java : 1.5 KB
- aeron/aeron-samples/scripts/archive/embedded-recording-throughput : 1.5 KB
- aeron/aeron-client/src/main/c/collections/aeron_bit_set.c : 1.5 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusterNodeControlProperties.java : 1.5 KB
- aeron/aeron-client/src/main/java/io/aeron/security/AuthenticationException.java : 1.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/SendChannelEndpointSupplier.java : 1.4 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/FlowControlTests.java : 1.4 KB
- aeron/aeron-samples/scripts/archive/embedded-replay-throughput : 1.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/DebugReceiveChannelEndpointSupplier.java : 1.4 KB
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/MillisecondClusterClock.java : 1.4 KB
- aeron/aeron-driver/src/test/c/aeron_system_test.cpp : 1.4 KB
- aeron/aeron-samples/scripts/archive/embedded-replay-throughput.bat : 1.4 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/RecordingSubscriptionDescriptorConsumer.java : 1.4 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/OptimalMulticastDelayGeneratorTest.java : 1.4 KB
- aeron/aeron-cluster/src/test/java/io/aeron/cluster/TestClusterClock.java : 1.4 KB
- aeron/aeron-client/src/main/cpp/LogBuffers.h : 1.4 KB
- aeron/aeron-client/src/main/cpp/util/LangUtil.h : 1.4 KB
- aeron/aeron-client/src/main/c/util/aeron_dlopen.h : 1.4 KB
- aeron/aeron-client/src/main/c/util/aeron_math.h : 1.4 KB
- aeron/aeron-client/src/main/c/aeron_cnc_file_descriptor.c : 1.4 KB
- aeron/aeron-archive/src/test/cpp/CMakeLists.txt : 1.4 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/TerminationValidator.java : 1.4 KB
- aeron/aeron-client/src/main/java/io/aeron/AvailableCounterHandler.java : 1.4 KB
- aeron/aeron-client/src/main/java/io/aeron/UnavailableCounterHandler.java : 1.3 KB
- aeron/buildSrc/src/main/java/io/aeron/build/AsciidocUtil.java : 1.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/status/ReadablePosition.h : 1.3 KB
- aeron/aeron-agent/README.md : 1.3 KB
- aeron/aeron-samples/scripts/embedded-ping-pong.bat : 1.3 KB
- aeron/aeron-system-tests/src/test/java/io/aeron/ClientContextTest.java : 1.3 KB
- aeron/aeron-client/src/main/c/aeron_counter.h : 1.3 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_broadcast_transmitter.h : 1.3 KB
- aeron/aeron-samples/scripts/embedded-exclusive-spied-throughput.bat : 1.3 KB
- aeron/aeron-client/src/main/c/aeron_windows.h : 1.3 KB
- aeron/aeron-samples/scripts/embedded-dual-exclusive-throughput.bat : 1.3 KB
- aeron/aeron-archive/src/test/java/io/aeron/archive/FailRecordingEventsListener.java : 1.3 KB
- aeron/aeron-samples/scripts/embedded-exclusive-throughput.bat : 1.3 KB
- aeron/aeron-samples/scripts/embedded-ping-pong : 1.3 KB
- aeron/aeron-samples/scripts/embedded-throughput.bat : 1.3 KB
- aeron/aeron-client/src/main/cpp/Counter.cpp : 1.3 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/SimpleFragmentHandler.java : 1.3 KB
- aeron/aeron-samples/scripts/embedded-exclusive-spied-throughput : 1.3 KB
- aeron/aeron-samples/scripts/embedded-dual-exclusive-throughput : 1.3 KB
- aeron/aeron-samples/scripts/embedded-exclusive-throughput : 1.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/SleepingIdleStrategy.h : 1.3 KB
- aeron/aeron-samples/scripts/embedded-throughput : 1.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultReceiveChannelEndpointSupplier.java : 1.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/DebugSendChannelEndpointSupplier.java : 1.3 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultNameResolver.java : 1.3 KB
- aeron/aeron-client/src/main/cpp/concurrent/logbuffer/TermRebuilder.h : 1.3 KB
- aeron/aeron-client/src/test/java/io/aeron/protocol/HeaderFlyweightTest.java : 1.3 KB
- aeron/aeron-agent/src/main/java/io/aeron/agent/package-info.java : 1.3 KB
- aeron/aeron-client/src/main/c/util/aeron_platform.h : 1.2 KB
- aeron/aeron-driver/src/test/java/io/aeron/driver/MediaDriverContextTest.java : 1.2 KB
- aeron/aeron-client/src/main/cpp/util/Platform.h : 1.2 KB
- aeron/aeron-client/src/main/cpp/concurrent/Atomic64.h : 1.2 KB
- aeron/CONTRIBUTING.md : 1.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/LossGenerator.java : 1.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/FlowControlSupplier.java : 1.2 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_term_unblocker.h : 1.2 KB
- aeron/aeron-client/src/main/c/aeron_common.h : 1.2 KB
- aeron/aeron-client/src/main/c/util/aeron_error.h : 1.2 KB
- aeron/aeron-samples/scripts/ping.bat : 1.2 KB
- aeron/aeron-client/src/main/cpp/util/CommandOptionParser.h : 1.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultSendChannelEndpointSupplier.java : 1.2 KB
- aeron/aeron-client/src/main/java/io/aeron/BufferBuilderUtil.java : 1.2 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveThreadingMode.java : 1.2 KB
- aeron/aeron-samples/scripts/ping : 1.2 KB
- aeron/aeron-client/src/main/java/io/aeron/UnavailableImageHandler.java : 1.2 KB
- aeron/aeron-client/src/main/java/io/aeron/exceptions/ChannelEndpointException.java : 1.2 KB
- aeron/aeron-client/src/main/java/io/aeron/AvailableImageHandler.java : 1.2 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/ImageConnection.java : 1.2 KB
- aeron/aeron-client/src/main/cpp/util/Index.h : 1.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/BusySpinIdleStrategy.h : 1.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/checksum/Checksum.java : 1.1 KB
- aeron/aeron-samples/scripts/embedded-exclusive-vectored-ipc-throughput.bat : 1.1 KB
- aeron/aeron-client/src/main/c/util/aeron_arrayutil.c : 1.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/status/Position.h : 1.1 KB
- aeron/aeron-samples/scripts/pong.bat : 1.1 KB
- aeron/aeron-driver/src/main/c/aeron_termination_validator.h : 1.1 KB
- aeron/aeron-client/src/main/java/io/aeron/exceptions/ControlProtocolException.java : 1.1 KB
- aeron/aeron-samples/scripts/embedded-exclusive-vectored-ipc-throughput : 1.1 KB
- aeron/aeron-client/src/main/c/aeron_log_buffer.h : 1.1 KB
- aeron/aeron-client/src/main/cpp/concurrent/YieldingIdleStrategy.h : 1.1 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/PreferredMulticastFlowControlSupplier.java : 1.1 KB
- aeron/aeron-samples/scripts/pong : 1.1 KB
- aeron/aeron-samples/scripts/embedded-exclusive-claim-ipc-throughput.bat : 1.1 KB
- aeron/aeron-client/src/main/java/io/aeron/security/NullCredentialsSupplier.java : 1.1 KB
- aeron/aeron-samples/scripts/embedded-exclusive-ipc-throughput.bat : 1.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/Session.java : 1.1 KB
- aeron/aeron-samples/scripts/embedded-exclusive-claim-ipc-throughput : 1.1 KB
- aeron/aeron-client/src/main/cpp/util/Export.h : 1.1 KB
- aeron/aeron-samples/scripts/streaming-publisher.bat : 1.1 KB
- aeron/aeron-samples/scripts/embedded-ipc-throughput.bat : 1.1 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/checksum/package-info.java : 1.1 KB
- aeron/aeron-samples/scripts/embedded-exclusive-ipc-throughput : 1.1 KB
- aeron/aeron-samples/scripts/low-latency-media-driver.bat : 1.1 KB
- aeron/.github/workflows/release.yml : 1.1 KB
- aeron/aeron-samples/scripts/embedded-ipc-throughput : 1.1 KB
- aeron/aeron-samples/scripts/streaming-publisher : 1.1 KB
- aeron/aeron-samples/scripts/low-latency-c-media-driver : 1.1 KB
- aeron/aeron-samples/scripts/embedded-claim-ipc-throughput.bat : 1.1 KB
- aeron/aeron-samples/scripts/archive/archiving-media-driver.bat : 1.1 KB
- aeron/aeron-samples/scripts/low-latency-media-driver : 1.0 KB
- aeron/aeron-client/src/main/java/io/aeron/LogBuffersFactory.java : 1.0 KB
- aeron/aeron-archive/src/main/java/io/aeron/archive/RecordingSummary.java : 1.0 KB
- aeron/aeron-client/src/test/java/io/aeron/CommonContextTest.java : 1.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/exceptions/InvalidChannelException.java : 1.0 KB
- aeron/aeron-samples/scripts/embedded-claim-ipc-throughput : 1.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/LossHandler.java : 1.0 KB
- aeron/aeron-samples/scripts/rate-subscriber.bat : 1.0 KB
- aeron/aeron-samples/scripts/archive/archiving-media-driver : 1.0 KB
- aeron/aeron-client/src/main/c/aeron_client.h : 1.0 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ClusterEventCodeTest.java : 1.0 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/ArchiveEventCodeTest.java : 1.0 KB
- aeron/aeron-samples/scripts/rate-subscriber : 1.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/TaggedMulticastFlowControlSupplier.java : 1.0 KB
- aeron/aeron-agent/src/test/java/io/aeron/agent/DriverEventCodeTest.java : 1.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/MaxMulticastFlowControlSupplier.java : 1.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/FeedbackDelayGenerator.java : 1.0 KB
- aeron/aeron-samples/scripts/archive/logging-archiving-media-driver.bat : 1.0 KB
- aeron/aeron-driver/src/main/java/io/aeron/driver/MinMulticastFlowControlSupplier.java : 1.0 KB
- aeron/aeron-client/src/main/c/concurrent/aeron_atomic.h : 1.0 KB
- aeron/aeron-driver/src/test/c/util/aeron_bitutil_test.cpp : 996 B
- aeron/aeron-client/src/test/java/io/aeron/BufferBuilderUtilTest.java : 995 B
- aeron/aeron-client/src/main/c/concurrent/aeron_atomic.c : 995 B
- aeron/aeron-client/src/main/c/util/aeron_env.c : 992 B
- aeron/aeron-samples/scripts/archive/logging-archiving-media-driver : 989 B
- aeron/aeron-client/src/main/java/io/aeron/package-info.java : 986 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/RetransmitSender.java : 973 B
- aeron/aeron-driver/src/main/c/concurrent/aeron_logbuffer_unblocker.h : 973 B
- aeron/aeron-samples/scripts/cluster/script-common : 971 B
- aeron/aeron-client/src/main/c/concurrent/aeron_term_gap_filler.h : 966 B
- aeron/aeron-client/src/main/c/concurrent/aeron_concurrent_array_queue.h : 963 B
- aeron/aeron-test-support/src/main/java/io/aeron/test/SlowTest.java : 956 B
- aeron/aeron-system-tests/src/test/java/io/aeron/test/DriverOutputConsumer.java : 952 B
- aeron/aeron-samples/scripts/logging-media-driver.bat : 945 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultDenyTerminationValidator.java : 945 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/DefaultAllowTerminationValidator.java : 945 B
- aeron/aeron-client/src/main/c/aeron_alloc.h : 944 B
- aeron/.gitignore : 942 B
- aeron/aeron-agent/src/main/java/io/aeron/agent/DissectFunction.java : 936 B
- aeron/aeron-client/src/main/cpp/concurrent/NoOpIdleStrategy.h : 935 B
- aeron/aeron-samples/scripts/logging-media-driver : 933 B
- aeron/aeron-agent/src/main/java/io/aeron/agent/EventCode.java : 916 B
- aeron/aeron-test-support/src/main/java/io/aeron/test/IgnoreStdErr.java : 912 B
- aeron/aeron-client/src/main/java/io/aeron/exceptions/ConductorServiceTimeoutException.java : 910 B
- aeron/aeron-archive/src/main/java/io/aeron/archive/CatalogTool.java : 906 B
- aeron/aeron-client/src/main/java/io/aeron/exceptions/DriverTimeoutException.java : 904 B
- aeron/aeron-client/src/test/cpp/concurrent/MockAtomicBuffer.cpp : 896 B
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/SampleAuthenticatorSupplier.java : 892 B
- aeron/aeron-client/src/main/c/concurrent/aeron_term_gap_scanner.c : 892 B
- aeron/aeron-samples/scripts/throughput-c-media-driver : 887 B
- aeron/aeron-client/src/main/java/io/aeron/exceptions/ClientTimeoutException.java : 883 B
- aeron/aeron-client/src/main/java/io/aeron/exceptions/ConcurrentConcludeException.java : 878 B
- aeron/aeron-client/src/main/c/util/aeron_bitutil.c : 875 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/package-info.java : 864 B
- aeron/aeron-client/src/main/java/io/aeron/MappedLogBuffersFactory.java : 861 B
- aeron/aeron-client/src/main/c/collections/aeron_map.h : 855 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/exceptions/UnknownSubscriptionException.java : 853 B
- aeron/aeron-samples/scripts/ipc-c-media-driver : 851 B
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/service/package-info.java : 850 B
- aeron/aeron-samples/scripts/loss-rate-c-media-driver : 844 B
- aeron/aeron-archive/src/main/java/io/aeron/archive/ArchiveMigrationStep.java : 842 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/exceptions/ActiveDriverException.java : 839 B
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/ControlResponseListener.java : 829 B
- aeron/aeron-client/src/main/java/io/aeron/security/AuthenticatorSupplier.java : 828 B
- aeron/aeron-samples/scripts/archive/replayed-basic-subscriber.bat : 826 B
- aeron/aeron-samples/scripts/archive/recorded-basic-publisher.bat : 825 B
- aeron/aeron-samples/scripts/archive/segment-inspector.bat : 822 B
- aeron/aeron-client/src/main/c/util/aeron_math.c : 822 B
- aeron/aeron-samples/scripts/archive/replayed-basic-subscriber : 815 B
- aeron/aeron-samples/scripts/archive/recorded-basic-publisher : 814 B
- aeron/aeron-samples/scripts/archive/segment-inspector : 812 B
- aeron/aeron-samples/scripts/media-driver.bat : 804 B
- aeron/aeron-samples/scripts/log-inspector.bat : 804 B
- aeron/aeron-samples/scripts/file-receiver.bat : 804 B
- aeron/aeron-samples/scripts/basic-subscriber.bat : 804 B
- aeron/aeron-samples/scripts/basic-publisher.bat : 803 B
- aeron/aeron-samples/scripts/stream-stat.bat : 802 B
- aeron/aeron-samples/scripts/file-sender.bat : 802 B
- aeron/aeron-samples/scripts/aeron-stat.bat : 801 B
- aeron/aeron-samples/scripts/backlog-stat.bat : 800 B
- aeron/aeron-samples/scripts/error-stat.bat : 798 B
- aeron/aeron-samples/scripts/loss-stat.bat : 797 B
- aeron/aeron-client/src/main/c/concurrent/aeron_term_scanner.c : 795 B
- aeron/aeron-samples/scripts/log-inspector : 794 B
- aeron/aeron-samples/scripts/file-receiver : 794 B
- aeron/aeron-samples/scripts/media-driver : 793 B
- aeron/aeron-samples/scripts/stream-stat : 792 B
- aeron/aeron-samples/scripts/file-sender : 792 B
- aeron/aeron-samples/scripts/basic-subscriber : 792 B
- aeron/aeron-samples/scripts/basic-publisher : 791 B
- aeron/aeron-samples/scripts/aeron-stat : 791 B
- aeron/aeron-client/src/main/java/io/aeron/exceptions/ConfigurationException.java : 790 B
- aeron/aeron-samples/scripts/backlog-stat : 788 B
- aeron/run-ci-tests.sh : 786 B
- aeron/aeron-samples/scripts/error-stat : 786 B
- aeron/aeron-samples/scripts/loss-stat : 785 B
- aeron/aeron-client/src/test/cpp/ClientConductorFixture.cpp : 785 B
- aeron/aeron-client/src/main/c/util/aeron_env.h : 779 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/ext/package-info.java : 775 B
- aeron/aeron-system-tests/CMakeLists.txt : 766 B
- aeron/cppbuild/centos-docker-build-helper : 765 B
- aeron/aeron-cluster/src/main/java/io/aeron/cluster/client/package-info.java : 764 B
- aeron/aeron-client/src/main/java/io/aeron/security/package-info.java : 761 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/reports/package-info.java : 757 B
- aeron/aeron-archive/src/main/java/io/aeron/archive/client/package-info.java : 750 B
- aeron/aeron-client/src/main/java/io/aeron/command/package-info.java : 749 B
- aeron/aeron-client/src/main/c/concurrent/aeron_term_rebuilder.c : 743 B
- aeron/aeron-samples/scripts/logging-c-media-driver : 739 B
- aeron/aeron-samples/src/main/java/io/aeron/samples/archive/package-info.java : 737 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/exceptions/package-info.java : 732 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/buffer/package-info.java : 732 B
- aeron/aeron-client/src/main/c/collections/aeron_map.c : 729 B
- aeron/aeron-client/src/main/java/io/aeron/logbuffer/package-info.java : 725 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/status/package-info.java : 720 B
- aeron/aeron-samples/src/main/java/io/aeron/samples/package-info.java : 716 B
- aeron/aeron-client/src/main/java/io/aeron/protocol/package-info.java : 713 B
- aeron/aeron-archive/src/main/java/io/aeron/archive/status/package-info.java : 713 B
- aeron/aeron-driver/src/main/java/io/aeron/driver/media/package-info.java : 710 B
- aeron/aeron-samples/src/main/java/io/aeron/samples/raw/package-info.java : 709 B
- aeron/aeron-client/src/main/java/io/aeron/exceptions/package-info.java : 700 B
- aeron/aeron-client/src/main/java/io/aeron/status/package-info.java : 698 B
- aeron/aeron-samples/scripts/archive/high-throughput-archive.properties : 553 B
- aeron/cppbuild/cppbuild-driver-vs.cmd : 506 B
- aeron/aeron-client/README.md : 461 B
- aeron/cppbuild/centos-docker-build : 369 B
- aeron/gradle.properties : 330 B
- aeron/aeron-driver/README.md : 330 B
- aeron/aeron-driver/src/main/resources/low-latency.properties : 325 B
- aeron/aeron-driver/src/main/resources/debug-loss-10.properties : 260 B
- aeron/config/checkstyle/suppressions.xml : 246 B
- aeron/aeron-samples/scripts/archive/standard-archive.properties : 242 B
- aeron/cppbuild/vs-helper.cmd : 238 B
- aeron/aeron-system-tests/README.md : 230 B
- aeron/aeron-samples/scripts/archive/lightweight-archive.properties : 227 B
- aeron/settings.gradle : 203 B
- aeron/aeron-driver/src/main/resources/aeron-throughput.properties : 203 B
- aeron/gradle/wrapper/gradle-wrapper.properties : 202 B
- aeron/buildSrc/build.gradle : 186 B
- aeron/aeron-driver/src/main/resources/high-stream-count.properties : 186 B
- aeron/aeron-driver/src/main/resources/aeron-ipc.properties : 119 B
- aeron/.gitattributes : 108 B
- bindings.h : 46 B
- aeron/version.txt : 6 B