Merge pull request !88 from 胡贵/develop

Author: qq254963746

lts-core/src/main/java/com/lts/core/monitor/MStatReportWorker.java

@@ -96,6 +96,13 @@ private void report(MData mData) {
         // Send monitor data
         mDataQueue.add(mData);
 
+        // check size
+        int size = mDataQueue.size();
+        if (size > MAX_RETRY_RETAIN) {
+            // delete the oldest
+            mDataQueue = mDataQueue.subList(size - MAX_RETRY_RETAIN, size);
+        }
+
         List<Node> monitorNodes = appContext.getSubscribedNodeManager().getNodeList(NodeType.MONITOR);
         if (CollectionUtils.isEmpty(monitorNodes)) {
             if (LOGGER.isDebugEnabled()) {
@@ -105,7 +112,7 @@ private void report(MData mData) {
         }
 
         int toIndex = 0;
-        int size = mDataQueue.size();
+        size = mDataQueue.size();
         try {
             for (int i = 0; i <= size / BATCH_REPORT_SIZE; i++) {
                 List<MData> mDatas = BatchUtils.getBatchList(i, BATCH_REPORT_SIZE, mDataQueue);
@@ -137,12 +144,6 @@ private void report(MData mData) {
                 mDataQueue = mDataQueue.subList(toIndex + 1, size);
             }
         }
-        // check size
-        size = mDataQueue.size();
-        if (size > MAX_RETRY_RETAIN) {
-            // delete the oldest
-            mDataQueue = mDataQueue.subList(size - MAX_RETRY_RETAIN, size);
-        }
     }
 
     // 发送请求