eu.javaexperience.electronic.uartbus

Class UartbusEscapedStreamPacketConnector

java.lang.Object

eu.javaexperience.electronic.uartbus.UartbusEscapedStreamPacketConnector

All Implemented Interfaces:

UartbusPacketConnector, Closeable, AutoCloseable

public class UartbusEscapedStreamPacketConnector
extends Object
implements UartbusPacketConnector

Field Summary

Fields

Modifier and Type	Field and Description
protected eu.javaexperience.binary.FramedPacketCutter	cutter
protected eu.javaexperience.io.IOStream	io
protected static eu.javaexperience.log.Logger	LOG
protected eu.javaexperience.interfaces.simple.SimpleCall	onClosed
protected eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]>	onPacketReceived
protected byte	packetEscape
protected Thread	receiver
protected boolean	run

Constructor Summary

Constructors

Constructor and Description
UartbusEscapedStreamPacketConnector(eu.javaexperience.io.IOStream io, byte terminator)

Method Summary

Modifier and Type	Method and Description
void	close()
protected static void	commProcessClosed()
protected void	dispatchPacket(byte[] data)
void	feedBytes(byte[] bs)
protected InputStream	getInputStream()
protected OutputStream	getOutputStream()
static void	main(String[] args)
protected void	manageClosedConnection(Exception caused, String whileOp)
void	sendPacket(byte[] data)
void	sendWithCrc8(byte[] data)
void	setIoStream(eu.javaexperience.io.IOStream io)
void	setPacketHook(eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> onPacketReceived)
void	setSocketCloseListener(eu.javaexperience.interfaces.simple.SimpleCall onClosed)
void	startListen()
void	stop()

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

io

protected eu.javaexperience.io.IOStream io

packetEscape

protected byte packetEscape

onPacketReceived

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

cutter

protected eu.javaexperience.binary.FramedPacketCutter cutter

run

protected volatile boolean run

receiver

protected Thread receiver

onClosed

protected eu.javaexperience.interfaces.simple.SimpleCall onClosed

Constructor Detail

UartbusEscapedStreamPacketConnector

public UartbusEscapedStreamPacketConnector(eu.javaexperience.io.IOStream io,
                                           byte terminator)

Method Detail

setPacketHook

public void setPacketHook(eu.javaexperience.interfaces.simple.publish.SimplePublish1<byte[]> onPacketReceived)

Specified by:

setPacketHook in interface UartbusPacketConnector

setSocketCloseListener

public void setSocketCloseListener(eu.javaexperience.interfaces.simple.SimpleCall onClosed)

commProcessClosed

protected static void commProcessClosed()

getInputStream

protected InputStream getInputStream()

getOutputStream

protected OutputStream getOutputStream()

setIoStream

public void setIoStream(eu.javaexperience.io.IOStream io)

dispatchPacket

protected void dispatchPacket(byte[] data)

startListen

public void startListen()

Specified by:

startListen in interface UartbusPacketConnector

manageClosedConnection

protected void manageClosedConnection(Exception caused,
                                      String whileOp)

sendPacket

public void sendPacket(byte[] data)

Specified by:

sendPacket in interface UartbusPacketConnector

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

sendWithCrc8

public void sendWithCrc8(byte[] data)
                  throws IOException

Throws:

IOException

stop

public void stop()

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

feedBytes

public void feedBytes(byte[] bs)