StreamSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,437 of 2,52743%144 of 22836%1211942394852576
checkPendingCompactions(Map, Map, TimeUUID, String, boolean, long)2000%80%55323211
checkDiskSpace(Map, TimeUUID, Function)1990%140%88313111
boundStackTrace(Throwable, int, int, Set, StringBuilder)840%100%66141411
logError(Throwable)830%60%449911
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean)700%100%66121211
onError(Throwable)652527%6440%56111701
checkAvailableDiskSpaceAndCompactions(Collection)630%60%44101011
addTransferRanges(String, RangesAtEndpoint, Collection, boolean)510%40%33131311
prepareAsync(Collection, Collection)455454%7750%6861801
abort()440%40%33111111
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection)400%80%554411
receive(IncomingStreamMessage)367667%3350%3431701
getColumnFamilyStores(String, Collection)340%40%336611
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind)340%20%229911
prepareSynAck(PrepareSynAckMessage)331531%7330%5661101
progress(String, ProgressInfo.Direction, long, long, long)322240%1150%122601
completePreview()310%40%336611
sessionFailed()280%n/a115511
flushSSTables(Iterable)250%20%225511
start()226374%3350%3462001
prepareAck(PrepareAckMessage)200%20%224411
toString()200%n/a111111
failIfFinished()19520%1150%121301
abortTasks()190%n/a116611
messageReceived(StreamMessage)175375%5758%51162401
streamOperation()14733%3125%232401
sessionTimeout()140%n/a113311
complete()131451%1150%121501
boundStackTrace(Throwable, int, StringBuilder)120%n/a112211
streamSent(OutgoingStreamMessage)93680%2250%2321001
createLogTag(StreamSession, Channel)90%20%221111
lambda$closeSession$5(StreamSession.State, Object)75288%3562%351801
getAggregator(TableId)61368%1150%120201
lambda$checkDiskSpace$7(ColumnFamilyStore)60%n/a111111
closeSession(StreamSession.State, String)52583%1150%121601
lambda$prepare$6(Collection, Collection)5654%n/a012501
getNumRequests()40%n/a111111
getNumTransfers()40%n/a111111
startStreamingFiles(StreamSession.PrepareDirection)35494%2675%2511401
getChannel()30%n/a111111
lambda$checkPendingCompactions$8(Integer)30%n/a111111
maybeCompleted()23995%1787%1511101
createLogTag(StreamSession, StreamingChannel)2777%1150%120101
attachOutbound(StreamingChannel)2195%2250%230501
isSuccess()787%1150%120101
StreamSession(StreamOperation, InetAddressAndPort, StreamingChannel.Factory, StreamingChannel, int, boolean, int, TimeUUID, PreviewKind)74100%n/a0101901
getSessionInfo()58100%4100%030701
addTransferStreams(Collection)45100%2466%2401201
onInitializationComplete()39100%2100%020801
createLogTag(StreamSession, Object)33100%1375%130801
state(StreamSession.State)31100%1150%120501
lambda$closeSession$2(StreamSession.State, String)25100%1150%120701
attachInbound(StreamingChannel)22100%4100%030501
prepareReceiving(StreamSummary)22100%1150%120401
lambda$attachInbound$0(StreamingChannel)15100%1375%130301
initiatorCompleteOrWait()13100%2100%020401
prepare(Collection, Collection)10100%n/a010301
taskCompleted(StreamReceiveTask)10100%n/a010301
taskCompleted(StreamTransferTask)10100%n/a010301
planId()9100%2100%020101
static {...}9100%n/a010301
init(StreamResultFuture)8100%n/a010301
received(TableId, int)8100%n/a010201
lambda$attachOutbound$1(StreamingChannel)7100%n/a010101
lambda$closeSession$4(List, StreamingChannel)6100%n/a010101
lambda$closeSession$3(List, StreamingChannel)6100%n/a010101
closeSession(StreamSession.State)5100%n/a010101
countStreamedIn(boolean)5100%n/a010201
isPreview()4100%n/a010101
createLogTag(StreamSession)4100%n/a010101
isFollower()3100%n/a010101
sessionIndex()3100%n/a010101
getStreamOperation()3100%n/a010101
getPendingRepair()3100%n/a010101
getPreviewKind()3100%n/a010101
state()3100%n/a010101