|
Project JXTA | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.rendezvous.RendezVousServiceProvider
net.jxta.impl.rendezvous.StdRendezVousService
net.jxta.impl.rendezvous.rdv.RdvPeerRdvService
public class RdvPeerRdvService
A JXTA RendezvousService
implementation which
implements the rendezvous server portion of the standard JXTA Rendezvous
Protocol (RVP).
RendezvousService
,
JXTA Protocols Specification : Rendezvous ProtocolNested Class Summary |
---|
Nested classes/interfaces inherited from class net.jxta.impl.rendezvous.StdRendezVousService |
---|
StdRendezVousService.StdRdvProtocolListener |
Field Summary | |
---|---|
static long |
GC_INTERVAL
|
static String |
RDV_SVC_NAME
|
static String |
RDV_SVC_PARAM
|
Fields inherited from class net.jxta.impl.rendezvous.StdRendezVousService |
---|
ConnectedLeaseReply, ConnectedPeerReply, ConnectedRdvAdvReply, ConnectRequest, DEFAULT_MAX_TTL, DisconnectRequest, pName, pParam, RdvAdvReply, timer |
Fields inherited from class net.jxta.impl.rendezvous.RendezVousServiceProvider |
---|
closed, group, HEADER_NAME, MAX_TTL, MESSAGE_NAMESPACE_NAME, PropPName, PropSName, rdvService, rendezvousMeter, rendezvousServiceMonitor |
Constructor Summary | |
---|---|
RdvPeerRdvService(PeerGroup g,
RendezVousServiceImpl rdvService)
Constructor for the RdvPeerRdvService object |
Method Summary | |
---|---|
void |
challengeRendezVous(ID peer,
long delay)
Resets the local idea of the lease to the specified value. |
void |
disconnectFromRendezVous(ID peerId)
Remove a RendezVousService point. |
Vector |
getConnectedPeerIDs()
|
Enumeration |
getConnectedPeers()
|
Enumeration |
getConnectedRendezVous()
Returns an Enumeration of the PeerID all the RendezVous on which this Peer is currentely connected. |
Enumeration |
getDisconnectedRendezVous()
Returns an Enumeration of the PeerID all the RendezVous on which this Peer failed to connect to. |
PeerConnection |
getPeerConnection(ID peer)
Returns the peer connection or null if not present. |
protected PeerConnection[] |
getPeerConnections()
Returns a list of the current peer connections. |
boolean |
isConnectedToRendezVous()
Return true if connected to a rendezvous. |
void |
propagate(Message msg,
String serviceName,
String serviceParam,
int ttl)
Propagates a message onto as many peers on the local network as possible. |
void |
propagateInGroup(Message msg,
String serviceName,
String serviceParam,
int ttl)
|
protected void |
repropagate(Message msg,
RendezVousPropagateMessage propHdr,
String serviceName,
String serviceParam)
|
void |
setChoiceDelay(long delay)
|
protected int |
startApp(String[] argv)
Supply arguments and starts this service if it hadn't started by itself. |
protected void |
stopApp()
Ask this service to stop. |
void |
walk(Message msg,
String serviceName,
String serviceParam,
int ttl)
Walk a message through the rendezvous peers of the network: only rendezvous peers will receive the message. |
void |
walk(Vector destPeerIDs,
Message msg,
String serviceName,
String serviceParam,
int defaultTTL)
Walk a message through the rendezvous peers of the network: only rendezvous peers will receive the message. |
Methods inherited from class net.jxta.impl.rendezvous.StdRendezVousService |
---|
processRdvAdvReply, processReceivedMessage, propagate, propagateToNeighbors, sendDisconnect, sendDisconnect, sendToEachConnection, startApp |
Methods inherited from class net.jxta.impl.rendezvous.RendezVousServiceProvider |
---|
checkPropHeader, getPeerAdvertisementDoc, getPropHeader, mkAddress, mkAddress, processIncomingMessage, sendToNetwork, setRendezvousServiceMonitor, updatePropHeader |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String RDV_SVC_NAME
public static final String RDV_SVC_PARAM
public static final long GC_INTERVAL
Constructor Detail |
---|
public RdvPeerRdvService(PeerGroup g, RendezVousServiceImpl rdvService)
Method Detail |
---|
protected int startApp(String[] argv)
startApp
in class RendezVousServiceProvider
protected void stopApp()
stopApp
in class StdRendezVousService
public void challengeRendezVous(ID peer, long delay)
challengeRendezVous
in class RendezVousServiceProvider
peer
- The peer to be chanllengeddelay
- The delaypublic void disconnectFromRendezVous(ID peerId)
disconnectFromRendezVous
in class RendezVousServiceProvider
peerId
- the PeerId of the RendezVous to disconnect from.public boolean isConnectedToRendezVous()
isConnectedToRendezVous
in class RendezVousServiceProvider
public void setChoiceDelay(long delay)
setChoiceDelay
in class RendezVousServiceProvider
public Vector getConnectedPeerIDs()
getConnectedPeerIDs
in class RendezVousServiceProvider
public Enumeration getConnectedPeers()
getConnectedPeers
in class RendezVousServiceProvider
public Enumeration getConnectedRendezVous()
getConnectedRendezVous
in class RendezVousServiceProvider
public Enumeration getDisconnectedRendezVous()
getDisconnectedRendezVous
in class RendezVousServiceProvider
public void propagate(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
propagate
in class RendezVousServiceProvider
msg
- is the message to propagate.serviceName
- is the name of the serviceserviceParam
- is the parameter of the service
IOException
public void propagateInGroup(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
propagateInGroup
in class RendezVousServiceProvider
IOException
protected void repropagate(Message msg, RendezVousPropagateMessage propHdr, String serviceName, String serviceParam)
repropagate
in class RendezVousServiceProvider
public PeerConnection getPeerConnection(ID peer)
StdRendezVousService
getPeerConnection
in class StdRendezVousService
protected PeerConnection[] getPeerConnections()
StdRendezVousService
getPeerConnections
in class StdRendezVousService
public void walk(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
walk
in class RendezVousServiceProvider
msg
- is the message to walk.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicettl
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.
IOException
- when walking the message is impossible (network failure)public void walk(Vector destPeerIDs, Message msg, String serviceName, String serviceParam, int defaultTTL) throws IOException
walk
in class RendezVousServiceProvider
destPeerIDs
- is a Vector of PeerID of the peers which are receiving
first the walker. Note that each entry in the Vector will create its own
walker.msg
- is the message to walk.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicedefaultTTL
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.
IOException
- when walking the message is impossible (network failure)
|
JXTA J2SE | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |