com.latencybusters.lbm
Class LBMSourceStatistics
java.lang.Object
com.latencybusters.lbm.LBMSourceStatistics
public class LBMSourceStatistics
- extends java.lang.Object
LBM Source Transport Statistics
Constructor Summary |
LBMSourceStatistics()
Instantiate an empty object containing no statistics. |
LBMSourceStatistics(LBMContext lbmctx,
int maxStats)
Instantiate object containing the current set of
source transport statistics for a given LBM context
This constructor will throw LBMMonitorEInvalException if maxStats
is less than the available number of transport statistical sets. |
LBMSourceStatistics(LBMSource lbmsrc)
Instantiate object containing the current set of
source transport statistics for a given LBM source. |
Method Summary |
long |
bytesBuffered()
Number of bytes currently in UM's TCP buffer, i.e., a snapshot (TCP only). |
long |
bytesBuffered(int n)
Number of bytes currently in UM's TCP buffer, i.e., a snapshot (TCP only). |
long |
bytesSent()
Number of datagram bytes sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA). |
long |
bytesSent(int n)
Number of datagram bytes sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA). |
void |
dispose()
Free memory associated with this set of statistics. |
protected void |
finalize()
|
java.lang.String |
getApplicationSourceId()
Retrieve the application source identifier associated with this
set of statistics. |
long |
getContextId()
Retrieve the sending context ID associated with this set of statistics. |
long |
getProcessId()
Retrieve the sending process ID associated with this set of statistics. |
java.net.InetAddress |
getSender()
Retrieve the IP sender address associated with this set of statistics. |
java.util.Date |
getTimestamp()
Retrieve the timestamp associated with this set of statistics. |
long |
messagesQueued()
Number of datagrams currently queued by the data rate limiter (LBT-RM only). |
long |
messagesQueued(int n)
Number of datagrams currently queued by the data rate limiter (LBT-RM only). |
long |
messagesSent()
Number of datagrams sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA). |
long |
messagesSent(int n)
Number of datagrams sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA). |
long |
nakPacketsReceived()
Number of NAK packets received by this source transport (LBT-RM, LBT-RU). |
long |
nakPacketsReceived(int n)
Number of NAK packets received by this source transport (LBT-RM, LBT-RU). |
long |
naksIgnored()
Number of NAKs the source ignored and sent an NCF with reason code "ignored"
(LBT-RM, LBT-RU). |
long |
naksIgnored(int n)
Number of NAKs the source ignored and sent an NCF with reason code "ignored"
(LBT-RM, LBT-RU). |
long |
naksIgnoredRetransmitDelay()
Number of NAKs this source did not process because doing so would exceed its retransmit
rate limit (LBT-RM, LBT-RU). |
long |
naksIgnoredRetransmitDelay(int n)
Number of NAKs this source did not process because doing so would exceed its retransmit
rate limit (LBT-RM, LBT-RU). |
long |
naksReceived()
Number of individual NAKs received by the source transport (LBT-RM, LBT-RU). |
long |
naksReceived(int n)
Number of individual NAKs received by the source transport (LBT-RM, LBT-RU). |
long |
naksShed()
Number of NAKs this source shed and sent an NCF with reason code "shed"
(LBT-RM, LBT-RU). |
long |
naksShed(int n)
Number of NAKs this source shed and sent an NCF with reason code "shed"
(LBT-RM, LBT-RU). |
long |
numberOfClients()
Number of receiver clients currently connected over this transport
(TCP, LBT-RU, LBT-IPC, LBT-RDMA). |
long |
numberOfClients(int n)
Number of receiver clients currently connected over this transport
(TCP, LBT-RU, LBT-IPC, LBT-RDMA). |
void |
refresh(LBMContext lbmctx,
int maxStats)
Refresh source transport statistics for a given LBM context. |
void |
refresh(LBMSource lbmsrc)
Refresh source transport statistics for a given LBM source |
long |
retransmissionBytesSent()
Number of bytes retransmitted by this source transport (LBT-RM, LBT-RU). |
long |
retransmissionBytesSent(int n)
Number of bytes retransmitted by this source transport (LBT-RM, LBT-RU). |
long |
retransmissionsQueued()
Number of retransmission datagrams currently queued by the retransmit
rate limiter (LBT-RM only). |
long |
retransmissionsQueued(int n)
Number of retransmission datagrams currently queued by the retransmit
rate limiter (LBT-RM only). |
long |
retransmissionsSent()
Number of datagrams retransmitted by this source transport (LBT-RM, LBT-RU). |
long |
retransmissionsSent(int n)
Number of datagrams retransmitted by this source transport (LBT-RM, LBT-RU). |
protected void |
setApplicationSourceId(java.lang.String appid)
|
protected void |
setContextId(long cid)
|
protected void |
setProcessId(long pid)
|
protected void |
setSender(long ip)
|
protected void |
setTimestamp(long ts)
|
int |
size()
Number of statistical sets encapsulated within this object |
java.lang.String |
source()
Source of a transport as a string. |
java.lang.String |
source(int n)
Source of a transport as a string. |
long |
transmissionWindowBytes()
Number of bytes currently in the transmission window (LBT-RM only). |
long |
transmissionWindowBytes(int n)
Number of bytes currently in the transmission window (LBT-RM only). |
long |
transmissionWindowMessages()
Number of datagrams in the transmission window (LBT-RM only). |
long |
transmissionWindowMessages(int n)
Number of datagrams in the transmission window (LBT-RM only). |
int |
type()
Transport type (TCP, LBT-RM, LBT-RU, etc.). |
int |
type(int n)
Transport type (TCP, LBT-RM, LBT-RU, etc.). |
java.lang.String |
typeName()
Transport type name (TCP, LBT-RM, LBT-RU, etc.). |
java.lang.String |
typeName(int n)
Transport type name (TCP, LBT-RM, LBT-RU, etc.). |
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LBMSourceStatistics
public LBMSourceStatistics()
- Instantiate an empty object containing no statistics.
LBMSourceStatistics
public LBMSourceStatistics(LBMContext lbmctx,
int maxStats)
throws LBMException
- Instantiate object containing the current set of
source transport statistics for a given LBM context
This constructor will throw LBMMonitorEInvalException if maxStats
is less than the available number of transport statistical sets.
- Parameters:
lbmctx
- LBMContext object associated with statistics to be retrievedmaxStats
- Maximum number of statistical sets to retrieve
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
refresh(com.latencybusters.lbm.LBMContext, int)
LBMSourceStatistics
public LBMSourceStatistics(LBMSource lbmsrc)
throws LBMException
- Instantiate object containing the current set of
source transport statistics for a given LBM source.
- Parameters:
lbmsrc
- LBMSource object
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
refresh(com.latencybusters.lbm.LBMContext, int)
refresh
public void refresh(LBMContext lbmctx,
int maxStats)
throws LBMException
- Refresh source transport statistics for a given LBM context.
This method will throw LBMMonitorEInvalException if maxStats
is less than the available number of transport statistical sets.
- Parameters:
lbmctx
- LBMContext object associated with statistics to be retrievedmaxStats
- Maximum number of statistical sets to retrieve
- Throws:
LBMException
- if any error occurred retrieving source statistics.
refresh
public void refresh(LBMSource lbmsrc)
throws LBMException
- Refresh source transport statistics for a given LBM source
- Parameters:
lbmsrc
- LBMSource object
- Throws:
LBMException
- if any error occurred retrieving source statistics.
dispose
public void dispose()
- Free memory associated with this set of statistics.
finalize
protected void finalize()
- Overrides:
finalize
in class java.lang.Object
size
public int size()
- Number of statistical sets encapsulated within this object
- Returns:
- Statistical set size
type
public int type()
throws LBMException
- Transport type (TCP, LBT-RM, LBT-RU, etc.).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Transport type
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
,
LBM
type
public int type(int n)
throws LBMException
- Transport type (TCP, LBT-RM, LBT-RU, etc.).
This method returns a value from the nth
set of statistics encapsulated within this object.
- Parameters:
n
- Statistics set index
- Returns:
- Transport type
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBM
typeName
public java.lang.String typeName()
throws LBMException
- Transport type name (TCP, LBT-RM, LBT-RU, etc.).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been created
using a specific source to instantiate the class.
- Returns:
- Transport type name
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
typeName
public java.lang.String typeName(int n)
throws LBMException
- Transport type name (TCP, LBT-RM, LBT-RU, etc.).
This method returns a value from the nth set of statistics
encapsulated within this object.
- Parameters:
n
- Statistics set index
- Returns:
- Transport type name
- Throws:
LBMException
- if any error occurred retrieving source statistics.
source
public java.lang.String source()
throws LBMException
- Source of a transport as a string.
The string format depends on transport type and is described under
LBMTransportSourceInfo.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Source of transport as a string
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMTransportSourceInfo
,
LBMSourceStatistics(LBMSource)
source
public java.lang.String source(int n)
throws LBMException
- Source of a transport as a string.
The string format depends on transport type and is described under
LBMTransportSourceInfo.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Source of transport as a string
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMTransportSourceInfo
numberOfClients
public long numberOfClients()
throws LBMException
- Number of receiver clients currently connected over this transport
(TCP, LBT-RU, LBT-IPC, LBT-RDMA).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of receiver clients currently connected over this transport
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
numberOfClients
public long numberOfClients(int n)
throws LBMException
- Number of receiver clients currently connected over this transport
(TCP, LBT-RU, LBT-IPC, LBT-RDMA).
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of receiver clients currently connected over this transport
- Throws:
LBMException
- if any error occurred retrieving source statistics.
bytesBuffered
public long bytesBuffered()
throws LBMException
- Number of bytes currently in UM's TCP buffer, i.e., a snapshot (TCP only).
This count is affected by the number of receivers,and configuration options
transport_tcp_multiple_receiver_behavior and transport_session_maximum_buffer.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of bytes currently in UM's TCP buffer
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
bytesBuffered
public long bytesBuffered(int n)
throws LBMException
- Number of bytes currently in UM's TCP buffer, i.e., a snapshot (TCP only).
This count is affected by the number of receivers,and configuration options
transport_tcp_multiple_receiver_behavior and transport_session_maximum_buffer.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of bytes currently in UM's TCP buffer
- Throws:
LBMException
- if any error occurred retrieving source statistics.
messagesSent
public long messagesSent()
throws LBMException
- Number of datagrams sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA).
Depending on batching settings, a single datagram may contain one or more messages, or a
fragment of a larger message. With LBT-RM, larger messages are split into fragment sizes
limited by configuration option transport_lbtrm_datagram_max_size (default 8KB).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of datagrams sent
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
messagesSent
public long messagesSent(int n)
throws LBMException
- Number of datagrams sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA).
Depending on batching settings, a single datagram may contain one or more messages, or a
fragment of a larger message. With LBT-RM, larger messages are split into fragment sizes
limited by configuration option transport_lbtrm_datagram_max_size (default 8KB).
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of datagrams sent
- Throws:
LBMException
- if any error occurred retrieving source statistics.
bytesSent
public long bytesSent()
throws LBMException
- Number of datagram bytes sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA).
This is the total of lengths of all LBT-RM packets, including UM header information.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of datagram bytes sent
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
bytesSent
public long bytesSent(int n)
throws LBMException
- Number of datagram bytes sent (LBT-RM, LBT-RU, LBT-IPC, LBT-RDMA).
This is the total of lengths of all LBT-RM packets, including UM header information.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of datagram bytes sent
- Throws:
LBMException
- if any error occurred retrieving source statistics.
transmissionWindowMessages
public long transmissionWindowMessages()
throws LBMException
- Number of datagrams in the transmission window (LBT-RM only).
Each source transport session maintains a transmission window buffer (the size of which
is set by transport_lbtrm_transmission_window_size, default 24MB). When the source
transport receives a NAK, the corresponding message for retransmission must be found in
this transmission window.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of datagrams in the transmission window
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
transmissionWindowMessages
public long transmissionWindowMessages(int n)
throws LBMException
- Number of datagrams in the transmission window (LBT-RM only).
Each source transport session maintains a transmission window buffer (the size of which
is set by transport_lbtrm_transmission_window_size, default 24MB). When the source
transport receives a NAK, the corresponding message for retransmission must be found in
this transmission window.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of datagrams in the transmission window
- Throws:
LBMException
- if any error occurred retrieving source statistics.
transmissionWindowBytes
public long transmissionWindowBytes()
throws LBMException
- Number of bytes currently in the transmission window (LBT-RM only).
Typically, this count approaches its window size or exceeds it by a small amount.
See #txw_msgs for a description of the transmission window.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of bytes currently in the transmission window
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
transmissionWindowBytes
public long transmissionWindowBytes(int n)
throws LBMException
- Number of bytes currently in the transmission window (LBT-RM only).
Typically, this count approaches its window size or exceeds it by a small amount.
See #txw_msgs for a description of the transmission window.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of bytes currently in the transmission window
- Throws:
LBMException
- if any error occurred retrieving source statistics.
nakPacketsReceived
public long nakPacketsReceived()
throws LBMException
- Number of NAK packets received by this source transport (LBT-RM, LBT-RU).
UM batches NAKs into NAK packets to save network bandwidth. This should always be less
than or equal to naksReceived (below).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of NAK packets received by this source transport
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
nakPacketsReceived
public long nakPacketsReceived(int n)
throws LBMException
- Number of NAK packets received by this source transport (LBT-RM, LBT-RU).
UM batches NAKs into NAK packets to save network bandwidth. This should always be less
than or equal to naksReceived (below).
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of NAK packets received by this source transport
- Throws:
LBMException
- if any error occurred retrieving source statistics.
naksReceived
public long naksReceived()
throws LBMException
- Number of individual NAKs received by the source transport (LBT-RM, LBT-RU).
When a source transport receives a NAK from a receiver transport, it may respond by
re-transmitting the requested LBT-RM datagram, or it may send an NCF. The NAKing
receiver transport responds to the NCF by waiting (timeout set by
transport_lbtrm_nak_suppress_interval, default 1000 ms), then re-sending the NAK.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of individual NAKs received by this source transport
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
naksReceived
public long naksReceived(int n)
throws LBMException
- Number of individual NAKs received by the source transport (LBT-RM, LBT-RU).
When a source transport receives a NAK from a receiver transport, it may respond by
re-transmitting the requested LBT-RM datagram, or it may send an NCF. The NAKing
receiver transport responds to the NCF by waiting (timeout set by
transport_lbtrm_nak_suppress_interval, default 1000 ms), then re-sending the NAK.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of individual NAKs received by this source transport
- Throws:
LBMException
- if any error occurred retrieving source statistics.
naksIgnored
public long naksIgnored()
throws LBMException
- Number of NAKs the source ignored and sent an NCF with reason code "ignored"
(LBT-RM, LBT-RU).
A source transport ignores a NAK for a datagram it has already recently retransmitted.
How "recently" is determined by the configuration option source
transport_lbtrm_ignore_interval (default 500ms). If this count is high, a receiver
transport may be having trouble receiving retransmissions, or the ignore interval may be
set too long.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of NAKs the source ignored and sent an NCF with reason code "ignored"
code set to "ignored".
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
naksIgnored
public long naksIgnored(int n)
throws LBMException
- Number of NAKs the source ignored and sent an NCF with reason code "ignored"
(LBT-RM, LBT-RU).
A source transport ignores a NAK for a datagram it has already recently retransmitted.
How "recently" is determined by the configuration option source
transport_lbtrm_ignore_interval (default 500ms). If this count is high, a receiver
transport may be having trouble receiving retransmissions, or the ignore interval may be
set too long.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of NAKs the source ignored and sent an NCF with reason code "ignored"
- Throws:
LBMException
- if any error occurred retrieving source statistics.
naksShed
public long naksShed()
throws LBMException
- Number of NAKs this source shed and sent an NCF with reason code "shed"
(LBT-RM, LBT-RU).
When a source transport's retransmit rate limiter and retransmit queue are both at
maximum, it responds to a NAK by sending an "NCF shed", and does not retransmit. The
receiver transport should wait, then send another NAK. If this count is high, one or
more crybaby receiver transports may be clogging the source transport's retransmit
queue.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of NAKs this source shed by sending an NCF with the reason code set to "shed"
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
naksShed
public long naksShed(int n)
throws LBMException
- Number of NAKs this source shed and sent an NCF with reason code "shed"
(LBT-RM, LBT-RU).
When a source transport's retransmit rate limiter and retransmit queue are both at
maximum, it responds to a NAK by sending an "NCF shed", and does not retransmit. The
receiver transport should wait, then send another NAK. If this count is high, one or
more crybaby receiver transports may be clogging the source transport's retransmit
queue.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of NAKs this source shed by sending an NCF with the reason code set to "shed"
- Throws:
LBMException
- if any error occurred retrieving source statistics.
naksIgnoredRetransmitDelay
public long naksIgnoredRetransmitDelay()
throws LBMException
- Number of NAKs this source did not process because doing so would exceed its retransmit
rate limit (LBT-RM, LBT-RU).
This rate limit is set by configuration option transport_lbtrm_retransmit_rate_limit
(default 5Mbps). For each of these NAKs, the source transport immediately sends an NFC
rx_delay, then queues the retransmission for a later send within the rate limit. If this
count is high, one or more crybaby receiver transports may be clogging the source
transport's retransmit queue.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of NAKs ignored due to retransmit delay
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
naksIgnoredRetransmitDelay
public long naksIgnoredRetransmitDelay(int n)
throws LBMException
- Number of NAKs this source did not process because doing so would exceed its retransmit
rate limit (LBT-RM, LBT-RU).
This rate limit is set by configuration option transport_lbtrm_retransmit_rate_limit
(default 5Mbps). For each of these NAKs, the source transport immediately sends an NFC
rx_delay, then queues the retransmission for a later send within the rate limit. If this
count is high, one or more crybaby receiver transports may be clogging the source
transport's retransmit queue.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of NAKs ignored due to retransmit delay
- Throws:
LBMException
- if any error occurred retrieving source statistics.
retransmissionsSent
public long retransmissionsSent()
throws LBMException
- Number of datagrams retransmitted by this source transport (LBT-RM, LBT-RU).
This count is incremented under the same circumstances as retransmissionBytesSent,
below. In a normal, light-loss scenario, most NAKs received induce a retransmission.
When losses become heavy and/or many receiver transports begin losing the same
datagrams, NCF-related no-retransmit counts (naksIgnored, naksShed and
naksIgnoredRetransmitDelay) may begin to inflate, and retransmissions
retransmissionsSent) may become significantly lower than NAKS received (naksReceived).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of datagrams retransmitted by this source
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
retransmissionsSent
public long retransmissionsSent(int n)
throws LBMException
- Number of datagrams retransmitted by this source transport (LBT-RM, LBT-RU).
This count is incremented under the same circumstances as retransmissionBytesSent,
below. In a normal, light-loss scenario, most NAKs received induce a retransmission.
When losses become heavy and/or many receiver transports begin losing the same
datagrams, NCF-related no-retransmit counts (naksIgnored, naksShed and
naksIgnoredRetransmitDelay) may begin to inflate, and retransmissions
retransmissionsSent) may become significantly lower than NAKS received (naksReceived).
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of datagrams retransmitted by this source
- Throws:
LBMException
- if any error occurred retrieving source statistics.
retransmissionBytesSent
public long retransmissionBytesSent()
throws LBMException
- Number of bytes retransmitted by this source transport (LBT-RM, LBT-RU).
This count is triggered under the same circumstances as retransmissionsSent, above. In a
normal, light-loss scenario, most NAKs received induce a retransmission. When losses
become heavy and/or many receiver transports begin losing the same datagrams,
NCF-related no-retransmit counts (naksIgnored, naksShed and naksIgnoredRetransmitDelay)
may begin to inflate, and retransmissions retransmissionsSent) may become significantly
lower than NAKs received (naksReceived).
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of transport bytes retransmitted by this source
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
retransmissionBytesSent
public long retransmissionBytesSent(int n)
throws LBMException
- Number of bytes retransmitted by this source transport (LBT-RM, LBT-RU).
This count is triggered under the same circumstances as retransmissionsSent, above. In a
normal, light-loss scenario, most NAKs received induce a retransmission. When losses
become heavy and/or many receiver transports begin losing the same datagrams,
NCF-related no-retransmit counts (naksIgnored, naksShed and naksIgnoredRetransmitDelay)
may begin to inflate, and retransmissions retransmissionsSent) may become significantly
lower than NAKs received (naksReceived).
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of transport bytes retransmitted by this source
- Throws:
LBMException
- if any error occurred retrieving source statistics.
messagesQueued
public long messagesQueued()
throws LBMException
- Number of datagrams currently queued by the data rate limiter (LBT-RM only).
When a source transport attempts to send messages (any type) faster than its data rate
limiter allows (set by configuration option transport_lbtrm_data_rate_limit, default
10Mbps), the data rate limiter queues the messages until they can be sent within the
data rate limit.
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of datagrams currently queued by the data rate limiter
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
messagesQueued
public long messagesQueued(int n)
throws LBMException
- Number of datagrams currently queued by the data rate limiter (LBT-RM only).
When a source transport attempts to send messages (any type) faster than its data rate
limiter allows (set by configuration option transport_lbtrm_data_rate_limit, default
10Mbps), the data rate limiter queues the messages until they can be sent within the
data rate limit.
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of datagrams currently queued by the data rate limiter
- Throws:
LBMException
- if any error occurred retrieving source statistics.
retransmissionsQueued
public long retransmissionsQueued()
throws LBMException
- Number of retransmission datagrams currently queued by the retransmit
rate limiter (LBT-RM only).
When a source transport attempts to send retransmissions faster that its
retransmit rate limiter allows (set by configuration option
transport_lbtrm_retransmit_rate_limit, default 5Mbps), the retransmit rate limiter
queues retransmissions until they can be sent within the rate limit.
naks_rx_delay_ignored (above) will generally also rise if this count is high
This method returns a value from the first
This method returns a value from the first
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Returns:
- Number of datagrams currently queued by the retransmit rate limiter
- Throws:
LBMException
- if any error occurred retrieving source statistics.- See Also:
LBMSourceStatistics(LBMSource)
retransmissionsQueued
public long retransmissionsQueued(int n)
throws LBMException
- Number of retransmission datagrams currently queued by the retransmit
rate limiter (LBT-RM only).
When a source transport attempts to send retransmissions faster that its
retransmit rate limiter allows (set by configuration option
transport_lbtrm_retransmit_rate_limit, default 5Mbps), the retransmit rate limiter
queues retransmissions until they can be sent within the rate limit.
naks_rx_delay_ignored (above) will generally also rise if this count is high
This method returns a value from the first
This method returns a value from the nth
set of statistics encapsulated within this object
and would normally be used when the object has been
created using a specific source to instantiate the class.
- Parameters:
n
- Statistics set index
- Returns:
- Number of datagrams currently queued by the retransmit rate limiter
- Throws:
LBMException
- if any error occurred retrieving source statistics.
setSender
protected void setSender(long ip)
setTimestamp
protected void setTimestamp(long ts)
setApplicationSourceId
protected void setApplicationSourceId(java.lang.String appid)
setProcessId
protected void setProcessId(long pid)
setContextId
protected void setContextId(long cid)
getApplicationSourceId
public java.lang.String getApplicationSourceId()
- Retrieve the application source identifier associated with this
set of statistics.
This attribute is only set for statistics returned by the UM
Monitoring framework.
- Returns:
- Application source ID
getSender
public java.net.InetAddress getSender()
throws java.net.UnknownHostException
- Retrieve the IP sender address associated with this set of statistics.
This attribute is only set for statistics returned by the UM
Monitoring framework.
- Returns:
- InetAddress object corresponding to the statistics' sender
IP address
- Throws:
java.net.UnknownHostException
- if IP address is of illegal length.
getTimestamp
public java.util.Date getTimestamp()
- Retrieve the timestamp associated with this set of statistics.
This attribute is only set for statistics returned by the UM
Monitoring framework.
- Returns:
- Timestamp Date object
getProcessId
public long getProcessId()
- Retrieve the sending process ID associated with this set of statistics.
This attribute is only set for statistics returned by the UM
Monitoring framework.
- Returns:
- Process ID
getContextId
public long getContextId()
- Retrieve the sending context ID associated with this set of statistics.
This attribute is only set for statistics returned by the UM
Monitoring framework.
- Returns:
- Context ID
All of the documentation and software included in this and any other Informatica Inc "Ultra Messaging" Release is Copyright (C) 2004-2014, Informatica Corporation. All rights reserved. Redistribution and use in source and binary forms, with or without modification, are permitted only as covered by the terms of a valid software license agreement with 29West Inc. Copyright © 2004-2014, Informatica, Inc. All Rights Reserved.