Class AgentProtocolClientFilterLayer
- java.lang.Object
-
- org.jenkinsci.remoting.protocol.FilterLayer
-
- org.jenkinsci.remoting.protocol.impl.AgentProtocolClientFilterLayer
-
- All Implemented Interfaces:
ProtocolLayer
,ProtocolLayer.Recv
,ProtocolLayer.Send
public class AgentProtocolClientFilterLayer extends FilterLayer
AFilterLayer
that sends the AgentProtocol client handshake.- Since:
- 3.0
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.jenkinsci.remoting.protocol.ProtocolLayer
ProtocolLayer.Recv, ProtocolLayer.Send
-
-
Field Summary
-
Fields inherited from interface org.jenkinsci.remoting.protocol.ProtocolLayer
EMPTY_BUFFER
-
-
Constructor Summary
Constructors Constructor Description AgentProtocolClientFilterLayer(String name)
Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
doSend(ByteBuffer data)
SPI: Sends data to the lower layer.void
onRecv(ByteBuffer data)
SPI: Callback on data being received from the lower layer.void
start()
Starts this layer.-
Methods inherited from class org.jenkinsci.remoting.protocol.FilterLayer
abort, completed, doCloseSend, flushRecv, flushSend, init, isRecvOpen, isSendOpen, next, onRecvClosed, stack
-
-
-
-
Constructor Detail
-
AgentProtocolClientFilterLayer
public AgentProtocolClientFilterLayer(String name)
Constructor- Parameters:
name
- theAgentProtocol.getName()
.
-
-
Method Detail
-
start
public void start() throws IOException
Starts this layer. All layers in the stack will be initialized before a call to this method. All lower layers in the stack will have been started before this layer is started.- Specified by:
start
in interfaceProtocolLayer
- Overrides:
start
in classFilterLayer
- Throws:
IOException
- if something goes wrong.
-
onRecv
public void onRecv(@NonNull ByteBuffer data) throws IOException
SPI: Callback on data being received from the lower layer.- Specified by:
onRecv
in interfaceProtocolLayer.Recv
- Specified by:
onRecv
in classFilterLayer
- Parameters:
data
- the data received. Any data consumed from theByteBuffer
can be assumed as processed. Any data not consumed from theByteBuffer
will be the responsibility of the caller to resubmit in subsequent calls.- Throws:
IOException
- if there was an error during processing of the received data.
-
doSend
public void doSend(@NonNull ByteBuffer data) throws IOException
SPI: Sends data to the lower layer.- Specified by:
doSend
in interfaceProtocolLayer.Send
- Specified by:
doSend
in classFilterLayer
- Parameters:
data
- the data to send. Any data consumed from theByteBuffer
can be assumed as processed. Any data not consumed from theByteBuffer
will be the responsibility of the caller to resubmit in subsequent calls.- Throws:
IOException
- if there was an error during processing of the data.
-
-