Package com.diozero.internal.provider.remote.websocket

Class ProtobufWebSocketProtocolHandler

java.lang.Object

com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

com.diozero.internal.provider.remote.ProtobufBaseAsyncProtocolHandler

com.diozero.internal.provider.remote.websocket.ProtobufWebSocketProtocolHandler

All Implemented Interfaces:

RemoteProtocolInterface, AutoCloseable, org.eclipse.jetty.websocket.api.WebSocketConnectionListener, org.eclipse.jetty.websocket.api.WebSocketListener

public class ProtobufWebSocketProtocolHandler
extends ProtobufBaseAsyncProtocolHandler
implements org.eclipse.jetty.websocket.api.WebSocketListener

Field Summary

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

conditions, lock, responses

Constructor Summary

Constructors

Constructor	Description
ProtobufWebSocketProtocolHandler(NativeDeviceFactoryInterface deviceFactory)

Method Summary

Modifier and Type	Method	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)
GetBoardInfoResponse	request(GetBoardInfoRequest request)
GpioAnalogReadResponse	request(GpioAnalogRead request)
Response	request(GpioAnalogWrite request)
Response	request(GpioClose request)
GpioDigitalReadResponse	request(GpioDigitalRead request)
Response	request(GpioDigitalWrite request)
Response	request(GpioEvents request)
GpioGetPwmFrequencyResponse	request(GpioGetPwmFrequency request)
GpioPwmReadResponse	request(GpioPwmRead request)
Response	request(GpioPwmWrite request)
Response	request(GpioSetPwmFrequency request)
I2CBytesResponse	request(I2CBlockProcessCall request)
Response	request(I2CClose request)
Response	request(I2COpen request)
I2CBooleanResponse	request(I2CProbe request)
I2CWordResponse	request(I2CProcessCall request)
I2CReadBlockDataResponse	request(I2CReadBlockData request)
I2CByteResponse	request(I2CReadByte request)
I2CByteResponse	request(I2CReadByteData request)
I2CBytesResponse	request(I2CReadBytes request)
I2CBytesResponse	request(I2CReadI2CBlockData request)
I2CWordResponse	request(I2CReadWordData request)
Response	request(I2CWriteBlockData request)
Response	request(I2CWriteByte request)
Response	request(I2CWriteByteData request)
Response	request(I2CWriteBytes request)
Response	request(I2CWriteI2CBlockData request)
Response	request(I2CWriteQuick request)
Response	request(I2CWriteWordData request)
Response	request(ProvisionAnalogInputDevice request)
Response	request(ProvisionAnalogOutputDevice request)
Response	request(ProvisionDigitalInputDevice request)
Response	request(ProvisionDigitalInputOutputDevice request)
Response	request(ProvisionDigitalOutputDevice request)
Response	request(ProvisionPwmOutputDevice request)
SerialBytesAvailableResponse	request(SerialBytesAvailable request)
Response	request(SerialClose request)
Response	request(SerialOpen request)
SerialReadResponse	request(SerialRead request)
SerialReadByteResponse	request(SerialReadByte request)
SerialReadBytesResponse	request(SerialReadBytes request)
Response	request(SerialWriteByte request)
Response	request(SerialWriteBytes request)
Response	request(SpiClose request)
Response	request(SpiOpen request)
Response	request(SpiWrite request)
SpiResponse	request(SpiWriteAndRead request)
protected void	sendMessage(String url, com.google.protobuf.GeneratedMessageV3 message)
void	start()

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

requestResponse

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 Details

ProtobufWebSocketProtocolHandler

public ProtobufWebSocketProtocolHandler(NativeDeviceFactoryInterface deviceFactory)

Method Details

start

public void start()

Specified by:

start in interface RemoteProtocolInterface

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RemoteProtocolInterface

sendMessage

protected void sendMessage(String url,
com.google.protobuf.GeneratedMessageV3 message)
                    throws IOException

Specified by:

sendMessage in class ProtobufBaseAsyncProtocolHandler

Throws:

IOException

request

public GetBoardInfoResponse request(GetBoardInfoRequest request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionDigitalInputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionDigitalOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionDigitalInputOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionPwmOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionAnalogInputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionAnalogOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioDigitalReadResponse request(GpioDigitalRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioDigitalWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioPwmReadResponse request(GpioPwmRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioPwmWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioGetPwmFrequencyResponse request(GpioGetPwmFrequency request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioSetPwmFrequency request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioAnalogReadResponse request(GpioAnalogRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioAnalogWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioEvents request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioClose request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2COpen request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CBooleanResponse request(I2CProbe request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteQuick request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CByteResponse request(I2CReadByte request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteByte request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CBytesResponse request(I2CReadBytes request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteBytes request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CByteResponse request(I2CReadByteData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteByteData request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CWordResponse request(I2CReadWordData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteWordData request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CWordResponse request(I2CProcessCall request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CReadBlockDataResponse request(I2CReadBlockData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteBlockData request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CBytesResponse request(I2CBlockProcessCall request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CBytesResponse request(I2CReadI2CBlockData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteI2CBlockData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CClose request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SpiOpen request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SpiWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public SpiResponse request(SpiWriteAndRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SpiClose request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SerialOpen request)

Specified by:

request in interface RemoteProtocolInterface

request

public SerialReadResponse request(SerialRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public SerialReadByteResponse request(SerialReadByte request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SerialWriteByte request)

Specified by:

request in interface RemoteProtocolInterface

request

public SerialReadBytesResponse request(SerialReadBytes request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SerialWriteBytes request)

Specified by:

request in interface RemoteProtocolInterface

request

public SerialBytesAvailableResponse request(SerialBytesAvailable request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SerialClose request)

Specified by:

request in interface 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