| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/ |
| H A D | NamenodeRegistration.java | 25 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
37 final NamenodeRole role; // node role
42 NamenodeRole role) { in NamenodeRegistration()
79 public NamenodeRole getRole() { in getRole()
83 public boolean isRole(NamenodeRole that) { in isRole()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/ |
| H A D | HdfsServerConstants.java | 134 public NamenodeRole toNodeRole() { in toNodeRole()
137 return NamenodeRole.BACKUP; in toNodeRole()
139 return NamenodeRole.CHECKPOINT; in toNodeRole()
141 return NamenodeRole.NAMENODE; in toNodeRole()
224 static public enum NamenodeRole { enum in HdfsServerConstants
230 private NamenodeRole(String arg) {this.description = arg;} in NamenodeRole() method in HdfsServerConstants.NamenodeRole
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestSaveNamespace.java | 54 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
124 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in saveNamespaceWithInjectedFault()
233 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testReinsertnamedirsInSavenamespace()
367 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in doTestFailedSaveNamespace()
431 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testSaveWhileEditsRolled()
467 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testTxIdPersistence()
533 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testCancelSaveNamespace()
|
| H A D | TestFSNamesystem.java | 35 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
75 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testFSNamespaceClearLeases()
130 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testReplQueuesActiveAfterStartupSafemode()
|
| H A D | TestFsLimits.java | 40 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
68 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in setUp()
|
| H A D | TestEditLogRace.java | 45 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
354 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testSaveImageWhileSyncInProgress()
454 NameNode.initMetrics(conf, NamenodeRole.NAMENODE); in testSaveRightBeforeSync()
|
| H A D | TestBackupNode.java | 44 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
371 canRead, backup.isRole(NamenodeRole.BACKUP)); in testCheckpoint()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | BackupNode.java | 39 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
88 BackupNode(Configuration conf, NamenodeRole role) throws IOException { in BackupNode()
294 if(isRole(NamenodeRole.CHECKPOINT)) { in shouldCheckpointAtStartup()
383 else if(!nnReg.isRole(NamenodeRole.NAMENODE)) { in registerWith()
438 !(OperationCategory.READ == op && !isRole(NamenodeRole.CHECKPOINT))) { in checkOperation()
|
| H A D | NameNode.java | 309 protected final NamenodeRole role;
358 static void initMetrics(Configuration conf, NamenodeRole role) { in initMetrics()
495 public NamenodeRole getRole() { in getRole()
499 boolean isRole(NamenodeRole that) { in isRole()
637 if (NamenodeRole.NAMENODE == role) { in initialize()
655 if (NamenodeRole.NAMENODE == role) { in initialize()
680 if (NamenodeRole.NAMENODE != role) { in startCommonServices()
795 this(conf, NamenodeRole.NAMENODE); in NameNode()
798 protected NameNode(Configuration conf, NamenodeRole role) in NameNode()
1467 NamenodeRole role = startOpt.toNodeRole(); in createNameNode()
[all …]
|
| H A D | Checkpointer.java | 35 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
272 if (backupNode.getRole() == NamenodeRole.BACKUP) { in doCheckpoint()
|
| H A D | FSImage.java | 50 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
1328 else if(bnReg.isRole(NamenodeRole.NAMENODE)) in startCheckpoint()
|
| H A D | FSEditLog.java | 49 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
1372 if(bnReg.isRole(NamenodeRole.CHECKPOINT)) in registerBackupNode()
|
| H A D | NameNodeRpcServer.java | 119 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
524 if(!nn.isRole(NamenodeRole.NAMENODE)) in startCheckpoint()
|
| H A D | FSNamesystem.java | 219 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
6459 if (bnReg.getRole() == NamenodeRole.BACKUP) { in registerBackupNode()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/protocolPB/ |
| H A D | TestPBHelper.java | 66 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
106 PBHelper.convert(NamenodeRole.BACKUP)); in testConvertNamenodeRole()
108 PBHelper.convert(NamenodeRole.CHECKPOINT)); in testConvertNamenodeRole()
110 PBHelper.convert(NamenodeRole.NAMENODE)); in testConvertNamenodeRole()
111 assertEquals(NamenodeRole.BACKUP, in testConvertNamenodeRole()
113 assertEquals(NamenodeRole.CHECKPOINT, in testConvertNamenodeRole()
115 assertEquals(NamenodeRole.NAMENODE, in testConvertNamenodeRole()
138 "http:1000", info, NamenodeRole.NAMENODE); in testConvertNamenodeRegistration()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/metrics/ |
| H A D | NameNodeMetrics.java | 25 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
153 public static NameNodeMetrics create(Configuration conf, NamenodeRole r) { in create()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/ |
| H A D | PBHelper.java | 188 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NamenodeRole;
273 public static NamenodeRole convert(NamenodeRoleProto role) { in convert()
276 return NamenodeRole.NAMENODE; in convert()
278 return NamenodeRole.BACKUP; in convert()
280 return NamenodeRole.CHECKPOINT; in convert()
285 public static NamenodeRoleProto convert(NamenodeRole role) { in convert()
|