import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
public synchronized void loadSecretManagerState(SecretManagerState state)
    throws IOException {
  Preconditions.checkState(!running,
      "Can't load state from image in a running SecretManager.");

  currentId = state.section.getCurrentId();
  delegationTokenSequenceNumber = state.section.getTokenSequenceNumber();
  for (SecretManagerSection.DelegationKey k : state.keys) {
    addKey(new DelegationKey(k.getId(), k.getExpiryDate(), k.hasKey() ? k
        .getKey().toByteArray() : null));
  }

  for (SecretManagerSection.PersistToken t : state.tokens) {
    DelegationTokenIdentifier id = new DelegationTokenIdentifier(new Text(
        t.getOwner()), new Text(t.getRenewer()), new Text(t.getRealUser()));
    id.setIssueDate(t.getIssueDate());
    id.setMaxDate(t.getMaxDate());
    id.setSequenceNumber(t.getSequenceNumber());
    id.setMasterKeyId(t.getMasterKeyId());
    addPersistedDelegationToken(id, t.getExpiryDate());
  }
}
 

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
private void loadSecretManagerSection(InputStream in) throws IOException {
  SecretManagerSection s = SecretManagerSection.parseDelimitedFrom(in);
  int numKeys = s.getNumKeys(), numTokens = s.getNumTokens();
  ArrayList<SecretManagerSection.DelegationKey> keys = Lists
      .newArrayListWithCapacity(numKeys);
  ArrayList<SecretManagerSection.PersistToken> tokens = Lists
      .newArrayListWithCapacity(numTokens);

  for (int i = 0; i < numKeys; ++i)
    keys.add(SecretManagerSection.DelegationKey.parseDelimitedFrom(in));

  for (int i = 0; i < numTokens; ++i)
    tokens.add(SecretManagerSection.PersistToken.parseDelimitedFrom(in));

  fsn.loadSecretManagerState(s, keys, tokens);
}
 

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
private void loadSecretManagerSection(InputStream in, StartupProgress prog,
    Step currentStep) throws IOException {
  SecretManagerSection s = SecretManagerSection.parseDelimitedFrom(in);
  int numKeys = s.getNumKeys(), numTokens = s.getNumTokens();
  ArrayList<SecretManagerSection.DelegationKey> keys = Lists
      .newArrayListWithCapacity(numKeys);
  ArrayList<SecretManagerSection.PersistToken> tokens = Lists
      .newArrayListWithCapacity(numTokens);

  for (int i = 0; i < numKeys; ++i)
    keys.add(SecretManagerSection.DelegationKey.parseDelimitedFrom(in));

  prog.setTotal(Phase.LOADING_FSIMAGE, currentStep, numTokens);
  Counter counter = prog.getCounter(Phase.LOADING_FSIMAGE, currentStep);
  for (int i = 0; i < numTokens; ++i) {
    tokens.add(SecretManagerSection.PersistToken.parseDelimitedFrom(in));
    counter.increment();
  }

  fsn.loadSecretManagerState(s, keys, tokens);
}
 

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
public SecretManagerState(
    SecretManagerSection s,
    List<SecretManagerSection.DelegationKey> keys,
    List<SecretManagerSection.PersistToken> tokens) {
  this.section = s;
  this.keys = keys;
  this.tokens = tokens;
}
 

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
private void saveSecretManagerSection(FileSummary.Builder summary)
    throws IOException {
  final FSNamesystem fsn = context.getSourceNamesystem();
  DelegationTokenSecretManager.SecretManagerState state = fsn
      .saveSecretManagerState();
  state.section.writeDelimitedTo(sectionOutputStream);
  for (SecretManagerSection.DelegationKey k : state.keys)
    k.writeDelimitedTo(sectionOutputStream);

  for (SecretManagerSection.PersistToken t : state.tokens)
    t.writeDelimitedTo(sectionOutputStream);

  commitSection(summary, SectionName.SECRET_MANAGER);
}
 

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
private void dumpSecretManagerSection(InputStream is) throws IOException {
  out.print("<SecretManagerSection>");
  SecretManagerSection s = SecretManagerSection.parseDelimitedFrom(is);
  o("currentId", s.getCurrentId()).o("tokenSequenceNumber",
      s.getTokenSequenceNumber());
  out.print("</SecretManagerSection>");
}
 

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.SecretManagerSection; //导入依赖的package包/类
void loadSecretManagerState(SecretManagerSection s,
    List<SecretManagerSection.DelegationKey> keys,
    List<SecretManagerSection.PersistToken> tokens) throws IOException {
  dtSecretManager.loadSecretManagerState(new SecretManagerState(s, keys, tokens));
}