eu.javaexperience.electronic.uartbus.rpc.service

Class UartbusServiceBridge

java.lang.Object

eu.javaexperience.electronic.uartbus.rpc.service.UartbusServiceBridge

All Implemented Interfaces:

Closeable, AutoCloseable

public class UartbusServiceBridge
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected UartBus	bus
protected static eu.javaexperience.log.Logger	LOG
protected List<AutoCloseable>	onClose
protected eu.javaexperience.interfaces.simple.getBy.GetBy1<Boolean,UartbusPacketDispatch>	packetAcceptor
protected static ThreadLocal<UartbusServiceRequest>	REQUESTS
protected eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]>	responseHandler
protected Object	serviceObject

Constructor Summary

Constructors

Constructor and Description
UartbusServiceBridge(Object serviceObject, eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> responseHandler, eu.javaexperience.interfaces.simple.getBy.GetBy1<Boolean,UartbusPacketDispatch> packetAcceptor)

Method Summary

Modifier and Type	Method and Description
void	addReleasableResource(AutoCloseable cl)
protected static Object	applyCall(UartbusServiceRequest req, Object subject, Method m)
static UartbusServiceBridge	attachServiceTo(Object service, UartBus bus, Integer serviceAddress, byte... path)
protected static boolean	canThrowPosixErrno(Method m)
void	close()
void	feedPacket(byte[] rawData)
void	feedPacket(ParsedUartBusPacket packet)
UartBus	getAssociatedBus()
protected UartBus	getBus()
static UartbusServiceRequest	getCurrentRequest()
int	getFromAddress(int to)
protected Object	getServiceObject()
protected static void	handleCall(UartbusServiceRequest req, Object subject, Method m)
protected static void	responsePacket(UartbusServiceRequest req, int dix, Object... response)
protected void	service(UartbusPacketDispatch disp)
protected static void	serviceRequest(UartbusServiceRequest req, Object servObj)
void	setAssociatedBus(UartBus bus)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static eu.javaexperience.log.Logger LOG

bus

protected UartBus bus

serviceObject

protected Object serviceObject

responseHandler

protected eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> responseHandler

packetAcceptor

protected eu.javaexperience.interfaces.simple.getBy.GetBy1<Boolean,UartbusPacketDispatch> packetAcceptor

onClose

protected List<AutoCloseable> onClose

REQUESTS

protected static ThreadLocal<UartbusServiceRequest> REQUESTS

Constructor Detail

UartbusServiceBridge

public UartbusServiceBridge(Object serviceObject,
                            eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> responseHandler,
                            eu.javaexperience.interfaces.simple.getBy.GetBy1<Boolean,UartbusPacketDispatch> packetAcceptor)

Method Detail

setAssociatedBus

public void setAssociatedBus(UartBus bus)

getAssociatedBus

public UartBus getAssociatedBus()

feedPacket

public void feedPacket(byte[] rawData)

addReleasableResource

public void addReleasableResource(AutoCloseable cl)

feedPacket

public void feedPacket(ParsedUartBusPacket packet)

getCurrentRequest

public static UartbusServiceRequest getCurrentRequest()

service

protected void service(UartbusPacketDispatch disp)

serviceRequest

protected static void serviceRequest(UartbusServiceRequest req,
                                     Object servObj)
                              throws Throwable

Throws:

Throwable

handleCall

protected static void handleCall(UartbusServiceRequest req,
                                 Object subject,
                                 Method m)
                          throws Throwable

Throws:

Throwable

applyCall

protected static Object applyCall(UartbusServiceRequest req,
                                  Object subject,
                                  Method m)
                           throws Throwable

Throws:

Throwable

responsePacket

protected static void responsePacket(UartbusServiceRequest req,
                                     int dix,
                                     Object... response)

canThrowPosixErrno

protected static boolean canThrowPosixErrno(Method m)

getFromAddress

public int getFromAddress(int to)

getBus

protected UartBus getBus()

getServiceObject

protected Object getServiceObject()

attachServiceTo

public static UartbusServiceBridge attachServiceTo(Object service,
                                                   UartBus bus,
                                                   Integer serviceAddress,
                                                   byte... path)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException