Repository: incubator-rocketmq Updated Branches: refs/heads/master 75d337d18 -> bfc19a167
Fix typo Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/bfc19a16 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/bfc19a16 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/bfc19a16 Branch: refs/heads/master Commit: bfc19a1673222df9d4d37260385befee70386359 Parents: 75d337d Author: Zhanhui Li <[email protected]> Authored: Mon Jan 16 15:16:34 2017 +0800 Committer: Zhanhui Li <[email protected]> Committed: Mon Jan 16 15:16:34 2017 +0800 ---------------------------------------------------------------------- store/src/main/java/org/apache/rocketmq/store/MappedFile.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/bfc19a16/store/src/main/java/org/apache/rocketmq/store/MappedFile.java ---------------------------------------------------------------------- diff --git a/store/src/main/java/org/apache/rocketmq/store/MappedFile.java b/store/src/main/java/org/apache/rocketmq/store/MappedFile.java index f975727..cd4b57b 100644 --- a/store/src/main/java/org/apache/rocketmq/store/MappedFile.java +++ b/store/src/main/java/org/apache/rocketmq/store/MappedFile.java @@ -486,11 +486,11 @@ public class MappedFile extends ReferenceResource { // force flush when prepare load finished if (type == FlushDiskType.SYNC_FLUSH) { - log.info("mapped file worm up done, force to disk, mappedFile={}, costTime={}", + log.info("mapped file warm-up done, force to disk, mappedFile={}, costTime={}", this.getFileName(), System.currentTimeMillis() - beginTime); mappedByteBuffer.force(); } - log.info("mapped file worm up done. mappedFile={}, costTime={}", this.getFileName(), + log.info("mapped file warm-up done. mappedFile={}, costTime={}", this.getFileName(), System.currentTimeMillis() - beginTime); this.mlock();
