cgl.narada.service.fragmentation
Class FragmentationService

java.lang.Object
  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)