From ea077348a36f7c09b0ccbec0c4ac2da20c2ca03f Mon Sep 17 00:00:00 2001 From: wusheng Date: Mon, 29 Feb 2016 16:36:47 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../skywalking/sender/DataSenderFactoryWithBalance.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java index 31c6d876d..b304d6766 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java @@ -202,9 +202,7 @@ public class DataSenderFactoryWithBalance { } private static DataSender findReadySender() { - DataSender result = null; - int index = 0; if (unusedServerAddresses.size() > 1){ @@ -234,11 +232,7 @@ public class DataSenderFactoryWithBalance { } public static void unRegister(DataSender socket) { - int index = usingDataSender.indexOf(socket); - if (index != -1) { - usingDataSender.get(index) - .setStatus(DataSender.SenderStatus.FAILED); - } + socket.setStatus(DataSender.SenderStatus.FAILED); } private static String listUsingServers(){