Skip to content

Commit d203103

Browse files
committed
More checkstyle
1 parent ca0dbbe commit d203103

File tree

5 files changed

+11
-13
lines changed

5 files changed

+11
-13
lines changed

bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BatchedReadCompletion.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
package org.apache.bookkeeper.proto;
2323

2424
import static org.apache.bookkeeper.client.LedgerHandle.INVALID_ENTRY_ID;
25+
2526
import org.apache.bookkeeper.client.BKException;
2627
import org.apache.bookkeeper.util.ByteBufList;
2728

bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/CompletionValue.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ void logOpResult(int rc) {
7272
}
7373

7474
if (rc != BKException.Code.OK
75-
&& !PerChannelBookieClient.expectedBkOperationErrors.contains(rc)) {
75+
&& !PerChannelBookieClient.EXPECTED_BK_OPERATION_ERRORS.contains(rc)) {
7676
perChannelBookieClient.recordError();
7777
}
7878
}

bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/GetListOfEntriesOfLedgerCompletion.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
package org.apache.bookkeeper.proto;
2323

2424
import static org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GetListOfEntriesOfLedgerCallback;
25+
2526
import io.netty.buffer.ByteBuf;
2627
import io.netty.buffer.Unpooled;
2728
import org.apache.bookkeeper.client.BKException;

bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ public class PerChannelBookieClient extends ChannelInboundHandlerAdapter {
149149
static final Logger LOG = LoggerFactory.getLogger(PerChannelBookieClient.class);
150150

151151
// this set contains the bookie error return codes that we do not consider for a bookie to be "faulty"
152-
protected static final Set<Integer> expectedBkOperationErrors = Collections.unmodifiableSet(Sets
152+
protected static final Set<Integer> EXPECTED_BK_OPERATION_ERRORS = Collections.unmodifiableSet(Sets
153153
.newHashSet(BKException.Code.BookieHandleNotAvailableException,
154154
BKException.Code.NoSuchEntryException,
155155
BKException.Code.NoSuchLedgerExistsException,

bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadCompletion.java

Lines changed: 7 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
package org.apache.bookkeeper.proto;
2323

2424
import static org.apache.bookkeeper.client.LedgerHandle.INVALID_ENTRY_ID;
25+
2526
import io.netty.buffer.ByteBuf;
2627
import io.netty.buffer.Unpooled;
2728
import io.netty.util.ReferenceCountUtil;
@@ -38,17 +39,12 @@ public ReadCompletion(final CompletionKey key,
3839
super("Read", originalCtx, ledgerId, entryId, perChannelBookieClient);
3940
this.opLogger = perChannelBookieClient.readEntryOpLogger;
4041
this.timeoutOpLogger = perChannelBookieClient.readTimeoutOpLogger;
41-
this.cb = new BookkeeperInternalCallbacks.ReadEntryCallback() {
42-
@Override
43-
public void readEntryComplete(int rc, long ledgerId,
44-
long entryId, ByteBuf buffer,
45-
Object ctx) {
46-
logOpResult(rc);
47-
originalCallback.readEntryComplete(rc,
48-
ledgerId, entryId,
49-
buffer, originalCtx);
50-
key.release();
51-
}
42+
this.cb = (rc, ledgerId1, entryId1, buffer, ctx) -> {
43+
logOpResult(rc);
44+
originalCallback.readEntryComplete(rc,
45+
ledgerId1, entryId1,
46+
buffer, originalCtx);
47+
key.release();
5248
};
5349
}
5450

0 commit comments

Comments
 (0)