rice.p2p.splitstream.testing
Class MySplitStreamClient
java.lang.Object
rice.p2p.splitstream.testing.MySplitStreamClient
- All Implemented Interfaces:
- SplitStreamClient
public class MySplitStreamClient
- extends java.lang.Object
- implements SplitStreamClient
- Author:
- Jeff Hoye
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SEND_PERIOD
public static int SEND_PERIOD
msgSize
public static int msgSize
MySplitStreamClient
public MySplitStreamClient(PastryNode n,
java.lang.String instance)
attachChannel
public void attachChannel(ChannelId cid)
subscribeToAllChannels
public void subscribeToAllChannels()
getStripes
public Stripe[] getStripes()
shouldPublish
public boolean shouldPublish()
publishNext
public void publishNext()
publish
public void publish(Id id,
int seq)
publishAll
public void publishAll(byte[] b)
publish
public void publish(byte[] b,
Stripe s)
joinFailed
public void joinFailed(Stripe s)
- Description copied from interface:
SplitStreamClient
- This is a call back into the application to notify it that one of the stripes was unable to to
find a parent, and thus unable to recieve data.
- Specified by:
joinFailed
in interface SplitStreamClient
- Parameters:
s
- The stripe which the join failed on
deliver
public void deliver(Stripe s,
byte[] data)
- Description copied from interface:
SplitStreamClient
- Is called when data is received on a stripe which this client has registered interest
- Specified by:
deliver
in interface SplitStreamClient
- Parameters:
s
- The stripe the data as received ondata
- The data that was received
startPublishTask
public void startPublishTask()
Copyright © 2001-2005 - Rice Pastry.