From 27a678de3c592f4b87c4284bba64b2d50d966785 Mon Sep 17 00:00:00 2001 From: wangkai <8738115@qq.com> Date: Wed, 20 Sep 2017 12:19:15 +0800 Subject: [PATCH] [ROCKETMQ-273] return an expression when a function has no write operations. Author: wangkai <8738115@qq.com> Closes #150 from kevin-better/develop. --- .../org/apache/rocketmq/store/DefaultMessageStore.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 59ef4904..192d0972 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -416,12 +416,8 @@ public class DefaultMessageStore implements MessageStore { long begin = this.getCommitLog().getBeginTimeInLock(); long diff = this.systemClock.now() - begin; - if (diff < 10000000 - && diff > this.messageStoreConfig.getOsPageCacheBusyTimeOutMills()) { - return true; - } - - return false; + return diff < 10000000 + && diff > this.messageStoreConfig.getOsPageCacheBusyTimeOutMills(); } @Override -- GitLab