Package org.yamcs.cfdp

Class CfdpTransfer

java.lang.Object

org.yamcs.cfdp.CfdpTransfer

Direct Known Subclasses:

CfdpIncomingTransfer, CfdpOutgoingTransfer

public abstract class CfdpTransfer
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	acknowledged
protected CfdpTransactionId	cfdpTransactionId
protected EventProducer	eventProducer
protected ScheduledThreadPoolExecutor	executor
protected ScheduledFuture<?>	inactivityFuture
protected Log	log
protected long	startTime
protected org.yamcs.protobuf.TransferState	state

Constructor Summary

Constructors

Constructor	Description
CfdpTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, long initiatorEntity, Stream cfdpOut, EventProducer eventProducer, TransferMonitor monitor)
CfdpTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpTransactionId cfdpTransactionId, Stream cfdpOut, EventProducer eventProducer, TransferMonitor monitor)

Method Summary

Modifier and Type	Method	Description
protected void	cancelInactivityTimer()
abstract boolean	cancellable()
CfdpTransfer	cancelTransfer()
protected void	changeState(org.yamcs.protobuf.TransferState newState)
abstract Bucket	getBucket()
abstract org.yamcs.protobuf.TransferDirection	getDirection()
String	getFailuredReason()
int	getId()
abstract String	getObjectName()
abstract String	getRemotePath()
long	getStartTime()
abstract long	getTotalSize()
CfdpTransactionId	getTransactionId()
abstract long	getTransferredSize()
org.yamcs.protobuf.TransferState	getTransferState()
boolean	isOngoing()
boolean	isReliable()
protected abstract void	onInactivityTimerExpiration()
abstract boolean	pausable()
CfdpTransfer	pause()
abstract void	processPacket(CfdpPacket packet)
protected void	rescheduleInactivityTimer()
CfdpTransfer	resumeTransfer()
protected void	sendPacket(CfdpPacket p)

Methods inherited from class java.lang.Object

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

Field Detail

cfdpTransactionId

protected CfdpTransactionId cfdpTransactionId

state

protected org.yamcs.protobuf.TransferState state

executor

protected final ScheduledThreadPoolExecutor executor

eventProducer

protected final EventProducer eventProducer

acknowledged

protected boolean acknowledged

log

protected final Log log

startTime

protected final long startTime

inactivityFuture

protected ScheduledFuture<?> inactivityFuture

Constructor Detail

CfdpTransfer

public CfdpTransfer(String yamcsInstance,
                    ScheduledThreadPoolExecutor executor,
                    YConfiguration config,
                    long initiatorEntity,
                    Stream cfdpOut,
                    EventProducer eventProducer,
                    TransferMonitor monitor)

CfdpTransfer

public CfdpTransfer(String yamcsInstance,
                    ScheduledThreadPoolExecutor executor,
                    YConfiguration config,
                    CfdpTransactionId cfdpTransactionId,
                    Stream cfdpOut,
                    EventProducer eventProducer,
                    TransferMonitor monitor)

Method Detail

processPacket

public abstract void processPacket(CfdpPacket packet)

sendPacket

protected void sendPacket(CfdpPacket p)

isOngoing

public final boolean isOngoing()

getTransferState

public final org.yamcs.protobuf.TransferState getTransferState()

getBucket

public abstract Bucket getBucket()

getObjectName

public abstract String getObjectName()

getRemotePath

public abstract String getRemotePath()

getDirection

public abstract org.yamcs.protobuf.TransferDirection getDirection()

getTotalSize

public abstract long getTotalSize()

getTransferredSize

public abstract long getTransferredSize()

cancellable

public abstract boolean cancellable()

pausable

public abstract boolean pausable()

onInactivityTimerExpiration

protected abstract void onInactivityTimerExpiration()

cancelInactivityTimer

protected void cancelInactivityTimer()

rescheduleInactivityTimer

protected void rescheduleInactivityTimer()

pause

public CfdpTransfer pause()

resumeTransfer

public CfdpTransfer resumeTransfer()

cancelTransfer

public CfdpTransfer cancelTransfer()

getTransactionId

public CfdpTransactionId getTransactionId()

isReliable

public boolean isReliable()

getStartTime

public long getStartTime()

changeState

protected void changeState(org.yamcs.protobuf.TransferState newState)

getFailuredReason

public String getFailuredReason()

getId

public int getId()