This is an automated email from the ASF dual-hosted git repository.
dpavlov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 74e5602 Code style & imports fix for NIO package
74e5602 is described below
commit 74e5602671c80fb1b6c37aa5917a7bf0150ead7a
Author: Dmitriy Pavlov <[email protected]>
AuthorDate: Thu Feb 14 17:04:21 2019 +0300
Code style & imports fix for NIO package
---
.../internal/util/nio/GridCommunicationClient.java | 2 +-
.../ignite/internal/util/nio/GridDirectParser.java | 6 ++--
.../util/nio/GridNioAsyncNotifyFilter.java | 3 +-
.../internal/util/nio/GridNioCodecFilter.java | 3 +-
.../internal/util/nio/GridNioDelimitedBuffer.java | 2 +-
.../internal/util/nio/GridNioEmbeddedFuture.java | 20 ++++++------
.../internal/util/nio/GridNioMessageTracker.java | 2 +-
.../util/nio/GridNioRecoveryDescriptor.java | 2 +-
.../ignite/internal/util/nio/GridNioServer.java | 36 ++++++++++++----------
.../internal/util/nio/GridNioSessionImpl.java | 2 +-
.../util/nio/GridSelectorNioSessionImpl.java | 2 +-
.../util/nio/GridShmemCommunicationClient.java | 3 +-
.../util/nio/GridTcpNioCommunicationClient.java | 2 +-
.../internal/util/nio/SelectedSelectionKeySet.java | 5 ++-
.../ignite/internal/util/nio/package-info.java | 3 +-
.../internal/util/nio/ssl/BlockingSslHandler.java | 11 +++----
.../internal/util/nio/ssl/GridNioSslFilter.java | 5 ++-
.../internal/util/nio/ssl/GridNioSslHandler.java | 14 ++++-----
.../ignite/internal/util/nio/ssl/package-info.java | 3 +-
19 files changed, 62 insertions(+), 64 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java
index f872ff6..b4a9a95 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java
@@ -92,8 +92,8 @@ public interface GridCommunicationClient {
* @param nodeId Remote node ID. Provided only for sync clients.
* @param msg Message to send.
* @param c Ack closure.
- * @throws IgniteCheckedException If failed.
* @return {@code True} if should try to resend message.
+ * @throws IgniteCheckedException If failed.
*/
public boolean sendMessage(@Nullable UUID nodeId, Message msg, @Nullable
IgniteInClosure<IgniteException> c)
throws IgniteCheckedException;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java
index 152ffe6..2e178e2 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java
@@ -104,9 +104,9 @@ public class GridDirectParser implements GridNioParser {
}
catch (Throwable e) {
U.error(log, "Failed to read message [msg=" + msg +
- ", buf=" + buf +
- ", reader=" + reader +
- ", ses=" + ses + "]",
+ ", buf=" + buf +
+ ", reader=" + reader +
+ ", ses=" + ses + "]",
e);
throw e;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java
index d55bc54..3ca6a8c 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java
@@ -104,7 +104,8 @@ public class GridNioAsyncNotifyFilter extends
GridNioFilterAdapter {
}
/** {@inheritDoc} */
- @Override public void onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex) throws IgniteCheckedException {
+ @Override public void onExceptionCaught(GridNioSession ses,
+ IgniteCheckedException ex) throws IgniteCheckedException {
proceedExceptionCaught(ses, ex);
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java
index b81086a..a53a5c0 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java
@@ -28,8 +28,7 @@ import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteInClosure;
/**
- * Filter that transforms byte buffers to user-defined objects and vice-versa
- * with specified {@link GridNioParser}.
+ * Filter that transforms byte buffers to user-defined objects and vice-versa
with specified {@link GridNioParser}.
*/
public class GridNioCodecFilter extends GridNioFilterAdapter {
/** Parser used. */
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java
index fdbd402..044d186 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java
@@ -62,7 +62,7 @@ public class GridNioDelimitedBuffer {
* @return Message bytes or {@code null} if message is not fully read yet.
*/
@Nullable public byte[] read(ByteBuffer buf) {
- while(buf.hasRemaining()) {
+ while (buf.hasRemaining()) {
if (cnt == data.length)
data = Arrays.copyOf(data, data.length * 2);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java
index dcb11b2..4e25e71 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java
@@ -56,16 +56,18 @@ public class GridNioEmbeddedFuture<R> extends
GridNioFutureImpl<R> {
if (err != null)
onDone(err);
- else delegate.listen(new IgniteInClosure<IgniteInternalFuture<R>>() {
- @Override public void apply(IgniteInternalFuture<R> t) {
- try {
- onDone(t.get());
+ else {
+ delegate.listen(new IgniteInClosure<IgniteInternalFuture<R>>() {
+ @Override public void apply(IgniteInternalFuture<R> t) {
+ try {
+ onDone(t.get());
+ }
+ catch (IgniteCheckedException e) {
+ onDone(e);
+ }
}
- catch (IgniteCheckedException e) {
- onDone(e);
- }
- }
- });
+ });
+ }
}
/** {@inheritDoc} */
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageTracker.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageTracker.java
index f05ee0c..b6df5a6 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageTracker.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageTracker.java
@@ -63,7 +63,7 @@ public class GridNioMessageTracker implements IgniteRunnable {
// It seems acceptable to have the following logic accounting the
aforementioned.
int cnt = 0;
- for (;;) {
+ for (; ; ) {
int cur = msgCnt.get();
if (cur == 0)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
index bd1291a..50084b5 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
@@ -278,8 +278,8 @@ public class GridNioRecoveryDescriptor {
}
/**
- * @throws InterruptedException If interrupted.
* @return {@code True} if reserved.
+ * @throws InterruptedException If interrupted.
*/
public boolean reserve() throws InterruptedException {
synchronized (this) {
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
index 794c8fc..096260b 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
@@ -1076,11 +1076,11 @@ public class GridNioServer<T> {
}
/**
- * Processes read-available event on the key.
- *
- * @param key Key that is ready to be read.
- * @throws IOException If key read failed.
- */
+ * Processes read-available event on the key.
+ *
+ * @param key Key that is ready to be read.
+ * @throws IOException If key read failed.
+ */
@Override protected void processRead(SelectionKey key) throws
IOException {
if (skipRead) {
try {
@@ -1144,11 +1144,11 @@ public class GridNioServer<T> {
}
/**
- * Processes write-ready event on the key.
- *
- * @param key Key that is ready to be written.
- * @throws IOException If write failed.
- */
+ * Processes write-ready event on the key.
+ *
+ * @param key Key that is ready to be written.
+ * @throws IOException If write failed.
+ */
@Override protected void processWrite(SelectionKey key) throws
IOException {
WritableByteChannel sockCh = (WritableByteChannel)key.channel();
@@ -1421,7 +1421,7 @@ public class GridNioServer<T> {
List<SessionWriteRequest> pendingRequests = new
ArrayList<>(2);
if (req != null) {
- msg = (Message) req.message();
+ msg = (Message)req.message();
assert msg != null;
@@ -1448,7 +1448,7 @@ public class GridNioServer<T> {
if (req == null)
break;
- msg = (Message) req.message();
+ msg = (Message)req.message();
assert msg != null;
@@ -1717,6 +1717,7 @@ public class GridNioServer<T> {
/**
* Notifies SessionWriteRequests and it's messages when requests were
actually written.
+ *
* @param ses GridNioSession.
* @param requests SessionWriteRequests.
*/
@@ -2118,7 +2119,7 @@ public class GridNioServer<T> {
StringBuilder sb = new StringBuilder();
try {
- dumpStats(sb, p, p!= null);
+ dumpStats(sb, p, p != null);
}
finally {
req.onDone(sb.toString());
@@ -2380,7 +2381,7 @@ public class GridNioServer<T> {
* @throws ClosedByInterruptException If this thread was interrupted
while reading data.
*/
private void processSelectedKeysOptimized(SelectionKey[] keys) throws
ClosedByInterruptException {
- for (int i = 0; ; i ++) {
+ for (int i = 0; ; i++) {
final SelectionKey key = keys[i];
if (key == null)
@@ -2544,7 +2545,7 @@ public class GridNioServer<T> {
}
}
catch (IgniteCheckedException e) {
- close(ses, e);
+ close(ses, e);
}
}
}
@@ -3003,7 +3004,7 @@ public class GridNioServer<T> {
if (log.isDebugEnabled())
log.debug("Processing keys in accept worker: " + keys.size());
- for (Iterator<SelectionKey> iter = keys.iterator();
iter.hasNext();) {
+ for (Iterator<SelectionKey> iter = keys.iterator();
iter.hasNext(); ) {
SelectionKey key = iter.next();
iter.remove();
@@ -3530,7 +3531,8 @@ public class GridNioServer<T> {
}
/** {@inheritDoc} */
- @Override public void onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex) throws IgniteCheckedException {
+ @Override public void onExceptionCaught(GridNioSession ses,
+ IgniteCheckedException ex) throws IgniteCheckedException {
proceedExceptionCaught(ses, ex);
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
index c6410c4..51cb558 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
@@ -175,7 +175,7 @@ public class GridNioSessionImpl implements GridNioSession {
}
/** {@inheritDoc} */
- @Override @Nullable public InetSocketAddress remoteAddress() {
+ @Override @Nullable public InetSocketAddress remoteAddress() {
return rmtAddr;
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
index d9c3cae..2739299 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
@@ -31,8 +31,8 @@ import org.apache.ignite.IgniteLogger;
import org.apache.ignite.internal.util.tostring.GridToStringExclude;
import org.apache.ignite.internal.util.typedef.internal.LT;
import org.apache.ignite.internal.util.typedef.internal.S;
-import org.jetbrains.annotations.Nullable;
import org.apache.ignite.util.deque.FastSizeDeque;
+import org.jetbrains.annotations.Nullable;
/**
* Session implementation bound to selector API and socket API.
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridShmemCommunicationClient.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridShmemCommunicationClient.java
index ab9b2eb..f93738c 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridShmemCommunicationClient.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridShmemCommunicationClient.java
@@ -63,8 +63,7 @@ public class GridShmemCommunicationClient extends
GridAbstractCommunicationClien
long connTimeout,
IgniteLogger log,
MessageFormatter formatter)
- throws IgniteCheckedException
- {
+ throws IgniteCheckedException {
super(connIdx, metricsLsnr);
assert metricsLsnr != null;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
index eff893f..98f6941 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
@@ -69,7 +69,7 @@ public class GridTcpNioCommunicationClient extends
GridAbstractCommunicationClie
}
/** {@inheritDoc} */
- @Override public void doHandshake(IgniteInClosure2X<InputStream,
OutputStream> handshakeC) throws IgniteCheckedException {
+ @Override public void doHandshake(IgniteInClosure2X<InputStream,
OutputStream> handshakeC) {
throw new UnsupportedOperationException();
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/SelectedSelectionKeySet.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/SelectedSelectionKeySet.java
index 389975a..b671892 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/SelectedSelectionKeySet.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/SelectedSelectionKeySet.java
@@ -16,7 +16,6 @@
package org.apache.ignite.internal.util.nio;
-
import java.nio.channels.SelectionKey;
import java.util.AbstractSet;
import java.util.Iterator;
@@ -55,14 +54,14 @@ final class SelectedSelectionKeySet extends
AbstractSet<SelectionKey> {
if (isA) {
int size = keysASize;
- keysA[size ++] = o;
+ keysA[size++] = o;
keysASize = size;
if (size == keysA.length)
doubleCapacityA();
}
else {
int size = keysBSize;
- keysB[size ++] = o;
+ keysB[size++] = o;
keysBSize = size;
if (size == keysB.length)
doubleCapacityB();
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/package-info.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/package-info.java
index 4680153..d1882a4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/package-info.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/package-info.java
@@ -16,7 +16,6 @@
*/
/**
- * <!-- Package description. -->
- * NIO server interfaces and common utility classes for NIO.
+ * <!-- Package description. --> NIO server interfaces and common utility
classes for NIO.
*/
package org.apache.ignite.internal.util.nio;
\ No newline at end of file
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/BlockingSslHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/BlockingSslHandler.java
index 0099c46..67c0084 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/BlockingSslHandler.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/BlockingSslHandler.java
@@ -68,7 +68,7 @@ public class BlockingSslHandler {
/** Input buffer from which SSL engine will decrypt data. */
private ByteBuffer inNetBuf;
- /** Empty buffer used in handshake procedure. */
+ /** Empty buffer used in handshake procedure. */
private ByteBuffer handshakeBuf = ByteBuffer.allocate(0);
/** Application buffer. */
@@ -119,7 +119,7 @@ public class BlockingSslHandler {
/**
*
*/
- public ByteBuffer inputBuffer(){
+ public ByteBuffer inputBuffer() {
return inNetBuf;
}
@@ -223,8 +223,8 @@ public class BlockingSslHandler {
* Encrypts data to be written to the network.
*
* @param src data to encrypt.
- * @throws SSLException on errors.
* @return Output buffer with encrypted data.
+ * @throws SSLException on errors.
*/
public ByteBuffer encrypt(ByteBuffer src) throws SSLException {
assert handshakeFinished;
@@ -364,7 +364,6 @@ public class BlockingSslHandler {
return sslEngine.getHandshakeStatus();
}
-
/**
* Unwraps handshake data and processes it.
*
@@ -373,7 +372,7 @@ public class BlockingSslHandler {
* @throws GridNioException If failed to pass event to the next filter.
*/
private Status unwrapHandshake() throws SSLException,
IgniteCheckedException {
- if(!inNetBuf.hasRemaining())
+ if (!inNetBuf.hasRemaining())
readFromNet();
// Flip input buffer so we can read the collected data.
@@ -400,7 +399,7 @@ public class BlockingSslHandler {
else if (res.getStatus() == BUFFER_UNDERFLOW) {
inNetBuf.compact();
- if(inNetBuf.capacity() == inNetBuf.limit())
+ if (inNetBuf.capacity() == inNetBuf.limit())
inNetBuf = expandBuffer(inNetBuf, inNetBuf.capacity() * 2);
readFromNet();
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslFilter.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslFilter.java
index f8a0dce..845f1e7 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslFilter.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslFilter.java
@@ -90,7 +90,6 @@ public class GridNioSslFilter extends GridNioFilterAdapter {
}
/**
- *
* @param directMode Flag indicating whether direct mode is used.
*/
public void directMode(boolean directMode) {
@@ -376,8 +375,8 @@ public class GridNioSslFilter extends GridNioFilterAdapter {
*
* @param ses Session to shutdown.
* @param hnd SSL handler.
- * @throws GridNioException If failed to forward requests to filter chain.
* @return Close future.
+ * @throws GridNioException If failed to forward requests to filter chain.
*/
private GridNioFuture<Boolean> shutdownSession(GridNioSession ses,
GridNioSslHandler hnd)
throws IgniteCheckedException {
@@ -435,7 +434,7 @@ public class GridNioSslFilter extends GridNioFilterAdapter {
private ByteBuffer checkMessage(GridNioSession ses, Object msg) throws
GridNioException {
if (!(msg instanceof ByteBuffer))
throw new GridNioException("Invalid object type received (is SSL
filter correctly placed in filter " +
- "chain?) [ses=" + ses + ", msgClass=" +
msg.getClass().getName() + ']');
+ "chain?) [ses=" + ses + ", msgClass=" +
msg.getClass().getName() + ']');
return (ByteBuffer)msg;
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslHandler.java
index e268716..8d28de2 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslHandler.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslHandler.java
@@ -84,7 +84,7 @@ class GridNioSslHandler extends ReentrantLock {
/** Input buffer from which SSL engine will decrypt data. */
private ByteBuffer inNetBuf;
- /** Empty buffer used in handshake procedure. */
+ /** Empty buffer used in handshake procedure. */
private ByteBuffer handshakeBuf = ByteBuffer.allocate(0);
/** Application buffer. */
@@ -341,8 +341,8 @@ class GridNioSslHandler extends ReentrantLock {
* Encrypts data to be written to the network.
*
* @param src data to encrypt.
- * @throws SSLException on errors.
* @return Output buffer with encrypted data.
+ * @throws SSLException on errors.
*/
ByteBuffer encrypt(ByteBuffer src) throws SSLException {
assert handshakeFinished;
@@ -431,6 +431,7 @@ class GridNioSslHandler extends ReentrantLock {
/**
* Flushes all deferred write events.
+ *
* @throws GridNioException If failed to forward writes to the filter.
*/
void flushDeferredWrites() throws IgniteCheckedException {
@@ -447,10 +448,9 @@ class GridNioSslHandler extends ReentrantLock {
/**
* Writes close_notify message to the network output buffer.
*
- * @throws SSLException If wrap failed or SSL engine does not get closed
- * after wrap.
- * @return {@code True} if <tt>close_notify</tt> message was encoded,
{@code false} if outbound
- * stream was already closed.
+ * @return {@code True} if <tt>close_notify</tt> message was encoded,
{@code false} if outbound stream was already
+ * closed.
+ * @throws SSLException If wrap failed or SSL engine does not get closed
after wrap.
*/
boolean closeOutbound() throws SSLException {
assert isHeldByCurrentThread();
@@ -477,8 +477,8 @@ class GridNioSslHandler extends ReentrantLock {
/**
* Copies data from out net buffer and passes it to the underlying chain.
*
- * @return Write future.
* @param ackC Closure invoked when message ACK is received.
+ * @return Write future.
* @throws GridNioException If send failed.
*/
GridNioFuture<?> writeNetBuffer(IgniteInClosure<IgniteException> ackC)
throws IgniteCheckedException {
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/package-info.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/package-info.java
index aacc985..64337c4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/package-info.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/package-info.java
@@ -16,7 +16,6 @@
*/
/**
- * <!-- Package description. -->
- * Implementation of Secure Socket Layer filter for NIO server based on
SSLEngine class.
+ * <!-- Package description. --> Implementation of Secure Socket Layer filter
for NIO server based on SSLEngine class.
*/
package org.apache.ignite.internal.util.nio.ssl;
\ No newline at end of file
