Class BlockingSslHandler
- java.lang.Object
-
- org.apache.ignite.internal.util.nio.ssl.BlockingSslHandler
-
public class BlockingSslHandler extends Object
-
-
Constructor Summary
Constructors Constructor Description BlockingSslHandler(SSLEngine sslEngine, SocketChannel ch, boolean directBuf, ByteOrder order, IgniteLogger log)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ByteBufferapplicationBuffer()ByteBufferdecode(ByteBuffer buf)Called by SSL filter when new message was received.ByteBufferencrypt(ByteBuffer src)Encrypts data to be written to the network.booleanhandshake()Performs handshake procedure with remote peer.ByteBufferinputBuffer()
-
-
-
Constructor Detail
-
BlockingSslHandler
public BlockingSslHandler(SSLEngine sslEngine, SocketChannel ch, boolean directBuf, ByteOrder order, IgniteLogger log)
- Parameters:
sslEngine- SSLEngine.ch- Socket channel.directBuf- Direct buffer flag.order- Byte order.log- Logger.
-
-
Method Detail
-
inputBuffer
public ByteBuffer inputBuffer()
-
handshake
public boolean handshake() throws IgniteCheckedException, SSLExceptionPerforms handshake procedure with remote peer.- Throws:
GridNioException- If filter processing has thrown an exception.SSLException- If failed to process SSL data.IgniteCheckedException
-
applicationBuffer
public ByteBuffer applicationBuffer()
- Returns:
- Application buffer with decoded data.
-
encrypt
public ByteBuffer encrypt(ByteBuffer src) throws SSLException
Encrypts data to be written to the network.- Parameters:
src- data to encrypt.- Returns:
- Output buffer with encrypted data.
- Throws:
SSLException- on errors.
-
decode
public ByteBuffer decode(ByteBuffer buf) throws IgniteCheckedException, SSLException
Called by SSL filter when new message was received.- Parameters:
buf- Received message.- Throws:
GridNioException- If exception occurred while forwarding events to underlying filter.SSLException- If failed to process SSL data.IgniteCheckedException
-
-