Class ConnectionHeadersFilterLayer
- java.lang.Object
-
- org.jenkinsci.remoting.protocol.FilterLayer
-
- org.jenkinsci.remoting.protocol.impl.ConnectionHeadersFilterLayer
-
- All Implemented Interfaces:
ProtocolLayer
,ProtocolLayer.Recv
,ProtocolLayer.Send
public class ConnectionHeadersFilterLayer extends FilterLayer
Performs the connection header negotiation.- Since:
- 3.0
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
ConnectionHeadersFilterLayer.Listener
A listener for the connection headers.-
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 ConnectionHeadersFilterLayer(Map<String,String> headers, ConnectionHeadersFilterLayer.Listener listener)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
complete()
void
doSend(ByteBuffer data)
SPI: Sends data to the lower layer.boolean
isRecvOpen()
Tracks if this layer is accepting received data viaProtocolLayer.Recv.onRecv(ByteBuffer)
.boolean
isSendOpen()
Tracks if this layer is submitting data to be sent viaProtocolLayer.Send.doSend(ByteBuffer)
.void
onRecv(ByteBuffer data)
SPI: Callback on data being received from the lower layer.void
onRecvClosed(IOException cause)
Callback on the lower layer's source of data being closed.void
start()
Starts this layer.-
Methods inherited from class org.jenkinsci.remoting.protocol.FilterLayer
abort, completed, doCloseSend, flushRecv, flushSend, init, next, stack
-
-
-
-
Constructor Detail
-
ConnectionHeadersFilterLayer
public ConnectionHeadersFilterLayer(Map<String,String> headers, ConnectionHeadersFilterLayer.Listener listener)
Constructor.- Parameters:
headers
- Our headers to send.listener
- Our listener to decide the response to the remote headers.
-
-
Method Detail
-
start
public void start()
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
-
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.
-
complete
protected void complete()
-
onRecvClosed
public void onRecvClosed(IOException cause) throws IOException
Callback on the lower layer's source of data being closed.- Specified by:
onRecvClosed
in interfaceProtocolLayer.Recv
- Overrides:
onRecvClosed
in classFilterLayer
- Parameters:
cause
- the cause of the lower layer being closed ornull
.- Throws:
IOException
- if there was an error during the processing of the close notification.
-
isRecvOpen
public boolean isRecvOpen()
Tracks if this layer is accepting received data viaProtocolLayer.Recv.onRecv(ByteBuffer)
. Once this method returnsfalse
it must always returnfalse
and can be assumed to behave in this way.- Specified by:
isRecvOpen
in interfaceProtocolLayer.Recv
- Overrides:
isRecvOpen
in classFilterLayer
- Returns:
true
if accepting received data viaProtocolLayer.Recv.onRecv(ByteBuffer)
.
-
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.
-
isSendOpen
public boolean isSendOpen()
Tracks if this layer is submitting data to be sent viaProtocolLayer.Send.doSend(ByteBuffer)
. Once this method returnsfalse
it must always returnfalse
and can be assumed to behave in this way.- Specified by:
isSendOpen
in interfaceProtocolLayer.Send
- Overrides:
isSendOpen
in classFilterLayer
- Returns:
true
if submitting data to be sent viaProtocolLayer.Send.doSend(ByteBuffer)
.
-
-