com.bea.wcp.diameter

Class PeerTable

java.lang.Object

com.bea.wcp.diameter.PeerTable

public final class PeerTable
extends Object

The peer table manages information about configured Diameter peers.

Author:

Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAXIMUM_ATTEMPTS
static int	DEFAULT_PEER_RETRY_DELAY Default connection retry in second.s
static long	DEFAULT_REQUEST_TIMEOUT Default request timeout in milliseconds.
static int	DEFAULT_WATCHDOG_TIMEOUT Default watchdog timeout in seconds.
static int	WATCHDOG_TICK_RESOLUTION Watchdog period in milliiseconds.

Method Summary

Modifier and Type	Method and Description
void	addPeer(Peer peer)
void	addPeer(String host, InetAddress addr, int port)
void	addPeerIpAddressToHostIdMapping(Peer peer, String host)
int	getMaxRequestAttempts() Returns the maximum number of times to retry a send.
Peer	getPeer(String host)
Peer	getPeerByAddress(InetAddress address)
int	getPeerRetryDelay() Returns the time to wait for attempting to reconnect to a failed peer.
Peer	getPeerWithoutCreation(String host)
long	getRequestTimeout() Returns the maximum time to wait for an answer to a request.
int	getWatchdogTimeout()
boolean	isAllowDynamicPeers()
List<String>	listPeers() Lists all known peer host names.
void	scheduleReconnect(Peer peer) Schedules a timer task to reconnect to a peer after a configured peerRetryDelay (specified as timer "Tc" in RFC3588).
TimerTask	scheduleWatchdogTick(Peer peer) Schedules a timer task tick to expire a watchdog timer (specified as timer "Tw" in RFC3539).
void	setAllowDynamicPeers(boolean status)
void	setMaxRequestAttempts(int maximum) Sets the number of times to retry on failure.
void	setPeerRetryDelay(int secs) Sets the time to wait before attempting to reconnect to a failed peer.
void	setRequestTimeout(long msec) Sets the maximum time to wait for an answer to a request.
void	setWatchdogTimeout(int secs) Sets the watchdog timeout Tw.
void	start()
void	stop() Stops all peers.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PEER_RETRY_DELAY

public static final int DEFAULT_PEER_RETRY_DELAY

Default connection retry in second.s

See Also:

Constant Field Values

DEFAULT_REQUEST_TIMEOUT

public static final long DEFAULT_REQUEST_TIMEOUT

Default request timeout in milliseconds.

See Also:

Constant Field Values

DEFAULT_MAXIMUM_ATTEMPTS

public static final int DEFAULT_MAXIMUM_ATTEMPTS

See Also:

Constant Field Values

DEFAULT_WATCHDOG_TIMEOUT

public static final int DEFAULT_WATCHDOG_TIMEOUT

Default watchdog timeout in seconds.

See Also:

Constant Field Values

WATCHDOG_TICK_RESOLUTION

public static final int WATCHDOG_TICK_RESOLUTION

Watchdog period in milliiseconds.

See Also:

Constant Field Values

Method Detail

getPeer

public Peer getPeer(String host)

getPeerByAddress

public Peer getPeerByAddress(InetAddress address)

getPeerWithoutCreation

public Peer getPeerWithoutCreation(String host)

addPeer

public void addPeer(Peer peer)

addPeerIpAddressToHostIdMapping

public void addPeerIpAddressToHostIdMapping(Peer peer,
                                            String host)

addPeer

public void addPeer(String host,
                    InetAddress addr,
                    int port)

listPeers

public List<String> listPeers()

Lists all known peer host names.

Returns:

Hostname of all peers

start

public void start()

scheduleReconnect

public void scheduleReconnect(Peer peer)

Schedules a timer task to reconnect to a peer after a configured peerRetryDelay (specified as timer "Tc" in RFC3588). The default is to reconnect after 30 seconds.

Parameters:

peer - the peer to reconnect to after the configured peerRetryDelay

scheduleWatchdogTick

public TimerTask scheduleWatchdogTick(Peer peer)

Schedules a timer task tick to expire a watchdog timer (specified as timer "Tw" in RFC3539).

Parameters:

peer - the peer to inform about Tw tick

Returns:

null if timer is not available yet

setPeerRetryDelay

public void setPeerRetryDelay(int secs)

Sets the time to wait before attempting to reconnect to a failed peer.

Parameters:

secs - the peer retry delay in seconds

getPeerRetryDelay

public int getPeerRetryDelay()

Returns the time to wait for attempting to reconnect to a failed peer.

Returns:

the peer retry delay in seconds

setRequestTimeout

public void setRequestTimeout(long msec)

Sets the maximum time to wait for an answer to a request. If no answer is received within the given timeout period, then an UNABLE_TO_DELIVER error answer will generated and delivered to the application. (assuming that all retries have been exhausted). Note that retries are attempted after a timeout, so the total request duration is maxAttempts * timeout length.

Parameters:

msec - the request timeout in milliseconds

getRequestTimeout

public long getRequestTimeout()

Returns the maximum time to wait for an answer to a request.

Returns:

the request timeout in milliseconds

setMaxRequestAttempts

public void setMaxRequestAttempts(int maximum)

Sets the number of times to retry on failure.

Parameters:

maximum - the number of times to attempt to send a request.

getMaxRequestAttempts

public int getMaxRequestAttempts()

Returns the maximum number of times to retry a send.

Returns:

the max retries value

setWatchdogTimeout

public void setWatchdogTimeout(int secs)

Sets the watchdog timeout Tw.

Parameters:

secs - watchdog timeout Tw

getWatchdogTimeout

public int getWatchdogTimeout()

Returns:

the value of Tw in seconds

stop

public void stop()

Stops all peers.

setAllowDynamicPeers

public void setAllowDynamicPeers(boolean status)

isAllowDynamicPeers

public boolean isAllowDynamicPeers()