StreamSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total787 of 2,52768%97 of 22857%941941204851376
boundStackTrace(Throwable, int, int, Set, StringBuilder)840%100%66141411
logError(Throwable)830%60%449911
onError(Throwable)652527%6440%56111701
checkDiskSpace(Map, TimeUUID, Function)6413567%41071%48103101
checkAvailableDiskSpaceAndCompactions(Collection)422133%3350%3441001
receive(IncomingStreamMessage)367667%3350%3431701
progress(String, ProgressInfo.Direction, long, long, long)322240%1150%122601
abort()321227%3125%2381101
completePreview()310%40%336611
checkPendingCompactions(Map, Map, TimeUUID, String, boolean, long)3017085%1787%1533201
sessionFailed()280%n/a115511
start()265969%4233%3462001
toString()200%n/a111111
failIfFinished()19520%1150%121301
abortTasks()190%n/a116611
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection)152562%5337%450401
streamOperation()14733%3125%232401
sessionTimeout()140%n/a113311
complete()131451%1150%121501
prepareAck(PrepareAckMessage)13735%1150%121401
messageReceived(StreamMessage)125882%4866%41142401
boundStackTrace(Throwable, int, StringBuilder)120%n/a112211
createLogTag(StreamSession, Channel)90%20%221111
lambda$closeSession$5(StreamSession.State, Object)75288%3562%351801
getColumnFamilyStores(String, Collection)72779%1375%131601
prepareAsync(Collection, Collection)69393%41071%4821801
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind)62882%2100%023901
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
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean)36795%4660%4611201
startStreamingFiles(StreamSession.PrepareDirection)35494%2675%2511401
prepareSynAck(PrepareSynAckMessage)34593%4660%4611101
getChannel()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
addTransferRanges(String, RangesAtEndpoint, Collection, boolean)51100%2250%2301301
addTransferStreams(Collection)45100%2466%2401201
streamSent(OutgoingStreamMessage)45100%2250%2301001
onInitializationComplete()39100%2100%020801
createLogTag(StreamSession, Object)33100%4100%030801
state(StreamSession.State)31100%1150%120501
flushSSTables(Iterable)25100%2100%020501
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
lambda$checkPendingCompactions$8(Integer)3100%n/a010101