org.yamcs.sle.user

Class RafServiceUserHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.yamcs.sle.user.AbstractServiceUserHandler

org.yamcs.sle.user.RacfServiceUserHandler

org.yamcs.sle.user.RafServiceUserHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class RafServiceUserHandler
extends RacfServiceUserHandler

Implementation for the CCSDS RECOMMENDED STANDARD FOR SLE RCF SERVICE CCSDS 911.2-B-3 August 2016 https://public.ccsds.org/Pubs/911x1b4.pdf

This class contains RAF specific implementation

Author:

nm

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class org.yamcs.sle.user.AbstractServiceUserHandler

attr, authLevel, channelHandlerContext, monitors, startingCf, state

Constructor Summary

Constructors

Constructor and Description
RafServiceUserHandler(Isp1Authentication auth, SleAttributes attr, Constants.DeliveryMode deliveryMode, FrameConsumer consumer)

Method Summary

Modifier and Type	Method and Description
void	addMonitor(RacfSleMonitor monitor) Add a monitor to be notified when events happen.
protected Constants.ApplicationIdentifier	getApplicationIdentifier()
CompletableFuture<SleParameter>	getParameter(int parameterId) Get the value of an RAF parameter from the provider
Constants.RequestedFrameQuality	getRequestedFrameQuality()
protected void	processData(com.beanit.jasn1.ber.BerTag berTag, InputStream is)
void	removeMonitor(RacfSleMonitor monitor)
protected void	sendStart(CompletableFuture<Void> cf, CcsdsTime start, CcsdsTime stop)
void	setRequestedFrameQuality(Constants.RequestedFrameQuality requestedFrameQuality) Set the requested frame quality.
CompletableFuture<Void>	start() Request that the SLE service provider starts sending data
CompletableFuture<Void>	start(CcsdsTime startTime, CcsdsTime stopTime) Request that the SLE service provider starts sending

Methods inherited from class org.yamcs.sle.user.RacfServiceUserHandler

getDeliveryMode, isConnected, setDeliveryMode

Methods inherited from class org.yamcs.sle.user.AbstractServiceUserHandler

bind, changeState, channelActive, channelRead, channelRegistered, checkUnbound, exceptionCaught, getAuthLevel, getFuture, getInvokeId, getInvokeId, getNonBindCredentials, getState, getVersionNumber, notifyDisconnected, peerAbort, processBindInvocation, processStopReturn, processUnbindInvocation, schedulePeriodicStatusReport, setAuthLevel, setVersionNumber, shutdown, stop, stopPeriodicStatusReport, unbind, verifyBindCredentials, verifyNonBindCredentials

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelInactive, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

RafServiceUserHandler

public RafServiceUserHandler(Isp1Authentication auth,
                             SleAttributes attr,
                             Constants.DeliveryMode deliveryMode,
                             FrameConsumer consumer)

Method Detail

getParameter

public CompletableFuture<SleParameter> getParameter(int parameterId)

Get the value of an RAF parameter from the provider

Specified by:

getParameter in class RacfServiceUserHandler

Parameters:

parameterId - one of the parameters defined in Constants.ParameterName. Note that not all of them make sense for the RAF, see the table 3-11 in the standard to see which ones make sense.

Returns:

start

public CompletableFuture<Void> start()

Request that the SLE service provider starts sending data

Returns:

start

public CompletableFuture<Void> start(CcsdsTime startTime,
                                     CcsdsTime stopTime)

Request that the SLE service provider starts sending

Returns:

getRequestedFrameQuality

public Constants.RequestedFrameQuality getRequestedFrameQuality()

setRequestedFrameQuality

public void setRequestedFrameQuality(Constants.RequestedFrameQuality requestedFrameQuality)

Set the requested frame quality. This has to be done before the service start.

Parameters:

requestedFrameQuality -

addMonitor

public void addMonitor(RacfSleMonitor monitor)

Add a monitor to be notified when events happen.

Overrides:

addMonitor in class RacfServiceUserHandler

Parameters:

monitor -

removeMonitor

public void removeMonitor(RacfSleMonitor monitor)

Overrides:

removeMonitor in class RacfServiceUserHandler

processData

protected void processData(com.beanit.jasn1.ber.BerTag berTag,
                           InputStream is)
                    throws IOException

Specified by:

processData in class AbstractServiceUserHandler

Throws:

IOException

sendStart

protected void sendStart(CompletableFuture<Void> cf,
                         CcsdsTime start,
                         CcsdsTime stop)

getApplicationIdentifier

protected Constants.ApplicationIdentifier getApplicationIdentifier()

Specified by:

getApplicationIdentifier in class AbstractServiceUserHandler