Class Sl4jLogger

java.lang.Object

io.perl.logger.impl.ResultsLogger

io.sbk.logger.impl.AbstractRWLogger

io.sbk.logger.impl.SystemLogger

io.sbk.logger.impl.Sl4jLogger

All Implemented Interfaces:

io.perl.logger.PerformanceLogger, io.perl.logger.Print, io.perl.logger.ReportLatency, CountReaders, CountRW, CountWriters, Logger, ReadRequestsLogger, RWLogger, RWPrint, SetRW, WriteRequestsLogger

public class Sl4jLogger
extends SystemLogger

Logger implementation that prints periodic and total benchmark results using SLF4J.

Extends SystemLogger to reuse formatting and aggregation helpers from AbstractRWLogger. Output is written via a named SLF4J logger ("SBK").

Constructor Summary

Constructors

Constructor	Description
Sl4jLogger()	Creates an SLF4J-backed benchmark logger.

Method Summary

Modifier and Type	Method	Description
protected String	getTimeStamp(long reportTime)	Formats a report timestamp in the local time zone.
final void	print(int writers, int maxWriters, int readers, int maxReaders, long writeRequestBytes, double writeRequestMbPerSec, long writeRequestRecords, double writeRequestRecordsPerSec, long readRequestBytes, double readRequestMbPerSec, long readRequestRecords, double readRequestRecordsPerSec, long writeResponsePendingRecords, long writeResponsePendingBytes, long readResponsePendingRecords, long readResponsePendingBytes, long writeReadRequestPendingRecords, long writeReadRequestPendingBytes, long writeTimeoutEvents, double writeTimeoutEventsPerSec, long readTimeoutEvents, double readTimeoutEventsPerSec, double seconds, long bytes, long records, double recsPerSec, double mbPerSec, double avgLatency, long minLatency, long maxLatency, long invalid, long lowerDiscard, long higherDiscard, long slc1, long slc2, long[] percentileLatencies, long[] percentileLatencyCounts)	Print the periodic results to System.out at the end of each interval.
void	print(long reportTime, int writers, int maxWriters, int readers, int maxReaders, long writeRequestBytes, double writeRequestMbPerSec, long writeRequestRecords, double writeRequestRecordsPerSec, long readRequestBytes, double readRequestMbPerSec, long readRequestRecords, double readRequestRecordsPerSec, long writeResponsePendingRecords, long writeResponsePendingBytes, long readResponsePendingRecords, long readResponsePendingBytes, long writeReadRequestPendingRecords, long writeReadRequestPendingBytes, long writeTimeoutEvents, double writeTimeoutEventsPerSec, long readTimeoutEvents, double readTimeoutEventsPerSec, double seconds, long bytes, long records, double recsPerSec, double mbPerSec, double avgLatency, long minLatency, long maxLatency, long invalid, long lowerDiscard, long higherDiscard, long slc1, long slc2, long[] percentileLatencies, long[] percentileLatencyCounts)	Log the periodic results using SLF4J at info level.
final void	printTotal(int writers, int maxWriters, int readers, int maxReaders, long writeRequestBytes, double writeRequestMbPerSec, long writeRequestRecords, double writeRequestRecordsPerSec, long readRequestBytes, double readRequestsMbPerSec, long readRequestRecords, double readRequestRecordsPerSec, long writeResponsePendingRecords, long writeResponsePendingBytes, long readResponsePendingRecords, long readResponsePendingBytes, long writeReadRequestPendingRecords, long writeReadRequestPendingBytes, long writeTimeoutEvents, double writeTimeoutEventsPerSec, long readTimeoutEvents, double readTimeoutEventsPerSec, double seconds, long bytes, long records, double recsPerSec, double mbPerSec, double avgLatency, long minLatency, long maxLatency, long invalid, long lowerDiscard, long higherDiscard, long slc1, long slc2, long[] percentileLatencies, long[] percentileLatencyCounts)	Print the final accumulated totals to System.out at the end of the run.
void	printTotal(long reportTime, int writers, int maxWriters, int readers, int maxReaders, long writeRequestBytes, double writeRequestMbPerSec, long writeRequestRecords, double writeRequestRecordsPerSec, long readRequestBytes, double readRequestsMbPerSec, long readRequestRecords, double readRequestRecordsPerSec, long writeResponsePendingRecords, long writeResponsePendingBytes, long readResponsePendingRecords, long readResponsePendingBytes, long writeReadRequestPendingRecords, long writeReadRequestPendingBytes, long writeTimeoutEvents, double writeTimeoutEventsPerSec, long readTimeoutEvents, double readTimeoutEventsPerSec, double seconds, long bytes, long records, double recsPerSec, double mbPerSec, double avgLatency, long minLatency, long maxLatency, long invalid, long lowerDiscard, long higherDiscard, long slc1, long slc2, long[] percentileLatencies, long[] percentileLatencyCounts)	Log the final accumulated totals using SLF4J at info level.

