(ratis) branch master updated: RATIS-2144. SegmentedRaftLogWorker should close the stream before releasing the buffer. (#1138)

[szetszwo]

This is an automated email from the ASF dual-hosted git repository.

szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git


The following commit(s) were added to refs/heads/master by this push:
     new 24fb55363 RATIS-2144. SegmentedRaftLogWorker should close the stream 
before releasing the buffer. (#1138)
24fb55363 is described below

commit 24fb55363e94f171ab8e1d736bdaf3745f16719f
Author: Potato <tanxi...@apache.org>
AuthorDate: Thu Aug 22 10:42:39 2024 +0800

    RATIS-2144. SegmentedRaftLogWorker should close the stream before releasing 
the buffer. (#1138)
---
 .../apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java
 
b/ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java
index dedba2690..9ed3a1b76 100644
--- 
a/ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java
+++ 
b/ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java
@@ -246,8 +246,8 @@ class SegmentedRaftLogWorker {
     Optional.ofNullable(flushExecutor).ifPresent(ExecutorService::shutdown);
     ConcurrentUtils.shutdownAndWait(TimeDuration.ONE_SECOND.multiply(3),
         workerThreadExecutor, timeout -> LOG.warn("{}: shutdown timeout in " + 
timeout, name));
-    PlatformDependent.freeDirectBuffer(writeBuffer);
     IOUtils.cleanup(LOG, out);
+    PlatformDependent.freeDirectBuffer(writeBuffer);
     LOG.info("{} close()", name);
   }