Rice Pastry API

rice.p2p.splitstream.testing
Class MySplitStreamClient

java.lang.Object
  extended by rice.p2p.splitstream.testing.MySplitStreamClient
All Implemented Interfaces:
SplitStreamClient

public class MySplitStreamClient
extends java.lang.Object
implements SplitStreamClient

Author:
Jeff Hoye

Field Summary
static int msgSize
           
static int SEND_PERIOD
           
 
Constructor Summary
MySplitStreamClient(PastryNode n, java.lang.String instance)
           
 
Method Summary
 void attachChannel(ChannelId cid)
           
 void deliver(Stripe s, byte[] data)
          Is called when data is received on a stripe which this client has registered interest
 Stripe[] getStripes()
           
 void joinFailed(Stripe s)
          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.
 void publish(byte[] b, Stripe s)
           
 void publish(Id id, int seq)
           
 void publishAll(byte[] b)
           
 void publishNext()
           
 boolean shouldPublish()
           
 void startPublishTask()
           
 void subscribeToAllChannels()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

SEND_PERIOD

public static int SEND_PERIOD

msgSize

public static int msgSize
Constructor Detail

MySplitStreamClient

public MySplitStreamClient(PastryNode n,
                           java.lang.String instance)
Method Detail

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 on
data - The data that was received

startPublishTask

public void startPublishTask()

Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection