Package org.yamcs.cfdp

Class CfdpOutgoingTransfer

java.lang.Object

org.yamcs.cfdp.CfdpTransfer

org.yamcs.cfdp.CfdpOutgoingTransfer

public class CfdpOutgoingTransfer
extends CfdpTransfer

Field Summary

Fields inherited from class org.yamcs.cfdp.CfdpTransfer

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

Constructor Summary

Constructors

Constructor	Description
CfdpOutgoingTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, PutRequest request, Stream cfdpOut, YConfiguration config, EventProducer eventProducer, TransferMonitor monitor)

Method Summary

Modifier and Type	Method	Description
boolean	cancellable()
CfdpOutgoingTransfer	cancelTransfer()
Bucket	getBucket()
org.yamcs.cfdp.CfdpOutgoingTransfer.OutgoingTransferState	getCfdpState()
org.yamcs.protobuf.TransferDirection	getDirection()
String	getObjectName()
String	getRemotePath()
long	getTotalSize()
long	getTransferredSize()
protected void	onInactivityTimerExpiration()
boolean	pausable()
CfdpOutgoingTransfer	pause()
void	processPacket(CfdpPacket packet)
CfdpOutgoingTransfer	resumeTransfer()
void	run()
void	start()

Methods inherited from class org.yamcs.cfdp.CfdpTransfer

cancelInactivityTimer, changeState, getFailuredReason, getId, getStartTime, getTransactionId, getTransferState, isOngoing, isReliable, rescheduleInactivityTimer, sendPacket

Methods inherited from class java.lang.Object

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

Constructor Detail

CfdpOutgoingTransfer

public CfdpOutgoingTransfer(String yamcsInstance,
                            ScheduledThreadPoolExecutor executor,
                            PutRequest request,
                            Stream cfdpOut,
                            YConfiguration config,
                            EventProducer eventProducer,
                            TransferMonitor monitor)

Method Detail

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

getTransferredSize

public long getTransferredSize()

Specified by:

getTransferredSize in class CfdpTransfer

run

public void run()

onInactivityTimerExpiration

protected void onInactivityTimerExpiration()

Specified by:

onInactivityTimerExpiration in class CfdpTransfer

getCfdpState

public org.yamcs.cfdp.CfdpOutgoingTransfer.OutgoingTransferState getCfdpState()

getDirection

public org.yamcs.protobuf.TransferDirection getDirection()

Specified by:

getDirection in class CfdpTransfer

getTotalSize

public long getTotalSize()

Specified by:

getTotalSize in class CfdpTransfer

pause

public CfdpOutgoingTransfer pause()

Overrides:

pause in class CfdpTransfer

resumeTransfer

public CfdpOutgoingTransfer resumeTransfer()

Overrides:

resumeTransfer in class CfdpTransfer

cancelTransfer

public CfdpOutgoingTransfer cancelTransfer()

Overrides:

cancelTransfer in class CfdpTransfer

start

public void start()

processPacket

public void processPacket(CfdpPacket packet)

Specified by:

processPacket in class CfdpTransfer

cancellable

public boolean cancellable()

Specified by:

cancellable in class CfdpTransfer

pausable

public boolean pausable()

Specified by:

pausable in class CfdpTransfer