/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 | RemoteEditLog.java | 27 private long endTxId = HdfsConstants.INVALID_TXID; field in RemoteEditLog 33 public RemoteEditLog(long startTxId, long endTxId) { in RemoteEditLog() argument 35 this.endTxId = endTxId; in RemoteEditLog() 36 this.isInProgress = (endTxId == HdfsConstants.INVALID_TXID); in RemoteEditLog() 39 public RemoteEditLog(long startTxId, long endTxId, boolean inProgress) { in RemoteEditLog() argument 41 this.endTxId = endTxId; in RemoteEditLog() 50 return endTxId; in getEndTxId() 60 return "[" + startTxId + "," + endTxId + "]"; in toString() 70 .compare(endTxId, log.endTxId) in compareTo() 82 return (int) (startTxId * endTxId); in hashCode()
|
/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 | NNStorage.java | 734 long startTxId, long endTxId) { in getFinalizedEditsFile() argument 736 getFinalizedEditsFileName(startTxId, endTxId)); in getFinalizedEditsFile() 740 long startTxId, long endTxId, long timestamp) { in getTemporaryEditsFile() argument 742 getTemporaryEditsFileName(startTxId, endTxId, timestamp)); in getTemporaryEditsFile() 750 public static String getFinalizedEditsFileName(long startTxId, long endTxId) { in getFinalizedEditsFileName() argument 752 startTxId, endTxId); in getFinalizedEditsFileName() 755 public static String getTemporaryEditsFileName(long startTxId, long endTxId, in getTemporaryEditsFileName() argument 758 startTxId, endTxId, timestamp); in getTemporaryEditsFileName() 764 File findFinalizedEditsFile(long startTxId, long endTxId) in findFinalizedEditsFile() argument 767 getFinalizedEditsFileName(startTxId, endTxId)); in findFinalizedEditsFile() [all …]
|
H A D | ImageServlet.java | 125 long endTxId = parsedParams.getEndTxId(); in doGet() 128 .findFinalizedEditsFile(startTxId, endTxId); in doGet() 318 private long startTxId, endTxId, txId; field in ImageServlet.GetImageParams 354 endTxId = ServletUtil.parseLongParam(request, END_TXID_PARAM); in GetImageParams() 387 return endTxId; in getEndTxId()
|
H A D | EditLogFileInputStream.java | 120 long endTxId, boolean inProgress) { in fromUrl() argument 122 startTxId, endTxId, inProgress); in fromUrl()
|
H A D | FSEditLogLoader.java | 1175 private final long endTxId; field in FSEditLogLoader.EditLogValidation 1178 EditLogValidation(long validLength, long endTxId, in EditLogValidation() argument 1181 this.endTxId = endTxId; in EditLogValidation() 1187 long getEndTxId() { return endTxId; } in getEndTxId()
|
H A D | FileJournalManager.java | 272 long endTxId = Long.parseLong(editsMatch.group(2)); 273 ret.add(new EditLogFile(f, startTxId, endTxId));
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/contrib/bkjournal/src/main/java/org/apache/hadoop/contrib/bkjournal/ |
H A D | BookKeeperJournalManager.java | 636 long endTxId = recoverLastTxId(l, true); in recoverUnfinalizedSegments() local 637 if (endTxId == HdfsConstants.INVALID_TXID) { in recoverUnfinalizedSegments() 644 finalizeLogSegment(l.getFirstTxId(), endTxId); in recoverUnfinalizedSegments() local 791 long endTxId = HdfsConstants.INVALID_TXID; in recoverLastTxId() local 794 if (endTxId == HdfsConstants.INVALID_TXID in recoverLastTxId() 795 || op.getTransactionId() == endTxId+1) { in recoverLastTxId() 796 endTxId = op.getTransactionId(); in recoverLastTxId() 800 return endTxId; in recoverLastTxId() 857 String finalizedLedgerZNode(long startTxId, long endTxId) { in finalizedLedgerZNode() argument 859 ledgerPath, startTxId, endTxId); in finalizedLedgerZNode()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/ |
H A D | JNStorage.java | 92 File findFinalizedEditsFile(long startTxId, long endTxId) throws IOException { in findFinalizedEditsFile() argument 94 NNStorage.getFinalizedEditsFileName(startTxId, endTxId)); in findFinalizedEditsFile() 97 "No edits file for range " + startTxId + "-" + endTxId); in findFinalizedEditsFile()
|
H A D | Journal.java | 557 long endTxId) throws IOException { in finalizeLogSegment() argument 571 checkSync(nextTxId == endTxId + 1, in finalizeLogSegment() 574 startTxId, endTxId, nextTxId - 1); in finalizeLogSegment() 592 checkSync(elf.getLastTxId() == endTxId, in finalizeLogSegment() 595 startTxId, endTxId, elf.getFile(), elf.getLastTxId()); in finalizeLogSegment() local 597 fjm.finalizeLogSegment(startTxId, endTxId); in finalizeLogSegment() 599 Preconditions.checkArgument(endTxId == elf.getLastTxId(), in finalizeLogSegment() 601 elf + " with different endTxId " + endTxId); in finalizeLogSegment()
|
H A D | JournalNodeRpcServer.java | 167 long endTxId) throws IOException { in finalizeLogSegment() argument 169 .finalizeLogSegment(reqInfo, startTxId, endTxId); in finalizeLogSegment()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/ |
H A D | AsyncLogger.java | 81 long startTxId, long endTxId); in finalizeLogSegment() argument
|
H A D | IPCLoggerChannel.java | 527 final long startTxId, final long endTxId) { 533 getProxy().finalizeLogSegment(createReqInfo(), startTxId, endTxId);
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/protocol/ |
H A D | QJournalProtocol.java | 117 long startTxId, long endTxId) throws IOException; in finalizeLogSegment() argument
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/proto/ |
H A D | QJournalProtocol.proto | 52 required uint64 endTxId = 2; 109 required uint64 endTxId = 3;
|
H A D | hdfs.proto | 515 required uint64 endTxId = 2; // Ending available edit log transaction
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/protocolPB/ |
H A D | QJournalProtocolTranslatorPB.java | 212 long endTxId) throws IOException { in finalizeLogSegment() argument 217 .setEndTxId(endTxId) in finalizeLogSegment()
|