Fix checkstyle in Kryo{IO,Input,Output}Pool

[controller.git] / atomix-storage / src / main / java / io / atomix / utils / serializer / KryoInputPool.java

diff --git a/atomix-storage/src/main/java/io/atomix/utils/serializer/KryoInputPool.java b/atomix-storage/src/main/java/io/atomix/utils/serializer/KryoInputPool.java
index 0eeb8dfc89dbccc88427a1a054b55a942c1b57a0..4f5ac46f77f62c200c542ebdc4a823d94b293ac9 100644 (file)
--- a/atomix-storage/src/main/java/io/atomix/utils/serializer/KryoInputPool.java
+++ b/atomix-storage/src/main/java/io/atomix/utils/serializer/KryoInputPool.java
@@ -17,21 +17,21 @@ package io.atomix.utils.serializer;
 
 import com.esotericsoftware.kryo.io.Input;
 
-class KryoInputPool extends KryoIOPool<Input> {
+final class KryoInputPool extends KryoIOPool<Input> {
+    static final int MAX_POOLED_BUFFER_SIZE = 512 * 1024;
 
-  static final int MAX_POOLED_BUFFER_SIZE = 512 * 1024;
-
-  @Override
-  protected Input create(int bufferSize) {
-    return new Input(bufferSize);
-  }
+    @Override
+    Input create(final int bufferSize) {
+        return new Input(bufferSize);
+    }
 
-  @Override
-  protected boolean recycle(Input input) {
-    if (input.getBuffer().length < MAX_POOLED_BUFFER_SIZE) {
-      input.setInputStream(null);
-      return true;
+    @Override
+    boolean recycle(final Input input) {
+        if (input.getBuffer().length >= MAX_POOLED_BUFFER_SIZE) {
+            // discard
+            return false;
+        }
+        input.setInputStream(null);
+        return true;
     }
-    return false; // discard
-  }
 }