eu.javaexperience.electronic.uartbus.rpc.client

Class UartbusTransaction

java.lang.Object

eu.javaexperience.electronic.uartbus.rpc.client.UartbusTransaction

All Implemented Interfaces:

Closeable, AutoCloseable

public class UartbusTransaction
extends Object
implements Closeable

I know, this is a blob but maybe it's easier to manager request-response as one unit.

Field Summary

Fields

Modifier and Type	Field and Description
UartBus	bus
int	from
protected static eu.javaexperience.log.Logger	LOG
byte[]	path
byte[]	payload
byte[]	responsePayload
boolean	revoked
int	to
protected eu.javaexperience.multithread.notify.WaitForSingleEvent	wait response section
boolean	zeroNamespaceAnswer

Constructor Summary

Constructors

Constructor and Description
UartbusTransaction(UartBus bus)

Method Summary

Modifier and Type	Method and Description
void	close()
byte[]	ensureResponse(long timeout, TimeUnit unit)
byte[]	ensureResponse(long timeout, TimeUnit unit, String errAppendMsg)
protected void	finalize()
boolean	isResponsed()
boolean	isRevoked()
protected void	receiveResponse(byte[] data)
void	send()
byte[]	toPacket()
boolean	tryAcceptResponse(ParsedUartBusPacket a)
boolean	waitResponse(long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final eu.javaexperience.log.Logger LOG

bus

public final UartBus bus

zeroNamespaceAnswer

public boolean zeroNamespaceAnswer

to

public int to

from

public int from

path

public byte[] path

payload

public byte[] payload

revoked

public volatile boolean revoked

responsePayload

public volatile byte[] responsePayload

wait

protected final eu.javaexperience.multithread.notify.WaitForSingleEvent wait

response section

Constructor Detail

UartbusTransaction

public UartbusTransaction(UartBus bus)

Method Detail

toPacket

public byte[] toPacket()

send

public void send()
          throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

isResponsed

public boolean isResponsed()

isRevoked

public boolean isRevoked()

waitResponse

public boolean waitResponse(long timeout,
                            TimeUnit unit)
                     throws InterruptedException

Throws:

InterruptedException

ensureResponse

public byte[] ensureResponse(long timeout,
                             TimeUnit unit)
                      throws InterruptedException

Throws:

InterruptedException

ensureResponse

public byte[] ensureResponse(long timeout,
                             TimeUnit unit,
                             String errAppendMsg)
                      throws InterruptedException

Throws:

InterruptedException

receiveResponse

protected void receiveResponse(byte[] data)

tryAcceptResponse

public boolean tryAcceptResponse(ParsedUartBusPacket a)