eu.javaexperience.electronic.uartbus.rpc

Class UartbusRpcEndpoint

java.lang.Object

eu.javaexperience.electronic.uartbus.rpc.UartbusRpcEndpoint

All Implemented Interfaces:

UartbusConnection, Closeable, AutoCloseable

public class UartbusRpcEndpoint
extends Object
implements UartbusConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	UartbusRpcEndpoint.PacketEndpointQueue

Field Summary

Fields

Modifier and Type	Field and Description
protected UartbusPacketConnector	conn
protected boolean	default_echo_loopback
protected boolean	default_loopback_send_packets
protected static byte[]	END_OF_RECEIVE
protected static eu.javaexperience.log.Logger	LOG
protected static String	SESSION_KEY
protected Set<UartbusRpcEndpoint.PacketEndpointQueue>	sessions

Constructor Summary

Constructors

Constructor and Description
UartbusRpcEndpoint(UartbusPacketConnector connector)

Method Summary

Modifier and Type	Method and Description
void	close()
String	getAttribute(String key)
byte[]	getNextPacket()
protected UartbusRpcEndpoint.PacketEndpointQueue	getSessionQueue()
void	init()
Map<String,String>	listAttributes()
void	sendPacket(byte[] data)
void	setAttribute(String key, String value)

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

conn

protected UartbusPacketConnector conn

END_OF_RECEIVE

protected static final byte[] END_OF_RECEIVE

sessions

protected volatile Set<UartbusRpcEndpoint.PacketEndpointQueue> sessions

default_echo_loopback

protected boolean default_echo_loopback

default_loopback_send_packets

protected boolean default_loopback_send_packets

SESSION_KEY

protected static final String SESSION_KEY

See Also:

Constant Field Values

Constructor Detail

UartbusRpcEndpoint

public UartbusRpcEndpoint(UartbusPacketConnector connector)

Method Detail

getSessionQueue

protected UartbusRpcEndpoint.PacketEndpointQueue getSessionQueue()

sendPacket

public void sendPacket(byte[] data)
                throws IOException

Specified by:

sendPacket in interface UartbusConnection

Throws:

IOException

listAttributes

public Map<String,String> listAttributes()

Specified by:

listAttributes in interface UartbusConnection

getAttribute

public String getAttribute(String key)

Specified by:

getAttribute in interface UartbusConnection

setAttribute

public void setAttribute(String key,
                         String value)

Specified by:

setAttribute in interface UartbusConnection

getNextPacket

public byte[] getNextPacket()
                     throws IOException

Specified by:

getNextPacket in interface UartbusConnection

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

init

public void init()

Specified by:

init in interface UartbusConnection