fixed #6 打印刷盘进度时，会导致Slave创建错误的文件，修复

chenld · May 19, 2013 · 5aabcf3 · 5aabcf3
1 parent a445e65
commit 5aabcf3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/MapedFileQueue.java b/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/MapedFileQueue.java
@@ -132,6 +132,9 @@ public boolean load() {
      * 刷盘进度落后了多少
      */
     public long howMuchFallBehind() {
+        if (this.mapedFiles.isEmpty())
+            return 0;
+
         long committed = this.committedWhere;
         if (committed != 0) {
             MapedFile mapedFile = this.getLastMapedFile();