Top Inners Fields Constructors Methods
io.undertow.server

public Class ConnectorStatisticsImpl

extends Object
implements ConnectorStatistics
Class Inheritance
All Implemented Interfaces
io.undertow.server.ConnectorStatistics
Imports
io.undertow.conduits.ByteActivityCallback, io.undertow.util.StatusCodes, java.util.concurrent.atomic.AtomicLongFieldUpdater
Author
Stuart Douglas

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
ConnectorStatisticsImpl.BytesReceivedAccumulator

private class
ConnectorStatisticsImpl.BytesSentAccumulator

Field Summary

Modifier and TypeField and Description
private volatile long
activeConnections

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
activeConnectionsUpdater

private volatile long
activeRequests

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
activeRequestsUpdater

private volatile long
bytesReceived

private final ByteActivityCallback
bytesReceivedAccumulator

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
bytesReceivedUpdater

private volatile long
bytesSent

private final ByteActivityCallback
bytesSentAccumulator

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
bytesSentUpdater

private final ExchangeCompletionListener
completionListener

private volatile long
errorCount

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
errorCountUpdater

private volatile long
maxActiveConnections

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
maxActiveConnectionsUpdater

private volatile long
maxActiveRequests

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
maxActiveRequestsUpdater

private volatile long
maxProcessingTime

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
maxProcessingTimeUpdater

private volatile long
processingTime

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
processingTimeUpdater

private volatile long
requestCount

private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl>
requestCountUpdater

Constructor Summary

AccessConstructor and Description
public
ConnectorStatisticsImpl()

Method Summary

Modifier and TypeMethod and Description
public void
decrementConnectionCount()

public long
getActiveConnections()

Implements io.undertow.server.ConnectorStatistics.getActiveConnections.

public long
getActiveRequests()

Implements io.undertow.server.ConnectorStatistics.getActiveRequests.

public long
getBytesReceived()

Implements io.undertow.server.ConnectorStatistics.getBytesReceived.

public long
getBytesSent()

Implements io.undertow.server.ConnectorStatistics.getBytesSent.

public long
getErrorCount()

Implements io.undertow.server.ConnectorStatistics.getErrorCount.

public long
getMaxActiveConnections()

Implements io.undertow.server.ConnectorStatistics.getMaxActiveConnections.

public long
getMaxActiveRequests()

Implements io.undertow.server.ConnectorStatistics.getMaxActiveRequests.

public long
getMaxProcessingTime()

Implements io.undertow.server.ConnectorStatistics.getMaxProcessingTime.

public long
getProcessingTime()

Implements io.undertow.server.ConnectorStatistics.getProcessingTime.

public long
getRequestCount()

Implements io.undertow.server.ConnectorStatistics.getRequestCount.

public void
incrementConnectionCount()

public ByteActivityCallback
receivedAccumulator()

public void
requestFinished(long bytesSent, long bytesReceived, boolean error)

public void
reset()

Implements io.undertow.server.ConnectorStatistics.reset.

Resets all values to zero

public ByteActivityCallback
sentAccumulator()

public void
setup(HttpServerExchange exchange)

public void
updateBytesReceived(long bytes)

public void
updateBytesSent(long bytes)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

activeConnectionsback to summary
private volatile long activeConnections
activeConnectionsUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> activeConnectionsUpdater
activeRequestsback to summary
private volatile long activeRequests
activeRequestsUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> activeRequestsUpdater
bytesReceivedback to summary
private volatile long bytesReceived
bytesReceivedAccumulatorback to summary
private final ByteActivityCallback bytesReceivedAccumulator
bytesReceivedUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> bytesReceivedUpdater
bytesSentback to summary
private volatile long bytesSent
bytesSentAccumulatorback to summary
private final ByteActivityCallback bytesSentAccumulator
bytesSentUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> bytesSentUpdater
completionListenerback to summary
private final ExchangeCompletionListener completionListener
errorCountback to summary
private volatile long errorCount
errorCountUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> errorCountUpdater
maxActiveConnectionsback to summary
private volatile long maxActiveConnections
maxActiveConnectionsUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> maxActiveConnectionsUpdater
maxActiveRequestsback to summary
private volatile long maxActiveRequests
maxActiveRequestsUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> maxActiveRequestsUpdater
maxProcessingTimeback to summary
private volatile long maxProcessingTime
maxProcessingTimeUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> maxProcessingTimeUpdater
processingTimeback to summary
private volatile long processingTime
processingTimeUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> processingTimeUpdater
requestCountback to summary
private volatile long requestCount
requestCountUpdaterback to summary
private static final AtomicLongFieldUpdater<ConnectorStatisticsImpl> requestCountUpdater

Constructor Detail

ConnectorStatisticsImplback to summary
public ConnectorStatisticsImpl()

Method Detail

