feat(wal):reduce concurrent conflicts between block write operations …

…and poll operations (#1550)
AutoMQ · Jul 12, 2024 · 3cc61aa · 3cc61aa
1 parent 0847d72
commit 3cc61aa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java b/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/SlidingWindowService.java
@@ -61,11 +61,11 @@ public class SlidingWindowService {
     private final WALHeaderFlusher walHeaderFlusher;
 
     /**
-     * The lock of {@link #pendingBlocks}, {@link #writingBlocks}, {@link #currentBlock}.
+     * The lock of {@link #pendingBlocks}, {@link #currentBlock}.
      */
     private final Lock blockLock = new ReentrantLock();
     /**
-     * The lock of {@link #pendingBlocks}.
+     * The lock of {@link #pendingBlocks}, {@link #writingBlocks}.
      */
     private final Lock pollBlockLock = new ReentrantLock();
     /**