[ISSUE #7592] testCleanBuffer unit test modifies, changed non-direct …

common/src/main/java/org/apache/rocketmq/common/UtilAll.java

@@ -699,10 +699,19 @@ public static void deleteEmptyDirectory(File file) {
         }
     }
 
+    /**
+     * Free direct-buffer's memory actively.
+     * @param buffer Direct buffer to free.
+     */
     public static void cleanBuffer(final ByteBuffer buffer) {
         if (null == buffer) {
             return;
         }
+
+        if (!buffer.isDirect()) {
+            return;
+        }
+
         PlatformDependent.freeDirectBuffer(buffer);
     }
 

common/src/test/java/org/apache/rocketmq/common/UtilAllTest.java

@@ -215,8 +215,9 @@ public void setSubField1(boolean subField1) {
     @Test
     public void testCleanBuffer() {
         UtilAll.cleanBuffer(null);
+        UtilAll.cleanBuffer(ByteBuffer.allocateDirect(10));
+        UtilAll.cleanBuffer(ByteBuffer.allocateDirect(0));
         UtilAll.cleanBuffer(ByteBuffer.allocate(10));
-        UtilAll.cleanBuffer(ByteBuffer.allocate(0));
     }
 
     @Test

store/src/test/java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java

@@ -387,7 +387,7 @@ public void testStateAndRecover() throws Exception {
             assertEquals(PutMessageStatus.PUT_OK, putMessageResult.getPutMessageStatus());
         }
 
-        // Wait until messages have wrote to TimerLog and currReadTimeMs catches up current time.
+        // Wait until messages have written to TimerLog and currReadTimeMs catches up current time.
         await().atMost(5000, TimeUnit.MILLISECONDS).until(new Callable<Boolean>() {
             @Override
             public Boolean call() {