decrementConnectionCountback to summary
public void decrementConnectionCount()
getActiveConnectionsback to summary
public long getActiveConnections()

Implements io.undertow.server.ConnectorStatistics.getActiveConnections.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getActiveConnections.

The current number of active connections

Annotations
@Override
getActiveRequestsback to summary
public long getActiveRequests()

Implements io.undertow.server.ConnectorStatistics.getActiveRequests.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getActiveRequests.

The current number of active requests

Annotations
@Override
getBytesReceivedback to summary
public long getBytesReceived()

Implements io.undertow.server.ConnectorStatistics.getBytesReceived.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getBytesReceived.

The number of bytes that have been received by this connector

Annotations
@Override
getBytesSentback to summary
public long getBytesSent()

Implements io.undertow.server.ConnectorStatistics.getBytesSent.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getBytesSent.

The number of bytes sent on this connector

Annotations
@Override
getErrorCountback to summary
public long getErrorCount()

Implements io.undertow.server.ConnectorStatistics.getErrorCount.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getErrorCount.

The number of requests that triggered an error (i.e. 500) response.

Annotations
@Override
getMaxActiveConnectionsback to summary
public long getMaxActiveConnections()

Implements io.undertow.server.ConnectorStatistics.getMaxActiveConnections.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getMaxActiveConnections.

The maximum number of active connections that have every been active on this connector

Annotations
@Override
getMaxActiveRequestsback to summary
public long getMaxActiveRequests()

Implements io.undertow.server.ConnectorStatistics.getMaxActiveRequests.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getMaxActiveRequests.

The maximum number of active requests

Annotations
@Override
getMaxProcessingTimeback to summary
public long getMaxProcessingTime()

Implements io.undertow.server.ConnectorStatistics.getMaxProcessingTime.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getMaxProcessingTime.

The time taken by the slowest request (nanoseconds)

Annotations
@Override
getProcessingTimeback to summary
public long getProcessingTime()

Implements io.undertow.server.ConnectorStatistics.getProcessingTime.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getProcessingTime.

The total amount of time spent processing all requests on this connector (nanoseconds)

Annotations
@Override
getRequestCountback to summary
public long getRequestCount()

Implements io.undertow.server.ConnectorStatistics.getRequestCount.

Returns:long

Doc from io.undertow.server.ConnectorStatistics.getRequestCount.

The number of requests processed by this connector

Annotations
@Override
incrementConnectionCountback to summary
public void incrementConnectionCount()
receivedAccumulatorback to summary
public ByteActivityCallback receivedAccumulator()
requestFinishedback to summary
public void requestFinished(long bytesSent, long bytesReceived, boolean error)
resetback to summary
public void reset()

Implements io.undertow.server.ConnectorStatistics.reset.

Doc from io.undertow.server.ConnectorStatistics.reset.

Resets all values to zero

Annotations
@Override
sentAccumulatorback to summary
public ByteActivityCallback sentAccumulator()
setupback to summary
public void setup(HttpServerExchange exchange)
updateBytesReceivedback to summary
public void updateBytesReceived(long bytes)
updateBytesSentback to summary
public void updateBytesSent(long bytes)
io.undertow.server back to summary

private Class ConnectorStatisticsImpl.BytesReceivedAccumulator

extends Object
implements ByteActivityCallback
Class Inheritance
  • java.lang.Object
  • io.undertow.server.ConnectorStatisticsImpl.BytesReceivedAccumulator
All Implemented Interfaces
io.undertow.conduits.ByteActivityCallback

Constructor Summary

AccessConstructor and Description
private
BytesReceivedAccumulator()

Method Summary

Modifier and TypeMethod and Description
public void
activity(long bytes)

Implements io.undertow.conduits.ByteActivityCallback.activity.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

BytesReceivedAccumulatorback to summary
private BytesReceivedAccumulator()

Method Detail

activityback to summary
public void activity(long bytes)

Implements io.undertow.conduits.ByteActivityCallback.activity.

Annotations
@Override
io.undertow.server back to summary

private Class ConnectorStatisticsImpl.BytesSentAccumulator

extends Object
implements ByteActivityCallback
Class Inheritance
  • java.lang.Object
  • io.undertow.server.ConnectorStatisticsImpl.BytesSentAccumulator
All Implemented Interfaces
io.undertow.conduits.ByteActivityCallback

Constructor Summary

AccessConstructor and Description
private
BytesSentAccumulator()

Method Summary

Modifier and TypeMethod and Description
public void
activity(long bytes)

Implements io.undertow.conduits.ByteActivityCallback.activity.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

BytesSentAccumulatorback to summary
private BytesSentAccumulator()

Method Detail

activityback to summary
public void activity(long bytes)

Implements io.undertow.conduits.ByteActivityCallback.activity.

Annotations
@Override