HDDS-9844. [hsync] De-synchronize write APIs (#6859)

apache · Jul 15, 2024 · d8ea69d · d8ea69d
1 parent aa3c24e
commit d8ea69d
Show file tree

Hide file tree

Showing 13 changed files with 588 additions and 334 deletions.
diff --git a/...p-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/AbstractCommitWatcher.java b/...p-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/AbstractCommitWatcher.java
@@ -79,7 +79,7 @@ synchronized void updateCommitInfoMap(long index, List<BUFFER> buffers) {
   }
 
   /** @return the total data which has been acknowledged. */
-  long getTotalAckDataLength() {
+  synchronized long getTotalAckDataLength() {
     return totalAckDataLength;
   }
 
@@ -166,7 +166,7 @@ List<BUFFER> remove(long i) {
   /** Release the buffers for the given index. */
   abstract void releaseBuffers(long index);
 
-  void adjustBuffers(long commitIndex) {
+  synchronized void adjustBuffers(long commitIndex) {
     commitIndexMap.keySet().stream()
         .filter(p -> p <= commitIndex)
         .forEach(this::releaseBuffers);