eu.javaexperience.electronic.uartbus.rpc.client

Class UartBus

java.lang.Object

eu.javaexperience.electronic.uartbus.rpc.client.UartBus

All Implemented Interfaces:

Closeable, AutoCloseable

public class UartBus
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected Closeable	connResource
protected int	fromAddress
protected eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]>	invalidPackets
protected static eu.javaexperience.log.Logger	LOG
protected eu.javaexperience.patterns.behavioral.mediator.EventMediator<ParsedUartBusPacket>	onNewValidPackageReceived
protected LinkedList<UartbusTransaction>	pendingRequests
protected eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]>	sendPacket
protected eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]>	unrelatedPackets

Constructor Summary

Constructors

Constructor and Description
UartBus(Closeable resource, eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> sendPacket, int fromAddress)

Method Summary

Modifier and Type	Method and Description
void	addPendingRequest(UartbusTransaction req)
void	close()
UartBusDevice	device(int addr)
static UartBus	fromConnection(eu.javaexperience.interfaces.simple.SimpleGet<UartbusConnection> gSrv, Closeable onClose, int busFromAddress)
static UartBus	fromConnection(UartbusConnection srv, boolean closeConnOnClose, int busFromAddress)
static UartBus	fromTcp(String ip, int port, int fromAddress)
int	getFromAddress()
eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]>	getInvalidPacketListener()
eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]>	getUnrelatedPacketListener()
UartbusTransaction	newTransaction(int to, byte[] path, byte[] payloadData, boolean zeroNamespaceAnswer)
void	processPacket(byte[] packet)
boolean	revokePendingRequest(UartbusTransaction req)
void	sendRawPacket(byte[] data)
UartbusTransaction	subscribeResponse(int from, int to, byte[] path, boolean zeroNamespace)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final eu.javaexperience.log.Logger LOG

connResource

protected Closeable connResource

fromAddress

protected int fromAddress

sendPacket

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

onNewValidPackageReceived

protected final eu.javaexperience.patterns.behavioral.mediator.EventMediator<ParsedUartBusPacket> onNewValidPackageReceived

pendingRequests

protected final LinkedList<UartbusTransaction> pendingRequests

invalidPackets

protected final eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]> invalidPackets

unrelatedPackets

protected final eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]> unrelatedPackets

Constructor Detail

UartBus

public UartBus(Closeable resource,
               eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> sendPacket,
               int fromAddress)

Method Detail

getInvalidPacketListener

public eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]> getInvalidPacketListener()

getUnrelatedPacketListener

public eu.javaexperience.patterns.behavioral.mediator.EventMediator<byte[]> getUnrelatedPacketListener()

processPacket

public void processPacket(byte[] packet)

addPendingRequest

public void addPendingRequest(UartbusTransaction req)

revokePendingRequest

public boolean revokePendingRequest(UartbusTransaction req)

newTransaction

public UartbusTransaction newTransaction(int to,
                                         byte[] path,
                                         byte[] payloadData,
                                         boolean zeroNamespaceAnswer)
                                  throws IOException

Throws:

IOException

subscribeResponse

public UartbusTransaction subscribeResponse(int from,
                                            int to,
                                            byte[] path,
                                            boolean zeroNamespace)

fromTcp

public static UartBus fromTcp(String ip,
                              int port,
                              int fromAddress)
                       throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getFromAddress

public int getFromAddress()

device

public UartBusDevice device(int addr)

sendRawPacket

public void sendRawPacket(byte[] data)

fromConnection

public static UartBus fromConnection(UartbusConnection srv,
                                     boolean closeConnOnClose,
                                     int busFromAddress)

fromConnection

public static UartBus fromConnection(eu.javaexperience.interfaces.simple.SimpleGet<UartbusConnection> gSrv,
                                     Closeable onClose,
                                     int busFromAddress)