Methods inherited from class SystemLogger

recordLatency

Methods inherited from class AbstractRWLogger

addArgs, appendResultString, appendWriteAndReadRequests, appendWriteAndReadRequestsPending, appendWriteAndReadTimeoutEvents, appendWritesAndReaders, close, decrementReaders, decrementWriters, getAction, getConfiguredMaxRequestIds, getLoggerConfigStream, getMaxReaderIDs, getMaxReadersCount, getMaxWriterIDs, getMaxWritersCount, getPrintingIntervalSeconds, getReadersCount, getStorageName, getTime, getWritersCount, incrementReaders, incrementWriters, isReadRequestsEnabled, isWriteRequestsEnabled, open, parseArgs, print, printTotal, recordReadRequests, recordReadTimeoutEvents, recordWriteRequests, recordWriteTimeoutEvents, setMaxReaders, setMaxReadersIds, setMaxWriters, setMaxWritersIds, setReaders, setWriters

Methods inherited from class io.perl.logger.impl.ResultsLogger

appendResultString, getMaxLatency, getMinLatency, getPercentileNames, getPercentiles, getPrefix, getTimeUnit, setMaxLatency, setMinLatency, setPercentiles, setPrefix, setTimeUnit

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Logger

reportFailure, setExceptionHandler

Methods inherited from interface io.perl.logger.PerformanceLogger

getMaxLatency, getMinLatency, getPercentiles, getTimeUnit

Constructor Details

Sl4jLogger

public Sl4jLogger()

Creates an SLF4J-backed benchmark logger.

Method Details

print

public void print(long reportTime,
 int writers,
 int maxWriters,
 int readers,
 int maxReaders,
 long writeRequestBytes,
 double writeRequestMbPerSec,
 long writeRequestRecords,
 double writeRequestRecordsPerSec,
 long readRequestBytes,
 double readRequestMbPerSec,
 long readRequestRecords,
 double readRequestRecordsPerSec,
 long writeResponsePendingRecords,
 long writeResponsePendingBytes,
 long readResponsePendingRecords,
 long readResponsePendingBytes,
 long writeReadRequestPendingRecords,
 long writeReadRequestPendingBytes,
 long writeTimeoutEvents,
 double writeTimeoutEventsPerSec,
 long readTimeoutEvents,
 double readTimeoutEventsPerSec,
 double seconds,
 long bytes,
 long records,
 double recsPerSec,
 double mbPerSec,
 double avgLatency,
 long minLatency,
 long maxLatency,
 long invalid,
 long lowerDiscard,
 long higherDiscard,
 long slc1,
 long slc2,
 long[] percentileLatencies,
 long[] percentileLatencyCounts)

Log the periodic results using SLF4J at info level.

Parameters:

reportTime - local report time

writers - number of active writers

maxWriters - maximum writers seen

readers - number of active readers

maxReaders - maximum readers seen

writeRequestBytes - write request bytes in this interval

writeRequestMbPerSec - write request throughput in MB/sec

writeRequestRecords - write request count

writeRequestRecordsPerSec - write requests per second

readRequestBytes - read request bytes in this interval

readRequestMbPerSec - read request throughput in MB/sec

readRequestRecords - read request count

readRequestRecordsPerSec - read requests per second

writeResponsePendingRecords - pending write response records

writeResponsePendingBytes - pending write response bytes

readResponsePendingRecords - pending read response records

readResponsePendingBytes - pending read response bytes

writeReadRequestPendingRecords - write-read pending records delta

writeReadRequestPendingBytes - write-read pending bytes delta

writeTimeoutEvents - write timeout events count

writeTimeoutEventsPerSec - write timeout events per second

readTimeoutEvents - read timeout events count

readTimeoutEventsPerSec - read timeout events per second

seconds - reporting interval seconds

bytes - total bytes processed in interval

records - total records processed in interval

recsPerSec - records per second

mbPerSec - MB per second

avgLatency - average latency

minLatency - minimum latency

maxLatency - maximum latency

invalid - invalid/negative latency count

lowerDiscard - discarded below min latency

higherDiscard - discarded above max latency

slc1 - sliding latency coverage 1

slc2 - sliding latency coverage 2

percentileLatencies - percentile latency values

percentileLatencyCounts - percentile latency counts

printTotal

public void printTotal(long reportTime,
 int writers,
 int maxWriters,
 int readers,
 int maxReaders,
 long writeRequestBytes,
 double writeRequestMbPerSec,
 long writeRequestRecords,
 double writeRequestRecordsPerSec,
 long readRequestBytes,
 double readRequestsMbPerSec,
 long readRequestRecords,
 double readRequestRecordsPerSec,
 long writeResponsePendingRecords,
 long writeResponsePendingBytes,
 long readResponsePendingRecords,
 long readResponsePendingBytes,
 long writeReadRequestPendingRecords,
 long writeReadRequestPendingBytes,
 long writeTimeoutEvents,
 double writeTimeoutEventsPerSec,
 long readTimeoutEvents,
 double readTimeoutEventsPerSec,
 double seconds,
 long bytes,
 long records,
 double recsPerSec,
 double mbPerSec,
 double avgLatency,
 long minLatency,
 long maxLatency,
 long invalid,
 long lowerDiscard,
 long higherDiscard,
 long slc1,
 long slc2,
 long[] percentileLatencies,
 long[] percentileLatencyCounts)

Log the final accumulated totals using SLF4J at info level.

Parameters:

reportTime - local report time

writers - number of active writers

maxWriters - maximum writers seen

readers - number of active readers

maxReaders - maximum readers seen

writeRequestBytes - write request bytes total

writeRequestMbPerSec - write request throughput in MB/sec

writeRequestRecords - write request count total

writeRequestRecordsPerSec - write requests per second

readRequestBytes - read request bytes total

readRequestsMbPerSec - read request throughput in MB/sec

readRequestRecords - read request count total

readRequestRecordsPerSec - read requests per second

writeResponsePendingRecords - pending write response records

writeResponsePendingBytes - pending write response bytes

readResponsePendingRecords - pending read response records

readResponsePendingBytes - pending read response bytes

writeReadRequestPendingRecords - write-read pending records delta

writeReadRequestPendingBytes - write-read pending bytes delta

writeTimeoutEvents - write timeout events count

writeTimeoutEventsPerSec - write timeout events per second

readTimeoutEvents - read timeout events count

readTimeoutEventsPerSec - read timeout events per second

seconds - reporting seconds

bytes - total bytes processed

records - total records processed

recsPerSec - records per second

mbPerSec - MB per second

avgLatency - average latency

minLatency - minimum latency

maxLatency - maximum latency

invalid - invalid/negative latency count

lowerDiscard - discarded below min latency

higherDiscard - discarded above max latency

slc1 - sliding latency coverage 1

slc2 - sliding latency coverage 2

percentileLatencies - percentile latency values

percentileLatencyCounts - percentile latency counts

getTimeStamp

protected String getTimeStamp(long reportTime)

Formats a report timestamp in the local time zone.

Parameters:

reportTime - epoch-millisecond report time

Returns:

formatted timestamp

print

public final void print(int writers,
 int maxWriters,
 int readers,
 int maxReaders,
 long writeRequestBytes,
 double writeRequestMbPerSec,
 long writeRequestRecords,
 double writeRequestRecordsPerSec,
 long readRequestBytes,
 double readRequestMbPerSec,
 long readRequestRecords,
 double readRequestRecordsPerSec,
 long writeResponsePendingRecords,
 long writeResponsePendingBytes,
 long readResponsePendingRecords,
 long readResponsePendingBytes,
 long writeReadRequestPendingRecords,
 long writeReadRequestPendingBytes,
 long writeTimeoutEvents,
 double writeTimeoutEventsPerSec,
 long readTimeoutEvents,
 double readTimeoutEventsPerSec,
 double seconds,
 long bytes,
 long records,
 double recsPerSec,
 double mbPerSec,
 double avgLatency,
 long minLatency,
 long maxLatency,
 long invalid,
 long lowerDiscard,
 long higherDiscard,
 long slc1,
 long slc2,
 long[] percentileLatencies,
 long[] percentileLatencyCounts)

