[iotdb] branch add_restart_logs updated: add more logs

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch add_restart_logs
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/add_restart_logs by this push:
     new 24b4154  add more logs
24b4154 is described below

commit 24b4154a1b5c8ab2c4d0ade5a41aa6ea17575c45
Author: jt <jt2594...@163.com>
AuthorDate: Tue Oct 13 13:07:05 2020 +0800

    add more logs
---
 .../java/org/apache/iotdb/db/writelog/recover/LogReplayer.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java 
b/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
index 8f9cbd4..0922b0c 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
@@ -88,10 +88,16 @@ public class LogReplayer {
         logNodePrefix + 
FSFactoryProducer.getFSFactory().getFile(insertFilePath).getName());
 
     ILogReader logReader = logNode.getLogReader();
+    long readLogTime = 0;
+    long replayLogTime = 0;
     try {
       while (logReader.hasNext()) {
         try {
+          long start = System.nanoTime();
           PhysicalPlan plan = logReader.next();
+          readLogTime += System.nanoTime() - start;
+
+          start = System.nanoTime();
           if (plan instanceof InsertPlan) {
             replayInsert((InsertPlan) plan);
           } else if (plan instanceof DeletePlan) {
@@ -99,6 +105,7 @@ public class LogReplayer {
           } else if (plan instanceof UpdatePlan) {
             replayUpdate((UpdatePlan) plan);
           }
+          replayLogTime += System.nanoTime() - start;
         } catch (Exception e) {
           logger.error("recover wal of {} failed", insertFilePath, e);
         }
@@ -113,6 +120,9 @@ public class LogReplayer {
         logger.error("Canno close the modifications file {}", 
modFile.getFilePath(), e);
       }
     }
+    readLogTime = readLogTime / 1_000_000L;
+    replayLogTime = replayLogTime / 1_000_000L;
+    logger.debug("Read logs costs {}ms, replay logs costs {}ms", readLogTime, 
replayLogTime);
     tempStartTimeMap.forEach((k, v) -> 
currentTsFileResource.updateStartTime(k, v));
     tempEndTimeMap.forEach((k, v) -> currentTsFileResource.updateEndTime(k, 
v));
   }