MCPcopy Create free account

hub / github.com/aeron-io/benchmarks / functions

Functions713 in github.com/aeron-io/benchmarks

↓ 47 callersMethodmessageRate
Number of messages to be sent per iteration. @return target message rate per iteration. @implNote Actual number of messages sent can be less than thi
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:274
↓ 40 callersMethodtoString
()
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:384
↓ 35 callersMethodoutputFileNamePrefix
Output file name prefix used for creating the file name to persist the results histogram. @return output file name prefix.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:379
↓ 34 callersMethodmessageTransceiverClass
{@link MessageTransceiver} class to use for the benchmark. @return {@link MessageTransceiver} class.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:309
↓ 33 callersMethodmessageLength
Length in bytes of a single message. @return length in bytes of a single message, defaults to {@link #MIN_MESSAGE_LENGTH}.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:299
↓ 32 callersMethodoutputDirectory
Output directory used for storing the histogram files. @return output directory.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:329
↓ 32 callersMethodpoll
()
benchmarks-api/src/main/java/io/aeron/benchmarks/LoggingPersistedHistogram.java:200
↓ 31 callersMethodwarmupIterations
Number of the warmup iterations, where each iteration has a duration of one second. warmup iterations results will be discarded. @return number of th
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:240
↓ 30 callersMethodbatchSize
Size of the batch, i.e. number of messages to be sent in a single burst. <p> For example if the number of messages is {@code 1000} and the batch size
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:289
↓ 30 callersMethodreset
()
benchmarks-api/src/main/java/io/aeron/benchmarks/ProgressReporter.java:27
↓ 29 callersMethoditerations
Number of the measurement iterations, where each iteration has a duration of one second. @return number of the measurement iterations, defaults to {@
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:250
↓ 26 callersMethodbuild
Create a new instance of the {@link Configuration} class from this builder. @return a {@link Configuration} instance
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:614
↓ 23 callersMethodwarmupMessageRate
Number of messages to be sent per iteration during the warmup period. @return target message rate per iteration during the warmup period. @implNote A
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:262
↓ 21 callersMethodsend
( final int numberOfMessages, final int messageLength, final long timestamp, final long checks
benchmarks-api/src/test/java/io/aeron/benchmarks/LoadTestRigTest.java:63
↓ 19 callersMethodclose
{@inheritDoc}
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:201
↓ 18 callersMethodoffset
(final long index)
benchmarks-api/src/main/java/io/aeron/benchmarks/InMemoryMessageTransceiver.java:104
↓ 15 callersMethodreportProgress
( final long startTimeNs, final long nowNs, final long sentMessages, final int iterations)
benchmarks-api/src/main/java/io/aeron/benchmarks/ProgressReporter.java:22
↓ 14 callersMethodidleStrategy
{@link IdleStrategy} to use when sending and receiving messages. @return sender {@link IdleStrategy}, defaults to {@link NoOpIdleStrategy}.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:319
↓ 14 callersMethodstart
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/Component.java:36
↓ 13 callersMethodonMessageReceived
Callback method to be invoked for every message received. @param timestamp from the received message. @param checksum from the received message.
benchmarks-api/src/main/java/io/aeron/benchmarks/MessageTransceiver.java:145
↓ 13 callersMethodsaveToFile
Save histogram into a file on disc. Uses provided {@code namePrefix} and appending an <em>index</em> to ensure unique name, i.e. {@code namePrefix_ind
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:90
↓ 12 callersMethoddumpAeronStats
(final File cncFile, final Path statsFile, final Path errorFile)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:463
↓ 12 callersMethodputIfProvided
(final Map<String, String> props, final String propName)
benchmarks-kafka/src/main/java/io/aeron/benchmarks/kafka/KafkaConfig.java:148
↓ 11 callersMethodidleStrategy
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:251
↓ 11 callersMethodreceive
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverTransceiver.java:24
↓ 11 callersMethodrun
Run the benchmark and print histogram of the RTT values at the end. @throws Exception in case of any error from the {@link MessageTransceiver}
benchmarks-api/src/main/java/io/aeron/benchmarks/LoadTestRig.java:118
↓ 10 callersMethodawait
(final Future<? extends T> future)
benchmarks-kafka/src/main/java/io/aeron/benchmarks/kafka/KafkaMessageTransceiver.java:212
↓ 10 callersMethodawaitConnected
( final BooleanSupplier connection, final long connectionTimeoutNs, final NanoClock cl
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:425
↓ 10 callersMethodisPropertyProvided
(final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:830
↓ 10 callersMethodloadPropertiesFiles
Load system properties from a given set of filenames or URLs. File is first searched for in resources using the system {@link ClassLoader}, then file
benchmarks-api/src/main/java/io/aeron/benchmarks/PropertiesUtil.java:90
↓ 10 callersMethodmergeWithSystemProperties
Merge a set of properties with the system properties. Use the supplied action to determine the behaviour when a property already exists. @param prope
benchmarks-api/src/main/java/io/aeron/benchmarks/PropertiesUtil.java:109
↓ 10 callersMethodoutputPercentileDistribution
Produce textual representation of the value distribution of histogram data by percentile. The distribution is output with exponentially increasing res
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:74
↓ 10 callersMethodrun
benchmarks-aeron/src/main/cpp/NanoMark.h:276
↓ 10 callersMethodtoString
()
benchmarks-api/src/test/java/io/aeron/benchmarks/PersistedHistogramTest.java:244
↓ 9 callersMethodapply
(final Path path)
benchmarks-api/src/test/java/io/aeron/benchmarks/PersistedHistogramTest.java:239
↓ 9 callersMethodprintingErrorHandler
(final String context)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:454
↓ 8 callersMethodcheckPublicationResult
(final long result)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:444
↓ 8 callersMethodconnectionTimeoutNs
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:149
↓ 8 callersMethodcreateHistogram
(final long startTimeMs, final long endTimeMs, final long... values)
benchmarks-api/src/test/java/io/aeron/benchmarks/ResultsAggregatorTest.java:154
↓ 8 callersMethoddestinationChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:160
↓ 8 callersMethoddestinationStreamId
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:171
↓ 8 callersMethodsourceChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:182
↓ 8 callersMethodsourceStreamId
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:193
↓ 7 callersMethodtrackHistory
Indicate if history should be tracked for the latency test. @return true if history should be tracked.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:349
↓ 7 callersMethodvalueRecorder
Provide a value recorder to be used for measurements. Values recorded through this interface will be persisted by this PersistedHistogram. @return th
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:98
↓ 6 callersMethodassertContains
(final Properties properties, final String... keyOrValue)
benchmarks-api/src/test/java/io/aeron/benchmarks/util/PropertiesUtilTest.java:161
↓ 6 callersMethodbuild
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverConfiguration.java:67
↓ 6 callersMethodcheckValueRange
(final int value, final int minValue, final int maxValue, final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:787
↓ 6 callersMethoddumpArchiveErrors
(final File archiveDir, final Path destFile)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:506
↓ 6 callersMethoddumpClusterErrors
( final Path resultFile, final File clusterDir, final String markFileName, final String linkFileName)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:524
↓ 6 callersMethodmessageTransceiverClass
()
benchmarks-aeron/src/test/java/io/aeron/benchmarks/aeron/EchoTest.java:85
↓ 6 callersFunctionnanoClock
benchmarks-aeron/src/main/cpp/NanoMark.h:53
↓ 6 callersMethodreceivedMessages
()
benchmarks-api/src/main/java/io/aeron/benchmarks/MessageTransceiver.java:52
↓ 6 callersMethodrecordChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:204
↓ 6 callersMethodrecordStream
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:214
↓ 6 callersMethodresolveLogsDir
Resolve directory to store the log files in. @return directory to store the results and the other outputs.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:715
↓ 6 callersMethodsaveToDisc
(final String fileName, final Histogram histogram)
benchmarks-api/src/test/java/io/aeron/benchmarks/ResultsAggregatorTest.java:168
↓ 6 callersMethodstart
benchmarks-aeron/src/main/cpp/EmbeddedAeronMediaDriver.h:66
↓ 6 callersMethodstart
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverControlServer.java:98
↓ 5 callersMethodembeddedMediaDriver
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:246
↓ 5 callersMethodgetPropertyValue
(final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:891
↓ 5 callersMethodlaunchEmbeddedMediaDriverIfConfigured
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:256
↓ 5 callersMethodlogsDir
Directory to store logs and diagnostics files. @return logs dir location.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:339
↓ 5 callersMethodoutputTimeUnit
Output time unit for the latency histogram. Defaults to microseconds. @return latency history time unit.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:369
↓ 5 callersMethodresolveMarkFile
(final File parentDir, final String markFileName, final String linkFileName)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:543
↓ 5 callersMethodsend
(final int iterations, final int numberOfMessages)
benchmarks-api/src/main/java/io/aeron/benchmarks/LoadTestRig.java:188
↓ 4 callersMethodfromSystemProperties
Create a {@link Configuration} instance based on the provided system properties. @return a {@link Configuration} instance.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:625
↓ 4 callersMethodhasNext
()
benchmarks-api/src/main/java/io/aeron/benchmarks/LoggingPersistedHistogram.java:111
↓ 4 callersMethodinit
(Configuration configuration, FailoverListener listener)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverTransceiver.java:22
↓ 4 callersMethodintProperty
(final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:877
↓ 4 callersMethodmessageIndexOffset
(final int n)
benchmarks-api/src/main/java/io/aeron/benchmarks/InMemoryMessageTransceiver.java:83
↓ 4 callersMethodname
benchmarks-aeron/src/main/cpp/NanoMark.h:151
↓ 4 callersMethodreadHistogram
(final Path file)
benchmarks-api/src/test/java/io/aeron/benchmarks/PersistedHistogramTest.java:216
↓ 4 callersMethodreceiverIndex
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:136
↓ 4 callersMethodreplayChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:224
↓ 4 callersMethodreplayStreamId
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:235
↓ 4 callersMethodrun
()
benchmarks-api/src/main/java/io/aeron/benchmarks/ResultsAggregator.java:64
↓ 4 callersMethodstop
benchmarks-aeron/src/main/cpp/EmbeddedAeronMediaDriver.h:60
↓ 4 callersMethodsyncAndLoadHistogram
()
benchmarks-api/src/main/java/io/aeron/benchmarks/LoggingPersistedHistogram.java:153
↓ 4 callersMethodtest
( final int messages, final int messageLength, final int burstSize, final Path
benchmarks-aeron/src/test/java/io/aeron/benchmarks/aeron/ClusterTest.java:95
↓ 4 callersMethodyieldUninterruptedly
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:399
↓ 3 callersMethodgetCommonProperties
()
benchmarks-kafka/src/main/java/io/aeron/benchmarks/kafka/KafkaConfig.java:50
↓ 3 callersMethodinstallSignalHandler
(final Runnable onSignal)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:394
↓ 3 callersMethoditerationsPerRun
benchmarks-aeron/src/main/cpp/NanoMark.h:171
↓ 3 callersMethodlaunchArchiveWithEmbeddedDriver
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/ArchivingMediaDriver.java:46
↓ 3 callersMethodlaunchArchivingMediaDriver
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:268
↓ 3 callersMethodlaunchDriver
(final MediaDriver.Context ctx)
benchmarks-aeron/src/test/java/io/aeron/benchmarks/aeron/EchoTest.java:66
↓ 3 callersMethodloadProperties
( final Properties existingProperties, final PropertyAction propertyAction, final Inpu
benchmarks-api/src/main/java/io/aeron/benchmarks/PropertiesUtil.java:114
↓ 3 callersMethodloadPropertiesFile
Load system properties from a given filename or url. <p> File is first searched for in resources using the system {@link ClassLoader}, then file syste
benchmarks-api/src/main/java/io/aeron/benchmarks/PropertiesUtil.java:41
↓ 3 callersMethodprepareCommand
(final int command)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverControlClient.java:95
↓ 3 callersMethodreceive
Receive one or more messages. @implSpec For every received message method {@link #onMessageReceived(long, long)} <strong>must be</strong> called. @im
benchmarks-api/src/main/java/io/aeron/benchmarks/MessageTransceiver.java:137
↓ 3 callersMethodsaveErrors
(final AtomicBuffer errorBuffer, final Path errorFile)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:570
↓ 3 callersMethodsaveHistoryToCsvFile
( final Path outputDirectory, final String prefix, final Status status, final double... percentiles)
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:132
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ManyToOneRingBufferBenchmark.java:173
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ManyToOneConcurrentArrayQueueBenchmark.java:148
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ConcurrentLinkedQueueBenchmark.java:149
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/LinkedBlockingQueueBenchmark.java:149
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ManyToOneConcurrentLinkedQueueBenchmark.java:149
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/AeronIpcBenchmark.java:207
↓ 3 callersMethodsendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ArrayBlockingQueueBenchmark.java:149
next →1–100 of 713, ranked by callers