acceptRecovery(RequestInfo, QJournalProtocolProtos.SegmentStateProto, URL) |  | 0% |  | 0% | 12 | 12 | 44 | 44 | 1 | 1 |
journal(RequestInfo, long, long, int, byte[]) |  | 0% |  | 0% | 11 | 11 | 38 | 38 | 1 | 1 |
finalizeLogSegment(RequestInfo, long, long) |  | 0% |  | 0% | 9 | 9 | 25 | 25 | 1 | 1 |
doUpgrade(StorageInfo) |  | 0% | | n/a | 1 | 1 | 22 | 22 | 1 | 1 |
getJournaledEdits(long, int) |  | 0% |  | 0% | 6 | 6 | 29 | 29 | 1 | 1 |
startLogSegment(RequestInfo, long, int) |  | 0% |  | 0% | 8 | 8 | 25 | 25 | 1 | 1 |
prepareRecovery(RequestInfo, long) |  | 0% |  | 0% | 9 | 9 | 25 | 25 | 1 | 1 |
checkRequest(RequestInfo) |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
Journal(Configuration, File, String, HdfsServerConstants.StartupOption, StorageErrorReporter) |  | 0% |  | 0% | 2 | 2 | 20 | 20 | 1 | 1 |
scanStorageForLatestEdits() |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
moveTmpSegmentToCurrent(File, File, long) |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
getPersistedPaxosData(long) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
getSegmentInfo(long) |  | 0% |  | 0% | 4 | 4 | 17 | 17 | 1 | 1 |
getEditLogManifest(long, boolean) |  | 0% |  | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
persistPaxosData(long, QJournalProtocolProtos.PersistedRecoveryPaxosData) |  | 0% |  | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
refreshCachedData() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
newEpoch(NamespaceInfo, long) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
completeHalfDoneAcceptRecovery(QJournalProtocolProtos.PersistedRecoveryPaxosData) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
format(NamespaceInfo, boolean) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
syncLog(RequestInfo, QJournalProtocolProtos.SegmentStateProto, URL) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
doFinalize() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
checkWriteRequest(RequestInfo) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
txnRange(QJournalProtocolProtos.SegmentStateProto) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
purgePaxosDecision(long) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
updateLastPromisedEpoch(long) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getCurrentLagTxns() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
abortCurSegment() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
doRollback() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createCache() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
checkFormatted() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
doPreUpgrade() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
discardSegments(long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
close() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
checkSync(boolean, String, Object[]) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
alwaysAssert(boolean, String, Object[]) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
purgeLogsOlderThan(RequestInfo, long) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
canRollBack(StorageInfo, StorageInfo, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
updateHighestWrittenTxId(long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getLastPromisedEpoch() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getLastWriterEpoch() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getJournalCTime() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setTriedJournalSyncerStartedwithnsId(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getCommittedTxnId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
heartbeat(RequestInfo) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isFormatted() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTriedJournalSyncerStartedwithnsId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStorage() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJournalId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLastJournalTimestamp() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHighestWrittenTxId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMetrics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJournaledEditsCache() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |