cgl.narada.service.fragmentation
Class FragmentationService

java.lang.Object
  extended by cgl.narada.service.fragmentation.FragmentationService

public class FragmentationService
extends Object

This class is responsible for fragmenting events. Based on the specified fragmentation constraints.


Constructor Summary
protected FragmentationService()
          This is to be used for testing purposes only
  FragmentationService(QosServiceImpl qosServiceImpl)
           
 
Method Summary
 void assignedCatenationNum(String filename, int fragmentNum, int catenationNum)
          This is used by the reliable delivery algorithm to update information regarding the catenation number associated with the fragment for a specific file
 void checkForPendingTransfers(int publisherCatenationNumber)
           
 void fragmentEvent(NBEvent nbEvent, ProducerConstraints producerConstraints)
           
static void main(String[] args)
           
 void processReliableStorageOf(String filename, int fragmentNumber)
          This is used by the reliable delivery service to manage the successful storage of the fragment of a file
 byte[] retrievePayloadForFragment(String filename, int fragmentNumber)
          This is used by the Reliable delivery algorithm to satisfy requests for retransmissions
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FragmentationService

protected FragmentationService()
This is to be used for testing purposes only


FragmentationService

public FragmentationService(QosServiceImpl qosServiceImpl)
Method Detail

fragmentEvent

public void fragmentEvent(NBEvent nbEvent,
                          ProducerConstraints producerConstraints)
                   throws ServiceException
Throws:
ServiceException

retrievePayloadForFragment

public byte[] retrievePayloadForFragment(String filename,
                                         int fragmentNumber)
                                  throws ServiceException
This is used by the Reliable delivery algorithm to satisfy requests for retransmissions

Throws:
ServiceException

assignedCatenationNum

public void assignedCatenationNum(String filename,
                                  int fragmentNum,
                                  int catenationNum)
                           throws ServiceException
This is used by the reliable delivery algorithm to update information regarding the catenation number associated with the fragment for a specific file

Throws:
ServiceException

processReliableStorageOf

public void processReliableStorageOf(String filename,
                                     int fragmentNumber)
                              throws ServiceException
This is used by the reliable delivery service to manage the successful storage of the fragment of a file

Throws:
ServiceException

checkForPendingTransfers

public void checkForPendingTransfers(int publisherCatenationNumber)
                              throws ServiceException
Throws:
ServiceException

main

public static void main(String[] args)


For comments and suggestions please send e-mail to The NaradaBrokering Project