Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/aeron-io/benchmarks
/ functions
Functions
713 in github.com/aeron-io/benchmarks
⨍
Functions
713
◇
Types & classes
128
↓ 47 callers
Method
messageRate
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 callers
Method
toString
()
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:384
↓ 35 callers
Method
outputFileNamePrefix
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 callers
Method
messageTransceiverClass
{@link MessageTransceiver} class to use for the benchmark. @return {@link MessageTransceiver} class.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:309
↓ 33 callers
Method
messageLength
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 callers
Method
outputDirectory
Output directory used for storing the histogram files. @return output directory.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:329
↓ 32 callers
Method
poll
()
benchmarks-api/src/main/java/io/aeron/benchmarks/LoggingPersistedHistogram.java:200
↓ 31 callers
Method
warmupIterations
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 callers
Method
batchSize
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 callers
Method
reset
()
benchmarks-api/src/main/java/io/aeron/benchmarks/ProgressReporter.java:27
↓ 29 callers
Method
iterations
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 callers
Method
build
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 callers
Method
warmupMessageRate
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 callers
Method
send
( final int numberOfMessages, final int messageLength, final long timestamp, final long checks
benchmarks-api/src/test/java/io/aeron/benchmarks/LoadTestRigTest.java:63
↓ 19 callers
Method
close
{@inheritDoc}
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:201
↓ 18 callers
Method
offset
(final long index)
benchmarks-api/src/main/java/io/aeron/benchmarks/InMemoryMessageTransceiver.java:104
↓ 15 callers
Method
reportProgress
( final long startTimeNs, final long nowNs, final long sentMessages, final int iterations)
benchmarks-api/src/main/java/io/aeron/benchmarks/ProgressReporter.java:22
↓ 14 callers
Method
idleStrategy
{@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 callers
Method
start
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/Component.java:36
↓ 13 callers
Method
onMessageReceived
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 callers
Method
saveToFile
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 callers
Method
dumpAeronStats
(final File cncFile, final Path statsFile, final Path errorFile)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:463
↓ 12 callers
Method
putIfProvided
(final Map<String, String> props, final String propName)
benchmarks-kafka/src/main/java/io/aeron/benchmarks/kafka/KafkaConfig.java:148
↓ 11 callers
Method
idleStrategy
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:251
↓ 11 callers
Method
receive
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverTransceiver.java:24
↓ 11 callers
Method
run
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 callers
Method
await
(final Future<? extends T> future)
benchmarks-kafka/src/main/java/io/aeron/benchmarks/kafka/KafkaMessageTransceiver.java:212
↓ 10 callers
Method
awaitConnected
( final BooleanSupplier connection, final long connectionTimeoutNs, final NanoClock cl
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:425
↓ 10 callers
Method
isPropertyProvided
(final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:830
↓ 10 callers
Method
loadPropertiesFiles
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 callers
Method
mergeWithSystemProperties
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 callers
Method
outputPercentileDistribution
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 callers
Method
run
benchmarks-aeron/src/main/cpp/NanoMark.h:276
↓ 10 callers
Method
toString
()
benchmarks-api/src/test/java/io/aeron/benchmarks/PersistedHistogramTest.java:244
↓ 9 callers
Method
apply
(final Path path)
benchmarks-api/src/test/java/io/aeron/benchmarks/PersistedHistogramTest.java:239
↓ 9 callers
Method
printingErrorHandler
(final String context)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:454
↓ 8 callers
Method
checkPublicationResult
(final long result)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:444
↓ 8 callers
Method
connectionTimeoutNs
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:149
↓ 8 callers
Method
createHistogram
(final long startTimeMs, final long endTimeMs, final long... values)
benchmarks-api/src/test/java/io/aeron/benchmarks/ResultsAggregatorTest.java:154
↓ 8 callers
Method
destinationChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:160
↓ 8 callers
Method
destinationStreamId
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:171
↓ 8 callers
Method
sourceChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:182
↓ 8 callers
Method
sourceStreamId
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:193
↓ 7 callers
Method
trackHistory
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 callers
Method
valueRecorder
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 callers
Method
assertContains
(final Properties properties, final String... keyOrValue)
benchmarks-api/src/test/java/io/aeron/benchmarks/util/PropertiesUtilTest.java:161
↓ 6 callers
Method
build
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverConfiguration.java:67
↓ 6 callers
Method
checkValueRange
(final int value, final int minValue, final int maxValue, final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:787
↓ 6 callers
Method
dumpArchiveErrors
(final File archiveDir, final Path destFile)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:506
↓ 6 callers
Method
dumpClusterErrors
( 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 callers
Method
messageTransceiverClass
()
benchmarks-aeron/src/test/java/io/aeron/benchmarks/aeron/EchoTest.java:85
↓ 6 callers
Function
nanoClock
benchmarks-aeron/src/main/cpp/NanoMark.h:53
↓ 6 callers
Method
receivedMessages
()
benchmarks-api/src/main/java/io/aeron/benchmarks/MessageTransceiver.java:52
↓ 6 callers
Method
recordChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:204
↓ 6 callers
Method
recordStream
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:214
↓ 6 callers
Method
resolveLogsDir
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 callers
Method
saveToDisc
(final String fileName, final Histogram histogram)
benchmarks-api/src/test/java/io/aeron/benchmarks/ResultsAggregatorTest.java:168
↓ 6 callers
Method
start
benchmarks-aeron/src/main/cpp/EmbeddedAeronMediaDriver.h:66
↓ 6 callers
Method
start
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverControlServer.java:98
↓ 5 callers
Method
embeddedMediaDriver
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:246
↓ 5 callers
Method
getPropertyValue
(final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:891
↓ 5 callers
Method
launchEmbeddedMediaDriverIfConfigured
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:256
↓ 5 callers
Method
logsDir
Directory to store logs and diagnostics files. @return logs dir location.
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:339
↓ 5 callers
Method
outputTimeUnit
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 callers
Method
resolveMarkFile
(final File parentDir, final String markFileName, final String linkFileName)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:543
↓ 5 callers
Method
send
(final int iterations, final int numberOfMessages)
benchmarks-api/src/main/java/io/aeron/benchmarks/LoadTestRig.java:188
↓ 4 callers
Method
fromSystemProperties
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 callers
Method
hasNext
()
benchmarks-api/src/main/java/io/aeron/benchmarks/LoggingPersistedHistogram.java:111
↓ 4 callers
Method
init
(Configuration configuration, FailoverListener listener)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverTransceiver.java:22
↓ 4 callers
Method
intProperty
(final String propName)
benchmarks-api/src/main/java/io/aeron/benchmarks/Configuration.java:877
↓ 4 callers
Method
messageIndexOffset
(final int n)
benchmarks-api/src/main/java/io/aeron/benchmarks/InMemoryMessageTransceiver.java:83
↓ 4 callers
Method
name
benchmarks-aeron/src/main/cpp/NanoMark.h:151
↓ 4 callers
Method
readHistogram
(final Path file)
benchmarks-api/src/test/java/io/aeron/benchmarks/PersistedHistogramTest.java:216
↓ 4 callers
Method
receiverIndex
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:136
↓ 4 callers
Method
replayChannel
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:224
↓ 4 callers
Method
replayStreamId
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:235
↓ 4 callers
Method
run
()
benchmarks-api/src/main/java/io/aeron/benchmarks/ResultsAggregator.java:64
↓ 4 callers
Method
stop
benchmarks-aeron/src/main/cpp/EmbeddedAeronMediaDriver.h:60
↓ 4 callers
Method
syncAndLoadHistogram
()
benchmarks-api/src/main/java/io/aeron/benchmarks/LoggingPersistedHistogram.java:153
↓ 4 callers
Method
test
( final int messages, final int messageLength, final int burstSize, final Path
benchmarks-aeron/src/test/java/io/aeron/benchmarks/aeron/ClusterTest.java:95
↓ 4 callers
Method
yieldUninterruptedly
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:399
↓ 3 callers
Method
getCommonProperties
()
benchmarks-kafka/src/main/java/io/aeron/benchmarks/kafka/KafkaConfig.java:50
↓ 3 callers
Method
installSignalHandler
(final Runnable onSignal)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:394
↓ 3 callers
Method
iterationsPerRun
benchmarks-aeron/src/main/cpp/NanoMark.h:171
↓ 3 callers
Method
launchArchiveWithEmbeddedDriver
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/ArchivingMediaDriver.java:46
↓ 3 callers
Method
launchArchivingMediaDriver
()
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:268
↓ 3 callers
Method
launchDriver
(final MediaDriver.Context ctx)
benchmarks-aeron/src/test/java/io/aeron/benchmarks/aeron/EchoTest.java:66
↓ 3 callers
Method
loadProperties
( final Properties existingProperties, final PropertyAction propertyAction, final Inpu
benchmarks-api/src/main/java/io/aeron/benchmarks/PropertiesUtil.java:114
↓ 3 callers
Method
loadPropertiesFile
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 callers
Method
prepareCommand
(final int command)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/FailoverControlClient.java:95
↓ 3 callers
Method
receive
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 callers
Method
saveErrors
(final AtomicBuffer errorBuffer, final Path errorFile)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/AeronUtil.java:570
↓ 3 callers
Method
saveHistoryToCsvFile
( final Path outputDirectory, final String prefix, final Status status, final double... percentiles)
benchmarks-api/src/main/java/io/aeron/benchmarks/PersistedHistogram.java:132
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ManyToOneRingBufferBenchmark.java:173
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ManyToOneConcurrentArrayQueueBenchmark.java:148
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ConcurrentLinkedQueueBenchmark.java:149
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/LinkedBlockingQueueBenchmark.java:149
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ManyToOneConcurrentLinkedQueueBenchmark.java:149
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/AeronIpcBenchmark.java:207
↓ 3 callers
Method
sendBurst
(final PerThreadState state)
benchmarks-aeron/src/main/java/io/aeron/benchmarks/aeron/jmh/ArrayBlockingQueueBenchmark.java:149
next →
1–100 of 713, ranked by callers