cgl.narada.service.reliable.impl
Class RdFragmentationHelper

java.lang.Object
  cgl.narada.service.reliable.impl.RdFragmentationHelper

All Implemented Interfaces:

RdDebugFlags

public class RdFragmentationHelper
extends Object
implements RdDebugFlags

Field Summary

Fields inherited from interface cgl.narada.service.reliable.impl.RdDebugFlags

InvoicerThread_Debug, NakProcessor_Debug, PublisherPercolator_Debug, RdEntityActuatorImpl_Debug, RdFragmentationHelper_Debug, RdPublishingEntityImpl_Debug, SubscriberPercolator_Debug

Constructor Summary

RdFragmentationHelper(QosServiceImpl qosServiceImpl)

Method Summary

void	catenationNumberAssigned(NBEvent fragmentedEvent, int catenationNumber) Keeps track of the catenation number that has been assigned to individual fragments
void	drainPayloadFromEvent(NBEvent fragmentedEvent)
void	fragmentStoredReliably(NBEvent fragmentedEvent)
void	onRecovery(int publisherCatenationNum) After recovery, we need to make sure that any pending fragments of files need to be sent across
void	refillPayloadIntoEvent(NBEvent fragmentedEvent) If there is a retransmission request and the event is a fragmented one, we need to retrieve this informtion from a file and then add this to the payload

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RdFragmentationHelper

public RdFragmentationHelper(QosServiceImpl qosServiceImpl)

Method Detail

onRecovery

public void onRecovery(int publisherCatenationNum)
                throws ServiceException

After recovery, we need to make sure that any pending fragments of files need to be sent across

Throws:

ServiceException

drainPayloadFromEvent

public void drainPayloadFromEvent(NBEvent fragmentedEvent)

refillPayloadIntoEvent

public void refillPayloadIntoEvent(NBEvent fragmentedEvent)
                            throws ServiceException

If there is a retransmission request and the event is a fragmented one, we need to retrieve this informtion from a file and then add this to the payload

Throws:

ServiceException

catenationNumberAssigned

public void catenationNumberAssigned(NBEvent fragmentedEvent,
                                     int catenationNumber)
                              throws ServiceException

Keeps track of the catenation number that has been assigned to individual fragments

Throws:

ServiceException

fragmentStoredReliably

public void fragmentStoredReliably(NBEvent fragmentedEvent)
                            throws ServiceException

Throws:

ServiceException