com.diozero.internal.provider.remote.websocket

Class JsonWebSocketProtocolHandler

java.lang.Object

com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

com.diozero.internal.provider.remote.websocket.JsonWebSocketProtocolHandler

All Implemented Interfaces:

com.diozero.remote.message.RemoteProtocolInterface, Closeable, AutoCloseable, org.eclipse.jetty.websocket.api.WebSocketConnectionListener, org.eclipse.jetty.websocket.api.WebSocketListener

public class JsonWebSocketProtocolHandler
extends BaseAsyncProtocolHandler
implements org.eclipse.jetty.websocket.api.WebSocketListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	JsonWebSocketProtocolHandler.Deserialiser
static interface	JsonWebSocketProtocolHandler.Serialiser

Field Summary

Fields inherited from class com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

conditions, lock, responses

Constructor Summary

Constructors

Constructor and Description
JsonWebSocketProtocolHandler(com.diozero.internal.provider.NativeDeviceFactoryInterface deviceFactory)

Method Summary

Modifier and Type	Method and Description
void	close()
void	onWebSocketBinary(byte[] payload, int offset, int len)
void	onWebSocketClose(int statusCode, String reason)
void	onWebSocketConnect(org.eclipse.jetty.websocket.api.Session newSession)
void	onWebSocketError(Throwable cause)
void	onWebSocketText(String message)
com.diozero.remote.message.GetBoardInfoResponse	request(com.diozero.remote.message.GetBoardInfo request)
com.diozero.remote.message.GpioAnalogReadResponse	request(com.diozero.remote.message.GpioAnalogRead request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioAnalogWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioClose request)
com.diozero.remote.message.GpioDigitalReadResponse	request(com.diozero.remote.message.GpioDigitalRead request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioDigitalWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioEvents request)
com.diozero.remote.message.GpioPwmReadResponse	request(com.diozero.remote.message.GpioPwmRead request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioPwmWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CClose request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2COpen request)
com.diozero.remote.message.I2CReadResponse	request(com.diozero.remote.message.I2CRead request)
com.diozero.remote.message.I2CReadByteResponse	request(com.diozero.remote.message.I2CReadByte request)
com.diozero.remote.message.I2CReadByteResponse	request(com.diozero.remote.message.I2CReadByteData request)
com.diozero.remote.message.I2CReadResponse	request(com.diozero.remote.message.I2CReadI2CBlockData request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWriteByte request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWriteByteData request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWriteI2CBlockData request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionAnalogInputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionAnalogOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionDigitalInputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionDigitalInputOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionDigitalOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionPwmOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.SpiClose request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.SpiOpen request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.SpiWrite request)
com.diozero.remote.message.SpiResponse	request(com.diozero.remote.message.SpiWriteAndRead request)

Methods inherited from class com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

processEvent, processResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonWebSocketProtocolHandler

public JsonWebSocketProtocolHandler(com.diozero.internal.provider.NativeDeviceFactoryInterface deviceFactory)

Method Detail

close

public void close()

Specified by:

close in interface com.diozero.remote.message.RemoteProtocolInterface

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

request

public com.diozero.remote.message.GetBoardInfoResponse request(com.diozero.remote.message.GetBoardInfo request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionDigitalInputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionDigitalOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionDigitalInputOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionPwmOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionAnalogInputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionAnalogOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.GpioDigitalReadResponse request(com.diozero.remote.message.GpioDigitalRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioDigitalWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.GpioPwmReadResponse request(com.diozero.remote.message.GpioPwmRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioPwmWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.GpioAnalogReadResponse request(com.diozero.remote.message.GpioAnalogRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioAnalogWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioEvents request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioClose request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2COpen request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadByteResponse request(com.diozero.remote.message.I2CReadByte request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWriteByte request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadResponse request(com.diozero.remote.message.I2CRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadByteResponse request(com.diozero.remote.message.I2CReadByteData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWriteByteData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadResponse request(com.diozero.remote.message.I2CReadI2CBlockData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWriteI2CBlockData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CClose request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.SpiOpen request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.SpiWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.SpiResponse request(com.diozero.remote.message.SpiWriteAndRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.SpiClose request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

onWebSocketClose

public void onWebSocketClose(int statusCode,
                             String reason)

Specified by:

onWebSocketClose in interface org.eclipse.jetty.websocket.api.WebSocketConnectionListener

onWebSocketConnect

public void onWebSocketConnect(org.eclipse.jetty.websocket.api.Session newSession)

Specified by:

onWebSocketConnect in interface org.eclipse.jetty.websocket.api.WebSocketConnectionListener

onWebSocketError

public void onWebSocketError(Throwable cause)

Specified by:

onWebSocketError in interface org.eclipse.jetty.websocket.api.WebSocketConnectionListener

onWebSocketBinary

public void onWebSocketBinary(byte[] payload,
                              int offset,
                              int len)

Specified by:

onWebSocketBinary in interface org.eclipse.jetty.websocket.api.WebSocketListener

onWebSocketText

public void onWebSocketText(String message)

Specified by:

onWebSocketText in interface org.eclipse.jetty.websocket.api.WebSocketListener