remove synchronized blocks and let native long contentLength as volatile

Author: saxenapranav

hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsInputStream.java

@@ -73,7 +73,7 @@ public class AbfsInputStream extends FSInputStream implements CanUnbuffer,
   private final AbfsClient client;
   private final Statistics statistics;
   private final String path;
-  private long contentLength;
+  private volatile long contentLength;
   private final int bufferSize; // default buffer size
   private final int footerReadSize; // default buffer size to read when reading footer
   private final int readAheadQueueDepth;         // initialized in constructor
@@ -533,14 +533,10 @@ private boolean shouldBreakLazyOptimizedRead(final int actualLen,
   }
 
   @VisibleForTesting
-  synchronized long getContentLength() {
+  long getContentLength() {
     return contentLength;
   }
 
-  private synchronized void setContentLength(long contentLength) {
-    this.contentLength = contentLength;
-  }
-
   private boolean hasFileStatusInfo() {
     return fileStatusInformationPresent;
   }
@@ -754,8 +750,8 @@ int readRemote(long position, byte[] b, int offset, int length, TracingContext t
 
   private void initPropertiesFromReadResponseHeader(final AbfsHttpOperation op) throws IOException {
     validateFileResourceTypeAndParseETag(op);
-    setContentLength(parseFromRange(
-        op.getResponseHeader(HttpHeaderConfigurations.CONTENT_RANGE)));
+    contentLength = parseFromRange(
+        op.getResponseHeader(HttpHeaderConfigurations.CONTENT_RANGE));
   }
 
   private long parseFromRange(final String responseHeader) {
@@ -849,8 +845,8 @@ public synchronized int available() throws IOException {
       AbfsRestOperation op = client.getPathStatus(path, false, tracingContext,
           null);
       validateFileResourceTypeAndParseETag(op.getResult());
-      setContentLength(Long.parseLong(
-          op.getResult().getResponseHeader(HttpHeaderConfigurations.CONTENT_LENGTH)));
+      contentLength = Long.parseLong(
+          op.getResult().getResponseHeader(HttpHeaderConfigurations.CONTENT_LENGTH));
     }
     final long remaining = getContentLength() - this.getPos();
     return remaining <= Integer.MAX_VALUE