From 60bf7631aa748687690294d5dc0238a5e8b48a24 Mon Sep 17 00:00:00 2001
From: wusheng <wu.sheng@foxmail.com>
Date: Thu, 25 Feb 2016 10:08:37 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=8F=90=E4=BA=A4=EF=BC=8C?=
 =?UTF-8?q?=E4=BF=AE=E5=A4=8DunusedServerAddresses=E7=9A=84=E6=95=B0?=
 =?UTF-8?q?=E9=87=8F=E5=B0=8F=E4=BA=8E1=E7=9A=84=E6=83=85=E5=86=B5?=
 =?UTF-8?q?=EF=BC=8C=E9=98=B2=E6=AD=A2unusedServerAddresses.size=E4=B8=BA0?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8C=E8=BF=9E=E6=8E=A5=E5=B7=A1=E6=A3=80=E7=BA=BF?=
 =?UTF-8?q?=E7=A8=8B=E5=BC=82=E5=B8=B8=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 skywalking-api/pom.xml                                    | 8 ++++++++
 .../skywalking/sender/DataSenderFactoryWithBalance.java   | 4 ++--
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/skywalking-api/pom.xml b/skywalking-api/pom.xml
index fcf5ce51e..93965ccae 100644
--- a/skywalking-api/pom.xml
+++ b/skywalking-api/pom.xml
@@ -134,4 +134,12 @@
 			</plugin>
 		</plugins>
 	</build>
+	
+	<distributionManagement>
+		<snapshotRepository>
+			<id>company-private-nexus-library-snapshots</id>
+			<name>company-private-nexus-library-snapshots</name>
+			<url>http://10.1.228.199:18081/nexus/content/repositories/snapshots/</url>
+		</snapshotRepository>
+	</distributionManagement>
 </project>
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 5a2662c2c..8a021aef5 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
@@ -135,7 +135,7 @@ public class DataSenderFactoryWithBalance {
                     }
 
                     // try to fill up senders. if size is not enough.
-                    while (usingDataSender.size() < maxKeepConnectingSenderSize) {
+                    while (unusedServerAddresses.size() > 0 && usingDataSender.size() < maxKeepConnectingSenderSize) {
                         if ((newSender = findReadySender()) == null) {
                             // no available sender. ignore.
                             break;
@@ -145,7 +145,7 @@ public class DataSenderFactoryWithBalance {
                     }
 
                     // try to switch.
-                    if (sleepTime >= SWITCH_SENDER_INTERVAL) {
+                    if (sleepTime >= SWITCH_SENDER_INTERVAL && unusedServerAddresses.size() > 0) {
                         // if sender is enough, go to switch for balancing.
                         if (usingDataSender.size() >= maxKeepConnectingSenderSize) {
                             DataSender toBeSwitchSender;