akka.stream.impl.io

Class TLSActor.ChoppingBlock

java.lang.Object

akka.stream.impl.io.TLSActor.ChoppingBlock

All Implemented Interfaces:

TransferState

Enclosing class:

TLSActor

public class TLSActor.ChoppingBlock
extends java.lang.Object
implements TransferState

The SSLEngine needs bite-sized chunks of data but we get arbitrary ByteString from both the UserIn and the TransportIn ports. This is used to chop up such a ByteString by filling the respective ByteBuffer and taking care to dequeue a new element when data are demanded and none are left lying on the chopping block.

Constructor Summary

Constructors

Constructor and Description
ChoppingBlock(int idx, java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	chopInto(java.nio.ByteBuffer b) Pour as many bytes as are available either on the chopping block or in the inputBunch’s next ByteString into the supplied ByteBuffer, which is expected to be in “read left-overs” mode, i.e.
boolean	isCompleted()
boolean	isEmpty() Whether there are no bytes lying on this chopping block.
boolean	isReady()
void	prepare(java.nio.ByteBuffer b) Prepare a fresh ByteBuffer for receiving a chop of data.
void	putBack(java.nio.ByteBuffer b) When potentially complete packet data are left after unwrap() we must put them back onto the chopping block because otherwise the pump will not know that we are runnable.

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.impl.TransferState

isExecutable

Constructor Detail

ChoppingBlock

public ChoppingBlock(int idx,
                     java.lang.String name)

Method Detail

isReady

public boolean isReady()

Specified by:

isReady in interface TransferState

isCompleted

public boolean isCompleted()

Specified by:

isCompleted in interface TransferState

isEmpty

public boolean isEmpty()

Whether there are no bytes lying on this chopping block.

Returns:

(undocumented)

chopInto

public void chopInto(java.nio.ByteBuffer b)

Pour as many bytes as are available either on the chopping block or in the inputBunch’s next ByteString into the supplied ByteBuffer, which is expected to be in “read left-overs” mode, i.e. everything between its position and limit is retained. In order to allocate a fresh ByteBuffer with these characteristics, use prepare().

Parameters:

b - (undocumented)

putBack

public void putBack(java.nio.ByteBuffer b)

When potentially complete packet data are left after unwrap() we must put them back onto the chopping block because otherwise the pump will not know that we are runnable.

Parameters:

b - (undocumented)

prepare

public void prepare(java.nio.ByteBuffer b)

Prepare a fresh ByteBuffer for receiving a chop of data.

Parameters:

b - (undocumented)