Package org.yamcs.cfdp

Class CfdpIncomingTransfer

java.lang.Object

org.yamcs.cfdp.OngoingCfdpTransfer

org.yamcs.cfdp.CfdpIncomingTransfer

All Implemented Interfaces:

CfdpTransfer

public class CfdpIncomingTransfer
extends OngoingCfdpTransfer

Field Summary

Fields inherited from class org.yamcs.cfdp.OngoingCfdpTransfer

acknowledged, cfdpTransactionId, eventProducer, executor, failureReason, inactivityFuture, log, startTime, state

Constructor Summary

Constructors

Constructor	Description
CfdpIncomingTransfer(String yamcsInstance, long id, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpHeader hdr, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)
CfdpIncomingTransfer(String yamcsInstance, long id, ScheduledThreadPoolExecutor executor, YConfiguration config, MetadataPacket packet, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)

Method Summary

Modifier and Type	Method	Description
protected void	cancel(ConditionCode code)
String	getBucketName()
org.yamcs.protobuf.TransferDirection	getDirection()
String	getObjectName()
String	getRemotePath()
long	getTotalSize()
long	getTransferredSize()
protected void	onInactivityTimerExpiration()
void	processPacket(CfdpPacket packet)
protected void	resume()
protected void	suspend()

Methods inherited from class org.yamcs.cfdp.OngoingCfdpTransfer

abandonTransfer, cancelInactivityTimer, cancellable, cancelTransfer, changeState, failTransfer, getDestinationId, getFailuredReason, getFaultHandlingAction, getId, getSourceId, getStartTime, getTransactionId, getTransferState, isOngoing, isReliable, pausable, pauseTransfer, rescheduleInactivityTimer, resumeTransfer, sendAck, sendPacket

Methods inherited from class java.lang.Object

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

Constructor Detail

CfdpIncomingTransfer

public CfdpIncomingTransfer(String yamcsInstance,
                            long id,
                            ScheduledThreadPoolExecutor executor,
                            YConfiguration config,
                            MetadataPacket packet,
                            Stream cfdpOut,
                            Bucket target,
                            EventProducer eventProducer,
                            TransferMonitor monitor,
                            Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)

CfdpIncomingTransfer

public CfdpIncomingTransfer(String yamcsInstance,
                            long id,
                            ScheduledThreadPoolExecutor executor,
                            YConfiguration config,
                            CfdpHeader hdr,
                            Stream cfdpOut,
                            Bucket target,
                            EventProducer eventProducer,
                            TransferMonitor monitor,
                            Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)

Method Detail

processPacket

public void processPacket(CfdpPacket packet)

Specified by:

processPacket in class OngoingCfdpTransfer

onInactivityTimerExpiration

protected void onInactivityTimerExpiration()

Specified by:

onInactivityTimerExpiration in class OngoingCfdpTransfer

suspend

protected void suspend()

Specified by:

suspend in class OngoingCfdpTransfer

resume

protected void resume()

Specified by:

resume in class OngoingCfdpTransfer

cancel

protected void cancel(ConditionCode code)

Specified by:

cancel in class OngoingCfdpTransfer

getBucketName

public String getBucketName()

getObjectName

public String getObjectName()

getRemotePath

public String getRemotePath()

getDirection

public org.yamcs.protobuf.TransferDirection getDirection()

getTotalSize

public long getTotalSize()

getTransferredSize

public long getTransferredSize()