Home
last modified time | relevance | path

Searched refs:minTxIdToKeep (Results 1 – 18 of 18) sorted by relevance

/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.java144 void purgeDataOlderThan(long minTxIdToKeep) throws IOException { in purgeDataOlderThan() argument
146 CURRENT_DIR_PURGE_REGEXES, minTxIdToKeep); in purgeDataOlderThan() local
147 purgeMatching(getPaxosDir(), PAXOS_DIR_PURGE_REGEXES, minTxIdToKeep); in purgeDataOlderThan() local
158 long minTxIdToKeep) throws IOException { in purgeMatching() argument
169 if (txid < minTxIdToKeep) { in purgeMatching()
H A DJournalNodeRpcServer.java173 public void purgeLogsOlderThan(RequestInfo reqInfo, long minTxIdToKeep) in purgeLogsOlderThan() argument
176 .purgeLogsOlderThan(reqInfo, minTxIdToKeep); in purgeLogsOlderThan()
H A DJournal.java615 long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument
619 storage.purgeDataOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/
H A DLogsPurgeable.java36 public void purgeLogsOlderThan(long minTxIdToKeep) throws IOException; in purgeLogsOlderThan() argument
H A DFileJournalManager.java162 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument
164 LOG.info("Purging logs older than " + minTxIdToKeep); in purgeLogsOlderThan()
168 if (log.getFirstTxId() < minTxIdToKeep && in purgeLogsOlderThan()
169 log.getLastTxId() < minTxIdToKeep) { in purgeLogsOlderThan()
H A DBackupJournalManager.java77 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument
H A DJournalSet.java610 public void purgeLogsOlderThan(final long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument
614 jas.getManager().purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
616 }, "purgeLogsOlderThan " + minTxIdToKeep); in purgeLogsOlderThan()
H A DFSEditLog.java1306 public synchronized void purgeLogsOlderThan(final long minTxIdToKeep) { in purgeLogsOlderThan() argument
1314 minTxIdToKeep <= curSegmentTxId : in purgeLogsOlderThan() local
1315 "cannot purge logs older than txid " + minTxIdToKeep + in purgeLogsOlderThan()
1317 if (minTxIdToKeep == 0) { in purgeLogsOlderThan()
1324 journalSet.purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
H A DSecondaryNameNode.java870 public void purgeLogsOlderThan(long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument
877 if (f.getLastTxId() < minTxIdToKeep) { in purgeLogsOlderThan()
/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.java87 public ListenableFuture<Void> purgeLogsOlderThan(long minTxIdToKeep); in purgeLogsOlderThan() argument
H A DQuorumJournalManager.java424 public void purgeLogsOlderThan(long minTxIdToKeep) throws IOException { in purgeLogsOlderThan() argument
427 LOG.info("Purging remote journals older than txid " + minTxIdToKeep); in purgeLogsOlderThan()
428 loggers.purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
H A DAsyncLoggerSet.java106 void purgeLogsOlderThan(long minTxIdToKeep) { in purgeLogsOlderThan() argument
108 logger.purgeLogsOlderThan(minTxIdToKeep); in purgeLogsOlderThan()
H A DIPCLoggerChannel.java540 public ListenableFuture<Void> purgeLogsOlderThan(final long minTxIdToKeep) {
544 getProxy().purgeLogsOlderThan(createReqInfo(), minTxIdToKeep);
/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.java123 public void purgeLogsOlderThan(RequestInfo requestInfo, long minTxIdToKeep) in purgeLogsOlderThan() argument
/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.java227 public void purgeLogsOlderThan(RequestInfo reqInfo, long minTxIdToKeep) in purgeLogsOlderThan() argument
231 .setMinTxIdToKeep(minTxIdToKeep) in purgeLogsOlderThan()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/
H A DTestGenericJournalConf.java186 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument
/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.java676 public void purgeLogsOlderThan(long minTxIdToKeep) in purgeLogsOlderThan() argument
681 if (l.getLastTxId() < minTxIdToKeep) { in purgeLogsOlderThan()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/proto/
H A DQJournalProtocol.proto120 required uint64 minTxIdToKeep = 2;