From 2f923b26e2c9d9e60fd1d486371dea9d258c92fa Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Mon, 7 Dec 2015 18:15:39 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=97=A0=E6=95=88=E7=9A=84?= =?UTF-8?q?=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cloud/skywalking/sender/DataSenderFactoryWithBalance.java | 2 -- 1 file changed, 2 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 784a54d28..dea1708ee 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 @@ -126,7 +126,6 @@ public class DataSenderFactoryWithBalance { logger.log(Level.ALL, "Sleep failed."); } } - // 找到可以替换的Sender usingDataSender.set(i, newSender); unusedServerAddresses.add(usingDataSender.get(i).getServerIp()); if (usingDataSender.size() >= maxKeepConnectingSenderSize) { @@ -148,7 +147,6 @@ public class DataSenderFactoryWithBalance { toBeSwitchSender = usingDataSender.get(toBeSwitchIndex); if (toBeSwitchSender.getStatus() == DataSender.SenderStatus.READY) { tmpSender = findReadySender(); - // 找到可以替换的Sender if (tmpSender != null) { usingDataSender.set(toBeSwitchIndex, tmpSender); try {