Home
last modified time | relevance | path

Searched refs:endTxId (Results 1 – 16 of 16) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/
H A DRemoteEditLog.java27 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 DNNStorage.java734 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 DImageServlet.java125 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 DEditLogFileInputStream.java120 long endTxId, boolean inProgress) { in fromUrl() argument
122 startTxId, endTxId, inProgress); in fromUrl()
H A DFSEditLogLoader.java1175 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 DFileJournalManager.java272 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 DBookKeeperJournalManager.java636 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 DJNStorage.java92 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 DJournal.java557 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 DJournalNodeRpcServer.java167 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 DAsyncLogger.java81 long startTxId, long endTxId); in finalizeLogSegment() argument
H A DIPCLoggerChannel.java527 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 DQJournalProtocol.java117 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 DQJournalProtocol.proto52 required uint64 endTxId = 2;
109 required uint64 endTxId = 3;
H A Dhdfs.proto515 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 DQJournalProtocolTranslatorPB.java212 long endTxId) throws IOException { in finalizeLogSegment() argument
217 .setEndTxId(endTxId) in finalizeLogSegment()