Package org.yamcs.cfdp

Class CfdpOutgoingTransfer

java.lang.Object

org.yamcs.cfdp.OngoingCfdpTransfer

org.yamcs.cfdp.CfdpOutgoingTransfer

All Implemented Interfaces:

CfdpFileTransfer, FileTransfer

public class CfdpOutgoingTransfer
extends OngoingCfdpTransfer

Field Summary

Fields inherited from class org.yamcs.cfdp.OngoingCfdpTransfer

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

Constructor Summary

Constructors

Constructor	Description
CfdpOutgoingTransfer(String yamcsInstance, long id, long creationTime, ScheduledThreadPoolExecutor executor, PutRequest request, Stream cfdpOut, YConfiguration config, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)

Method Summary

Modifier and Type	Method	Description
protected void	cancel(ConditionCode conditionCode)
String	getBucketName()
org.yamcs.cfdp.CfdpOutgoingTransfer.OutTxState	getCfdpState()
org.yamcs.protobuf.TransferDirection	getDirection()
String	getObjectName()
String	getRemotePath()
long	getTotalSize()
long	getTransferredSize()
protected void	onInactivityTimerExpiration()	The inactivity timer is active after the EOF ACK has been received
void	processPacket(CfdpPacket packet)
protected void	resume()
void	start()
protected void	suspend()

Methods inherited from class org.yamcs.cfdp.OngoingCfdpTransfer

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

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,
                            long id,
                            long creationTime,
                            ScheduledThreadPoolExecutor executor,
                            PutRequest request,
                            Stream cfdpOut,
                            YConfiguration config,
                            EventProducer eventProducer,
                            TransferMonitor monitor,
                            Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)

Method Detail

start

public void start()

processPacket

public void processPacket(CfdpPacket packet)

Specified by:

processPacket in class OngoingCfdpTransfer

onInactivityTimerExpiration

protected void onInactivityTimerExpiration()

The inactivity timer is active after the EOF ACK has been received

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

getCfdpState

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

cancel

protected void cancel(ConditionCode conditionCode)

Specified by:

cancel in class OngoingCfdpTransfer

getDirection

public org.yamcs.protobuf.TransferDirection getDirection()

getTotalSize

public long getTotalSize()

getBucketName

public String getBucketName()

getObjectName

public String getObjectName()

getRemotePath

public String getRemotePath()

getTransferredSize

public long getTransferredSize()