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:

com.diozero.remote.message.RemoteProtocolInterface, Closeable, 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 and Description
ProtobufWebSocketProtocolHandler(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)
protected void	sendMessage(String url, com.google.protobuf.GeneratedMessageV3 message)

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 Detail

ProtobufWebSocketProtocolHandler

public ProtobufWebSocketProtocolHandler(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

sendMessage

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

Specified by:

sendMessage in class ProtobufBaseAsyncProtocolHandler

Throws:

IOException

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