|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--rice.p2p.splitstream.SplitStreamImpl
This is the implementing class of the ISplitStream interface. It provides the functionality of creating and attaching to channels. This class is responsible for handling all channels that a local node is part of.
Field Summary | |
protected java.util.Hashtable |
channels
Hashtable of all the channels currently created on this node implicitly or explicitly. |
protected rice.p2p.commonapi.Node |
node
The node that this application is running on |
protected rice.p2p.scribe.Scribe |
scribe
The scribe instance for this SplitStream Object |
Constructor Summary | |
SplitStreamImpl(rice.p2p.commonapi.Node node,
java.lang.String instance)
The constructor for building the splitStream object which internally creates it's own Scribe. |
Method Summary | |
rice.p2p.splitstream.Channel |
attachChannel(rice.p2p.splitstream.ChannelId id)
This method is used by peers who wish to listen to content distributed by some other peer using SplitStream. |
rice.p2p.splitstream.Channel |
createChannel(rice.p2p.splitstream.ChannelId id)
This method is used by a peer who wishes to distribute the content using SplitStream. |
rice.p2p.splitstream.Channel[] |
getChannels()
Returns all of the channels on this local splitstream |
rice.p2p.splitstream.SplitStreamScribePolicy |
getPolicy()
Returns the policy used to control Scribe |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected rice.p2p.scribe.Scribe scribe
protected rice.p2p.commonapi.Node node
protected java.util.Hashtable channels
Constructor Detail |
public SplitStreamImpl(rice.p2p.commonapi.Node node, java.lang.String instance)
node
- the pastry node that we will useinstance
- The instance name for this splitstreamMethod Detail |
public rice.p2p.splitstream.Channel createChannel(rice.p2p.splitstream.ChannelId id)
createChannel
in interface SplitStream
id
- The id of the channel to create
public rice.p2p.splitstream.Channel attachChannel(rice.p2p.splitstream.ChannelId id)
attachChannel
in interface SplitStream
id
- The id of the channel to create
public rice.p2p.splitstream.Channel[] getChannels()
getChannels
in interface SplitStream
public rice.p2p.splitstream.SplitStreamScribePolicy getPolicy()
|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |