This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch autoai_debug_single in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 01a50ab29cff8b3ad9e5107b9ec61f5b658ca416 Author: HTHou <[email protected]> AuthorDate: Wed Jul 21 18:21:27 2021 +0800 spotless --- .../db/writelog/node/ExclusiveWriteLogNode.java | 28 +++++++++++----------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java b/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java index 57d8c15..0a663cd 100644 --- a/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java +++ b/server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java @@ -314,7 +314,7 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive private void switchBufferWorkingToFlushing() throws InterruptedException { // logger.warn("[wal] {} switchBufferWorkingToFlushing start", this.hashCode()); - //long start = System.currentTimeMillis(); + // long start = System.currentTimeMillis(); synchronized (switchBufferCondition) { while (logBufferFlushing != null && !deleted) { switchBufferCondition.wait(100); @@ -323,10 +323,10 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive logBufferWorking = null; switchBufferCondition.notifyAll(); } -// long elapse = System.currentTimeMillis() - start; -// if (elapse > 2000) { -// logger.error("[wal] switch Working -> Flushing cost: {}ms", elapse); -// } + // long elapse = System.currentTimeMillis() - start; + // if (elapse > 2000) { + // logger.error("[wal] switch Working -> Flushing cost: {}ms", elapse); + // } // logger.warn("[wal] {} switchBufferWorkingToFlushing end", this.hashCode()); } @@ -341,16 +341,16 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive logBufferIdle = null; switchBufferCondition.notifyAll(); } -// long elapse = System.currentTimeMillis() - start; -// if (elapse > 2000) { -// logger.error("[wal] switch Idle -> Working cost: {}ms", elapse); -// } + // long elapse = System.currentTimeMillis() - start; + // if (elapse > 2000) { + // logger.error("[wal] switch Idle -> Working cost: {}ms", elapse); + // } // logger.warn("[wal] {} switchBufferIdleToWorking end", this.hashCode()); } private void switchBufferFlushingToIdle() throws InterruptedException { // logger.warn("[wal] {} switchBufferFlushingToIdle start", this.hashCode()); -// long start = System.currentTimeMillis(); + // long start = System.currentTimeMillis(); synchronized (switchBufferCondition) { while (logBufferIdle != null && !deleted) { switchBufferCondition.wait(100); @@ -360,10 +360,10 @@ public class ExclusiveWriteLogNode implements WriteLogNode, Comparable<Exclusive logBufferFlushing = null; switchBufferCondition.notifyAll(); } -// long elapse = System.currentTimeMillis() - start; -// if (elapse > 2000) { -// logger.error("[wal] switch Flushing -> Idle cost: {}ms", elapse); -// } + // long elapse = System.currentTimeMillis() - start; + // if (elapse > 2000) { + // logger.error("[wal] switch Flushing -> Idle cost: {}ms", elapse); + // } // logger.warn("[wal] {} switchBufferFlushingToIdle end", this.hashCode()); }
