doSingleWrite(WriteCtx) |  | 0% |  | 0% | 12 | 12 | 56 | 56 | 1 | 1 |
addWritesToCache(WRITE3Request, Channel, int) |  | 0% |  | 0% | 8 | 8 | 40 | 40 | 1 | 1 |
checkCommitInternal(long, Channel, int, Nfs3FileAttributes, boolean) |  | 0% |  | 0% | 20 | 20 | 45 | 45 | 1 | 1 |
processCommits(long) |  | 0% |  | 0% | 9 | 9 | 44 | 44 | 1 | 1 |
processPerfectOverWrite(DFSClient, long, int, Nfs3Constant.WriteStableHow, byte[], String, WccData, IdMappingServiceProvider) |  | 0% |  | 0% | 3 | 3 | 37 | 37 | 1 | 1 |
cleanup() |  | 0% |  | 0% | 11 | 11 | 43 | 43 | 1 | 1 |
offerNextToWrite() |  | 0% |  | 0% | 6 | 6 | 33 | 33 | 1 | 1 |
receivedNewWrite(DFSClient, WRITE3Request, Channel, int, AsyncDataService, IdMappingServiceProvider) |  | 0% |  | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
alterWriteRequest(WRITE3Request, long) |  | 0% |  | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
OpenFileCtx(HdfsDataOutputStream, Nfs3FileAttributes, String, DFSClient, IdMappingServiceProvider, boolean, NfsConfiguration) |  | 0% |  | 0% | 4 | 4 | 23 | 23 | 1 | 1 |
receivedNewWriteInternal(DFSClient, WRITE3Request, Channel, int, AsyncDataService, IdMappingServiceProvider) |  | 0% |  | 0% | 4 | 4 | 23 | 23 | 1 | 1 |
executeWriteBack() |  | 0% |  | 0% | 5 | 5 | 20 | 20 | 1 | 1 |
processOverWrite(DFSClient, WRITE3Request, Channel, int, IdMappingServiceProvider) |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
checkCommit(DFSClient, long, Channel, int, Nfs3FileAttributes, boolean) |  | 0% |  | 0% | 8 | 8 | 18 | 18 | 1 | 1 |
trimWriteRequest(WriteCtx, long) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
waitForDump() |  | 0% |  | 0% | 6 | 6 | 18 | 18 | 1 | 1 |
checkSequential(long, long) |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
checkAndStartWrite(AsyncDataService, WriteCtx) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
checkRepeatedWriteRequest(WRITE3Request, Channel, int) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
updateNonSequentialWriteInMemory(long) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
streamCleanup(FileHandle, long) |  | 0% |  | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
handleSpecialWait(boolean, long, Channel, int, Nfs3FileAttributes) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
hasPendingWork() |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
OpenFileCtx(HdfsDataOutputStream, Nfs3FileAttributes, String, DFSClient, IdMappingServiceProvider) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
checkStreamTimeout(long) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
setNextOffsetForTest(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
updateLastAccessTime() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getNextOffset() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFlushedOffset() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNextOffsetForTest() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setActiveStatusForTest(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getLastAccessTime() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getActiveState() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLatestAttr() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingWritesForTest() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingCommitsForTest() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |