Package org.yamcs.cfdp

Class CfdpIncomingTransfer

java.lang.Object

org.yamcs.cfdp.CfdpTransfer

org.yamcs.cfdp.CfdpIncomingTransfer

public class CfdpIncomingTransfer
extends CfdpTransfer

Field Summary

Fields inherited from class org.yamcs.cfdp.CfdpTransfer

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

Constructor Summary

Constructors

Constructor	Description
CfdpIncomingTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpTransactionId id, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor)
CfdpIncomingTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, MetadataPacket packet, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor)

Method Summary

Modifier and Type	Method	Description
boolean	cancellable()
Bucket	getBucket()
org.yamcs.protobuf.TransferDirection	getDirection()
String	getObjectName()
String	getRemotePath()
long	getTotalSize()
long	getTransferredSize()
protected void	onInactivityTimerExpiration()
boolean	pausable()
void	processPacket(CfdpPacket packet)

Methods inherited from class org.yamcs.cfdp.CfdpTransfer

cancelInactivityTimer, cancelTransfer, changeState, getFailuredReason, getId, getStartTime, getTransactionId, getTransferState, isOngoing, isReliable, pause, rescheduleInactivityTimer, resumeTransfer, 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,
                            ScheduledThreadPoolExecutor executor,
                            YConfiguration config,
                            MetadataPacket packet,
                            Stream cfdpOut,
                            Bucket target,
                            EventProducer eventProducer,
                            TransferMonitor monitor)

CfdpIncomingTransfer

public CfdpIncomingTransfer(String yamcsInstance,
                            ScheduledThreadPoolExecutor executor,
                            YConfiguration config,
                            CfdpTransactionId id,
                            Stream cfdpOut,
                            Bucket target,
                            EventProducer eventProducer,
                            TransferMonitor monitor)

Method Detail

processPacket

public void processPacket(CfdpPacket packet)

Specified by:

processPacket in class CfdpTransfer

onInactivityTimerExpiration

protected void onInactivityTimerExpiration()

Specified by:

onInactivityTimerExpiration in class CfdpTransfer

getBucket

public Bucket getBucket()

Specified by:

getBucket in class CfdpTransfer

getObjectName

public String getObjectName()

Specified by:

getObjectName in class CfdpTransfer

getRemotePath

public String getRemotePath()

Specified by:

getRemotePath in class CfdpTransfer

getDirection

public org.yamcs.protobuf.TransferDirection getDirection()

Specified by:

getDirection in class CfdpTransfer

getTotalSize

public long getTotalSize()

Specified by:

getTotalSize in class CfdpTransfer

getTransferredSize

public long getTransferredSize()

Specified by:

getTransferredSize in class CfdpTransfer

cancellable

public boolean cancellable()

Specified by:

cancellable in class CfdpTransfer

pausable

public boolean pausable()

Specified by:

pausable in class CfdpTransfer