(hadoop) branch HDFS-17384 updated: HDFS-17472. [FGL] gcDeletedSnapshot and getDelegationToken support FGL (#6743)

[ferhui]

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

ferhui pushed a commit to branch HDFS-17384
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/HDFS-17384 by this push:
     new 5614b6934b88 HDFS-17472. [FGL] gcDeletedSnapshot and 
getDelegationToken support FGL (#6743)
5614b6934b88 is described below

commit 5614b6934b888ef5fcb9da8d991c76d5eec1be54
Author: ZanderXu <zande...@apache.org>
AuthorDate: Thu Apr 18 09:33:32 2024 +0800

    HDFS-17472. [FGL] gcDeletedSnapshot and getDelegationToken support FGL 
(#6743)
---
 .../java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
index 17f2080a4d11..e692945f06b3 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
@@ -6334,7 +6334,7 @@ public class FSNamesystem implements Namesystem, 
FSNamesystemMBean,
     String tokenId = null;
     Token<DelegationTokenIdentifier> token;
     checkOperation(OperationCategory.WRITE);
-    writeLock();
+    writeLock(FSNamesystemLockMode.FS);
     try {
       checkOperation(OperationCategory.WRITE);
       checkNameNodeSafeMode("Cannot issue delegation token");
@@ -6362,7 +6362,7 @@ public class FSNamesystem implements Namesystem, 
FSNamesystemMBean,
       getEditLog().logGetDelegationToken(dtId, expiryTime);
       tokenId = dtId.toStringStable();
     } finally {
-      writeUnlock(operationName, getLockReportInfoSupplier(tokenId));
+      writeUnlock(FSNamesystemLockMode.FS, operationName, 
getLockReportInfoSupplier(tokenId));
     }
     getEditLog().logSync();
     logAuditEvent(true, operationName, tokenId);
@@ -7497,7 +7497,7 @@ public class FSNamesystem implements Namesystem, 
FSNamesystemMBean,
     final INode.BlocksMapUpdateInfo blocksToBeDeleted;
 
     checkOperation(OperationCategory.WRITE);
-    writeLock();
+    writeLock(FSNamesystemLockMode.GLOBAL);
     try {
       checkOperation(OperationCategory.WRITE);
       rootPath = Snapshot.getSnapshotPath(snapshotRoot, snapshotName);
@@ -7509,7 +7509,7 @@ public class FSNamesystem implements Namesystem, 
FSNamesystemMBean,
       blocksToBeDeleted = FSDirSnapshotOp.deleteSnapshot(
           dir, snapshotManager, iip, snapshotName, now, snapshotRoot, false);
     } finally {
-      writeUnlock(operationName, getLockReportInfoSupplier(rootPath));
+      writeUnlock(FSNamesystemLockMode.GLOBAL, operationName, 
getLockReportInfoSupplier(rootPath));
     }
     blockManager.addBLocksToMarkedDeleteQueue(
         blocksToBeDeleted.getToDeleteList());


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org