Repository: hadoop
Updated Branches:
  refs/heads/branch-3.0.1 cb283982e -> cea25ac63


HADOOP-15212. Add independent secret manager method for logging expired tokens. 
Contributed by Daryn Sharp.

(cherry picked from commit 2dd960de983a30bf0d9ee957bdb09f825f9d40a3)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/cea25ac6
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/cea25ac6
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/cea25ac6

Branch: refs/heads/branch-3.0.1
Commit: cea25ac63a920ad6c3b6bd7003733d42b92e6f88
Parents: cb28398
Author: Kihwal Lee <kih...@apache.org>
Authored: Tue Feb 6 15:35:56 2018 -0600
Committer: Kihwal Lee <kih...@apache.org>
Committed: Tue Feb 6 15:35:56 2018 -0600

----------------------------------------------------------------------
 .../token/delegation/AbstractDelegationTokenSecretManager.java | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/cea25ac6/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager.java
----------------------------------------------------------------------
diff --git 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager.java
 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager.java
index f06681b..7593b4e 100644
--- 
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager.java
+++ 
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager.java
@@ -22,6 +22,7 @@ import java.io.ByteArrayInputStream;
 import java.io.DataInputStream;
 import java.io.IOException;
 import java.security.MessageDigest;
+import java.util.Collection;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Iterator;
@@ -627,6 +628,11 @@ extends AbstractDelegationTokenIdentifier>
       }
     }
     // don't hold lock on 'this' to avoid edit log updates blocking token ops
+    logExpireTokens(expiredTokens);
+  }
+
+  protected void logExpireTokens(
+      Collection<TokenIdent> expiredTokens) throws IOException {
     for (TokenIdent ident : expiredTokens) {
       logExpireToken(ident);
       LOG.info("Removing expired token " + formatTokenId(ident));


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

Reply via email to