From 181486c3489307201592c9f42211933d925839e2 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Sun, 30 Apr 2017 18:30:53 +0800 Subject: [PATCH] --- src/org/redkale/net/sncp/SncpClient.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/org/redkale/net/sncp/SncpClient.java b/src/org/redkale/net/sncp/SncpClient.java index 86599e7c1..609ea995d 100644 --- a/src/org/redkale/net/sncp/SncpClient.java +++ b/src/org/redkale/net/sncp/SncpClient.java @@ -367,12 +367,12 @@ public final class SncpClient { } private CompletableFuture remoteSncp0(final AsyncHandler handler, final BsonConvert bsonConvert, final Transport transport, final SocketAddress addr0, final SncpAction action, final Object... params) { - Type[] myparamtypes = action.paramTypes; - Class[] myparamclass = action.paramClass; + final Type[] myparamtypes = action.paramTypes; + final Class[] myparamclass = action.paramClass; if (action.addressSourceParamIndex >= 0) params[action.addressSourceParamIndex] = this.clientAddress; final BsonWriter writer = bsonConvert.pollBsonWriter(transport.getBufferSupplier()); // 将head写入 writer.writeTo(DEFAULT_HEADER); - for (int i = 0; i < params.length; i++) { + for (int i = 0; i < myparamtypes.length; i++) { //params 可能包含: 3 个 boolean bsonConvert.convertTo(writer, AsyncHandler.class.isAssignableFrom(myparamclass[i]) ? AsyncHandler.class : myparamtypes[i], params[i]); } final int reqBodyLength = writer.count() - HEADER_SIZE; //body总长度