org.yamcs.sle

Class AbstractServiceUserHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.yamcs.sle.AbstractServiceUserHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

CltuServiceUserHandler, RafServiceUserHandler

public abstract class AbstractServiceUserHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Common class for all SLE services

Author:

nm

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractServiceUserHandler.AuthLevel
static class	AbstractServiceUserHandler.State

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected SleAttributes	attr
protected AbstractServiceUserHandler.AuthLevel	authLevel
protected io.netty.channel.ChannelHandlerContext	channelHandlerContext
protected List<SleMonitor>	monitors
protected CompletableFuture<Void>	startingCf
protected AbstractServiceUserHandler.State	state

Constructor Summary

Constructors

Constructor and Description
AbstractServiceUserHandler(Isp1Authentication auth, SleAttributes attr)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	bind() Establish an association with the provider
protected void	changeState(AbstractServiceUserHandler.State newState)
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void	channelRegistered(io.netty.channel.ChannelHandlerContext ctx)
protected void	checkUnbound()
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected abstract Constants.ApplicationIdentifier	getApplicationIdentifier()
AbstractServiceUserHandler.AuthLevel	getAuthLevel()
protected static ConditionalTime	getConditionalTime(CcsdsTime time)
protected <T> CompletableFuture<T>	getFuture(InvokeId invokeId)
protected InvokeId	getInvokeId()
protected InvokeId	getInvokeId(CompletableFuture<?> cf)
protected Credentials	getNonBindCredentials()
protected static Time	getTime(CcsdsTime time)
int	getVersionNumber()
boolean	isConnected()
protected void	notifyDisconnected()
protected void	peerAbort()
protected void	processBindInvocation(SleBindInvocation bindInvocation)
protected abstract void	processData(com.beanit.jasn1.ber.BerTag berTag, InputStream is)
protected void	processStopReturn(SleAcknowledgement stopReturn)
protected void	processUnbindInvocation(SleUnbindInvocation unbindInvocation)
CompletableFuture<Void>	schedulePeriodicStatusReport(int intervalSec) Send a request to the server to ask for a periodic status report.
void	setAuthLevel(AbstractServiceUserHandler.AuthLevel authLevel)
void	setVersionNumber(int versionNumber)
void	shutdown()
CompletableFuture<Void>	start() Request that the SLE service provider starts sending data
CompletableFuture<Void>	stop() request that the SLE service provider stop service provision and production.
CompletableFuture<Void>	stopPeriodicStatusReport() Send a request to stop the periodic status report.
CompletableFuture<Void>	unbind()
protected void	verifyBindCredentials(Credentials credentials)
protected void	verifyNonBindCredentials(Credentials credentials)

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

Field Detail

startingCf

protected CompletableFuture<Void> startingCf

state

protected volatile AbstractServiceUserHandler.State state

channelHandlerContext

protected io.netty.channel.ChannelHandlerContext channelHandlerContext

authLevel

protected AbstractServiceUserHandler.AuthLevel authLevel

attr

protected final SleAttributes attr

monitors

protected List<SleMonitor> monitors

Constructor Detail

AbstractServiceUserHandler

public AbstractServiceUserHandler(Isp1Authentication auth,
                                  SleAttributes attr)

Method Detail

getVersionNumber

public int getVersionNumber()

setVersionNumber

public void setVersionNumber(int versionNumber)

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

getAuthLevel

public AbstractServiceUserHandler.AuthLevel getAuthLevel()

setAuthLevel

public void setAuthLevel(AbstractServiceUserHandler.AuthLevel authLevel)

channelRegistered

public void channelRegistered(io.netty.channel.ChannelHandlerContext ctx)
                       throws Exception

Specified by:

channelRegistered in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRegistered in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
                   throws Exception

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

isConnected

public boolean isConnected()

bind

public CompletableFuture<Void> bind()

Establish an association with the provider

Returns:

start

public CompletableFuture<Void> start()

Request that the SLE service provider starts sending data

Returns:

stop

public CompletableFuture<Void> stop()

request that the SLE service provider stop service provision and production.

Returns:

unbind

public CompletableFuture<Void> unbind()

schedulePeriodicStatusReport

public CompletableFuture<Void> schedulePeriodicStatusReport(int intervalSec)

Send a request to the server to ask for a periodic status report.

Parameters:

intervalSec - - the cycle on which the periodic report shall be sent

Returns:

stopPeriodicStatusReport

public CompletableFuture<Void> stopPeriodicStatusReport()

Send a request to stop the periodic status report.

Returns:

shutdown

public void shutdown()

checkUnbound

protected void checkUnbound()

processBindInvocation

protected void processBindInvocation(SleBindInvocation bindInvocation)

processUnbindInvocation

protected void processUnbindInvocation(SleUnbindInvocation unbindInvocation)

processStopReturn

protected void processStopReturn(SleAcknowledgement stopReturn)

peerAbort

protected void peerAbort()

getNonBindCredentials

protected Credentials getNonBindCredentials()

verifyNonBindCredentials

protected void verifyNonBindCredentials(Credentials credentials)

verifyBindCredentials

protected void verifyBindCredentials(Credentials credentials)

getInvokeId

protected InvokeId getInvokeId()

getFuture

protected <T> CompletableFuture<T> getFuture(InvokeId invokeId)

changeState

protected void changeState(AbstractServiceUserHandler.State newState)

getInvokeId

protected InvokeId getInvokeId(CompletableFuture<?> cf)

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

notifyDisconnected

protected void notifyDisconnected()

getConditionalTime

protected static ConditionalTime getConditionalTime(CcsdsTime time)

getTime

protected static Time getTime(CcsdsTime time)

getApplicationIdentifier

protected abstract Constants.ApplicationIdentifier getApplicationIdentifier()

processData

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

Throws:

IOException