jadex.base.relay

Class PeerList

java.lang.Object

jadex.base.relay.PeerList

public class PeerList
extends java.lang.Object

The peer list actively manages the list of connected peer relay servers.

Field Summary

Fields

Modifier and Type	Field and Description
protected RelayHandler	handler The relay handler.
protected java.util.Map<java.lang.String,PeerHandler>	peers The peer handlers for polling relay peers (url -> peer handler).

Constructor Summary

Constructors

Constructor and Description
PeerList(RelayHandler handler) Create a new peer list.

Method Summary

Modifier and Type	Method and Description
PeerHandler	addPeer(java.lang.String peerurl) Add a peer that requested a connection.
PeerHandler	addPeer(java.lang.String peerurl, java.lang.String peerid, int peerstate) Add a peer that requested a connection.
protected PeerHandler	addPeer(java.lang.String peerurl, java.lang.String peerid, int peerstate, boolean initial) Add a peer found in a servers list or a peer that requested a connection.
void	addPeers(java.lang.String peerurls, boolean initial) Add peers from a servers list.
boolean	checkPlatform(java.lang.String id) Test if the given platform is connected to some peer.
void	dispose() Stop any activities for managing the peer list.
PeerHandler[]	getPeers() Get the currently connected peers.
java.lang.String	getURLs(java.lang.String request) Get the known relay urls.
void	removePeer(PeerHandler peer) Remove a peer from the list.

Methods inherited from class java.lang.Object

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

Field Detail

handler

protected RelayHandler handler

The relay handler.

peers

protected java.util.Map<java.lang.String,PeerHandler> peers

The peer handlers for polling relay peers (url -> peer handler).

Constructor Detail

PeerList

public PeerList(RelayHandler handler)

Create a new peer list.

Method Detail

dispose

public void dispose()

Stop any activities for managing the peer list.

getURLs

public java.lang.String getURLs(java.lang.String request)

Get the known relay urls. If no urls are known, the request url is returned.

getPeers

public PeerHandler[] getPeers()

Get the currently connected peers.

checkPlatform

public boolean checkPlatform(java.lang.String id)

Test if the given platform is connected to some peer.

addPeers

public void addPeers(java.lang.String peerurls,
                     boolean initial)

Add peers from a servers list.

Parameters:

peerurls - The remote peer urls (comma separated).

initial - Denotes an initial peer as specified in the properties of this relay. Initial peers are not removed when they are offline.

addPeer

public PeerHandler addPeer(java.lang.String peerurl)

Add a peer that requested a connection.

Parameters:

peerurl - The remote peer url.

addPeer

public PeerHandler addPeer(java.lang.String peerurl,
                           java.lang.String peerid,
                           int peerstate)

Add a peer that requested a connection. Called for the continuous pings sent by connected peers.

Parameters:

peerurl - The remote peer url.

peerid - Contains the id of the remote peer.

peerstate - Contains id of the latest history entry of that peer to enable synchronization.

removePeer

public void removePeer(PeerHandler peer)

Remove a peer from the list.

addPeer

protected PeerHandler addPeer(java.lang.String peerurl,
                              java.lang.String peerid,
                              int peerstate,
                              boolean initial)

Add a peer found in a servers list or a peer that requested a connection. Also called for the continuous pings sent by connected peers.

Parameters:

peerurl - The remote peer url.

peerid - If called from remote peer, contains the id of that peer.

peerstate - If called from remote peer, contains id of the latest history entry of that peer to enable synchronization.

initial - Denotes an initial peer as specified in the properties of this relay. Initial peers are not removed when they are offline.