Code style & imports fix for NIO package
authorDmitriy Pavlov <dpavlov@apache.org>
Thu, 14 Feb 2019 14:04:21 +0000 (17:04 +0300)
committerDmitriy Pavlov <dpavlov@apache.org>
Thu, 14 Feb 2019 14:04:21 +0000 (17:04 +0300)
19 files changed:
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageTracker.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridShmemCommunicationClient.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/SelectedSelectionKeySet.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/package-info.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/BlockingSslHandler.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslFilter.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/GridNioSslHandler.java
modules/core/src/main/java/org/apache/ignite/internal/util/nio/ssl/package-info.java

index f872ff6..b4a9a95 100644 (file)
@@ -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;
index 152ffe6..2e178e2 100644 (file)
@@ -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;
index d55bc54..3ca6a8c 100644 (file)
@@ -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);
     }
 
index b81086a..a53a5c0 100644 (file)
@@ -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. */
index fdbd402..044d186 100644 (file)
@@ -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);
 
index dcb11b2..4e25e71 100644 (file)
@@ -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} */
index f05ee0c..b6df5a6 100644 (file)
@@ -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)
index bd1291a..50084b5 100644 (file)
@@ -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) {
index 794c8fc..096260b 100644 (file)
@@ -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);
         }
 
index c6410c4..51cb558 100644 (file)
@@ -175,7 +175,7 @@ public class GridNioSessionImpl implements GridNioSession {
     }
 
     /** {@inheritDoc} */
-    @Override  @Nullable public InetSocketAddress remoteAddress() {
+    @Override @Nullable public InetSocketAddress remoteAddress() {
         return rmtAddr;
     }
 
index d9c3cae..2739299 100644 (file)
@@ -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.
index ab9b2eb..f93738c 100644 (file)
@@ -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;
index eff893f..98f6941 100644 (file)
@@ -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();
     }
 
index 389975a..b671892 100644 (file)
@@ -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();
index 4680153..d1882a4 100644 (file)
@@ -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
index 0099c46..67c0084 100644 (file)
@@ -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();
index f8a0dce..845f1e7 100644 (file)
@@ -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;
     }
index e268716..8d28de2 100644 (file)
@@ -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 {
index aacc985..64337c4 100644 (file)
@@ -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