Fix os pache cache busy problem

broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java

@@ -783,6 +783,15 @@ public class BrokerController {
             this.filterServerManager.start();
         }
 
+        if (messageStoreConfig.isEnableDLegerCommitLog()) {
+            changeToSlave();
+        } else {
+            startProcessorByHa();
+            handleSlaveSynchronize(messageStoreConfig.getBrokerRole());
+        }
+
+
+
         this.registerBrokerAll(true, false, true);
 
         this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
@@ -805,10 +814,7 @@ public class BrokerController {
             this.brokerFastFailure.start();
         }
 
-        if (!messageStoreConfig.isEnableDLegerCommitLog()) {
-            startProcessorByHa();
-            handleSlaveSynchronize(messageStoreConfig.getBrokerRole());
-        }
+
     }
 
     public synchronized void registerIncrementBrokerData(TopicConfig topicConfig, DataVersion dataVersion) {

store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java

@@ -345,6 +345,7 @@ public class DLegerCommitLog extends CommitLog {
             log.error("Put message error", e);
             appendResult = new AppendMessageResult(AppendMessageStatus.UNKNOWN_ERROR);
         } finally {
+            beginTimeInLock = 0;
             putMessageLock.unlock();
         }
 
@@ -352,7 +353,6 @@ public class DLegerCommitLog extends CommitLog {
             log.warn("[NOTIFYME]putMessage in lock cost time(ms)={}, bodyLength={} AppendMessageResult={}", eclipseTimeInLock, msg.getBody().length, appendResult);
         }
 
-
         if (dlegerFuture != null) {
             try {
                 AppendEntryResponse appendEntryResponse = dlegerFuture.get(3, TimeUnit.SECONDS);