DFSClient

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total5,339 of 5,3390%264 of 2640%3643641,1101,110232232
DFSClient(URI, ClientProtocol, Configuration, FileSystem.Statistics)2660%220%1212646411
getLocalInterfaceAddrs(String[])900%100%66111111
setQuota(String, long, long)810%120%779911
primitiveMkdir(String, FsPermission, boolean)770%20%228811
setQuotaByStorageType(String, StorageType, long)770%100%66141411
callAppend(String, EnumSet, Progressable, String[])760%20%22111111
renewLease()670%60%44131311
closeAllFilesBeingWritten(boolean)660%80%55151511
createWrappedOutputStream(DFSOutputStream, FileSystem.Statistics, long)640%20%22151511
createSymlink(String, String, boolean)620%n/a118811
rename(String, String, Options.Rename[])620%n/a117711
inferChecksumTypeByReading(LocatedBlock, DatanodeInfo)610%n/a11121211
getFileChecksumInternal(String, long, Options.ChecksumCombineMode)580%60%44131311
getNamespaces()530%80%55121211
rename(String, String)500%n/a115511
setReplication(String, short)490%n/a115511
getQuotaUsage(String)480%20%229911
modifyAclEntries(String, List)480%n/a117711
removeAclEntries(String, List)480%n/a117711
setAcl(String, List)480%n/a117711
removeDefaultAcl(String)470%n/a117711
removeAcl(String)470%n/a117711
setXAttr(String, String, byte[], EnumSet)470%n/a117711
newConnectedPeer(InetSocketAddress, Token, DatanodeID)470%20%22121211
delete(String, boolean)450%n/a115511
removeXAttr(String, String)450%n/a117711
getBlockLocations(String, long, long)440%20%228811
setStoragePolicy(String, String)440%n/a117711
getSnapshotRoot(Path)440%80%55101011
removeNodeFromDeadNodeDetector(DFSInputStream, LocatedBlocks)440%80%558811
unsetStoragePolicy(String)430%n/a117711
truncate(String, long)410%20%227711
setOwner(String, String, String)410%n/a117711
setPermission(String, FsPermission)400%n/a117711
getDeadNodes(DFSInputStream)400%60%44111111
getDelegationToken(Text)390%60%449911
unsetErasureCodingPolicy(String)390%n/a118811
getXAttr(String, String)390%n/a117711
primitiveCreate(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, Options.ChecksumOpt)380%20%228811
create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, Options.ChecksumOpt, InetSocketAddress[], String, String)370%n/a118811
setTimes(String, long, long)370%n/a117711
listXAttrs(String)370%n/a117711
getStoragePolicy(String)360%n/a115511
getAclStatus(String)360%n/a115511
setErasureCodingPolicy(String, String)360%n/a118811
getServerDefaults()350%80%557711
getXAttrs(String, List)350%n/a116611
satisfyStoragePolicy(String)350%n/a118811
recoverLease(String)340%n/a115511
callAppend(String, EnumSetWritable)340%40%33121211
listPaths(String, byte[], boolean)340%n/a115511
getSnapshotDiffReport(String, String, String)340%40%338811
getXAttrs(String)340%n/a115511
primitiveAppend(String, EnumSet, Progressable)330%60%448811
getLocatedFileInfo(String, boolean)330%n/a115511
initThreadsNumForStripedReads(int)330%80%55101011
cancelDelegationToken(Token)320%n/a118811
concat(String, String[])320%n/a117711
getFileInfo(String)320%n/a115511
isFileClosed(String)320%n/a115511
getContentSummary(String)320%n/a115511
createEncryptionZone(String, String)320%n/a117711
reencryptEncryptionZone(String, HdfsConstants.ReencryptAction)320%n/a117711
checkAccess(String, FsAction)320%n/a117711
getErasureCodingPolicy(String)320%n/a116611
beginFileLease(String, DFSOutputStream)310%20%22101011
renewDelegationToken(Token)310%n/a116611
newDataEncryptionKey()310%60%448811
initThreadsNumForHedgedReads(int)310%40%335511
openInternal(LocatedBlocks, String, boolean)300%40%336611
getFavoredNodesStr(InetSocketAddress[])300%40%337711
open(HdfsPathHandle, int, boolean)290%n/a117711
isDeadNode(DFSInputStream, DatanodeInfo)290%80%558811
createWrappedInputStream(DFSInputStream)280%20%227711
getLinkTarget(String)280%n/a115511
getFileLinkInfo(String)280%n/a115511
getDiskStatus()280%n/a116611
getEZForPath(String)280%n/a115511
addErasureCodingPolicies(ErasureCodingPolicy[])280%n/a115511
getEnclosingRoot(String)280%n/a115511
batchedListPaths(String[], byte[], boolean)270%n/a114411
getBlockLocations(String, long)270%40%336611
removeErasureCodingPolicy(String)270%n/a117711
enableErasureCodingPolicy(String)270%n/a117711
disableErasureCodingPolicy(String)270%n/a117711
saveNamespace(long, long)250%n/a115511
getRandomLocalInterfaceAddr()240%20%226611
callGetBlockLocations(ClientProtocol, String, long, long)240%n/a113311
getStateByIndex(int)230%20%224411
rollEdits()230%n/a115511
putFileBeingWritten(String, DFSOutputStream)220%20%226611
getSnapshotDiffReportListing(String, String, String, byte[], int)220%n/a116611
removeFileBeingWritten(String)210%20%226611
getBlockSize(String)210%n/a116611
getECTopologyResultForPolicies(String[])210%n/a114411
updateFileSystemReadStats(int, int, long)210%40%336611
endFileLease(String)200%20%226611
open(String, int, boolean)200%n/a114411
updateLastLeaseRenewal()190%20%226611
createSnapshot(String, String)190%n/a115511
renameSnapshot(String, String, String)190%n/a117711
addCacheDirective(CacheDirectiveInfo, EnumSet)190%n/a115511
newSrcDstTraceScope(String, String, String)190%40%336611
create(String, boolean, short, long, Progressable, int)180%20%223311
deleteSnapshot(String, String)180%n/a117711
getSnapshotListing(String)180%n/a115511
modifyCacheDirective(CacheDirectiveInfo, EnumSet)180%n/a117711
close()170%40%337711
append(String, int, EnumSet, Progressable, FileSystem.Statistics, InetSocketAddress[])170%n/a113311
getSnapshottableDirListing()170%n/a115511
allowSnapshot(String)170%n/a117711
disallowSnapshot(String)170%n/a117711
removeCacheDirective(long)170%n/a117711
addCachePool(CachePoolInfo)170%n/a117711
modifyCachePool(CachePoolInfo)170%n/a117711
removeCachePool(String)170%n/a117711
static {...}170%20%224411
append(String, int, EnumSet, String[], Progressable)160%n/a114411
isEZRoot(Path)160%20%224411
create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, Options.ChecksumOpt, InetSocketAddress[], String)150%n/a111111
append(String, int, EnumSet, Progressable, FileSystem.Statistics)150%n/a112211
connectToDN(DatanodeInfo, int, Token)150%n/a112211
listCorruptFileBlocks(String, String)150%n/a114411
addNodeToDeadNodeDetector(DFSInputStream, DatanodeInfo)150%20%225511
removeNodeFromDeadNodeDetector(DFSInputStream, DatanodeInfo)150%20%226611
getDatanodeWriteTimeout(int)140%20%222211
getDatanodeReadTimeout(int)140%20%222211
getLocatedBlocks(String, long, long)140%n/a112211
create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, Options.ChecksumOpt, InetSocketAddress[])140%n/a111111
clearDataEncryptionKey()140%n/a115511
datanodeReport(HdfsConstants.DatanodeReportType)140%n/a113311
getDatanodeStorageReport(HdfsConstants.DatanodeReportType)140%n/a113311
restoreFailedStorage(String)140%n/a113311
rollingUpgrade(HdfsConstants.RollingUpgradeAction)140%n/a113311
getLeaseRenewer()130%20%222211
create(String, FsPermission, EnumSet, short, long, Progressable, int, Options.ChecksumOpt)130%n/a111111
create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, Options.ChecksumOpt)130%n/a111111
getStoragePolicies()130%n/a113311
setSafeMode(HdfsConstants.SafeModeAction, boolean)130%n/a112211
upgradeStatus()130%n/a113311
getErasureCodingPolicies()130%n/a113311
getErasureCodingCodecs()130%n/a113311
newPathTraceScope(String, String)130%20%224411
slowDatanodeReport()130%n/a113311
create(String, boolean)120%n/a112211
create(String, boolean, Progressable)120%n/a112211
shouldEncryptData()120%40%332211
metaSave(String)120%n/a114411
setBalancerBandwidth(long)120%n/a114411
listOpenFiles(EnumSet, String)120%n/a112211
isFilesBeingWrittenEmpty()110%n/a112211
getNumOfFilesBeingWritten()110%n/a112211
getDelegationToken(String)110%20%221111
create(String, boolean, short, long, Progressable)110%n/a112211
listCacheDirectives(CacheDirectiveInfo)110%n/a112211
refreshNodes()110%n/a114411
finalizeUpgrade()110%n/a114411
reportChecksumFailure(String, LocatedBlock[])110%n/a115511
getInotifyEventStream(long)110%n/a112211
getKeyProviderUri()110%n/a112211
applyUMask(FsPermission)100%20%223311
applyUMaskDir(FsPermission)100%20%223311
exists(String)100%20%222211
getFileChecksumWithCombineMode(String, long)100%n/a112211
getStateAtIndex(long[], int)100%20%221111
listCachePools()100%n/a112211
mkdirs(String, FsPermission, boolean)100%n/a112211
listEncryptionZones()100%n/a112211
listReencryptionStatus()100%n/a112211
getInotifyEventStream()100%n/a112211
checkOpen()90%20%223311
getCanonicalServiceName()90%20%221111
toString()90%n/a111111
updateFileSystemECReadStats(int)90%20%223311
isHedgedReadsEnabled()90%40%332211
getKeyProvider()90%n/a111111
addLocatedBlocksRefresh(DFSInputStream)90%20%223311
removeLocatedBlocksRefresh(DFSInputStream)90%20%223311
getLocatedBlocks(String, long)80%n/a111111
open(String)80%n/a111111
create(String, boolean, short, long)80%n/a111111
setKeyProvider(KeyProvider)80%n/a112211
listOpenFiles()80%n/a112211
listOpenFiles(String)80%n/a112211
DFSClient(URI, Configuration, FileSystem.Statistics)70%n/a112211
closeOutputStreams(boolean)70%20%223311
reportBadBlocks(LocatedBlock[])70%n/a113311
delete(String)70%n/a112211
getFileChecksum(String, long)70%n/a111111
setSafeMode(HdfsConstants.SafeModeAction)70%n/a112211
getPreviousBlock(String)70%n/a111111
isHDFSEncryptionEnabled()70%20%221111
listOpenFiles(EnumSet)70%n/a112211
DFSClient(Configuration)60%n/a112211
DFSClient(InetSocketAddress, Configuration)60%n/a112211
DFSClient(URI, Configuration)60%n/a112211
createWrappedOutputStream(DFSOutputStream, FileSystem.Statistics)60%n/a111111
open(String, int, boolean, FileSystem.Statistics)60%n/a111111
listPaths(String, byte[])60%n/a111111
mkdirs(String)60%n/a111111
primitiveMkdir(String, FsPermission)60%n/a111111
closeConnectionToNamenode()40%n/a112211
getRefreshReadBlkLocationsInterval()40%n/a111111
getMissingBlocksCount()40%n/a111111
getMissingReplOneBlocksCount()40%n/a111111
getPendingDeletionBlocksCount()40%n/a111111
getLowRedundancyBlocksCount()40%n/a111111
getCorruptBlocksCount()40%n/a111111
getBytesInFutureBlocks()40%n/a111111
isSnapshotTrashRootEnabled()40%n/a111111
msync()40%n/a112211
getHAServiceState()40%n/a111111
isDeadNodeDetectionEnabled()40%n/a111111
getDeadNodeDetector()40%n/a111111
getLocatedBlockRefresher()40%n/a111111
isLocatedBlocksRefresherEnabled()40%n/a111111
setDisabledStopDeadNodeDetectorThreadForTest(boolean)30%n/a112211
getConf()30%n/a111111
getConfiguration()30%n/a111111
getClientName()30%n/a111111
isClientRunning()30%n/a111111
getLastLeaseRenewal()30%n/a111111
getNamenode()30%n/a111111
getEncryptionKey()30%n/a111111
getDefaultReadCachingStrategy()30%n/a111111
getDefaultWriteCachingStrategy()30%n/a111111
getClientContext()30%n/a111111
getSaslDataTransferClient()30%n/a111111
getTracer()30%n/a111111
getHedgedReadsThreadPool()0%n/a111111
getStripedReadsThreadPool()0%n/a111111
getHedgedReadMetrics()0%n/a111111