Package org.yamcs.cfdp

Class CfdpService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.AbstractYamcsService

org.yamcs.cfdp.CfdpService

All Implemented Interfaces:

com.google.common.util.concurrent.Service, TransferMonitor, YamcsService, StreamSubscriber

public class CfdpService
extends AbstractYamcsService
implements StreamSubscriber, TransferMonitor

Implements CCSDS File Delivery Protocol (CFDP) in Yamcs.

The standard is specified in CCSDS 727.0-B-4

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields inherited from class org.yamcs.AbstractYamcsService

config, log, yamcsInstance

Constructor Summary

Constructors

Constructor	Description
CfdpService()

Method Summary

Modifier and Type	Method	Description
void	addTransferListener(TransferMonitor listener)
protected void	doStart()
protected void	doStop()
CfdpTransfer	getCfdpTransfer(long id)
CfdpTransfer	getCfdpTransfer(CfdpTransactionId transferId)
Collection<CfdpTransfer>	getCfdpTransfers()
Spec	getSpec()	Returns the valid configuration options for this service.
void	init(String yamcsInstance, YConfiguration config)	Initialize this service.
void	onTuple(Stream stream, Tuple tuple)
CfdpTransfer	processRequest(CfdpRequest request)
void	removeTransferListener(TransferMonitor listener)
void	stateChanged(CfdpTransfer cfdpTransfer)
void	streamClosed(Stream stream)
CfdpOutgoingTransfer	upload(String objName, String target, boolean overwrite, boolean acknowledged, boolean createpath, Bucket b, byte[] objData)

Methods inherited from class org.yamcs.AbstractYamcsService

getConfig, getYamcsInstance

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Constructor Detail

CfdpService

public CfdpService()

Method Detail

getSpec

public Spec getSpec()

Description copied from interface: YamcsService

Returns the valid configuration options for this service.

Specified by:

getSpec in interface YamcsService

Returns:

the argument specification, or null if the args should not be validated.

init

public void init(String yamcsInstance,
                 YConfiguration config)
          throws InitException

Description copied from interface: YamcsService

Initialize this service. This is called before the service is started. All operations should finish fast.

Specified by:

init in interface YamcsService

Overrides:

init in class AbstractYamcsService

Parameters:

yamcsInstance - The yamcs instance, or null if this is a global service.

config - The configured arguments for this service. If YamcsService.getSpec() is implemented then this contains the arguments after being validated (including any defaults).

Throws:

InitException - When something goes wrong during the execution of this method.

getCfdpTransfer

public CfdpTransfer getCfdpTransfer(CfdpTransactionId transferId)

getCfdpTransfer

public CfdpTransfer getCfdpTransfer(long id)

getCfdpTransfers

public Collection<CfdpTransfer> getCfdpTransfers()

processRequest

public CfdpTransfer processRequest(CfdpRequest request)

onTuple

public void onTuple(Stream stream,
                    Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

addTransferListener

public void addTransferListener(TransferMonitor listener)

removeTransferListener

public void removeTransferListener(TransferMonitor listener)

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber

upload

public CfdpOutgoingTransfer upload(String objName,
                                   String target,
                                   boolean overwrite,
                                   boolean acknowledged,
                                   boolean createpath,
                                   Bucket b,
                                   byte[] objData)

stateChanged

public void stateChanged(CfdpTransfer cfdpTransfer)

Specified by:

stateChanged in interface TransferMonitor