Print the periodic results to System.out at the end of each interval.

Specified by:

print in interface RWPrint

Overrides:

print in class AbstractRWLogger

Parameters:

writers - number of active writers

maxWriters - maximum writers seen

readers - number of active readers

maxReaders - maximum readers seen

writeRequestBytes - write request bytes in this interval

writeRequestMbPerSec - write request throughput in MB/sec

writeRequestRecords - write request count

writeRequestRecordsPerSec - write requests per second

readRequestBytes - read request bytes in this interval

readRequestMbPerSec - read request throughput in MB/sec

readRequestRecords - read request count

readRequestRecordsPerSec - read requests per second

writeResponsePendingRecords - pending write response records

writeResponsePendingBytes - pending write response bytes

readResponsePendingRecords - pending read response records

readResponsePendingBytes - pending read response bytes

writeReadRequestPendingRecords - write-read pending records delta

writeReadRequestPendingBytes - write-read pending bytes delta

writeTimeoutEvents - write timeout events count

writeTimeoutEventsPerSec - write timeout events per second

readTimeoutEvents - read timeout events count

readTimeoutEventsPerSec - read timeout events per second

seconds - reporting interval seconds

bytes - total bytes processed in interval

records - total records processed in interval

recsPerSec - records per second

mbPerSec - MB per second

avgLatency - average latency

minLatency - minimum latency

maxLatency - maximum latency

invalid - invalid/negative latency count

lowerDiscard - discarded below min latency

higherDiscard - discarded above max latency

slc1 - sliding latency coverage 1

slc2 - sliding latency coverage 2

percentileLatencies - percentile latency values

percentileLatencyCounts - percentile latency counts

printTotal

public final void printTotal(int writers,
 int maxWriters,
 int readers,
 int maxReaders,
 long writeRequestBytes,
 double writeRequestMbPerSec,
 long writeRequestRecords,
 double writeRequestRecordsPerSec,
 long readRequestBytes,
 double readRequestsMbPerSec,
 long readRequestRecords,
 double readRequestRecordsPerSec,
 long writeResponsePendingRecords,
 long writeResponsePendingBytes,
 long readResponsePendingRecords,
 long readResponsePendingBytes,
 long writeReadRequestPendingRecords,
 long writeReadRequestPendingBytes,
 long writeTimeoutEvents,
 double writeTimeoutEventsPerSec,
 long readTimeoutEvents,
 double readTimeoutEventsPerSec,
 double seconds,
 long bytes,
 long records,
 double recsPerSec,
 double mbPerSec,
 double avgLatency,
 long minLatency,
 long maxLatency,
 long invalid,
 long lowerDiscard,
 long higherDiscard,
 long slc1,
 long slc2,
 long[] percentileLatencies,
 long[] percentileLatencyCounts)

Print the final accumulated totals to System.out at the end of the run.

Specified by:

printTotal in interface RWLogger

Overrides:

printTotal in class AbstractRWLogger

Parameters:

writers - number of active writers

maxWriters - maximum writers seen

readers - number of active readers

maxReaders - maximum readers seen

writeRequestBytes - write request bytes total

writeRequestMbPerSec - write request throughput in MB/sec

writeRequestRecords - write request count total

writeRequestRecordsPerSec - write requests per second

readRequestBytes - read request bytes total

readRequestsMbPerSec - read request throughput in MB/sec

readRequestRecords - read request count total

readRequestRecordsPerSec - read requests per second

writeResponsePendingRecords - pending write response records

writeResponsePendingBytes - pending write response bytes

readResponsePendingRecords - pending read response records

readResponsePendingBytes - pending read response bytes

writeReadRequestPendingRecords - write-read pending records delta

writeReadRequestPendingBytes - write-read pending bytes delta

writeTimeoutEvents - write timeout events count

writeTimeoutEventsPerSec - write timeout events per second

readTimeoutEvents - read timeout events count

readTimeoutEventsPerSec - read timeout events per second

seconds - reporting seconds

bytes - total bytes processed

records - total records processed

recsPerSec - records per second

mbPerSec - MB per second

avgLatency - average latency

minLatency - minimum latency

maxLatency - maximum latency

invalid - invalid/negative latency count

lowerDiscard - discarded below min latency

higherDiscard - discarded above max latency

slc1 - sliding latency coverage 1

slc2 - sliding latency coverage 2

percentileLatencies - percentile latency values

percentileLatencyCounts - percentile latency counts