[iotdb] branch autoai_debug updated: add log 3: timing LogWriter.channel.write

[qiaojialin]

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

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


The following commit(s) were added to refs/heads/autoai_debug by this push:
     new 87aa38d  add log 3: timing LogWriter.channel.write
87aa38d is described below

commit 87aa38d1d370e99ae7dbb56b00a670798e90188a
Author: qiaojialin <646274...@qq.com>
AuthorDate: Wed Jul 28 15:50:25 2021 +0800

    add log 3: timing LogWriter.channel.write
---
 .../main/java/org/apache/iotdb/db/writelog/io/LogWriter.java  | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/writelog/io/LogWriter.java 
b/server/src/main/java/org/apache/iotdb/db/writelog/io/LogWriter.java
index 41de59e..de716c3 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/io/LogWriter.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/io/LogWriter.java
@@ -94,17 +94,16 @@ public class LogWriter implements ILogWriter {
     checkSumBuffer.flip();
 
     try {
+      long start = System.nanoTime();
       channel.write(lengthBuffer);
       channel.write(logBuffer);
       channel.write(checkSumBuffer);
-
+      long elapse = System.nanoTime() - start;
+      if (elapse > 3_000_000_000L) {
+        logger.warn("[WAL] LogWriter channel.force cost {}ms", elapse / 
1_000_000L);
+      }
       if (this.forceEachWrite) {
-        long start = System.nanoTime();
         channel.force(true);
-        long elapse = System.nanoTime() - start;
-        if (elapse > 3_000_000_000L) {
-          logger.warn("[WAL] LogWriter channel.force cost {}ms", elapse / 
1_000_000L);
-        }
       }
     } catch (ClosedChannelException ignored) {
       logger.warn("someone interrupt current thread, so no need to do write 
for io safety");